| /foundation/distributedhardware/device_manager/test/softbusunittest/ |
| D | UTTest_softbus_adapter.cpp | 59 int32_t socket = 1; variable
72 int32_t socket = 1; variable
80 int32_t socket = 1; variable
88 int32_t socket = 1; variable
98 int32_t socket = 1; variable
106 int32_t socket = 1; variable
120 int32_t socket = 1; variable
133 int32_t socket = 1; variable
141 int32_t socket = 1; variable
149 int32_t socket = 1; variable
[all …]
|
| /foundation/distributedhardware/device_manager/services/service/src/softbus/ |
| D | softbus_adapter.cpp | 35 static void DmOnSoftbusSessionBind(int32_t socket, PeerSocketInfo info) in DmOnSoftbusSessionBind()
40 static void DmOnSoftbusSessionClosed(int32_t socket, ShutdownReason reason) in DmOnSoftbusSessionClosed()
45 static void DmOnBytesReceived(int32_t socket, const void *data, uint32_t dataLen) in DmOnBytesReceived()
50 static void DmOnStreamReceived(int32_t socket, const StreamData *data, const StreamData *ext, in DmOnStreamReceived()
56 static void DmOnMessageReceived(int32_t socket, const void *data, uint32_t dataLen) in DmOnMessageReceived()
61 static void DmOnQosEvent(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in DmOnQosEvent()
94 int32_t socket = Socket(info); in CreateSoftbusSessionServer() local
121 void SoftbusAdapter::OnSoftbusSessionOpened(int32_t socket, PeerSocketInfo info) in OnSoftbusSessionOpened()
127 void SoftbusAdapter::OnSoftbusSessionClosed(int32_t socket, ShutdownReason reason) in OnSoftbusSessionClosed()
134 void SoftbusAdapter::OnBytesReceived(int32_t socket, const void *data, uint32_t dataLen) in OnBytesReceived()
[all …]
|
| /foundation/multimedia/av_session/services/session/server/softbus/ |
| D | softbus_session_manager.cpp | 29 static void OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
35 static void OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown()
41 static void OnBytes(int socket, const void *data, unsigned int dataLen) in OnBytes()
48 static void OnMessage(int socket, const void *data, unsigned int dataLen) in OnMessage()
73 int32_t socket = ::Socket(info); in Socket() local
90 void SoftbusSessionManager::Shutdown(int32_t socket) in Shutdown()
96 int32_t SoftbusSessionManager::SendMessage(int32_t socket, const std::string &data) in SendMessage()
110 int32_t SoftbusSessionManager::SendBytes(int32_t socket, const std::string &data) in SendBytes()
124 int32_t SoftbusSessionManager::ObtainPeerDeviceId(int32_t socket, std::string &deviceId) in ObtainPeerDeviceId()
148 void SoftbusSessionManager::OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
[all …]
|
| D | softbus_distributed_data_manager.cpp | 38 void SoftbusDistributedDataManager::SessionOpened(int32_t socket, PeerSocketInfo info) in SessionOpened()
53 void SoftbusDistributedDataManager::SessionClosed(int32_t socket) in SessionClosed()
62 void SoftbusDistributedDataManager::MessageReceived(int32_t socket, const std::string &data) in MessageReceived()
73 void SoftbusDistributedDataManager::BytesReceived(int32_t socket, const std::string &data) in BytesReceived()
87 int32_t socket = SoftbusSessionManager::GetInstance().Socket(pkg); in InitSessionServer() local
135 void SoftbusDistributedDataManager::OnSessionServerClosed(int32_t socket) in OnSessionServerClosed()
145 void SoftbusDistributedDataManager::OnMessageHandleReceived(int32_t socket, const std::string &data) in OnMessageHandleReceived()
|
| D | softbus_distributed_data_manager.h | 33 void OnBind(int32_t socket, PeerSocketInfo info) override in OnBind()
41 void OnShutdown(int32_t socket, ShutdownReason reason) override in OnShutdown()
49 void OnMessage(int32_t socket, const void *data, int32_t dataLen) override in OnMessage()
58 void OnBytes(int32_t socket, const void *data, int32_t dataLen) override in OnBytes()
|
| /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/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/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_camera/services/channel/src/ |
| D | dcamera_softbus_adapter.cpp | 42 static void DCameraSourceOnBind(int32_t socket, PeerSocketInfo info) in DCameraSourceOnBind()
47 static void DCameraSourceOnShutDown(int32_t socket, ShutdownReason reason) in DCameraSourceOnShutDown()
53 static void DCameraSourceOnBytes(int32_t socket, const void *data, uint32_t dataLen) in DCameraSourceOnBytes()
59 static void DCameraSourceOnMessage(int32_t socket, const void *data, uint32_t dataLen) in DCameraSourceOnMessage()
65 static void DCameraSourceOnStream(int32_t socket, const StreamData *data, const StreamData *ext, in DCameraSourceOnStream()
73 static void DCameraSinkOnBind(int32_t socket, PeerSocketInfo info) in DCameraSinkOnBind()
79 static void DCameraSinkOnShutDown(int32_t socket, ShutdownReason reason) in DCameraSinkOnShutDown()
85 static void DCameraSinkOnBytes(int32_t socket, const void *data, uint32_t dataLen) in DCameraSinkOnBytes()
91 static void DCameraSinkOnMessage(int32_t socket, const void *data, uint32_t dataLen) in DCameraSinkOnMessage()
97 static void DCameraSinkOnStream(int32_t socket, const StreamData *data, const StreamData *ext, in DCameraSinkOnStream()
[all …]
|
| /foundation/filemanagement/dfs_service/test/mock/ |
| D | socket_mock.cpp | 24 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listene… in Listen()
29 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind()
34 void Shutdown(int32_t socket) in Shutdown()
39 int SendFile(int32_t socket, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) in SendFile()
|
| /foundation/communication/dsoftbus/sdk/transmission/session/src/ |
| D | client_trans_socket_service.c | 120 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listene… in Listen()
126 static int32_t StartBindWaitTimer(int32_t socket, const QosTV qos[], uint32_t qosCount) in StartBindWaitTimer()
144 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind()
169 int32_t BindAsync(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *list… in BindAsync()
195 void Shutdown(int32_t socket) in Shutdown()
213 int32_t GetMtuSize(int32_t socket, uint32_t *mtuSize) in GetMtuSize()
229 int32_t DfsBind(int32_t socket, const ISocketListener *listener) in DfsBind()
251 int32_t SetSocketOpt(int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t optVa… in SetSocketOpt()
274 int32_t GetSocketOpt(int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t *optV… in GetSocketOpt()
|
| D | client_trans_socket_option.c | 22 int32_t SetExtSocketOpt(int32_t socket, OptLevel level, OptType optType, void *optValue, uint32_t o… in SetExtSocketOpt()
32 int32_t GetExtSocketOpt(int32_t socket, OptLevel level, OptType optType, void *optValue, int32_t *o… in GetExtSocketOpt()
|
| /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()
|
| D | tmessenger.cpp | 162 int32_t socket = Socket(info); in StartListen() local
207 int32_t socket = Socket(info); in StartConnect() local
240 void TMessenger::OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
245 void TMessenger::OnMessage(int32_t socket, const void *data, uint32_t dataLen) in OnMessage()
251 void TMessenger::OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown()
256 void TMessenger::SetConnectSocket(int32_t socket, PeerSocketInfo info) in SetConnectSocket()
306 void TMessenger::CloseSocket(int32_t socket) in CloseSocket()
|
| /foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/network/softbus/ |
| D | softbus_asset_recv_listener_test.cpp | 78 int32_t socket = 1; variable
110 int32_t socket = 1; variable
141 int32_t socket = 1; variable
167 int32_t socket = 1; variable
|
| 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
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/transport/ |
| D | dh_transport.cpp | 155 void OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
165 void OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown()
175 void OnBytes(int32_t socket, const void *data, uint32_t dataLen) in OnBytes()
185 void OnMessage(int32_t socket, const void *data, uint32_t dataLen) in OnMessage()
193 void OnStream(int32_t socket, const StreamData *data, const StreamData *ext, in OnStream()
203 void OnFile(int32_t socket, FileEvent *event) in OnFile()
209 void OnQos(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQos()
244 int32_t socket = Socket(info); in CreateServerSocket() local
263 int32_t socket = Socket(info); in CreateClientSocket() local
276 int32_t socket = CreateServerSocket(); in Init() local
[all …]
|
| /foundation/communication/ipc/ipc/native/src/core/source/ |
| D | dbinder_softbus_client.cpp | 163 int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen()
184 int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind()
204 int32_t DBinderSoftbusClient::SendBytes(int32_t socket, const void *data, uint32_t len) in SendBytes()
223 int32_t DBinderSoftbusClient::SendMessage(int32_t socket, const void *data, uint32_t len) in SendMessage()
242 void DBinderSoftbusClient::Shutdown(int32_t socket) in Shutdown()
|
| /foundation/graphic/graphic_2d/rosen/modules/render_service_profiler/ |
| D | rs_profiler_socket.cpp | 41 static timeval GetTimeout(int32_t socket) in GetTimeout()
49 static void SetTimeout(int32_t socket, const timeval& timeout) in SetTimeout()
54 static void SetTimeout(int32_t socket, uint32_t milliseconds) in SetTimeout()
64 static void SetBlocking(int32_t socket, bool enable) in SetBlocking()
69 static void SetCloseOnExec(int32_t socket, bool enable) in SetCloseOnExec()
74 static fd_set GetFdSet(int32_t socket) in GetFdSet()
82 static bool IsFdSet(int32_t socket, const fd_set& set) in IsFdSet()
|
| /foundation/distributedhardware/distributed_input/services/transportbase/src/ |
| D | distributed_input_transport_base.cpp | 57 void OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
62 void OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown()
67 void OnBytes(int32_t socket, const void *data, uint32_t dataLen) in OnBytes()
72 void OnMessage(int32_t socket, const void *data, uint32_t dataLen) in OnMessage()
80 void OnStream(int32_t socket, const StreamData *data, const StreamData *ext, in OnStream()
90 void OnFile(int32_t socket, FileEvent *event) in OnFile()
96 void OnQos(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQos()
122 int32_t socket = CreateServerSocket(); in Init() local
157 int32_t socket = Socket(info); in CreateServerSocket() local
220 int32_t socket = Socket(info); in CreateClientSocket() local
[all …]
|
| /foundation/multimodalinput/input/intention/adapters/dsoftbus_adapter/src/ |
| D | dsoftbus_adapter_impl.cpp | 188 int32_t socket = FindConnection(networkId); in SendPacket() local
214 int32_t socket = FindConnection(networkId); in SendParcel() local
245 int32_t socket = elem.second.socket_; in BroadcastPacket() local
259 static void OnBindLink(int32_t socket, PeerSocketInfo info) in OnBindLink()
264 static void OnShutdownLink(int32_t socket, ShutdownReason reason) in OnShutdownLink()
269 static void OnBytesAvailable(int32_t socket, const void *data, uint32_t dataLen) in OnBytesAvailable()
274 void DSoftbusAdapterImpl::OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
301 void DSoftbusAdapterImpl::OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown()
327 void DSoftbusAdapterImpl::OnBytes(int32_t socket, const void *data, uint32_t dataLen) in OnBytes()
353 int32_t DSoftbusAdapterImpl::InitSocket(SocketInfo info, int32_t socketType, int32_t &socket) in InitSocket()
[all …]
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/core/ |
| D | nstackx_socket.c | 29 void CloseSocket(Socket *socket) in CloseSocket()
298 Socket *socket = calloc(1, sizeof(Socket)); in ClientSocketWithTargetDev() local
343 Socket *socket = calloc(1, sizeof(Socket)); in ServerSocket() local
462 static int32_t SocketSendUdp(const Socket *socket, const uint8_t *buffer, size_t length) in SocketSendUdp()
473 int32_t SocketSend(const Socket *socket, const uint8_t *buffer, size_t length) in SocketSend()
493 static int32_t SocketRecvTcp(const Socket *socket, uint8_t *buffer, size_t length, struct sockaddr_… in SocketRecvTcp()
503 static int32_t SocketRecvUdp(const Socket *socket, uint8_t *buffer, size_t length, struct sockaddr_… in SocketRecvUdp()
522 int32_t SocketRecv(Socket *socket, uint8_t *buffer, size_t length, struct sockaddr_in *srcAddr, in SocketRecv()
|
| /foundation/distributedhardware/device_manager/services/implementation/src/dependency/softbus/ |
| D | softbus_session.cpp | 41 static void OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown()
47 static void OnBytes(int32_t socket, const void *data, uint32_t dataLen) in OnBytes()
53 static void OnQos(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQos()
121 int32_t SoftbusSession::CloseUnbindSession(int32_t socket) in CloseUnbindSession()
220 void SoftbusSession::OnUnbindSessionOpened(int32_t socket, PeerSocketInfo info) in OnUnbindSessionOpened()
237 int32_t socket = Socket(info); in OpenUnbindSession() local
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/ |
| D | socket_service.cpp | 104 auto socket = std::make_unique<Socket>(); in Connect() local
123 auto socket = std::make_unique<Socket>(); in Listen() local
180 Socket *socket = static_cast<Socket *>(msg.arg2_); in ProcessMessage() local
220 void SocketService::CleanupClientSocket(Socket *socket) in CleanupClientSocket()
|