NtripUploader Struct Reference

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)
void	getJsonNetworkStatistics (GTime now)
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)
virtual void	requestResponseHandler (const boost::system::error_code &err)
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	~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_service	ioService
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 )

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