Changeset e0dccb59


Ignore:
Timestamp:
Apr 2, 2009 8:54:28 AM (11 years ago)
Author:
mkvore-commit <mkvore-commit@…>
Branches:
master
Children:
bc086a7
Parents:
a4d16af
Message:
 
File:
1 edited

Legend:

Unmodified
Added
Removed
  • apps/streaming/java/src/net/i2p/client/streaming/ConnectionHandler.java

    ra4d16af re0dccb59  
    6565   
    6666    public boolean waitSyn( long ms ) throws InterruptedException {
    67         boolean incoming = false ;
    68         boolean isTimed = (ms>=0);
    69 
    70         Clock clock = I2PAppContext.getGlobalContext().clock();
    71         long now = clock.now();
    72         long end = now + ms;
    73         while (!incoming && (!isTimed || now<=end) ) {
    74                 synchronized (_synQueue) {
    75 
    76                         for (Packet p : _synQueue)
    77                         {
    78                                 if (p.isFlagSet(Packet.FLAG_SYNCHRONIZE)) {
    79                                         incoming = true ;
    80                                         break;
    81                                 }
    82                         }
    83                         if (!incoming) {
    84                                 if (!isTimed) {
    85                                         _synQueue.wait();
    86                                 } else {
    87                                         now = clock.now();
    88                                         if (now < end) {
    89                                                 _synQueue.wait(end-now);
    90                                         }
    91                                 }
    92                         }
    93                 }
    94         }
    95         return incoming ;
     67        throw new InterruptedException();
    9668    }
    9769   
Note: See TracChangeset for help on using the changeset viewer.