aboutsummaryrefslogtreecommitdiff
path: root/lib/Net.Messaging.FBM/src/Client
diff options
context:
space:
mode:
authorLibravatar vnugent <public@vaughnnugent.com>2023-06-16 13:33:43 -0400
committerLibravatar vnugent <public@vaughnnugent.com>2023-06-16 13:33:43 -0400
commit44f25885437d6d09ea04cf74db4556df95821d56 (patch)
treeb7876edf7b36f0c56ec9bcd947dcbcbb4a9b6a1f /lib/Net.Messaging.FBM/src/Client
parentabbfe728fde9e0a5643b3c4e85d1cd27b15c59f4 (diff)
Some tcp buf, minor bits and bobs
Diffstat (limited to 'lib/Net.Messaging.FBM/src/Client')
-rw-r--r--lib/Net.Messaging.FBM/src/Client/FBMClient.cs4
1 files changed, 4 insertions, 0 deletions
diff --git a/lib/Net.Messaging.FBM/src/Client/FBMClient.cs b/lib/Net.Messaging.FBM/src/Client/FBMClient.cs
index 861811e..82b6c7e 100644
--- a/lib/Net.Messaging.FBM/src/Client/FBMClient.cs
+++ b/lib/Net.Messaging.FBM/src/Client/FBMClient.cs
@@ -140,11 +140,15 @@ namespace VNLib.Net.Messaging.FBM.Client
$"{REQ_RECV_BUF_QUERY_ARG}={Config.RecvBufferSize}" +
$"&{REQ_HEAD_BUF_QUERY_ARG}={Config.MaxHeaderBufferSize}" +
$"&{REQ_MAX_MESS_QUERY_ARG}={Config.MaxMessageSize}";
+
Debug("Connection string {con}", urib.Uri.ToString());
+
//Connect to server
await ClientSocket.ConnectAsync(urib.Uri, cancellationToken);
+
//Reset wait handle before return
ConnectionStatusHandle.Reset();
+
//Begin listeing for requets in a background task
_ = Task.Run(ProcessContinuousRecvAsync, cancellationToken);
}