| /foundation/communication/dsoftbus/tests/core/transmission/trans_channel/manager/trans_channel_callback_test/ |
| H A D | trans_channel_callback_test.cpp | 111 TransReceiveData *receiveData = (TransReceiveData *)SoftBusCalloc(sizeof(TransReceiveData)); in HWTEST_F() local
112 ASSERT_TRUE(receiveData != nullptr); in HWTEST_F()
114 int32_t ret = TransServerGetChannelCb()->OnDataReceived(NULL, pid, channelId, channelType, receiveData); in HWTEST_F()
119 receiveData->data = (void *)TEST_PKG_NAME; in HWTEST_F()
120 receiveData->dataLen = 2; in HWTEST_F()
123 ret = TransServerGetChannelCb()->OnDataReceived(pkgName, pid, channelId, channelType, receiveData); in HWTEST_F()
128 receiveData->dataLen = 1; in HWTEST_F()
129 ret = TransServerGetChannelCb()->OnDataReceived(pkgName, pid, channelId, channelType, receiveData); in HWTEST_F()
132 if (receiveData != NULL) { in HWTEST_F()
133 SoftBusFree(receiveData); in HWTEST_F()
[all...] |
| /foundation/communication/dsoftbus/core/transmission/ipc/mini/ |
| H A D | trans_client_proxy.c | 53 int32_t ClientIpcOnChannelMsgReceived(ChannelMsg *data, TransReceiveData *receiveData) in ClientIpcOnChannelMsgReceived() argument
56 receiveData->data, receiveData->dataLen, (SessionPktType)receiveData->dataType); in ClientIpcOnChannelMsgReceived()
|
| /foundation/communication/dsoftbus/tests/core/transmission/ipc/ |
| H A D | trans_client_proxy_test.cpp | 253 TransReceiveData receiveData; in HWTEST_F() local
254 receiveData.data = (unsigned char *)SoftBusCalloc(TEST_LEN); in HWTEST_F()
255 ASSERT_TRUE(receiveData.data != nullptr); in HWTEST_F()
256 receiveData.dataLen = TEST_LEN; in HWTEST_F()
257 receiveData.dataType = TEST_DATA_TYPE; in HWTEST_F()
261 ret = ClientIpcOnChannelMsgReceived(&data, &receiveData); in HWTEST_F()
274 ret = ClientIpcOnChannelMsgReceived(&msg, &receiveData); in HWTEST_F()
436 TransReceiveData *receiveData = (TransReceiveData *)SoftBusCalloc(sizeof(TransReceiveData)); in HWTEST_F() local
437 ASSERT_NE(nullptr, receiveData); in HWTEST_F()
438 receiveData in HWTEST_F()
[all...] |
| /foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/ |
| H A D | softbus_proxychannel_session.c | 39 int32_t NotifyClientMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, TransReceiveData *receiveData) in NotifyClientMsgReceived() argument
45 int32_t ret = TransProxyOnMsgReceived(pkgName, pid, channelId, receiveData); in NotifyClientMsgReceived()
215 TransReceiveData receiveData; in TransOnNormalMsgReceived() local
216 receiveData.data = (void *)data; in TransOnNormalMsgReceived()
217 receiveData.dataLen = len; in TransOnNormalMsgReceived()
219 int32_t ret = NotifyClientMsgReceived(pkgName, pid, channelId, &receiveData); in TransOnNormalMsgReceived()
|
| H A D | softbus_proxychannel_callback.c | 55 TransReceiveData *receiveData) in TransProxyOnMsgReceived()
57 return g_channelCb.OnDataReceived(pkgName, pid, channelId, CHANNEL_TYPE_PROXY, receiveData); in TransProxyOnMsgReceived()
54 TransProxyOnMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, TransReceiveData *receiveData) TransProxyOnMsgReceived() argument
|
| H A D | softbus_proxychannel_manager.c | 1083 TransReceiveData receiveData; in TransProxyFastDataRecv() local
1084 receiveData.data = (void *)chan->appInfo.fastTransData; in TransProxyFastDataRecv()
1086 receiveData.dataLen = chan->appInfo.fastTransDataSize + FAST_EXT_MSG_SIZE; in TransProxyFastDataRecv()
1088 receiveData.dataLen = chan->appInfo.fastTransDataSize + FAST_EXT_BYTE_SIZE; in TransProxyFastDataRecv()
1091 receiveData.dataType = TRANS_SESSION_MESSAGE; in TransProxyFastDataRecv()
1093 receiveData.dataType = TRANS_SESSION_BYTES; in TransProxyFastDataRecv()
1096 chan->channelId, &receiveData) != SOFTBUS_OK) { in TransProxyFastDataRecv()
|
| /foundation/communication/dsoftbus/core/transmission/ipc/standard/src/ |
| H A D | trans_client_proxy.cpp | 171 int32_t ClientIpcOnChannelMsgReceived(ChannelMsg *data, TransReceiveData *receiveData) in ClientIpcOnChannelMsgReceived() argument
173 if (data == nullptr || receiveData == nullptr) { in ClientIpcOnChannelMsgReceived()
174 TRANS_LOGE(TRANS_CTRL, "ClientIpcOnChannelMsgReceived data or receiveData is nullptr!"); in ClientIpcOnChannelMsgReceived()
182 object.OnBytesReceived(data->msgChannelId, receiveData->data, receiveData->dataLen); in ClientIpcOnChannelMsgReceived()
191 receiveData->data, receiveData->dataLen, receiveData->dataType); in ClientIpcOnChannelMsgReceived()
|
| /foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/ |
| H A D | trans_tcp_direct_callback_test.cpp | 58 TransReceiveData* receiveData) in TransServerOnMsgReceived()
224 TransReceiveData *receiveData = (TransReceiveData *)SoftBusMalloc(sizeof(TransReceiveData)); in HWTEST_F() local
225 ASSERT_TRUE(receiveData != nullptr); in HWTEST_F()
227 ret = TransTdcOnMsgReceived(pkgName, pid, channelId, receiveData); in HWTEST_F()
229 SoftBusFree(receiveData); in HWTEST_F()
57 TransServerOnMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, TransReceiveData* receiveData) TransServerOnMsgReceived() argument
|
| /foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/ |
| H A D | trans_tcp_direct_callback.c | 66 int32_t TransTdcOnMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, TransReceiveData *receiveData) in TransTdcOnMsgReceived() argument
68 return g_channelCb.OnDataReceived(pkgName, pid, channelId, CHANNEL_TYPE_TCP_DIRECT, receiveData); in TransTdcOnMsgReceived()
|
| H A D | trans_tcp_direct_message.c | 749 TransReceiveData receiveData; in NotifyFastDataRecv() local
750 receiveData.data = (void*)conn->appInfo.fastTransData; in NotifyFastDataRecv()
751 receiveData.dataLen = conn->appInfo.fastTransDataSize + FAST_TDC_EXT_DATA_SIZE; in NotifyFastDataRecv()
753 receiveData.dataType = TRANS_SESSION_MESSAGE; in NotifyFastDataRecv()
755 receiveData.dataType = TRANS_SESSION_BYTES; in NotifyFastDataRecv()
758 channelId, &receiveData) != SOFTBUS_OK) { in NotifyFastDataRecv()
|
| /foundation/communication/dsoftbus/core/transmission/ipc/small/ |
| H A D | trans_client_proxy.c | 228 int32_t ClientIpcOnChannelMsgReceived(ChannelMsg *data, TransReceiveData *receiveData) in ClientIpcOnChannelMsgReceived() argument
230 if (data == NULL || receiveData == NULL) { in ClientIpcOnChannelMsgReceived()
231 TRANS_LOGE(TRANS_CTRL, "ClientIpcOnChannelClosed data or receiveData is null."); in ClientIpcOnChannelMsgReceived()
236 uint8_t *tmpData = (uint8_t *)SoftBusCalloc(receiveData->dataLen + MAX_SOFT_BUS_IPC_LEN); in ClientIpcOnChannelMsgReceived()
241 IpcIoInit(&io, tmpData, receiveData->dataLen + MAX_SOFT_BUS_IPC_LEN, 0); in ClientIpcOnChannelMsgReceived()
244 WriteInt32(&io, receiveData->dataType); in ClientIpcOnChannelMsgReceived()
245 WriteUint32(&io, receiveData->dataLen); in ClientIpcOnChannelMsgReceived()
246 WriteBuffer(&io, receiveData->data, receiveData->dataLen); in ClientIpcOnChannelMsgReceived()
|
| /foundation/communication/dsoftbus/core/transmission/trans_channel/manager/src/ |
| H A D | trans_channel_callback.c | 192 TransReceiveData* receiveData) in TransServerOnMsgReceived()
194 if (pkgName == NULL || receiveData == NULL || receiveData->data == NULL || receiveData->dataLen == 0) { in TransServerOnMsgReceived()
206 if (ClientIpcOnChannelMsgReceived(&data, receiveData) != SOFTBUS_OK) { in TransServerOnMsgReceived()
191 TransServerOnMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, TransReceiveData* receiveData) TransServerOnMsgReceived() argument
|
| /foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/include/ |
| H A D | softbus_proxychannel_session.h | 47 int32_t NotifyClientMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, TransReceiveData *receiveData);
|
| H A D | softbus_proxychannel_callback.h | 42 TransReceiveData *receiveData);
|
| /foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/include/ |
| H A D | trans_tcp_direct_callback.h | 44 int32_t TransTdcOnMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, TransReceiveData *receiveData);
|
| /foundation/communication/dsoftbus/tests/core/transmission/trans_channel/proxy_channel/ |
| H A D | softbus_proxy_session_test.cpp | 90 TransReceiveData* receiveData) in TestSessionDataReceived()
96 (void)receiveData; in TestSessionDataReceived()
444 TransReceiveData receiveData; in HWTEST_F() local
445 memset_s(&receiveData, sizeof(TransReceiveData), 0, sizeof(TransReceiveData)); in HWTEST_F()
446 int32_t ret = NotifyClientMsgReceived(pkgName, pid, channelId, &receiveData); in HWTEST_F()
89 TestSessionDataReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, TransReceiveData* receiveData) TestSessionDataReceived() argument
|
| H A D | trans_proxy_network_test.cpp | 73 TransReceiveData* receiveData) in TestChannelDataReceived()
79 (void)receiveData; in TestChannelDataReceived()
72 TestChannelDataReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, TransReceiveData* receiveData) TestChannelDataReceived() argument
|
| H A D | softbus_proxychannel_listener_test.cpp | 62 TransReceiveData* receiveData) in TestOnDataReceived()
68 (void)receiveData; in TestOnDataReceived()
61 TestOnDataReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, TransReceiveData* receiveData) TestOnDataReceived() argument
|
| H A D | softbus_proxy_network_test.cpp | 75 TransReceiveData* receiveData) in TestChannelDataReceived()
81 (void)receiveData; in TestChannelDataReceived()
74 TestChannelDataReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, TransReceiveData* receiveData) TestChannelDataReceived() argument
|
| H A D | trans_proxy_session_test.cpp | 93 TransReceiveData* receiveData) in TestSessionDataReceived()
99 (void)receiveData; in TestSessionDataReceived()
92 TestSessionDataReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, TransReceiveData* receiveData) TestSessionDataReceived() argument
|
| /foundation/communication/dsoftbus/core/transmission/trans_channel/manager/include/ |
| H A D | trans_channel_callback.h | 38 TransReceiveData* receiveData);
|
| /foundation/communication/dsoftbus/core/transmission/ipc/include/ |
| H A D | trans_client_proxy.h | 42 int32_t ClientIpcOnChannelMsgReceived(ChannelMsg *data, TransReceiveData *receiveData);
|
| /foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/mock/ |
| H A D | trans_tcp_direct_message_test_mock.cpp | 212 int32_t TransTdcOnMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, TransReceiveData *receiveData)
in TransTdcOnMsgReceived() argument
214 return GetTransTcpDirectMessageInterface()->TransTdcOnMsgReceived(pkgName, pid, channelId, receiveData);
in TransTdcOnMsgReceived()
|
| H A D | trans_tcp_direct_message_test_mock.h | 78 int32_t channelId, TransReceiveData *receiveData) = 0;
128 int32_t channelId, TransReceiveData *receiveData));
|
| /foundation/communication/dsoftbus/core/transmission/trans_channel/auth/src/ |
| H A D | trans_auth_manager.c | 215 TransReceiveData receiveData; in NotifyOnDataReceived() local
216 receiveData.data = (void *)data; in NotifyOnDataReceived()
217 receiveData.dataLen = len; in NotifyOnDataReceived()
218 receiveData.dataType = TRANS_SESSION_BYTES; in NotifyOnDataReceived()
221 channel.appInfo.myData.channelId, CHANNEL_TYPE_AUTH, &receiveData); in NotifyOnDataReceived()
|