| /ohos5.0/foundation/distributedhardware/device_manager/services/implementation/src/dependency/softbus/ |
| H A 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
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_util/core/ |
| H A 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()
|
| /ohos5.0/foundation/multimodalinput/input/intention/adapters/dsoftbus_adapter/src/ |
| H A 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()
456 int32_t socket { -1 }; in OpenSessionLocked() local
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/moduletest/socket/stream_encrypt_test/ |
| H A D | tmessenger.cpp | 163 int32_t socket = Socket(info); in StartListen() local
208 int32_t socket = Socket(info); in StartConnect() local
241 void TMessenger::OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
246 void TMessenger::OnMessage(int32_t socket, const void *data, uint32_t dataLen) in OnMessage()
252 void TMessenger::OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown()
257 void TMessenger::SetConnectSocket(int32_t socket, PeerSocketInfo info) in SetConnectSocket()
307 void TMessenger::CloseSocket(int32_t socket) in CloseSocket()
|
| H A D | stream_encrypt_client_mt.cpp | 54 void OnShutdownClient(int32_t socket, ShutdownReason reason) in OnShutdownClient()
88 static int32_t SendStreamExt(int32_t socket) in SendStreamExt()
120 int32_t socket = Socket(info); variable
174 int32_t socket = Socket(info); variable
|
| /ohos5.0/base/msdp/device_status/intention/adapters/dsoftbus_adapter/src/ |
| H A D | dsoftbus_adapter_impl.cpp | 183 int32_t socket = FindConnection(networkId); in SendPacket() local
209 int32_t socket = FindConnection(networkId); in SendParcel() local
240 int32_t socket = elem.second.socket_; in BroadcastPacket() local
261 static void OnBindLink(int32_t socket, PeerSocketInfo info) in OnBindLink()
266 static void OnShutdownLink(int32_t socket, ShutdownReason reason) in OnShutdownLink()
271 static void OnBytesAvailable(int32_t socket, const void *data, uint32_t dataLen) in OnBytesAvailable()
276 void DSoftbusAdapterImpl::OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
303 void DSoftbusAdapterImpl::OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown()
329 void DSoftbusAdapterImpl::OnBytes(int32_t socket, const void *data, uint32_t dataLen) in OnBytes()
458 int32_t socket { -1 }; in OpenSessionLocked() local
[all …]
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/ |
| H A 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()
|
| H A D | socket.cpp | 136 DataTransportObserverImplement(Socket &socket) : socket_(socket) in DataTransportObserverImplement()
145 void Socket::impl::OnConnectIncomingNative(Socket &socket, RawAddress addr, uint8_t port) in OnConnectIncomingNative()
186 void Socket::impl::OnDisconnectedNative(Socket &socket, DataTransport *transport) in OnDisconnectedNative()
193 void Socket::impl::OnDisconnectSuccessNative(Socket &socket, DataTransport *transport) in OnDisconnectSuccessNative()
200 void Socket::impl::OnDataAvailableNative(Socket &socket, DataTransport *transport) in OnDataAvailableNative()
256 void Socket::impl::OnTransportErrorNative(Socket &socket, DataTransport *transport, int errType) in OnTransportErrorNative()
275 void Socket::impl::SockRfcConnectFail(Socket &socket, DataTransport *transport) in SockRfcConnectFail()
297 void Socket::impl::SockRfcDisconnectFail(Socket &socket, DataTransport *transport) in SockRfcDisconnectFail()
315 void Socket::impl::SockRfcFcOn(Socket &socket, DataTransport *transport) in SockRfcFcOn()
565 void Socket::ProcessDisconnection(Socket &socket, DataTransport *transport) in ProcessDisconnection()
[all …]
|
| /ohos5.0/foundation/distributedhardware/device_manager/test/softbusfuzztest/softbussessionobject_fuzzer/ |
| H A D | softbus_session_object_fuzzer.cpp | 48 void OnUnbindSessionOpened(int32_t socket, PeerSocketInfo info) override in OnUnbindSessionOpened()
58 void BindSocketSuccess(int32_t socket) override in BindSocketSuccess()
71 int32_t socket = *(reinterpret_cast<const int*>(data)); in SoftBusSessionFuzzTest() local
|
| /ohos5.0/foundation/communication/ipc/services/dbinder/dbinder_service/src/socket/ |
| H A D | dbinder_remote_listener.cpp | 50 void DBinderRemoteListener::ServerOnBind(int32_t socket, PeerSocketInfo info) in ServerOnBind()
59 void DBinderRemoteListener::ServerOnShutdown(int32_t socket, ShutdownReason reason) in ServerOnShutdown()
72 void DBinderRemoteListener::ClientOnBind(int32_t socket, PeerSocketInfo info) in ClientOnBind()
77 void DBinderRemoteListener::ClientOnShutdown(int32_t socket, ShutdownReason reason) in ClientOnShutdown()
99 void DBinderRemoteListener::OnBytesReceived(int32_t socket, const void *data, uint32_t dataLen) in OnBytesReceived()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/ |
| H A D | mod.rs | 16 mod socket; module
|
| H A D | socket.rs | 25 socket: c_int, field
38 let socket = socket_new(domain, socket_type)?; in create_socket() localVariable
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| H A D | mod.rs | 14 mod socket; module
|
| /ohos5.0/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/softbus/ |
| H A D | softbus_adapter.cpp | 45 int socket = ::Socket(info); in CreateSessionServer() local
82 int32_t socket = SoftbusAdapter::GetInstance().GetSocketNameFromMap(val); in RemoveSessionServer() local
94 void SoftbusAdapter::OnBind(int socket, PeerSocketInfo info) in OnBind()
113 void SoftbusAdapter::OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown()
132 void SoftbusAdapter::OnBytes(int socket, const void *data, unsigned int dataLen) in OnBytes()
197 void SoftbusAdapter::OnFile(int32_t socket, FileEvent *event) in OnFile()
216 int32_t socket = Socket(info); in OpenSession() local
301 int32_t socket = -1; in GetSocketNameFromMap() local
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| H A D | mod.rs | 19 mod socket; module
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| H A D | mod.rs | 17 mod socket; module
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/server/src/ |
| H A D | bluetooth_socket_server.cpp | 35 …IProfileSocket *socket = (IProfileSocket *)IProfileManager::GetInstance()->GetProfileService(PROFI… in Connect() local
50 …IProfileSocket *socket = (IProfileSocket *)IProfileManager::GetInstance()->GetProfileService(PROFI… in Listen() local
|
| /ohos5.0/foundation/communication/ipc/ipc/native/src/core/source/ |
| H A D | databus_socket_listener.cpp | 62 void DatabusSocketListener::ServerOnBind(int32_t socket, PeerSocketInfo info) in ServerOnBind()
84 void DatabusSocketListener::ServerOnShutdown(int32_t socket, ShutdownReason reason) in ServerOnShutdown()
96 void DatabusSocketListener::ClientOnBind(int32_t socket, PeerSocketInfo info) in ClientOnBind()
101 void DatabusSocketListener::ClientOnShutdown(int32_t socket, ShutdownReason reason) in ClientOnShutdown()
127 void DatabusSocketListener::OnBytesReceived(int32_t socket, const void *data, uint32_t dataLen) in OnBytesReceived()
|
| /ohos5.0/foundation/filemanagement/storage_service/services/storage_daemon/netlink/test/ |
| H A D | netlink_listener_mock.h | 25 explicit NetlinkListenerMock(int32_t socket) : NetlinkListener(socket) {} in NetlinkListenerMock()
|
| H A D | netlink_handler_test.cpp | 49 int32_t socket = -1; variable
71 int32_t socket = 0; variable
|
| H A D | netlink_listener_test.cpp | 49 int32_t socket = -1; variable
70 int32_t socket = 0; variable
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | mod.rs | 14 mod socket; module
|
| H A D | listener.rs | 67 let socket = { in accept() localVariable
78 let socket = { in accept() localVariable
86 let socket = unsafe { net::UnixStream::from_raw_fd(socket) }; in accept() localVariable
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
| H A D | softbus_adapter_standard.cpp | 355 std::string SoftBusAdapter::DelConnect(int32_t socket, bool isForce) in DelConnect()
385 std::string SoftBusAdapter::OnClientShutdown(int32_t socket, bool isForce) in OnClientShutdown()
483 void AppDataListenerWrap::OnClientShutdown(int32_t socket, ShutdownReason reason) in OnClientShutdown()
491 void AppDataListenerWrap::OnClientBytesReceived(int32_t socket, const void *data, uint32_t dataLen)… in OnClientBytesReceived()
493 void AppDataListenerWrap::OnClientSocketChanged(int32_t socket, QoSEvent eventId, const QosTV *qos,… in OnClientSocketChanged()
501 void AppDataListenerWrap::OnServerBind(int32_t socket, PeerSocketInfo info) in OnServerBind()
510 void AppDataListenerWrap::OnServerShutdown(int32_t socket, ShutdownReason reason) in OnServerShutdown()
516 void AppDataListenerWrap::OnServerBytesReceived(int32_t socket, const void *data, uint32_t dataLen) in OnServerBytesReceived()
551 bool SoftBusAdapter::GetPeerSocketInfo(int32_t socket, ServerSocketInfo &info) in GetPeerSocketInfo()
561 void SoftBusAdapter::OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/communicator/ |
| H A D | softbus_adapter_standard.cpp | 513 void SoftBusAdapter::OnClientShutdown(int32_t socket) in OnClientShutdown()
528 int socket = GetSocket(pipeInfo, peer); in IsSameStartedOnPeer() local
575 bool SoftBusAdapter::GetPeerSocketInfo(int32_t socket, PeerSocketInfo &info) in GetPeerSocketInfo()
585 void SoftBusAdapter::OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
590 void SoftBusAdapter::OnServerShutdown(int32_t socket) in OnServerShutdown()
600 void AppDataListenerWrap::OnClientShutdown(int32_t socket, ShutdownReason reason) in OnClientShutdown()
606 void AppDataListenerWrap::OnClientBytesReceived(int32_t socket, const void *data, uint32_t dataLen)… in OnClientBytesReceived()
608 void AppDataListenerWrap::OnServerBind(int32_t socket, PeerSocketInfo info) in OnServerBind()
615 void AppDataListenerWrap::OnServerShutdown(int32_t socket, ShutdownReason reason) in OnServerShutdown()
621 void AppDataListenerWrap::OnServerBytesReceived(int32_t socket, const void *data, uint32_t dataLen) in OnServerBytesReceived()
|