Home
last modified time | relevance | path

Searched refs:socket_ (Results 1 - 25 of 44) sorted by relevance

12

/foundation/CastEngine/castengine_wifi_display/services/network/client/
H A Dtcp_client.cpp42 socket_ = std::make_unique<TcpSocket>(); in Connect()
43 if (socket_) { in Connect()
44 if (socket_->Connect(peerIp, peerPort, retCode, true, true, localIp, localPort)) { in Connect()
56 ret = eventListener_->AddFdListener(socket_->GetLocalFd(), eventListener_, eventHandler_); in Connect()
62 callback->OnClientWriteable(socket_->GetLocalFd()); in Connect()
69 eventListener_->RemoveFdListener(socket_->GetLocalFd()); in Connect()
73 SocketUtils::ShutDownSocket(socket_->GetLocalFd()); in Connect()
74 SocketUtils::CloseSocket(socket_->GetLocalFd()); in Connect()
75 socket_.reset(); in Connect()
91 if (socket_ ! in Disconnect()
[all...]
H A Dudp_client.cpp43 socket_ = std::make_unique<UdpSocket>(); in Connect()
44 if (socket_) { in Connect()
45 if (socket_->Connect(peerHost, peerPort, retCode, false, true, localIp, localPort)) { in Connect()
56 bool ret = eventListener_->AddFdListener(socket_->GetLocalFd(), eventListener_, eventHandler_); in Connect()
78 if (socket_ != nullptr) { in Disconnect()
79 eventListener_->RemoveFdListener(socket_->GetLocalFd()); in Disconnect()
80 SocketUtils::ShutDownSocket(socket_->GetLocalFd()); in Disconnect()
81 SocketUtils::CloseSocket(socket_->GetLocalFd()); in Disconnect()
82 socket_.reset(); in Disconnect()
97 if (socket_ ! in Send()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/network/session/
H A Dudp_session.cpp39 if (socket_) { in Start()
51 return eventListener_->AddFdListener(socket_->GetPeerFd(), eventListener_, eventHandler_); in Start()
60 if (socket_) { in Shutdown()
62 eventListener_->RemoveFdListener(socket_->GetPeerFd()); in Shutdown()
64 SocketUtils::ShutDownSocket(socket_->GetPeerFd()); in Shutdown()
65 SocketUtils::CloseSocket(socket_->GetPeerFd()); in Shutdown()
66 socket_.reset(); in Shutdown()
79 if (socket_ == nullptr) { in Send()
83 MEDIA_LOGD("fd: %{public}d, address: %{public}s, port: %{public}d, len: %{public}d.", socket_->GetLocalFd(), in Send()
84 GetAnonyString(inet_ntoa(socket_ in Send()
[all...]
H A Dtcp_session.cpp38 if (socket_) { in Start()
49 return eventListener_->AddFdListener(socket_->GetPeerFd(), eventListener_, eventHandler_); in Start()
66 if (socket_) { in Send()
67 int32_t ret = SocketUtils::SendSocket(socket_->GetPeerFd(), buf, nSize); in Send()
73 callback_->OnSessionClose(socket_->GetPeerFd()); in Send()
86 if (socket_) { in Shutdown()
88 eventListener_->RemoveFdListener(socket_->GetPeerFd()); in Shutdown()
90 SocketUtils::ShutDownSocket(socket_->GetPeerFd()); in Shutdown()
91 SocketUtils::CloseSocket(socket_->GetPeerFd()); in Shutdown()
92 socket_ in Shutdown()
[all...]
H A Dbase_network_session.cpp22 BaseNetworkSession::BaseNetworkSession(SocketInfo::Ptr socket) : socket_(std::move(socket)) in BaseNetworkSession()
47 return socket_; in GetSocketInfo()
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/channel/src/tcp/
H A Dtcp_socket.cpp31 socket_ = ::socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); in TcpSocket()
32 if (socket_ < RET_OK) { in TcpSocket()
58 if (::bind(socket_, reinterpret_cast<struct sockaddr *>(&sockaddr), sizeof(sockaddr)) < RET_OK) { in Bind()
71 if (socket_ == INVALID_SOCKET) { in GetBindPort()
72 CLOGE("Socket getBindPort error: socket_ is invalid"); in GetBindPort()
77 if (getsockname(socket_, reinterpret_cast<struct sockaddr *>(&sockaddr), &addrLen) < RET_OK) { in GetBindPort()
101 return socket_; in GetSocketFd()
106 if (::listen(socket_, backlog) < RET_OK) { in Listen()
120 if (::connect(socket_, reinterpret_cast<struct sockaddr *>(&sockaddr), sizeof(sockaddr)) < RET_OK) { in Connect()
130 int connfd = ::accept(socket_, nullpt in Accept()
[all...]
H A Dtcp_connection.cpp59 int port = socket_.Bind(channelRequest_.localDeviceInfo.ipAddress, channelRequest_.localPort); in Connect()
62 bool ret = socket_.Connect(channelRequest_.remoteDeviceInfo.ipAddress, channelRequest_.remotePort); in Connect()
82 int port = socket_.Bind(request.localDeviceInfo.ipAddress, request.localPort); in StartListen()
84 socket_.Listen(SOMAXCONN); in StartListen()
95 socket_.SetSendBufferSize(SOCKET_SEND_BUFFER_SIZE); in ConfigSocket()
96 socket_.SetRecvBufferSize(SOCKET_RECV_BUFFER_SIZE); in ConfigSocket()
97 socket_.SetKeepAlive(); in ConfigSocket()
98 socket_.SetReuseAddr(); in ConfigSocket()
119 int sockfd = socket_.Accept(); in Accept()
126 int remotePort = socket_ in Accept()
[all...]
/foundation/CastEngine/castengine_cast_plus_stream/src/channel/src/tcp/
H A Dtcp_socket.cpp31 socket_ = ::socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); in TcpSocket()
32 if (socket_ < RET_OK) { in TcpSocket()
58 if (::bind(socket_, reinterpret_cast<struct sockaddr *>(&sockaddr), sizeof(sockaddr)) < RET_OK) { in Bind()
71 if (socket_ == INVALID_SOCKET) { in GetBindPort()
72 CLOGE("Socket getBindPort error: socket_ is invalid"); in GetBindPort()
77 if (getsockname(socket_, reinterpret_cast<struct sockaddr *>(&sockaddr), &addrLen) < RET_OK) { in GetBindPort()
101 return socket_; in GetSocketFd()
106 if (::listen(socket_, backlog) < RET_OK) { in Listen()
120 if (::connect(socket_, reinterpret_cast<struct sockaddr *>(&sockaddr), sizeof(sockaddr)) < RET_OK) { in Connect()
130 int connfd = ::accept(socket_, nullpt in Accept()
[all...]
H A Dtcp_connection.cpp59 int port = socket_.Bind(channelRequest_.localDeviceInfo.ipAddress, channelRequest_.localPort); in Connect()
62 bool ret = socket_.Connect(channelRequest_.remoteDeviceInfo.ipAddress, channelRequest_.remotePort); in Connect()
82 int port = socket_.Bind(request.localDeviceInfo.ipAddress, request.localPort); in StartListen()
84 socket_.Listen(SOMAXCONN); in StartListen()
95 socket_.SetSendBufferSize(SOCKET_SEND_BUFFER_SIZE); in ConfigSocket()
96 socket_.SetRecvBufferSize(SOCKET_RECV_BUFFER_SIZE); in ConfigSocket()
97 socket_.SetKeepAlive(); in ConfigSocket()
98 socket_.SetReuseAddr(); in ConfigSocket()
119 int sockfd = socket_.Accept(); in Accept()
126 int remotePort = socket_ in Accept()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/network/server/
H A Dtcp_server.cpp40 socket_ = std::make_unique<TcpSocket>(); in Start()
41 if (socket_) { in Start()
42 if (socket_->Bind(port, host, enableReuse, backlog)) { in Start()
43 SHARING_LOGD("start success fd: %{public}d.", socket_->GetLocalFd()); in Start()
44 socketLocalFd_ = socket_->GetLocalFd(); in Start()
55 return eventListener_->AddFdListener(socket_->GetLocalFd(), eventListener_, eventHandler_); in Start()
67 if (socket_ != nullptr) { in Stop()
69 eventListener_->RemoveFdListener(socket_->GetLocalFd()); in Stop()
71 SocketUtils::ShutDownSocket(socket_->GetLocalFd()); in Stop()
72 SocketUtils::CloseSocket(socket_ in Stop()
[all...]
H A Dudp_server.cpp34 socket_ = std::make_unique<UdpSocket>(); in Start()
35 if (socket_) { in Start()
36 if (socket_->Bind(port, host, enableReuse)) { in Start()
37 SHARING_LOGD("start success, fd: %{public}d.", socket_->GetLocalFd()); in Start()
48 return eventListener_->AddFdListener(socket_->GetLocalFd(), eventListener_, eventHandler_); in Start()
80 if (socket_ != nullptr) { in Stop()
82 eventListener_->RemoveFdListener(socket_->GetLocalFd()); in Stop()
84 SocketUtils::ShutDownSocket(socket_->GetLocalFd()); in Stop()
85 SocketUtils::CloseSocket(socket_->GetLocalFd()); in Stop()
86 socket_ in Stop()
[all...]
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/wrapper/
H A Dwrapper_listener.cpp40 socket_ = socket; in WrapperListener()
51 if (socket_ < 0) { in Start()
52 NETNATIVE_LOGE("listener socket_ < 0 %{public}d", socket_); in Start()
81 if (socket_ > -1) { in Stop()
82 close(socket_); in Stop()
107 polfd.fd = socket_; in Listen()
110 ffrt::sync_io(socket_); in Listen()
124 startReceiveFunc_(socket_); in Listen()
H A Ddata_receiver.cpp29 DataReceiver::DataReceiver(int32_t socketFd, int32_t format) : socket_(socketFd), format_(format) in DataReceiver()
51 socket_ = socket; in StartReceive()
85 ssize_t count = TEMP_FAILURE_RETRY(recvmsg(socket_, &hdr, 0)); in ReceiveMessage()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/
H A Dsoftbus_client.cpp39 ZLOGI("Shutdown socket:%{public}d", socket_); in ~SoftBusClient()
40 if (socket_ > 0) { in ~SoftBusClient()
41 Shutdown(socket_); in ~SoftBusClient()
47 return socket_ == socket; in operator ==()
57 ZLOGD("get mtu size socket:%{public}d mtu:%{public}d", socket_, mtu_); in GetMtuSize()
73 ZLOGD("send data socket:%{public}d, data size:%{public}u.", socket_, dataInfo.length); in SendData()
74 int32_t ret = SendBytes(socket_, dataInfo.data, dataInfo.length); in SendData()
77 ZLOGE("send data to socket%{public}d failed, ret:%{public}d.", socket_, ret); in SendData()
157 ZLOGE("GetMtu failed, session:%{public}s, socket:%{public}d", pipe_.pipeId.c_str(), socket_); in Open()
162 socket_ in Open()
[all...]
/foundation/communication/netmanager_ext/services/networksharemanager/src/
H A Drouter_advertisement_daemon.cpp65 return socket_ > 0; in IsSocketValid()
118 socket_ = socket(AF_INET6, SOCK_RAW, IPPROTO_ICMPV6); in CreateRASocket()
119 if (socket_ < 0) { in CreateRASocket()
125 if (setsockopt(socket_, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout)) < 0) { in CreateRASocket()
127 close(socket_); in CreateRASocket()
133 close(socket_); in CreateRASocket()
136 if (setsockopt(socket_, SOL_SOCKET, SO_BINDTODEVICE, (void *)&ifr, sizeof(ifr)) < 0) { in CreateRASocket()
138 close(socket_); in CreateRASocket()
142 if (setsockopt(socket_, IPPROTO_IPV6, IPV6_UNICAST_HOPS, (void *)&hoplimitNew, sizeof(hoplimitNew)) == -1) { in CreateRASocket()
151 if (socket_ > in CloseRaSocket()
[all...]
/foundation/graphic/graphic_2d/rosen/modules/render_service_profiler/
H A Drs_profiler_socket.cpp104 shutdown(socket_, SHUT_RDWR); in Shutdown()
105 close(socket_); in Shutdown()
106 socket_ = -1; in Shutdown()
117 socket_ = socket(AF_UNIX, SOCK_STREAM | SOCK_CLOEXEC, 0); in Open()
118 if (socket_ == -1) { in Open()
130 if (bind(socket_, reinterpret_cast<sockaddr*>(&address), addressSize) == -1) { in Open()
136 if (listen(socket_, maxConnections) != 0) { in Open()
141 SetBlocking(socket_, false); in Open()
142 SetCloseOnExec(socket_, true); in Open()
149 client_ = accept4(socket_, nullpt in AcceptClient()
[all...]
/foundation/multimodalinput/input/intention/ipc/socket/src/
H A Dsocket_client.cpp61 if (socket_ != nullptr) { in Connect()
76 socket_ = socket; in Connect()
109 if (socket_ != nullptr) { in OnDisconnected()
110 eventHandler_->RemoveFileDescriptorListener(socket_->GetFd()); in OnDisconnected()
112 socket_.reset(); in OnDisconnected()
/foundation/communication/ipc/ipc/native/src/core/source/
H A Ddbinder_session_object.cpp45 IPCProcessSkeleton::ConvertToSecureString(GetDeviceId()).c_str(), socket_); in CloseDatabusSession()
46 listener->ShutdownSocket(socket_); in CloseDatabusSession()
47 socket_ = SOCKET_ID_INVALID; in CloseDatabusSession()
107 return socket_; in GetSocketId()
112 socket_ = socketId; in SetSocketId()
/foundation/communication/dsoftbus/tests/sdk/transmission/moduletest/socket/stream_encrypt_test/
H A Dtmessenger.cpp135 if (socket_ > 0) { in Close()
136 Shutdown(socket_); in Close()
137 socket_ = -1; in Close()
194 if (socket_ > 0) { in StartConnect()
236 socket_ = socket; in StartConnect()
258 if (socket_ > 0) { in SetConnectSocket()
262 socket_ = socket; in SetConnectSocket()
308 if (socket_ == socket) { in CloseSocket()
309 Shutdown(socket_); in CloseSocket()
310 socket_ in CloseSocket()
[all...]
/foundation/multimodalinput/input/intention/adapters/dsoftbus_adapter/include/
H A Ddsoftbus_adapter_impl.h57 Session(int32_t socket) : socket_(socket) {} in Session()
58 Session(const Session &other) : socket_(other.socket_) {} in Session()
63 int32_t socket_; member
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_profiler/unittest/
H A Drs_profiler_socket_test.cpp58 EXPECT_EQ(s.socket_, -1); in HWTEST_F()
73 EXPECT_EQ(s.socket_, -1); in HWTEST_F()
/foundation/multimodalinput/input/intention/adapters/dsoftbus_adapter/src/
H A Ddsoftbus_adapter_impl.cpp163 ::Shutdown(iter->second.socket_); in CloseSession()
165 FI_HILOGI("Shutdown session(%{public}d, %{public}s)", iter->second.socket_, in CloseSession()
181 return (iter != sessions_.end() ? iter->second.socket_ : -1); in FindConnection()
245 int32_t socket = elem.second.socket_; in BroadcastPacket()
281 if (iter->second.socket_ == socket) { in OnBind()
282 FI_HILOGI("(%{public}d, %{public}s) has bound", iter->second.socket_, in OnBind()
286 FI_HILOGI("(%{public}d, %{public}s) need erase", iter->second.socket_, Utility::Anonymize(networkId).c_str()); in OnBind()
307 return (item.second.socket_ == socket); in OnShutdown()
333 return (item.second.socket_ == socket); in OnBytes()
484 ::Shutdown(item.second.socket_); in CloseAllSessionsLocked()
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/
H A Dsocket.cpp62 std::bind(&impl::OnConnectIncomingNative, socket_.pimpl.get(), std::ref(socket_), addr, port));
78 socketService->GetDispatcher()->PostTask(std::bind(&impl::OnConnectedNative, socket_.pimpl.get(),
79 std::ref(socket_), transport, sendMTU, recvMTU));
91 std::bind(&impl::OnDisconnectedNative, socket_.pimpl.get(), std::ref(socket_), transport));
103 std::bind(&impl::OnDisconnectSuccessNative, socket_.pimpl.get(), std::ref(socket_), transport));
115 std::bind(&impl::OnDataAvailableNative, socket_.pimpl.get(), std::ref(socket_), transpor
142 Socket &socket_; global() member in OHOS::bluetooth::Socket::impl::DataTransportObserverImplement
[all...]
/foundation/communication/netmanager_base/services/netmanagernative/include/netsys/wrapper/
H A Ddata_receiver.h57 int32_t socket_; member in OHOS::nmd::DataReceiver
H A Dwrapper_listener.h48 int32_t socket_; member in OHOS::nmd::WrapperListener

Completed in 10 milliseconds

12