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 )
