| /foundation/multimedia/av_session/services/session/server/softbus/ |
| H A D | softbus_session_manager.cpp | 29 static void OnBind(int32_t socket, PeerSocketInfo info)
in OnBind() argument
31 SLOGI("OnBind sessionId[%{public}d] result[%{public}s]", socket, info.networkId);
in OnBind()
32 SoftbusSessionManager::GetInstance().OnBind(socket, info);
in OnBind()
35 static void OnShutdown(int32_t socket, ShutdownReason reason)
in OnShutdown() argument
37 SLOGI("OnSessionClosed sessionId[%{public}d], reason[%{public}d]", socket, reason);
in OnShutdown()
38 SoftbusSessionManager::GetInstance().OnShutdown(socket, reason);
in OnShutdown()
41 static void OnBytes(int socket, const void *data, unsigned int dataLen)
in OnBytes() argument
43 SLOGI("OnBytesReceived sessionId[%{public}d], datalen[%{public}d]", socket, dataLen);
in OnBytes()
45 SoftbusSessionManager::GetInstance().OnBytes(socket, msg.c_str(), dataLen);
in OnBytes()
48 static void OnMessage(int socket, cons argument
73 int32_t socket = ::Socket(info); Socket() local
90 Shutdown(int32_t socket) Shutdown() argument
96 SendMessage(int32_t socket, const std::string &data) SendMessage() argument
110 SendBytes(int32_t socket, const std::string &data) SendBytes() argument
124 ObtainPeerDeviceId(int32_t socket, std::string &deviceId) ObtainPeerDeviceId() argument
148 OnBind(int32_t socket, PeerSocketInfo info) OnBind() argument
161 OnShutdown(int32_t socket, ShutdownReason reason) OnShutdown() argument
171 OnMessage(int32_t socket, const void *data, int32_t dataLen) OnMessage() argument
183 OnBytes(int32_t socket, const void *data, int32_t dataLen) OnBytes() argument
[all...] |
| H A D | softbus_session_manager.h | 23 #include "socket.h"
28 virtual void OnBind(int32_t socket, PeerSocketInfo info) = 0;
29 virtual void OnShutdown(int32_t socket, ShutdownReason reason) = 0;
30 virtual void OnBytes(int32_t socket, const void *data, int32_t dataLen) = 0;
31 virtual void OnMessage(int32_t socket, const void *data, int32_t dataLen) = 0;
41 void Shutdown(int32_t socket);
43 int32_t SendMessage(int32_t socket, const std::string &data);
45 int32_t SendBytes(int32_t socket, const std::string &data);
47 int32_t ObtainPeerDeviceId(int32_t socket, std::string &deviceId);
54 * @param socket socke
[all...] |
| H A D | softbus_distributed_data_manager.h | 33 void OnBind(int32_t socket, PeerSocketInfo info) override
37 manager->SessionOpened(socket, info);
41 void OnShutdown(int32_t socket, ShutdownReason reason) override
45 manager->SessionClosed(socket);
49 void OnMessage(int32_t socket, const void *data, int32_t dataLen) override
54 manager->MessageReceived(socket, msg);
58 void OnBytes(int32_t socket, const void *data, int32_t dataLen) override
63 manager->BytesReceived(socket, msg);
86 void SessionOpened(int32_t socket, PeerSocketInfo info);
87 void SessionClosed(int32_t socket);
[all...] |
| /foundation/communication/dsoftbus/interfaces/kits/transport/ |
| H A D | socket.h | 31 * @file socket.h
35 * This file provides data transmission capabilities, including creating and removing a socket server,
36 * opening and closing sockets, receiving data, and querying basic socket information. \n
66 * @brief Defines socket callbacks.
68 * When a socket is opened or closed, or there is data to process, the related callback is invoked.
75 * @brief Called when a socket is bind.
77 * This callback is invoked to verify the socket or initialize resources related to the socket.
81 * When a socket is async bind, client side need implement this interface.
83 * @param socket Indicate
[all...] |
| /foundation/distributedhardware/distributed_camera/services/channel/test/unittest/common/channel/ |
| H A D | session_mock.cpp | 21 #include "socket.h"
30 int Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() argument
32 (void)socket; in Listen()
39 int Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind() argument
41 (void)socket; in Bind()
48 void Shutdown(int32_t socket) in Shutdown() argument
50 (void)socket; in Shutdown()
53 int SendBytes(int32_t socket, const void *data, uint32_t len) in SendBytes() argument
55 (void)socket; in SendBytes()
61 int SendMessage(int32_t socket, cons argument
69 SendStream(int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) SendStream() argument
78 SendFile(int32_t socket, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) SendFile() argument
[all...] |
| H A D | socket.h | 31 * @file socket.h
35 * This file provides data transmission capabilities, including creating and removing a socket server,
36 * opening and closing sockets, receiving data, and querying basic socket information. \n
65 * @brief Defines socket callbacks.
67 * When a socket is opened or closed, or there is data to process, the related callback is invoked.
74 * @brief Called when a socket is bind.
76 * This callback is invoked to verify the socket or initialize resources related to the socket.
78 * @param socket Indicates the unique socket f
[all...] |
| /foundation/distributedhardware/distributed_input/common/test/mock/ |
| H A D | socket_mock.cpp | 16 #include "socket.h"
24 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() argument
26 (void)socket; in Listen()
33 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind() argument
35 (void)socket; in Bind()
42 int32_t SendBytes(int32_t socket, const void *data, uint32_t len) in SendBytes() argument
44 (void)socket; in SendBytes()
50 int32_t SendMessage(int32_t socket, const void *data, uint32_t len) in SendMessage() argument
52 (void)socket; in SendMessage()
58 int32_t SendStream(int32_t socket, cons argument
67 SendFile(int32_t socket, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) SendFile() argument
76 Shutdown(int32_t socket) Shutdown() argument
[all...] |
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/mock/ |
| H A D | socket_mock.cpp | 16 #include "socket.h"
24 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() argument
26 (void)socket; in Listen()
33 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind() argument
35 (void)socket; in Bind()
42 int32_t SendBytes(int32_t socket, const void *data, uint32_t len) in SendBytes() argument
44 (void)socket; in SendBytes()
50 int32_t SendMessage(int32_t socket, const void *data, uint32_t len) in SendMessage() argument
52 (void)socket; in SendMessage()
58 int32_t SendStream(int32_t socket, cons argument
67 SendFile(int32_t socket, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) SendFile() argument
76 Shutdown(int32_t socket) Shutdown() argument
[all...] |
| /foundation/distributedhardware/distributed_camera/services/channel/src/ |
| H A D | dcamera_softbus_adapter.cpp | 56 static void DCameraSourceOnBind(int32_t socket, PeerSocketInfo info) in DCameraSourceOnBind() argument
61 static void DCameraSourceOnShutDown(int32_t socket, ShutdownReason reason) in DCameraSourceOnShutDown() argument
63 DCameraSoftbusAdapter::GetInstance().SourceOnShutDown(socket, reason); in DCameraSourceOnShutDown()
67 static void DCameraSourceOnBytes(int32_t socket, const void *data, uint32_t dataLen) in DCameraSourceOnBytes() argument
69 DCameraSoftbusAdapter::GetInstance().SourceOnBytes(socket, data, dataLen); in DCameraSourceOnBytes()
73 static void DCameraSourceOnMessage(int32_t socket, const void *data, uint32_t dataLen) in DCameraSourceOnMessage() argument
75 DCameraSoftbusAdapter::GetInstance().SourceOnMessage(socket, data, dataLen); in DCameraSourceOnMessage()
79 static void DCameraSourceOnStream(int32_t socket, const StreamData *data, const StreamData *ext, in DCameraSourceOnStream() argument
82 DCameraSoftbusAdapter::GetInstance().SourceOnStream(socket, data, ext, param); in DCameraSourceOnStream()
87 static void DCameraSinkOnBind(int32_t socket, PeerSocketInf argument
93 DCameraSinkOnShutDown(int32_t socket, ShutdownReason reason) DCameraSinkOnShutDown() argument
99 DCameraSinkOnBytes(int32_t socket, const void *data, uint32_t dataLen) DCameraSinkOnBytes() argument
105 DCameraSinkOnMessage(int32_t socket, const void *data, uint32_t dataLen) DCameraSinkOnMessage() argument
111 DCameraSinkOnStream(int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) DCameraSinkOnStream() argument
258 CloseSoftbusSession(int32_t socket) CloseSoftbusSession() argument
274 SendSofbusBytes(int32_t socket, std::shared_ptr<DataBuffer>& buffer) SendSofbusBytes() argument
280 SendSofbusStream(int32_t socket, std::shared_ptr<DataBuffer>& buffer) SendSofbusStream() argument
323 DCameraSoftbusSourceGetSession(int32_t socket, std::shared_ptr<DCameraSoftbusSession>& session) DCameraSoftbusSourceGetSession() argument
337 SourceOnBind(int32_t socket, PeerSocketInfo info) SourceOnBind() argument
354 SourceOnShutDown(int32_t socket, ShutdownReason reason) SourceOnShutDown() argument
368 SourceOnBytes(int32_t socket, const void *data, uint32_t dataLen) SourceOnBytes() argument
393 SourceOnMessage(int32_t socket, const void *data, uint32_t dataLen) SourceOnMessage() argument
401 SourceOnStream(int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) SourceOnStream() argument
472 RecordSourceSocketSession(int32_t socket, std::shared_ptr<DCameraSoftbusSession> session) RecordSourceSocketSession() argument
484 DCameraSoftbusSinkGetSession(int32_t socket, std::shared_ptr<DCameraSoftbusSession>& session) DCameraSoftbusSinkGetSession() argument
516 DCameraSoftBusGetSessionByPeerSocket(int32_t socket, std::shared_ptr<DCameraSoftbusSession> &session, PeerSocketInfo info) DCameraSoftBusGetSessionByPeerSocket() argument
552 SinkOnBind(int32_t socket, PeerSocketInfo info) SinkOnBind() argument
569 SinkOnShutDown(int32_t socket, ShutdownReason reason) SinkOnShutDown() argument
583 SinkOnBytes(int32_t socket, const void *data, uint32_t dataLen) SinkOnBytes() argument
607 SinkOnMessage(int32_t socket, const void *data, uint32_t dataLen) SinkOnMessage() argument
612 SinkOnStream(int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) SinkOnStream() argument
[all...] |
| /foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/network/softbus/ |
| H A D | softbus_asset_send_listener_test.cpp | 76 int32_t socket = 1; in HWTEST_F() local
77 SoftBusAssetSendListener::OnFile(socket, nullptr); in HWTEST_F()
78 SoftBusAssetSendListener::OnFile(socket, &event); in HWTEST_F()
81 SoftBusAssetSendListener::OnFile(socket, &event); in HWTEST_F()
86 SoftBusHandlerAsset::GetInstance().AddAssetObj(socket, assetObj); in HWTEST_F()
87 SoftBusAssetSendListener::OnFile(socket, &event); in HWTEST_F()
88 EXPECT_EQ(SoftBusHandlerAsset::GetInstance().GetAssetObj(socket), nullptr); in HWTEST_F()
110 int32_t socket = 1; in HWTEST_F() local
111 SoftBusAssetSendListener::OnFile(socket, nullptr); in HWTEST_F()
112 SoftBusAssetSendListener::OnFile(socket, in HWTEST_F()
144 int32_t socket = 1; HWTEST_F() local
[all...] |
| H A D | softbus_asset_recv_listener_test.cpp | 78 int32_t socket = 1; in HWTEST_F() local
79 SoftbusAssetRecvListener::OnFile(socket, nullptr); in HWTEST_F()
80 SoftbusAssetRecvListener::OnFile(socket, &event); in HWTEST_F()
83 SoftbusAssetRecvListener::OnFile(socket, &event); in HWTEST_F()
86 SoftBusHandlerAsset::GetInstance().clientInfoMap_.insert(std::make_pair(socket, "test")); in HWTEST_F()
87 SoftbusAssetRecvListener::OnFile(socket, &event); in HWTEST_F()
88 SoftBusHandlerAsset::GetInstance().clientInfoMap_.erase(socket); in HWTEST_F()
110 int32_t socket = 1; in HWTEST_F() local
111 SoftbusAssetRecvListener::OnFile(socket, &event); in HWTEST_F()
114 SoftbusAssetRecvListener::OnFile(socket, in HWTEST_F()
141 int32_t socket = 1; HWTEST_F() local
167 int32_t socket = 1; HWTEST_F() local
[all...] |
| /foundation/multimedia/av_session/services/session/server/test/fuzztest/softbussessionmanager_fuzzer/ |
| H A D | softbussessionmanager_fuzzer.cpp | 39 void OnBind(int32_t socket, PeerSocketInfo info) override {};
40 void OnShutdown(int32_t socket, ShutdownReason reason) override {};
41 void OnBytes(int32_t socket, const void *data, int32_t dataLen) override {};
42 void OnMessage(int32_t socket, const void *data, int32_t dataLen) override {};
52 int32_t socket = *reinterpret_cast<const int32_t *>(data); in SoftbusSessionManagerFuzzTest() local
53 manager_->OnBind(socket, info); in SoftbusSessionManagerFuzzTest()
54 manager_->OnShutdown(socket, ShutdownReason::SHUTDOWN_REASON_LOCAL); in SoftbusSessionManagerFuzzTest()
60 manager_->ObtainPeerDeviceId(socket, deviceId); in SoftbusSessionManagerFuzzTest()
66 manager_->OnBytes(socket, objectId, dataLen); in SoftbusSessionManagerFuzzTest()
67 manager_->OnBytes(socket, nullpt in SoftbusSessionManagerFuzzTest()
[all...] |
| /foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/bind_fuzzer/ |
| H A D | bind_fuzzer.cpp | 19 #include "socket.h"
22 static void OnBindFuzzTest(int32_t socket, PeerSocketInfo info) in OnBindFuzzTest() argument
24 (void)socket; in OnBindFuzzTest()
28 static void OnShutdownFuzzTest(int32_t socket, ShutdownReason reason) in OnShutdownFuzzTest() argument
30 (void)socket; in OnShutdownFuzzTest()
34 static void OnBytesFuzzTest(int32_t socket, const void *data, uint32_t dataLen) in OnBytesFuzzTest() argument
36 (void)socket; in OnBytesFuzzTest()
41 static void OnMessageFuzzTest(int32_t socket, const void *data, uint32_t dataLen) in OnMessageFuzzTest() argument
43 (void)socket; in OnMessageFuzzTest()
48 static void OnStreamFuzzTest(int32_t socket, cons argument
57 OnFileFuzzTest(int32_t socket, FileEvent *event) OnFileFuzzTest() argument
63 OnQosFuzzTest(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) OnQosFuzzTest() argument
71 OnErrorFuzzTest(int32_t socket, int32_t errCode) OnErrorFuzzTest() argument
77 OnNegotiateFuzzTest(int32_t socket, PeerSocketInfo info) OnNegotiateFuzzTest() argument
[all...] |
| /foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/listen_fuzzer/ |
| H A D | listen_fuzzer.cpp | 19 #include "socket.h"
22 static void OnBindFuzzTest(int32_t socket, PeerSocketInfo info) in OnBindFuzzTest() argument
24 (void)socket; in OnBindFuzzTest()
28 static void OnShutdownFuzzTest(int32_t socket, ShutdownReason reason) in OnShutdownFuzzTest() argument
30 (void)socket; in OnShutdownFuzzTest()
34 static void OnBytesFuzzTest(int32_t socket, const void *data, uint32_t dataLen) in OnBytesFuzzTest() argument
36 (void)socket; in OnBytesFuzzTest()
41 static void OnMessageFuzzTest(int32_t socket, const void *data, uint32_t dataLen) in OnMessageFuzzTest() argument
43 (void)socket; in OnMessageFuzzTest()
48 static void OnStreamFuzzTest(int32_t socket, cons argument
57 OnFileFuzzTest(int32_t socket, FileEvent *event) OnFileFuzzTest() argument
63 OnQosFuzzTest(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) OnQosFuzzTest() argument
71 OnErrorFuzzTest(int32_t socket, int32_t errCode) OnErrorFuzzTest() argument
77 OnNegotiateFuzzTest(int32_t socket, PeerSocketInfo info) OnNegotiateFuzzTest() argument
[all...] |
| /foundation/communication/dsoftbus/sdk/transmission/session/src/ |
| H A D | client_trans_socket_service.c | 24 #include "socket.h"
38 TRANS_LOGE(TRANS_SDK, "invalid name or package name of socket"); in CheckSocketInfoIsValid()
113 TRANS_LOGE(TRANS_SDK, "add socket failed, ret=%{public}d.", ret); in Socket()
116 TRANS_LOGD(TRANS_SDK, "create socket ok, socket=%{public}d", socketFd); in Socket()
120 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() argument
122 TRANS_LOGD(TRANS_SDK, "Listen: socket=%{public}d", socket); in Listen()
123 return ClientListen(socket, qos, qosCount, listener); in Listen()
126 static int32_t StartBindWaitTimer(int32_t socket, cons argument
144 Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) Bind() argument
169 BindAsync(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) BindAsync() argument
195 Shutdown(int32_t socket) Shutdown() argument
213 GetMtuSize(int32_t socket, uint32_t *mtuSize) GetMtuSize() argument
229 DfsBind(int32_t socket, const ISocketListener *listener) DfsBind() argument
251 SetSocketOpt(int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t optValueSize) SetSocketOpt() argument
274 GetSocketOpt(int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t *optValueSize) GetSocketOpt() argument
[all...] |
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/core/ |
| H A D | nstackx_socket.c | 29 void CloseSocket(Socket *socket) in CloseSocket() argument
31 if (socket == NULL) { in CloseSocket()
34 CloseSocketInner(socket->sockfd); in CloseSocket()
35 socket->sockfd = INVALID_SOCKET; in CloseSocket()
36 free(socket); in CloseSocket()
92 clientSocket->sockfd = socket(AF_INET, SOCK_STREAM, 0); in ConnectTcpServerWithTargetDev()
94 LOGE(TAG, "socket create failed, error :%d", GetErrno()); in ConnectTcpServerWithTargetDev()
98 LOGE(TAG, "set socket buf failed"); in ConnectTcpServerWithTargetDev()
101 LOGE(TAG, "set socket nonblock failed"); in ConnectTcpServerWithTargetDev()
137 clientSocket->sockfd = socket(AF_INE in ConnectUdpServerWithTargetDev()
298 Socket *socket = calloc(1, sizeof(Socket)); ClientSocketWithTargetDev() local
343 Socket *socket = calloc(1, sizeof(Socket)); ServerSocket() local
462 SocketSendUdp(const Socket *socket, const uint8_t *buffer, size_t length) SocketSendUdp() argument
473 SocketSend(const Socket *socket, const uint8_t *buffer, size_t length) SocketSend() argument
493 SocketRecvTcp(const Socket *socket, uint8_t *buffer, size_t length, struct sockaddr_in *srcAddr, const socklen_t *addrLen) SocketRecvTcp() argument
503 SocketRecvUdp(const Socket *socket, uint8_t *buffer, size_t length, struct sockaddr_in *srcAddr, const socklen_t *addrLen) SocketRecvUdp() argument
522 SocketRecv(Socket *socket, uint8_t *buffer, size_t length, struct sockaddr_in *srcAddr, const socklen_t *addrLen) SocketRecv() argument
[all...] |
| /foundation/filemanagement/dfs_service/test/mock/ |
| H A D | socket_mock.cpp | 24 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() argument
26 return DfsSocket::dfsSocket->Listen(socket, qos, qosCount, listener); in Listen()
29 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind() argument
31 return DfsSocket::dfsSocket->Bind(socket, qos, qosCount, listener); in Bind()
34 void Shutdown(int32_t socket) in Shutdown() argument
36 (void)socket; in Shutdown()
39 int SendFile(int32_t socket, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) in SendFile() argument
41 return DfsSocket::dfsSocket->SendFile(socket, sFileList, dFileList, fileCnt); in SendFile()
|
| /foundation/distributedhardware/distributed_camera/services/channel/include/ |
| H A D | dcamera_softbus_adapter.h | 27 #include "socket.h"
47 int32_t CloseSoftbusSession(int32_t socket);
48 int32_t SendSofbusBytes(int32_t socket, std::shared_ptr<DataBuffer> &buffer);
49 int32_t SendSofbusStream(int32_t socket, std::shared_ptr<DataBuffer> &buffer);
52 int32_t SourceOnBind(int32_t socket, PeerSocketInfo info);
53 void SourceOnShutDown(int32_t socket, ShutdownReason reason);
54 void SourceOnBytes(int32_t socket, const void *data, uint32_t dataLen);
55 void SourceOnMessage(int32_t socket, const void *data, uint32_t dataLen);
56 void SourceOnStream(int32_t socket, const StreamData *data, const StreamData *ext,
59 int32_t SinkOnBind(int32_t socket, PeerSocketInf
[all...] |
| /foundation/distributedhardware/distributed_input/services/transportbase/src/ |
| H A D | distributed_input_transport_base.cpp | 57 void OnBind(int32_t socket, PeerSocketInfo info) in OnBind() argument
59 DistributedInput::DistributedInputTransportBase::GetInstance().OnSessionOpened(socket, info); in OnBind()
62 void OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown() argument
64 DistributedInput::DistributedInputTransportBase::GetInstance().OnSessionClosed(socket, reason); in OnShutdown()
67 void OnBytes(int32_t socket, const void *data, uint32_t dataLen) in OnBytes() argument
69 DistributedInput::DistributedInputTransportBase::GetInstance().OnBytesReceived(socket, data, dataLen); in OnBytes()
72 void OnMessage(int32_t socket, const void *data, uint32_t dataLen) in OnMessage() argument
74 (void)socket; in OnMessage()
77 DHLOGI("socket: %{public}d, dataLen:%{public}d", socket, dataLe in OnMessage()
80 OnStream(int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnStream() argument
90 OnFile(int32_t socket, FileEvent *event) OnFile() argument
96 OnQos(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) OnQos() argument
122 int32_t socket = CreateServerSocket(); Init() local
157 int32_t socket = Socket(info); CreateServerSocket() local
220 int32_t socket = Socket(info); CreateClientSocket() local
234 int socket = CreateClientSocket(remoteDevId); StartSession() local
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/ |
| H A D | socket.cpp | 16 #include "socket.h"
18 #include <sys/socket.h>
42 void OnConnectIncomingNative(Socket &socket, RawAddress addr, uint8_t port);
43 void OnConnectedNative(Socket &socket, DataTransport *transport, uint16_t sendMTU, uint16_t recvMTU);
44 void OnDisconnectedNative(Socket &socket, DataTransport *transport);
45 void OnDisconnectSuccessNative(Socket &socket, DataTransport *transport);
46 void OnDataAvailableNative(Socket &socket, DataTransport *transport);
47 void OnTransportErrorNative(Socket &socket, DataTransport *transport, int errType);
48 void SockRfcConnectFail(Socket &socket, DataTransport *transport);
49 void SockRfcDisconnectFail(Socket &socket, DataTranspor
136 DataTransportObserverImplement(Socket &socket) DataTransportObserverImplement() argument
145 OnConnectIncomingNative(Socket &socket, RawAddress addr, uint8_t port) OnConnectIncomingNative() argument
159 OnConnectedNative(Socket &socket, DataTransport *transport, uint16_t sendMTU, uint16_t recvMTU) OnConnectedNative() argument
186 OnDisconnectedNative(Socket &socket, DataTransport *transport) OnDisconnectedNative() argument
193 OnDisconnectSuccessNative(Socket &socket, DataTransport *transport) OnDisconnectSuccessNative() argument
200 OnDataAvailableNative(Socket &socket, DataTransport *transport) OnDataAvailableNative() argument
256 OnTransportErrorNative(Socket &socket, DataTransport *transport, int errType) OnTransportErrorNative() argument
275 SockRfcConnectFail(Socket &socket, DataTransport *transport) SockRfcConnectFail() argument
297 SockRfcDisconnectFail(Socket &socket, DataTransport *transport) SockRfcDisconnectFail() argument
315 SockRfcFcOn(Socket &socket, DataTransport *transport) SockRfcFcOn() argument
565 ProcessDisconnection(Socket &socket, DataTransport *transport) ProcessDisconnection() argument
981 EraseSocket(Socket &socket) EraseSocket() argument
[all...] |
| /foundation/multimodalinput/input/intention/adapters/dsoftbus_adapter/src/ |
| H A D | dsoftbus_adapter_impl.cpp | 188 int32_t socket = FindConnection(networkId); in SendPacket() local
189 if (socket < 0) { in SendPacket()
202 int32_t ret = ::SendBytes(socket, buffer.Data(), buffer.Size()); in SendPacket()
214 int32_t socket = FindConnection(networkId); in SendParcel() local
215 if (socket < 0) { in SendParcel()
219 int32_t ret = ::SendBytes(socket, reinterpret_cast<const void*>(parcel.GetData()), parcel.GetDataSize()); in SendParcel()
245 int32_t socket = elem.second.socket_; in BroadcastPacket() local
246 if (socket < 0) { in BroadcastPacket()
250 if (int32_t ret = ::SendBytes(socket, buffer.Data(), buffer.Size()); ret != SOFTBUS_OK) { in BroadcastPacket()
259 static void OnBindLink(int32_t socket, PeerSocketInf argument
264 OnShutdownLink(int32_t socket, ShutdownReason reason) OnShutdownLink() argument
269 OnBytesAvailable(int32_t socket, const void *data, uint32_t dataLen) OnBytesAvailable() argument
274 OnBind(int32_t socket, PeerSocketInfo info) OnBind() argument
301 OnShutdown(int32_t socket, ShutdownReason reason) OnShutdown() argument
327 OnBytes(int32_t socket, const void *data, uint32_t dataLen) OnBytes() argument
353 InitSocket(SocketInfo info, int32_t socketType, int32_t &socket) InitSocket() argument
490 ConfigTcpAlive(int32_t socket) ConfigTcpAlive() argument
[all...] |
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/transport/ |
| H A D | dh_transport.cpp | 58 DHLOGI("OnSocketOpened, socket: %{public}d, peerSocketName: %{public}s, peerNetworkId: %{public}s, " in OnSocketOpened()
67 DHLOGI("OnSocketClosed, socket: %{public}d, reason: %{public}d", socketId, (int32_t)reason); in OnSocketClosed()
155 void OnBind(int32_t socket, PeerSocketInfo info) in OnBind() argument
162 dhCommToolSPtr->GetDHTransportPtr()->OnSocketOpened(socket, info); in OnBind()
165 void OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown() argument
172 dhCommToolSPtr->GetDHTransportPtr()->OnSocketClosed(socket, reason); in OnShutdown()
175 void OnBytes(int32_t socket, const void *data, uint32_t dataLen) in OnBytes() argument
182 dhCommToolSPtr->GetDHTransportPtr()->OnBytesReceived(socket, data, dataLen); in OnBytes()
185 void OnMessage(int32_t socket, const void *data, uint32_t dataLen) in OnMessage() argument
187 (void)socket; in OnMessage()
193 OnStream(int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnStream() argument
203 OnFile(int32_t socket, FileEvent *event) OnFile() argument
209 OnQos(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) OnQos() argument
244 int32_t socket = Socket(info); CreateServerSocket() local
263 int32_t socket = Socket(info); CreateClientSocket() local
276 int32_t socket = CreateServerSocket(); Init() local
364 int32_t socket = CreateClientSocket(remoteNetworkId); StartSocket() local
[all...] |
| /foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/softbus/ |
| H A D | softbus_adapter.cpp | 45 int socket = ::Socket(info); in CreateSessionServer() local
46 if (socket <= 0) { in CreateSessionServer()
47 LOGE("Failed to CreateSessionServer ret:%{public}d, sessionName:%{public}s", socket, sessionName); in CreateSessionServer()
53 auto sessionAndPackage = sessionAndPackageMap_.find(socket); in CreateSessionServer()
55 sessionAndPackageMap_.insert({socket, saveKey}); in CreateSessionServer()
73 int32_t ret = ::Listen(socket, serverQos, QOS_COUNT, &listener); in CreateSessionServer()
85 int32_t socket = SoftbusAdapter::GetInstance().GetSocketNameFromMap(val); in RemoveSessionServer() local
86 string existSessionName = SoftbusAdapter::GetInstance().GetSessionNameFromMap(socket); in RemoveSessionServer()
91 SoftbusAdapter::GetInstance().RemoveSesion(socket); in RemoveSessionServer()
92 ::Shutdown(socket); in RemoveSessionServer()
97 OnBind(int socket, PeerSocketInfo info) OnBind() argument
116 OnShutdown(int32_t socket, ShutdownReason reason) OnShutdown() argument
135 OnBytes(int socket, const void *data, unsigned int dataLen) OnBytes() argument
200 OnFile(int32_t socket, FileEvent *event) OnFile() argument
219 int32_t socket = Socket(info); OpenSession() local
307 int32_t socket = -1; GetSocketNameFromMap() local
[all...] |
| /foundation/graphic/graphic_2d/rosen/modules/render_service_profiler/ |
| H A D | rs_profiler_socket.cpp | 23 #include <sys/socket.h>
41 static timeval GetTimeout(int32_t socket) in GetTimeout() argument
45 getsockopt(socket, SOL_SOCKET, SO_SNDTIMEO, reinterpret_cast<char*>(&timeout), &size); in GetTimeout()
49 static void SetTimeout(int32_t socket, const timeval& timeout) in SetTimeout() argument
51 setsockopt(socket, SOL_SOCKET, SO_SNDTIMEO, reinterpret_cast<const char*>(&timeout), sizeof(timeout)); in SetTimeout()
54 static void SetTimeout(int32_t socket, uint32_t milliseconds) in SetTimeout() argument
56 SetTimeout(socket, GetTimeoutDesc(milliseconds)); in SetTimeout()
64 static void SetBlocking(int32_t socket, bool enable) in SetBlocking() argument
66 fcntl(socket, F_SETFL, ToggleFlag(fcntl(socket, F_GETF in SetBlocking()
69 SetCloseOnExec(int32_t socket, bool enable) SetCloseOnExec() argument
74 GetFdSet(int32_t socket) GetFdSet() argument
82 IsFdSet(int32_t socket, const fd_set& set) IsFdSet() argument
[all...] |
| /foundation/communication/dsoftbus/tests/sdk/transmission/moduletest/socket/stream_encrypt_test/ |
| H A D | stream_encrypt_server_mt.cpp | 58 void OnBindServer(int32_t socket, PeerSocketInfo info) in OnBindServer() argument
60 LOGI(">> OnBind {socket:%d, name:%s, networkId:%s, pkgName:%s, dataType:%d}", socket, info.name, info.networkId, in OnBindServer()
64 void OnShutdownServer(int32_t socket, ShutdownReason reason) in OnShutdownServer() argument
66 LOGI(">> OnOnShutdown {socket:%d, reason:%d}", socket, reason); in OnShutdownServer()
96 int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) in OnStreamReceivedWithNoDataType()
98 OnStreamReceived(socket, "RawStreamEncryptTestServer001", data); in OnStreamReceivedWithNoDataType()
116 * @tc.steps: step 1. do not set dataType and create socket by 'Socket' function. in HWTEST_F()
117 * @tc.expect: socket greate in HWTEST_F()
95 OnStreamReceivedWithNoDataType( int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnStreamReceivedWithNoDataType() argument
123 int32_t socket = Socket(info); HWTEST_F() local
160 OnStreamReceivedWithUnencryptOpt( int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnStreamReceivedWithUnencryptOpt() argument
182 int32_t socket = Socket(info); HWTEST_F() local
219 OnStreamReceivedWithEncryptOpt( int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnStreamReceivedWithEncryptOpt() argument
242 int32_t socket = Socket(info); HWTEST_F() local
293 OnStreamReceivedWithOldInterface( int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnStreamReceivedWithOldInterface() argument
[all...] |