Skip to content

Commit

Permalink
UCT/IB: Add connect counter.
Browse files Browse the repository at this point in the history
  • Loading branch information
binl committed May 11, 2021
1 parent 24b2bb9 commit d8a8f34
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions test/apps/iodemo/io_demo.cc
Original file line number Diff line number Diff line change
Expand Up @@ -761,7 +761,7 @@ class DemoServer : public P2pDemoCommon {
state_t _curr_state;
};


int test_counter = 0;
class DemoClient : public P2pDemoCommon {
public:
typedef struct {
Expand Down Expand Up @@ -1111,6 +1111,7 @@ class DemoClient : public P2pDemoCommon {

UcxConnection *conn = new UcxConnection(*this);
_server_info[server_index].conn = conn;
LOG << "Connect counter " << ++test_counter;
conn->connect((const struct sockaddr*)&connect_addr,
sizeof(connect_addr),
new ConnectCallback(*this, server_index));
Expand All @@ -1127,7 +1128,7 @@ class DemoClient : public P2pDemoCommon {
server_info_t &server_info = _server_info[server_index];
long attempts = server_info.retry_count + 1;

server_info.retry_count = 0;
//server_info.retry_count = 0;
server_info.prev_connect_time = 0.;
_server_index_lookup[server_info.conn] = server_index;
active_servers_add(server_index);
Expand Down

0 comments on commit d8a8f34

Please sign in to comment.