Lines Matching refs:cb
117 CB* cb = cb_iter->cb;
120 if (cb) {
121 cb->OnShutdown(this, fd);
191 void EpollServer::RegisterFD(int fd, CB* cb, int event_mask) {
192 CHECK(cb);
200 CB* other_cb = fd_i->cb;
210 fd_i->cb = cb;
215 cb_map_.insert(CBAndEventMask(cb, event_mask, fd));
222 cb->OnRegistration(this, fd, event_mask);
248 void EpollServer::RegisterFDForWrite(int fd, CB* cb) {
249 RegisterFD(fd, cb, EPOLLOUT);
252 void EpollServer::RegisterFDForReadWrite(int fd, CB* cb) {
253 RegisterFD(fd, cb, EPOLLIN | EPOLLOUT);
256 void EpollServer::RegisterFDForRead(int fd, CB* cb) {
257 RegisterFD(fd, cb, EPOLLIN);
262 if (cb_map_.end() == fd_i || fd_i->cb == NULL) {
270 CB* cb = fd_i->cb;
275 cb->OnUnregistration(fd, false);
276 // fd_i->cb is NULL if that fd is unregistered inside the callchain of
279 // erase the entry if it is in use. Thus, a NULL fd_i->cb is used as a
288 fd_i->cb = NULL;
319 if (fd_i == cb_map_.end() || fd_i->cb == NULL) {
404 if (cb_map_.end() != fd_i && fd_i->cb != NULL) {
433 fd_i->cb != NULL &&
467 AlarmCB* cb = iterator_token->second;
469 all_alarms_.erase(cb);
470 cb->OnUnregistration();
527 << " registered with cb: " << it->cb;
598 if (fd_i->cb != NULL) {
609 fd_i->cb->OnModification(fd, event_mask);
695 // UnRegister call will now simply set the cb to NULL instead of
699 cb_and_mask->cb->OnEvent(cb_and_mask->fd, &event);
705 if (cb_and_mask->cb == NULL) {
740 AlarmCB* cb = i->second;
744 alarms_reregistered_and_should_be_skipped_.find(cb)
750 all_alarms_.erase(cb);
751 const int64 new_timeout_time_in_us = cb->OnAlarm();
763 << " " << cb
767 alarms_reregistered_and_should_be_skipped_.insert(cb);
769 RegisterAlarm(new_timeout_time_in_us, cb);
