| /foundation/multimedia/av_session/services/session/server/softbus/ |
| D | softbus_session_manager.cpp | 31 static void OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
38 static void OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown()
44 static void OnBytes(int socket, const void *data, unsigned int dataLen) in OnBytes()
51 static void OnMessage(int socket, const void *data, unsigned int dataLen) in OnMessage()
76 int32_t socket = ::Socket(info); in Socket() local
106 int32_t socket = ::Socket(info); in Bind() local
126 void SoftbusSessionManager::Shutdown(int32_t socket) in Shutdown()
132 int32_t SoftbusSessionManager::SendMessage(int32_t socket, const std::string &data) in SendMessage()
146 int32_t SoftbusSessionManager::SendBytes(int32_t socket, const std::string &data) in SendBytes()
164 int32_t SoftbusSessionManager::SendBytesForNext(int32_t socket, const std::string &data) in SendBytesForNext()
[all …]
|
| D | softbus_distributed_data_manager.cpp | 40 void SoftbusDistributedDataManager::SessionOpened(int32_t socket, PeerSocketInfo info) in SessionOpened()
59 void SoftbusDistributedDataManager::SessionClosed(int32_t socket) in SessionClosed()
72 void SoftbusDistributedDataManager::MessageReceived(int32_t socket, const std::string &data) in MessageReceived()
85 void SoftbusDistributedDataManager::BytesReceived(int32_t socket, const std::string &data) in BytesReceived()
104 int32_t socket = SoftbusSessionManager::GetInstance().Socket(pkg); in InitSessionServer() local
192 int32_t socket = mProxySocketMap_[peerNetworkId]; in ReleaseProxy() local
199 int32_t socket = mProxySocketMap_[peerNetworkId]; in ReleaseProxy() local
249 void SoftbusDistributedDataManager::OnSessionServerClosed(int32_t socket) in OnSessionServerClosed()
259 void SoftbusDistributedDataManager::OnMessageHandleReceived(int32_t socket, const std::string &data) in OnMessageHandleReceived()
275 void SoftbusDistributedDataManager::OnBytesServerReceived(int32_t socket, const std::string &data) in OnBytesServerReceived()
[all …]
|
| D | softbus_distributed_data_manager.h | 34 void OnBind(int32_t socket, PeerSocketInfo info) override in OnBind()
42 void OnShutdown(int32_t socket, ShutdownReason reason) override in OnShutdown()
50 void OnMessage(int32_t socket, const void *data, int32_t dataLen) override in OnMessage()
59 void OnBytes(int32_t socket, const void *data, int32_t dataLen) override in OnBytes()
|
| /foundation/filemanagement/dfs_service/test/mock/ |
| D | socket_mock.cpp | 29 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listene… in Listen()
37 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind()
45 void Shutdown(int32_t socket) in Shutdown()
50 int SendFile(int32_t socket, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) in SendFile()
58 int32_t DfsBind(int32_t socket, const ISocketListener *listener) in DfsBind()
66 int32_t SetAccessInfo(int32_t socket, SocketAccessInfo accessInfo) in SetAccessInfo()
74 int32_t SendBytes(int32_t socket, const void *data, uint32_t len) in SendBytes()
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/bind_fuzzer/ |
| D | bind_fuzzer.cpp | 22 static void OnBindFuzzTest(int32_t socket, PeerSocketInfo info) in OnBindFuzzTest()
28 static void OnShutdownFuzzTest(int32_t socket, ShutdownReason reason) in OnShutdownFuzzTest()
34 static void OnBytesFuzzTest(int32_t socket, const void *data, uint32_t dataLen) in OnBytesFuzzTest()
41 static void OnMessageFuzzTest(int32_t socket, const void *data, uint32_t dataLen) in OnMessageFuzzTest()
48 static void OnStreamFuzzTest(int32_t socket, const StreamData *data, const StreamData *ext, in OnStreamFuzzTest()
57 static void OnFileFuzzTest(int32_t socket, FileEvent *event) in OnFileFuzzTest()
63 static void OnQosFuzzTest(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQosFuzzTest()
71 static void OnErrorFuzzTest(int32_t socket, int32_t errCode) in OnErrorFuzzTest()
77 static bool OnNegotiateFuzzTest(int32_t socket, PeerSocketInfo info) in OnNegotiateFuzzTest()
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/listen_fuzzer/ |
| D | listen_fuzzer.cpp | 22 static void OnBindFuzzTest(int32_t socket, PeerSocketInfo info) in OnBindFuzzTest()
28 static void OnShutdownFuzzTest(int32_t socket, ShutdownReason reason) in OnShutdownFuzzTest()
34 static void OnBytesFuzzTest(int32_t socket, const void *data, uint32_t dataLen) in OnBytesFuzzTest()
41 static void OnMessageFuzzTest(int32_t socket, const void *data, uint32_t dataLen) in OnMessageFuzzTest()
48 static void OnStreamFuzzTest(int32_t socket, const StreamData *data, const StreamData *ext, in OnStreamFuzzTest()
57 static void OnFileFuzzTest(int32_t socket, FileEvent *event) in OnFileFuzzTest()
63 static void OnQosFuzzTest(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQosFuzzTest()
71 static void OnErrorFuzzTest(int32_t socket, int32_t errCode) in OnErrorFuzzTest()
77 static bool OnNegotiateFuzzTest(int32_t socket, PeerSocketInfo info) in OnNegotiateFuzzTest()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/mock/ |
| D | socket_mock.cpp | 24 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listene… in Listen()
33 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind()
42 int32_t SendBytes(int32_t socket, const void *data, uint32_t len) in SendBytes()
50 int32_t SendMessage(int32_t socket, const void *data, uint32_t len) in SendMessage()
58 int32_t SendStream(int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrame… in SendStream()
67 int32_t SendFile(int32_t socket, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) in SendFile()
76 void Shutdown(int32_t socket) in Shutdown()
|
| /foundation/distributedhardware/distributed_input/common/test/mock/ |
| D | socket_mock.cpp | 24 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listene… in Listen()
33 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind()
42 int32_t SendBytes(int32_t socket, const void *data, uint32_t len) in SendBytes()
50 int32_t SendMessage(int32_t socket, const void *data, uint32_t len) in SendMessage()
58 int32_t SendStream(int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrame… in SendStream()
67 int32_t SendFile(int32_t socket, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) in SendFile()
76 void Shutdown(int32_t socket) in Shutdown()
|
| /foundation/distributedhardware/distributed_camera/services/channel/test/unittest/common/channel/ |
| D | session_mock.cpp | 30 int Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen()
39 int Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind()
48 void Shutdown(int32_t socket) in Shutdown()
53 int SendBytes(int32_t socket, const void *data, uint32_t len) in SendBytes()
61 int SendMessage(int32_t socket, const void *data, uint32_t len) in SendMessage()
69 int SendStream(int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo… in SendStream()
78 int SendFile(int32_t socket, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) in SendFile()
|
| /foundation/distributedhardware/distributed_input/services/transportbase/test/transbaseunittest/ |
| D | socket_mock.cpp | 25 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listene… in Listen()
30 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind()
35 void Shutdown(int32_t socket) in Shutdown()
40 int SendFile(int32_t socket, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) in SendFile()
45 int32_t SetAccessInfo(int32_t socket, SocketAccessInfo accessInfo) in SetAccessInfo()
|
| /foundation/distributedhardware/distributed_screen/services/softbusadapter/test/unittest/src/ |
| D | socket_mock.cpp | 25 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listene… in Listen()
30 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind()
35 void Shutdown(int32_t socket) in Shutdown()
40 int SendFile(int32_t socket, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) in SendFile()
45 int32_t SetAccessInfo(int32_t socket, SocketAccessInfo accessInfo) in SetAccessInfo()
|
| /foundation/ability/dmsfwk/services/dtbcollabmgr/test/unittest/channel_manager/ |
| D | softbus_mock.cpp | 43 …int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener* listen… in Listen()
48 …int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener* listener) in Bind()
53 …int32_t BindAsync(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener* lis… in BindAsync()
58 int32_t SendBytes(int32_t socket, const void* data, uint32_t len) in SendBytes()
63 int32_t SendMessage(int32_t socket, const void* data, uint32_t len) in SendMessage()
68 …int32_t SendStream(int32_t socket, const StreamData* data, const StreamData* ext, const StreamFram… in SendStream()
73 …int32_t SendFile(int32_t socket, const char* sFileList[], const char* dFileList[], uint32_t fileCn… in SendFile()
79 void Shutdown(int32_t socket) in Shutdown()
|
| /foundation/distributedhardware/distributed_camera/services/channel/src/ |
| D | dcamera_softbus_adapter.cpp | 46 static void DCameraSourceOnBind(int32_t socket, PeerSocketInfo info) in DCameraSourceOnBind()
51 static void DCameraSourceOnShutDown(int32_t socket, ShutdownReason reason) in DCameraSourceOnShutDown()
57 static void DCameraSourceOnBytes(int32_t socket, const void *data, uint32_t dataLen) in DCameraSourceOnBytes()
63 static void DCameraSourceOnMessage(int32_t socket, const void *data, uint32_t dataLen) in DCameraSourceOnMessage()
69 static void DCameraSourceOnStream(int32_t socket, const StreamData *data, const StreamData *ext, in DCameraSourceOnStream()
77 static void DCameraSinkOnBind(int32_t socket, PeerSocketInfo info) in DCameraSinkOnBind()
83 static void DCameraSinkOnShutDown(int32_t socket, ShutdownReason reason) in DCameraSinkOnShutDown()
89 static void DCameraSinkOnBytes(int32_t socket, const void *data, uint32_t dataLen) in DCameraSinkOnBytes()
95 static void DCameraSinkOnMessage(int32_t socket, const void *data, uint32_t dataLen) in DCameraSinkOnMessage()
101 static void DCameraSinkOnStream(int32_t socket, const StreamData *data, const StreamData *ext, in DCameraSinkOnStream()
[all …]
|
| /foundation/communication/dsoftbus/sdk/transmission/session/src/ |
| D | client_trans_socket_option.c | 30 int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t *optValueSize) in TransGetSocketMaxBufferLen()
41 int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t *optValueSize) in TransGetSocketFirstPackage()
52 int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t *optValueSize) in TransGetSocketMaxIdleTime()
63 int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t optValueSize) in TransSetSocketMaxIdleTime()
75 int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t *optValueSize) in TransGetSupportTlv()
85 int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t optValueSize) in TransSetNeedAck()
107 int32_t GetCommonSocketOpt(int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t… in GetCommonSocketOpt()
126 int32_t SetCommonSocketOpt(int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t… in SetCommonSocketOpt()
|
| D | client_trans_socket_service.c | 127 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listene… in Listen()
133 static int32_t StartBindWaitTimer(int32_t socket, const QosTV qos[], uint32_t qosCount) in StartBindWaitTimer()
151 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind()
176 int32_t BindAsync(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *list… in BindAsync()
202 void Shutdown(int32_t socket) in Shutdown()
220 int32_t GetMtuSize(int32_t socket, uint32_t *mtuSize) in GetMtuSize()
236 int32_t DfsBind(int32_t socket, const ISocketListener *listener) in DfsBind()
268 int32_t socket, OptLevel level, OptType optType, void *optValue, uint32_t optValueSize) in SetExtSocketOptPacked()
277 int32_t SetSocketOpt(int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t optVa… in SetSocketOpt()
296 int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t *optValueSize) in GetExtSocketOptPacked()
[all …]
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/moduletest/socket/stream_encrypt_test/ |
| D | stream_encrypt_server_mt.cpp | 58 void OnBindServer(int32_t socket, PeerSocketInfo info) in OnBindServer()
64 void OnShutdownServer(int32_t socket, ShutdownReason reason) in OnShutdownServer()
96 int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) in OnStreamReceivedWithNoDataType()
123 int32_t socket = Socket(info); variable
161 int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) in OnStreamReceivedWithUnencryptOpt()
182 int32_t socket = Socket(info); variable
220 int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) in OnStreamReceivedWithEncryptOpt()
242 int32_t socket = Socket(info); variable
294 int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) in OnStreamReceivedWithOldInterface()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/test/mock/softbus/ |
| D | socket.cpp | 42 int32_t SetAccessInfo(int32_t socket, SocketAccessInfo accessInfo) in SetAccessInfo()
54 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind()
76 void Shutdown(int32_t socket) in Shutdown()
90 int32_t SendBytes(int32_t socket, const void *data, uint32_t len) in SendBytes()
107 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listene… in Listen()
|
| /foundation/communication/ipc/ipc/native/src/core/dbinder/source/ |
| D | dbinder_softbus_client.cpp | 158 int32_t DBinderSoftbusClient::Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, in Listen()
179 int32_t DBinderSoftbusClient::Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, in Bind()
200 int32_t DBinderSoftbusClient::SendBytes(int32_t socket, const void *data, uint32_t len) in SendBytes()
219 int32_t DBinderSoftbusClient::SendMessage(int32_t socket, const void *data, uint32_t len) in SendMessage()
238 void DBinderSoftbusClient::Shutdown(int32_t socket) in Shutdown()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/softbus_adapter/ |
| D | mock_softbus_adapter.cpp | 45 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener* listene… in Listen()
50 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener* listener) in Bind()
55 int32_t SendBytes(int32_t socket, const void* data, uint32_t len) in SendBytes()
60 void Shutdown(int32_t socket) in Shutdown()
|
| /foundation/communication/ipc/test/unittest/ipc/native/src/core/source/ |
| D | databus_socket_listener_unittest.cpp | 107 int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen()
112 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, in Bind()
127 int32_t socket = 1; variable
148 int32_t socket = 1; variable
169 int32_t socket = 1; variable
190 int32_t socket = 1; variable
211 int32_t socket = 1; variable
227 int32_t socket = 100; variable
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/transport/ |
| D | dh_transport.cpp | 219 void OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
233 void OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown()
247 void OnBytes(int32_t socket, const void *data, uint32_t dataLen) in OnBytes()
261 void OnMessage(int32_t socket, const void *data, uint32_t dataLen) in OnMessage()
269 void OnStream(int32_t socket, const StreamData *data, const StreamData *ext, in OnStream()
279 void OnFile(int32_t socket, FileEvent *event) in OnFile()
285 void OnQos(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQos()
320 int32_t socket = Socket(info); in CreateServerSocket() local
339 int32_t socket = Socket(info); in CreateClientSocket() local
352 int32_t socket = CreateServerSocket(); in Init() local
[all …]
|
| /foundation/communication/ipc/ipc/native/test/unittest/common/ |
| D | databus_socket_listener_unittest.cpp | 99 int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen()
105 int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind()
179 int32_t socket = 1001; variable
205 int32_t socket = 1001; variable
221 int32_t socket = 1001; variable
242 int32_t socket = 1001; variable
258 int32_t socket = 1001; variable
272 int32_t socket = 1001; variable
288 int32_t socket = 1001; variable
309 int32_t socket = 1001; variable
[all …]
|
| /foundation/distributedhardware/distributed_input/services/transportbase/src/ |
| D | distributed_input_transport_base.cpp | 58 void OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
63 void OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown()
68 void OnBytes(int32_t socket, const void *data, uint32_t dataLen) in OnBytes()
73 void OnMessage(int32_t socket, const void *data, uint32_t dataLen) in OnMessage()
81 void OnStream(int32_t socket, const StreamData *data, const StreamData *ext, in OnStream()
91 void OnFile(int32_t socket, FileEvent *event) in OnFile()
97 void OnQos(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQos()
105 static bool OnNegotiate2(int32_t socket, PeerSocketInfo info, SocketAccessInfo *peerInfo, SocketAcc… in OnNegotiate2()
129 int32_t socket = CreateServerSocket(); in Init() local
164 int32_t socket = Socket(info); in CreateServerSocket() local
[all …]
|
| /foundation/distributedhardware/device_manager/services/service/src/relationshipsyncmgr/ |
| D | dm_transport.cpp | 168 void OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
178 void OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown()
188 void OnBytes(int32_t socket, const void *data, uint32_t dataLen) in OnBytes()
198 void OnMessage(int32_t socket, const void *data, uint32_t dataLen) in OnMessage()
206 void OnStream(int32_t socket, const StreamData *data, const StreamData *ext, in OnStream()
216 void OnFile(int32_t socket, FileEvent *event) in OnFile()
222 void OnQos(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQos()
256 int32_t socket = Socket(info); in CreateServerSocket() local
276 int32_t socket = Socket(info); in CreateClientSocket() local
289 int32_t socket = CreateServerSocket(); in Init() local
[all …]
|
| /foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/network/softbus/ |
| D | softbus_asset_send_listener_test.cpp | 76 int32_t socket = 1; variable
110 int32_t socket = 1; variable
144 int32_t socket = 1; variable
|