Skip to content

Commit 80e0481

Browse files
committed
Fix sync issue
1 parent 94d50d1 commit 80e0481

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

src/core/lib/ibverbs/busy_poller.cc

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
#ifdef GRPC_USE_IBVERBS
22

33
#include "src/core/lib/ibverbs/busy_poller.h"
4+
#include "src/core/util/sync.h"
45

56
#include <poll.h>
67
#include <unistd.h>
@@ -9,7 +10,6 @@
910

1011
#include "absl/log/absl_check.h"
1112
#include "absl/log/log.h"
12-
#include "absl/time/clock.h"
1313

1414
namespace grpc_event_engine::experimental {
1515
void BusyPoller::AddPollable(PairPollable* pollable) {
@@ -56,6 +56,7 @@ void BusyPoller::begin_polling(int poller_id) {
5656

5757
while (running_) {
5858
if (n_pairs_ == 0) {
59+
grpc_core::MutexLock lock(&mu_);
5960
cv_.WaitWithTimeout(&mu_, absl::Milliseconds(poller_sleep_timeout));
6061
continue;
6162
}

src/core/lib/ibverbs/busy_poller.h

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,7 @@
22
#define GRPC_SRC_CORE_LIB_IBVERBS_BUSY_POLLER_H
33
#ifdef GRPC_USE_IBVERBS
44

5-
#include <condition_variable>
6-
#include <mutex>
7-
#include <queue>
5+
#include <array>
86

97
#include "src/core/config/config_vars.h"
108
#include "src/core/lib/ibverbs/pair.h"

0 commit comments

Comments
 (0)