accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen) | BaseScheduler | |
acquire() | Coroutine | [inline] |
addReadCallback(Callback &cb, int fd) | EpollScheduler | [virtual] |
addRelativeWaitCallback(Callback &cb, const timeval &tv) | BaseScheduler | |
addWaitCallback(Callback &cb, const timeval &tv) | EpollScheduler | [virtual] |
addWriteCallback(Callback &cb, int fd) | EpollScheduler | [virtual] |
BaseScheduler(BlockingQueue< Microthread * > *q=NULL) | BaseScheduler | [protected] |
channelmanager | Microthread | |
connect(int sockfd, const struct sockaddr *serv_addr, socklen_t addrlen) | BaseScheduler | |
context | Coroutine | [protected] |
Coroutine() | Coroutine | |
create(BlockingQueue< Microthread * > *q=NULL) | EpollScheduler | [static] |
decref() | RefCounter | [inline] |
delayme() | Microthread | |
EpollScheduler(BlockingQueue< Microthread * > *q=NULL) | EpollScheduler | [protected] |
incref() | RefCounter | [inline] |
Microthread(BlockingQueue< Microthread * > *q=NULL) | Microthread | [protected] |
NewCoroutine(int stacksize=4096 *1024) | NewCoroutine | |
NewCoroutine (defined in Coroutine) | Coroutine | [friend] |
notifyRead(Channel< T > &chan, const T &value, int fd) | BaseScheduler | [inline] |
notifyWait(Channel< T > &chan, const T &value, const timeval &tv) | BaseScheduler | [inline] |
notifyWrite(Channel< T > &chan, const T &value, int fd) | BaseScheduler | [inline] |
queue | Microthread | [protected] |
read(int fd, void *buf, size_t count) | BaseScheduler | |
RefCounter() | RefCounter | [inline, protected] |
release() | Coroutine | [inline] |
returnto(Coroutine &o, bool acquired=false) | NewCoroutine | |
run() | EpollScheduler | [virtual] |
scheduleme() | Microthread | [inline] |
scheduleRead(int fd) | BaseScheduler | |
scheduleWait(const timeval &tv) | BaseScheduler | |
scheduleWrite(int fd) | BaseScheduler | |
setcallback(Callback *cb) | Microthread | |
sleep(unsigned int seconds) | BaseScheduler | |
start() | Microthread | [protected, virtual] |
swapto(Microthread &o, bool acquired=false) | Microthread | |
NewCoroutine::swapto(Coroutine &o, bool acquired=false) | Coroutine | |
write(int fd, const void *buf, size_t count) | BaseScheduler | |
~Coroutine() (defined in Coroutine) | Coroutine | [virtual] |
~Microthread() (defined in Microthread) | Microthread | [inline, virtual] |
~NewCoroutine() (defined in NewCoroutine) | NewCoroutine | |
~RefCounter() (defined in RefCounter) | RefCounter | [inline, virtual] |