1582869968

Build Type

github

Committed by GitHub

Commit Message

<a href="https://github.com/OPAE/opae-sdk/commit/<a class=hub.com/OPAE/opae-sdk/commit/<a class="double-link" href="https://git"><a class=hub.com/OPAE/opae-sdk/commit/<a class="double-link" href="https://git"><a class=hub.com/OPAE/opae-sdk/commit/<a class="double-link" href="https://git"><a class=hub.com/OPAE/opae-sdk/commit/e0ef1d99ae9f6d45e36a6a6d4e4ed0272fd5bcb5">e0ef1d99a">&lt;a href=&quot;https://github.com/OPAE/opae-sdk/commit/</a><a class="double-link" href="https://github.com/OPAE/opae-sdk/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/OPAE/opae-sdk/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/OPAE/opae-sdk/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/OPAE/opae-sdk/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/OPAE/opae-sdk/commit/e0ef1d99ae9f6d45e36a6a6d4e4ed0272fd5bcb5">e0ef1d99a</a><a href="https://github.com/OPAE/opae-sdk/commit/e0ef1d99ae9f6d45e36a6a6d4e4ed0272fd5bcb5">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/OPAE/opae-sdk/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/OPAE/opae-sdk/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/OPAE/opae-sdk/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/OPAE/opae-sdk/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/OPAE/opae-sdk/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/OPAE/opae-sdk/commit/e0ef1d99ae9f6d45e36a6a6d4e4ed0272fd5bcb5&quot;&gt;e0ef1d99a&lt;/a&gt;&lt;a href=&quot;https://github.com/OPAE/opae-sdk/commit/e0ef1d99ae9f6d45e36a6a6d4e4ed0272fd5bcb5&quot;&gt;&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/OPAE/opae-sdk/commit/&amp;lt;/a&amp;gt;&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://github.com/OPAE/opae-sdk/commit/&amp;amp;lt;a class=&amp;amp;quot;double-link&amp;amp;quot; href=&amp;amp;quot;htt... (continued)

Pull Request Pull Request #2424: hssi: support hssi performance

Run Details

49 of 49 new or added lines in 3 files covered. (100.0%)

11099 of 18145 relevant lines covered (61.17%)

12795.83 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/samples/hssi/hssi_cmd.h

// Copyright(c) 2020-2021, Intel Corporation
//
// Redistribution  and  use  in source  and  binary  forms,  with  or  without
// modification, are permitted provided that the following conditions are met:
//
// * Redistributions of  source code  must retain the  above copyright notice,
//   this list of conditions and the following disclaimer.
// * Redistributions in binary form must reproduce the above copyright notice,
//   this list of conditions and the following disclaimer in the documentation
//   and/or other materials provided with the distribution.
// * Neither the name  of Intel Corporation  nor the names of its contributors
//   may be used to  endorse or promote  products derived  from this  software
//   without specific prior written permission.
//
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
// AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING,  BUT NOT LIMITED TO,  THE
// IMPLIED WARRANTIES OF  MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
// ARE DISCLAIMED.  IN NO EVENT  SHALL THE COPYRIGHT OWNER  OR CONTRIBUTORS BE
// LIABLE  FOR  ANY  DIRECT,  INDIRECT,  INCIDENTAL,  SPECIAL,  EXEMPLARY,  OR
// CONSEQUENTIAL  DAMAGES  (INCLUDING,  BUT  NOT LIMITED  TO,  PROCUREMENT  OF
// SUBSTITUTE GOODS OR SERVICES;  LOSS OF USE,  DATA, OR PROFITS;  OR BUSINESS
// INTERRUPTION)  HOWEVER CAUSED  AND ON ANY THEORY  OF LIABILITY,  WHETHER IN
// CONTRACT,  STRICT LIABILITY,  OR TORT  (INCLUDING NEGLIGENCE  OR OTHERWISE)
// ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE,  EVEN IF ADVISED OF THE
// POSSIBILITY OF SUCH DAMAGE.
#pragma once
#include <string>
#include <sstream>
#include <cstdio>
#include <cstring>
#include <netinet/ether.h>
#include "afu_test.h"

