MCPcopy Create free account
hub / github.com/ceph/ceph / add_event

Method add_event

src/msg/async/EventPoll.cc:120–135  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

118}
119
120int PollDriver::add_event(int fd, int cur_mask, int add_mask) {
121 ldout(cct, 10) << __func__ << " add event to fd=" << fd << " mask="
122 << add_mask << dendl;
123 int op, events = 0;
124 op = cur_mask == EVENT_NONE ? POLL_ADD: POLL_MOD;
125
126 add_mask |= cur_mask; /* Merge old events */
127 if (add_mask & EVENT_READABLE) {
128 events |= POLLIN;
129 }
130 if (add_mask & EVENT_WRITABLE) {
131 events |= POLLOUT;
132 }
133 int ret = poll_ctl(fd, op, events);
134 return ret;
135}
136
137int PollDriver::del_event(int fd, int cur_mask, int delmask) {
138 ldout(cct, 10) << __func__ << " del event fd=" << fd << " cur mask="

Callers 15

start_tickMethod · 0.45
pool_op_submitMethod · 0.45
get_pool_stats_Method · 0.45
get_fs_stats_Method · 0.45
submit_commandMethod · 0.45
writeMethod · 0.45
TEST_PFunction · 0.45
run_someFunction · 0.45
run_orderlyFunction · 0.45
cancel_allFunction · 0.45
cancellationFunction · 0.45

Calls

no outgoing calls

Tested by 6

TEST_PFunction · 0.36
run_someFunction · 0.36
run_orderlyFunction · 0.36
cancel_allFunction · 0.36
cancellationFunction · 0.36
TESTFunction · 0.36