Home
last modified time | relevance | path

Searched refs:client_conn (Results 1 – 12 of 12) sorted by relevance

/third_party/glib/gio/tests/
Dgdbus-connection-flush.c165 GDBusConnection *client_conn; member
180 f->client_conn = g_dbus_connection_new_finish (res, &f->error); in setup_client_cb()
182 g_assert (G_IS_DBUS_CONNECTION (f->client_conn)); in setup_client_cb()
183 g_assert (f->client_conn == G_DBUS_CONNECTION (source)); in setup_client_cb()
235 while (f->client_conn == NULL || f->server_conn == NULL) in setup()
248 g_assert (G_IS_DBUS_CONNECTION (f->client_conn)); in flush_cb()
249 g_assert_cmpuint ((guintptr) f->client_conn, ==, (guintptr) G_DBUS_CONNECTION (source)); in flush_cb()
251 ok = g_dbus_connection_flush_finish (f->client_conn, res, &f->error); in flush_cb()
269 ok = g_dbus_connection_emit_signal (f->client_conn, NULL, "/", in test_flush_busy()
288 g_dbus_connection_flush (f->client_conn, NULL, flush_cb, f); in test_flush_busy()
[all …]
Dpollable.c337 GSocketConnection *client_conn = NULL, *server_conn = NULL; in test_pollable_socket() local
357 NULL, client_connected, &client_conn); in test_pollable_socket()
361 while (!client_conn || !server_conn) in test_pollable_socket()
364 in = G_POLLABLE_INPUT_STREAM (g_io_stream_get_input_stream (G_IO_STREAM (client_conn))); in test_pollable_socket()
369 g_object_unref (client_conn); in test_pollable_socket()
Dconverter-stream.c923 GSocketConnection *client_conn = NULL, *server_conn = NULL; in make_socketpair() local
943 NULL, client_connected, &client_conn); in make_socketpair()
947 while (!client_conn || !server_conn) in make_socketpair()
954 *left = G_IO_STREAM (client_conn); in make_socketpair()
/third_party/lwip/src/apps/lwiperf/
Dlwiperf.c391 lwiperf_state_tcp_t *client_conn; in lwiperf_tx_start_impl() local
400 client_conn = (lwiperf_state_tcp_t *)LWIPERF_ALLOC(lwiperf_state_tcp_t); in lwiperf_tx_start_impl()
401 if (client_conn == NULL) { in lwiperf_tx_start_impl()
406 LWIPERF_FREE(lwiperf_state_tcp_t, client_conn); in lwiperf_tx_start_impl()
409 memset(client_conn, 0, sizeof(lwiperf_state_tcp_t)); in lwiperf_tx_start_impl()
410 client_conn->base.tcp = 1; in lwiperf_tx_start_impl()
411 client_conn->base.related_master_state = related_master_state; in lwiperf_tx_start_impl()
412 client_conn->conn_pcb = newpcb; in lwiperf_tx_start_impl()
413 client_conn->time_started = sys_now(); /* @todo: set this again on 'connected' */ in lwiperf_tx_start_impl()
414 client_conn->report_fn = report_fn; in lwiperf_tx_start_impl()
[all …]
/third_party/libwebsockets/lib/abstract/transports/
Dunit-test.c141 if (s->ai->at->client_conn(s->ai)) { in unit_test_sequencer_cb()
532 .client_conn = NULL,
534 .client_conn = lws_atcut_client_conn,
Draw-skt.c400 .client_conn = NULL,
402 .client_conn = lws_atcrs_client_conn,
/third_party/libwebsockets/include/libwebsockets/abstract/
Dtransports.h42 int (*client_conn)(const lws_abs_t *abs); member
/third_party/gstreamer/gstplugins_base/tests/check/libs/
Drtspconnection.c111 create_connection (GSocketConnection ** client_conn, in create_connection() argument
133 *client_conn = g_socket_client_connect_to_host (client, (gchar *) "localhost", in create_connection()
135 fail_unless (*client_conn != NULL); in create_connection()
136 fail_unless (g_socket_connection_is_connected (*client_conn)); in create_connection()
/third_party/mindspore/mindspore/ccsrc/ps/core/communicator/
Dtcp_server.h93 void SetServerCallback(const OnConnected &client_conn, const OnDisconnected &client_disconn,
Dtcp_server.cc137 void TcpServer::SetServerCallback(const OnConnected &client_conn, const OnDisconnected &client_disc… in SetServerCallback() argument
139 this->client_connection_ = client_conn; in SetServerCallback()
/third_party/libwebsockets/lib/abstract/protocols/smtp/
Dsmtp-sequencer.c146 if (s->abs->at->client_conn(s->abs)) { in lws_smtpc_kick_internal()
/third_party/libwebsockets/lib/abstract/
DREADME.md83 |`client_conn()`|start a connection to a peer|