| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/distributed_stream/ |
| H A D | distributed_stream_test.cpp | 77 void P2pTransTest(bool isRawStream, bool isP2P, int32_t sendCnt, const string &mySessionName,
79 void TestSendCommonStream(int32_t sendCnt);
80 void TestSendStream(int32_t sendCnt);
217 void DistributeStreamTest::TestSendStream(int32_t sendCnt) in TestSendStream() argument
219 if (sendCnt >= MAX_SEND_CNT) { in TestSendStream()
241 for (int32_t i = 0; i < sendCnt; i++) { in TestSendStream()
255 void DistributeStreamTest::TestSendCommonStream(int32_t sendCnt) in TestSendCommonStream() argument
288 while (sendCnt > 0) { in TestSendCommonStream()
303 sendCnt--; in TestSendCommonStream()
430 int32_t sendCnt, cons in P2pTransTest()
429 P2pTransTest(bool isRawStream, bool isP2P, int32_t sendCnt, const string &mySessionName, const string &peerSessionName) P2pTransTest() argument
[all...] |
| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/auth/ |
| H A D | auth_session_test.c | 206 int32_t sendCnt = 0; in TestAuthSessionSendData() local
208 while (sendCnt < count) { in TestAuthSessionSendData()
209 printf("******* sendCnt[%d] *******\n", sendCnt); in TestAuthSessionSendData()
235 sendCnt++; in TestAuthSessionSendData()
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/br/file/ |
| H A D | proxy_session_file_test.cpp | 248 static void TestSendMessage(int32_t sendCnt, const char *data, uint32_t len, bool ex = false);
249 static void TestSendBytes(int32_t sendCnt, const char *data, uint32_t len, bool ex = false);
251 static void TestSendFile(int32_t sendCnt, const char *sfileList[], const char *dfileList[],
376 void AuthSessionTest::TestSendMessage(int32_t sendCnt, const char *data, uint32_t len, bool ex) in TestSendMessage() argument
381 for (int32_t i = 0; i < sendCnt; i++) { in TestSendMessage()
395 void AuthSessionTest::TestSendBytes(int32_t sendCnt, const char *data, uint32_t len, bool ex) in TestSendBytes() argument
400 for (int32_t i = 0; i < sendCnt; i++) { in TestSendBytes()
412 void AuthSessionTest::TestSendFile(int32_t sendCnt, const char *sfileList[], const char *dfileList[], in TestSendFile() argument
418 for (int32_t i = 0; i < sendCnt; i++) { in TestSendFile()
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/br/optimization/ |
| H A D | auth_session_test2.cpp | 223 static void TestSendMessage(int32_t sendCnt, const char *data, uint32_t len, bool ex = false);
224 static void TestSendBytes(int32_t sendCnt, const char *data, uint32_t len, bool ex = false);
226 static void TestSendFile(int32_t sendCnt, const char *sfileList[], const char *dfileList[],
355 void AuthSessionTest::TestSendMessage(int32_t sendCnt, const char *data, uint32_t len, bool ex) in TestSendMessage() argument
360 for (int32_t i = 0; i < sendCnt; i++) { in TestSendMessage()
374 void AuthSessionTest::TestSendBytes(int32_t sendCnt, const char *data, uint32_t len, bool ex) in TestSendBytes() argument
379 for (int32_t i = 0; i < sendCnt; i++) { in TestSendBytes()
391 void AuthSessionTest::TestSendFile(int32_t sendCnt, const char *sfileList[], const char *dfileList[], in TestSendFile() argument
397 for (int32_t i = 0; i < sendCnt; i++) { in TestSendFile()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_send_receive_test.cpp | 414 int sendCnt = 0; in HWTEST_F() local
416 std::thread sendThread([&sendCnt, &sendFailCnt]() { in HWTEST_F()
417 while (sendCnt < SEND_COUNT_GOAL) { in HWTEST_F()
427 sendCnt++; in HWTEST_F()
439 EXPECT_EQ(sendCnt, SEND_COUNT_GOAL); in HWTEST_F()
|
| /foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/heartbeat/src/ |
| H A D | lnn_heartbeat_strategy.c | 334 uint32_t sendCnt = isRelayV0 ? 1 : HB_SEND_SEPARATELY_CNT; in RelayHeartbeatV0SplitOld() local
343 for (uint32_t i = 1; i < sendCnt; ++i) { in RelayHeartbeatV0SplitOld()
347 if (i == sendCnt - 1) { in RelayHeartbeatV0SplitOld()
429 uint32_t sendCnt = HB_SEND_SEPARATELY_CNT; in RelayHeartbeatV1Split() local
438 for (uint32_t i = 1; i < sendCnt; ++i) { in RelayHeartbeatV1Split()
442 if (i == sendCnt - 1) { in RelayHeartbeatV1Split()
|