File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 1212#include " absl/time/clock.h"
1313
1414namespace grpc_event_engine ::experimental {
15- void Poller ::AddPollable (PairPollable* pollable) {
15+ void BusyPoller ::AddPollable (PairPollable* pollable) {
1616 ABSL_CHECK_LT (tail_, GRPC_IBVERBS_POLLER_CAPACITY);
1717 bool inserted;
1818 do {
@@ -38,7 +38,7 @@ void Poller::AddPollable(PairPollable* pollable) {
3838 cv_.Signal ();
3939}
4040
41- void Poller ::RemovePollable (PairPollable* pollable) {
41+ void BusyPoller ::RemovePollable (PairPollable* pollable) {
4242 uint32_t tail = tail_;
4343 for (int i = 0 ; i < tail; i++) {
4444 if (pairs_[i] == reinterpret_cast <uint64_t >(pollable)) {
@@ -49,7 +49,7 @@ void Poller::RemovePollable(PairPollable* pollable) {
4949 }
5050}
5151
52- void Poller ::begin_polling (int poller_id) {
52+ void BusyPoller ::begin_polling (int poller_id) {
5353 auto poller_sleep_timeout = grpc_core::ConfigVars::Get ().RdmaPollerSleepTimeoutMs ();
5454 struct pollfd fds[1 ];
5555
You can’t perform that action at this time.
0 commit comments