Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- function readWriteThread( t : ThreadInfos )
- {
- for (s in t.socks) { try s.peer() catch (e:Dynamic) { cleanup(t,s); };} // TOEGEVOEGD
- for (s in t.wsocks){ try s.peer() catch (e:Dynamic) { cleanup(t,s); };} // TOEGEVOEGD
- var socks = neko.net.Socket.select(t.socks, t.wsocks,null, config.connectLag);
- for( s in socks.read ) {
- var ok = try clientRead(getInfos(s)) catch( e : Dynamic ) { logError(e); false; };
- if( !ok ) {
- socks.write.remove(s);
- cleanup(t,s);
- }
- }
- for( s in socks.write ) {
- var ok = try clientWrite(getInfos(s)) catch( e : Dynamic ) { logError(e); false; };
- if( !ok )
- cleanup(t,s);
- }
- }
- function cleanup( t : ThreadInfos, s : neko.net.Socket ) {
- t.socks.remove(s);// TOEGEVOEGD
- //if( !t.socks.remove(s) ) // COMMENT
- //return; //COMMENT
- try s.close() catch( e : Dynamic ) { logError(e);};
- t.wsocks.remove(s);
- var i = 0;
- while( i < t.sleeps.length )
- if( t.sleeps[i].s == s )
- t.sleeps.splice(i,1);
- else
- i++;
- try {
- clientDisconnected(getInfos(s).client);
- } catch( e : Dynamic ) {
- logError(e);
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment