antEnvBaseMsg.cc File Reference

#include "OpenSdkThread.h"
#include <OPENR/OSyslog.h>
#include <ant.h>
#include <EndpointTypes.h>
#include <TCPEndpointMsg.h>
#include <UDPEndpointMsg.h>
#include <DNSEndpointMsg.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <unistd.h>
#include <errno.h>
#include <pthread.h>
#include <map>
#include "OpenSdkEndpoint.h"
#include "OpenSdkEndpointInfo.h"
#include <opensdkAPI.h>
#include "antSharedBufferManager.h"

Go to the source code of this file.

Classes
struct	portsStruct
Typedefs
typedef std::map< int, OpenSdkEndpointInfo * >	EndpointInfoMap
Functions
TCPEndpointError	TCP_error (void)
TCPEndpointError	TCP_state_error (OpenSdkEndpointInfo::State state)
UDPEndpointError	UDP_error (void)
UDPEndpointError	UDP_state_error (OpenSdkEndpointInfo::State state)
void *	tcpListenThreadFunc (void *arg)
void *	tcpReceiveThreadFunc (void *arg)
void *	tcpSendThreadFunc (void *arg)
void *	tcpConnectThreadFunc (void *arg)
void *	tcpCloseThreadFunc (void *arg)
void *	udpReceiveThreadFunc (void *arg)
void *	udpSendThreadFunc (void *arg)
void *	udpCloseThreadFunc (void *arg)
void *	dnsGetHostByNameThreadFunc (void *arg)
DNSEndpointError	DNS_error (int error)
Variables
EndpointInfoMap	endpointMap = EndpointInfoMap()
int	nextEndpointId = 0
pthread_mutex_t	mapMut = PTHREAD_MUTEX_INITIALIZER
map< short, portsStruct >	PortsMap
pthread_mutex_t	PortsMutex = PTHREAD_MUTEX_INITIALIZER

---

Typedef Documentation

typedef std::map<int, OpenSdkEndpointInfo*> EndpointInfoMap

Definition at line 69 of file antEnvBaseMsg.cc.

---

Function Documentation

DNSEndpointError DNS_error (  int  error  )  [static]

Definition at line 955 of file antEnvBaseMsg.cc. Referenced by dnsGetHostByNameThreadFunc().

void * dnsGetHostByNameThreadFunc (  void *  arg  )  [static]

Definition at line 967 of file antEnvBaseMsg.cc. References _sendMessage(), DNS_error(), OpenSdkEndpointInfo::entry, OpenSdkEndpointInfo::hostname, and OpenSdkEndpointInfo::msg.

TCPEndpointError TCP_error (  void   )  [static]

translate errno codes to TCPEndpointError Definition at line 693 of file antEnvBaseMsg.cc. Referenced by tcpConnectThreadFunc(), tcpListenThreadFunc(), tcpReceiveThreadFunc(), and tcpSendThreadFunc().

TCPEndpointError TCP_state_error (  OpenSdkEndpointInfo::State  state  )  [static]

translate OpenSdkEndpointInfo states to TCPEndpointError Definition at line 710 of file antEnvBaseMsg.cc.

void * tcpCloseThreadFunc (  void *  arg  )  [static]

Definition at line 825 of file antEnvBaseMsg.cc. References _sendMessage(), OpenSdkEndpointInfo::entry, OpenSdkEndpointInfo::msg, OpenSdkEndpointInfo::server_socket, OpenSdkEndpointInfo::socket, and OpenSdkEndpointInfo::state.

void * tcpConnectThreadFunc (  void *  arg  )  [static]

Definition at line 797 of file antEnvBaseMsg.cc. References _sendMessage(), OpenSdkEndpointInfo::entry, OpenSdkEndpointInfo::ip, OpenSdkEndpointInfo::msg, OpenSdkEndpointInfo::port, OpenSdkEndpointInfo::socket, OpenSdkEndpointInfo::state, and TCP_error().

void * tcpListenThreadFunc (  void *  arg  )  [static]

Definition at line 722 of file antEnvBaseMsg.cc. References _sendMessage(), OpenSdkEndpointInfo::entry, OpenSdkEndpointInfo::listen_mutex, OpenSdkEndpointInfo::msg, OpenSdkEndpointInfo::server_socket, OpenSdkEndpointInfo::socket, OpenSdkEndpointInfo::state, and TCP_error().

void * tcpReceiveThreadFunc (  void *  arg  )  [static]

Definition at line 747 of file antEnvBaseMsg.cc. References _sendMessage(), OpenSdkEndpointInfo::buffer, OpenSdkEndpointInfo::entry, OpenSdkEndpointInfo::msg, OpenSdkEndpointInfo::size, OpenSdkEndpointInfo::socket, and TCP_error().

void * tcpSendThreadFunc (  void *  arg  )  [static]

Definition at line 775 of file antEnvBaseMsg.cc. References _sendMessage(), OpenSdkEndpointInfo::buffer, OpenSdkEndpointInfo::entry, OpenSdkEndpointInfo::msg, OpenSdkEndpointInfo::size, OpenSdkEndpointInfo::socket, and TCP_error().

UDPEndpointError UDP_error (  void   )  [static]

translate errno codes to UDPEndpointError Definition at line 850 of file antEnvBaseMsg.cc. Referenced by udpReceiveThreadFunc(), and udpSendThreadFunc().

UDPEndpointError UDP_state_error (  OpenSdkEndpointInfo::State  state  )  [static]

translate OpenSdkEndpointInfo states to UDPEndpointError Definition at line 867 of file antEnvBaseMsg.cc.

void * udpCloseThreadFunc (  void *  arg  )  [static]

Definition at line 937 of file antEnvBaseMsg.cc. References _sendMessage(), OpenSdkEndpointInfo::entry, OpenSdkEndpointInfo::msg, OpenSdkEndpointInfo::socket, and OpenSdkEndpointInfo::state.

void * udpReceiveThreadFunc (  void *  arg  )  [static]

Definition at line 877 of file antEnvBaseMsg.cc. References _sendMessage(), OpenSdkEndpointInfo::buffer, OpenSdkEndpointInfo::entry, OpenSdkEndpointInfo::msg, OpenSdkEndpointInfo::port, OpenSdkEndpointInfo::size, OpenSdkEndpointInfo::socket, and UDP_error().

void * udpSendThreadFunc (  void *  arg  )  [static]

Definition at line 907 of file antEnvBaseMsg.cc. References _sendMessage(), OpenSdkEndpointInfo::buffer, OpenSdkEndpointInfo::entry, OpenSdkEndpointInfo::ip, OpenSdkEndpointInfo::msg, OpenSdkEndpointInfo::size, OpenSdkEndpointInfo::socket, and UDP_error().

---

Variable Documentation

EndpointInfoMap endpointMap = EndpointInfoMap() [static]

Definition at line 71 of file antEnvBaseMsg.cc.

pthread_mutex_t mapMut = PTHREAD_MUTEX_INITIALIZER [static]

Definition at line 73 of file antEnvBaseMsg.cc.

int nextEndpointId = 0 [static]

Definition at line 72 of file antEnvBaseMsg.cc.

map<short, portsStruct> PortsMap [static]

Definition at line 87 of file antEnvBaseMsg.cc.

pthread_mutex_t PortsMutex = PTHREAD_MUTEX_INITIALIZER [static]

Definition at line 88 of file antEnvBaseMsg.cc.

---