| /third_party/skia/third_party/externals/microhttpd/src/microhttpd/ |
| D | connection.c | 128 MHD_get_connection_values (struct MHD_Connection *connection, in MHD_get_connection_values() argument
135 if (NULL == connection) in MHD_get_connection_values()
138 for (pos = connection->headers_received; NULL != pos; pos = pos->next) in MHD_get_connection_values()
177 MHD_set_connection_value (struct MHD_Connection *connection, in MHD_set_connection_value() argument
183 pos = MHD_pool_allocate (connection->pool, in MHD_set_connection_value()
192 if (NULL == connection->headers_received_tail) in MHD_set_connection_value()
194 connection->headers_received = pos; in MHD_set_connection_value()
195 connection->headers_received_tail = pos; in MHD_set_connection_value()
199 connection->headers_received_tail->next = pos; in MHD_set_connection_value()
200 connection->headers_received_tail = pos; in MHD_set_connection_value()
[all …]
|
| D | connection_https.c | 46 run_tls_handshake (struct MHD_Connection *connection) in run_tls_handshake() argument
50 connection->last_activity = MHD_monotonic_time(); in run_tls_handshake()
51 if (connection->state == MHD_TLS_CONNECTION_INIT) in run_tls_handshake()
53 ret = gnutls_handshake (connection->tls_session); in run_tls_handshake()
57 connection->state = MHD_CONNECTION_INIT; in run_tls_handshake()
68 MHD_DLOG (connection->daemon, in run_tls_handshake()
71 MHD_connection_close (connection, in run_tls_handshake()
96 MHD_tls_connection_handle_read (struct MHD_Connection *connection) in MHD_tls_connection_handle_read() argument
98 if (MHD_YES == run_tls_handshake (connection)) in MHD_tls_connection_handle_read()
100 return MHD_connection_handle_read (connection); in MHD_tls_connection_handle_read()
[all …]
|
| D | digestauth.c | 301 check_nonce_nc (struct MHD_Connection *connection, in check_nonce_nc() argument
309 mod = connection->daemon->nonce_nc_size; in check_nonce_nc()
327 (void) MHD_mutex_lock_ (&connection->daemon->nnc_lock); in check_nonce_nc()
330 strcpy(connection->daemon->nnc[off].nonce, in check_nonce_nc()
332 connection->daemon->nnc[off].nc = 0; in check_nonce_nc()
333 (void) MHD_mutex_unlock_ (&connection->daemon->nnc_lock); in check_nonce_nc()
336 if ( (nc <= connection->daemon->nnc[off].nc) || in check_nonce_nc()
337 (0 != strcmp(connection->daemon->nnc[off].nonce, nonce)) ) in check_nonce_nc()
339 (void) MHD_mutex_unlock_ (&connection->daemon->nnc_lock); in check_nonce_nc()
341 MHD_DLOG (connection->daemon, in check_nonce_nc()
[all …]
|
| D | test_postprocessor.c | 124 struct MHD_Connection connection; in test_urlencoding() local
132 memset (&connection, 0, sizeof (struct MHD_Connection)); in test_urlencoding()
134 connection.headers_received = &header; in test_urlencoding()
138 pp = MHD_create_post_processor (&connection, in test_urlencoding()
158 struct MHD_Connection connection; in test_multipart_garbage() local
177 memset (&connection, 0, sizeof (struct MHD_Connection)); in test_multipart_garbage()
179 connection.headers_received = &header; in test_multipart_garbage()
184 pp = MHD_create_post_processor (&connection, in test_multipart_garbage()
199 struct MHD_Connection connection; in test_multipart_splits() local
210 memset (&connection, 0, sizeof (struct MHD_Connection)); in test_multipart_splits()
[all …]
|
| /third_party/gstreamer/gstplugins_bad/sys/dvb/ |
| D | camtransport.c | 111 CamTLConnection *connection; in cam_tl_connection_new() local
113 connection = g_new0 (CamTLConnection, 1); in cam_tl_connection_new()
114 connection->tl = tl; in cam_tl_connection_new()
115 connection->id = id; in cam_tl_connection_new()
116 connection->state = CAM_TL_CONNECTION_STATE_CLOSED; in cam_tl_connection_new()
117 connection->has_data = FALSE; in cam_tl_connection_new()
119 return connection; in cam_tl_connection_new()
123 cam_tl_connection_destroy (CamTLConnection * connection) in cam_tl_connection_destroy() argument
125 if (connection->last_poll) in cam_tl_connection_destroy()
126 g_timer_destroy (connection->last_poll); in cam_tl_connection_destroy()
[all …]
|
| /third_party/glib/gio/ |
| D | gdbusconnection.c | 206 void (*closed) (GDBusConnection *connection,
491 static void distribute_signals (GDBusConnection *connection,
494 static void distribute_method_call (GDBusConnection *connection,
497 static gboolean handle_generic_unlocked (GDBusConnection *connection,
501 static void purge_all_signal_subscriptions (GDBusConnection *connection);
502 static void purge_all_filters (GDBusConnection *connection);
504 static void schedule_method_call (GDBusConnection *connection,
542 check_initialized (GDBusConnection *connection) in check_initialized() argument
558 gint flags = g_atomic_int_get (&connection->atomic_flags); in check_initialized()
563 g_return_val_if_fail (connection->initialization_error == NULL, FALSE); in check_initialized()
[all …]
|
| D | gsocketconnection.c | 100 GSocketConnection *connection = G_SOCKET_CONNECTION (io_stream); in G_DEFINE_TYPE_WITH_PRIVATE() local
102 if (connection->priv->input_stream == NULL) in G_DEFINE_TYPE_WITH_PRIVATE()
103 connection->priv->input_stream = (GInputStream *) in G_DEFINE_TYPE_WITH_PRIVATE()
104 _g_socket_input_stream_new (connection->priv->socket); in G_DEFINE_TYPE_WITH_PRIVATE()
106 return connection->priv->input_stream; in G_DEFINE_TYPE_WITH_PRIVATE()
112 GSocketConnection *connection = G_SOCKET_CONNECTION (io_stream); in g_socket_connection_get_output_stream() local
114 if (connection->priv->output_stream == NULL) in g_socket_connection_get_output_stream()
115 connection->priv->output_stream = (GOutputStream *) in g_socket_connection_get_output_stream()
116 _g_socket_output_stream_new (connection->priv->socket); in g_socket_connection_get_output_stream()
118 return connection->priv->output_stream; in g_socket_connection_get_output_stream()
[all …]
|
| D | gdbusconnection.h | 95 void g_dbus_connection_start_message_processing (GDBusConnection *connection);
97 gboolean g_dbus_connection_is_closed (GDBusConnection *connection);
99 GIOStream *g_dbus_connection_get_stream (GDBusConnection *connection);
101 const gchar *g_dbus_connection_get_guid (GDBusConnection *connection);
103 const gchar *g_dbus_connection_get_unique_name (GDBusConnection *connection);
105 GCredentials *g_dbus_connection_get_peer_credentials (GDBusConnection *connection);
108 guint32 g_dbus_connection_get_last_serial (GDBusConnection *connection);
111 gboolean g_dbus_connection_get_exit_on_close (GDBusConnection *connection);
113 void g_dbus_connection_set_exit_on_close (GDBusConnection *connection,
116 GDBusCapabilityFlags g_dbus_connection_get_capabilities (GDBusConnection *connection);
[all …]
|
| D | gdbusnameowning.c | 71 GDBusConnection *connection; member
97 if (client->connection != NULL) in client_unref()
100 … g_signal_handler_disconnect (client->connection, client->disconnected_signal_handler_id); in client_unref()
102 … g_dbus_connection_signal_unsubscribe (client->connection, client->name_acquired_subscription_id); in client_unref()
104 … g_dbus_connection_signal_unsubscribe (client->connection, client->name_lost_subscription_id); in client_unref()
105 g_object_unref (client->connection); in client_unref()
131 GDBusConnection *connection; member
140 if (data->connection != NULL) in call_handler_data_free()
141 g_object_unref (data->connection); in call_handler_data_free()
147 actually_do_call (Client *client, GDBusConnection *connection, CallType call_type) in actually_do_call() argument
[all …]
|
| D | gtcpwrapperconnection.c | 68 GTcpWrapperConnection *connection = G_TCP_WRAPPER_CONNECTION (io_stream); in g_tcp_wrapper_connection_get_input_stream() local
70 return g_io_stream_get_input_stream (connection->priv->base_io_stream); in g_tcp_wrapper_connection_get_input_stream()
76 GTcpWrapperConnection *connection = G_TCP_WRAPPER_CONNECTION (io_stream); in g_tcp_wrapper_connection_get_output_stream() local
78 return g_io_stream_get_output_stream (connection->priv->base_io_stream); in g_tcp_wrapper_connection_get_output_stream()
87 GTcpWrapperConnection *connection = G_TCP_WRAPPER_CONNECTION (object); in g_tcp_wrapper_connection_get_property() local
92 g_value_set_object (value, connection->priv->base_io_stream); in g_tcp_wrapper_connection_get_property()
106 GTcpWrapperConnection *connection = G_TCP_WRAPPER_CONNECTION (object); in g_tcp_wrapper_connection_set_property() local
111 connection->priv->base_io_stream = g_value_dup_object (value); in g_tcp_wrapper_connection_set_property()
122 GTcpWrapperConnection *connection = G_TCP_WRAPPER_CONNECTION (object); in g_tcp_wrapper_connection_finalize() local
124 if (connection->priv->base_io_stream) in g_tcp_wrapper_connection_finalize()
[all …]
|
| D | gdbusnamewatching.c | 70 GDBusConnection *connection; member
98 if (client->connection != NULL) in client_unref()
101 …g_dbus_connection_signal_unsubscribe (client->connection, client->name_owner_changed_subscription_… in client_unref()
103 … g_signal_handler_disconnect (client->connection, client->disconnected_signal_handler_id); in client_unref()
104 g_object_unref (client->connection); in client_unref()
130 GDBusConnection *connection; member
141 if (data->connection != NULL) in call_handler_data_free()
142 g_object_unref (data->connection); in call_handler_data_free()
149 actually_do_call (Client *client, GDBusConnection *connection, const gchar *name_owner, CallType ca… in actually_do_call() argument
161 client->name_appeared_handler (connection, in actually_do_call()
[all …]
|
| D | gsocketclient.c | 950 GIOStream *connection) in g_socket_client_emit_event() argument
953 event, connectable, connection); in g_socket_client_emit_event()
1058 GIOStream *connection = NULL; in g_socket_client_connect() local
1079 while (connection == NULL) in g_socket_client_connect()
1126 connection = (GIOStream *)g_socket_connection_factory_create_connection (socket); in g_socket_client_connect()
1127 g_socket_connection_set_cached_remote_address ((GSocketConnection*)connection, address); in g_socket_client_connect()
1128 g_socket_client_emit_event (client, G_SOCKET_CLIENT_CONNECTING, connectable, connection); in g_socket_client_connect()
1130 if (g_socket_connection_connect (G_SOCKET_CONNECTION (connection), in g_socket_client_connect()
1133 g_socket_connection_set_cached_remote_address ((GSocketConnection*)connection, NULL); in g_socket_client_connect()
1134 g_socket_client_emit_event (client, G_SOCKET_CLIENT_CONNECTED, connectable, connection); in g_socket_client_connect()
[all …]
|
| D | gtcpconnection.c | 76 g_tcp_connection_init (GTcpConnection *connection) in g_tcp_connection_init() argument
78 connection->priv = g_tcp_connection_get_instance_private (connection); in g_tcp_connection_init()
79 connection->priv->graceful_disconnect = FALSE; in g_tcp_connection_init()
88 GTcpConnection *connection = G_TCP_CONNECTION (object); in g_tcp_connection_get_property() local
93 g_value_set_boolean (value, connection->priv->graceful_disconnect); in g_tcp_connection_get_property()
107 GTcpConnection *connection = G_TCP_CONNECTION (object); in g_tcp_connection_set_property() local
112 g_tcp_connection_set_graceful_disconnect (connection, in g_tcp_connection_set_property()
147 GTcpConnection *connection = G_TCP_CONNECTION (stream); in g_tcp_connection_close() local
156 if (connection->priv->graceful_disconnect && in g_tcp_connection_close()
254 GTcpConnection *connection = G_TCP_CONNECTION (stream); in g_tcp_connection_close_async() local
[all …]
|
| /third_party/skia/third_party/externals/microhttpd/src/examples/ |
| D | mhd2spdy_spdy.c | 146 struct SPDY_Connection *connection; in spdy_cb_send() local
148 connection = (struct SPDY_Connection*)user_data; in spdy_cb_send()
149 connection->want_io = IO_NONE; in spdy_cb_send()
164 if(connection->is_tls) in spdy_cb_send()
167 rv = SSL_write(connection->ssl, data, length); in spdy_cb_send()
169 int err = SSL_get_error(connection->ssl, rv); in spdy_cb_send()
171 connection->want_io |= (err == SSL_ERROR_WANT_READ ? in spdy_cb_send()
181 rv = write(connection->fd, in spdy_cb_send()
193 connection->want_io |= WANT_WRITE; in spdy_cb_send()
228 struct SPDY_Connection *connection; in spdy_cb_recv() local
[all …]
|
| /third_party/boost/boost/signals2/ |
| D | connection.hpp | 227 class connection class
232 connection() {} in connection() function in boost::signals2::connection
233 connection(const connection &other): _weak_connection_body(other._weak_connection_body) in connection() function in boost::signals2::connection
235 connection(const boost::weak_ptr<detail::connection_body_base> &connectionBody): in connection() function in boost::signals2::connection
241 connection(connection && other): _weak_connection_body(std::move(other._weak_connection_body)) in connection() function in boost::signals2::connection
247 connection & operator=(connection && other) in operator =()
257 connection & operator=(const connection & other) in operator =()
264 ~connection() {} in ~connection()
283 bool operator==(const connection& other) const in operator ==()
289 bool operator!=(const connection& other) const in operator !=()
[all …]
|
| /third_party/glib/gio/tests/ |
| D | gdbus-proxy-threads.c | 63 GDBusConnection *connection = data; in run_proxy_thread() local
77 proxy = g_dbus_proxy_new_sync (connection, in run_proxy_thread()
110 static void release_name (GDBusConnection *connection, gboolean wait);
117 GDBusConnection *connection = G_DBUS_CONNECTION (source); in request_name_cb() local
121 var = g_dbus_connection_call_finish (connection, res, &error); in request_name_cb()
126 release_name (connection, TRUE); in request_name_cb()
130 request_name (GDBusConnection *connection, in request_name() argument
133 g_dbus_connection_call (connection, in request_name()
152 GDBusConnection *connection = G_DBUS_CONNECTION (source); in release_name_cb() local
157 var = g_dbus_connection_call_finish (connection, res, &error); in release_name_cb()
[all …]
|
| /third_party/gstreamer/gstplugins_bad/gst/rtmp2/rtmp/ |
| D | rtmpconnection.c | 40 typedef void (*GstRtmpConnectionCallback) (GstRtmpConnection * connection);
52 GSocketConnection *connection; member
120 connection, GstBuffer * buffer);
122 connection, GstBuffer * buffer);
123 static void gst_rtmp_connection_handle_cm (GstRtmpConnection * connection,
136 static void gst_rtmp_connection_send_ack (GstRtmpConnection * connection);
138 gst_rtmp_connection_send_ping_response (GstRtmpConnection * connection,
301 g_clear_object (&rtmpconnection->connection); in gst_rtmp_connection_finalize()
316 return g_socket_connection_get_socket (sc->connection); in gst_rtmp_connection_get_socket()
321 GSocketConnection * connection) in gst_rtmp_connection_set_socket_connection() argument
[all …]
|
| D | rtmpconnection.h | 45 (GstRtmpConnection * connection, gpointer user_data);
47 (GstRtmpConnection * connection, GstBuffer * buffer, gpointer user_data);
54 GstRtmpConnection *gst_rtmp_connection_new (GSocketConnection * connection, GCancellable * cancella…
56 GSocket *gst_rtmp_connection_get_socket (GstRtmpConnection * connection);
58 void gst_rtmp_connection_close (GstRtmpConnection * connection);
61 void gst_rtmp_connection_set_input_handler (GstRtmpConnection * connection,
65 void gst_rtmp_connection_set_output_handler (GstRtmpConnection * connection,
71 void gst_rtmp_connection_queue_message (GstRtmpConnection * connection,
73 guint gst_rtmp_connection_get_num_queued (GstRtmpConnection * connection);
75 guint gst_rtmp_connection_send_command (GstRtmpConnection * connection,
[all …]
|
| /third_party/gstreamer/gstplugins_bad/gst-libs/gst/vulkan/xcb/ |
| D | gstvkdisplay_xcb.c | 64 if (!display_xcb->foreign_display && display_xcb->connection) in gst_vulkan_display_xcb_finalize()
65 xcb_disconnect (display_xcb->connection); in gst_vulkan_display_xcb_finalize()
66 display_xcb->connection = NULL; in gst_vulkan_display_xcb_finalize()
70 _get_screen_from_connection (xcb_connection_t * connection, int screen_no) in _get_screen_from_connection() argument
75 setup = xcb_get_setup (connection); in _get_screen_from_connection()
97 xcb_connection_t *connection; in gst_vulkan_display_xcb_new() local
103 connection = xcb_connect (NULL, &screen_no); in gst_vulkan_display_xcb_new()
104 if (connection == NULL || xcb_connection_has_error (connection)) { in gst_vulkan_display_xcb_new()
109 ret = gst_vulkan_display_xcb_new_with_connection (connection, screen_no); in gst_vulkan_display_xcb_new()
130 gst_vulkan_display_xcb_new_with_connection (xcb_connection_t * connection, in gst_vulkan_display_xcb_new_with_connection() argument
[all …]
|
| D | gstvkwindow_xcb.c | 145 xcb_connection_t *connection = in gst_vulkan_window_xcb_show() local
149 xcb_map_window (connection, window_xcb->win_id); in gst_vulkan_window_xcb_show()
150 xcb_flush (connection); in gst_vulkan_window_xcb_show()
160 xcb_connection_t *connection = in gst_vulkan_window_xcb_hide() local
164 xcb_unmap_window (connection, window_xcb->win_id); in gst_vulkan_window_xcb_hide()
175 xcb_connection_t *connection = in init_keyboard() local
179 ret = xkb_x11_setup_xkb_extension (connection, in init_keyboard()
193 priv->kbd_device_id = xkb_x11_get_core_keyboard_device_id (connection); in init_keyboard()
196 connection, priv->kbd_device_id, XKB_KEYMAP_COMPILE_NO_FLAGS); in init_keyboard()
200 connection, priv->kbd_device_id); in init_keyboard()
[all …]
|
| /third_party/wayland_standard/src/ |
| D | connection.c | 172 struct wl_connection *connection; in wl_connection_create() local
174 connection = zalloc(sizeof *connection); in wl_connection_create()
175 if (connection == NULL) in wl_connection_create()
178 connection->fd = fd; in wl_connection_create()
180 return connection; in wl_connection_create()
204 wl_connection_close_fds_in(struct wl_connection *connection, int max) in wl_connection_close_fds_in() argument
206 close_fds(&connection->fds_in, max); in wl_connection_close_fds_in()
210 wl_connection_destroy(struct wl_connection *connection) in wl_connection_destroy() argument
212 int fd = connection->fd; in wl_connection_destroy()
214 close_fds(&connection->fds_out, -1); in wl_connection_destroy()
[all …]
|
| /third_party/pulseaudio/src/modules/x11/ |
| D | module-x11-xsmp.c | 57 SmcConn connection; member
61 static void die_cb(SmcConn connection, SmPointer client_data) { in die_cb() argument
75 static void save_complete_cb(SmcConn connection, SmPointer client_data) { in save_complete_cb() argument
78 static void shutdown_cancelled_cb(SmcConn connection, SmPointer client_data) { in shutdown_cancelled_cb() argument
79 SmcSaveYourselfDone(connection, True); in shutdown_cancelled_cb()
82 static void save_yourself_cb(SmcConn connection, SmPointer client_data, int save_type, Bool _shutdo… in save_yourself_cb() argument
83 SmcSaveYourselfDone(connection, True); in save_yourself_cb()
87 IceConn connection = userdata; in ice_io_cb() local
89 if (IceProcessMessages(connection, NULL, NULL) == IceProcessMessagesIOError) { in ice_io_cb()
90 IceSetShutdownNegotiation(connection, False); in ice_io_cb()
[all …]
|
| /third_party/mbedtls/tests/scripts/ |
| D | tcp_client.pl | 47 my ($connection) = @_;
48 $connection->shutdown(2);
55 my ($connection, $hexdata) = @_;
59 my $sent = $connection->send($data, 0);
70 my ($connection, $expected_hex) = @_;
75 my $ok = $connection->recv($actual_data, length($expected_data));
96 my $connection = open_connection($host, $port);
97 write_data($connection, $data1);
98 if (!read_response($connection, $response1)) {
101 close_connection($connection);
|
| /third_party/node/test/parallel/ |
| D | test-pipe-writev.js | 13 const server = net.createServer((connection) => {
14 connection.on('error', (err) => {
18 const writev = connection._writev.bind(connection);
19 connection._writev = common.mustCall(writev);
21 connection.cork();
22 connection.write('pi');
23 connection.write('ng');
24 connection.end();
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | rtkit.c | 65 static long long rtkit_get_int_property(DBusConnection *connection, const char* propname, long long… in rtkit_get_int_property() argument
95 if (!(r = dbus_connection_send_with_reply_and_block(connection, m, -1, &error))) { in rtkit_get_int_property()
145 int rtkit_get_max_realtime_priority(DBusConnection *connection) { in rtkit_get_max_realtime_priority() argument
149 err = rtkit_get_int_property(connection, "MaxRealtimePriority", &retval); in rtkit_get_max_realtime_priority()
153 int rtkit_get_min_nice_level(DBusConnection *connection, int* min_nice_level) { in rtkit_get_min_nice_level() argument
157 err = rtkit_get_int_property(connection, "MinNiceLevel", &retval); in rtkit_get_min_nice_level()
163 long long rtkit_get_rttime_usec_max(DBusConnection *connection) { in rtkit_get_rttime_usec_max() argument
167 err = rtkit_get_int_property(connection, "RTTimeUSecMax", &retval); in rtkit_get_rttime_usec_max()
171 int rtkit_make_realtime(DBusConnection *connection, pid_t thread, int priority) { in rtkit_make_realtime() argument
204 if (!(r = dbus_connection_send_with_reply_and_block(connection, m, -1, &error))) { in rtkit_make_realtime()
[all …]
|