You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2008/09/16 23:19:45 UTC
svn commit: r696068 - in
/incubator/qpid/trunk/qpid/dotnet/client-010/client: client/Client.cs
transport/Session.cs transport/util/ResultFuture.cs
Author: arnaudsimon
Date: Tue Sep 16 14:19:44 2008
New Revision: 696068
URL: http://svn.apache.org/viewvc?rev=696068&view=rev
Log:
qpid-1277: fixed Date issue
Modified:
incubator/qpid/trunk/qpid/dotnet/client-010/client/client/Client.cs
incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/Session.cs
incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/util/ResultFuture.cs
Modified: incubator/qpid/trunk/qpid/dotnet/client-010/client/client/Client.cs
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/dotnet/client-010/client/client/Client.cs?rev=696068&r1=696067&r2=696068&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/dotnet/client-010/client/client/Client.cs (original)
+++ incubator/qpid/trunk/qpid/dotnet/client-010/client/client/Client.cs Tue Sep 16 14:19:44 2008
@@ -74,12 +74,12 @@
ch.connectionClose(ConnectionCloseCode.NORMAL, "client is closing");
lock (CloseOk)
{
- long start = DateTime.Now.Millisecond;
+ DateTime start = DateTime.Now;
long elapsed = 0;
while (!Closed && elapsed < timeout)
{
Monitor.Wait(CloseOk, (int) (timeout - elapsed));
- elapsed = DateTime.Now.Millisecond - start;
+ elapsed = DateTime.Now.Subtract(start).Milliseconds;
}
if (!Closed)
{
Modified: incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/Session.cs
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/Session.cs?rev=696068&r1=696067&r2=696068&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/Session.cs (original)
+++ incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/Session.cs Tue Sep 16 14:19:44 2008
@@ -354,7 +354,7 @@
executionSync(Option.SYNC);
}
- long start = DateTime.Now.Millisecond;
+ DateTime start = DateTime.Now;
long elapsed = 0;
while (! Closed && elapsed < timeout && Serial.lt(_maxComplete, point))
@@ -362,7 +362,7 @@
log.debug("{0} waiting for[{1}]: {2}, {3}", this, point,
_maxComplete, _commands);
Monitor.Wait(_commands, (int) (timeout - elapsed));
- elapsed = DateTime.Now.Millisecond - start;
+ elapsed = DateTime.Now.Subtract(start).Milliseconds;
}
if (Serial.lt(_maxComplete, point))
@@ -469,13 +469,13 @@
sessionDetach(_name);
lock (_commands)
{
- long start = DateTime.Now.Millisecond;
+ DateTime start = DateTime.Now;
long elapsed = 0;
while (! Closed && elapsed < _timeout)
{
Monitor.Wait(_commands, (int) (_timeout - elapsed));
- elapsed = DateTime.Now.Millisecond - start;
+ elapsed = DateTime.Now.Subtract(start).Milliseconds;
}
}
}
Modified: incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/util/ResultFuture.cs
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/util/ResultFuture.cs?rev=696068&r1=696067&r2=696068&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/util/ResultFuture.cs (original)
+++ incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/util/ResultFuture.cs Tue Sep 16 14:19:44 2008
@@ -16,13 +16,13 @@
{
lock (this)
{
- long start = DateTime.Now.Millisecond;
+ DateTime start = DateTime.Now;
long elapsed = 0;
while (! _session.Closed && _timeout - elapsed > 0 && _result == null)
{
log.debug("{0} waiting for result: {1}", _session, this );
Monitor.Wait(this, (int) (timeout - elapsed));
- elapsed = DateTime.Now.Millisecond - start;
+ elapsed = DateTime.Now.Subtract( start ).Milliseconds;
}
}
if( _session.Closed )