/foundation/arkui/ace_engine/adapter/preview/osal/ |
H A D | fetch_manager.cpp | 154 static size_t OnWritingMemoryBody(const void* data, size_t size, size_t memBytes, void* userData) in OnWritingMemoryBody() argument 156 ((std::string*)userData)->append((char*)data, 0, size * memBytes); in OnWritingMemoryBody() 157 return size * memBytes; in OnWritingMemoryBody() 159 static size_t OnWritingMemoryHeader(const void* data, size_t size, size_t memBytes, void* userData) in OnWritingMemoryHeader() argument 161 ((std::string*)userData)->append((char*)data, 0, size * memBytes); in OnWritingMemoryHeader() 162 return size * memBytes; in OnWritingMemoryHeader()
|
H A D | download_manager_preview.cpp | 154 static size_t OnWritingMemory(void* data, size_t size, size_t memBytes, void* userData) in OnWritingMemory() argument 159 dataOut.insert(dataOut.end(), chunkData, chunkData + memBytes); in OnWritingMemory() 160 return memBytes; in OnWritingMemory()
|
/foundation/communication/netstack/frameworks/js/builtin/fetch/src/ |
H A D | http_request.cpp | 158 size_t HttpRequest::OnWritingMemoryBody(const void *data, size_t size, size_t memBytes, void *userData) in OnWritingMemoryBody() argument 160 static_cast<ResponseData *>(userData)->AppendData(static_cast<const char *>(data), size * memBytes); in OnWritingMemoryBody() local 161 return size * memBytes; in OnWritingMemoryBody() 164 size_t HttpRequest::OnWritingMemoryHeader(const void *data, size_t size, size_t memBytes, void *userData) in OnWritingMemoryHeader() argument 166 static_cast<std::string *>(userData)->append(static_cast<const char *>(data), size * memBytes); in OnWritingMemoryHeader() local 167 return size * memBytes; in OnWritingMemoryHeader()
|
/foundation/communication/netstack/frameworks/js/builtin/fetch/include/ |
H A D | http_request.h | 45 static size_t OnWritingMemoryBody(const void *data, size_t size, size_t memBytes, void *userData); 47 static size_t OnWritingMemoryHeader(const void *data, size_t size, size_t memBytes, void *userData);
|
/foundation/communication/netstack/frameworks/js/napi/fetch/fetch_exec/include/ |
H A D | fetch_exec.h | 53 static size_t OnWritingMemoryBody(const void *data, size_t size, size_t memBytes, void *userData); 55 static size_t OnWritingMemoryHeader(const void *data, size_t size, size_t memBytes, void *userData);
|
/foundation/communication/netstack/frameworks/native/http/http_client/ |
H A D | http_client_task.cpp | 507 size_t HttpClientTask::DataReceiveCallback(const void *data, size_t size, size_t memBytes, void *userData) in DataReceiveCallback() argument 510 NETSTACK_LOGD("taskId=%{public}d size=%{public}zu memBytes=%{public}zu", task->taskId_, size, memBytes); in DataReceiveCallback() 519 task->onDataReceive_(request, static_cast<const uint8_t *>(data), size * memBytes); in DataReceiveCallback() 523 task->response_.AppendResult(data, size * memBytes); in DataReceiveCallback() 526 return size * memBytes; in DataReceiveCallback() 549 size_t HttpClientTask::HeaderReceiveCallback(const void *data, size_t size, size_t memBytes, void *userData) in HeaderReceiveCallback() argument 553 NETSTACK_LOGD("taskId=%{public}d size=%{public}zu memBytes=%{public}zu", task->taskId_, size, memBytes); in HeaderReceiveCallback() 555 if (size * memBytes > MAX_LIMI in HeaderReceiveCallback() 560 task->response_.AppendHeader(static_cast<const char *>(data), size * memBytes); HeaderReceiveCallback() local [all...] |
/foundation/communication/netmanager_base/test/netsysbpfstats/unittest/bpf_core_test/ |
H A D | BpfTaskTaskTest.cpp | 451 size_t memBytes = 1; in HWTEST_F() local 454 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 456 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 471 size_t memBytes = 1; in HWTEST_F() local 472 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 474 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 489 size_t memBytes = 1; in HWTEST_F() local 491 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 569 size_t memBytes = 2; in HWTEST_F() local 570 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userDat in HWTEST_F() 587 size_t memBytes = 1; HWTEST_F() local 605 size_t memBytes = 2; HWTEST_F() local [all...] |
/foundation/communication/netmanager_base/test/netmanagernative/unittest/netsys_core_test/ |
H A D | NetSysTaskTaskTest.cpp | 451 size_t memBytes = 1; in HWTEST_F() local 454 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 456 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 471 size_t memBytes = 1; in HWTEST_F() local 472 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 474 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 489 size_t memBytes = 1; in HWTEST_F() local 491 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 569 size_t memBytes = 2; in HWTEST_F() local 570 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userDat in HWTEST_F() 587 size_t memBytes = 1; HWTEST_F() local 605 size_t memBytes = 2; HWTEST_F() local [all...] |
/foundation/communication/netmanager_ext/test/vpnmanager/unittest/vpn_core_test/ |
H A D | VpnTaskTaskTest.cpp | 451 size_t memBytes = 1; in HWTEST_F() local 454 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 456 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 471 size_t memBytes = 1; in HWTEST_F() local 472 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 474 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 489 size_t memBytes = 1; in HWTEST_F() local 491 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 569 size_t memBytes = 2; in HWTEST_F() local 570 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userDat in HWTEST_F() 587 size_t memBytes = 1; HWTEST_F() local 605 size_t memBytes = 2; HWTEST_F() local [all...] |
/foundation/communication/netstack/test/unittest/http_test/ |
H A D | HttpClientTaskTest.cpp | 451 size_t memBytes = 1; in HWTEST_F() local 454 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 456 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 471 size_t memBytes = 1; in HWTEST_F() local 472 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 474 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 489 size_t memBytes = 1; in HWTEST_F() local 491 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 569 size_t memBytes = 2; in HWTEST_F() local 570 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userDat in HWTEST_F() 587 size_t memBytes = 1; HWTEST_F() local 605 size_t memBytes = 2; HWTEST_F() local [all...] |
/foundation/communication/netstack/test/unittest/tcp_core_test/ |
H A D | TcpSocketTaskTaskTest.cpp | 451 size_t memBytes = 1; in HWTEST_F() local 454 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 456 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 471 size_t memBytes = 1; in HWTEST_F() local 472 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 474 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 489 size_t memBytes = 1; in HWTEST_F() local 491 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 569 size_t memBytes = 2; in HWTEST_F() local 570 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userDat in HWTEST_F() 587 size_t memBytes = 1; HWTEST_F() local 605 size_t memBytes = 2; HWTEST_F() local [all...] |
/foundation/communication/netmanager_ext/test/networksharemanager/unittest/netshare_core_test/ |
H A D | NetShareTaskTaskTest.cpp | 451 size_t memBytes = 1; in HWTEST_F() local 454 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 456 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 471 size_t memBytes = 1; in HWTEST_F() local 472 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 474 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 489 size_t memBytes = 1; in HWTEST_F() local 491 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 569 size_t memBytes = 2; in HWTEST_F() local 570 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userDat in HWTEST_F() 587 size_t memBytes = 1; HWTEST_F() local 605 size_t memBytes = 2; HWTEST_F() local [all...] |
/foundation/communication/netstack/test/unittest/http_client_test/ |
H A D | HttpClientTaskTest.cpp | 450 size_t memBytes = 1; in HWTEST_F() local 453 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 455 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 470 size_t memBytes = 1; in HWTEST_F() local 471 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 473 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 488 size_t memBytes = 1; in HWTEST_F() local 490 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 568 size_t memBytes = 2; in HWTEST_F() local 569 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userDat in HWTEST_F() 586 size_t memBytes = 1; HWTEST_F() local 604 size_t memBytes = 2; HWTEST_F() local [all...] |
/foundation/communication/netstack/test/unittest/http_client/ |
H A D | HttpClientTaskTest.cpp | 451 size_t memBytes = 1; in HWTEST_F() local 454 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 456 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 471 size_t memBytes = 1; in HWTEST_F() local 472 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 474 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 489 size_t memBytes = 1; in HWTEST_F() local 491 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 569 size_t memBytes = 2; in HWTEST_F() local 570 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userDat in HWTEST_F() 587 size_t memBytes = 1; HWTEST_F() local 605 size_t memBytes = 2; HWTEST_F() local [all...] |
/foundation/communication/netstack/test/unittest/websocket_core_test/ |
H A D | WebSocketTaskTaskTest.cpp | 451 size_t memBytes = 1; in HWTEST_F() local 454 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 456 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 471 size_t memBytes = 1; in HWTEST_F() local 472 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 474 EXPECT_EQ(result, size * memBytes); in HWTEST_F() 489 size_t memBytes = 1; in HWTEST_F() local 491 size_t result = task->DataReceiveCallback(data, size, memBytes, userData); in HWTEST_F() 569 size_t memBytes = 2; in HWTEST_F() local 570 size_t result = task->HeaderReceiveCallback(data, size, memBytes, userDat in HWTEST_F() 587 size_t memBytes = 1; HWTEST_F() local 605 size_t memBytes = 2; HWTEST_F() local [all...] |
/foundation/communication/netstack/frameworks/js/napi/fetch/fetch_exec/src/ |
H A D | fetch_exec.cpp | 296 size_t FetchExec::OnWritingMemoryBody(const void *data, size_t size, size_t memBytes, void *userData) in OnWritingMemoryBody() argument 299 context->response.AppendData(data, size * memBytes); in OnWritingMemoryBody() 300 return size * memBytes; in OnWritingMemoryBody() 303 size_t FetchExec::OnWritingMemoryHeader(const void *data, size_t size, size_t memBytes, void *userData) in OnWritingMemoryHeader() argument 306 context->response.AppendRawHeader(data, size * memBytes); in OnWritingMemoryHeader() 307 return size * memBytes; in OnWritingMemoryHeader()
|
/foundation/communication/netstack/frameworks/cj/http/include/ |
H A D | net_http_client_exec.h | 78 static size_t OnWritingMemoryBody(const void *data, size_t size, size_t memBytes, void *userData); 80 static size_t OnWritingMemoryHeader(const void *data, size_t size, size_t memBytes, void *userData);
|
/foundation/communication/netstack/interfaces/innerkits/http_client/include/ |
H A D | http_client_task.h | 282 * @param memBytes Number of elements in the data buffer. 286 static size_t DataReceiveCallback(const void *data, size_t size, size_t memBytes, void *userData); 292 * @param memBytes Number of elements in the data buffer. 296 static size_t HeaderReceiveCallback(const void *data, size_t size, size_t memBytes, void *userData);
|
/foundation/communication/netstack/frameworks/js/napi/http/http_exec/include/ |
H A D | http_exec.h | 107 static size_t OnWritingMemoryBody(const void *data, size_t size, size_t memBytes, void *userData); 109 static size_t OnWritingMemoryHeader(const void *data, size_t size, size_t memBytes, void *userData);
|
/foundation/communication/netstack/frameworks/cj/http/src/ |
H A D | net_http_client_exec.cpp | 810 size_t NetHttpClientExec::OnWritingMemoryBody(const void *data, size_t size, size_t memBytes, void *userData) in OnWritingMemoryBody() argument 825 context->SetTempData(data, size * memBytes); in OnWritingMemoryBody() 836 return size * memBytes; in OnWritingMemoryBody() 843 context->response.AppendResult(data, size * memBytes); in OnWritingMemoryBody() 845 return size * memBytes; in OnWritingMemoryBody() 864 size_t NetHttpClientExec::OnWritingMemoryHeader(const void *data, size_t size, size_t memBytes, void *userData) in OnWritingMemoryHeader() argument 879 context->response.AppendRawHeader(data, size * memBytes); in OnWritingMemoryHeader() 904 return size * memBytes; in OnWritingMemoryHeader()
|
/foundation/arkui/ace_engine/frameworks/base/network/ |
H A D | download_manager_impl.cpp | 378 static size_t OnWritingMemory(void* data, size_t size, size_t memBytes, void* userData) in OnWritingMemory() argument 383 dataOut.insert(dataOut.end(), chunkData, chunkData + memBytes); in OnWritingMemory() 384 return memBytes; in OnWritingMemory()
|
/foundation/communication/netstack/frameworks/js/napi/http/http_exec/src/ |
H A D | http_exec.cpp | 1207 size_t HttpExec::OnWritingMemoryBody(const void *data, size_t size, size_t memBytes, void *userData) in AddCurlHandle() argument 1218 context->SetTempData(data, size * memBytes); in AddCurlHandle() 1222 return size * memBytes; in AddCurlHandle() 1225 size * memBytes > context->options.GetMaxLimit()) { in AddCurlHandle() 1230 context->response.AppendResult(data, size * memBytes); in AddCurlHandle() 1232 return size * memBytes; in AddCurlHandle() 1303 size_t HttpExec::OnWritingMemoryHeader(const void *data, size_t size, size_t memBytes, void *userData) in AddCurlHandle() argument 1314 context->response.AppendRawHeader(data, size * memBytes); in AddCurlHandle() 1327 return size * memBytes; in AddCurlHandle()
|