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

Method rpc_wakeup

lib_acl_cpp/samples/gui_rpc/rpc/http_download.cpp:142–172  ·  view source on GitHub ↗

���̴߳������̣��յ����̵߳�֪ͨ��Ϣ

Source from the content-addressed store, hash-verified

140
141// ���̴߳������̣��յ����̵߳�֪ͨ��Ϣ
142void http_download::rpc_wakeup(void* ctx)
143{
144 DOWN_CTX* down_ctx = (DOWN_CTX*) ctx;
145
146 // �������߳��д����IJ�ͬ�����ؽ׶ν��д���
147
148 switch (down_ctx->type)
149 {
150 case CTX_T_REQ_HDR:
151 callback_->SetRequestHdr(req_hdr_.c_str());
152 break;
153 case CTX_T_RES_HDR:
154 callback_->SetResponseHdr(res_hdr_.c_str());
155 break;
156 case CTX_T_CONTENT_LENGTH:
157 break;
158 case CTX_T_PARTIAL_LENGTH:
159 total_read_ += down_ctx->length;
160 callback_->OnDownloading(content_length_, total_read_);
161 break;
162 case CTX_T_END:
163 logger("%s: read over", addr_.c_str());
164 break;
165 default:
166 logger_error("%s: ERROR", addr_.c_str());
167 break;
168 }
169
170 // ɾ�������߳��ж�̬����Ķ���
171 delete down_ctx;
172}
173
174//////////////////////////////////////////////////////////////////////////

Callers 2

on_messageMethod · 0.45
win32_procMethod · 0.45

Calls 4

SetRequestHdrMethod · 0.80
SetResponseHdrMethod · 0.80
OnDownloadingMethod · 0.80
c_strMethod · 0.45

Tested by

no test coverage detected