| /foundation/communication/dsoftbus/sdk/transmission/session/src/ |
| H A D | client_trans_socket_service.c | 120 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() argument
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/netmanager_base/services/netmanagernative/src/netsys/wrapper/ |
| H A D | wrapper_distributor.cpp | 31 WrapperDistributor::WrapperDistributor(int32_t socket, const int32_t format, std::mutex& externMutex) in WrapperDistributor() argument
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/moduletest/socket/stream_encrypt_test/ |
| H A D | stream_encrypt_client_mt.cpp | 54 void OnShutdownClient(int32_t socket, ShutdownReason reason) in OnShutdownClient() argument
88 static int32_t SendStreamExt(int32_t socket) in SendStreamExt() argument
120 int32_t socket = Socket(info); in HWTEST_F() local
174 int32_t socket = Socket(info); HWTEST_F() local
[all...] |
| H A D | tmessenger.cpp | 162 int32_t socket = Socket(info); in StartListen() local
207 int32_t socket = Socket(info); StartConnect() local
240 OnBind(int32_t socket, PeerSocketInfo info) OnBind() argument
245 OnMessage(int32_t socket, const void *data, uint32_t dataLen) OnMessage() argument
251 OnShutdown(int32_t socket, ShutdownReason reason) OnShutdown() argument
256 SetConnectSocket(int32_t socket, PeerSocketInfo info) SetConnectSocket() argument
306 CloseSocket(int32_t socket) CloseSocket() argument
[all...] |
| /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() argument
88 void DatabusSocketListener::ServerOnShutdown(int32_t socket, ShutdownReason reason) in ServerOnShutdown() argument
100 void DatabusSocketListener::ClientOnBind(int32_t socket, PeerSocketInfo info) in ClientOnBind() argument
105 void DatabusSocketListener::ClientOnShutdown(int32_t socket, ShutdownReason reason) in ClientOnShutdown() argument
131 OnBytesReceived(int32_t socket, const void *data, uint32_t dataLen) OnBytesReceived() argument
[all...] |
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/file/src/ |
| H A D | client_trans_file.c | 161 NotifySocketSendResult( int32_t socket, DFileMsgType msgType, const DFileMsg *msgData, const FileListener *listener) NotifySocketSendResult() argument
317 NotifySocketRecvResult( int32_t socket, DFileMsgType msgType, const DFileMsg *msgData, const FileListener *listener) NotifySocketRecvResult() argument
|
| /foundation/distributedhardware/distributed_camera/services/channel/src/ |
| H A D | dcamera_softbus_session.cpp | 85 int32_t DCameraSoftbusSession::OnSessionOpened(int32_t socket, std::string networkId) in OnSessionOpened() argument
|
| /foundation/distributedhardware/distributed_screen/services/softbusadapter/test/fuzztest/softbusadapter_fuzzer/ |
| H A D | softbusadapter_fuzzer.cpp | 224 extern "C" __attribute__((constructor)) int Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, in Listen() argument
230 extern "C" __attribute__((constructor)) int Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, in Bind() argument
236 extern "C" __attribute__((constructor)) void Shutdown(int32_t socket) {} in Shutdown() argument
238 extern "C" __attribute__((constructor)) int SendBytes(int32_t socket, const void *data, uint32_t len) in SendBytes() argument
243 extern "C" __attribute__((constructor)) int SendStream(int32_t socket, const StreamData *data, const StreamData *ext, in SendStream() argument
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/transport/ |
| H A D | dh_transport.cpp | 155 void OnBind(int32_t socket, PeerSocketInfo info) in OnBind() argument
165 void OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown() argument
175 void OnBytes(int32_t socket, const void *data, uint32_t dataLen) in OnBytes() argument
185 void OnMessage(int32_t socket, const void *data, uint32_t dataLen) in OnMessage() argument
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/distributedfiledaemon/src/network/softbus/ |
| H A D | softbus_asset_recv_listener.cpp | 38 void SoftbusAssetRecvListener::OnFile(int32_t socket, FileEvent *event) in OnFile() argument
|
| /foundation/communication/dhcp/test/unittest/services/dhcp_client/ |
| H A D | mock_system_func.cpp | 177 int __wrap_socketpair(int address, int type, int protocol, int *socket) in __wrap_socketpair() argument
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/ |
| H A D | nstackx_dfile_send.c | 85 static int32_t TcpSendFileDataFrame(Socket *socket, PeerInfo *peerInfo, List *p, BlockFrame *block, uint16_t len) in TcpSendFileDataFrame() argument
133 Socket *socket = session->socket[0]; in SendFileDataFrame() local
321 Socket *socket in SendControlFrame() local
409 Socket *socket = session->socket[0]; TcpSocketRecv() local
[all...] |
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/core/ |
| H A D | nstackx_socket.c | 29 void CloseSocket(Socket *socket) in CloseSocket() argument
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...] |
| /test/xts/dcts/communication/softbus_standard/socket_trans/server/ |
| H A D | SocketTestServer.cpp | 91 static void OnBind(int32_t socket, PeerSocketInfo info)
in OnBind() argument
97 static void OnShutdown(int32_t socket, ShutdownReason reason)
in OnShutdown() argument
102 static void OnByte(int32_t socket, const void* data, unsigned int dataLen)
in OnByte() argument
113 OnMessage(int32_t socket, const void* data, unsigned int dataLen) OnMessage() argument
124 OnStream(int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnStream() argument
154 OnFile(int32_t socket, FileEvent *event) OnFile() argument
188 OnQos(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCunt) OnQos() argument
[all...] |
| /third_party/curl/tests/ |
| H A D | negtelnetserver.py | 32 import socket namespace
|
| /third_party/ffmpeg/libavformat/ |
| H A D | os_support.c | 212 int ff_socket_nonblock(int socket, int enable) in ff_socket_nonblock() argument
|
| H A D | libamqp.c | 36 amqp_socket_t *socket; member
|
| /third_party/googletest/googletest/scripts/ |
| H A D | upload.py | 57 import socket namespace
|
| /third_party/NuttX/include/nuttx/net/ |
| H A D | net.h | 186 struct socket global() struct
[all...] |
| /third_party/libuv/src/win/ |
| H A D | poll.c | 415 uv_poll_init_socket(uv_loop_t* loop, uv_poll_t* handle, uv_os_sock_t socket) uv_poll_init_socket() argument
[all...] |
| H A D | winsock.c | 41 static BOOL uv__get_extension_function(SOCKET socket, GUID guid, in uv__get_extension_function() argument
65 BOOL uv__get_acceptex_function(SOCKET socket, LPFN_ACCEPTEX* target) { in uv__get_acceptex_function() argument
71 BOOL uv__get_connectex_function(SOCKET socket, LPFN_CONNECTEX* target) { in uv__get_connectex_function() argument
270 int WSAAPI uv__wsarecv_workaround(SOCKET socket, WSABUF* buffers, in uv__wsarecv_workaround() argument
364 uv__wsarecvfrom_workaround(SOCKET socket, WSABUF* buffers, DWORD buffer_count, DWORD* bytes, DWORD* flags, struct sockaddr* addr, int* addr_len, WSAOVERLAPPED *overlapped, LPWSAOVERLAPPED_COMPLETION_ROUTINE completion_routine) uv__wsarecvfrom_workaround() argument
461 uv__msafd_poll(SOCKET socket, AFD_POLL_INFO* info_in, AFD_POLL_INFO* info_out, OVERLAPPED* overlapped) uv__msafd_poll() argument
[all...] |
| /third_party/jerryscript/jerry-debugger/ |
| H A D | jerry_client.py | 21 import socket namespace
|
| /third_party/json/tools/serve_header/ |
| H A D | serve_header.py | 338 import socket namespace
[all...] |
| /third_party/ltp/lib/ |
| H A D | safe_net.c | 325 safe_bind(const char *file, const int lineno, void (cleanup_fn)(void), int socket, const struct sockaddr *address, socklen_t address_len) safe_bind() argument
367 safe_listen(const char *file, const int lineno, void (cleanup_fn)(void), int socket, int backlog) safe_listen() argument
[all...] |
| H A D | tst_rtnetlink.c | 19 int socket; member
[all...] |