Home
last modified time | relevance | path

Searched refs:socket_ (Results 1 – 25 of 29) sorted by relevance

12

/ohos5.0/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()
/ohos5.0/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()
138 close(socket_); in CreateRASocket()
151 if (socket_ > 0) { in CloseRaSocket()
152 close(socket_); in CloseRaSocket()
154 socket_ = -1; in CloseRaSocket()
[all …]
/ohos5.0/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()
169 socket_ = socket; in Open()
174 KvStoreUtils::ToBeAnonymous(device_.deviceId).c_str(), pipe_.pipeId.c_str(), socket_); in Open()
[all …]
H A Dsoftbus_client.h86 int32_t socket_ = INVALID_SOCKET_ID; variable
H A Dsoftbus_adapter_standard.cpp412 socket_ = Socket(socketInfo); in CreateSessionServerAdapter()
413 return Listen(socket_, Qos, QOS_COUNT, &serverListener_); in CreateSessionServerAdapter()
419 Shutdown(socket_); in RemoveSessionServerAdapter()
/ohos5.0/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_, nullptr, nullptr, SOCK_CLOEXEC); in AcceptClient()
H A Drs_profiler_socket.h53 int32_t socket_ = -1;
/ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/moduletest/socket/stream_encrypt_test/
H A Dtmessenger.cpp136 if (socket_ > 0) { in Close()
137 Shutdown(socket_); in Close()
138 socket_ = -1; in Close()
195 if (socket_ > 0) { in StartConnect()
237 socket_ = socket; in StartConnect()
259 if (socket_ > 0) { in SetConnectSocket()
263 socket_ = socket; in SetConnectSocket()
309 if (socket_ == socket) { in CloseSocket()
310 Shutdown(socket_); in CloseSocket()
311 socket_ = -1; in CloseSocket()
[all …]
/ohos5.0/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()
/ohos5.0/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()
/ohos5.0/base/msdp/device_status/intention/ipc/socket/src/
H A Dsocket_client.cpp61 if (socket_ != nullptr) { in Connect()
76 socket_ = socket; in Connect()
113 if (socket_ != nullptr) { in OnDisconnected()
114 eventHandler_->RemoveFileDescriptorListener(socket_->GetFd()); in OnDisconnected()
116 socket_.reset(); in OnDisconnected()
/ohos5.0/base/msdp/device_status/intention/adapters/dsoftbus_adapter/src/
H A Ddsoftbus_adapter_impl.cpp158 ::Shutdown(iter->second.socket_); in CloseSession()
160 FI_HILOGI("Shutdown session(%{public}d, %{public}s)", iter->second.socket_, in CloseSession()
176 return (iter != sessions_.end() ? iter->second.socket_ : -1); in FindConnection()
240 int32_t socket = elem.second.socket_; in BroadcastPacket()
258 return (iter != sessions_.end() && iter->second.socket_ != INVALID_SOCKET); in HasSessionExisted()
283 if (iter->second.socket_ == socket) { in OnBind()
284 FI_HILOGI("(%{public}d, %{public}s) has bound", iter->second.socket_, in OnBind()
288 …FI_HILOGI("(%{public}d, %{public}s) need erase", iter->second.socket_, Utility::Anonymize(networkI… in OnBind()
309 return (item.second.socket_ == socket); in OnShutdown()
335 return (item.second.socket_ == socket); in OnBytes()
[all …]
/ohos5.0/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
/ohos5.0/base/msdp/device_status/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
/ohos5.0/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(networkI… 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()
/ohos5.0/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)); in OnConnectIncoming()
78 … socketService->GetDispatcher()->PostTask(std::bind(&impl::OnConnectedNative, socket_.pimpl.get(), in OnConnected()
79 … std::ref(socket_), transport, sendMTU, recvMTU)); in OnConnected()
91 … std::bind(&impl::OnDisconnectedNative, socket_.pimpl.get(), std::ref(socket_), transport)); in OnDisconnected()
103 … std::bind(&impl::OnDisconnectSuccessNative, socket_.pimpl.get(), std::ref(socket_), transport)); in OnDisconnectSuccess()
115 … std::bind(&impl::OnDataAvailableNative, socket_.pimpl.get(), std::ref(socket_), transport)); in OnDataAvailable()
132 …std::bind(&impl::OnTransportErrorNative, socket_.pimpl.get(), std::ref(socket_), transport, errTyp… in OnTransportError()
136 DataTransportObserverImplement(Socket &socket) : socket_(socket) in DataTransportObserverImplement()
142 Socket &socket_; member in OHOS::bluetooth::Socket::impl::DataTransportObserverImplement
/ohos5.0/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_profiler/unittest/
H A Drs_profiler_socket_test.cpp58 EXPECT_EQ(s.socket_, -1);
73 EXPECT_EQ(s.socket_, -1);
/ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/include/netsys/wrapper/
H A Dwrapper_listener.h48 int32_t socket_; variable
H A Ddata_receiver.h57 int32_t socket_; variable
/ohos5.0/foundation/multimodalinput/input/intention/ipc/socket/include/
H A Dsocket_client.h52 std::shared_ptr<SocketConnection> socket_ { nullptr };
/ohos5.0/base/msdp/device_status/intention/ipc/socket/include/
H A Dsocket_client.h55 std::shared_ptr<SocketConnection> socket_ { nullptr };
/ohos5.0/foundation/communication/ipc/ipc/native/src/core/include/
H A Ddbinder_session_object.h76 int32_t socket_ = SOCKET_ID_INVALID; variable
/ohos5.0/base/msdp/device_status/test/unittest/intention/ipc/src/
H A Dsocket_session_test.cpp544 g_client->socket_->OnReadable(fd);
546 g_client->socket_->OnReadable(fd);
547 g_client->socket_->OnException(fd);
/ohos5.0/foundation/communication/netmanager_ext/services/networksharemanager/include/
H A Drouter_advertisement_daemon.h146 int socket_ = -1; variable

12