using test_command = opae::afu_test::command;
namespace fpga = opae::fpga::types;

#define INVALID_MAC           0xffffffffffffffffULL

#define INVALID_CLOCK_FREQ    static_cast<double>(0.0)

#define USER_CLKFREQ_S10      156.25  // MHz
#define USER_CLKFREQ_N6000    300.00  // MHz
#define BITSVER_MAJOR_S10     4
#define BITSVER_MAJOR_N6000   5

#define FPGA_BBS_VER_MAJOR(i) (((i) >> 56) & 0xf)

class hssi_cmd : public test_command
{
public:
  hssi_cmd()
  : running_(true)
  {}

  double clock_freq_for(test_afu *afu) const
  {
    auto afu_props = afu->afu_properties();
    auto filter = fpga::properties::get();

    // To get the FME matching our accelerator, we filter
    // for the ssss:bb:dd and for FPGA_DEVICE object type.
    filter->segment = afu_props->segment;
    filter->bus = afu_props->bus;
    filter->device = afu_props->device;
    filter->type = FPGA_DEVICE;

    std::vector<fpga::token::ptr_t> toks =
            fpga::token::enumerate({filter});

    if (toks.empty()) {
      std::cerr << "Couldn't find FME for AFU!" << std::endl;
      return INVALID_CLOCK_FREQ;
    }

    auto fme_props = fpga::properties::get(toks[0]);

    uint32_t major = FPGA_BBS_VER_MAJOR(fme_props->bbs_id);

    if (major == BITSVER_MAJOR_S10)
      return USER_CLKFREQ_S10;
    else if (major == BITSVER_MAJOR_N6000)
      return USER_CLKFREQ_N6000;

    return INVALID_CLOCK_FREQ;
  }

  uint64_t mac_bits_for(std::string addr) const
  {
    uint64_t res = INVALID_MAC;
    struct ether_addr *eth = ether_aton(addr.c_str());
  
    if (eth) {
      res = 0ULL;
      memcpy(&res, eth->ether_addr_octet, sizeof(eth->ether_addr_octet));
    }

    return res;
  }

  void run_process(const std::string &proc)
  {
    FILE *fp = popen(proc.c_str(), "r");
    if (fp) {
      char buf[256];
      while (fgets(buf, sizeof(buf), fp)) {
        std::cout << buf;
      }
      pclose(fp);
    }
  }
  
  void show_eth_stats(const std::string &eth)
  {
    std::string cmd = std::string("ethtool --statistics ") + eth;
    run_process(cmd);
  }
  
  void enable_eth_loopback(const std::string &eth, bool enable)
  {
    std::string cmd = std::string("ethtool --features ") + eth;
    if (enable)
      cmd += std::string(" loopback on");
    else
      cmd += std::string(" loopback off");
    run_process(cmd);
    usleep(1000000);
  }

  template <typename X>
  std::string int_to_hex(X x) const
  {
    std::stringstream ss;
    ss << "0x" <<
      std::setfill('0') <<
      std::setw(2 * sizeof(X)) <<
      std::hex << x;
    return ss.str();
  }

  void stop()
  {
    running_ = false;
  }

protected:
  bool running_;
};

