W::insts[]W::_pidmapW::insts[]-workeridW::insts[]-_contextW::insts[]-_socketnameW::insts[]-count
Timer
?callback
for(;;)-($ret = stream_select(W::globalEvt-_readfds))for(;;)-($ret = stream_select(W::globalEvt-_writefds))
for(;;){}
W::_pidmap[$inst[]-workerid][$pid]W::_idmap[$inst[]-workerid][$id]
W::insts[]-connections[]-baseRead(W::insts[]-connections[]-_socket)
for($insts[]-count){ $pid= pcntl_fork();}
Evt
W::monitor()
Conn
callback
I::init()
W::globalEvt-_readfds
W-__contruct()
new()
subprocess
I::init(W::globalEvt)
I::_event
E-_construct()
worker
instance
W::insts[]-run()
C::connections[]
W::insts[]-connections[]-_socket
mainprocess
W::insts[]-onConnect(){}
W::insts[]-transportW::insts[]-_mainSocket
W::insts[]-resumeAccept()
W::insts[]-connections[]-baseWrite(W::insts[]-connections[]-_socket)
W::globalEvt-_readfdsW::globalEvt-_writefds
W::initId()
W::insts[]-accept(W::insts[]-_mainSocket)
static
W::insts[]-onMessage()W::insts-connections[]-send()
I::signalHandle()
W::globalEvt
E-loop()
W::insts[]-listen()
W::insts[]-connections[]
W::init()
W::forkOneWorkerForLinux($insts[])
W::initWorkers()
[$worker_id] = foreach($worker-count);
W::insts[]-onError()
W::idmap
W::insts[]-onBufferDrain()W::insts[]-onClose()
stream_socket_accept()
