Searched refs:connection (Results 1 - 25 of 56) sorted by relevance

123

/freebsd-13-stable/lib/libc/net/
H A Dnscachedcli.c55 * safe_write writes data to the specified connection and tries to do it in
61 safe_write(struct cached_connection_ *connection, const void *data, argument
77 nevents = _kevent(connection->write_queue, NULL, 0, &eventlist,
80 s_result = _sendto(connection->sockfd, data + result,
99 * safe_read reads data from connection and tries to do it in the very safe
105 safe_read(struct cached_connection_ *connection, void *data, size_t data_size) argument
120 nevents = _kevent(connection->read_queue, NULL, 0, &eventlist,
123 s_result = _read(connection->sockfd, data + result,
141 * Sends the credentials information to the connection along with the
145 send_credentials(struct cached_connection_ *connection, in argument
240 __close_cached_connection(struct cached_connection_ *connection) argument
256 __cached_write(struct cached_connection_ *connection, const char *entry_name, const char *key, size_t key_size, const char *data, size_t data_size) argument
308 __cached_read(struct cached_connection_ *connection, const char *entry_name, const char *key, size_t key_size, char *data, size_t *data_size) argument
381 struct cached_connection_ *connection, *retval; local
489 struct cached_connection_ *connection, *retval; local
[all...]
H A Dnscache.c60 cached_connection connection; local
111 connection = __open_cached_connection(&params);
112 if (connection == NULL) {
116 res = __cached_read(connection, cache_info->entry_name,
119 __close_cached_connection(connection);
164 cached_connection connection; local
183 connection = __open_cached_connection(&params);
184 if (connection == NULL) {
213 __close_cached_connection(connection);
219 res = __cached_write(connection, cache_inf
233 cached_connection connection; local
[all...]
/freebsd-13-stable/usr.sbin/nscd/
H A Dnscdcli.c56 safe_write(struct nscd_connection_ *connection, const void *data, argument
72 nevents = kevent(connection->write_queue, NULL, 0, &eventlist,
75 s_result = write(connection->sockfd,
94 safe_read(struct nscd_connection_ *connection, void *data, size_t data_size) argument
109 nevents = kevent(connection->read_queue, NULL, 0, &eventlist, 1,
112 s_result = read(connection->sockfd,
131 send_credentials(struct nscd_connection_ *connection, int type) argument
159 EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD,
161 res = kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL);
163 nevents = kevent(connection
229 close_nscd_connection__(struct nscd_connection_ *connection) argument
243 nscd_transform__(struct nscd_connection_ *connection, const char *entry_name, int transformation_type) argument
[all...]
/freebsd-13-stable/contrib/sendmail/contrib/
H A DsocketmapClient.pl9 die "usage: $0 <connection> <mapname> <key> [<key2> ...]" if (@ARGV < 3);
11 my $connection = shift @ARGV;
16 if ($connection =~ /tcp:(.+):([0-9]*)/) {
22 } elsif ($connection =~ /((unix)|(local)):(.+)/) {
28 die "unrecognized connection specification $connection";
H A DsocketmapServer.pl9 die "usage: $0 <connection>" if (@ARGV < 1);
10 my $connection = shift @ARGV;
13 if ($connection =~ /tcp:(.+):([0-9]*)/) {
21 } elsif ($connection =~ /((unix)|(local)):(.+)/) {
29 die "unrecognized connection specification $connection";
/freebsd-13-stable/share/doc/psd/20.ipctut/
H A Dstrchkread.c94 printf("Ending connection\en");
H A Dstreamread.c39 * through the loop it accepts a connection and prints out messages from it.
40 * When the connection breaks, or a termination message comes through, the
41 * program accepts a new connection.
87 printf("Ending connection\en");
H A Dustreamread.c40 * loop it accepts a connection and prints out messages from it. When the
41 * connection breaks, or a termination message comes through, the program
42 * accepts a new connection.
75 printf("Ending connection\en");
/freebsd-13-stable/usr.sbin/iscsid/
H A Discsid.h49 struct connection { struct
72 struct connection *pdu_connection;
127 struct pdu *pdu_new(struct connection *ic);
133 void login(struct connection *ic);
135 void discovery(struct connection *ic);
150 void fail(const struct connection *, const char *);
H A Ddiscovery.c45 text_receive(struct connection *conn)
76 text_new_request(struct connection *conn)
97 logout_receive(struct connection *conn)
122 logout_new_request(struct connection *conn)
141 kernel_add(const struct connection *conn, const char *target)
157 kernel_remove(const struct connection *conn)
170 discovery(struct connection *conn)
H A Dpdu.c81 pdu_new(struct connection *conn)
110 struct connection *conn;
149 struct connection *conn;
187 pdu_read(const struct connection *conn, char *data, size_t len)
201 fail(conn, "connection lost");
202 log_errx(1, "read: connection lost");
212 struct connection *conn;
255 struct connection *conn;
H A Dlogin.c163 kernel_modify(const struct connection *conn, const char *target_address)
187 * This would allow us to "backtrack" on connection failure,
191 login_handle_redirection(struct connection *conn, struct pdu *response)
218 login_receive(struct connection *conn)
273 login_new_request(struct connection *conn, int csg)
331 login_negotiate_key(struct connection *conn, const char *name,
483 login_negotiate(struct connection *conn)
600 login_send_chap_a(struct connection *conn)
617 struct connection *conn;
702 struct connection *con
[all...]
/freebsd-13-stable/contrib/subversion/subversion/svnserve/
H A Dsvnserve.c78 connection_mode_fork, /* Create a process per connection */
79 connection_mode_thread, /* Create a thread per connection */
80 connection_mode_single /* One connection at a time in this process */
395 N_("handle one connection at a time in the parent\n"
517 /* Wait for the next client connection to come in from SOCK. Allocate
518 * the connection in a root pool from CONNECTION_POOLS and assign PARAMS.
519 * Return the connection object in *CONNECTION.
524 accept_connection(connection_t **connection,
533 * the connection threads so it cannot clean up after each one. So
537 *connection
523 accept_connection(connection_t **connection, apr_socket_t *sock, serve_params_t *params, enum connection_handling_mode handling_mode, apr_pool_t *pool) argument
573 attach_connection(connection_t *connection) argument
582 close_connection(connection_t *connection) argument
595 serve_socket(connection_t *connection, apr_pool_t *pool) argument
621 is_busy(connection_t *connection) argument
633 connection_t *connection = data; local
1335 connection_t *connection = NULL; local
[all...]
H A Dserver.h103 /* True if the connection is tunneled over an ssh-like transport,
166 connection. Their lifetime is separated from the thread-local
176 /* connection-specific objects */
179 /* buffered connection object used by the marshaller */
182 /* memory pool for objects with connection lifetime */
204 /* Serve the connection CONN according to the parameters PARAMS. */
208 /* Serve the connection CONNECTION for as long as IS_BUSY does not
209 return TRUE. If IS_BUSY is NULL, serve the connection until it
211 not NULL, set *TERMINATE_P to TRUE if the connection got
215 will create an ra_svn connection objec
[all...]
/freebsd-13-stable/contrib/llvm-project/compiler-rt/lib/tsan/rtl/
H A Dtsan_interceptors_mac.cpp292 xpc_connection_t connection, xpc_handler_t handler) {
293 SCOPED_TSAN_INTERCEPTOR(xpc_connection_set_event_handler, connection,
295 Release(thr, pc, (uptr)connection);
299 Acquire(thr, pc, (uptr)connection);
303 REAL(xpc_connection_set_event_handler)(connection, new_handler);
306 TSAN_INTERCEPTOR(void, xpc_connection_send_barrier, xpc_connection_t connection, argument
308 SCOPED_TSAN_INTERCEPTOR(xpc_connection_send_barrier, connection, barrier);
309 Release(thr, pc, (uptr)connection);
313 Acquire(thr, pc, (uptr)connection);
317 REAL(xpc_connection_send_barrier)(connection, new_barrie
291 TSAN_INTERCEPTOR(void, xpc_connection_set_event_handler, xpc_connection_t connection, xpc_handler_t handler) argument
320 TSAN_INTERCEPTOR(void, xpc_connection_send_message_with_reply, xpc_connection_t connection, xpc_object_t message, dispatch_queue_t replyq, xpc_handler_t handler) argument
337 TSAN_INTERCEPTOR(void, xpc_connection_cancel, xpc_connection_t connection) argument
[all...]
/freebsd-13-stable/lib/lib9p/
H A DMakefile16 SRCS= connection.c \
/freebsd-13-stable/contrib/lib9p/
H A DMakefile8 connection.c \
/freebsd-13-stable/contrib/libevent/
H A Devrpc.c503 static int evrpc_schedule_request(struct evhttp_connection *connection,
539 struct evhttp_connection *connection; local
555 while ((connection = TAILQ_FIRST(&pool->connections)) != NULL) {
556 TAILQ_REMOVE(&pool->connections, connection, next);
557 evhttp_connection_free(connection);
574 * Add a connection to the RPC pool. A request scheduled on the pool
575 * may use any available connection.
580 struct evhttp_connection *connection)
582 EVUTIL_ASSERT(connection->http_server == NULL);
583 TAILQ_INSERT_TAIL(&pool->connections, connection, nex
579 evrpc_pool_add_connection(struct evrpc_pool *pool, struct evhttp_connection *connection) argument
612 evrpc_pool_remove_connection(struct evrpc_pool *pool, struct evhttp_connection *connection) argument
639 struct evhttp_connection *connection; local
658 evrpc_schedule_request(struct evhttp_connection *connection, struct evrpc_request_wrapper *ctx) argument
720 struct evhttp_connection *connection = ctx->evcon; local
[all...]
/freebsd-13-stable/contrib/ntp/sntp/libevent/
H A Devrpc.c503 static int evrpc_schedule_request(struct evhttp_connection *connection,
539 struct evhttp_connection *connection; local
555 while ((connection = TAILQ_FIRST(&pool->connections)) != NULL) {
556 TAILQ_REMOVE(&pool->connections, connection, next);
557 evhttp_connection_free(connection);
574 * Add a connection to the RPC pool. A request scheduled on the pool
575 * may use any available connection.
580 struct evhttp_connection *connection)
582 EVUTIL_ASSERT(connection->http_server == NULL);
583 TAILQ_INSERT_TAIL(&pool->connections, connection, nex
579 evrpc_pool_add_connection(struct evrpc_pool *pool, struct evhttp_connection *connection) argument
612 evrpc_pool_remove_connection(struct evrpc_pool *pool, struct evhttp_connection *connection) argument
639 struct evhttp_connection *connection; local
658 evrpc_schedule_request(struct evhttp_connection *connection, struct evrpc_request_wrapper *ctx) argument
720 struct evhttp_connection *connection = ctx->evcon; local
[all...]
/freebsd-13-stable/tools/tools/netrate/tcpp/
H A Dtcpp_server.c55 * port number for new connections. The first 8 bytes of each connection
64 struct connection { struct
76 static struct connection *
79 struct connection *conn;
111 tcpp_server_closeconn(struct connection *conn)
130 struct connection *conn;
162 * Drain up to a buffer from the connection, so that we pay
H A Dtcpp_client.c67 struct connection { struct
83 static struct connection *
87 struct connection *conn;
146 tcpp_client_closeconn(struct connection *conn)
158 struct connection *conn;
/freebsd-13-stable/usr.sbin/ctld/
H A Ddiscovery.c47 text_receive(struct connection *conn)
88 struct connection *conn;
110 logout_receive(struct connection *conn)
146 struct connection *conn;
214 discovery_target_filtered_out(const struct connection *conn,
277 discovery(struct connection *conn)
H A Dctld.h235 struct connection { struct
264 struct connection *pdu_connection;
415 void kernel_handoff(struct connection *conn);
446 struct pdu *pdu_new(struct connection *conn);
452 void login(struct connection *conn);
454 void discovery(struct connection *conn);
/freebsd-13-stable/sys/xen/interface/io/
H A Dxs_wire.h126 uint32_t connection; member in struct:xenstore_domain_interface
139 /* Valid values for the connection field */
/freebsd-13-stable/contrib/wpa/wpa_supplicant/dbus/
H A Ddbus_new_helpers.h28 DBusConnection *connection; member in struct:wpa_dbus_object_desc

Completed in 109 milliseconds

123