Ignore:
Timestamp:
Jan 23, 2011, 7:59:03 PM (11 years ago)
Author:
Sven Rech
Message:

more fixes concerning p2p

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/CrypP2P/Internal/P2PBase.cs

    r2379 r2437  
    396396
    397397            // blocking till response
    398             autoResetEvent.WaitOne();
    399 
     398            bool success = autoResetEvent.WaitOne(1000*60*2);
     399            if (!success)
     400            {
     401                if (!IsConnected)
     402                    throw new NotConnectedException();
     403                else
     404                    throw new InvalidOperationException("SynchStore failed for some reason!");
     405            }
    400406            LogToMonitor("End: SynchStore. Key: " + key + ". Status: " + requestResult.Status);
    401407
     
    437443
    438444            // blocking till response
    439             autoResetEvent.WaitOne();
     445            bool success = autoResetEvent.WaitOne(1000 * 60 * 2);
     446            if (!success)
     447            {
     448                if (!IsConnected)
     449                    throw new NotConnectedException();
     450                else
     451                    throw new InvalidOperationException("SynchStore failed for some reason!");
     452            }
    440453
    441454            LogToMonitor("End: SynchRetrieve. Key: " + key + ". Status: " + requestResult.Status);
     
    477490
    478491            // blocking till response
    479             autoResetEvent.WaitOne();
     492            bool success = autoResetEvent.WaitOne(1000 * 60 * 2);
     493            if (!success)
     494            {
     495                if (!IsConnected)
     496                    throw new NotConnectedException();
     497                else
     498                    throw new InvalidOperationException("SynchStore failed for some reason!");
     499            }
    480500
    481501            LogToMonitor("End: SynchRemove. Key: " + key + ". Status: " + requestResult.Status);
Note: See TracChangeset for help on using the changeset viewer.