Changeset 104:a41f04cda4c2 in xplra for src/plugin/src/xplra/ListenThread.cc

Timestamp:

12/15/22 19:15:24 (17 months ago)

Author:

István Váradi <ivaradi@…>

Branch:

default

Phase:

public

Message:

The plugin accepts connections over TCP as well

File:

• src/plugin/src/xplra/ListenThread.cc (modified) (4 diffs)

src/plugin/src/xplra/ListenThread.cc

@@ -1 @@
-// Copyright (c) 2013 by István Váradi
+// Copyright (c) 2022 by István Váradi
 
 // This file is part of XPLRA, a remote-access plugin for X-Plane
@@ -35 +35 @@
 #include <hu/varadiistvan/scpl/io/LocalServerSocket.h>
 #include <hu/varadiistvan/scpl/io/LocalAcceptor.h>
+#include <hu/varadiistvan/scpl/io/TCPServerSocket.h>
+#include <hu/varadiistvan/scpl/io/TCPAcceptor.h>
 #include <hu/varadiistvan/xplcommon/Util.h>
 
@@ -43 +45 @@
 using hu::varadiistvan::scpl::io::LocalServerSocket;
 using hu::varadiistvan::scpl::io::LocalAcceptor;
+using hu::varadiistvan::scpl::io::TCPServerSocket;
+using hu::varadiistvan::scpl::io::TCPAcceptor;
 using hu::varadiistvan::xplcommon::Util;
 
@@ -51 +55 @@
     Util::debug("xplra::ListenThread::run: started\n");
 
-    LocalServerSocket socket("xplra", &waiter);
-    LocalAcceptor& acceptor = socket.getAcceptor();
-    while(!quitEvent.check() && !quitEvent.failed() && !acceptor.failed()) {
-        while (acceptor.accept()) {
+    LocalServerSocket localSocket("xplra", &waiter);
+    LocalAcceptor& localAcceptor = localSocket.getAcceptor();
+
+    TCPServerSocket tcpSocket(defaultTCPPort, &waiter);
+    TCPAcceptor& tcpAcceptor = tcpSocket.getAcceptor();
+
+    while(!quitEvent.check() && !quitEvent.failed() &&
+          !localAcceptor.failed() && !tcpAcceptor.failed()) {
+        while (localAcceptor.accept()) {
             ServerThread* serverThread = new ServerThread(*this,
                                                           requestQueue,
-                                                          acceptor);
+                                                          localAcceptor);
+            serverThread->start();
+        }
+        while (tcpAcceptor.accept()) {
+            ServerThread* serverThread = new ServerThread(*this,
+                                                          requestQueue,
+                                                          tcpAcceptor);
             serverThread->start();
         }