/freebsd-13-stable/lib/libc/net/ |
H A D | nscachedcli.c | 55 * 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 D | nscache.c | 60 cached_connection connection; local 111 connection = __open_cached_connection(¶ms); 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(¶ms); 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 D | nscdcli.c | 56 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 D | socketmapClient.pl | 9 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 D | socketmapServer.pl | 9 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 D | strchkread.c | 94 printf("Ending connection\en");
|
H A D | streamread.c | 39 * 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 D | ustreamread.c | 40 * 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 D | iscsid.h | 49 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 D | discovery.c | 45 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 D | pdu.c | 81 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 D | login.c | 163 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 D | svnserve.c | 78 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 D | server.h | 103 /* 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 D | tsan_interceptors_mac.cpp | 292 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 D | Makefile | 16 SRCS= connection.c \
|
/freebsd-13-stable/contrib/lib9p/ |
H A D | Makefile | 8 connection.c \
|
/freebsd-13-stable/contrib/libevent/ |
H A D | evrpc.c | 503 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 D | evrpc.c | 503 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 D | tcpp_server.c | 55 * 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 D | tcpp_client.c | 67 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 D | discovery.c | 47 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 D | ctld.h | 235 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 D | xs_wire.h | 126 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 D | dbus_new_helpers.h | 28 DBusConnection *connection; member in struct:wpa_dbus_object_desc
|