Chilkat HOME .NET Core C# Android™ AutoIt C C# C++ Chilkat2-Python CkPython Classic ASP DataFlex Delphi ActiveX Delphi DLL Go Java Lianja Mono C# Node.js Objective-C PHP ActiveX PHP Extension Perl PowerBuilder PowerShell PureBasic Ruby SQL Server Swift 2 Swift 3,4,5... Tcl Unicode C Unicode C++ VB.NET VBScript Visual Basic 6.0 Visual FoxPro Xojo Plugin
(Unicode C) Bidirectional Sockets (TLS or non-TLS, simultaneous reading and writing a connection)This example demonstrates how to simultaneously read/write on a single socket connection.
#include <C_CkSocketW.h> #include <C_CkTaskW.h> void ChilkatSample(void) { HCkSocketW tlsRead; BOOL bUseTls; int maxWaitMs; BOOL success; HCkSocketW tlsWrite; HCkTaskW task; const wchar_t *httpGetReq; // This example requires the Chilkat API to have been previously unlocked. // See Global Unlock Sample for sample code. tlsRead = CkSocketW_Create(); // We'll just use an HTTPS server for this example... bUseTls = TRUE; maxWaitMs = 5000; success = CkSocketW_Connect(tlsRead,L"www.chilkatsoft.com",443,bUseTls,maxWaitMs); if (success != TRUE) { wprintf(L"%s\n",CkSocketW_lastErrorText(tlsRead)); CkSocketW_Dispose(tlsRead); return; } // Chilkat classes are thread-safe. This means that only one method call can be active // at a time for a given object instance. It would seem that this would prevent the possibility // to simultaneously read/write a given connection because it would require two method calls // to be simultaneously active: one for reading and one for writing. // // There's a trick to doing it... // // The CloneSocket method is provided to get a new object instance that shares the same socket // connection. This allows for the coarse-grained object-level thread safety to be maintained, // while finer-grained thread-safety mechanisms keep things kosher internally. // One object will be used for reading, and the cloned socket is used for writing. // It doesn't matter which -- you can use the cloned socket for reading or the original for writing. // However.. if you try to read simultneously from both the original and cloned objects at the same // time, then one will block until the other finishes. (This is because of the finer-grained thread // safety internally.) The same is true if you try to write both socket objects simultaneously. tlsWrite = CkSocketW_CloneSocket(tlsRead); // Let's start an async read on the socket. Nothing will be arriving until we actually send the GET // request and the server responds. This will read until the end of the HTTP response header. task = CkSocketW_ReceiveUntilMatchAsync(tlsRead,L"\r\n\r\n"); CkTaskW_Run(task); // Now send the request. This should not block because the read is happening on the tlsRead object. httpGetReq = L"GET / HTTP/1.1\r\nHost: www.chilkatsoft.com\r\n\r\n"; success = CkSocketW_SendString(tlsWrite,httpGetReq); // Assuming success for the example... // Wait for the read task to finish. // The TRUE/FALSE returned by Wait applies to the Wait method call, not the task. maxWaitMs = 5000; success = CkTaskW_Wait(task,maxWaitMs); if (!success || (CkTaskW_getStatusInt(task) != 7) || (CkTaskW_getTaskSuccess(task) != TRUE)) { if (!success) { // The task.LastErrorText applies to the Wait method call. wprintf(L"%s\n",CkTaskW_lastErrorText(task)); } else { // The ResultErrorText applies to the underlying task method call (i.e. the Connect) wprintf(L"%s\n",CkTaskW_status(task)); wprintf(L"%s\n",CkTaskW_resultErrorText(task)); } CkTaskW_Dispose(task); CkSocketW_Dispose(tlsWrite); CkSocketW_Dispose(tlsRead); return; } // Examine the received HTTP response header: wprintf(L"HTTP response header:\n"); wprintf(L"%s\n",CkTaskW_getResultString(task)); // We should get a response that looks like this: // HTTP response header: // HTTP/1.1 200 OK // Cache-Control: private // Content-Length: 7477 // Content-Type: text/html // Server: Microsoft-IIS/8.5 // Set-Cookie: ASPSESSIONIDSWDSTRTQ=BBNMIKGCHFJNILFFPLDIOGDE; secure; path=/ // X-Powered-By: ASP.NET // X-Powered-By-Plesk: PleskWin // Date: Thu, 06 Apr 2017 12:03:30 GMT CkTaskW_Dispose(task); CkSocketW_Dispose(tlsWrite); // Forget about the remainder of the HTTP response... The example was only to demonstrate // simultaneous reading/writing.. maxWaitMs = 20; CkSocketW_Close(tlsRead,maxWaitMs); CkSocketW_Dispose(tlsRead); } |
© 2000-2024 Chilkat Software, Inc. All Rights Reserved.