Fixed issue with CreateRemoteWaitHandle which created a handle on the…

… local list instead of the remote.
Dtronix · Oct 12, 2016 · 33d806c · 33d806c
1 parent 65f9313
commit 33d806c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/DtronixMessageQueue.Tests/Rpc/RpcClientTests.cs b/src/DtronixMessageQueue.Tests/Rpc/RpcClientTests.cs
@@ -91,9 +91,10 @@ public void Client_calls_proxy_method_and_canceles() {
 				var service = Client.Session.GetProxy<ICalculatorService>();
 				var token_source = new CancellationTokenSource();
 
-				token_source.CancelAfter(200);
+
 				bool threw = false;
 				try {
+					token_source.CancelAfter(500);
 					service.LongRunningTask(1, 2, token_source.Token);
 				} catch (OperationCanceledException) {
 					threw = true;

diff --git a/src/DtronixMessageQueue/Rpc/ResponseWait.cs b/src/DtronixMessageQueue/Rpc/ResponseWait.cs
@@ -76,7 +76,7 @@ public ResponseWaitHandle CreateRemoteWaitHandle(ushort id) {
 			};
 
 			// Add the wait to the outstanding wait dictionary for retrieval later.
-			if (local_wait_handles.TryAdd(return_wait.Id, return_wait) == false) {
+			if (remote_wait_handles.TryAdd(return_wait.Id, return_wait) == false) {
 				throw new InvalidOperationException($"Id {return_wait.Id} already exists in the remote handles dictionary.");
 			}