static unsigned int
noop_accept_cb(isc_nmhandle_t *handle, unsigned int result, void *cbarg) {
UNUSED(handle);
- UNUSED(result);
UNUSED(cbarg);
+ if (result == ISC_R_SUCCESS) {
+ (void)atomic_fetch_add(&saccepts, 1);
+ }
+
return (0);
}
stream_connect(connect_connect_cb, NULL, T_CONNECT);
WAIT_FOR_EQ(cconnects, 1);
- WAIT_FOR_EQ(csends, 1);
+ WAIT_FOR_EQ(saccepts, 1);
isc_nm_stoplistening(listen_sock);
isc_nmsocket_close(&listen_sock);
X(ssends);
atomic_assert_int_eq(cconnects, 1);
- atomic_assert_int_eq(csends, 1);
+ atomic_assert_int_eq(saccepts, 1);
atomic_assert_int_eq(creads, 0);
atomic_assert_int_eq(sreads, 0);
atomic_assert_int_eq(ssends, 0);
connect_connect_cb, NULL, T_CONNECT);
WAIT_FOR_EQ(cconnects, 1);
- WAIT_FOR_EQ(csends, 1);
+ WAIT_FOR_EQ(saccepts, 1);
isc_nm_stoplistening(listen_sock);
isc_nmsocket_close(&listen_sock);
X(ssends);
atomic_assert_int_eq(cconnects, 1);
- atomic_assert_int_eq(csends, 1);
+ atomic_assert_int_eq(saccepts, 1);
atomic_assert_int_eq(creads, 0);
atomic_assert_int_eq(sreads, 0);
atomic_assert_int_eq(ssends, 0);
tcp_connect_tlsctx, tcp_tlsctx_client_sess_cache);
WAIT_FOR_EQ(cconnects, 1);
- WAIT_FOR_EQ(csends, 1);
+ WAIT_FOR_EQ(saccepts, 1);
isc_nm_stoplistening(listen_sock);
isc_nmsocket_close(&listen_sock);
X(ssends);
atomic_assert_int_eq(cconnects, 1);
- atomic_assert_int_eq(csends, 1);
+ atomic_assert_int_eq(saccepts, 1);
atomic_assert_int_eq(creads, 0);
atomic_assert_int_eq(sreads, 0);
atomic_assert_int_eq(ssends, 0);
WAIT_FOR_EQ(saccepts, 1);
WAIT_FOR_EQ(cconnects, 1);
- WAIT_FOR_EQ(csends, 1);
isc_nm_stoplistening(listen_sock);
isc_nmsocket_close(&listen_sock);
atomic_assert_int_eq(saccepts, 1);
atomic_assert_int_eq(cconnects, 1);
- atomic_assert_int_eq(csends, 1);
atomic_assert_int_eq(creads, 0);
atomic_assert_int_eq(sreads, 0);
atomic_assert_int_eq(ssends, 0);