Inheritance diagram for NtripUploader:

Collaboration diagram for NtripUploader:

Public Member Functions
	NtripUploader (const string &url_str)

void	startBroadcast ()

void	connected () override

void	messageTimeoutHandler (const boost::system::error_code &err)

void	writeHandler (const boost::system::error_code &err)

void	serverResponse (unsigned int status_code, string http_version) override

void	getJsonNetworkStatistics (GTime now)

Public Member Functions inherited from NtripResponder
	NtripResponder (const string &url_str)

void	requestResponseHandler (const boost::system::error_code &err) override

Public Member Functions inherited from TcpSocket
	TcpSocket (const string &url_str, const string &readUntil="\r\n\r\n")

void	setUrl (const string &url_str)

void	connect ()

void	disconnect ()

void	startRead (bool chunked)

void	timeoutHandler (const boost::system::error_code &err)

void	delayedReconnect ()

void	connectHandler (const boost::system::error_code &err, tcp::resolver::iterator endpoint_iterator)

void	logChunkError ()

void	dataChunkDownloaded (vector< char > &dataChunk)

virtual void	readContentDownloaded (vector< char > content)

virtual void	messageChunkLog (string message)

virtual void	networkLog (string message)

void	getData () override

void	connectionError (const boost::system::error_code &err, string operation)

virtual	~TcpSocket ()=default

Public Member Functions inherited from NetworkStatistics
string	getNetworkStatistics (GTime now, string label)

void	onConnectedStatistics ()

void	onDisconnectedStatistics ()

void	onChunkSentStatistics ()

void	onChunkReceivedStatistics ()

void	onErrorStatistics (const boost::system::error_code &err, string operation)

Public Member Functions inherited from SerialStream
	SerialStream ()

	SerialStream (string path)

void	openStream ()

unique_ptr< std::istream >	getIStream_ptr () override

virtual	~SerialStream ()

Public Member Functions inherited from Stream
virtual bool	isDead ()
	Check to see if this stream has run out of data.

virtual bool	isAvailable ()

virtual	~Stream ()=default

Public Member Functions inherited from RtcmEncoder
	RtcmEncoder (string rtcmMountpoint="", string rtcmTraceFilename="")

void	encodeWriteMessages (std::ostream &outputStream)

bool	encodeWriteMessageToBuffer (vector< uint8_t > &buffer)

vector< uint8_t >	encodeTimeStampRTCM ()

int	encodeSsrHeader (unsigned char *buf, E_Sys sys, RtcmMessageType messCode, SSRMeta &ssrMeta, int iod, int dispBiasConistInd=-1, int MWConistInd=-1)
	encode SSR header information

vector< uint8_t >	encodeSsrOrbClk (SsrOutMap &ssrOutMap, RtcmMessageType messCode)
	encode orbit/clock messages

vector< uint8_t >	encodeSsrUra (SsrOutMap &ssrOutMap, RtcmMessageType messCode)
	encode URA messages

vector< uint8_t >	encodeSsrCode (SsrCBMap &ssrCBMap, RtcmMessageType messCode)
	encode code bias messages

vector< uint8_t >	encodeSsrPhase (SsrPBMap &ssrPBMap, RtcmMessageType messCode)
	encode phase bias messages

vector< uint8_t >	encodeEphemeris (Eph &eph, RtcmMessageType messCode)
	encode GPS/GAL/BDS/QZS ephemeris messages

vector< uint8_t >	encodeEphemeris (Geph &geph, RtcmMessageType messCode)
	encode GLO ephemeris messages

Public Member Functions inherited from RtcmTrace
	RtcmTrace (string mountpoint="", string filename="")

void	networkLog (string message)

void	messageChunkLog (string message)

void	messageRtcmLog (string message)

void	traceSsrEph (RtcmMessageType messCode, SatSys Sat, SSREph &ssrEph)

void	traceSsrClk (RtcmMessageType messCode, SatSys Sat, SSRClk &ssrClk)

void	traceSsrUra (RtcmMessageType messCode, SatSys Sat, SSRUra &ssrUra)

void	traceSsrHRClk (RtcmMessageType messCode, SatSys Sat, SSRHRClk &ssrHRClk)

void	traceSsrCodeBias (RtcmMessageType messCode, SatSys Sat, E_ObsCode code, SSRCodeBias &ssrBias)

void	traceSsrPhasBias (RtcmMessageType messCode, SatSys Sat, E_ObsCode code, SSRPhasBias &ssrBias)

void	traceTimestamp (GTime time)

void	traceBrdcEph (RtcmMessageType messCode, Eph &eph)
	Write decoded/encoded GPS/GAL/BDS/QZS ephemeris messages to a json file.

void	traceBrdcEph (RtcmMessageType messCode, Geph &geph)
	Write decoded/encoded GAL ephemeris messages to a json file.

void	traceMSM (RtcmMessageType messCode, GTime time, SatSys Sat, Sig &sig)
	Write msm message to a json file.

void	traceUnknown ()
	Write unknown message to a json file.

Data Fields
boost::posix_time::ptime	timeNextMessage

