Lines Matching refs:task
49 void ProcesslTaskCb(std::shared_ptr<HttpClientTask> task);
63 auto task = session.CreateTask(httpReq);
65 uint32_t httpVersionTest = task->GetHttpVersion(HttpProtocol::HTTP_NONE);
75 auto task = session.CreateTask(httpReq);
77 uint32_t httpVersionTest = task->GetHttpVersion(HttpProtocol::HTTP1_1);
87 auto task = session.CreateTask(httpReq);
89 uint32_t httpVersionTest = task->GetHttpVersion(HttpProtocol::HTTP2);
91 httpVersionTest = task->GetHttpVersion(HttpProtocol::HTTP3);
110 auto task = session.CreateTask(httpReq);
112 bool result = task->SetOtherCurlOption(task->curlHandle_);
130 auto task = session.CreateTask(httpReq);
132 EXPECT_TRUE(task->SetOtherCurlOption(task->curlHandle_));
149 auto task = session.CreateTask(httpReq);
151 EXPECT_TRUE(task->SetOtherCurlOption(task->curlHandle_));
169 auto task = session.CreateTask(httpReq);
171 EXPECT_TRUE(task->SetOtherCurlOption(task->curlHandle_));
172 curl_easy_cleanup(task->curlHandle_);
173 task->curlHandle_ = nullptr;
191 auto task = session.CreateTask(httpReq);
192 EXPECT_TRUE(task->SetOtherCurlOption(task->curlHandle_));
193 curl_easy_cleanup(task->curlHandle_);
194 task->curlHandle_ = nullptr;
207 auto task = session.CreateTask(httpReq, UPLOAD, filePath);
209 EXPECT_TRUE(task->SetUploadOptions(task->curlHandle_));
222 auto task = session.CreateTask(httpReq, UPLOAD, filePath);
224 EXPECT_FALSE(task->SetUploadOptions(task->curlHandle_));
237 auto task = session.CreateTask(httpReq, UPLOAD, filePath);
239 EXPECT_FALSE(task->SetUploadOptions(task->curlHandle_));
249 auto task = session.CreateTask(httpReq);
251 EXPECT_TRUE(task->SetCurlOptions());
261 auto task = session.CreateTask(httpReq);
263 task->request_.SetMethod(HttpConstant::HTTP_METHOD_HEAD);
265 EXPECT_TRUE(task->SetCurlOptions());
278 auto task = session.CreateTask(httpReq, UPLOAD, filePath);
280 task->curlHandle_ = nullptr;
281 EXPECT_FALSE(task->SetCurlOptions());
291 auto task = session.CreateTask(httpReq);
293 task->request_.SetMethod(HttpConstant::HTTP_METHOD_POST);
295 EXPECT_TRUE(task->SetCurlOptions());
305 auto task = session.CreateTask(httpReq);
307 task->curlHandle_ = nullptr;
309 EXPECT_FALSE(task->SetCurlOptions());
319 auto task = session.CreateTask(httpReq);
321 task->curlHandle_ = nullptr;
323 task->curlHeaderList_ = curl_slist_append(task->curlHeaderList_, headerStr.c_str());
325 EXPECT_FALSE(task->SetCurlOptions());
335 auto task = session.CreateTask(httpReq);
337 EXPECT_EQ(TaskType::DEFAULT, task->GetType());
350 auto task = session.CreateTask(httpReq, UPLOAD, filePath);
352 EXPECT_EQ(task->GetFilePath(), "/bin/who");
361 auto task = session.CreateTask(httpReq);
363 unsigned int taskId = task->GetTaskId();
374 auto task = session.CreateTask(httpReq);
375 task->OnSuccess([task](const HttpClientRequest &request, const HttpClientResponse &response) {});
377 EXPECT_TRUE(task->onSucceeded_ != nullptr);
387 auto task = session.CreateTask(httpReq);
389 task->OnCancel([](const HttpClientRequest &request, const HttpClientResponse &response) {});
391 EXPECT_TRUE(task->onCanceled_ != nullptr);
401 auto task = session.CreateTask(httpReq);
403 task->OnFail(
406 EXPECT_TRUE(task->onFailed_ != nullptr);
416 auto task = session.CreateTask(httpReq);
418 task->OnDataReceive([](const HttpClientRequest &request, const uint8_t *data, size_t length) {});
420 EXPECT_TRUE(task->onDataReceive_ != nullptr);
430 auto task = session.CreateTask(httpReq);
432 task->OnProgress(
435 EXPECT_TRUE(task->onProgress_ != nullptr);
446 auto task = session.CreateTask(httpReq);
448 auto *userData = task.get();
452 task->OnDataReceive([](const HttpClientRequest &request, const uint8_t *data, size_t length) {});
453 size_t result = task->DataReceiveCallback(data, size, memBytes, userData);
466 auto task = session.CreateTask(httpReq);
468 auto *userData = task.get();
471 size_t result = task->DataReceiveCallback(data, size, memBytes, userData);
484 auto task = session.CreateTask(httpReq);
486 auto *userData = task.get();
489 task->canceled_ = true;
490 size_t result = task->DataReceiveCallback(data, size, memBytes, userData);
493 task->canceled_ = false;
503 auto task = session.CreateTask(httpReq);
505 auto *userData = task.get();
512 result = task->ProgressCallback(userData, dltotal, dlnow, ultotal, ulnow);
523 auto task = session.CreateTask(httpReq);
525 auto *userData = task.get();
532 task->Cancel();
533 result = task->ProgressCallback(userData, dltotal, dlnow, ultotal, ulnow);
544 auto task = session.CreateTask(httpReq);
546 auto *userData = task.get();
552 int result = task->ProgressCallback(userData, dltotal, dlnow, ultotal, ulnow);
563 auto task = session.CreateTask(httpReq);
565 auto *userData = task.get();
569 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userData);
580 auto task = session.CreateTask(httpReq);
582 auto *userData = task.get();
587 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userData);
598 auto task = session.CreateTask(httpReq);
600 auto *userData = task.get();
605 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userData);
616 auto task = session.CreateTask(httpReq);
617 task->Start();
619 while (task->GetStatus() != TaskStatus::IDLE) {
622 EXPECT_TRUE(task->ProcessResponseCode());
632 auto task = session.CreateTask(httpReq);
636 task->OnCancel([](const HttpClientRequest &request, const HttpClientResponse &response) {});
637 task->ProcessResponse(&msg);
638 EXPECT_TRUE(task->onCanceled_);
641 task->OnFail(
643 task->ProcessResponse(&msg);
644 EXPECT_TRUE(task->onFailed_);
647 task->response_.SetResponseCode(ResponseCode::NOT_MODIFIED);
648 task->OnSuccess([task](const HttpClientRequest &request, const HttpClientResponse &response) {});
649 task->ProcessResponse(&msg);
650 EXPECT_TRUE(task->onSucceeded_);
652 task->curlHandle_ = nullptr;
653 task->OnFail(
655 task->ProcessResponse(&msg);
656 EXPECT_TRUE(task->onFailed_);
666 auto task = session.CreateTask(httpReq);
670 task->SetResponse(resp);
672 EXPECT_EQ(task->response_.result_, "result1");
690 auto task = session.CreateTask(httpReq);
696 task->GetHttpProxyInfo(host, port, exclusions, tunnel);
719 auto task = session.CreateTask(httpReq);
725 task->GetHttpProxyInfo(host, port, exclusions, tunnel);
740 auto task = session.CreateTask(httpReq);
742 task->SetStatus(RUNNING);
743 EXPECT_EQ(RUNNING, task->GetStatus());
753 auto task = session.CreateTask(httpReq);
755 EXPECT_EQ(IDLE, task->GetStatus());
765 auto task = session.CreateTask(httpReq);
767 task->SetStatus(TaskStatus::RUNNING);
769 EXPECT_EQ(task->GetStatus(), RUNNING);
779 auto task = session.CreateTask(httpReq);
781 task->SetStatus(TaskStatus::RUNNING);
782 bool result = task->Start();
793 auto task = session.CreateTask(httpReq);
795 task->error_.SetErrorCode(HttpErrorCode::HTTP_UNSUPPORTED_PROTOCOL);
796 bool result = task->Start();
807 auto task = session.CreateTask(httpReq);
808 task->Start();
810 while (task->GetStatus() != TaskStatus::IDLE) {
813 EXPECT_EQ(task->GetResponse().GetResponseCode(), ResponseCode::OK);
823 auto task = session.CreateTask(httpReq);
825 task->Cancel();
826 EXPECT_TRUE(task->canceled_);
836 auto task = session.CreateTask(httpReq);
838 bool result = task->SetServerSSLCertOption(task->curlHandle_);
861 auto task = session.CreateTask(httpReq);
862 EXPECT_TRUE(task->SetServerSSLCertOption(task->curlHandle_));