#include <ace/TLI_Acceptor.h>
class ACE_TLI_Acceptor : public ACE_TLI {
public:
friend class ACE_Request_Queue;
ACE_TLI_Acceptor (void);
ACE_TLI_Acceptor ( const ACE_Addr &remote_sap, int reuse_addr = 0, int oflag = O_RDWR, struct t_info *info = 0, int backlog = ACE_DEFAULT_BACKLOG, const char device[] = ACE_TLI_TCP_DEVICE );
ACE_HANDLE open ( const ACE_Addr &remote_sap, int reuse_addr = 0, int oflag = O_RDWR, struct t_info *info = 0, int backlog = ACE_DEFAULT_BACKLOG, const char device[] = ACE_TLI_TCP_DEVICE );
int close (void);
int accept ( ACE_TLI_Stream &new_tli_sap, ACE_Addr *remote_addr = 0, ACE_Time_Value *timeout = 0, int restart = 1, int reset_new_handle = 0, int rwflag = 1, netbuf *udata = 0, netbuf *opt = 0 );
typedef ACE_INET_Addr PEER_ADDR;
typedef ACE_TLI_Stream PEER_STREAM;
void dump (void) const;
ACE_ALLOC_HOOK_DECLARE;
private:
const char *device_;
int backlog_;
int rwflag_;
int handle_async_event (int restart, int rwflag);
ACE_TLI_Request_Queue *queue_;
};
ACE_TLI_Acceptor (void);
ACE_TLI_Acceptor (
const ACE_Addr &remote_sap,
int reuse_addr = 0,
int oflag = O_RDWR,
struct t_info *info = 0,
int backlog = ACE_DEFAULT_BACKLOG,
const char device[] = ACE_TLI_TCP_DEVICE
);
ACE_HANDLE open (
const ACE_Addr &remote_sap,
int reuse_addr = 0,
int oflag = O_RDWR,
struct t_info *info = 0,
int backlog = ACE_DEFAULT_BACKLOG,
const char device[] = ACE_TLI_TCP_DEVICE
);
int close (void);
int accept (
ACE_TLI_Stream &new_tli_sap,
ACE_Addr *remote_addr = 0,
ACE_Time_Value *timeout = 0,
int restart = 1,
int reset_new_handle = 0,
int rwflag = 1,
netbuf *udata = 0,
netbuf *opt = 0
);
timeout
of 0 means
block forever, a timeout
of {0, 0} means poll. restart
== 1
means "restart if interrupted."
typedef ACE_INET_Addr PEER_ADDR;
typedef ACE_TLI_Stream PEER_STREAM;
void dump (void) const;
ACE_ALLOC_HOOK_DECLARE;