diff options
| author | Arnaud Simon <arnaudsimon@apache.org> | 2008-09-16 21:19:44 +0000 |
|---|---|---|
| committer | Arnaud Simon <arnaudsimon@apache.org> | 2008-09-16 21:19:44 +0000 |
| commit | 6970fd34c1f6b86608d30dbf77020869d9d72b3c (patch) | |
| tree | 888efe11e740973ea49f771b8bc2e638ecbc7aa4 | |
| parent | 46f995ab743a7c8a61be86de7dff9a062b0ea1f7 (diff) | |
| download | qpid-python-6970fd34c1f6b86608d30dbf77020869d9d72b3c.tar.gz | |
qpid-1277: fixed Date issue
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@696068 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/dotnet/client-010/client/client/Client.cs | 4 | ||||
| -rw-r--r-- | qpid/dotnet/client-010/client/transport/Session.cs | 8 | ||||
| -rw-r--r-- | qpid/dotnet/client-010/client/transport/util/ResultFuture.cs | 4 |
3 files changed, 8 insertions, 8 deletions
diff --git a/qpid/dotnet/client-010/client/client/Client.cs b/qpid/dotnet/client-010/client/client/Client.cs index 6759c6dbdc..f07609380f 100644 --- a/qpid/dotnet/client-010/client/client/Client.cs +++ b/qpid/dotnet/client-010/client/client/Client.cs @@ -74,12 +74,12 @@ namespace org.apache.qpid.client 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)
{
diff --git a/qpid/dotnet/client-010/client/transport/Session.cs b/qpid/dotnet/client-010/client/transport/Session.cs index 81c984bb4d..f97fb44568 100644 --- a/qpid/dotnet/client-010/client/transport/Session.cs +++ b/qpid/dotnet/client-010/client/transport/Session.cs @@ -354,7 +354,7 @@ namespace org.apache.qpid.transport 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 @@ namespace org.apache.qpid.transport 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 @@ namespace org.apache.qpid.transport 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;
}
}
}
diff --git a/qpid/dotnet/client-010/client/transport/util/ResultFuture.cs b/qpid/dotnet/client-010/client/transport/util/ResultFuture.cs index 11e57ed821..dd10e6a74a 100644 --- a/qpid/dotnet/client-010/client/transport/util/ResultFuture.cs +++ b/qpid/dotnet/client-010/client/transport/util/ResultFuture.cs @@ -16,13 +16,13 @@ namespace common.org.apache.qpid.transport.util {
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 )
|