The Assimilation Project  based on Assimilation version 1.1.7.1474836767
_FsProtocol Struct Reference

This is an FsProtocol class object - implementing a reliable user-level FrameSet class delivery system It is a subclass of the AssimObj class and is managed by our C-Class Management system. More...

#include <fsprotocol.h>

Collaboration diagram for _FsProtocol:

Data Fields

AssimObj baseclass
 base AssimObj class object More...
 
NetIOio
 Our parent NetIO object. More...
 
GHashTable * endpoints
 All our FsProtoElem endpoints. More...
 
GList * unacked
 List of FsProtoElems awaiting ACKs. More...
 
GQueue * ipend
 List of FsProtoElems ready to be read. More...
 
guint window_size
 Window size of our connections. More...
 
gint64 rexmit_interval
 How often to retransmit - in uS. More...
 
gint64 acktimeout
 ACK timeout interval. More...
 
guint _timersrc
 gmainloop timer source id More...
 
FsProtoElem *(* find )(FsProtocol *, guint16, const NetAddr *)
 Find connection to given endpoint. More...
 
FsProtoElem *(* findbypkt )(FsProtocol *, NetAddr *, FrameSet *)
 Find connection to given originator. More...
 
FsProtoElem *(* addconn )(FsProtocol *, guint16, NetAddr *)
 Add a connection to the given endpoint. More...
 
void(* closeconn )(FsProtocol *, guint16, const NetAddr *)
 Close this connection (reset it) More...
 
FsProtoState(* connstate )(FsProtocol *, guint16, const NetAddr *)
 Return the state of this connection. More...
 
gboolean(* iready )(FsProtocol *)
 TRUE if input is ready to be read. More...
 
gboolean(* outputpending )(FsProtocol *)
 Return TRUE if output is pending. More...
 
FrameSet *(* read )(FsProtocol *, NetAddr **)
 Read the next FrameSet class. More...
 
void(* receive )(FsProtocol *, NetAddr *, FrameSet *)
 Enqueue a received input FrameSet class. More...
 
gboolean(* send1 )(FsProtocol *, FrameSet *, guint16, NetAddr *)
 Send one FrameSet class. More...
 
gboolean(* send )(FsProtocol *, GSList *, guint16, NetAddr *)
 Send a list of FrameSets. More...
 
void(* ackmessage )(FsProtocol *, NetAddr *, FrameSet *)
 ACK the given FrameSet class. More...
 
void(* closeall )(FsProtocol *)
 Close all our connections. More...
 
int(* activeconncount )(FsProtocol *)
 How many active connections do we have? More...
 
void(* log_conn )(FsProtocol *, guint16, NetAddr *)
 Log connection information. More...
 

Detailed Description

This is an FsProtocol class object - implementing a reliable user-level FrameSet class delivery system It is a subclass of the AssimObj class and is managed by our C-Class Management system.

Definition at line 107 of file fsprotocol.h.

Field Documentation

guint _FsProtocol::_timersrc

gmainloop timer source id

Definition at line 116 of file fsprotocol.h.

void(* _FsProtocol::ackmessage) (FsProtocol *, NetAddr *, FrameSet *)

ACK the given FrameSet class.

Definition at line 128 of file fsprotocol.h.

gint64 _FsProtocol::acktimeout

ACK timeout interval.

Definition at line 115 of file fsprotocol.h.

Referenced by _fsprotocol_fsa(), and _fsprotocol_xmitifwecan().

int(* _FsProtocol::activeconncount) (FsProtocol *)

How many active connections do we have?

Definition at line 130 of file fsprotocol.h.

Referenced by exit_when_connsdown(), and shutdown_when_outdone().

FsProtoElem*(* _FsProtocol::addconn) (FsProtocol *, guint16, NetAddr *)

Add a connection to the given endpoint.

Definition at line 119 of file fsprotocol.h.

AssimObj _FsProtocol::baseclass

base AssimObj class object

Definition at line 108 of file fsprotocol.h.

void(* _FsProtocol::closeall) (FsProtocol *)

Close all our connections.

Definition at line 129 of file fsprotocol.h.

Referenced by nano_initiate_shutdown(), obey_pingpong(), and timeout_agent().

void(* _FsProtocol::closeconn) (FsProtocol *, guint16, const NetAddr *)

Close this connection (reset it)

Definition at line 120 of file fsprotocol.h.

FsProtoState(* _FsProtocol::connstate) (FsProtocol *, guint16, const NetAddr *)

Return the state of this connection.

Definition at line 121 of file fsprotocol.h.

Referenced by cma.AssimCclasses.pyNetIO::connactive(), and obey_pingpong().

GHashTable* _FsProtocol::endpoints

All our FsProtoElem endpoints.

Definition at line 110 of file fsprotocol.h.

FsProtoElem*(* _FsProtocol::find) (FsProtocol *, guint16, const NetAddr *)

Find connection to given endpoint.

Definition at line 117 of file fsprotocol.h.

FsProtoElem*(* _FsProtocol::findbypkt) (FsProtocol *, NetAddr *, FrameSet *)

Find connection to given originator.

Definition at line 118 of file fsprotocol.h.

NetIO* _FsProtocol::io

Our parent NetIO object.

Definition at line 109 of file fsprotocol.h.

Referenced by _fsprotocol_xmitifwecan().

GQueue* _FsProtocol::ipend

List of FsProtoElems ready to be read.

Definition at line 112 of file fsprotocol.h.

gboolean(* _FsProtocol::iready) (FsProtocol *)

TRUE if input is ready to be read.

Definition at line 122 of file fsprotocol.h.

Referenced by _reliableudp_recvframesets().

void(* _FsProtocol::log_conn) (FsProtocol *, guint16, NetAddr *)

Log connection information.

Definition at line 131 of file fsprotocol.h.

gboolean(* _FsProtocol::outputpending) (FsProtocol *)

Return TRUE if output is pending.

Definition at line 123 of file fsprotocol.h.

FrameSet*(* _FsProtocol::read) (FsProtocol *, NetAddr **)

Read the next FrameSet class.

Definition at line 124 of file fsprotocol.h.

Referenced by _reliableudp_recvframesets().

void(* _FsProtocol::receive) (FsProtocol *, NetAddr *, FrameSet *)

Enqueue a received input FrameSet class.

Definition at line 125 of file fsprotocol.h.

Referenced by _reliableudp_recvframesets().

gint64 _FsProtocol::rexmit_interval

How often to retransmit - in uS.

Definition at line 114 of file fsprotocol.h.

Referenced by _fsprotocol_xmitifwecan().

gboolean(* _FsProtocol::send) (FsProtocol *, GSList *, guint16, NetAddr *)

Send a list of FrameSets.

Definition at line 127 of file fsprotocol.h.

gboolean(* _FsProtocol::send1) (FsProtocol *, FrameSet *, guint16, NetAddr *)

Send one FrameSet class.

Definition at line 126 of file fsprotocol.h.

Referenced by _fsprotocol_fsa().

GList* _FsProtocol::unacked

List of FsProtoElems awaiting ACKs.

Definition at line 111 of file fsprotocol.h.

Referenced by _fsprotocol_auditfspe(), _fsprotocol_receive(), _fsprotocol_send1(), and _fsprotocol_xmitifwecan().

guint _FsProtocol::window_size

Window size of our connections.

Definition at line 113 of file fsprotocol.h.

Referenced by _fsprotocol_xmitifwecan(), and main().


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