We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b5dc6fc commit 5fdb0d8Copy full SHA for 5fdb0d8
3 files changed
src/brpc/rdma/rdma_helper.cpp
@@ -505,7 +505,6 @@ static void GlobalRdmaInitializeOrDieImpl() {
505
} else {
506
LOG(INFO) << "RDMA GID Index: " << (int)g_gid_index;
507
}
508
- IbvCreateCompChannel(g_context);
509
510
// Create protection domain
511
g_pd = IbvAllocPd(g_context);
src/brpc/socket.cpp
@@ -2512,8 +2512,12 @@ void Socket::DebugSocket(std::ostream& os, SocketId id) {
2512
<< "\n}";
2513
2514
#endif
2515
+
2516
+ os << "\nrdma={\n";
2517
ptr->_transport->Debug(os);
- { os << "\nbthread_tag=" << ptr->_io_event.bthread_tag(); }
2518
+ os << "}\n";
2519
2520
+ os << "\nbthread_tag=" << ptr->_io_event.bthread_tag();
2521
2522
2523
int Socket::CheckHealth() {
test/bvar_recorder_unittest.cpp
@@ -244,15 +244,15 @@ TEST(RecorderTest, latency_recorder_qps_accuracy) {
244
double err = fabs(qps_sum / 1000.0 - exp_qps);
245
return err;
246
};
247
- ASSERT_GT(0.2, read(lr1, 10/2.0));
248
- ASSERT_GT(0.2, read(lr2, 11/2.0));
249
- ASSERT_GT(0.2, read(lr3, 3/2.0));
250
- ASSERT_GT(0.2, read(lr4, 1/2.0));
+ ASSERT_GT(0.1, read(lr1, 10/2.0));
+ ASSERT_GT(0.1, read(lr2, 11/2.0));
+ ASSERT_GT(0.1, read(lr3, 3/2.0));
+ ASSERT_GT(0.1, read(lr4, 1/2.0));
251
252
- ASSERT_GT(0.2, read(lr1, 10/3.0, 3));
253
- ASSERT_GT(0.2, read(lr2, 11/3.0, 3));
254
- ASSERT_GT(0.2, read(lr3, 3/3.0, 3));
255
- ASSERT_GT(0.2, read(lr4, 1/3.0, 3));
+ ASSERT_GT(0.1, read(lr1, 10/3.0, 3));
+ ASSERT_GT(0.1, read(lr2, 11/3.0, 3));
+ ASSERT_GT(0.1, read(lr3, 3/3.0, 3));
+ ASSERT_GT(0.1, read(lr4, 1/3.0, 3));
256
257
258
} // namespace
0 commit comments