同步操作将从 mirrors/srpc 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
long long get_seqid() const;
请求+回复视为1次完整通信,获得当前socket连接上的通信sequence id,seqid=0代表第1次
std::string get_remote_ip() const;
获得对方IP地址,支持ipv4/ipv6
int get_peer_addr(struct sockaddr *addr, socklen_t *addrlen) const;
获得对方地址,in/out参数为更底层的数据结构sockaddr
const std::string& get_service_name() const;
获取RPC Service Name
const std::string& get_method_name() const;
获取RPC Methode Name
SeriesWork *get_series() const;
获取当前ServerTask/ClientTask所在series
bool success() const;
client专用。这次请求是否成功
int get_status_code() const;
client专用。这次请求的rpc status code
const char *get_errmsg() const;
client专用。这次请求的错误信息
int get_error() const;
client专用。这次请求的错误码
void *get_user_data() const;
client专用。获取ClientTask的user_data。如果用户通过create_xxx_task接口产生task,则可以通过user_data域记录上下文,在创建task时设置,在回调函数中拿回。
void set_data_type(RPCDataType type);
Server专用。设置数据打包类型
void set_compress_type(RPCCompressType type);
Server专用。设置数据压缩类型(注:Client的压缩类型在Client或Task上设置)
void set_attachment_nocopy(const char *attachment, size_t len);
Server专用。设置attachment附件。
bool get_attachment(const char **attachment, size_t *len) const;
Server专用。获取attachment附件。
void set_reply_callback(std::function<void (RPCContext *ctx)> cb);
Server专用。设置reply callback,操作系统写入socket缓冲区成功后被调用。
void set_send_timeout(int timeout);
Server专用。设置发送超时,单位毫秒。-1代表无限。
void set_keep_alive(int timeout);
Server专用。设置连接保活时间,单位毫秒。-1代表无限。
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。