160 local callback = function( ) |
160 local callback = function( ) |
161 self:_lock( false, false, false ) |
161 self:_lock( false, false, false ) |
162 --vdebug( "start listening on client socket with id:", self.id ) |
162 --vdebug( "start listening on client socket with id:", self.id ) |
163 self.eventread = addevent( base, self.conn, EV_READ, self.readcallback, cfg.READ_TIMEOUT ); -- register callback |
163 self.eventread = addevent( base, self.conn, EV_READ, self.readcallback, cfg.READ_TIMEOUT ); -- register callback |
164 if call_onconnect then |
164 if call_onconnect then |
165 debug("CALLING ONCONNECT") |
|
166 self:onconnect() |
165 self:onconnect() |
167 else |
|
168 debug("NOT CALLING ONCONNECT"); |
|
169 end |
166 end |
170 self.eventsession = nil |
167 self.eventsession = nil |
171 return -1 |
168 return -1 |
172 end |
169 end |
173 self.eventsession = addevent( base, nil, EV_TIMEOUT, callback, 0 ) |
170 self.eventsession = addevent( base, nil, EV_TIMEOUT, callback, 0 ) |