wokerman

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()