| /ohos5.0/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)); variable
112 ASSERT_TRUE(receiveData != nullptr);
114 …_t ret = TransServerGetChannelCb()->OnDataReceived(NULL, pid, channelId, channelType, receiveData);
119 receiveData->data = (void *)TEST_PKG_NAME;
120 receiveData->dataLen = 2;
123 …ret = TransServerGetChannelCb()->OnDataReceived(pkgName, pid, channelId, channelType, receiveData);
128 receiveData->dataLen = 1;
129 …ret = TransServerGetChannelCb()->OnDataReceived(pkgName, pid, channelId, channelType, receiveData);
132 if (receiveData != NULL) {
133 SoftBusFree(receiveData);
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/ipc/ |
| H A D | trans_client_proxy_test.cpp | 253 TransReceiveData receiveData; variable
255 ASSERT_TRUE(receiveData.data != nullptr);
256 receiveData.dataLen = TEST_LEN;
257 receiveData.dataType = TEST_DATA_TYPE;
261 ret = ClientIpcOnChannelMsgReceived(&data, &receiveData);
274 ret = ClientIpcOnChannelMsgReceived(&msg, &receiveData);
437 ASSERT_NE(nullptr, receiveData);
438 receiveData->dataLen = TEST_LEN;
439 receiveData->dataType = TEST_DATA_TYPE;
440 ret = ClientIpcOnChannelMsgReceived(data, receiveData);
[all …]
|
| /ohos5.0/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()
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/ |
| H A D | softbus_proxychannel_session.c | 46 …ientMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, TransReceiveData *receiveData) in NotifyClientMsgReceived() argument
52 int32_t ret = TransProxyOnMsgReceived(pkgName, pid, channelId, receiveData); in NotifyClientMsgReceived()
222 TransReceiveData receiveData; in TransOnNormalMsgReceived() local
223 receiveData.data = (void *)data; in TransOnNormalMsgReceived()
224 receiveData.dataLen = len; in TransOnNormalMsgReceived()
226 int32_t ret = NotifyClientMsgReceived(pkgName, pid, channelId, &receiveData); in TransOnNormalMsgReceived()
|
| H A D | softbus_proxychannel_callback.c | 55 TransReceiveData *receiveData) in TransProxyOnMsgReceived() argument
57 return g_channelCb.OnDataReceived(pkgName, pid, channelId, CHANNEL_TYPE_PROXY, receiveData); in TransProxyOnMsgReceived()
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/ipc/standard/src/ |
| H A D | trans_client_proxy.cpp | 174 int32_t ClientIpcOnChannelMsgReceived(ChannelMsg *data, TransReceiveData *receiveData) in ClientIpcOnChannelMsgReceived() argument
176 if (data == nullptr || receiveData == nullptr) { in ClientIpcOnChannelMsgReceived()
185 object.OnBytesReceived(data->msgChannelId, receiveData->data, receiveData->dataLen); in ClientIpcOnChannelMsgReceived()
194 receiveData->data, receiveData->dataLen, receiveData->dataType); in ClientIpcOnChannelMsgReceived()
|
| /ohos5.0/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() argument
224 TransReceiveData *receiveData = (TransReceiveData *)SoftBusMalloc(sizeof(TransReceiveData)); variable
225 ASSERT_TRUE(receiveData != nullptr);
227 ret = TransTdcOnMsgReceived(pkgName, pid, channelId, receiveData);
229 SoftBusFree(receiveData);
|
| /ohos5.0/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()
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()
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/manager/src/ |
| H A D | trans_channel_callback.c | 188 TransReceiveData* receiveData) in TransServerOnMsgReceived() argument
190 …if (pkgName == NULL || receiveData == NULL || receiveData->data == NULL || receiveData->dataLen ==… in TransServerOnMsgReceived()
202 if (ClientIpcOnChannelMsgReceived(&data, receiveData) != SOFTBUS_OK) { in TransServerOnMsgReceived()
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/ |
| H A D | trans_tcp_direct_callback.c | 66 …dcOnMsgReceived(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 | 747 TransReceiveData receiveData; in NotifyFastDataRecv() local
748 receiveData.data = (void*)conn->appInfo.fastTransData; in NotifyFastDataRecv()
749 receiveData.dataLen = conn->appInfo.fastTransDataSize + FAST_TDC_EXT_DATA_SIZE; in NotifyFastDataRecv()
751 receiveData.dataType = TRANS_SESSION_MESSAGE; in NotifyFastDataRecv()
753 receiveData.dataType = TRANS_SESSION_BYTES; in NotifyFastDataRecv()
756 channelId, &receiveData) != SOFTBUS_OK) { in NotifyFastDataRecv()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/proxy_channel/ |
| H A D | softbus_proxy_session_test.cpp | 90 TransReceiveData* receiveData) in TestSessionDataReceived() argument
96 (void)receiveData; in TestSessionDataReceived()
444 TransReceiveData receiveData; variable
445 memset_s(&receiveData, sizeof(TransReceiveData), 0, sizeof(TransReceiveData));
446 int32_t ret = NotifyClientMsgReceived(pkgName, pid, channelId, &receiveData);
|
| H A D | trans_proxy_network_test.cpp | 73 TransReceiveData* receiveData) in TestChannelDataReceived() argument
79 (void)receiveData; in TestChannelDataReceived()
|
| H A D | softbus_proxy_network_test.cpp | 75 TransReceiveData* receiveData) in TestChannelDataReceived() argument
81 (void)receiveData; in TestChannelDataReceived()
|
| H A D | softbus_proxychannel_listener_test.cpp | 62 TransReceiveData* receiveData) in TestOnDataReceived() argument
68 (void)receiveData; in TestOnDataReceived()
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/include/ |
| H A D | softbus_proxychannel_session.h | 47 …entMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, TransReceiveData *receiveData);
|
| H A D | softbus_proxychannel_callback.h | 42 TransReceiveData *receiveData);
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/include/ |
| H A D | trans_tcp_direct_callback.h | 44 …cOnMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, TransReceiveData *receiveData);
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/manager/include/ |
| H A D | trans_channel_callback.h | 38 TransReceiveData* receiveData);
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/mock/ |
| H A D | trans_tcp_direct_message_test_mock.cpp | 212 …dcOnMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, TransReceiveData *receiveData) in TransTdcOnMsgReceived() argument
214 …n 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));
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/ipc/include/ |
| H A D | trans_client_proxy.h | 43 int32_t ClientIpcOnChannelMsgReceived(ChannelMsg *data, TransReceiveData *receiveData);
|
| /ohos5.0/base/security/access_token/services/tokensyncmanager/src/remote/ |
| H A D | soft_bus_channel.cpp | 222 std::string receiveData = Decompress(bytes, length); in HandleDataReceived() local
223 if (receiveData.empty()) { in HandleDataReceived()
227 std::shared_ptr<SoftBusMessage> message = SoftBusMessage::FromJson(receiveData); in HandleDataReceived()
|
| /ohos5.0/base/security/device_auth/services/session_manager/src/session/v1/compatible_auth_sub_session/ |
| H A D | compatible_auth_sub_session.c | 143 static void ProcessDeviceLevel(const CJson *receiveData, CJson *authParam) in ProcessDeviceLevel() argument
147 (void)GetBoolFromJson(receiveData, FIELD_IS_DEVICE_LEVEL, &receiveLevel); in ProcessDeviceLevel()
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/auth/src/ |
| H A D | trans_auth_manager.c | 225 TransReceiveData receiveData; in NotifyOnDataReceived() local
226 receiveData.data = (void *)data; in NotifyOnDataReceived()
227 receiveData.dataLen = len; in NotifyOnDataReceived()
228 receiveData.dataType = TRANS_SESSION_BYTES; in NotifyOnDataReceived()
231 channel.appInfo.myData.channelId, CHANNEL_TYPE_AUTH, &receiveData); in NotifyOnDataReceived()
|