otsdaq-mu2e-stm  5.02.01
Public Member Functions | Public Attributes | Static Public Attributes | List of all members
UDPsocket Class Reference

#include <Mu2e-STMDAQ/OLD_BUT_DONT_DELETE_YET/utils/UDPsocket.hh>

+ Collaboration diagram for UDPsocket:

Public Member Functions

 UDPsocket ()
 This module creates a UDP socket for 10G readout (main).
 
uint16_t getBufferSize ()
 
uint16_t getBufferLength ()
 
void die (char *s)
 
char * getIPaddress (int CHANNEL)
 
int getPORT (int CHANNEL)
 
int getPort (int READWRITE)
 
int createSocket (int CHANNEL)
 
int createClient (int CHANNEL)
 
int bindSocket (int sock)
 
int set_SO_RCVBUF (int sock, uint32_t size)
 
int set_SO_SNDBUF (int sock, uint32_t size)
 
int setTimeout (int secs, double usecs)
 
int setBufferLength ()
 
int sendPacket (struct packet &p, int sock)
 
int getPacket (packet &p, int sock, int chan)
 
int flushPackets (int sock)
 
uint16_t getBufferSize ()
 
uint16_t getBufferLength ()
 
void die (char *s)
 
char * getIPaddress (int CHANNEL)
 
int getPORT (int CHANNEL)
 
int getPort (int READWRITE)
 
int createSocket (int CHANNEL)
 
int createClient (int CHANNEL)
 
int bindSocket (int sock)
 
int set_SO_RCVBUF (int sock, uint32_t size)
 
int set_SO_SNDBUF (int sock, uint32_t size)
 
int setTimeout (int secs, double usecs)
 
int setBufferLength ()
 
int sendPacket (struct packet &p, int sock)
 
int getPacket (packet &p, int sock, int chan)
 
int flushPackets (int sock)
 
uint16_t getBufferSize ()
 
uint16_t getBufferLength ()
 
void die (char *s)
 
const char * getIPaddress (int READWRITE)
 
int getPort (int READWRITE)
 
int createSocket (int READWRITE)
 
int createClient (int READWRITE)
 
int bindSocket (int sock)
 
int set_SO_RCVBUF (int sock, uint32_t size)
 
int set_SO_SNDBUF (int sock, uint32_t size)
 
int setTimeout (int secs, double usecs)
 
int setBufferLength ()
 
int sendPacket (struct packet &p, int sock)
 
packet getPacket (int sock)
 
int flushPackets (int sock)
 
uint16_t getBufferSize ()
 
uint16_t getBufferLength ()
 
void die (char *s)
 
char * getIPaddress (int CHANNEL)
 
int getPORT (int CHANNEL)
 
int getPort (int READWRITE)
 
int createSocket (int CHANNEL)
 
int createClient (int CHANNEL)
 
int bindSocket (int sock)
 
int set_SO_RCVBUF (int sock, uint32_t size)
 
int set_SO_SNDBUF (int sock, uint32_t size)
 
int setTimeout (int secs, double usecs)
 
int setBufferLength ()
 
int sendPacket (struct packet &p, int sock)
 
int getPacket (packet &p, int sock, int chan)
 
int flushPackets (int sock)
 
void check_channel (int CHAN)
 
void check_fw_or_sw (int FW_or_SW)
 
string get_channel_name (int CHAN)
 
uint16_t get_max_udp_size ()
 
void setLastPacketNum (int chan, uint32_t lastPacket)
 
uint32_t getLastPacketNum (int chan)
 
uint getTimeoutMax ()
 
void die (char *s)
 
std::string getIPaddress (int CHAN, int FW_or_SW)
 
int getPort (int CHAN, int FW_or_SW)
 
int setupServer (int CHAN, int FW_or_SW)
 
int createSocket (int CHAN, int FW_or_SW)
 
int setupClient (int CHAN, int FW_or_SW)
 
int bindSocket (int sock)
 
int set_SO_RCVBUF (int sock, uint64_t size)
 
int set_SO_SNDBUF (int sock, uint64_t size)
 
int setTimeout (int secs, double usecs)
 
int setBufferLength ()
 
int sendOne (int16_t *data, uint16_t size, int sock)
 
int send (int16_t **data, uint16_t *size, int MSG_NUM, int sock)
 
int recvOne (int16_t *data, int sock, int CHAN)
 
int recv (int16_t *data, int sock, int CHAN)
 
uint16_t get_max_udp_size ()
 
void setLastPacketNum (uint32_t lastPacket)
 
uint32_t getLastPacketNum ()
 
uint getTimeoutMax ()
 
void die (char *s)
 
std::string getIPaddress ()
 
int getPort ()
 
int setupServer ()
 
int createSocket ()
 
int setupClient ()
 
int bindSocket (int sock)
 
int set_SO_RCVBUF (int sock, uint64_t size)
 
int set_SO_SNDBUF (int sock, uint64_t size)
 
int setTimeout (int secs, double usecs)
 
int setBufferLength ()
 
int sendOne (int16_t *data, uint16_t size, int sock)
 
int send (int16_t **data, uint16_t *size, int MSG_NUM, int sock)
 
int recvOne (int16_t *data, int sock)
 
int recv (int16_t *data, int sock)
 
uint16_t get_max_udp_size ()
 
void setLastPacketNum (uint32_t lastPacket)
 
uint32_t getLastPacketNum ()
 
uint getTimeoutMax ()
 
void die (char *s)
 
std::string getIPaddress ()
 
int getPort ()
 
int setupServer ()
 
int createSocket ()
 
int setupClient ()
 
int bindSocket (int sock)
 
int set_SO_RCVBUF (int sock, uint64_t size)
 
int set_SO_SNDBUF (int sock, uint64_t size)
 
int setTimeout (int secs, double usecs)
 
int setBufferLength ()
 
int sendOne (int16_t *data, uint16_t size, int sock)
 
int send (int16_t **data, uint16_t *size, int MSG_NUM, int sock)
 
int recvOne (int16_t *data, int sock)
 
int recv (int16_t *data, int sock)
 

Public Attributes

struct sockaddr_in servaddr cliaddr
 
int slen = sizeof(cliaddr)
 
int timeout_count = 0
 
uint16_t length
 
int16_t * buffer
 
fd_set readfds
 
const char * IP = "192.168.34.12"
 
uint timeout_counter = 0
 
bool timeout_wait = false
 
bool timeout = false
 
int16_t * size
 
uint64_t sock_mem = 0
 
int16_t packet [MAX_PACKET_LEN] = {}
 
int ret [CHNUM] = {}
 
struct timeval read_timeout
 
bool rcv_multiple = true
 
bool firstPacket = true
 
bool receiving_data [CHNUM] = {}
 

Static Public Attributes

static const uint timeout_max = 5e7
 
static const uint64_t SO_SNDBUF_SIZE = 0
 
static const int RECVMMSG_NUM = 65536
 
static const int SENDMMSG_NUM = RECVMMSG_NUM/1e2
 
static const uint16_t MAX_UDP_LEN = MAX_UDP_SIZE/2
 

Detailed Description

This module creates a UDP socket for 10G readout (header).

Definition at line 39 of file UDPsocket.hh.

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