Inherits Continuation.
Public Member Functions | |
| UDPReadContinuation (Event *completionToken) | |
| UDPReadContinuation () | |
| ~UDPReadContinuation () | |
| void | free (void) |
| void | init_token (Event *completionToken) |
| void | init_read (int fd, IOBufferBlock *buf, int len, struct sockaddr *fromaddr, socklen_t *fromaddrlen) |
| void | set_timer (int seconds) |
| void | cancel () |
| int | readPollEvent (int event, Event *e) |
| Action * | getAction () |
| void | setupPollDescriptor () |
Detailed Description
Definition at line 175 of file UnixUDPNet.cc.
Constructor & Destructor Documentation
| UDPReadContinuation::UDPReadContinuation | ( | Event * | completionToken | ) |
Definition at line 218 of file UnixUDPNet.cc.
References Action::continuation, Continuation::mutex, and new_ProxyMutex().
| UDPReadContinuation::UDPReadContinuation | ( | ) |
Definition at line 228 of file UnixUDPNet.cc.
| UDPReadContinuation::~UDPReadContinuation | ( | ) |
Definition at line 277 of file UnixUDPNet.cc.
References completionUtil::destroy(), ink_assert, and UNINITIALIZED_EVENT_PTR.
Member Function Documentation
| void UDPReadContinuation::cancel | ( | void | ) |
Definition at line 288 of file UnixUDPNet.cc.
| void UDPReadContinuation::free | ( | void | ) | [inline] |
Definition at line 234 of file UnixUDPNet.cc.
References completionUtil::destroy(), ink_assert, Continuation::mutex, and udpReadContAllocator.
Referenced by readPollEvent().
| Action* UDPReadContinuation::getAction | ( | ) | [inline] |
Definition at line 193 of file UnixUDPNet.cc.
| void UDPReadContinuation::init_read | ( | int | fd, | |
| IOBufferBlock * | buf, | |||
| int | len, | |||
| struct sockaddr * | fromaddr, | |||
| socklen_t * | fromaddrlen | |||
| ) | [inline] |
Definition at line 263 of file UnixUDPNet.cc.
References ats_ip6_cast(), ink_assert, readPollEvent(), EThread::schedule_every(), SET_HANDLER, setupPollDescriptor(), and this_ethread().
Referenced by UDPNetProcessor::recvfrom_re().
| void UDPReadContinuation::init_token | ( | Event * | completionToken | ) | [inline] |
Definition at line 252 of file UnixUDPNet.cc.
References Action::continuation, Continuation::mutex, and new_ProxyMutex().
Referenced by UDPNetProcessor::recvfrom_re().
| int UDPReadContinuation::readPollEvent | ( | int | event, | |
| Event * | e | |||
| ) |
Definition at line 315 of file UnixUDPNet.cc.
References ats_ip_sa_cast(), Action::cancel(), Action::cancelled, Event::ethread, free(), completionUtil::getContinuation(), Continuation::handleEvent(), NET_EVENT_DATAGRAM_READ_COMPLETE, NET_EVENT_DATAGRAM_READ_ERROR, SocketManager::recvfrom(), completionUtil::setInfo(), completionUtil::setThread(), setupPollDescriptor(), and socketManager.
Referenced by init_read().
| void UDPReadContinuation::set_timer | ( | int | seconds | ) | [inline] |
Definition at line 185 of file UnixUDPNet.cc.
References HRTIME_SECONDS.
Referenced by UDPNetProcessor::recvfrom_re().
| void UDPReadContinuation::setupPollDescriptor | ( | ) |
Definition at line 295 of file UnixUDPNet.cc.
References PollDescriptor::alloc(), get_PollCont(), PollDescriptor::init(), ink_assert, PollCont::nextPollDescriptor, and this_thread().
Referenced by init_read(), and readPollEvent().
The documentation for this class was generated from the following file:
