jan_flanders

Untitled

Jun 21st, 2012
67
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1.     function readWriteThread( t : ThreadInfos )
  2.     {
  3.         for (s in t.socks) { try s.peer() catch (e:Dynamic) { cleanup(t,s); };} // TOEGEVOEGD
  4.         for (s in t.wsocks){ try s.peer() catch (e:Dynamic) { cleanup(t,s); };} // TOEGEVOEGD
  5.  
  6.         var socks = neko.net.Socket.select(t.socks, t.wsocks,null, config.connectLag);
  7.         for( s in socks.read ) {
  8.             var ok = try clientRead(getInfos(s)) catch( e : Dynamic ) { logError(e); false; };
  9.             if( !ok ) {
  10.                 socks.write.remove(s);
  11.                 cleanup(t,s);
  12.             }
  13.         }
  14.         for( s in socks.write ) {
  15.             var ok = try clientWrite(getInfos(s)) catch( e : Dynamic ) { logError(e); false; };
  16.             if( !ok )
  17.                 cleanup(t,s);
  18.         }
  19.     }
  20.    
  21.     function cleanup( t : ThreadInfos, s : neko.net.Socket ) {
  22.         t.socks.remove(s);// TOEGEVOEGD
  23.         //if( !t.socks.remove(s) ) // COMMENT
  24.             //return; //COMMENT
  25.         try s.close() catch( e : Dynamic ) { logError(e);};
  26.         t.wsocks.remove(s);
  27.         var i = 0;
  28.         while( i < t.sleeps.length )
  29.             if( t.sleeps[i].s == s )
  30.                 t.sleeps.splice(i,1);
  31.             else
  32.                 i++;
  33.         try {
  34.             clientDisconnected(getInfos(s).client);
  35.         } catch( e : Dynamic ) {
  36.             logError(e);
  37.         }
  38.     }
Advertisement
Add Comment
Please, Sign In to add comment