source: ntrip/trunk/ntripserver/ntripserver.c@ 9441

Last change on this file since 9441 was 9404, checked in by stoecker, 3 years ago

drop the deprecated www prefix
  • Property svn:keywords set to Id Revision Date
File size: 77.9 KB
Line 
1/*
2 * $Id: ntripserver.c 9404 2021-04-14 12:51:04Z stoecker $
3 *
4 * Copyright (c) 2003...2019
5 * German Federal Agency for Cartography and Geodesy (BKG)
6 * Dirk Stöcker (Alberding GmbH)
7 *
8 * Developed for Networked Transport of RTCM via Internet Protocol (NTRIP)
9 * for streaming GNSS data over the Internet.
10 *
11 * Designed by Informatik Centrum Dortmund http://www.icd.de
12 *
13 * The BKG disclaims any liability nor responsibility to any person or
14 * entity with respect to any loss or damage caused, or alleged to be
15 * caused, directly or indirectly by the use and application of the NTRIP
16 * technology.
17 *
18 * For latest information and updates, access:
19 * https://igs.bkg.bund.de/ntrip/index
20 *
21 * BKG, Frankfurt, Germany, August 2019
22 * E-mail: euref-ip@bkg.bund.de
23 *
24 * This program is free software; you can redistribute it and/or
25 * modify it under the terms of the GNU General Public License
26 * as published by the Free Software Foundation; either version 2
27 * of the License, or (at your option) any later version.
28 *
29 * This program is distributed in the hope that it will be useful,
30 * but WITHOUT ANY WARRANTY; without even the implied warranty of
31 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
32 * GNU General Public License for more details.
33 *
34 * You should have received a copy of the GNU General Public License along
35 * with this program; if not, write to the Free Software Foundation, Inc.,
36 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
37 */
38
39/* SVN revision and version */
40static char revisionstr[] = "$Revision: 9404 $";
41static char datestr[] = "$Date: 2021-04-14 12:51:04 +0000 (Wed, 14 Apr 2021) $";
42
43#include <ctype.h>
44#include <errno.h>
45#include <fcntl.h>
46#include <getopt.h>
47#include <stdio.h>
48#include <stdlib.h>
49#include <string.h>
50#include <sys/time.h>
51#include <sys/types.h>
52#include <time.h>
53#include <signal.h>
54#include <unistd.h>
55
56#ifdef WINDOWSVERSION
57 #include <winsock2.h>
58 #include <io.h>
59 #include <sys/stat.h>
60 #include <windows.h>
61 typedef SOCKET sockettype;
62 typedef u_long in_addr_t;
63 typedef size_t socklen_t;
64 typedef u_short uint16_t;
65#else
66typedef int sockettype;
67#include <arpa/inet.h>
68#include <sys/socket.h>
69#include <netinet/in.h>
70#include <netdb.h>
71#include <sys/termios.h>
72#define closesocket(sock) close(sock)
73#define INVALID_HANDLE_VALUE -1
74#define INVALID_SOCKET -1
75#endif
76
77#ifndef COMPILEDATE
78#define COMPILEDATE " built " __DATE__
79#endif
80
81#define ALARMTIME (2*60)
82
83#ifndef MSG_DONTWAIT
84#define MSG_DONTWAIT 0 /* prevent compiler errors */
85#endif
86#ifndef O_EXLOCK
87#define O_EXLOCK 0 /* prevent compiler errors */
88#endif
89
90enum MODE {
91 SERIAL = 1,
92 TCPSOCKET = 2,
93 INFILE = 3,
94 SISNET = 4,
95 UDPSOCKET = 5,
96 NTRIP1_IN = 6,
97 NTRIP2_HTTP_IN = 7, // HTTP only
98 LAST
99};
100
101enum OUTMODE {
102 HTTP = 1,
103 RTSP = 2,
104 NTRIP1 = 3,
105 UDP = 4,
106 TDC = 5,
107 END
108};
109
110#define AGENTSTRING "NTRIP NtripServerPOSIX"
111#define BUFSZ 10240
112#define SZ 64
113
114/* default socket source */
115#define SERV_HOST_ADDR "localhost"
116#define SERV_TCP_PORT 2101
117
118/* default destination */
119#define NTRIP_CASTER "euref-ip.net"
120#define NTRIP_PORT 2101
121
122#define SISNET_SERVER "131.176.49.142"
123#define SISNET_PORT 7777
124
125#define RTP_VERSION 2
126#define TIME_RESOLUTION 125
127
128static int ttybaud = 19200;
129#ifndef WINDOWSVERSION
130static const char *ttyport = "/dev/gps";
131#else
132 static const char *ttyport = "COM1";
133#endif
134static const char *filepath = "/dev/stdin";
135static enum MODE inputmode = INFILE;
136static int sisnet = 31;
137static int gps_file = -1;
138static sockettype gps_socket = INVALID_SOCKET;
139static sockettype socket_tcp = INVALID_SOCKET;
140static sockettype socket_udp = INVALID_SOCKET;
141#ifndef WINDOWSVERSION
142static int gps_serial = INVALID_HANDLE_VALUE;
143static int sigpipe_received = 0;
144#else
145 HANDLE gps_serial = INVALID_HANDLE_VALUE;
146#endif
147static int sigalarm_received = 0;
148static int sigint_received = 0;
149static int reconnect_sec = 1;
150static const char *casterouthost = NTRIP_CASTER;
151static char rtsp_extension[SZ] = "";
152static const char *mountpoint = NULL;
153static int udp_cseq = 1;
154static int udp_tim, udp_seq, udp_init;
155
156/* Forward references */
157static void send_receive_loop(sockettype sock, int outmode,
158 struct sockaddr *pcasterRTP, socklen_t length, unsigned int rtpssrc,
159 int chnunkymode);
160static void usage(int, char*);
161static int encode(char *buf, int size, const char *user, const char *pwd);
162static int send_to_caster(char *input, sockettype socket, int input_size);
163static void close_session(const char *caster_addr, const char *mountpoint,
164 int session, char *rtsp_ext, int fallback);
165static int reconnect(int rec_sec, int rec_sec_max);
166static void handle_sigint(int sig);
167static void setup_signal_handler(int sig, void (*handler)(int));
168#ifndef WINDOWSVERSION
169static int openserial(const char *tty, int blocksz, int baud);
170static void handle_sigpipe(int sig);
171static void handle_alarm(int sig);
172#else
173 static HANDLE openserial(const char * tty, int baud);
174#endif
175
176/*
177 * main
178 *
179 * Main entry point for the program. Processes command-line arguments and
180 * prepares for action.
181 *
182 * Parameters:
183 * argc : integer : Number of command-line arguments.
184 * argv : array of char : Command-line arguments as an array of
185 * zero-terminated pointers to strings.
186 *
187 * Return Value:
188 * The function does not return a value (although its return type is int).
189 *
190 * Remarks:
191 *
192 */
193int main(int argc, char **argv) {
194 int c;
195 int size = 2048; /* for setting send buffer size */
196 struct sockaddr_in caster;
197 const char *proxyhost = "";
198 unsigned int proxyport = 0;
199
200 /*** INPUT ***/
201 const char *casterinhost = 0;
202 unsigned int casterinport = 0;
203 const char *inhost = 0;
204 unsigned int inport = 0;
205 int chunkymode = 0;
206 char get_extension[SZ] = "";
207
208 struct hostent *he;
209
210 const char *sisnetpassword = "";
211 const char *sisnetuser = "";
212
213 const char *stream_name = 0;
214 const char *stream_user = 0;
215 const char *stream_password = 0;
216
217 const char *recvrid = 0;
218 const char *recvrpwd = 0;
219
220 const char *initfile = NULL;
221
222 int bindmode = 0;
223
224 /*** OUTPUT ***/
225 unsigned int casteroutport = NTRIP_PORT;
226 const char *outhost = 0;
227 unsigned int outport = 0;
228 char post_extension[SZ] = "";
229
230 const char *ntrip_str = "";
231
232 const char *dabplus_provider = 0;
233 char dabplus_provider_str[17] = "";
234
235 const char *user = "";
236 const char *password = "";
237
238 int outputmode = NTRIP1;
239
240 struct sockaddr_in casterRTP;
241 struct sockaddr_in local;
242 int client_port = 0;
243 int server_port = 0;
244 unsigned int session = 0;
245 socklen_t len = 0;
246 int i = 0;
247
248 char szSendBuffer[BUFSZ];
249 char authorization[SZ];
250 int nBufferBytes = 0;
251 char *dlim = " \r\n=";
252 char *token;
253 char *tok_buf[BUFSZ];
254
255 int reconnect_sec_max = 0;
256
257 setbuf(stdout, 0);
258 setbuf(stdin, 0);
259 setbuf(stderr, 0);
260
261 {
262 char *a;
263 int i = 2;
264 strcpy(revisionstr, "1.");
265 for (a = revisionstr + 11; *a && *a != ' '; ++a)
266 revisionstr[i++] = *a;
267 revisionstr[i] = 0;
268 i = 0;
269 for (a = datestr + 7; *a && *a != ' '; ++a)
270 datestr[i++] = *a;
271 datestr[i] = 0;
272 }
273
274 /* setup signal handler for CTRL+C */
275 setup_signal_handler(SIGINT, handle_sigint);
276#ifndef WINDOWSVERSION
277 /* setup signal handler for boken pipe */
278 setup_signal_handler(SIGPIPE, handle_sigpipe);
279 /* setup signal handler for timeout */
280 setup_signal_handler(SIGALRM, handle_alarm);
281 alarm(ALARMTIME);
282#else
283 /* winsock initialization */
284 WSADATA wsaData;
285 if (WSAStartup(MAKEWORD(1,1), &wsaData))
286 {
287 fprintf(stderr, "Could not init network access.\n");
288 return 20;
289 }
290#endif
291
292 /* get and check program arguments */
293 if (argc <= 1) {
294 usage(2, argv[0]);
295 exit(1);
296 }
297 while ((c = getopt(argc, argv,
298 "M:i:h:b:p:s:a:m:c:H:P:f:x:y:l:u:V:D:U:W:O:E:F:R:N:T:n:B")) != EOF) {
299 switch (c) {
300 case 'M': /*** InputMode ***/
301 if (!strcmp(optarg, "serial"))
302 inputmode = SERIAL;
303 else if (!strcmp(optarg, "tcpsocket"))
304 inputmode = TCPSOCKET;
305 else if (!strcmp(optarg, "file"))
306 inputmode = INFILE;
307 else if (!strcmp(optarg, "sisnet"))
308 inputmode = SISNET;
309 else if (!strcmp(optarg, "udpsocket"))
310 inputmode = UDPSOCKET;
311 else if (!strcmp(optarg, "ntrip1"))
312 inputmode = NTRIP1_IN;
313 else if (!strcmp(optarg, "ntrip2http"))
314 inputmode = NTRIP2_HTTP_IN;
315 else
316 inputmode = atoi(optarg);
317 if ((inputmode == 0) || (inputmode >= LAST)) {
318 fprintf(stderr, "ERROR: can't convert <%s> to a valid InputMode\n",
319 optarg);
320 usage(-1, argv[0]);
321 }
322 break;
323 case 'i': /* serial input device */
324 ttyport = optarg;
325 break;
326 case 'B': /* bind to incoming UDP stream */
327 bindmode = 1;
328 break;
329 case 'V': /* Sisnet data server version number */
330 if (!strcmp("3.0", optarg))
331 sisnet = 30;
332 else if (!strcmp("3.1", optarg))
333 sisnet = 31;
334 else if (!strcmp("2.1", optarg))
335 sisnet = 21;
336 else {
337 fprintf(stderr, "ERROR: unknown SISNeT version <%s>\n", optarg);
338 usage(-2, argv[0]);
339 }
340 break;
341 case 'b': /* serial input baud rate */
342 ttybaud = atoi(optarg);
343 if (ttybaud <= 1) {
344 fprintf(stderr,
345 "ERROR: can't convert <%s> to valid serial baud rate\n", optarg);
346 usage(1, argv[0]);
347 }
348 break;
349 case 'a': /* Destination caster address */
350 casterouthost = optarg;
351 break;
352 case 'p': /* Destination caster port */
353 casteroutport = atoi(optarg);
354 if (casteroutport <= 1 || casteroutport > 65535) {
355 fprintf(stderr,
356 "ERROR: can't convert <%s> to a valid HTTP server port\n",
357 optarg);
358 usage(1, argv[0]);
359 }
360 break;
361 case 'm': /* Destination caster mountpoint for stream upload */
362 mountpoint = optarg;
363 break;
364 case 's': /* File name for input data simulation from file */
365 filepath = optarg;
366 break;
367 case 'f': /* name of an initialization file */
368 initfile = optarg;
369 break;
370 case 'x': /* user ID to access incoming stream */
371 recvrid = optarg;
372 break;
373 case 'y': /* password to access incoming stream */
374 recvrpwd = optarg;
375 break;
376 case 'u': /* Sisnet data server user ID */
377 sisnetuser = optarg;
378 break;
379 case 'l': /* Sisnet data server password */
380 sisnetpassword = optarg;
381 break;
382 case 'c': /* DestinationCaster password for stream upload to mountpoint */
383 password = optarg;
384 break;
385 case 'H': /* Input host address*/
386 casterinhost = optarg;
387 break;
388 case 'P': /* Input port */
389 casterinport = atoi(optarg);
390 if (casterinport <= 1 || casterinport > 65535) {
391 fprintf(stderr, "ERROR: can't convert <%s> to a valid port number\n",
392 optarg);
393 usage(1, argv[0]);
394 }
395 break;
396 case 'D': /* Source caster mountpoint for stream input */
397 stream_name = optarg;
398 break;
399 case 'U': /* Source caster user ID for input stream access */
400 stream_user = optarg;
401 break;
402 case 'W': /* Source caster password for input stream access */
403 stream_password = optarg;
404 break;
405 case 'E': /* Proxy Server */
406 proxyhost = optarg;
407 break;
408 case 'F': /* Proxy port */
409 proxyport = atoi(optarg);
410 break;
411 case 'R': /* maximum delay between reconnect attempts in seconds */
412 reconnect_sec_max = atoi(optarg);
413 break;
414 case 'O': /* OutputMode */
415 outputmode = 0;
416 if (!strcmp(optarg, "n") || !strcmp(optarg, "ntrip1"))
417 outputmode = NTRIP1;
418 else if (!strcmp(optarg, "h") || !strcmp(optarg, "http"))
419 outputmode = HTTP;
420 else if (!strcmp(optarg, "r") || !strcmp(optarg, "rtsp"))
421 outputmode = RTSP;
422 else if (!strcmp(optarg, "u") || !strcmp(optarg, "udp"))
423 outputmode = UDP;
424 else if (!strcmp(optarg, "t") || !strcmp(optarg, "tdc"))
425 outputmode = TDC;
426 else
427 outputmode = atoi(optarg);
428 if ((outputmode == 0) || (outputmode >= END)) {
429 fprintf(stderr, "ERROR: can't convert <%s> to a valid OutputMode\n",
430 optarg);
431 usage(-1, argv[0]);
432 }
433 break;
434 case 'n': /* Destination caster user ID for stream upload to mountpoint */
435 user = optarg;
436 break;
437 case 'N': /* Ntrip-STR, optional for Ntrip Version 2.0 */
438 ntrip_str = optarg;
439 break;
440 case 'T':
441 dabplus_provider = optarg;
442 break;
443 case 'h': /* print help screen */
444 case '?':
445 usage(0, argv[0]);
446 break;
447 default:
448 usage(2, argv[0]);
449 break;
450 }
451 }
452
453 argc -= optind;
454 argv += optind;
455
456 /*** argument analysis ***/
457 if (argc > 0) {
458 fprintf(stderr, "ERROR: Extra args on command line: ");
459 for (; argc > 0; argc--) {
460 fprintf(stderr, " %s", *argv++);
461 }
462 fprintf(stderr, "\n");
463 usage(1, argv[0]); /* never returns */
464 }
465
466 if ((reconnect_sec_max > 0) && (reconnect_sec_max < 256)) {
467 fprintf(stderr,
468 "WARNING: maximum delay between reconnect attempts changed from %d to 256 seconds\n",
469 reconnect_sec_max);
470 reconnect_sec_max = 256;
471 }
472
473 if (!mountpoint && outputmode != TDC) {
474 fprintf(stderr, "ERROR: Missing mountpoint argument for stream upload\n");
475 exit(1);
476 }
477
478 if (outputmode == TDC) {
479 fprintf(stderr, "ERROR: DABPLUS server upload implementation is so far not completed\n\n");
480 exit(0);
481
482 mountpoint = NULL;
483 if (dabplus_provider) {
484 i = snprintf(dabplus_provider_str, 17, "%16s", dabplus_provider);
485 if ((i > 16) || (i < 0)) {
486 fprintf(stderr, "ERROR: DABPLUS provider name to long - length = %d (max: %d)\n", i, 16);
487 exit(0);
488 }
489 }
490 else {
491 fprintf(stderr, "ERROR: DABPLUS provider name required\n");
492 exit(0);
493 }
494 }
495
496 if (!password[0]) {
497 if (outputmode != TDC)
498 fprintf(stderr,
499 "WARNING: Missing password argument for stream upload - are you really sure?\n");
500 } else {
501 nBufferBytes += encode(authorization, sizeof(authorization), user,
502 password);
503 if (nBufferBytes > (int) sizeof(authorization)) {
504 fprintf(stderr, "ERROR: user ID and/or password too long: %d (%d)\n"
505 " user ID: %s \npassword: <%s>\n", nBufferBytes,
506 (int) sizeof(authorization), user, password);
507 exit(1);
508 }
509 }
510
511 if (stream_name && stream_user && !stream_password) {
512 fprintf(stderr, "WARNING: Missing password argument for stream download - are you really sure?\n");
513 }
514
515 /*** proxy server handling ***/
516 if (*proxyhost) {
517 if (outputmode == TDC) {
518 fprintf(stderr, "\nWARNING: TDC is not able to support proxy servers, try direct connection\n\n");
519 inhost = proxyhost;
520 inport = proxyport;
521 outhost = casterouthost;
522 outport = casteroutport;
523 } else {
524 outhost = inhost = proxyhost;
525 outport = inport = proxyport;
526 }
527 i = snprintf(szSendBuffer, sizeof(szSendBuffer), "http://%s:%d", casterouthost, casteroutport);
528 if ((i > SZ) || (i < 0)) {
529 fprintf(stderr,
530 "ERROR: Destination caster name/port to long - length = %d (max: %d)\n",
531 i, SZ);
532 exit(0);
533 } else {
534 strncpy(post_extension, szSendBuffer, (size_t) i);
535 strcpy(szSendBuffer, "");
536 i = snprintf(szSendBuffer, sizeof(szSendBuffer), ":%d", casteroutport);
537 strncpy(rtsp_extension, szSendBuffer, SZ);
538 strcpy(szSendBuffer, ""); i = 0;
539 }
540 i = snprintf(szSendBuffer, sizeof(szSendBuffer), "http://%s:%d", casterinhost, casterinport);
541 if ((i > SZ) || (i < 0)) {
542 fprintf(stderr,
543 "ERROR: Destination caster name/port to long - length = %d (max: %d)\n",
544 i, SZ);
545 exit(0);
546 } else {
547 strncpy(get_extension, szSendBuffer, (size_t) i);
548 strcpy(szSendBuffer, "");
549 i = 0;
550 }
551 } else {
552 outhost = casterouthost;
553 outport = casteroutport;
554 inhost = casterinhost;
555 inport = casterinport;
556 }
557
558 while (inputmode != LAST) {
559 int input_init = 1;
560 if (sigint_received)
561 break;
562 /*** InputMode handling ***/
563 switch (inputmode) {
564 case INFILE: {
565 if ((gps_file = open(filepath, O_RDONLY)) < 0) {
566 perror("ERROR: opening input file");
567 exit(1);
568 }
569#ifndef WINDOWSVERSION
570 /* set blocking inputmode in case it was not set
571 (seems to be sometimes for fifo's) */
572 fcntl(gps_file, F_SETFL, 0);
573#endif
574 printf("file input: file = %s\n", filepath);
575 }
576 break;
577 case SERIAL: /* open serial port */ {
578#ifndef WINDOWSVERSION
579 gps_serial = openserial(ttyport, 1, ttybaud);
580#else
581 gps_serial = openserial(ttyport, ttybaud);
582#endif
583 if (gps_serial == INVALID_HANDLE_VALUE)
584 exit(1);
585 printf("serial input: device = %s, speed = %d\n", ttyport, ttybaud);
586
587 if (initfile) {
588 char buffer[1024];
589 FILE *fh;
590 int i;
591
592 if ((fh = fopen(initfile, "r"))) {
593 while ((i = fread(buffer, 1, sizeof(buffer), fh)) > 0) {
594#ifndef WINDOWSVERSION
595 if ((write(gps_serial, buffer, i)) != i) {
596 perror("WARNING: sending init file");
597 input_init = 0;
598 break;
599 }
600#else
601 DWORD nWrite = -1;
602 if(!WriteFile(gps_serial, buffer, sizeof(buffer), &nWrite, NULL)) {
603 fprintf(stderr,"ERROR: sending init file \n");
604 input_init = 0;
605 break;
606 }
607 i = (int)nWrite;
608#endif
609 }
610 if (i < 0) {
611 perror("ERROR: reading init file");
612 reconnect_sec_max = 0;
613 input_init = 0;
614 break;
615 }
616 fclose(fh);
617 } else {
618 fprintf(stderr, "ERROR: can't read init file <%s>\n", initfile);
619 reconnect_sec_max = 0;
620 input_init = 0;
621 break;
622 }
623 }
624 }
625 break;
626 case TCPSOCKET:
627 case UDPSOCKET:
628 case SISNET:
629 case NTRIP1_IN:
630 case NTRIP2_HTTP_IN: {
631 if (inputmode == SISNET) {
632 if (!inhost)
633 inhost = SISNET_SERVER;
634 if (!inport)
635 inport = SISNET_PORT;
636 } else if (inputmode == NTRIP1_IN || inputmode == NTRIP2_HTTP_IN) {
637 if (!inport)
638 inport = NTRIP_PORT;
639 if (!inhost)
640 inhost = NTRIP_CASTER;
641 } else if ((inputmode == TCPSOCKET) || (inputmode == UDPSOCKET)) {
642 if (!inport)
643 inport = SERV_TCP_PORT;
644 if (!inhost)
645 inhost = SERV_HOST_ADDR;
646 }
647
648 if (!(he = gethostbyname(inhost))) {
649 fprintf(stderr, "ERROR: Input host <%s> unknown\n", inhost);
650 usage(-2, argv[0]);
651 }
652
653 if ((gps_socket = socket(AF_INET, inputmode == UDPSOCKET ? SOCK_DGRAM : SOCK_STREAM, 0)) == INVALID_SOCKET) {
654 fprintf(stderr,
655 "ERROR: can't create socket for incoming data stream\n");
656 exit(1);
657 }
658
659 memset((char*) &caster, 0x00, sizeof(caster));
660 if (!bindmode)
661 memcpy(&caster.sin_addr, he->h_addr, (size_t)he->h_length);
662 caster.sin_family = AF_INET;
663 caster.sin_port = htons(inport);
664
665 fprintf(stderr, "%s input: host = %s, port = %d, %s%s%s%s%s\n",
666 inputmode == NTRIP1_IN ? "ntrip1" :
667 inputmode == NTRIP2_HTTP_IN ? "ntrip2" :
668 inputmode == SISNET ? "sisnet" :
669 inputmode == TCPSOCKET ? "tcp socket" : "udp socket",
670 bindmode ? "127.0.0.1" : inet_ntoa(caster.sin_addr), inport,
671 stream_name ? "stream = " : "", stream_name ? stream_name : "",
672 initfile ? ", initfile = " : "", initfile ? initfile : "",
673 bindmode ? "binding mode" : "");
674
675 if (bindmode) {
676 if (bind(gps_socket, (struct sockaddr*) &caster, sizeof(caster))
677 < 0) {
678 fprintf(stderr, "ERROR: can't bind input to port %d\n", inport);
679 reconnect_sec_max = 0;
680 input_init = 0;
681 break;
682 }
683 } /* connect to input-caster or proxy server*/
684 else if (connect(gps_socket, (struct sockaddr*) &caster, sizeof(caster))
685 < 0) {
686 fprintf(stderr, "WARNING: can't connect input to %s at port %d\n",
687 inet_ntoa(caster.sin_addr), inport);
688 input_init = 0;
689 break;
690 }
691
692 /* input from NTRIP caster */
693 int init = 0;
694 /* set socket buffer size */
695 setsockopt(gps_socket, SOL_SOCKET, SO_SNDBUF, (const char*) &size, sizeof(const char*));
696 /* input from Ntrip caster*/
697 nBufferBytes=snprintf(szSendBuffer, sizeof(szSendBuffer) - 40,/* leave some space for login */
698 "GET %s/%s HTTP/1.1\r\n"
699 "Host: %s\r\n"
700 "%s"
701 "User-Agent: %s/%s\r\n"
702 //"%s%s%s" // nmea
703 "Connection: close%s",
704 get_extension,
705 stream_name ? stream_name : "",
706 casterinhost,
707 inputmode == NTRIP1_IN ? "" : "Ntrip-Version: Ntrip/2.0\r\n",
708 AGENTSTRING, revisionstr,
709 //args.nmea ? "Ntrip-GGA: " : "", args.nmea ? args.nmea : "", args.nmea ? "\r\n" : "", // TODO: add argument
710 (*stream_user || *stream_password) ? "\r\nAuthorization: Basic " : "");
711 /* second check for old glibc */
712 if (nBufferBytes > (int) sizeof(szSendBuffer) - 40 || nBufferBytes < 0) {
713 fprintf(stderr, "ERROR: Source caster request too long\n");
714 input_init = 0;
715 reconnect_sec_max = 0;
716 break;
717 }
718 nBufferBytes += encode(szSendBuffer + nBufferBytes, sizeof(szSendBuffer) - nBufferBytes - 4,
719 stream_user, stream_password);
720 if (nBufferBytes > (int) sizeof(szSendBuffer) - 4) {
721 fprintf(stderr, "ERROR: Source caster user ID and/or password too long\n");
722 input_init = 0;
723 reconnect_sec_max = 0;
724 break;
725 }
726 szSendBuffer[nBufferBytes++] = '\r';
727 szSendBuffer[nBufferBytes++] = '\n';
728 szSendBuffer[nBufferBytes++] = '\r';
729 szSendBuffer[nBufferBytes++] = '\n';
730 // fprintf(stdout, "%s\n", szSendBuffer);
731 if ((send(gps_socket, szSendBuffer, (size_t) nBufferBytes, 0)) != nBufferBytes) {
732 fprintf(stderr, "WARNING: could not send Source caster request\n");
733 input_init = 0;
734 break;
735 }
736 nBufferBytes = 0;
737 /* check Source caster's response */
738 while (!init && nBufferBytes < (int) sizeof(szSendBuffer) &&
739 (nBufferBytes += recv(gps_socket, szSendBuffer, sizeof(szSendBuffer) - nBufferBytes, 0)) > 0) {
740 if( nBufferBytes > 17 && !strstr(szSendBuffer, "ICY 200 OK") && /* case 'proxy & ntrip 1.0 caster' */
741 (!strncmp(szSendBuffer, "HTTP/1.1 200 OK\r\n", 17) ||
742 !strncmp(szSendBuffer, "HTTP/1.0 200 OK\r\n", 17)) ) {
743 const char *datacheck = "Content-Type: gnss/data\r\n";
744 const char *chunkycheck = "Transfer-Encoding: chunked\r\n";
745 int l = strlen(datacheck)-1;
746 int j=0;
747 for(i = 0; j != l && i < nBufferBytes-l; ++i) {
748 for(j = 0; j < l && szSendBuffer[i+j] == datacheck[j]; ++j)
749 ;
750 }
751 if(i == nBufferBytes-l) {
752 fprintf(stderr, "No 'Content-Type: gnss/data' found\n");
753 input_init = 0;
754 }
755 l = strlen(chunkycheck)-1;
756 j=0;
757 for(i = 0; j != l && i < nBufferBytes-l; ++i) {
758 for(j = 0; j < l && szSendBuffer[i+j] == chunkycheck[j]; ++j)
759 ;
760 }
761 if(i < nBufferBytes-l)
762 chunkymode = 1;
763 init = 1;
764 }
765 else if (strstr(szSendBuffer, "\r\n")) {
766 if (!strstr(szSendBuffer, "ICY 200 OK")) {
767 int k;
768 fprintf(stderr, "ERROR: could not get requested data from Source caster: ");
769 for (k = 0; k < nBufferBytes && szSendBuffer[k] != '\n' && szSendBuffer[k] != '\r'; ++k) {
770 fprintf(stderr, "%c", isprint(szSendBuffer[k]) ? szSendBuffer[k] : '.');
771 }
772 fprintf(stderr, "\n");
773 if (!strstr(szSendBuffer, "SOURCETABLE 200 OK")) {
774 reconnect_sec_max = 0;
775 }
776 input_init = 0;
777 break;
778 } else {// eventuell auskommentieren!
779 init = 1;
780 }
781 }
782
783 }
784 /* end input from NTRIP caster */
785
786 if (initfile && inputmode != SISNET) {
787 char buffer[1024];
788 FILE *fh;
789 int i;
790
791 if ((fh = fopen(initfile, "r"))) {
792 while ((i = fread(buffer, 1, sizeof(buffer), fh)) > 0) {
793 if ((send(gps_socket, buffer, (size_t) i, 0)) != i) {
794 perror("WARNING: sending init file");
795 input_init = 0;
796 break;
797 }
798 }
799 if (i < 0) {
800 perror("ERROR: reading init file");
801 reconnect_sec_max = 0;
802 input_init = 0;
803 break;
804 }
805 fclose(fh);
806 } else {
807 fprintf(stderr, "ERROR: can't read init file <%s>\n", initfile);
808 reconnect_sec_max = 0;
809 input_init = 0;
810 break;
811 }
812 }
813 }
814 if (inputmode == SISNET) {
815 int i, j;
816 char buffer[1024];
817
818 i = snprintf(buffer, sizeof(buffer),
819 sisnet >= 30 ? "AUTH,%s,%s\r\n" : "AUTH,%s,%s", sisnetuser,
820 sisnetpassword);
821 if ((send(gps_socket, buffer, (size_t) i, 0)) != i) {
822 perror("WARNING: sending authentication for SISNeT data server");
823 input_init = 0;
824 break;
825 }
826 i = sisnet >= 30 ? 7 : 5;
827 if ((j = recv(gps_socket, buffer, i, 0)) != i
828 && strncmp("*AUTH", buffer, 5)) {
829 fprintf(stderr, "WARNING: SISNeT connect failed:");
830 for (i = 0; i < j; ++i) {
831 if (buffer[i] != '\r' && buffer[i] != '\n') {
832 fprintf(stderr, "%c", isprint(buffer[i]) ? buffer[i] : '.');
833 }
834 }
835 fprintf(stderr, "\n");
836 input_init = 0;
837 break;
838 }
839 if (sisnet >= 31) {
840 if ((send(gps_socket, "START\r\n", 7, 0)) != i) {
841 perror("WARNING: sending Sisnet start command");
842 input_init = 0;
843 break;
844 }
845 }
846 }
847 /*** receiver authentication ***/
848 if (recvrid && recvrpwd
849 && ((inputmode == TCPSOCKET) || (inputmode == UDPSOCKET))) {
850 if (strlen(recvrid) > (BUFSZ - 3)) {
851 fprintf(stderr, "ERROR: Receiver ID too long\n");
852 reconnect_sec_max = 0;
853 input_init = 0;
854 break;
855 } else {
856 fprintf(stderr, "Sending user ID for receiver...\n");
857 nBufferBytes = recv(gps_socket, szSendBuffer, BUFSZ, 0);
858 strcpy(szSendBuffer, recvrid);
859 strcat(szSendBuffer, "\r\n");
860 if (send(gps_socket, szSendBuffer, strlen(szSendBuffer),
861 MSG_DONTWAIT) < 0) {
862 perror("WARNING: sending user ID for receiver");
863 input_init = 0;
864 break;
865 }
866 }
867
868 if (strlen(recvrpwd) > (BUFSZ - 3)) {
869 fprintf(stderr, "ERROR: Receiver password too long\n");
870 reconnect_sec_max = 0;
871 input_init = 0;
872 break;
873 } else {
874 fprintf(stderr, "Sending user password for receiver...\n");
875 nBufferBytes = recv(gps_socket, szSendBuffer, BUFSZ, 0);
876 strcpy(szSendBuffer, recvrpwd);
877 strcat(szSendBuffer, "\r\n");
878 if (send(gps_socket, szSendBuffer, strlen(szSendBuffer),
879 MSG_DONTWAIT) < 0) {
880 perror("WARNING: sending user password for receiver");
881 input_init = 0;
882 break;
883 }
884 }
885 }
886 break;
887 default:
888 usage(-1, argv[0]);
889 break;
890 }
891
892 /* ----- main part ----- */
893 int output_init = 1, fallback = 0;
894
895 while ((input_init) && (output_init)) {
896#ifndef WINDOWSVERSION
897 if ((sigalarm_received) || (sigint_received) || (sigpipe_received))
898 break;
899#else
900 if((sigalarm_received) || (sigint_received)) break;
901#endif
902
903 if (!(he = gethostbyname(outhost))) {
904 fprintf(stderr,
905 "ERROR: Destination caster, server or proxy host <%s> unknown\n",
906 outhost);
907 close_session(casterouthost, mountpoint, session, rtsp_extension, 0);
908 usage(-2, argv[0]);
909 }else {fprintf(stderr,
910 "Destination caster, server or proxy host <%s> \n",
911 outhost);}
912
913 /* create socket */
914 if ((socket_tcp = socket(AF_INET, (outputmode == UDP ? SOCK_DGRAM : SOCK_STREAM), 0)) == INVALID_SOCKET) {
915 perror("ERROR: tcp socket");
916 reconnect_sec_max = 0;
917 break;
918 }
919
920 memset((char*) &caster, 0x00, sizeof(caster));
921 memcpy(&caster.sin_addr, he->h_addr, (size_t)he->h_length);
922 caster.sin_family = AF_INET;
923 caster.sin_port = htons(outport);
924
925 /* connect to Destination caster, server or proxy host */
926 fprintf(stderr, "caster|server output: host = %s, port = %d, mountpoint = %s"
927 ", mode = %s\n\n", inet_ntoa(caster.sin_addr), outport, mountpoint,
928 outputmode == NTRIP1 ? "ntrip1" :
929 outputmode == HTTP ? "http" :
930 outputmode == UDP ? "udp" :
931 outputmode == RTSP ? "rtsp" : "tdc");
932
933 if (connect(socket_tcp, (struct sockaddr*) &caster, sizeof(caster)) < 0) {
934 fprintf(stderr, "WARNING: can't connect output to %s at port %d\n",
935 inet_ntoa(caster.sin_addr), outport);
936 break;
937 }
938
939 /*** OutputMode handling ***/
940 switch (outputmode) {
941 case UDP: {
942 unsigned int session;
943 char rtpbuf[1526];
944 int i = 12, j;
945
946 udp_init = time(0);
947 srand(udp_init);
948 session = rand();
949 udp_tim = rand();
950 udp_seq = rand();
951
952 rtpbuf[0] = (2 << 6);
953 /* padding, extension, csrc are empty */
954 rtpbuf[1] = 97;
955 /* marker is empty */
956 rtpbuf[2] = (udp_seq >> 8) & 0xFF;
957 rtpbuf[3] = (udp_seq) & 0xFF;
958 rtpbuf[4] = (udp_tim >> 24) & 0xFF;
959 rtpbuf[5] = (udp_tim >> 16) & 0xFF;
960 rtpbuf[6] = (udp_tim >> 8) & 0xFF;
961 rtpbuf[7] = (udp_tim) & 0xFF;
962 /* sequence and timestamp are empty */
963 rtpbuf[8] = (session >> 24) & 0xFF;
964 rtpbuf[9] = (session >> 16) & 0xFF;
965 rtpbuf[10] = (session >> 8) & 0xFF;
966 rtpbuf[11] = (session) & 0xFF;
967 ++udp_seq;
968
969 j = snprintf(rtpbuf + i, sizeof(rtpbuf) - i - 40, /* leave some space for login */
970 "POST /%s HTTP/1.1\r\n"
971 "Host: %s\r\n"
972 "Ntrip-Version: Ntrip/2.0\r\n"
973 "User-Agent: %s/%s\r\n"
974 "Authorization: Basic %s%s%s\r\n"
975 "Connection: close\r\n"
976 "Transfer-Encoding: chunked\r\n\r\n", mountpoint, casterouthost,
977 AGENTSTRING, revisionstr, authorization,
978 ntrip_str ?
979 (outputmode == NTRIP1 ? "\r\nSTR: " : "\r\nNtrip-STR: ") : "",
980 ntrip_str);
981 i += j;
982 if (i > (int) sizeof(rtpbuf) - 40 || j < 0) /* second check for old glibc */
983 {
984 fprintf(stderr, "Requested data too long\n");
985 reconnect_sec_max = 0;
986 output_init = 0;
987 break;
988 } else {
989 rtpbuf[i++] = '\r';
990 rtpbuf[i++] = '\n';
991 rtpbuf[i++] = '\r';
992 rtpbuf[i++] = '\n';
993
994 if (send(socket_tcp, rtpbuf, i, 0) != i) {
995 perror("Could not send UDP packet");
996 reconnect_sec_max = 0;
997 output_init = 0;
998 break;
999 } else {
1000 int stop = 0;
1001 int numbytes;
1002 if ((numbytes = recv(socket_tcp, rtpbuf, sizeof(rtpbuf) - 1, 0))
1003 > 0) {
1004 /* we don't expect message longer than 1513, so we cut the last
1005 byte for security reasons to prevent buffer overrun */
1006 rtpbuf[numbytes] = 0;
1007 if (numbytes > 17 + 12
1008 && (!strncmp(rtpbuf + 12, "HTTP/1.1 200 OK\r\n", 17)
1009 || !strncmp(rtpbuf + 12, "HTTP/1.0 200 OK\r\n", 17))) {
1010 const char *sessioncheck = "session: ";
1011 int l = strlen(sessioncheck) - 1;
1012 int j = 0;
1013 for (i = 12; j != l && i < numbytes - l; ++i) {
1014 for (j = 0;
1015 j < l && tolower(rtpbuf[i + j]) == sessioncheck[j]; ++j)
1016 ;
1017 }
1018 if (i != numbytes - l) /* found a session number */
1019 {
1020 i += l;
1021 session = 0;
1022 while (i < numbytes && rtpbuf[i] >= '0' && rtpbuf[i] <= '9')
1023 session = session * 10 + rtpbuf[i++] - '0';
1024 if (rtpbuf[i] != '\r') {
1025 fprintf(stderr, "Could not extract session number\n");
1026 stop = 1;
1027 }
1028 }
1029 } else {
1030 int k;
1031 fprintf(stderr, "Could not access mountpoint: ");
1032 for (k = 12;
1033 k < numbytes && rtpbuf[k] != '\n' && rtpbuf[k] != '\r';
1034 ++k) {
1035 fprintf(stderr, "%c", isprint(rtpbuf[k]) ? rtpbuf[k] : '.');
1036 }
1037 fprintf(stderr, "\n");
1038 stop = 1;
1039 }
1040 }
1041 if (!stop) {
1042 send_receive_loop(socket_tcp, outputmode, NULL, 0, session, chunkymode);
1043 input_init = output_init = 0;
1044 /* send connection close always to allow nice session closing */
1045 udp_tim += (time(0) - udp_init) * 1000000 / TIME_RESOLUTION;
1046 rtpbuf[0] = (2 << 6);
1047 /* padding, extension, csrc are empty */
1048 rtpbuf[1] = 98;
1049 /* marker is empty */
1050 rtpbuf[2] = (udp_seq >> 8) & 0xFF;
1051 rtpbuf[3] = (udp_seq) & 0xFF;
1052 rtpbuf[4] = (udp_tim >> 24) & 0xFF;
1053 rtpbuf[5] = (udp_tim >> 16) & 0xFF;
1054 rtpbuf[6] = (udp_tim >> 8) & 0xFF;
1055 rtpbuf[7] = (udp_tim) & 0xFF;
1056 /* sequence and timestamp are empty */
1057 rtpbuf[8] = (session >> 24) & 0xFF;
1058 rtpbuf[9] = (session >> 16) & 0xFF;
1059 rtpbuf[10] = (session >> 8) & 0xFF;
1060 rtpbuf[11] = (session) & 0xFF;
1061
1062 send(socket_tcp, rtpbuf, 12, 0); /* cleanup */
1063 } else {
1064 reconnect_sec_max = 600;
1065 output_init = 0;
1066 }
1067 }
1068 }
1069 }
1070 break;
1071 case NTRIP1: /*** OutputMode Ntrip Version 1.0 ***/
1072 fallback = 0;
1073 nBufferBytes = snprintf(szSendBuffer, sizeof(szSendBuffer),
1074 "SOURCE %s %s/%s\r\n"
1075 "Source-Agent: %s/%s\r\n\r\n", password, post_extension,
1076 mountpoint, AGENTSTRING, revisionstr);
1077 if ((nBufferBytes > (int) sizeof(szSendBuffer))
1078 || (nBufferBytes < 0)) {
1079 fprintf(stderr, "ERROR: Destination caster request to long\n");
1080 reconnect_sec_max = 0;
1081 output_init = 0;
1082 break;
1083 }
1084 if (!send_to_caster(szSendBuffer, socket_tcp, nBufferBytes)) {
1085 output_init = 0;
1086 break;
1087 }
1088 /* check Destination caster's response */
1089 nBufferBytes = recv(socket_tcp, szSendBuffer, sizeof(szSendBuffer), 0);
1090 szSendBuffer[nBufferBytes] = '\0';
1091 if (!strstr(szSendBuffer, "OK")) {
1092 char *a;
1093 fprintf(stderr,
1094 "ERROR: Destination caster's or Proxy's reply is not OK: ");
1095 for (a = szSendBuffer; *a && *a != '\n' && *a != '\r'; ++a) {
1096 fprintf(stderr, "%.1s", isprint(*a) ? a : ".");
1097 }
1098 fprintf(stderr, "\n");
1099 if ((strstr(szSendBuffer, "ERROR - Bad Password"))
1100 || (strstr(szSendBuffer, "400 Bad Request")))
1101 reconnect_sec_max = 0;
1102 output_init = 0;
1103 break;
1104 }
1105#ifndef NDEBUG
1106 else {
1107 fprintf(stderr, "Destination caster response:\n%s\n", szSendBuffer);
1108 }
1109#endif
1110 send_receive_loop(socket_tcp, outputmode, NULL, 0, 0, chunkymode);
1111 input_init = output_init = 0;
1112 break;
1113 case HTTP: /*** Ntrip-Version 2.0 HTTP/1.1 ***/
1114 nBufferBytes = snprintf(szSendBuffer, sizeof(szSendBuffer),
1115 "POST %s/%s HTTP/1.1\r\n"
1116 "Host: %s\r\n"
1117 "Ntrip-Version: Ntrip/2.0\r\n"
1118 "User-Agent: %s/%s\r\n"
1119 "Authorization: Basic %s%s%s\r\n"
1120 "Connection: close\r\n"
1121 "Transfer-Encoding: chunked\r\n\r\n", post_extension,
1122 mountpoint, casterouthost, AGENTSTRING, revisionstr,
1123 authorization, ntrip_str ? "\r\nNtrip-STR: " : "", ntrip_str);
1124 if ((nBufferBytes > (int) sizeof(szSendBuffer))
1125 || (nBufferBytes < 0)) {
1126 fprintf(stderr, "ERROR: Destination caster request to long\n");
1127 reconnect_sec_max = 0;
1128 output_init = 0;
1129 break;
1130 }
1131 if (!send_to_caster(szSendBuffer, socket_tcp, nBufferBytes)) {
1132 output_init = 0;
1133 break;
1134 }
1135 /* check Destination caster's response */
1136 nBufferBytes = recv(socket_tcp, szSendBuffer, sizeof(szSendBuffer), 0);
1137 szSendBuffer[nBufferBytes] = '\0';
1138 if (!strstr(szSendBuffer, "HTTP/1.1 200 OK")) {
1139 char *a;
1140 fprintf(stderr, "ERROR: Destination caster's%s reply is not OK: ",
1141 *proxyhost ? " or Proxy's" : "");
1142 for (a = szSendBuffer; *a && *a != '\n' && *a != '\r'; ++a) {
1143 fprintf(stderr, "%.1s", isprint(*a) ? a : ".");
1144 }
1145 fprintf(stderr, "\n");
1146 /* fallback if necessary */
1147 if (!strstr(szSendBuffer, "Ntrip-Version: Ntrip/2.0\r\n")) {
1148 fprintf(stderr,
1149 " Ntrip Version 2.0 not implemented at Destination caster"
1150 " <%s>%s%s%s\n%s\n"
1151 "ntripserver falls back to Ntrip Version 1.0\n\n",
1152 casterouthost, *proxyhost ? " or Proxy <" : "", proxyhost,
1153 *proxyhost ? ">" : "",
1154 *proxyhost ?
1155 " or HTTP/1.1 not implemented at Proxy\n" : "");
1156 close_session(casterouthost, mountpoint, session, rtsp_extension, 1);
1157 outputmode = NTRIP1;
1158 break;
1159 } else if ((strstr(szSendBuffer, "HTTP/1.1 401 Unauthorized"))
1160 || (strstr(szSendBuffer, "501 Not Implemented"))) {
1161 reconnect_sec_max = 0;
1162 }
1163 output_init = 0;
1164 break;
1165 }
1166#ifndef NDEBUG
1167 else {
1168 fprintf(stderr, "Destination caster response:\n%s\n", szSendBuffer);
1169 }
1170#endif
1171 send_receive_loop(socket_tcp, outputmode, NULL, 0, 0, chunkymode);
1172 input_init = output_init = 0;
1173 break;
1174 case RTSP: /*** Ntrip-Version 2.0 RTSP / RTP ***/
1175 if ((socket_udp = socket(AF_INET, SOCK_DGRAM, 0)) == INVALID_SOCKET) {
1176 perror("ERROR: udp socket");
1177 exit(4);
1178 }
1179 /* fill structure with local address information for UDP */
1180 memset(&local, 0, sizeof(local));
1181 local.sin_family = AF_INET;
1182 local.sin_port = htons(0);
1183 local.sin_addr.s_addr = htonl(INADDR_ANY);
1184 len = (socklen_t) sizeof(local);
1185 /* bind() in order to get a random RTP client_port */
1186 if ((bind(socket_udp, (struct sockaddr*) &local, len)) < 0) {
1187 perror("ERROR: udp bind");
1188 reconnect_sec_max = 0;
1189 output_init = 0;
1190 break;
1191 }
1192 if ((getsockname(socket_udp, (struct sockaddr*) &local, &len))
1193 != -1) {
1194 client_port = (unsigned int) ntohs(local.sin_port);
1195 } else {
1196 perror("ERROR: getsockname(localhost)");
1197 reconnect_sec_max = 0;
1198 output_init = 0;
1199 break;
1200 }
1201 nBufferBytes = snprintf(szSendBuffer, sizeof(szSendBuffer),
1202 "SETUP rtsp://%s%s/%s RTSP/1.0\r\n"
1203 "CSeq: %d\r\n"
1204 "Ntrip-Version: Ntrip/2.0\r\n"
1205 "Ntrip-Component: Ntripserver\r\n"
1206 "User-Agent: %s/%s\r\n"
1207 "Transport: RTP/GNSS;unicast;client_port=%u\r\n"
1208 "Authorization: Basic %s%s%s\r\n\r\n", casterouthost,
1209 rtsp_extension, mountpoint, udp_cseq++, AGENTSTRING, revisionstr,
1210 client_port, authorization, ntrip_str ? "\r\nNtrip-STR: " : "",
1211 ntrip_str);
1212 if ((nBufferBytes > (int) sizeof(szSendBuffer))
1213 || (nBufferBytes < 0)) {
1214 fprintf(stderr, "ERROR: Destination caster request to long\n");
1215 reconnect_sec_max = 0;
1216 output_init = 0;
1217 break;
1218 }
1219 if (!send_to_caster(szSendBuffer, socket_tcp, nBufferBytes)) {
1220 output_init = 0;
1221 break;
1222 }
1223 while ((nBufferBytes = recv(socket_tcp, szSendBuffer,
1224 sizeof(szSendBuffer), 0)) > 0) {
1225 /* check Destination caster's response */
1226 szSendBuffer[nBufferBytes] = '\0';
1227 if (!strstr(szSendBuffer, "RTSP/1.0 200 OK")) {
1228 char *a;
1229 fprintf(stderr, "ERROR: Destination caster's%s reply is not OK: ",
1230 *proxyhost ? " or Proxy's" : "");
1231 for (a = szSendBuffer; *a && *a != '\n' && *a != '\r'; ++a) {
1232 fprintf(stderr, "%c", isprint(*a) ? *a : '.');
1233 }
1234 fprintf(stderr, "\n");
1235 /* fallback if necessary */
1236 if (strncmp(szSendBuffer, "RTSP", 4) != 0) {
1237 if (strstr(szSendBuffer, "Ntrip-Version: Ntrip/2.0\r\n")) {
1238 fprintf(stderr,
1239 " RTSP not implemented at Destination caster <%s>%s%s%s\n\n"
1240 "ntripserver falls back to Ntrip Version 2.0 in TCP/IP"
1241 " mode\n\n", casterouthost,
1242 *proxyhost ? " or Proxy <" : "", proxyhost,
1243 *proxyhost ? ">" : "");
1244 close_session(casterouthost, mountpoint, session,
1245 rtsp_extension, 1);
1246 outputmode = HTTP;
1247 fallback = 1;
1248 break;
1249 } else {
1250 fprintf(stderr,
1251 " Ntrip-Version 2.0 not implemented at Destination caster"
1252 "<%s>%s%s%s\n%s"
1253 " or RTSP/1.0 not implemented at Destination caster%s\n\n"
1254 "ntripserver falls back to Ntrip Version 1.0\n\n",
1255 casterouthost, *proxyhost ? " or Proxy <" : "", proxyhost,
1256 *proxyhost ? ">" : "",
1257 *proxyhost ?
1258 " or HTTP/1.1 not implemented at Proxy\n" : "",
1259 *proxyhost ? " or Proxy" : "");
1260 close_session(casterouthost, mountpoint, session,
1261 rtsp_extension, 1);
1262 outputmode = NTRIP1;
1263 fallback = 1;
1264 break;
1265 }
1266 } else if ((strstr(szSendBuffer, "RTSP/1.0 401 Unauthorized"))
1267 || (strstr(szSendBuffer, "RTSP/1.0 501 Not Implemented"))) {
1268 reconnect_sec_max = 0;
1269 }
1270 output_init = 0;
1271 break;
1272 }
1273#ifndef NDEBUG
1274 else {
1275 fprintf(stderr, "Destination caster response:\n%s\n", szSendBuffer);
1276 }
1277#endif
1278 if ((strstr(szSendBuffer, "RTSP/1.0 200 OK\r\n"))
1279 && (strstr(szSendBuffer, "CSeq: 1\r\n"))) {
1280 for (token = strtok(szSendBuffer, dlim); token != NULL; token =
1281 strtok(NULL, dlim)) {
1282 tok_buf[i] = token;
1283 i++;
1284 }
1285 session = atoi(tok_buf[6]);
1286 server_port = atoi(tok_buf[10]);
1287 nBufferBytes = snprintf(szSendBuffer, sizeof(szSendBuffer),
1288 "RECORD rtsp://%s%s/%s RTSP/1.0\r\n"
1289 "CSeq: %d\r\n"
1290 "Session: %u\r\n"
1291 "\r\n", casterouthost, rtsp_extension, mountpoint,
1292 udp_cseq++, session);
1293 if ((nBufferBytes >= (int) sizeof(szSendBuffer))
1294 || (nBufferBytes < 0)) {
1295 fprintf(stderr, "ERROR: Destination caster request to long\n");
1296 reconnect_sec_max = 0;
1297 output_init = 0;
1298 break;
1299 }
1300 if (!send_to_caster(szSendBuffer, socket_tcp, nBufferBytes)) {
1301 output_init = 0;
1302 break;
1303 }
1304 } else if ((strstr(szSendBuffer, "RTSP/1.0 200 OK\r\n"))
1305 && (strstr(szSendBuffer, "CSeq: 2\r\n"))) {
1306 /* fill structure with caster address information for UDP */
1307 memset(&casterRTP, 0, sizeof(casterRTP));
1308 casterRTP.sin_family = AF_INET;
1309 casterRTP.sin_port = htons(((uint16_t) server_port));
1310 if ((he = gethostbyname(outhost)) == NULL) {
1311 fprintf(stderr, "ERROR: Destination caster unknown\n");
1312 reconnect_sec_max = 0;
1313 output_init = 0;
1314 break;
1315 } else {
1316 memcpy((char*) &casterRTP.sin_addr.s_addr, he->h_addr_list[0],
1317 (size_t) he->h_length);
1318 }
1319 len = (socklen_t) sizeof(casterRTP);
1320 send_receive_loop(socket_udp, outputmode,
1321 (struct sockaddr*) &casterRTP, (socklen_t) len, session, chunkymode);
1322 break;
1323 } else {
1324 break;
1325 }
1326 }
1327 input_init = output_init = 0;
1328 break;
1329 case TDC:
1330 fallback = 0;
1331 szSendBuffer[0] = 0x28;
1332 szSendBuffer[1] = 0x11;
1333 szSendBuffer[2] = 0x19;
1334 szSendBuffer[3] = 0x69;
1335 strncpy(szSendBuffer + 4, dabplus_provider_str, 16);
1336 szSendBuffer[20] = 0; // mot
1337 nBufferBytes = strlen(szSendBuffer);
1338 if ((nBufferBytes > 20) || (nBufferBytes < 0)) {
1339 fprintf(stderr, "ERROR: Destination server request to long\n");
1340 reconnect_sec_max = 0;
1341 output_init = 0;
1342 break;
1343 }
1344 if (!send_to_caster(szSendBuffer, socket_tcp, nBufferBytes)) {
1345 output_init = 0;
1346 break;
1347 }
1348 /* check Destination server's response
1349 in case of a unidirectional connection muxd will close the connection
1350 if an error occurs without transmitting any status information
1351 */
1352 send_receive_loop(socket_tcp, outputmode, NULL, 0, 0, chunkymode);
1353 input_init = output_init = 0;
1354 break;
1355 }
1356 }
1357 close_session(casterouthost, mountpoint, session, rtsp_extension, 0);
1358 if ((reconnect_sec_max || fallback) && !sigint_received)
1359 reconnect_sec = reconnect(reconnect_sec, reconnect_sec_max);
1360 else
1361 inputmode = LAST;
1362 }
1363 return 0;
1364}
1365
1366static void send_receive_loop(sockettype sock, int outmode,
1367 struct sockaddr *pcasterRTP, socklen_t length, unsigned int rtpssrc,
1368 int chunkymode) {
1369 int nodata = 0;
1370 char buffer[BUFSZ] = { 0 };
1371 char sisnetbackbuffer[200];
1372 char szSendBuffer[BUFSZ] = "";
1373 int nBufferBytes = 0;
1374 int remainChunk = 0;
1375
1376 /* RTSP / RTP Mode */
1377 int isfirstpacket = 1;
1378 struct timeval now;
1379 struct timeval last = { 0, 0 };
1380 long int sendtimediff;
1381 int rtpseq = 0;
1382 int rtptime = 0;
1383 time_t laststate = time(0);
1384
1385 if (outmode == UDP) {
1386 rtptime = time(0);
1387#ifdef WINDOWSVERSION
1388 u_long blockmode = 1;
1389 if(ioctlsocket(socket_tcp, FIONBIO, &blockmode))
1390#else /* WINDOWSVERSION */
1391 if (fcntl(socket_tcp, F_SETFL, O_NONBLOCK) < 0)
1392#endif /* WINDOWSVERSION */
1393 {
1394 fprintf(stderr, "Could not set nonblocking mode\n");
1395 return;
1396 }
1397 } else if (outmode == RTSP) {
1398#ifdef WINDOWSVERSION
1399 u_long blockmode = 1;
1400 if(ioctlsocket(socket_tcp, FIONBIO, &blockmode))
1401#else /* WINDOWSVERSION */
1402 if (fcntl(socket_tcp, F_SETFL, O_NONBLOCK) < 0)
1403#endif /* WINDOWSVERSION */
1404 {
1405 fprintf(stderr, "Could not set nonblocking mode\n");
1406 return;
1407 }
1408 }
1409
1410 /* data transmission */
1411 fprintf(stderr, "transfering data ...\n");
1412 int send_recv_success = 0;
1413#ifdef WINDOWSVERSION
1414 time_t nodata_begin = 0, nodata_current = 0;
1415#endif
1416 while (1) {
1417 if (send_recv_success < 3)
1418 send_recv_success++;
1419 if (!nodata) {
1420#ifndef WINDOWSVERSION
1421 alarm(ALARMTIME);
1422#else
1423 time(&nodata_begin);
1424#endif
1425 } else {
1426 nodata = 0;
1427#ifdef WINDOWSVERSION
1428 time(&nodata_current);
1429 if(difftime(nodata_current, nodata_begin) >= ALARMTIME) {
1430 sigalarm_received = 1;
1431 fprintf(stderr, "ERROR: more than %d seconds no activity\n", ALARMTIME);
1432 }
1433#endif
1434 }
1435 /* signal handling*/
1436#ifdef WINDOWSVERSION
1437 if((sigalarm_received) || (sigint_received)) break;
1438#else
1439 if ((sigalarm_received) || (sigint_received) || (sigpipe_received))
1440 break;
1441#endif
1442 if (!nBufferBytes) {
1443 if (inputmode == SISNET && sisnet <= 30) {
1444 int i;
1445 /* a somewhat higher rate than 1 second to get really each block */
1446 /* means we need to skip double blocks sometimes */
1447 struct timeval tv = { 0, 700000 };
1448 select(0, 0, 0, 0, &tv);
1449 memcpy(sisnetbackbuffer, buffer, sizeof(sisnetbackbuffer));
1450 i = (sisnet >= 30 ? 5 : 3);
1451 if ((send(gps_socket, "MSG\r\n", i, 0)) != i) {
1452 perror("WARNING: sending SISNeT data request failed");
1453 return;
1454 }
1455 }
1456 /***********************/
1457 /* receiving data */
1458 /***********************/
1459
1460 /* INFILE */
1461 if (inputmode == INFILE)
1462 nBufferBytes = read(gps_file, buffer, sizeof(buffer));
1463
1464 /* SERIAL */
1465 else if (inputmode == SERIAL) {
1466#ifndef WINDOWSVERSION
1467 nBufferBytes = read(gps_serial, buffer, sizeof(buffer));
1468#else
1469 DWORD nRead = 0;
1470 if(!ReadFile(gps_serial, buffer, sizeof(buffer), &nRead, NULL))
1471 {
1472 fprintf(stderr,"ERROR: reading serial input failed\n");
1473 return;
1474 }
1475 nBufferBytes = (int)nRead;
1476#endif
1477 }
1478
1479 /* ALL OTHER MODES */
1480 else
1481#ifdef WINDOWSVERSION
1482 nBufferBytes = recv(gps_socket, buffer, sizeof(buffer), 0);
1483#else
1484 nBufferBytes = read(gps_socket, buffer, sizeof(buffer));
1485#endif
1486 if (!nBufferBytes) {
1487 fprintf(stderr, "WARNING: no data received from input\n");
1488 nodata = 1;
1489#ifndef WINDOWSVERSION
1490 sleep(3);
1491#else
1492 Sleep(3*1000);
1493#endif
1494 continue;
1495 } else if ((nBufferBytes < 0) && (!sigint_received)) {
1496 perror("WARNING: reading input failed");
1497 return;
1498 }
1499 /* we can compare the whole buffer, as the additional bytes
1500 remain unchanged */
1501 if (inputmode == SISNET && sisnet <= 30
1502 && !memcmp(sisnetbackbuffer, buffer, sizeof(sisnetbackbuffer))) {
1503 nBufferBytes = 0;
1504 }
1505 }
1506 if (nBufferBytes < 0)
1507 return;
1508
1509 if (chunkymode) {
1510 int cstop = 0;
1511 int pos = 0;
1512 int chunksize = 0;
1513 int totalbytes = 0;
1514 int nChunkBytes = 0;
1515 char chunkBytes[BUFSZ];
1516
1517 long i;
1518 while (!sigint_received && !cstop && pos < nBufferBytes) {
1519 switch (chunkymode) {
1520 case 1: /* reading number starts */
1521 chunksize = 0;
1522 ++chunkymode; /* no break */
1523 break;
1524 case 2: /* during reading number */
1525 i = buffer[pos++];
1526 if (i >= '0' && i <= '9')
1527 chunksize = chunksize * 16 + i - '0';
1528 else if (i >= 'a' && i <= 'f')
1529 chunksize = chunksize * 16 + i - 'a' + 10;
1530 else if (i >= 'A' && i <= 'F')
1531 chunksize = chunksize * 16 + i - 'A' + 10;
1532 else if (i == '\r')
1533 ++chunkymode;
1534 else if (i == ';')
1535 chunkymode = 5;
1536 else
1537 cstop = 1;
1538 break;
1539 case 3: /* scanning for return */
1540 if (buffer[pos++] == '\n')
1541 chunkymode = chunksize ? 4 : 1;
1542 else
1543 cstop = 1;
1544 break;
1545 case 4: /* output data */
1546 i = nBufferBytes - pos;
1547 if (i > chunksize) {
1548 i = chunksize;
1549 }
1550 if (nChunkBytes <= nBufferBytes) {
1551 memcpy(chunkBytes + nChunkBytes, buffer + pos, (size_t) i);
1552 nChunkBytes += i;
1553 }
1554 totalbytes += i;
1555 chunksize -= i;
1556 pos += i;
1557 if (!chunksize)
1558 chunkymode = 1;
1559 break;
1560 case 5:
1561 if (i == '\r')
1562 chunkymode = 3;
1563 break;
1564 }
1565 }
1566 if (cstop) {
1567 fprintf(stderr, "Error in chunky transfer encoding\n");
1568 return;
1569 }
1570 else {
1571 if (nChunkBytes <= nBufferBytes) {
1572 strcpy(buffer, "");
1573 memcpy(buffer, chunkBytes, (size_t) nChunkBytes);
1574 nBufferBytes = nChunkBytes;
1575 }
1576 }
1577 }
1578
1579 /*****************/
1580 /* send data */
1581 /*****************/
1582 if ((nBufferBytes) && (outmode == NTRIP1)) {
1583 int i;
1584 if ((i = send(sock, buffer, (size_t) nBufferBytes, MSG_DONTWAIT)) != nBufferBytes) {
1585 if (i < 0) {
1586 if (errno != EAGAIN) {
1587 perror("WARNING: could not send data to Destination caster");
1588 return;
1589 }
1590 } else if (i) {
1591 memmove(buffer, buffer + i, (size_t) (nBufferBytes - i));
1592 nBufferBytes -= i;
1593 }
1594 } else {
1595 nBufferBytes = 0;
1596 }
1597 } else if ((nBufferBytes) && (outmode == UDP)) {
1598 char rtpbuf[1592];
1599 int i;
1600 int ct = time(0);
1601 udp_tim += (ct - udp_init) * 1000000 / TIME_RESOLUTION;
1602 udp_init = ct;
1603 rtpbuf[0] = (2 << 6);
1604 rtpbuf[1] = 96;
1605 rtpbuf[2] = (udp_seq >> 8) & 0xFF;
1606 rtpbuf[3] = (udp_seq) & 0xFF;
1607 rtpbuf[4] = (udp_tim >> 24) & 0xFF;
1608 rtpbuf[5] = (udp_tim >> 16) & 0xFF;
1609 rtpbuf[6] = (udp_tim >> 8) & 0xFF;
1610 rtpbuf[7] = (udp_tim) & 0xFF;
1611 rtpbuf[8] = (rtpssrc >> 24) & 0xFF;
1612 rtpbuf[9] = (rtpssrc >> 16) & 0xFF;
1613 rtpbuf[10] = (rtpssrc >> 8) & 0xFF;
1614 rtpbuf[11] = (rtpssrc) & 0xFF;
1615 ++udp_seq;
1616 memcpy(rtpbuf + 12, buffer, nBufferBytes);
1617 if ((i = send(socket_tcp, rtpbuf, (size_t) nBufferBytes + 12, MSG_DONTWAIT)) != nBufferBytes + 12) {
1618 if (errno != EAGAIN) {
1619 perror("WARNING: could not send data to Destination caster");
1620 return;
1621 }
1622 } else
1623 nBufferBytes = 0;
1624 i = recv(socket_tcp, rtpbuf, sizeof(rtpbuf), 0);
1625 if (i >= 12 && (unsigned char) rtpbuf[0] == (2 << 6)
1626 && rtpssrc
1627 == (unsigned int) (((unsigned char) rtpbuf[8] << 24)
1628 + ((unsigned char) rtpbuf[9] << 16)
1629 + ((unsigned char) rtpbuf[10] << 8)
1630 + (unsigned char) rtpbuf[11])) {
1631 if (rtpbuf[1] == 96)
1632 rtptime = time(0);
1633 else if (rtpbuf[1] == 98) {
1634 fprintf(stderr, "Connection end\n");
1635 return;
1636 }
1637 } else if (time(0) > rtptime + 60) {
1638 fprintf(stderr, "Timeout\n");
1639 return;
1640 }
1641 }
1642 /*** Ntrip-Version 2.0 HTTP/1.1 ***/
1643 else if ((nBufferBytes) && (outmode == HTTP)) {
1644 if (!remainChunk) {
1645 int nChunkBytes = snprintf(szSendBuffer, sizeof(szSendBuffer), "%x\r\n", nBufferBytes);
1646 send(sock, szSendBuffer, nChunkBytes, 0);
1647 remainChunk = nBufferBytes;
1648 }
1649 int i = send(sock, buffer, (size_t) remainChunk, MSG_DONTWAIT);
1650 if (i < 0) {
1651 if (errno != EAGAIN) {
1652 perror("WARNING: could not send data to Destination caster");
1653 return;
1654 }
1655 } else if (i) {
1656 memmove(buffer, buffer + i, (size_t) (nBufferBytes - i));
1657 nBufferBytes -= i;
1658 remainChunk -= i;
1659 } else {
1660 nBufferBytes = 0;
1661 remainChunk = 0;
1662 }
1663 if (!remainChunk)
1664 send(sock, "\r\n", strlen("\r\n"), 0);
1665 }
1666 /*** Ntrip-Version 2.0 RTSP(TCP) / RTP(UDP) ***/
1667 else if ((nBufferBytes) && (outmode == RTSP)) {
1668 time_t ct;
1669 int r;
1670 char rtpbuffer[BUFSZ + 12];
1671 int i, j;
1672 gettimeofday(&now, NULL);
1673 /* RTP data packet generation*/
1674 if (isfirstpacket) {
1675 rtpseq = rand();
1676 rtptime = rand();
1677 last = now;
1678 isfirstpacket = 0;
1679 } else {
1680 ++rtpseq;
1681 sendtimediff = (((now.tv_sec - last.tv_sec) * 1000000)
1682 + (now.tv_usec - last.tv_usec));
1683 rtptime += sendtimediff / TIME_RESOLUTION;
1684 }
1685 rtpbuffer[0] = (RTP_VERSION << 6);
1686 /* padding, extension, csrc are empty */
1687 rtpbuffer[1] = 96;
1688 /* marker is empty */
1689 rtpbuffer[2] = rtpseq >> 8;
1690 rtpbuffer[3] = rtpseq;
1691 rtpbuffer[4] = rtptime >> 24;
1692 rtpbuffer[5] = rtptime >> 16;
1693 rtpbuffer[6] = rtptime >> 8;
1694 rtpbuffer[7] = rtptime;
1695 rtpbuffer[8] = rtpssrc >> 24;
1696 rtpbuffer[9] = rtpssrc >> 16;
1697 rtpbuffer[10] = rtpssrc >> 8;
1698 rtpbuffer[11] = rtpssrc;
1699 for (j = 0; j < nBufferBytes; j++) {
1700 rtpbuffer[12 + j] = buffer[j];
1701 }
1702 last.tv_sec = now.tv_sec;
1703 last.tv_usec = now.tv_usec;
1704 if ((i = sendto(sock, rtpbuffer, 12 + nBufferBytes, 0, pcasterRTP, length))
1705 != (nBufferBytes + 12)) {
1706 if (i < 0) {
1707 if (errno != EAGAIN) {
1708 perror("WARNING: could not send data to Destination caster");
1709 return;
1710 }
1711 } else if (i) {
1712 memmove(buffer, buffer + (i - 12),
1713 (size_t) (nBufferBytes - (i - 12)));
1714 nBufferBytes -= i - 12;
1715 }
1716 } else {
1717 nBufferBytes = 0;
1718 }
1719 ct = time(0);
1720 if (ct - laststate > 15) {
1721 i = snprintf(buffer, sizeof(buffer),
1722 "GET_PARAMETER rtsp://%s%s/%s RTSP/1.0\r\n"
1723 "CSeq: %d\r\n"
1724 "Session: %u\r\n"
1725 "\r\n", casterouthost, rtsp_extension, mountpoint, udp_cseq++,
1726 rtpssrc);
1727 if (i > (int) sizeof(buffer) || i < 0) {
1728 fprintf(stderr, "Requested data too long\n");
1729 return;
1730 } else if (send(socket_tcp, buffer, (size_t) i, 0) != i) {
1731 perror("send");
1732 return;
1733 }
1734 laststate = ct;
1735 }
1736 /* ignore RTSP server replies */
1737 if ((r = recv(socket_tcp, buffer, sizeof(buffer), 0)) < 0) {
1738#ifdef WINDOWSVERSION
1739 if(WSAGetLastError() != WSAEWOULDBLOCK)
1740#else /* WINDOWSVERSION */
1741 if (errno != EAGAIN)
1742#endif /* WINDOWSVERSION */
1743 {
1744 fprintf(stderr, "Control connection closed\n");
1745 return;
1746 }
1747 } else if (!r) {
1748 fprintf(stderr, "Control connection read error\n");
1749 return;
1750 }
1751 }
1752 else if ((nBufferBytes) && (outmode == TDC)) {
1753
1754 }
1755 if (send_recv_success == 3)
1756 reconnect_sec = 1;
1757 }
1758 return;
1759}
1760
1761/********************************************************************
1762 * openserial
1763 *
1764 * Open the serial port with the given device name and configure it for
1765 * reading NMEA data from a GPS receiver.
1766 *
1767 * Parameters:
1768 * tty : pointer to : A zero-terminated string containing the device
1769 * unsigned char name of the appropriate serial port.
1770 * blocksz : integer : Block size for port I/O (ifndef WINDOWSVERSION)
1771 * baud : integer : Baud rate for port I/O
1772 *
1773 * Return Value:
1774 * The function returns a file descriptor for the opened port if successful.
1775 * The function returns -1 / INVALID_HANDLE_VALUE in the event of an error.
1776 *
1777 * Remarks:
1778 *
1779 ********************************************************************/
1780#ifndef WINDOWSVERSION
1781static int openserial(const char *tty, int blocksz, int baud) {
1782 struct termios termios;
1783
1784 /*** opening the serial port ***/
1785 gps_serial = open(tty, O_RDWR | O_NONBLOCK | O_EXLOCK);
1786 if (gps_serial < 0) {
1787 perror("ERROR: opening serial connection");
1788 return (-1);
1789 }
1790
1791 /*** configuring the serial port ***/
1792 if (tcgetattr(gps_serial, &termios) < 0) {
1793 perror("ERROR: get serial attributes");
1794 return (-1);
1795 }
1796 termios.c_iflag = 0;
1797 termios.c_oflag = 0; /* (ONLRET) */
1798 termios.c_cflag = CS8 | CLOCAL | CREAD;
1799 termios.c_lflag = 0;
1800 {
1801 int cnt;
1802 for (cnt = 0; cnt < NCCS; cnt++)
1803 termios.c_cc[cnt] = -1;
1804 }
1805 termios.c_cc[VMIN] = blocksz;
1806 termios.c_cc[VTIME] = 2;
1807
1808#if (B4800 != 4800)
1809 /* Not every system has speed settings equal to absolute speed value. */
1810 switch (baud) {
1811 case 300:
1812 baud = B300;
1813 break;
1814 case 1200:
1815 baud = B1200;
1816 break;
1817 case 2400:
1818 baud = B2400;
1819 break;
1820 case 4800:
1821 baud = B4800;
1822 break;
1823 case 9600:
1824 baud = B9600;
1825 break;
1826 case 19200:
1827 baud = B19200;
1828 break;
1829 case 38400:
1830 baud = B38400;
1831 break;
1832#ifdef B57600
1833 case 57600:
1834 baud = B57600;
1835 break;
1836#endif
1837#ifdef B115200
1838 case 115200:
1839 baud = B115200;
1840 break;
1841#endif
1842#ifdef B230400
1843 case 230400:
1844 baud = B230400;
1845 break;
1846#endif
1847 default:
1848 fprintf(stderr, "WARNING: Baud settings not useful, using 19200\n");
1849 baud = B19200;
1850 break;
1851 }
1852#endif
1853
1854 if (cfsetispeed(&termios, baud) != 0) {
1855 perror("ERROR: setting serial speed with cfsetispeed");
1856 return (-1);
1857 }
1858 if (cfsetospeed(&termios, baud) != 0) {
1859 perror("ERROR: setting serial speed with cfsetospeed");
1860 return (-1);
1861 }
1862 if (tcsetattr(gps_serial, TCSANOW, &termios) < 0) {
1863 perror("ERROR: setting serial attributes");
1864 return (-1);
1865 }
1866 if (fcntl(gps_serial, F_SETFL, 0) == -1) {
1867 perror("WARNING: setting blocking inputmode failed");
1868 }
1869 return (gps_serial);
1870}
1871#else
1872static HANDLE openserial(const char * tty, int baud) {
1873 char compath[15] = "";
1874
1875 snprintf(compath, sizeof(compath), "\\\\.\\%s", tty);
1876 if((gps_serial = CreateFile(compath, GENERIC_WRITE|GENERIC_READ
1877 , 0, 0, OPEN_EXISTING, 0, 0)) == INVALID_HANDLE_VALUE) {
1878 fprintf(stderr, "ERROR: opening serial connection\n");
1879 return (INVALID_HANDLE_VALUE);
1880 }
1881
1882 DCB dcb;
1883 memset(&dcb, 0, sizeof(dcb));
1884 char str[100];
1885 snprintf(str,sizeof(str),
1886 "baud=%d parity=N data=8 stop=1 xon=off octs=off rts=off",
1887 baud);
1888
1889 COMMTIMEOUTS ct = {1000, 1, 0, 0, 0};
1890
1891 if(!BuildCommDCB(str, &dcb)) {
1892 fprintf(stderr, "ERROR: get serial attributes\n");
1893 return (INVALID_HANDLE_VALUE);
1894 }
1895 else if(!SetCommState(gps_serial, &dcb)) {
1896 fprintf(stderr, "ERROR: set serial attributes\n");
1897 return (INVALID_HANDLE_VALUE);
1898 }
1899 else if(!SetCommTimeouts(gps_serial, &ct)) {
1900 fprintf(stderr, "ERROR: set serial timeouts\n");
1901 return (INVALID_HANDLE_VALUE);
1902 }
1903
1904 return (gps_serial);
1905}
1906#endif
1907
1908/********************************************************************
1909 * usage
1910 *
1911 * Send a usage message to standard error and quit the program.
1912 *
1913 * Parameters:
1914 * None.
1915 *
1916 * Return Value:
1917 * The function does not return a value.
1918 *
1919 * Remarks:
1920 *
1921 *********************************************************************/
1922#ifdef __GNUC__
1923__attribute__ ((noreturn))
1924#endif /* __GNUC__ */
1925void usage(int rc, char *name) {
1926 fprintf(stderr, "Version %s (%s) GPL" COMPILEDATE "\nUsage:\n%s [OPTIONS]\n",
1927 revisionstr, datestr, name);
1928 fprintf(stderr, "PURPOSE\n");
1929 fprintf(stderr,
1930 " The purpose of this program is to pick up a GNSS data stream (Input, Source)\n");
1931 fprintf(stderr, " from either\n\n");
1932 fprintf(stderr, " 1. a Serial port, or\n");
1933 fprintf(stderr, " 2. an IP server, or\n");
1934 fprintf(stderr, " 3. a File, or\n");
1935 fprintf(stderr, " 4. a SISNeT Data Server, or\n");
1936 fprintf(stderr, " 5. a UDP server, or\n");
1937 fprintf(stderr, " 6. an NTRIP Version 1.0 Caster\n");
1938 fprintf(stderr, " 7. an NTRIP Version 2.0 Caster in HTTP mode \n\n");
1939 fprintf(stderr,
1940 " and forward that incoming stream (Output, Destination) to either\n\n");
1941 fprintf(stderr, " - an NTRIP Version 1.0 Caster, or\n");
1942 fprintf(stderr, " - an NTRIP Version 2.0 Caster via TCP/IP or RTSP/RTP, or \n");
1943 fprintf(stderr, " - an DABPLUS Content Server via TCP/IP and TDC \n\n\n");
1944 fprintf(stderr, "OPTIONS\n");
1945 fprintf(stderr, " -h|? print this help screen\n\n");
1946 fprintf(stderr, " -E <ProxyHost> Proxy server host name or address, required i.e. when\n");
1947 fprintf(stderr, " running the program in a proxy server protected LAN,\n");
1948 fprintf(stderr, " optional\n");
1949 fprintf(stderr, " -F <ProxyPort> Proxy server IP port, required i.e. when running\n");
1950 fprintf(stderr, " the program in a proxy server protected LAN, optional\n");
1951 fprintf(stderr, " -R <maxDelay> Reconnect mechanism with maximum delay between reconnect\n");
1952 fprintf(stderr, " attemts in seconds, default: no reconnect activated,\n");
1953 fprintf(stderr, " optional\n\n");
1954 fprintf(stderr, " -M <InputMode> Sets the input mode (1 = Serial Port, 2 = IP server,\n");
1955 fprintf(stderr, " 3 = File, 4 = SISNeT Data Server, 5 = UDP server, 6 = NTRIP1 Caster, 7 = NTRIP2 Caster in HTTP mode),\n");
1956 fprintf(stderr, " mandatory\n\n");
1957 fprintf(stderr, " <InputMode> = 1 (Serial Port):\n");
1958 fprintf(stderr, " -i <Device> Serial input device, default: %s, mandatory if\n", ttyport);
1959 fprintf(stderr, " <InputMode>=1\n");
1960 fprintf(stderr, " -b <BaudRate> Serial input baud rate, default: 19200 bps, mandatory\n");
1961 fprintf(stderr, " if <InputMode>=1\n");
1962 fprintf(stderr, " -f <InitFile> Name of initialization file to be send to input device,\n");
1963 fprintf(stderr, " optional\n\n");
1964 fprintf(stderr, " <InputMode> = 2|5 (IP port | UDP port):\n");
1965 fprintf(stderr, " -H <ServerHost> Input host name or address, default: 127.0.0.1,\n");
1966 fprintf(stderr, " mandatory if <InputMode> = 2|5\n");
1967 fprintf(stderr, " -P <ServerPort> Input port, default: 1025, mandatory if <InputMode>= 2|5\n");
1968 fprintf(stderr, " -f <ServerFile> Name of initialization file to be send to server,\n");
1969 fprintf(stderr, " optional\n");
1970 fprintf(stderr, " -x <ServerUser> User ID to access incoming stream, optional\n");
1971 fprintf(stderr, " -y <ServerPass> Password, to access incoming stream, optional\n");
1972 fprintf(stderr, " -B Bind to incoming UDP stream, optional for <InputMode> = 5\n\n");
1973 fprintf(stderr, " <InputMode> = 3 (File):\n");
1974 fprintf(stderr, " -s <File> File name to simulate stream by reading data from (log)\n");
1975 fprintf(stderr, " file, default is %s, mandatory for <InputMode> = 3\n\n", filepath);
1976 fprintf(stderr, " <InputMode> = 4 (SISNeT Data Server):\n");
1977 fprintf(stderr, " -H <SisnetHost> SISNeT Data Server name or address,\n");
1978 fprintf(stderr, " default: 131.176.49.142, mandatory if <InputMode> = 4\n");
1979 fprintf(stderr, " -P <SisnetPort> SISNeT Data Server port, default: 7777, mandatory if\n");
1980 fprintf(stderr, " <InputMode> = 4\n");
1981 fprintf(stderr, " -u <SisnetUser> SISNeT Data Server user ID, mandatory if <InputMode> = 4\n");
1982 fprintf(stderr, " -l <SisnetPass> SISNeT Data Server password, mandatory if <InputMode> = 4\n");
1983 fprintf(stderr, " -V <SisnetVers> SISNeT Data Server Version number, options are 2.1, 3.0\n");
1984 fprintf(stderr, " or 3.1, default: 3.1, mandatory if <InputMode> = 4\n\n");
1985 fprintf(stderr, " <InputMode> = 6|7 (NTRIP Version 1.0|2.0 Caster):\n");
1986 fprintf(stderr, " -H <SourceHost> Source caster name or address, default: 127.0.0.1,\n");
1987 fprintf(stderr, " mandatory if <InputMode> = 6|7\n");
1988 fprintf(stderr, " -P <SourcePort> Source caster port, default: 2101, mandatory if\n");
1989 fprintf(stderr, " <InputMode> = 6|7\n");
1990 fprintf(stderr, " -D <SourceMount> Source caster mountpoint for stream input, mandatory if\n");
1991 fprintf(stderr, " <InputMode> = 6|7\n");
1992 fprintf(stderr, " -U <SourceUser> Source caster user Id for input stream access, mandatory\n");
1993 fprintf(stderr, " for protected streams if <InputMode> = 6|7\n");
1994 fprintf(stderr, " -W <SourcePass> Source caster password for input stream access, mandatory\n");
1995 fprintf(stderr, " for protected streams if <InputMode> = 6|7\n\n");
1996 fprintf(stderr, " -O <OutputMode> Sets output mode for communication with destination caster / server\n");
1997 fprintf(stderr, " 1 = http: NTRIP Version 2.0 Caster in TCP/IP mode\n");
1998 fprintf(stderr, " 2 = rtsp: NTRIP Version 2.0 Caster in RTSP/RTP mode\n");
1999 fprintf(stderr, " 3 = ntrip1: NTRIP Version 1.0 Caster\n");
2000 fprintf(stderr, " 4 = udp: NTRIP Version 2.0 Caster in Plain UDP mode\n");
2001 fprintf(stderr, " 5 = tdc: DABPLUS Content Server in TDC mode\n\n\n");
2002 fprintf(stderr, " Defaults to NTRIP1.0, but will change to 2.0 in future versions\n");
2003 fprintf(stderr, " Note that the program automatically falls back from mode rtsp to mode http and\n");
2004 fprintf(stderr, " further to mode ntrip1 if necessary.\n\n");
2005 fprintf(stderr, " -a <DestHost> Destination caster name or address, default: 127.0.0.1,\n");
2006 fprintf(stderr, " mandatory\n");
2007 fprintf(stderr, " -p <DestPort> Destination caster port, default: 2101,\n");
2008 fprintf(stderr, " mandatory\n");
2009 fprintf(stderr, " -m <DestMount> Destination caster mountpoint for stream upload,\n");
2010 fprintf(stderr, " only for NTRIP destination casters, mandatory\n");
2011 fprintf(stderr, " -n <DestUser> Destination caster user ID for stream upload to mountpoint,\n");
2012 fprintf(stderr, " only for NTRIP Version 2.0 destination casters, mandatory\n");
2013 fprintf(stderr, " -c <DestPass> Destination caster password for stream upload to mountpoint,\n");
2014 fprintf(stderr, " only for NTRIP destination casters, mandatory\n");
2015 fprintf(stderr, " -N <STR-record> Sourcetable STR-record\n");
2016 fprintf(stderr, " optional for NTRIP Version 2.0 in RTSP/RTP and TCP/IP mode\n\n");
2017 fprintf(stderr, " -T <DAB+provider> DAB+ provider name, not longer than 16 char, mandatory for \n");
2018 fprintf(stderr, " upload to DABPLUS Content Server in TDC mode\n");
2019 exit(rc);
2020} /* usage */
2021
2022/********************************************************************/
2023/* signal handling */
2024/********************************************************************/
2025#ifdef __GNUC__
2026static void handle_sigint(int sig __attribute__((__unused__)))
2027#else /* __GNUC__ */
2028static void handle_sigint(int sig)
2029#endif /* __GNUC__ */
2030{
2031 sigint_received = 1;
2032 fprintf(stderr, "WARNING: SIGINT received - ntripserver terminates\n");
2033}
2034
2035#ifndef WINDOWSVERSION
2036#ifdef __GNUC__
2037static void handle_alarm(int sig __attribute__((__unused__)))
2038#else /* __GNUC__ */
2039static void handle_alarm(int sig)
2040#endif /* __GNUC__ */
2041{
2042 sigalarm_received = 1;
2043 fprintf(stderr, "ERROR: more than %d seconds no activity\n", ALARMTIME);
2044}
2045
2046#ifdef __GNUC__
2047static void handle_sigpipe(int sig __attribute__((__unused__)))
2048#else /* __GNUC__ */
2049static void handle_sigpipe(int sig)
2050#endif /* __GNUC__ */
2051{
2052 sigpipe_received = 1;
2053}
2054#endif /* WINDOWSVERSION */
2055
2056static void setup_signal_handler(int sig, void (*handler)(int)) {
2057#if _POSIX_VERSION > 198800L
2058 struct sigaction action;
2059
2060 action.sa_handler = handler;
2061 sigemptyset(&(action.sa_mask));
2062 sigaddset(&(action.sa_mask), sig);
2063 action.sa_flags = 0;
2064 sigaction(sig, &action, 0);
2065#else
2066 signal(sig, handler);
2067#endif
2068 return;
2069} /* setupsignal_handler */
2070
2071/********************************************************************
2072 * base64-encoding *
2073 *******************************************************************/
2074static const char encodingTable[64] = { 'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H',
2075 'I', 'J', 'K', 'L', 'M', 'N', 'O', 'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W',
2076 'X', 'Y', 'Z', 'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', 'k', 'l',
2077 'm', 'n', 'o', 'p', 'q', 'r', 's', 't', 'u', 'v', 'w', 'x', 'y', 'z', '0',
2078 '1', '2', '3', '4', '5', '6', '7', '8', '9', '+', '/' };
2079
2080/* does not buffer overrun, but breaks directly after an error */
2081/* returns the number of required bytes */
2082static int encode(char *buf, int size, const char *user, const char *pwd) {
2083 unsigned char inbuf[3];
2084 char *out = buf;
2085 int i, sep = 0, fill = 0, bytes = 0;
2086
2087 while (*user || *pwd) {
2088 i = 0;
2089 while (i < 3 && *user)
2090 inbuf[i++] = *(user++);
2091 if (i < 3 && !sep) {
2092 inbuf[i++] = ':';
2093 ++sep;
2094 }
2095 while (i < 3 && *pwd)
2096 inbuf[i++] = *(pwd++);
2097 while (i < 3) {
2098 inbuf[i++] = 0;
2099 ++fill;
2100 }
2101 if (out - buf < size - 1)
2102 *(out++) = encodingTable[(inbuf[0] & 0xFC) >> 2];
2103 if (out - buf < size - 1)
2104 *(out++) = encodingTable[((inbuf[0] & 0x03) << 4)
2105 | ((inbuf[1] & 0xF0) >> 4)];
2106 if (out - buf < size - 1) {
2107 if (fill == 2)
2108 *(out++) = '=';
2109 else
2110 *(out++) = encodingTable[((inbuf[1] & 0x0F) << 2)
2111 | ((inbuf[2] & 0xC0) >> 6)];
2112 }
2113 if (out - buf < size - 1) {
2114 if (fill >= 1)
2115 *(out++) = '=';
2116 else
2117 *(out++) = encodingTable[inbuf[2] & 0x3F];
2118 }
2119 bytes += 4;
2120 }
2121 if (out - buf < size)
2122 *out = 0;
2123 return bytes;
2124}/* base64 Encoding */
2125
2126/********************************************************************
2127 * send message to caster *
2128 *********************************************************************/
2129static int send_to_caster(char *input, sockettype socket, int input_size) {
2130 int send_error = 1;
2131
2132 if ((send(socket, input, (size_t) input_size, 0)) != input_size) {
2133 fprintf(stderr,
2134 "WARNING: could not send full header to Destination caster\n");
2135 send_error = 0;
2136 }
2137#ifndef NDEBUG
2138 else {
2139 fprintf(stderr, "\nDestination caster request:\n");
2140 fprintf(stderr, "%s\n", input);
2141 }
2142#endif
2143 return send_error;
2144}/* send_to_caster */
2145
2146/********************************************************************
2147 * reconnect *
2148 *********************************************************************/
2149int reconnect(int rec_sec, int rec_sec_max) {
2150 fprintf(stderr, "reconnect in <%d> seconds\n\n", rec_sec);
2151 rec_sec *= 2;
2152 if (rec_sec > rec_sec_max)
2153 rec_sec = rec_sec_max;
2154#ifndef WINDOWSVERSION
2155 sleep(rec_sec);
2156 sigpipe_received = 0;
2157#else
2158 Sleep(rec_sec*1000);
2159#endif
2160 sigalarm_received = 0;
2161 return rec_sec;
2162} /* reconnect */
2163
2164/********************************************************************
2165 * close session *
2166 *********************************************************************/
2167static void close_session(const char *caster_addr, const char *mountpoint,
2168 int session, char *rtsp_ext, int fallback) {
2169 int size_send_buf;
2170 char send_buf[BUFSZ];
2171
2172 if (!fallback) {
2173 if ((gps_socket != INVALID_SOCKET)
2174 && ((inputmode == TCPSOCKET) || (inputmode == UDPSOCKET)
2175 || (inputmode == NTRIP1_IN) || (inputmode == NTRIP2_HTTP_IN)
2176 || (inputmode == SISNET))) {
2177 if (closesocket(gps_socket) == -1) {
2178 perror("ERROR: close input device ");
2179 exit(0);
2180 } else {
2181 gps_socket = -1;
2182#ifndef NDEBUG
2183 fprintf(stderr, "close input device: successful\n");
2184#endif
2185 }
2186 } else if ((gps_serial != INVALID_HANDLE_VALUE) && (inputmode == SERIAL)) {
2187#ifndef WINDOWSVERSION
2188 if (close(gps_serial) == INVALID_HANDLE_VALUE) {
2189 perror("ERROR: close input device ");
2190 exit(0);
2191 }
2192#else
2193 if(!CloseHandle(gps_serial))
2194 {
2195 fprintf(stderr, "ERROR: close input device ");
2196 exit(0);
2197 }
2198#endif
2199 else {
2200 gps_serial = INVALID_HANDLE_VALUE;
2201#ifndef NDEBUG
2202 fprintf(stderr, "close input device: successful\n");
2203#endif
2204 }
2205 } else if ((gps_file != -1) && (inputmode == INFILE)) {
2206 if (close(gps_file) == -1) {
2207 perror("ERROR: close input device ");
2208 exit(0);
2209 } else {
2210 gps_file = -1;
2211#ifndef NDEBUG
2212 fprintf(stderr, "close input device: successful\n");
2213#endif
2214 }
2215 }
2216 }
2217
2218 if (socket_udp != INVALID_SOCKET) {
2219 if (udp_cseq > 2) {
2220 size_send_buf = snprintf(send_buf, sizeof(send_buf),
2221 "TEARDOWN rtsp://%s%s/%s RTSP/1.0\r\n"
2222 "CSeq: %d\r\n"
2223 "Session: %u\r\n"
2224 "\r\n", caster_addr, rtsp_ext, mountpoint, udp_cseq++, session);
2225 if ((size_send_buf >= (int) sizeof(send_buf)) || (size_send_buf < 0)) {
2226 fprintf(stderr, "ERROR: Destination caster request to long\n");
2227 exit(0);
2228 }
2229 send_to_caster(send_buf, socket_tcp, size_send_buf);
2230 strcpy(send_buf, "");
2231 size_send_buf = recv(socket_tcp, send_buf, sizeof(send_buf), 0);
2232 send_buf[size_send_buf] = '\0';
2233#ifndef NDEBUG
2234 fprintf(stderr, "Destination caster response:\n%s", send_buf);
2235#endif
2236 }
2237 if (closesocket(socket_udp) == -1) {
2238 perror("ERROR: close udp socket");
2239 exit(0);
2240 } else {
2241 socket_udp = -1;
2242#ifndef NDEBUG
2243 fprintf(stderr, "close udp socket: successful\n");
2244#endif
2245 }
2246 }
2247
2248 if (socket_tcp != INVALID_SOCKET) {
2249 if (closesocket(socket_tcp) == -1) {
2250 perror("ERROR: close tcp socket");
2251 exit(0);
2252 } else {
2253 socket_tcp = -1;
2254#ifndef NDEBUG
2255 fprintf(stderr, "close tcp socket: successful\n");
2256#endif
2257 }
2258 }
2259} /* close_session */
Note: See TracBrowser for help on using the repository browser.