Changeset 9453 in ntrip for trunk/ntripserver

Timestamp:

Jun 7, 2021, 2:36:06 PM (3 years ago)

Author:

stuerze

Message:

data upload to localhost added

File:

• trunk/ntripserver/ntripserver.c (modified) (4 diffs)

trunk/ntripserver/ntripserver.c

@@ -138 +138 @@
 static sockettype gps_socket = INVALID_SOCKET;
 static sockettype socket_tcp = INVALID_SOCKET;
+static sockettype local_socket_tcp = INVALID_SOCKET;
 static sockettype socket_udp = INVALID_SOCKET;
 #ifndef WINDOWSVERSION
@@ -897 +898 @@
         break;
       }
+
+      if (outputmode == TCPIP) {
+        // Forcefully attaching socket to the local port
+        int opt = 1;
+        if (setsockopt(socket_tcp, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT,
+                                                      &opt, sizeof(opt)))  {
+            perror("setsockopt");
+            break;
+        }
+      }
       memset((char*) &caster, 0x00, sizeof(caster));
       memcpy(&caster.sin_addr, he->h_addr, (size_t)he->h_length);
@@ -910 +921 @@
           outputmode == RTSP   ? "rtsp"   : "tcpip");
 
-      if (connect(socket_tcp, (struct sockaddr*) &caster, sizeof(caster)) < 0) {
-        fprintf(stderr, "WARNING: can't connect output to %s at port %d",
-            inet_ntoa(caster.sin_addr), outport);
-        perror(" ");
-        break;
+      if (outputmode == TCPIP) {
+        // Forcefully attaching socket to the local port
+        if (bind(socket_tcp, (struct sockaddr *)&caster, sizeof(caster)) < 0)        {
+            perror("bind failed");
+            break;
+        }
+        if (listen(socket_tcp, 3) < 0) {
+            perror("listen");
+            break;
+        }
+        int addrlen = sizeof(caster);
+        if ((local_socket_tcp = accept(socket_tcp, (struct sockaddr *)&caster,
+                                      (socklen_t*)&addrlen)) < 0)        {
+            perror("accept");
+            break;;
+        }
+      }
+      else {
+        if (connect(socket_tcp, (struct sockaddr*) &caster, sizeof(caster)) < 0) {
+          fprintf(stderr, "WARNING: can't connect output to %s at port %d",
+              inet_ntoa(caster.sin_addr), outport);
+          break;
+        }
       }
 
@@ -1308 +1337 @@
         case TCPIP:
           fallback = 0;
-          send_receive_loop(socket_tcp, outputmode, NULL, 0, 0, chunkymode);
+          send_receive_loop(local_socket_tcp, outputmode, NULL, 0, 0, chunkymode);
           input_init = output_init = 0;
           break;