| /foundation/resourceschedule/ffrt/src/dfx/watchdog/ |
| H A D | watchdog_util.cpp | 102 int sendCount = taskStatusMap[gid]; in RunTimeOutCallback() local
103 if (sendCount >= SEND_COUNT_MAX) { in RunTimeOutCallback()
111 taskStatusMap[gid] = (++sendCount); in RunTimeOutCallback()
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/ |
| H A D | fillp_output.c | 66 item->sendCount = 0; in FillpGetSendItem()
113 FILLP_GET_SOCKET(pcb)->index, item->pktNum, item->seqNum, item->sendCount, in FillpDoneSendAllData()
136 if (item->sendCount > 0) { /* resend item */ in FillpBeforeSendItem()
334 if (item->sendCount > 0) { in FillpAddToUnackList()
353 if (item->sendCount > 0) { in FillpItemRetrans()
381 if (item->sendCount == 0) { in FillpSendItem()
386 if (item->sendCount > stats->debugPcb.onePktMaxSendCount) { in FillpSendItem()
387 stats->debugPcb.onePktMaxSendCount = item->sendCount; in FillpSendItem()
418 if (item->sendCount > 0) { in FillpSendItem()
|
| H A D | fillp_input.c | 420 unackItem->sendCount++; in ProtectLongLoopRun()
|
| H A D | fillp_common.c | 113 item->sendCount++; in FillpMoveOneNode()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_send_receive_test.cpp | 285 int sendCount = 0; in HWTEST_F() local
292 sendCount++; in HWTEST_F()
307 EXPECT_EQ(sendCount, expectSendCount); in HWTEST_F()
348 int sendCount = 0; in HWTEST_F() local
350 std::thread sendThread([&sendCount, &sendFailCount]() { in HWTEST_F()
351 while (sendCount < SEND_COUNT_GOAL) { in HWTEST_F()
361 sendCount++; in HWTEST_F()
373 EXPECT_EQ(sendCount, SEND_COUNT_GOAL); in HWTEST_F()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/include/ |
| H A D | nstackx_dfile_transfer.h | 236 uint32_t sendCount; member
273 peerInfo->sendCount = 0; in ClearPeerinfoStats()
|
| /foundation/communication/ipc/ipc/test/auxiliary/native/src/ |
| H A D | test_service_skeleton.cpp | 905 static int sendCount = 0; in ServerEnableSerialInvokeFlag() local
907 if (sendCount == 0) { in ServerEnableSerialInvokeFlag()
916 sendCount++; in ServerEnableSerialInvokeFlag()
918 if (sendCount >= MAX_RECURSIVE_SENDS) { in ServerEnableSerialInvokeFlag()
925 std::string value = std::to_string(sendCount); // The last time was 4. in ServerEnableSerialInvokeFlag()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/ |
| H A D | nstackx_dfile_send.c | 96 NSTACKX_ATOM_FETCH_INC(&peerInfo->sendCount); in TcpSendFileDataFrame()
120 NSTACKX_ATOM_FETCH_INC(&peerInfo->sendCount); in UdpSendFileDataSuccess()
|
| H A D | nstackx_dfile_session.c | 1050 uint64_t sendCount; in DFileSendCalculateRate() local
1062 sendCount = (uint64_t)peerInfo->sendCount; in DFileSendCalculateRate()
1072 peerInfo->sendFrameRate = (uint32_t)(sendCount * DATA_FRAME_SEND_INTERVAL_US / measureElapse); in DFileSendCalculateRate()
1073 peerInfo->sendCountRateMB = (uint32_t)(sendCount * peerInfo->dataFrameSize * in DFileSendCalculateRate()
1079 DFILE_LOGI(TAG, "framesize %u maxsendrate %u sendRate %u, amendSendRate %d sendCount %llu," in DFileSendCalculateRate()
1086 peerInfo->sendCount, measureElapse, peerInfo->sendFrameRate, peerInfo->sendCountRateMB, in DFileSendCalculateRate()
|
| /foundation/ability/ability_runtime/test/unittest/pending_want_record_test/ |
| H A D | pending_want_record_test.cpp | 67 static int sendCount; member in OHOS::AAFwk::PendingWantRecordTest::CancelReceiver
82 int PendingWantRecordTest::CancelReceiver::sendCount = 0; member in OHOS::AAFwk::PendingWantRecordTest::CancelReceiver
86 sendCount = SEND_COUNT; in Send()
|
| /foundation/ability/ability_runtime/test/unittest/pending_want_manager_test/ |
| H A D | pending_want_manager_test.cpp | 65 static int sendCount; member in OHOS::AAFwk::PendingWantManagerTest::CancelReceiver
81 int PendingWantManagerTest::CancelReceiver::sendCount = 0; member in OHOS::AAFwk::PendingWantManagerTest::CancelReceiver
85 sendCount = DEFAULT_COUNT; in Send()
795 EXPECT_TRUE(CancelReceiver::sendCount == 100); in HWTEST_F()
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/ |
| H A D | fillp.h | 99 FILLP_UINT8 sendCount; member
|
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/ |
| H A D | spunge_core.c | 1371 } else if (item->sendCount > 0) { in SpungeClearItemWaitTokenList()
|