Changeset 110:9ac6386fe9ff in xplra for src/client/c/hu/varadiistvan/xplra/XPlane.cc

Timestamp:

12/23/22 09:09:50 (17 months ago)

Author:

István Váradi <ivaradi@…>

Branch:

default

hg-Phase:

(<MercurialRepository 3 'hg:/home/ivaradi/xplane/hg/xplra' '/'>, 'public')

Message:

The C++ client API can connect over TCP

File:

• src/client/c/hu/varadiistvan/xplra/XPlane.cc (modified) (4 diffs)

src/client/c/hu/varadiistvan/xplra/XPlane.cc

@@ -35 +35 @@
 
 #include <hu/varadiistvan/scpl/io/LocalClientSocket.h>
+#include <hu/varadiistvan/scpl/io/TCPClientSocket.h>
 #include <hu/varadiistvan/scpl/io/DataStream.h>
 
@@ -52 +53 @@
 
 using hu::varadiistvan::scpl::io::LocalClientSocket;
-using hu::varadiistvan::scpl::io::LocalConnector;
+using hu::varadiistvan::scpl::io::TCPClientSocket;
 using hu::varadiistvan::scpl::io::DataStream;
 
@@ -60 +61 @@
 using std::string;
 using std::min;
+
+//------------------------------------------------------------------------------
+
+const unsigned short XPlane::defaultTCPPort;
+
+//------------------------------------------------------------------------------
+
+template <class ClientSocket>
+void XPlane::connect(std::unique_ptr<ClientSocket> clientSocket)
+{
+    auto& connector = clientSocket->getConnector();
+
+    while (!connector.connect()) {
+        if (connector.failed()) {
+            throw IOException(connector.getErrorCode());
+        }
+        waiter.wait();
+        if (waiter.failed()) {
+            throw IOException(waiter.getErrorCode());
+        }
+    }
+
+#ifndef _WIN32
+    signal(SIGPIPE, SIG_IGN);
+#endif
+
+    socket = clientSocket.release();
+    stream = new DataStream(*socket);
+
+    for(multiBuffers_t::iterator i = multiBuffers.begin();
+        i!=multiBuffers.end(); ++i)
+    {
+        MultiBuffer* buffer = *i;
+        buffer->reregisterInXPlane();
+    }
+}
 
 //------------------------------------------------------------------------------
@@ -150 +187 @@
     unique_ptr<LocalClientSocket> clientSocket(new LocalClientSocket("xplra",
                                                                      &waiter));
-    LocalConnector& connector = clientSocket->getConnector();
-
-    while (!connector.connect()) {
-        if (connector.failed()) {
-            throw IOException(connector.getErrorCode());
-        }
-        waiter.wait();
-        if (waiter.failed()) {
-            throw IOException(waiter.getErrorCode());
-        }
-    }
-
-#ifndef _WIN32
-    signal(SIGPIPE, SIG_IGN);
-#endif
-
-    socket = clientSocket.release();
-    stream = new DataStream(*socket);
-
-    for(multiBuffers_t::iterator i = multiBuffers.begin();
-        i!=multiBuffers.end(); ++i)
-    {
-        MultiBuffer* buffer = *i;
-        buffer->reregisterInXPlane();
-    }
+    connect(std::move(clientSocket));
+}
+
+//------------------------------------------------------------------------------
+
+void XPlane::connectTCP(const std::string& address, unsigned short port)
+{
+    if (socket!=0) return;
+
+    unique_ptr<TCPClientSocket> clientSocket(new TCPClientSocket(address.c_str(),
+                                                                 port,
+                                                                 &waiter));
+    connect(std::move(clientSocket));
 }