rtklib_stream.h

Go to the documentation of this file.

/*!
 * \file rtklib_stream.h
 * \brief streaming functions
 * \authors <ul>
 *          <li> 2007-2013, T. Takasu
 *          <li> 2017, Javier Arribas
 *          <li> 2017, Carles Fernandez
 *          </ul>
 *
 * This is a derived work from RTKLIB http://www.rtklib.com/
 * The original source code at https://github.com/tomojitakasu/RTKLIB is
 * released under the BSD 2-clause license with an additional exclusive clause
 * that does not apply here. This additional clause is reproduced below:
 *
 * " The software package includes some companion executive binaries or shared
 * libraries necessary to execute APs on Windows. These licenses succeed to the
 * original ones of these software. "
 *
 * Neither the executive binaries nor the shared libraries are required by, used
 * or included in GNSS-SDR.
 *
 * -----------------------------------------------------------------------------
 * Copyright (C) 2007-2013, T. Takasu
 * Copyright (C) 2017, Javier Arribas
 * Copyright (C) 2017, Carles Fernandez
 * All rights reserved.
 *
 * SPDX-License-Identifier: BSD-2-Clause
 *
 *-----------------------------------------------------------------------------*/

#ifndef GNSS_SDR_RTKLIB_STREAM_H
#define GNSS_SDR_RTKLIB_STREAM_H

#include "rtklib.h"

/* constants -----------------------------------------------------------------*/

#define TINTACT 200       /* period for stream active (ms) */
#define SERIBUFFSIZE 4096 /* serial buffer size (bytes) */
#define TIMETAGH_LEN 64   /* time tag file header length */
#define MAXCLI 32         /* max client connection for tcp svr */
#define MAXSTATMSG 32     /* max length of status message */

#define VER_RTKLIB "2.4.2"
#define NTRIP_AGENT "RTKLIB/" VER_RTKLIB
#define NTRIP_CLI_PORT 2101                       /* default ntrip-client connection port */
#define NTRIP_SVR_PORT 80                         /* default ntrip-server connection port */
#define NTRIP_MAXRSP 32768                        /* max size of ntrip response */
#define NTRIP_MAXSTR 256                          /* max length of mountpoint string */
#define NTRIP_RSP_OK_CLI "ICY 200 OK\r\n"         /* ntrip response: client */
#define NTRIP_RSP_OK_SVR "OK\r\n"                 /* ntrip response: server */
#define NTRIP_RSP_SRCTBL "SOURCETABLE 200 OK\r\n" /* ntrip response: source table */
#define NTRIP_RSP_TBLEND "ENDSOURCETABLE"
#define NTRIP_RSP_HTTP "HTTP/"  /* ntrip response: http */
#define NTRIP_RSP_ERROR "ERROR" /* ntrip response: error */

#define FTP_CMD "wget" /* ftp/http command */
#define FTP_TIMEOUT 30 /* ftp/http timeout (s) */


serial_t *openserial(const char *path, int mode, char *msg);

void closeserial(serial_t *serial);

int readserial(serial_t *serial, unsigned char *buff, int n, char *msg);

int writeserial(serial_t *serial, unsigned char *buff, int n, char *msg);

int stateserial(serial_t *serial);

int openfile_(file_t *file, gtime_t time, char *msg);

void closefile_(file_t *file);

file_t *openfile(const char *path, int mode, char *msg);

void closefile(file_t *file);

void swapfile(file_t *file, gtime_t time, char *msg);

void swapclose(file_t *file);

int statefile(file_t *file);

int readfile(file_t *file, unsigned char *buff, int nmax, char *msg);

int writefile(file_t *file, unsigned char *buff, int n, char *msg);

void syncfile(file_t *file1, file_t *file2);

void decodetcppath(const char *path, char *addr, char *port, char *user,
    char *passwd, char *mntpnt, char *str);

int errsock();

int setsock(socket_t sock, char *msg);

socket_t accept_nb(socket_t sock, struct sockaddr *addr, socklen_t *len);

int connect_nb(socket_t sock, struct sockaddr *addr, socklen_t len);

int recv_nb(socket_t sock, unsigned char *buff, int n);

int send_nb(socket_t sock, unsigned char *buff, int n);

int gentcp(tcp_t *tcp, int type, char *msg);

void discontcp(tcp_t *tcp, int tcon);

tcpsvr_t *opentcpsvr(const char *path, char *msg);

void closetcpsvr(tcpsvr_t *tcpsvr);

void updatetcpsvr(tcpsvr_t *tcpsvr, char *msg);

int accsock(tcpsvr_t *tcpsvr, char *msg);

int waittcpsvr(tcpsvr_t *tcpsvr, char *msg);

int readtcpsvr(tcpsvr_t *tcpsvr, unsigned char *buff, int n, char *msg);

int writetcpsvr(tcpsvr_t *tcpsvr, unsigned char *buff, int n, char *msg);

int statetcpsvr(tcpsvr_t *tcpsvr);

int consock(tcpcli_t *tcpcli, char *msg);

tcpcli_t *opentcpcli(const char *path, char *msg);

void closetcpcli(tcpcli_t *tcpcli);

int waittcpcli(tcpcli_t *tcpcli, char *msg);

int readtcpcli(tcpcli_t *tcpcli, unsigned char *buff, int n, char *msg);

int writetcpcli(tcpcli_t *tcpcli, unsigned char *buff, int n, char *msg);

int statetcpcli(tcpcli_t *tcpcli);

int encbase64(char *str, const unsigned char *byte, int n);

int reqntrip_s(ntrip_t *ntrip, char *msg);

int reqntrip_c(ntrip_t *ntrip, char *msg);

int rspntrip_s(ntrip_t *ntrip, char *msg);

int rspntrip_c(ntrip_t *ntrip, char *msg);

int waitntrip(ntrip_t *ntrip, char *msg);

ntrip_t *openntrip(const char *path, int type, char *msg);

void closentrip(ntrip_t *ntrip);

int readntrip(ntrip_t *ntrip, unsigned char *buff, int n, char *msg);

int writentrip(ntrip_t *ntrip, unsigned char *buff, int n, char *msg);

int statentrip(ntrip_t *ntrip);

void decodeftppath(const char *path, char *addr, char *file, char *user,
    char *passwd, int *topts);

gtime_t nextdltime(const int *topts, int stat);

void *ftpthread(void *arg);

ftp_t *openftp(const char *path, int type, char *msg);

void closeftp(ftp_t *ftp);

int readftp(ftp_t *ftp, unsigned char *buff, int n, char *msg);

int stateftp(ftp_t *ftp);

void strinitcom();

void strinit(stream_t *stream);

int stropen(stream_t *stream, int type, int mode, const char *path);

void strclose(stream_t *stream);

void strsync(stream_t *stream1, stream_t *stream2);

void strlock(stream_t *stream);

void strunlock(stream_t *stream);

int strread(stream_t *stream, unsigned char *buff, int n);

int strwrite(stream_t *stream, unsigned char *buff, int n);

int strstat(stream_t *stream, char *msg);

void strsum(stream_t *stream, int *inb, int *inr, int *outb, int *outr);

void strsetopt(const int *opt);

void strsettimeout(stream_t *stream, int inactive_timeout, int tirecon);

void strsetdir(const char *dir);

void strsetproxy(const char *addr);

gtime_t strgettime(stream_t *stream);

void strsendnmea(stream_t *stream, const double *pos);

int gen_hex(const char *msg, unsigned char *buff);

void strsendcmd(stream_t *str, const char *cmd);


#endif