Lines Matching refs:task
50 void ProcesslTaskCb(std::shared_ptr<HttpClientTask> task);
64 auto task = session.CreateTask(httpReq); variable
66 uint32_t httpVersionTest = task->GetHttpVersion(HttpProtocol::HTTP_NONE);
76 auto task = session.CreateTask(httpReq); variable
78 uint32_t httpVersionTest = task->GetHttpVersion(HttpProtocol::HTTP1_1);
88 auto task = session.CreateTask(httpReq); variable
90 uint32_t httpVersionTest = task->GetHttpVersion(HttpProtocol::HTTP2);
92 httpVersionTest = task->GetHttpVersion(HttpProtocol::HTTP3);
111 auto task = session.CreateTask(httpReq); variable
113 bool result = task->SetOtherCurlOption(task->curlHandle_);
131 auto task = session.CreateTask(httpReq); variable
133 EXPECT_TRUE(task->SetOtherCurlOption(task->curlHandle_));
150 auto task = session.CreateTask(httpReq); variable
152 EXPECT_TRUE(task->SetOtherCurlOption(task->curlHandle_));
170 auto task = session.CreateTask(httpReq); variable
172 EXPECT_TRUE(task->SetOtherCurlOption(task->curlHandle_));
173 curl_easy_cleanup(task->curlHandle_);
174 task->curlHandle_ = nullptr;
192 auto task = session.CreateTask(httpReq); variable
193 EXPECT_TRUE(task->SetOtherCurlOption(task->curlHandle_));
194 curl_easy_cleanup(task->curlHandle_);
195 task->curlHandle_ = nullptr;
208 auto task = session.CreateTask(httpReq, UPLOAD, filePath); variable
210 EXPECT_TRUE(task->SetUploadOptions(task->curlHandle_));
223 auto task = session.CreateTask(httpReq, UPLOAD, filePath); variable
225 EXPECT_FALSE(task->SetUploadOptions(task->curlHandle_));
238 auto task = session.CreateTask(httpReq, UPLOAD, filePath); variable
240 EXPECT_FALSE(task->SetUploadOptions(task->curlHandle_));
250 auto task = session.CreateTask(httpReq); variable
252 EXPECT_TRUE(task->SetCurlOptions());
262 auto task = session.CreateTask(httpReq); variable
264 task->request_.SetMethod(HttpConstant::HTTP_METHOD_HEAD);
266 EXPECT_TRUE(task->SetCurlOptions());
279 auto task = session.CreateTask(httpReq, UPLOAD, filePath); variable
281 task->curlHandle_ = nullptr;
282 EXPECT_FALSE(task->SetCurlOptions());
292 auto task = session.CreateTask(httpReq); variable
294 task->request_.SetMethod(HttpConstant::HTTP_METHOD_POST);
296 EXPECT_TRUE(task->SetCurlOptions());
306 auto task = session.CreateTask(httpReq); variable
308 task->curlHandle_ = nullptr;
310 EXPECT_FALSE(task->SetCurlOptions());
320 auto task = session.CreateTask(httpReq); variable
322 task->curlHandle_ = nullptr;
324 task->curlHeaderList_ = curl_slist_append(task->curlHeaderList_, headerStr.c_str());
326 EXPECT_FALSE(task->SetCurlOptions());
336 auto task = session.CreateTask(httpReq); variable
338 EXPECT_EQ(TaskType::DEFAULT, task->GetType());
351 auto task = session.CreateTask(httpReq, UPLOAD, filePath); variable
353 EXPECT_EQ(task->GetFilePath(), "/bin/who");
362 auto task = session.CreateTask(httpReq); variable
364 unsigned int taskId = task->GetTaskId();
375 auto task = session.CreateTask(httpReq); variable
376 … task->OnSuccess([task](const HttpClientRequest &request, const HttpClientResponse &response) {}); in __anone15c4ce60202()
378 EXPECT_TRUE(task->onSucceeded_ != nullptr);
388 auto task = session.CreateTask(httpReq); variable
390 task->OnCancel([](const HttpClientRequest &request, const HttpClientResponse &response) {}); in __anone15c4ce60302()
392 EXPECT_TRUE(task->onCanceled_ != nullptr);
402 auto task = session.CreateTask(httpReq); variable
404 task->OnFail(
407 EXPECT_TRUE(task->onFailed_ != nullptr);
417 auto task = session.CreateTask(httpReq); variable
419 … task->OnDataReceive([](const HttpClientRequest &request, const uint8_t *data, size_t length) {}); in __anone15c4ce60502()
421 EXPECT_TRUE(task->onDataReceive_ != nullptr);
431 auto task = session.CreateTask(httpReq); variable
433 task->OnProgress(
436 EXPECT_TRUE(task->onProgress_ != nullptr);
447 auto task = session.CreateTask(httpReq); variable
449 auto *userData = task.get();
453 … task->OnDataReceive([](const HttpClientRequest &request, const uint8_t *data, size_t length) {}); in __anone15c4ce60702()
454 size_t result = task->DataReceiveCallback(data, size, memBytes, userData);
467 auto task = session.CreateTask(httpReq); variable
469 auto *userData = task.get();
472 size_t result = task->DataReceiveCallback(data, size, memBytes, userData);
485 auto task = session.CreateTask(httpReq); variable
487 auto *userData = task.get();
490 task->canceled_ = true;
491 size_t result = task->DataReceiveCallback(data, size, memBytes, userData);
494 task->canceled_ = false;
504 auto task = session.CreateTask(httpReq); variable
506 auto *userData = task.get();
513 result = task->ProgressCallback(userData, dltotal, dlnow, ultotal, ulnow);
524 auto task = session.CreateTask(httpReq); variable
526 auto *userData = task.get();
533 task->Cancel();
534 result = task->ProgressCallback(userData, dltotal, dlnow, ultotal, ulnow);
545 auto task = session.CreateTask(httpReq); variable
547 auto *userData = task.get();
553 int result = task->ProgressCallback(userData, dltotal, dlnow, ultotal, ulnow);
564 auto task = session.CreateTask(httpReq); variable
566 auto *userData = task.get();
570 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userData);
581 auto task = session.CreateTask(httpReq); variable
583 auto *userData = task.get();
588 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userData);
599 auto task = session.CreateTask(httpReq); variable
601 auto *userData = task.get();
606 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userData);
617 auto task = session.CreateTask(httpReq); variable
618 task->Start();
620 while (task->GetStatus() != TaskStatus::IDLE) {
623 EXPECT_TRUE(task->ProcessResponseCode());
633 auto task = session.CreateTask(httpReq); variable
637 task->OnCancel([](const HttpClientRequest &request, const HttpClientResponse &response) {}); in __anone15c4ce60802()
638 task->ProcessResponse(&msg);
639 EXPECT_TRUE(task->onCanceled_);
642 task->OnFail(
644 task->ProcessResponse(&msg);
645 EXPECT_TRUE(task->onFailed_);
648 task->response_.SetResponseCode(ResponseCode::NOT_MODIFIED);
649 … task->OnSuccess([task](const HttpClientRequest &request, const HttpClientResponse &response) {}); in __anone15c4ce60a02()
650 task->ProcessResponse(&msg);
651 EXPECT_TRUE(task->onSucceeded_);
653 task->curlHandle_ = nullptr;
654 task->OnFail(
656 task->ProcessResponse(&msg);
657 EXPECT_TRUE(task->onFailed_);
667 auto task = session.CreateTask(httpReq); variable
671 task->SetResponse(resp);
673 EXPECT_EQ(task->response_.result_, "result1");
691 auto task = session.CreateTask(httpReq); variable
697 task->GetHttpProxyInfo(host, port, exclusions, tunnel);
720 auto task = session.CreateTask(httpReq); variable
726 task->GetHttpProxyInfo(host, port, exclusions, tunnel);
741 auto task = session.CreateTask(httpReq); variable
743 task->SetStatus(RUNNING);
744 EXPECT_EQ(RUNNING, task->GetStatus());
754 auto task = session.CreateTask(httpReq); variable
756 EXPECT_EQ(IDLE, task->GetStatus());
766 auto task = session.CreateTask(httpReq); variable
768 task->SetStatus(TaskStatus::RUNNING);
770 EXPECT_EQ(task->GetStatus(), RUNNING);
780 auto task = session.CreateTask(httpReq); variable
782 task->SetStatus(TaskStatus::RUNNING);
783 bool result = task->Start();
794 auto task = session.CreateTask(httpReq); variable
796 task->error_.SetErrorCode(HttpErrorCode::HTTP_UNSUPPORTED_PROTOCOL);
797 bool result = task->Start();
808 auto task = session.CreateTask(httpReq); variable
810 task->Cancel();
811 EXPECT_TRUE(task->canceled_);
821 auto task = session.CreateTask(httpReq); variable
823 bool result = task->SetServerSSLCertOption(task->curlHandle_);
846 auto task = session.CreateTask(httpReq); variable
847 EXPECT_TRUE(task->SetServerSSLCertOption(task->curlHandle_));