Used to keep track of context of peer. More...

Collaboration diagram for Connection:

Data Fields
struct Connection *	next
	Linked list next.

struct Connection *	prev
	Linked list previous.

struct GNUNET_MQ_Handle *	mq
	Message queue towards the connected peer.

struct GNUNET_MQ_MessageHandler *	handlers
	Handlers for mq.

void *	cls_mq
	Closure for the mq towards the client.

struct GNUNET_NETWORK_Handle *	sock
	Socket for the connected peer.

char *	peer_addr
	Address of the connected peer.

struct GNUNET_SCHEDULER_Task *	recv_task
	Task waiting for incoming messages.

struct GNUNET_SCHEDULER_Task *	write_task
	Task waiting until the socket becomes ready to be written to.

struct GNUNET_SCHEDULER_Task *	notify_connect_task
	Task to notify the client about an open connection.

struct GNUNET_SCHEDULER_Task *	handle_message_task
	Task to pass the message to the client's handlers.

enum GNUNET_GenericReturnValue	notify_connect_called
	Whether notify_connect was called already It is used to check whether to call notify_disconnect or not.

enum GNUNET_GenericReturnValue	client_ready_to_receive
	Indicating whether the client is ready to receive new messages.

enum ConnectionStatus	status
	Status of the connection: Initializing, Live, Destroy.

const struct GNUNET_MessageHeader *	message_to_send
	Message about to be sent, given by the message queue, waiting for the socket to be ready.

struct QueuedMessage *	queued_recv_messages_head
	Queued received messages in a DLL TODO implement cleanup TODO replace with a performant queue.

struct QueuedMessage *	queued_recv_messages_tail

struct GNUNET_CORE_UNDERLAY_DUMMY_Handle *	handle
	Handle to the service.

ngtcp2_conn *	conn
	The QUIC connection.

nghttp3_conn *	h3_conn
	The HTTP/3 connection.

ngtcp2_ccerr	last_error
	The connection error.

ngtcp2_crypto_conn_ref	conn_ref
	The structure to get a pointer to ngtcp2_conn.

gnutls_session_t	session
	The gnutls session.

struct GNUNET_CONTAINER_MultiHashMap *	streams
	Information of the stream.

struct sockaddr *	address
	Address of the other peer.

socklen_t	address_len
	Length of the address.

struct GNUNET_PeerIdentity	target
	To whom are we talking to.

enum GNUNET_NetworkType	nt
	Which network type does this queue use?

struct GNUNET_TIME_Absolute	timeout
	Timeout for this connection.

int	is_initiator
	Flag to indicate if we are the initiator of the connection.

int	id_rcvd
	Flag to indicate whether we know the PeerIdentity (target) yet.

int	id_sent
	Flag to indicate whether we have sent OUR PeerIdentity to this peer.

size_t	d_mtu
	MTU we allowed transport for this receiver's default queue.

struct GNUNET_MQ_Handle *	d_mq
	Default message queue we are providing for the ch.

struct GNUNET_TRANSPORT_QueueHandle *	d_qh
	handle for default queue with the ch.

char *	foreign_addr
	Address of the receiver in the human-readable format with the COMMUNICATOR_ADDRESS_PREFIX.

int	connection_destroy_called
	connection_destroy already called on connection.

struct GNUNET_SCHEDULER_Task *	timer
	The timer of this connection.

uint8_t *	conn_closebuf
	conn_closebuf contains a packet which contains CONNECTION_CLOSE.

ngtcp2_ssize	conn_closebuflen
	The length of conn_closebuf;.

struct HTTP_Message *	msg_queue_head
	head pointer of message queue.

struct HTTP_Message *	msg_queue_rear
	rear pointer of message queue.

size_t	msg_queue_len
	length of message queue.

struct HTTP_Message *	submitted_msg_queue_head
	Messages that have been submitted will be put into this queue.

struct Long_Poll_Request *	long_poll_head
	head pointer of long polling struct queue.

struct Long_Poll_Request *	long_poll_rear
	rear pointer of long polling struct queue.

size_t	long_poll_len
	length of long polling struct queue.