acl
3.5.3.0
|
#include <ipc_service.hpp>
Public 成员函数 | |
ipc_service (int nthread, bool ipc_keep=true) | |
virtual | ~ipc_service () |
ipc_client * | peek_conn () |
void | push_conn (ipc_client *conn) |
Public 成员函数 继承自 acl::ipc_server | |
ipc_server () | |
virtual | ~ipc_server () |
bool | open (aio_handle *handle, const char *addr="127.0.0.1:0") |
const char * | get_addr () const |
aio_listen_stream * | get_stream () const |
aio_handle & | get_handle () const |
Protected 成员函数 | |
void | request (ipc_request *req) |
Protected 成员函数 继承自 acl::ipc_server | |
virtual void | on_open (const char *addr) |
virtual void | on_close () |
virtual void | on_accept (aio_socket_stream *client) |
Protected 属性 | |
long long int | magic_ |
在文件 ipc_service.hpp 第 56 行定义.
acl::ipc_service::ipc_service | ( | int | nthread, |
bool | ipc_keep = true |
||
) |
构造函数
nthread | {int} 如果该值 > 1 则内部自动采用线程池,否则 则是一个请求一个线程 |
ipc_keep | {bool} 内部 IPC 消息流是否保持长连接,保持长 连接有助于提高消息传递的效率 |
|
virtual |
ipc_client* acl::ipc_service::peek_conn | ( | ) |
从 ipc 消息流连接池中取得一个连接
void acl::ipc_service::push_conn | ( | ipc_client * | conn | ) |
将用完的 ipc 消息连接放回连接池中
conn | {ipc_client*} ipc 消息连接流 |
|
protected |
子类调用此函数发送请求服务
req | {ipc_request*} |
|
protected |
在文件 ipc_service.hpp 第 98 行定义.