1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
/********************************************************************
* Description: tcp_srv.hh
*
* Derived from a work by Fred Proctor & Will Shackleford
*
* Author:
* License: LGPL Version 2
* System: Linux
*
* Copyright (c) 2004 All rights reserved.
*
* Last change:
********************************************************************/
#ifndef TCP_SRV_HH
#define TCP_SRV_HH
#include "cms_srv.hh" /* class CMS_SERVER_REMOTE_PORT */
#include "linklist.hh" /* class LinkedList */
#include "rem_msg.hh"
#ifdef __cplusplus
extern "C" {
#endif
#include <string.h> /* memset(), strerror() */
#include <netinet/in.h>
#include <errno.h> /* errno */
#include <signal.h> // SIGPIPE, signal()
#include <sys/time.h> /* struct timeval */
#ifdef __cplusplus
}
#endif
#ifndef NO_THREADS
#define NO_THREADS
#ifdef POSIX_THREADS
#include <pthread.h>
#endif
#endif
#define MAX_TCP_BUFFER_SIZE 16
class CLIENT_TCP_PORT;
class CMS_SERVER_REMOTE_TCP_PORT:public CMS_SERVER_REMOTE_PORT {
public:
CMS_SERVER_REMOTE_TCP_PORT(CMS_SERVER * _cms_server);
virtual ~ CMS_SERVER_REMOTE_TCP_PORT();
int accept_local_port_cms(CMS *);
void run();
void register_port();
void unregister_port();
double dtimeout;
protected:
fd_set read_fd_set, write_fd_set;
void handle_request(CLIENT_TCP_PORT *);
int maxfdpl;
LinkedList *client_ports;
LinkedList *subscription_buffers;
int connection_socket;
long connection_port;
struct sockaddr_in server_socket_address;
REMOTE_CMS_REQUEST *request;
char temp_buffer[0x2000];
int current_poll_interval_millis;
int polling_enabled;
struct timeval select_timeout;
void update_subscriptions();
void add_subscription_client(int buffer_number, int subscription_type,
int poll_interval_millis, CLIENT_TCP_PORT * clnt);
void remove_subscription_client(CLIENT_TCP_PORT * clnt,
int buffer_number);
void recalculate_polling_interval();
void switch_function(CLIENT_TCP_PORT *
_client_tcp_port,
CMS_SERVER * server, long request_type, long buffer_number, long
received_serial_number);
};
class TCP_BUFFER_SUBSCRIPTION_INFO {
public:
TCP_BUFFER_SUBSCRIPTION_INFO();
~TCP_BUFFER_SUBSCRIPTION_INFO();
int buffer_number;
int min_last_id;
int list_id;
LinkedList *sub_clnt_info;
};
class TCP_CLIENT_SUBSCRIPTION_INFO {
public:
TCP_CLIENT_SUBSCRIPTION_INFO();
~TCP_CLIENT_SUBSCRIPTION_INFO();
int subscription_type;
int poll_interval_millis;
double last_sub_sent_time;
int subscription_list_id;
int buffer_number;
int subscription_paused;
int last_id_read;
TCP_BUFFER_SUBSCRIPTION_INFO *sub_buf_info;
CLIENT_TCP_PORT *clnt_port;
};
class TCPSVR_BLOCKING_READ_REQUEST;
class CLIENT_TCP_PORT {
public:
CLIENT_TCP_PORT();
~CLIENT_TCP_PORT();
long serial_number;
int errors, max_errors;
struct sockaddr_in address;
int socket_fd;
LinkedList *subscriptions;
pid_t tid;
pid_t pid;
int blocking;
#ifdef POSIX_THREADS
pthread_t threadId;
#else
int threadId;
#endif
TCPSVR_BLOCKING_READ_REQUEST *blocking_read_req;
REMOTE_SET_DIAG_INFO_REQUEST *diag_info;
};
class TCPSVR_BLOCKING_READ_REQUEST:public REMOTE_BLOCKING_READ_REQUEST {
public:
TCPSVR_BLOCKING_READ_REQUEST();
~TCPSVR_BLOCKING_READ_REQUEST();
CLIENT_TCP_PORT *_client_tcp_port;
CMS_SERVER_REMOTE_TCP_PORT *remport;
CMS_SERVER *server;
REMOTE_BLOCKING_READ_REPLY *read_reply;
};
#endif /* TCP_SRV_HH */
|
