reactive_socket.cpp

来自「这是广泛使用的通信开源项目,对于大容量,高并发的通讯要求完全能够胜任,他广泛可用」· C++ 代码 · 共 84 行

// Reactive_Socket.cpp,v 1.2 2003/11/09 04:12:07 dhinton Exp

#include "ace/Addr.h"
#include "ace/Acceptor.h"
#include "ace/Singleton.h"
#include "ace/SOCK_Stream.h"
#include "ace/SOCK_Acceptor.h"

#define JAWS_BUILD_DLL

#include "jaws3/Socket.h"
#include "jaws3/Reactive_Socket.h"


class JAWS_Socket_EC_SH_Adapter;

typedef ACE_Oneshot_Acceptor<JAWS_Socket_EC_SH_Adapter, ACE_SOCK_ACCEPTOR>
        JAWS_Socket_Oneshot_Acceptor;


void
JAWS_Reactive_Socket::accept ( const ACE_Addr &local_sap
                             , ACE_SOCK_Stream &new_stream
                             , JAWS_Event_Completer *completer
                             , void *act
                             )
{
}


void
JAWS_Reactive_Socket::connect ( const ACE_Addr &remote_sap
                              , ACE_SOCK_Stream &new_stream
                              , JAWS_Event_Completer *completer
                              , void *act
                              )
{
}


void
JAWS_Reactive_Socket::connect ( const ACE_Addr &remote_sap
                              , ACE_SOCK_Stream &new_stream
                              , const ACE_Addr &local_sap
                              , JAWS_Event_Completer *completer
                              , void *act
                              )
{
}


void
JAWS_Reactive_Socket::accept ( const ACE_Addr &local_sap
                             , ACE_SOCK_Stream &new_stream
                             , JAWS_Event_Completer *completer
                             , const ACE_Time_Value &timeout
                             , void *act
                             )
{
}


void
JAWS_Reactive_Socket::connect ( const ACE_Addr &remote_sap
                              , ACE_SOCK_Stream &new_stream
                              , JAWS_Event_Completer *completer
                              , const ACE_Time_Value &timeout
                              , void *act
                              )
{
}


void
JAWS_Reactive_Socket::connect ( const ACE_Addr &remote_sap
                              , ACE_SOCK_Stream &new_stream
                              , const ACE_Addr &local_sap
                              , JAWS_Event_Completer *completer
                              , const ACE_Time_Value &timeout
                              , void *act
                              )
{
}