| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/file/src/ |
| H A D | client_trans_file.c | 209 static void FileSendErrorEvent(UdpChannel *udpChannel, FileListener *fileListener, const DFileMsg *msgData, in FileSendErrorEvent() argument
212 if (fileListener->socketSendCallback != NULL) { in FileSendErrorEvent()
218 fileListener->socketSendCallback(sessionId, &event); in FileSendErrorEvent()
220 } else if (fileListener->sendListener.OnFileTransError != NULL) { in FileSendErrorEvent()
221 fileListener->sendListener.OnFileTransError(sessionId); in FileSendErrorEvent()
246 FileListener fileListener; in FileSendListener() local
247 (void)memset_s(&fileListener, sizeof(FileListener), 0, sizeof(FileListener)); in FileSendListener()
248 if (TransGetFileListener(udpChannel.info.mySessionName, &fileListener) != SOFTBUS_OK) { in FileSendListener()
253 if (fileListener.socketSendCallback != NULL) { in FileSendListener()
254 NotifySocketSendResult(udpChannel.sessionId, msgType, msgData, &fileListener); in FileSendListener()
357 FileRecvErrorEvent(UdpChannel *udpChannel, FileListener *fileListener, const DFileMsg *msgData, DFileMsgType msgType, int32_t sessionId) FileRecvErrorEvent() argument
388 FileListener fileListener; FileReceiveListener() local
418 UpdateFileRecvPath(int32_t channelId, FileListener *fileListener, int32_t fileSession) UpdateFileRecvPath() argument
480 FileListener fileListener; TransOnFileChannelOpened() local
583 FileListener fileListener; NotifyTransLimitChanged() local
[all...] |
| H A D | client_trans_file_virtual.c | 44 int32_t TransGetFileListener(const char *sessionName, FileListener *fileListener) in TransGetFileListener() argument
47 (void)fileListener; in TransGetFileListener()
|
| H A D | client_trans_file_listener.c | 241 int32_t TransGetFileListener(const char *sessionName, FileListener *fileListener) in TransGetFileListener() argument
255 if (memcpy_s(fileListener, sizeof(FileListener), fileNode, sizeof(FileListener)) != EOK) { in TransGetFileListener()
|
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/src/ |
| H A D | client_trans_proxy_file_manager.c | 67 if (info->fileListener.socketRecvCallback != NULL) { in ClearRecipientResources()
69 info->fileListener.socketRecvCallback(info->sessionId, &event); in ClearRecipientResources()
70 } else if (info->fileListener.recvListener.OnFileTransError != NULL) { in ClearRecipientResources()
71 info->fileListener.recvListener.OnFileTransError(info->sessionId); in ClearRecipientResources()
597 if (sendInfo->fileListener.socketSendCallback != NULL) { in HandleSendProgress()
606 sendInfo->fileListener.socketSendCallback(sendInfo->sessionId, &event); in HandleSendProgress()
607 } else if (sendInfo->fileListener.sendListener.OnSendFileProcess != NULL) { in HandleSendProgress()
608 sendInfo->fileListener.sendListener.OnSendFileProcess(sendInfo->channelId, fileOffset, fileSize); in HandleSendProgress()
848 if (sendInfo->fileListener.socketSendCallback != NULL) { in ProxyStartSendFile()
857 sendInfo->fileListener in ProxyStartSendFile()
1141 UpdateFileReceivePath(int32_t sessionId, FileListener *fileListener) UpdateFileReceivePath() argument
[all...] |
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/include/ |
| H A D | client_trans_proxy_file_manager.h | 133 FileListener fileListener; member
154 FileListener fileListener; member
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/clienttransfile_fuzzer/ |
| H A D | clienttransfile_fuzzer.cpp | 102 FileListener fileListener; in TransGetFileListenerTest() local
104 TransGetFileListener(sessionName, &fileListener); in TransGetFileListenerTest()
|
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/file/include/ |
| H A D | client_trans_file_listener.h | 47 int32_t TransGetFileListener(const char *sessionName, FileListener *fileListener);
|
| /foundation/filemanagement/file_api/interfaces/kits/cj/src/ |
| H A D | watcher_impl.cpp | 166 auto fileListener = [this, arg]() { in GetNotifyEvent() local
192 std::thread(fileListener).detach(); in GetNotifyEvent()
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/file/ |
| H A D | trans_sdk_file_test.cpp | 313 FileListener* fileListener = (FileListener *)SoftBusCalloc(sizeof(FileListener)); in HWTEST_F() local
314 if (fileListener == NULL) { in HWTEST_F()
323 ret = TransGetFileListener(inValidName, fileListener); in HWTEST_F()
326 ret = TransGetFileListener(sessionName, fileListener); in HWTEST_F()
331 ret = TransGetFileListener(sessionName, fileListener); in HWTEST_F()
333 SoftBusFree(fileListener); in HWTEST_F()
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/proxy/ |
| H A D | client_trans_proxy_file_manager_test.cpp | 620 info.fileListener.recvListener.OnFileTransError = nullptr; in HWTEST_F()
623 info.fileListener.recvListener.OnFileTransError = OnFileTransError; in HWTEST_F()
1527 .fileListener.rootDir = "../test", in HWTEST_F()
1538 ret = memcpy_s(info.fileListener.rootDir, TEST_FILEPATH_LENGTH, g_rootDir + 1, TEST_FILEPATH_LENGTH); in HWTEST_F()
1815 FileListener *fileListener = (FileListener *)SoftBusCalloc(sizeof(FileListener)); in HWTEST_F() local
1817 fileListener->socketRecvCallback = NULL; in HWTEST_F()
1818 int32_t ret = UpdateFileReceivePath(sessionId, fileListener); in HWTEST_F()
1821 ret = UpdateFileReceivePath(sessionId, fileListener); in HWTEST_F()
1823 SoftBusFree(fileListener); in HWTEST_F()
|