| /foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/ |
| H A D | trans_tcp_direct_listener_test.cpp | 138 int32_t cfd = NORMAL_FD; in HWTEST_F() local
140 int32_t ret = TdcOnConnectEvent(module, cfd, clientAddr); in HWTEST_F()
146 * @tc.desc: TdcOnConnectEvent test, use invalid cfd.
157 int32_t cfd = INVALID_FD; in HWTEST_F() local
159 int32_t ret = TdcOnConnectEvent(module, cfd, clientAddr); in HWTEST_F()
|
| /foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/ |
| H A D | trans_tcp_direct_listener.c | 207 static int32_t TdcOnConnectEvent(ListenerModule module, int cfd, const ConnectOption *clientAddr) in TdcOnConnectEvent() argument
209 if (cfd < 0 || clientAddr == NULL) { in TdcOnConnectEvent()
210 TRANS_LOGW(TRANS_CTRL, "invalid param, cfd=%{public}d", cfd); in TdcOnConnectEvent()
214 int32_t ret = TransSrvAddDataBufNode(channelId, cfd); // fd != channelId in TdcOnConnectEvent()
220 .socketFd = cfd, in TdcOnConnectEvent()
228 ConnShutdownSocket(cfd); in TdcOnConnectEvent()
231 ret = CreateSessionConnNode(module, cfd, channelId, clientAddr); in TdcOnConnectEvent()
238 ConnShutdownSocket(cfd); in TdcOnConnectEvent()
244 "tdc conn event cfd in TdcOnConnectEvent()
[all...] |
| /foundation/communication/dsoftbus/core/authentication/src/ |
| H A D | auth_tcp_connection.c | 65 int32_t __attribute__((weak)) RouteBuildServerAuthManager(int32_t cfd, const ConnectOption *clientAddr) in RouteBuildServerAuthManager() argument
67 (void)cfd; in RouteBuildServerAuthManager()
268 static int32_t OnConnectEvent(ListenerModule module, int32_t cfd, const ConnectOption *clientAddr) in OnConnectEvent() argument
270 if (cfd < 0) { in OnConnectEvent()
274 if (ConnSetTcpKeepalive(cfd, (int32_t)DEFAULT_FREQ_CYCLE, TCP_KEEPALIVE_INTERVAL, TCP_KEEPALIVE_DEFAULT_COUNT) != in OnConnectEvent()
277 ConnShutdownSocket(cfd); in OnConnectEvent()
282 if (SoftBusSocketSetOpt(cfd, SOFTBUS_IPPROTO_IP_, SOFTBUS_IP_TOS_, &ipTos, sizeof(ipTos)) != in OnConnectEvent()
285 ConnShutdownSocket(cfd); in OnConnectEvent()
289 if (AddTrigger(module, cfd, READ_TRIGGER) != SOFTBUS_OK) { in OnConnectEvent()
291 ConnShutdownSocket(cfd); in OnConnectEvent()
[all...] |
| H A D | auth_connection.c | 56 void __attribute__((weak)) RouteBuildClientAuthManager(int32_t cfd) in RouteBuildClientAuthManager() argument
58 (void)cfd; in RouteBuildClientAuthManager()
60 void __attribute__((weak)) RouteClearAuthChannelId(int32_t cfd) in RouteClearAuthChannelId() argument
62 (void)cfd; in RouteClearAuthChannelId()
|
| /foundation/communication/dsoftbus/core/connection/tcp/src/ |
| H A D | softbus_tcp_connect_manager.c | 71 static int32_t TcpOnConnectEvent(ListenerModule module, int32_t cfd, const ConnectOption *clientAddr);
216 static int32_t TcpOnConnectEvent(ListenerModule module, int32_t cfd, const ConnectOption *clientAddr) in TcpOnConnectEvent() argument
218 if (cfd < 0 || clientAddr == NULL) { in TcpOnConnectEvent()
219 CONN_LOGE(CONN_COMMON, "cfd is invalid or clientAddr is null. cfd=%{public}d", cfd); in TcpOnConnectEvent()
224 CONN_LOGI(CONN_COMMON, "recv p2p conned. cfd=%{public}d", cfd); in TcpOnConnectEvent()
226 cfd, AUTH_P2P_KEEP_ALIVE_TIME, AUTH_P2P_KEEP_ALIVE_INTERVAL, AUTH_P2P_KEEP_ALIVE_COUNT) != SOFTBUS_OK) { in TcpOnConnectEvent()
228 ConnShutdownSocket(cfd); in TcpOnConnectEvent()
[all...] |
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/tcp_direct/src/ |
| H A D | client_trans_tcp_direct_listener.c | 59 static int32_t ClientTdcOnConnectEvent(ListenerModule module, int cfd, in ClientTdcOnConnectEvent() argument
63 (void)cfd; in ClientTdcOnConnectEvent()
|
| /foundation/communication/dsoftbus/tests/core/authentication/unittest/ |
| H A D | auth_net_ledger_mock.cpp | 163 void RouteBuildClientAuthManager(int32_t cfd) in RouteBuildClientAuthManager() argument
165 return GetNetLedgerInterface()->RouteBuildClientAuthManager(cfd); in RouteBuildClientAuthManager()
168 void RouteClearAuthChannelId(int32_t cfd) in RouteClearAuthChannelId() argument
170 return GetNetLedgerInterface()->RouteClearAuthChannelId(cfd); in RouteClearAuthChannelId()
|
| H A D | auth_tcp_connection_test.cpp | 179 int32_t cfd = -1; in HWTEST_F() local
182 int32_t ret = OnConnectEvent(module, cfd, &clientAddr); in HWTEST_F()
184 cfd = 0; in HWTEST_F()
185 ret = OnConnectEvent(module, cfd, &clientAddr); in HWTEST_F()
|
| H A D | auth_net_ledger_mock.h | 61 virtual void RouteBuildClientAuthManager(int32_t cfd) = 0;
62 virtual void RouteClearAuthChannelId(int32_t cfd) = 0;
|
| H A D | auth_test.cpp | 2073 int32_t cfd = 0; in HWTEST_F() local
2076 int32_t ret = OnConnectEvent(module, cfd, &option); in HWTEST_F()
|
| /foundation/communication/dsoftbus/core/connection/interface/ |
| H A D | softbus_base_listener.h | 45 int32_t (*onConnectEvent)(ListenerModule module, int32_t cfd, const ConnectOption *clientAddr);
|
| H A D | softbus_socket.h | 63 int32_t (*AcceptClient)(int32_t fd, ConnectOption *clientAddr, int32_t *cfd);
|
| /foundation/communication/dsoftbus/tests/core/common/dfx/event/unittest/src/ |
| H A D | conn_event_test.cpp | 80 .cfd = 21,
140 .cfd = -21,
|
| /foundation/communication/dsoftbus/core/connection/common/src/ |
| H A D | softbus_tcp_socket.c | 407 static int32_t AcceptTcpClient(int32_t fd, ConnectOption *clientAddr, int32_t *cfd) in AcceptTcpClient() argument
413 int32_t ret = SOFTBUS_TEMP_FAILURE_RETRY(SoftBusSocketAccept(fd, &addr, cfd)); in AcceptTcpClient()
415 CONN_LOGE(CONN_COMMON, "accept failed, ret=%{public}" PRId32 ", cfd=%{public}d, fd=%{public}d", ret, *cfd, fd); in AcceptTcpClient()
420 clientAddr->socketOption.port = GetTcpSockPort(*cfd); in AcceptTcpClient()
|
| /foundation/communication/dsoftbus/adapter/common/bus_center/network/ |
| H A D | lnn_netlink_monitor.c | 190 static int32_t NetlinkOnConnectEvent(ListenerModule module, int32_t cfd, const ConnectOption *clientAddr) in NetlinkOnConnectEvent() argument
193 (void)cfd; in NetlinkOnConnectEvent()
|
| /foundation/communication/dsoftbus/tests/core/connection/common/fuzztest/connectioncommon_fuzzer/ |
| H A D | connectioncommon_fuzzer.cpp | 54 static int32_t ConnectEvent(ListenerModule module, int32_t cfd, const ConnectOption *clientAddr) in ConnectEvent() argument
|
| /foundation/communication/dsoftbus/adapter/common/kernel/posix/ |
| H A D | softbus_adapter_socket.c | 79 static void DfxReportAdapterSocket(ConnEventScene scene, int32_t res, int32_t fd, int32_t cfd) in DfxReportAdapterSocket() argument
83 .cfd = cfd, in DfxReportAdapterSocket()
|
| /foundation/communication/dsoftbus/core/common/dfx/interface/include/form/ |
| H A D | conn_event_form.h | 88 int32_t cfd; // CFD member
|
| /foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/lane_manager/src/ |
| H A D | lnn_lane_reliability.c | 222 static int32_t LaneDetectOnConnectEvent(ListenerModule module, int32_t cfd, const ConnectOption *clientAddr) in LaneDetectOnConnectEvent() argument
225 (void)cfd; in LaneDetectOnConnectEvent()
|
| /foundation/communication/dsoftbus/core/common/dfx/event/src/convert/ |
| H A D | conn_event_converter.h | 58 CONN_ASSIGNER(Int32, Cfd, cfd)
|
| /foundation/communication/dsoftbus/tests/core/common/dfx/event/unittest/mock/ |
| H A D | conn_hisysevent_matcher.h | 93 MatchConnEventNameTypeExtraInt32Param(params, ++index, extra.cfd); in MATCHER_P2()
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/tcp_direct/ |
| H A D | trans_tcp_direct_test.cpp | 786 int32_t cfd = 0; in HWTEST_F() local
787 int32_t ret = ClientTdcOnConnectEvent(DIRECT_CHANNEL_SERVER_WIFI, cfd, nullptr); in HWTEST_F()
|
| /foundation/communication/dsoftbus/tests/core/connection/common/unittest/ |
| H A D | softbus_conn_common_test.cpp | 81 int32_t ConnectEvent(ListenerModule module, int32_t cfd, const ConnectOption *clientAddr) in ConnectEvent() argument
|