diff options
Diffstat (limited to 'ace/TLI_Acceptor.h')
-rw-r--r-- | ace/TLI_Acceptor.h | 109 |
1 files changed, 109 insertions, 0 deletions
diff --git a/ace/TLI_Acceptor.h b/ace/TLI_Acceptor.h new file mode 100644 index 00000000000..374216c5a18 --- /dev/null +++ b/ace/TLI_Acceptor.h @@ -0,0 +1,109 @@ +/* -*- C++ -*- */ +// $Id$ + + +// ============================================================================ +// +// = LIBRARY +// ace +// +// = FILENAME +// TLI_Acceptor.h +// +// = AUTHOR +// Doug Schmidt +// +// ============================================================================ + +#if !defined (ACE_TLI_ACCEPTOR_H) +#define ACE_TLI_ACCEPTOR_H + +#include "ace/TLI.h" +#include "ace/Time_Value.h" +#include "ace/TLI_Stream.h" + +#if defined (ACE_HAS_TLI) + +/* Oh what I wouldn't do for namespaces... */ + +// Forward reference... +class ACE_TLI_Request_Queue; + +class ACE_Export ACE_TLI_Acceptor : public ACE_TLI + // = TITLE + // Defines the member functions for ACE_TLI_Acceptor abstraction. + // + // = DESCRIPTION + // This class implements the algorithm described in Steve Rago's + // book on System V UNIX network programming. It basically + // makes TLI look like the C++ SOCK_SAP socket wrappers with + // respect to establishing passive-mode listener endpoints. +{ +friend class ACE_Request_Queue; +public: + // = Initialization and termination methods. + ACE_TLI_Acceptor (void); + // Default constructor. + + ACE_TLI_Acceptor (const ACE_Addr &remote_sap, + int reuse_addr = 0, + int oflag = O_RDWR, + struct t_info *info = 0, + int backlog = 5, + const char device[] = "/dev/tcp"); + // Initiate a passive mode socket. + + ACE_HANDLE open (const ACE_Addr &remote_sap, + int reuse_addr = 0, + int oflag = O_RDWR, + struct t_info *info = 0, + int backlog = 5, + const char device[] = "/dev/tcp"); + // Initiate a passive mode socket. + + int close (void); + // Close down the acceptor and release resources. + + // = Passive connection acceptance method. + + int accept (ACE_TLI_Stream &new_tli_sap, + ACE_Addr *remote_addr = 0, + ACE_Time_Value *timeout = 0, + int restart = 1, + int rwflag = 1, + netbuf *udata = 0, + netbuf *opt = 0); + // Accept a new data transfer connection. A <timeout> of 0 means + // block forever, a <timeout> of {0, 0} means poll. <restart> == 1 + // means "restart if interrupted." + + void dump (void) const; + // Dump the state of an object. + + ACE_ALLOC_HOOK_DECLARE; + // Declare the dynamic allocation hooks. + +private: + const char *device_; + // Network "device" we are using. + + int backlog_; + // Number of connections to queue. + + int rwflag_; + // Are we using "tirdwr" mod? + + int handle_async_event (int restart, int rwflag); + // Handle TLI accept insanity... + + ACE_TLI_Request_Queue *queue_; + // Used for queueing up pending requests. + + struct t_discon *disp_; + // Used for handling disconnects +}; + +#include "ace/TLI_Acceptor.i" + +#endif /* ACE_HAS_TLI */ +#endif /* ACE_TLI_ACCEPTOR_H */ |