1	// Copyright(c) 2020-2021, Intel Corporation
2	//
3	// Redistribution and use in source and binary forms, with or without
4	// modification, are permitted provided that the following conditions are met:
5	//
6	// * Redistributions of source code must retain the above copyright notice,
7	// this list of conditions and the following disclaimer.
8	// * Redistributions in binary form must reproduce the above copyright notice,
9	// this list of conditions and the following disclaimer in the documentation
10	// and/or other materials provided with the distribution.
11	// * Neither the name of Intel Corporation nor the names of its contributors
12	// may be used to endorse or promote products derived from this software
13	// without specific prior written permission.
14	//
15	// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
16	// AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
17	// IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
18	// ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
19	// LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
20	// CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
21	// SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
22	// INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
23	// CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
24	// ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
25	// POSSIBILITY OF SUCH DAMAGE.
26	#pragma once
27	#include <string>
28	#include <sstream>
29	#include <cstdio>
30	#include <cstring>
31	#include <netinet/ether.h>
32	#include "afu_test.h"
33
34	using test_command = opae::afu_test::command;
35	namespace fpga = opae::fpga::types;
36
37	#define INVALID_MAC 0xffffffffffffffffULL
38
39	#define INVALID_CLOCK_FREQ static_cast<double>(0.0)
40
41	#define USER_CLKFREQ_S10 156.25 // MHz
42	#define USER_CLKFREQ_N6000 300.00 // MHz
43	#define BITSVER_MAJOR_S10 4
44	#define BITSVER_MAJOR_N6000 5
45
46	#define FPGA_BBS_VER_MAJOR(i) (((i) >> 56) & 0xf)
47
48	class hssi_cmd : public test_command
49	{
50	public:
51	hssi_cmd()	×
52	: running_(true)	×
53	{}	×
54
55	double clock_freq_for(test_afu *afu) const	×
56	{
57	auto afu_props = afu->afu_properties();	×
58	auto filter = fpga::properties::get();	×
59
60	// To get the FME matching our accelerator, we filter
61	// for the ssss:bb:dd and for FPGA_DEVICE object type.
62	filter->segment = afu_props->segment;	×
63	filter->bus = afu_props->bus;	×
64	filter->device = afu_props->device;	×
65	filter->type = FPGA_DEVICE;	×
66
67	std::vector<fpga::token::ptr_t> toks =
68	fpga::token::enumerate({filter});	×
69
70	if (toks.empty()) {	×
71	std::cerr << "Couldn't find FME for AFU!" << std::endl;	×
72	return INVALID_CLOCK_FREQ;	×
73	}
74
75	auto fme_props = fpga::properties::get(toks[0]);	×
76
77	uint32_t major = FPGA_BBS_VER_MAJOR(fme_props->bbs_id);	×
78
79	if (major == BITSVER_MAJOR_S10)	×
80	return USER_CLKFREQ_S10;	×
81	else if (major == BITSVER_MAJOR_N6000)	×
82	return USER_CLKFREQ_N6000;	×
83
84	return INVALID_CLOCK_FREQ;	×
85	}
86
87	uint64_t mac_bits_for(std::string addr) const	×
88	{
89	uint64_t res = INVALID_MAC;	×
90	struct ether_addr *eth = ether_aton(addr.c_str());	×
91
92	if (eth) {	×
93	res = 0ULL;	×
94	memcpy(&res, eth->ether_addr_octet, sizeof(eth->ether_addr_octet));	×
95	}
96
97	return res;	×
98	}
99
100	void run_process(const std::string &proc)	×
101	{
102	FILE *fp = popen(proc.c_str(), "r");	×
103	if (fp) {	×
104	char buf[256];
105	while (fgets(buf, sizeof(buf), fp)) {	×
106	std::cout << buf;	×
107	}
108	pclose(fp);	×
109	}
110	}	×
111
112	void show_eth_stats(const std::string &eth)	×
113	{
114	std::string cmd = std::string("ethtool --statistics ") + eth;	×
115	run_process(cmd);	×
116	}	×
117
118	void enable_eth_loopback(const std::string &eth, bool enable)	×
119	{
120	std::string cmd = std::string("ethtool --features ") + eth;	×
121	if (enable)	×
122	cmd += std::string(" loopback on");	×
123	else
124	cmd += std::string(" loopback off");	×
125	run_process(cmd);	×
126	usleep(1000000);	×
127	}	×
128
129	template <typename X>
130	std::string int_to_hex(X x) const	×
131	{
132	std::stringstream ss;	×
133	ss << "0x" <<
134	std::setfill('0') <<	×
135	std::setw(2 * sizeof(X)) <<	×
136	std::hex << x;	×
137	return ss.str();	×
138	}
139
140	void stop()	×
141	{
142	running_ = false;	×
143	}	×
144
145	protected:
146	bool running_;
147	};

OPAE / opae-sdk / 1582869968

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous