NCX TCP Support

TCP Support for Non-Blocking Connect. More...

Collaboration diagram for NCX TCP Support:

Data Structures
struct	udpnotif_hdr1_t
	UDP-Notif Header Part 1 (32 bits) More...
struct	udpnotif_segoption_t
	UDP-Notif Segmentation Option Header (32 bits) More...
struct	udpnotif_privoption_t
	UDP-Notif Private Encoding Option Header (maybe more than 32 bits) TBD: NOT SUPPORTED. More...
union	udpnotif_u_hdr1_t
	UDP-Notif Header Word 1 As Union. More...
union	udpnotif_u_segoption_t
	UDP-Notif Header SegOption As Union. More...
struct	udpnotif_hdr_t
	UDP-Notif Header Parsed from Message. More...

Functions
int	ncx_tcp_connect (int sockfd, struct sockaddr *name, socklen_t namelen, unsigned short timeout_sec, int *cp_errno)
	Initiate a TCP socket using 'connect'. More...
status_t	udpnotif_get_hdr (const xmlChar *buff, size_t bufflen, udpnotif_hdr_t *rethdr)
	FUNCTION udpnotif_get_hdr. More...
int	udpnotif_read (ses_cb_t *scb)
	The UDP IO input front-end for UDP-Notif Receiver. More...
status_t	udpnotif_init_scb (ses_cb_t *scb)
	Init the UDP Collector control blocks in this SCB. More...
void	udpnotif_clean_scb (ses_cb_t *scb)
	Clean the UDP Collector control blocks in this SCB. More...
uint32	udpnotif_get_publisher_cnt (const ses_cb_t *scb)
	Get the current publisher count. More...
dlq_hdr_t *	udpnotif_get_msgQ (ses_cb_t *scb, udpnotif_hdr_t *hdr)
	The UDP IO input front-end for UDP-Notif Receiver. More...
const xmlChar *	udpnotif_get_print_addr (const ses_cb_t *scb)
	The UDP recvaddr print address. More...
void	udpnotif_dump_hdr (const udpnotif_hdr_t *hdr, log_debug_t lvl)
	Log the UDP-Notif header if current log-level is lvl or higher. More...
status_t	udpnotif_setup_new_msg (ses_cb_t *scb)
	Init the Collector session for handling a message from the latest publisher. More...

Detailed Description

TCP Support for Non-Blocking Connect.

NCX UDP-Notif Header Support.

Function Documentation

ncx_tcp_connect()

int ncx_tcp_connect	(	int	sockfd,
		struct sockaddr *	name,
		socklen_t	namelen,
		unsigned short	timeout_sec,
		int *	cp_errno
	)

Initiate a TCP socket using 'connect'.

Parameters

	sockfd	File descriptor to use for the connect
	name	struct with prepared destination address
	namelen	socket descriptor struct length
	timeout_sec	number of seconds to wait; 0 == use blocking mode
[out]	cp_errno	pointer to return errno status number if error

Returns

status

Return values

-1	some error occurred; errno in *cp_errno
0	Success

udpnotif_clean_scb()

void udpnotif_clean_scb

(

ses_cb_t *

scb

)

Clean the UDP Collector control blocks in this SCB.

Parameters

scb	pointer for the session to clean

Here is the caller graph for this function:

udpnotif_dump_hdr()

void udpnotif_dump_hdr	(	const udpnotif_hdr_t *	hdr,
		log_debug_t	lvl
	)

Log the UDP-Notif header if current log-level is lvl or higher.

Parameters

hdr	UDP-Notif header to print to log
lvl	log-level needed to show any output

Here is the call graph for this function:

udpnotif_get_hdr()

status_t udpnotif_get_hdr	(	const xmlChar *	buff,
		size_t	bufflen,
		udpnotif_hdr_t *	rethdr
	)

FUNCTION udpnotif_get_hdr.

Parse a UDP-Notif Header from a network buffer

Parameters

	buff	buffer to parse from; only the binary header is read
	bufflen	total buffer length read
[out]	rethdr	UDP-Notif header struct filled in from parsing the buff

Returns

status

udpnotif_get_msgQ()

dlq_hdr_t * udpnotif_get_msgQ	(	ses_cb_t *	scb,
		udpnotif_hdr_t *	hdr
	)

The UDP IO input front-end for UDP-Notif Receiver.

Parameters

scb	pointer for the session to check
hdr	message header used for debugging info

Returns

pointer to the messageQ or NULL if some error

Here is the call graph for this function:

udpnotif_get_print_addr()

const xmlChar * udpnotif_get_print_addr

(

const ses_cb_t *

scb

)

The UDP recvaddr print address.

Parameters

scb	pointer for the session to check

Returns

pointer to the print address or UNLL if some error

udpnotif_get_publisher_cnt()

uint32 udpnotif_get_publisher_cnt

(

const ses_cb_t *

scb

)

Get the current publisher count.

Parameters

scb	pointer for the session to check

Returns

number of publishers received messages from

Here is the call graph for this function:

udpnotif_init_scb()

status_t udpnotif_init_scb

(

ses_cb_t *

scb

)

Init the UDP Collector control blocks in this SCB.

Parameters

scb	pointer for the session to inir

Returns

status

• ERR_INTERNAL_MEM if malloc control block fails

Here is the caller graph for this function:

udpnotif_read()

int udpnotif_read

(

ses_cb_t *

scb

)

The UDP IO input front-end for UDP-Notif Receiver.

Parameters

scb	pointer for the session to read

Returns

number of bytes read into the buffer
-1 indicates error and EOF

Here is the caller graph for this function:

udpnotif_setup_new_msg()

status_t udpnotif_setup_new_msg

(

ses_cb_t *

scb

)

Init the Collector session for handling a message from the latest publisher.

Parameters

scb	pointer for the session to use to for state data

Returns

status