std::mutex	outMessagesMtx

boost::asio::streambuf	outMessages

boost::asio::deadline_timer	sendTimer

int	numberChunksSent = 0

GTime	previousTargetTime
	Time to prevent aliasing.

string	ntripStr

string	id = "NtripUploader"

SsrBroadcast	streamConfig

Data Fields inherited from TcpSocket
URL	url

double	reconnectDelay = 1

int	disconnectionCount = 0

bool	isConnected = false

int	numberErroredChunks = 0

bool	logHttpSentReceived = false

unsigned int	content_length = 0

B_asio::ssl::context	sslContext

Data Fields inherited from NetworkStatistics
string	streamName

GTime	startTime

GTime	endTime

string	networkTraceFilename

int	connectCount = 0

int	disconnectCount = 0

int	chunksSent = 0

int	chunksReceived = 0

boost::posix_time::time_duration	connectedDuration = boost::posix_time::hours(0)

boost::posix_time::time_duration	disconnectedDuration = boost::posix_time::hours(0)

Data Fields inherited from SerialStream
string	path

int	fileDescriptor = -1

vector< char >	receivedData

Data Fields inherited from Stream
string	sourceString

Data Fields inherited from RtcmEncoder
vector< uint8_t >	data

int	masterIod = 1

SsrEphMap	lastRegSsrEphMap
	last SSR orbit corrections uploaded, used to check IODE's

SsrClkMap	lastRegSsrClkMap
	last regular SSR clock corrections uploaded, used to calculate high rate SSR clock corrections

Data Fields inherited from RtcmTrace
string	rtcmTraceFilename = ""

string	rtcmMountpoint

bool	qzssL6 = false

Additional Inherited Members
Static Public Member Functions inherited from TcpSocket
static void	runService ()

static void	startClients ()

Static Public Member Functions inherited from RtcmEncoder
static int	getUdiIndex (int udi)

Static Public Attributes inherited from TcpSocket
static B_asio::io_context	ioContext

Static Public Attributes inherited from RtcmEncoder
static constexpr int	updateInterval [16]

Protected Attributes inherited from TcpSocket
std::shared_ptr< tcp::socket >	_socket

tcp::socket *	socket_ptr

std::shared_ptr< ssl_socket >	_sslsocket

std::shared_ptr< tcp::resolver >	_resolver

boost::asio::deadline_timer	timer

string	readUntilString

string	requestString

string	responseString

boost::asio::streambuf	request

boost::asio::streambuf	downloadBuf

vector< char >	receivedTcpData

Constructor & Destructor Documentation

◆ NtripUploader()

NtripUploader::NtripUploader ( const string & url_str )

inline

Here is the call graph for this function:

Member Function Documentation

◆ connected()

void NtripUploader::connected ( )

overridevirtual

Reimplemented from TcpSocket.

Here is the call graph for this function:

◆ getJsonNetworkStatistics()

void NtripUploader::getJsonNetworkStatistics ( GTime now )

◆ messageTimeoutHandler()

void NtripUploader::messageTimeoutHandler ( const boost::system::error_code & err )

Here is the caller graph for this function:

◆ serverResponse()

void NtripUploader::serverResponse	(	unsigned int	status_code,
		string	http_version )

overridevirtual

Reimplemented from NtripResponder.

Here is the call graph for this function:

◆ startBroadcast()

void NtripUploader::startBroadcast ( )

Here is the call graph for this function:

Here is the caller graph for this function:

◆ writeHandler()

void NtripUploader::writeHandler ( const boost::system::error_code & err )

Here is the call graph for this function:

Here is the caller graph for this function:

Field Documentation

◆ id

string NtripUploader::id = "NtripUploader"

◆ ntripStr

string NtripUploader::ntripStr

◆ numberChunksSent

int NtripUploader::numberChunksSent = 0

◆ outMessages

boost::asio::streambuf NtripUploader::outMessages

◆ outMessagesMtx

std::mutex NtripUploader::outMessagesMtx

◆ previousTargetTime

GTime NtripUploader::previousTargetTime

Time to prevent aliasing.

◆ sendTimer

boost::asio::deadline_timer NtripUploader::sendTimer

◆ streamConfig

SsrBroadcast NtripUploader::streamConfig

◆ timeNextMessage

boost::posix_time::ptime NtripUploader::timeNextMessage

The documentation for this struct was generated from the following files:

/ginan/src/cpp/common/ntripBroadcast.hpp
/ginan/src/cpp/common/ntripBroadcast.cpp

Public Member Functions

Data Fields

Additional Inherited Members

Constructor & Destructor Documentation

◆ NtripUploader()

Member Function Documentation

◆ connected()

◆ getJsonNetworkStatistics()

◆ messageTimeoutHandler()

◆ serverResponse()

◆ startBroadcast()

◆ writeHandler()

Field Documentation

◆ id

◆ ntripStr

◆ numberChunksSent

◆ outMessages

◆ outMessagesMtx

◆ previousTargetTime

◆ sendTimer

◆ streamConfig

◆ timeNextMessage