#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. |
1.2.11.1 written by Dimitri van Heesch,
© 1997-2001