| /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/communication/dsoftbus/sdk/transmission/session/src/ |
| D | client_trans_socket_service.c | 99 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listene… in Listen()
105 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind()
114 void Shutdown(int32_t socket) in Shutdown()
131 int32_t GetMtuSize(int32_t socket, uint32_t *mtuSize) in GetMtuSize()
|
| /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
219 int32_t socket = Socket(info); in CreateClientSocket() local
[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/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()
|
| 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()
159 void Socket::impl::OnConnectedNative(Socket &socket, DataTransport *transport, uint16_t sendMTU, ui… in OnConnectedNative()
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()
[all …]
|
| /foundation/CastEngine/castengine_cast_plus_stream/src/channel/src/tcp/ |
| D | tcp_connection.cpp | 158 void TcpConnection::SetAudioConnection(int socket) in SetAudioConnection()
173 void TcpConnection::Receive(int socket) in Receive()
179 void TcpConnection::ReadLooper(int socket) in ReadLooper()
186 void TcpConnection::HandleReceivedData(int socket) in HandleReceivedData()
|
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/channel/src/tcp/ |
| D | tcp_connection.cpp | 158 void TcpConnection::SetAudioConnection(int socket) in SetAudioConnection()
173 void TcpConnection::Receive(int socket) in Receive()
179 void TcpConnection::ReadLooper(int socket) in ReadLooper()
186 void TcpConnection::HandleReceivedData(int socket) in HandleReceivedData()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
| D | softbus_adapter_standard.cpp | 298 std::string SoftBusAdapter::DelConnect(int32_t socket) in DelConnect()
316 std::string SoftBusAdapter::OnClientShutdown(int32_t socket) in OnClientShutdown()
406 void AppDataListenerWrap::OnClientShutdown(int32_t socket, ShutdownReason reason) in OnClientShutdown()
414 void AppDataListenerWrap::OnClientBytesReceived(int32_t socket, const void *data, uint32_t dataLen)… in OnClientBytesReceived()
416 void AppDataListenerWrap::OnServerBind(int32_t socket, PeerSocketInfo info) in OnServerBind()
425 void AppDataListenerWrap::OnServerShutdown(int32_t socket, ShutdownReason reason) in OnServerShutdown()
431 void AppDataListenerWrap::OnServerBytesReceived(int32_t socket, const void *data, uint32_t dataLen) in OnServerBytesReceived()
458 bool SoftBusAdapter::GetPeerSocketInfo(int32_t socket, ServerSocketInfo &info) in GetPeerSocketInfo()
468 void SoftBusAdapter::OnBind(int32_t socket, PeerSocketInfo info) in OnBind()
477 void SoftBusAdapter::OnServerShutdown(int32_t socket) in OnServerShutdown()
|
| D | softbus_client.cpp | 124 Status SoftBusClient::Open(int32_t socket, const QosTV qos[], const ISocketListener *listener) in Open()
174 std::pair<int32_t, uint32_t> SoftBusClient::GetMtu(int32_t socket) in GetMtu()
|
| /foundation/communication/bluetooth_service/services/bluetooth/server/src/ |
| 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
|
| /foundation/filemanagement/storage_service/services/storage_daemon/netlink/test/ |
| D | netlink_listener_mock.h | 25 explicit NetlinkListenerMock(int32_t socket) : NetlinkListener(socket) {} in NetlinkListenerMock()
|
| D | netlink_handler_test.cpp | 49 int32_t socket = -1; variable
71 int32_t socket = 0; variable
|
| D | netlink_listener_test.cpp | 49 int32_t socket = -1; variable
70 int32_t socket = 0; variable
|
| /foundation/communication/netmanager_base/services/netmanagernative/src/netsys/wrapper/ |
| D | data_receiver.cpp | 31 …listener_ = std::make_unique<WrapperListener>(socketFd, [this](int32_t socket) { this->StartReceiv… in DataReceiver()
49 void DataReceiver::StartReceive(int32_t socket) in StartReceive()
|
| D | wrapper_listener.cpp | 36 WrapperListener::WrapperListener(int32_t socket, std::function<void(int32_t)> recvFunc) in WrapperListener()
|
| /foundation/filemanagement/storage_service/services/storage_daemon/netlink/src/ |
| D | netlink_handler.cpp | 25 NetlinkHandler::NetlinkHandler(int32_t socket) : NetlinkListener(socket) {} in NetlinkHandler()
|
| D | netlink_listener.cpp | 34 ssize_t UeventKernelMulticastRecv(int32_t socket, char *buffer, size_t length) in UeventKernelMulticastRecv()
210 NetlinkListener::NetlinkListener(int32_t socket) in NetlinkListener()
|
| /foundation/communication/netmanager_base/test/netmanagernative/unittest/netsys_wrapper_test/ |
| D | wrapper_listener_test.cpp | 26 WrapperListener::RecvFunc g_func = [](int32_t socket) { std::cout << "Socket :" << socket << std::e… in __anon8aeac5600202()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/ |
| D | nstackx_dfile_send.c | 85 static int32_t TcpSendFileDataFrame(Socket *socket, PeerInfo *peerInfo, List *p, BlockFrame *block,… in TcpSendFileDataFrame()
133 Socket *socket = session->socket[0]; in SendFileDataFrame() local
321 Socket *socket = NULL; in SendControlFrame() local
409 Socket *socket = session->socket[0]; in TcpSocketRecv() local
|
| /foundation/CastEngine/castengine_wifi_display/services/network/session/ |
| D | tcp_session.cpp | 24 TcpSession::TcpSession(SocketInfo::Ptr socket) : BaseNetworkSession(socket) in TcpSession()
|
| D | udp_session.cpp | 26 UdpSession::UdpSession(SocketInfo::Ptr socket) : BaseNetworkSession(socket) in UdpSession()
|
| /foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/network/ |
| D | softbus_session_test.cpp | 99 int32_t socket = g_session->GetHandle(); variable
|