1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
/* -*- c++ -*- */
// $Id$
#include "ace/OS.h"
#include "ace/Addr.h"
#include "ace/Synch.h"
#include "ace/Acceptor.h"
#include "ace/Singleton.h"
#include "ace/SOCK_Stream.h"
#include "ace/SOCK_Acceptor.h"
#include "jaws3/Reactive_Socket_Helpers.h"
JAWS_Socket_EC_SH_Adapter
::JAWS_Socket_EC_SH_Adapter ( ACE_SOCK_Stream *stream
, JAWS_Event_Completer *completer
, void *act
, JAWS_EC_CALLBACK callback
, JAWS_Event_Result::JE_REASON ok_reason
, JAWS_Event_Result::JE_REASON timeout_reason
, JAWS_Event_Result::JE_REASON error_reason
)
: stream_ (stream)
, completer_ (completer)
, act_ (act)
, callback_ (callback)
, ok_reason_ (ok_reason)
, timeout_reason_ (timeout_reason)
, error_reason_ (error_reason)
{
}
int
JAWS_Socket_EC_SH_Adapter::open (void *)
{
JAWS_Event_Result result ( 0
, JAWS_Event_Result::JE_OK
, this->ok_reason_
, 0
, this->stream_);
*this->stream_ = this->peer ();
this->set_handle (ACE_INVALID_HANDLE);
(this->completer_->*callback_) (result, this->act_);
return -1;
}
JAWS_Socket_Accept_EC_SH_Adapter
::JAWS_Socket_Accept_EC_SH_Adapter ( ACE_SOCK_Stream *stream
, JAWS_Event_Completer *completer
, void *act
)
: JAWS_Socket_EC_SH_Adapter ( stream
, completer
, act
, & JAWS_Event_Completer::accept_complete
, JAWS_Event_Result::JE_ACCEPT_OK
, JAWS_Event_Result::JE_ACCEPT_TIMEOUT
, JAWS_Event_Result::JE_ACCEPT_FAIL
)
{
}
JAWS_Socket_Connect_EC_SH_Adapter::
JAWS_Socket_Connect_EC_SH_Adapter ( ACE_SOCK_Stream *stream
, JAWS_Event_Completer *completer
, void *act
)
: JAWS_Socket_EC_SH_Adapter ( stream
, completer
, act
, & JAWS_Event_Completer::connect_complete
, JAWS_Event_Result::JE_CONNECT_OK
, JAWS_Event_Result::JE_CONNECT_TIMEOUT
, JAWS_Event_Result::JE_CONNECT_FAIL
)
{
}
|
