MCPcopy Create free account
hub / github.com/acl-dev/acl / open

Method open

lib_acl_cpp/src/ipc/ipc_client.cpp:48–67  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

46}
47
48bool ipc_client::open(aio_handle* handle, const char* addr, int timeout)
49{
50 acl_assert(sync_stream_ == NULL && async_stream_ == NULL);
51
52 async_stream_ = aio_socket_stream::open(handle, addr, timeout);
53 if (async_stream_ == NULL) {
54 return false;
55 }
56 addr_ = acl_mystrdup(addr);
57
58 // �������ӳɹ��Ļص�������
59 async_stream_->add_open_callback(this);
60
61 // ��������ʧ�ܺ�ص�������
62 async_stream_->add_close_callback(this);
63
64 // �������ӳ�ʱ�Ļص�������
65 async_stream_->add_timeout_callback(this);
66 return true;
67}
68
69void ipc_client::open(aio_socket_stream* client)
70{

Callers 4

thread_pool_mainFunction · 0.45
thread_once_mainFunction · 0.45
peek_connMethod · 0.45
on_acceptMethod · 0.45

Calls 7

openFunction · 0.85
add_open_callbackMethod · 0.80
add_close_callbackMethod · 0.80
add_timeout_callbackMethod · 0.80
add_read_callbackMethod · 0.80
add_write_callbackMethod · 0.80
socket_streamClass · 0.50

Tested by

no test coverage detected