Searched refs:socket_ (Results 1 - 11 of 11) sorted by relevance
| /base/telephony/call_manager/services/distributed_call/src/transmission/ |
| H A D | client_session.cpp | 30 if (socket_ > INVALID_SOCKET_ID) { in Connect()
31 TELEPHONY_LOGI("client socket %{public}d already connect", socket_); in Connect()
50 if (socket_ > INVALID_SOCKET_ID) { in Disconnect()
51 Shutdown(socket_); in Disconnect()
52 TELEPHONY_LOGI("close client socket %{public}d success", socket_); in Disconnect()
54 socket_ = INVALID_SOCKET_ID; in Disconnect()
61 socket_ = socket; in OnSessionBind()
72 if (socket == socket_) { in OnSessionShutdown()
73 socket_ = INVALID_SOCKET_ID; in OnSessionShutdown()
|
| H A D | server_session.cpp | 75 socket_ = INVALID_SOCKET_ID; in Destroy()
82 if (socket_ > INVALID_SOCKET_ID) { in OnSessionBind()
83 TELEPHONY_LOGW("replace old socket %{public}d", socket_); in OnSessionBind()
85 socket_ = socket; in OnSessionBind()
98 socket_ = INVALID_SOCKET_ID; in OnSessionShutdown()
100 if (socket == socket_) { in OnSessionShutdown()
101 socket_ = INVALID_SOCKET_ID; in OnSessionShutdown()
|
| H A D | session_adapter.cpp | 38 return socket_ > INVALID_SOCKET_ID; in IsReady()
46 if (socket_ <= INVALID_SOCKET_ID) { in SendMsg()
47 TELEPHONY_LOGE("send msg fail, invalid socket %{public}d", socket_); in SendMsg()
50 socket = socket_; in SendMsg()
62 if (socket != socket_) { in OnReceiveMsg()
63 TELEPHONY_LOGW("socket %{public}d not match %{public}d", socket, socket_); in OnReceiveMsg()
|
| /base/telephony/call_manager/test/unittest/distributed_communication_test/src/ |
| H A D | distributed_transmission_test.cpp | 65 session->socket_ = 0; in HWTEST_F()
67 session->socket_ = INVALID_SOCKET_ID; in HWTEST_F()
72 EXPECT_EQ(session->socket_, INVALID_SOCKET_ID); in HWTEST_F()
86 session->socket_ = 0; in HWTEST_F()
88 session->socket_ = INVALID_SOCKET_ID; in HWTEST_F()
108 session->socket_ = 0; in HWTEST_F()
110 session->socket_ = INVALID_SOCKET_ID; in HWTEST_F()
113 session->socket_ = 0; in HWTEST_F()
128 session->socket_ = 0; in HWTEST_F()
|
| H A D | distributed_data_test.cpp | 128 controller->session_->socket_ = 0; in HWTEST_F()
|
| /base/msdp/device_status/intention/ipc/socket/src/ |
| H A D | socket_client.cpp | 61 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()
|
| /base/msdp/device_status/intention/adapters/dsoftbus_adapter/include/ |
| H A D | dsoftbus_adapter_impl.h | 58 Session(int32_t socket) : socket_(socket) {} in Session()
59 Session(const Session &other) : socket_(other.socket_) {} in Session()
64 int32_t socket_; member
|
| /base/msdp/device_status/intention/adapters/dsoftbus_adapter/src/ |
| H A D | dsoftbus_adapter_impl.cpp | 169 ::Shutdown(iter->second.socket_); in CloseSession()
171 FI_HILOGI("Shutdown session(%{public}d, %{public}s)", iter->second.socket_, in CloseSession()
187 return (iter != sessions_.end() ? iter->second.socket_ : -1); in FindConnection()
251 int32_t socket = elem.second.socket_; in BroadcastPacket()
269 return (iter != sessions_.end() && iter->second.socket_ != INVALID_SOCKET); in HasSessionExisted()
294 if (iter->second.socket_ == socket) { in OnBind()
295 FI_HILOGI("(%{public}d, %{public}s) has bound", iter->second.socket_, in OnBind()
299 FI_HILOGI("(%{public}d, %{public}s) need erase", iter->second.socket_, Utility::Anonymize(networkId).c_str()); in OnBind()
320 return (item.second.socket_ == socket); in OnShutdown()
346 return (item.second.socket_ in OnBytes()
[all...] |
| /base/msdp/device_status/intention/ipc/socket/include/ |
| H A D | socket_client.h | 55 std::shared_ptr<SocketConnection> socket_ { nullptr };
|
| /base/telephony/call_manager/services/distributed_call/include/transmission/ |
| H A D | session_adapter.h | 64 int32_t socket_{INVALID_SOCKET_ID};
|
| /base/msdp/device_status/test/unittest/intention/ipc/src/ |
| H A D | socket_session_test.cpp | 544 g_client->socket_->OnReadable(fd); in HWTEST_F()
546 g_client->socket_->OnReadable(fd); in HWTEST_F()
547 g_client->socket_->OnException(fd); in HWTEST_F()
|
Completed in 5 milliseconds