#include "rcs_defs.hh"
#include "sokintrf.h"
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <signal.h>
#include "cms.hh"
#include "nml.hh"
#include "tcp_srv.hh"
#include "rcs_prnt.hh"
#include "linklist.hh"
#include "tcp_opts.hh"
#include "timer.hh"
#include "cmsdiag.hh"
#include "recvn.h"
#include "sendn.h"
Include dependency graph for tcp_srv.cc:
Go to the source code of this file.
Functions | |
int RCS_EXPORT | recvn (int fd, void *vptr, int n, int flags, double timeout, int *bytes_read_ptr) |
int RCS_EXPORT | sendn (int fd, const void *vptr, int n, int flags, double timeout) |
double | tcp_svr_reverse_double (double in) |
void | blocking_thread_kill (long int id) |
void | handle_pipe_error (int signum) |
void | tcpsvr_handle_blocking_request_sigint_handler (int sig) |
Variables | |
int | recvn_timedout |
int | print_recvn_timeout_errors |
int | tcpsvr_threads_created = 0 |
int | tcpsvr_threads_killed = 0 |
int | tcpsvr_threads_exited = 0 |
int | tcpsvr_threads_returned_early = 0 |
int | last_pipe_signum = 0 |
int | tcpsvr_handle_blocking_request_sigint_count = 0 |
int | tcpsvr_last_sig = 0 |
|
|
|
|
|
Definition at line 172 of file tcp_srv.cc. 00174 { 00175 rcs_print_error ("Can not create linked list for client ports.\n"); 00176 return; 00177 } 00178 polling_enabled = 0; 00179 memset (&select_timeout, 0, sizeof (select_timeout)); 00180 select_timeout.tv_sec = 30; 00181 select_timeout.tv_usec = 30; 00182 subscription_buffers = NULL; 00183 current_poll_interval_millis = 30000; 00184 memset (&read_fd_set, 0, sizeof (read_fd_set)); 00185 memset (&write_fd_set, 0, sizeof (write_fd_set)); 00186 } |
|
Definition at line 268 of file tcp_srv.cc. 00270 { 00271 TCP_BUFFER_SUBSCRIPTION_INFO *sub_info = 00272 (TCP_BUFFER_SUBSCRIPTION_INFO *) subscription_buffers->get_head (); 00273 while (NULL != sub_info) 00274 { 00275 delete sub_info; 00276 sub_info = 00277 (TCP_BUFFER_SUBSCRIPTION_INFO *) 00278 subscription_buffers->get_next (); 00279 } 00280 delete subscription_buffers; 00281 subscription_buffers = NULL; 00282 } 00283 if (number_of_connected_clients > 0) 00284 { 00285 esleep (2.0); 00286 } 00287 if (connection_socket > 0) 00288 { 00289 dl_closesocket (connection_socket); 00290 connection_socket = 0; 00291 } 00292 } 00293 00294 int 00295 CMS_SERVER_REMOTE_TCP_PORT::accept_local_port_cms (CMS * _cms) 00296 { 00297 if (NULL == _cms) 00298 { 00299 return 0; 00300 } 00301 if (_cms->remote_port_type != CMS_TCP_REMOTE_PORT_TYPE) 00302 { 00303 return 0; |
|
Definition at line 459 of file tcp_srv.cc. 00463 { |
|
Definition at line 713 of file tcp_srv.cc. 00720 { |
|
Definition at line 70 of file tcp_srv.cc. |
|
Definition at line 71 of file tcp_srv.cc. |
|
Definition at line 148 of file tcp_srv.cc. |
|
Definition at line 149 of file tcp_srv.cc. |
|
Definition at line 150 of file tcp_srv.cc. |
|
Definition at line 151 of file tcp_srv.cc. |
|
Definition at line 456 of file tcp_srv.cc. |
|
Definition at line 709 of file tcp_srv.cc. |
|
Definition at line 710 of file tcp_srv.cc. |