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

123

/freebsd-current/lib/libc/net/
H A Dnscachedcli.c52 * safe_write writes data to the specified connection and tries to do it in
58 safe_write(struct cached_connection_ *connection, const void *data, argument
74 nevents = _kevent(connection->write_queue, NULL, 0, &eventlist,
77 s_result = _sendto(connection->sockfd, data + result,
96 * safe_read reads data from connection and tries to do it in the very safe
102 safe_read(struct cached_connection_ *connection, void *data, size_t data_size) argument
117 nevents = _kevent(connection->read_queue, NULL, 0, &eventlist,
120 s_result = _read(connection->sockfd, data + result,
138 * Sends the credentials information to the connection along with the
142 send_credentials(struct cached_connection_ *connection, in argument
236 __close_cached_connection(struct cached_connection_ *connection) argument
252 __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
304 __cached_read(struct cached_connection_ *connection, const char *entry_name, const char *key, size_t key_size, char *data, size_t *data_size) argument
377 struct cached_connection_ *connection, *retval; local
484 struct cached_connection_ *connection, *retval; local
[all...]
H A Dnscache.c57 cached_connection connection; local
108 connection = __open_cached_connection(&params);
109 if (connection == NULL) {
113 res = __cached_read(connection, cache_info->entry_name,
116 __close_cached_connection(connection);
161 cached_connection connection; local
180 connection = __open_cached_connection(&params);
181 if (connection == NULL) {
210 __close_cached_connection(connection);
216 res = __cached_write(connection, cache_inf
230 cached_connection connection; local
[all...]
/freebsd-current/usr.sbin/nscd/
H A Dnscdcli.c53 safe_write(struct nscd_connection_ *connection, const void *data, argument
69 nevents = kevent(connection->write_queue, NULL, 0, &eventlist,
72 s_result = write(connection->sockfd,
91 safe_read(struct nscd_connection_ *connection, void *data, size_t data_size) argument
106 nevents = kevent(connection->read_queue, NULL, 0, &eventlist, 1,
109 s_result = read(connection->sockfd,
128 send_credentials(struct nscd_connection_ *connection, int type) argument
155 EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD,
157 kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL);
159 nevents = kevent(connection
225 close_nscd_connection__(struct nscd_connection_ *connection) argument
239 nscd_transform__(struct nscd_connection_ *connection, const char *entry_name, int transformation_type) argument
[all...]
/freebsd-current/usr.sbin/iscsid/
H A Discsid.h46 struct connection conn;
61 void fail(const struct connection *, const char *);
/freebsd-current/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-current/share/doc/psd/20.ipctut/
H A Dustreamread.c38 * loop it accepts a connection and prints out messages from it. When the
39 * connection breaks, or a termination message comes through, the program
40 * accepts a new connection.
73 printf("Ending connection\en");
H A Dstreamread.c37 * through the loop it accepts a connection and prints out messages from it.
38 * When the connection breaks, or a termination message comes through, the
39 * program accepts a new connection.
85 printf("Ending connection\en");
H A Dstrchkread.c92 printf("Ending connection\en");
/freebsd-current/lib/libiscsiutil/
H A Dlibiscsiutil.h42 struct connection { struct
62 struct connection *pdu_connection;
72 void (*fail)(const struct connection *, const char *);
136 struct pdu *pdu_new(struct connection *ic);
146 void text_send_request(struct connection *conn,
148 struct keys * text_read_response(struct connection *conn);
149 struct keys * text_read_request(struct connection *conn,
154 void connection_init(struct connection *conn,
H A DMakefile7 SRCS= chap.c connection.c keys.c log.c pdu.c text.c utils.c
H A Dconnection.c36 connection_init(struct connection *conn, const struct connection_ops *ops,
H A Dtext.c42 text_new_request(struct connection *conn, uint32_t ttt)
61 /* Receive a TextRequest PDU from a connection. */
63 text_receive_request(struct connection *conn)
99 struct connection *conn;
123 /* Receive a TextResponse PDU from a connection. */
125 text_receive_response(struct connection *conn)
170 text_send_request(struct connection *conn, struct keys *request_keys)
191 text_read_response(struct connection *conn)
247 text_read_request(struct connection *conn, struct pdu **requestp)
277 struct connection *con
[all...]
H A Dpdu.c74 pdu_new(struct connection *conn)
109 pdu_read(const struct connection *conn, char *data, size_t len)
124 conn->conn_ops->fail(conn, "connection lost");
125 log_errx(1, "read: connection lost");
135 struct connection *conn;
175 struct connection *conn;
/freebsd-current/contrib/llvm-project/compiler-rt/lib/tsan/rtl/
H A Dtsan_interceptors_mac.cpp294 xpc_connection_t connection, xpc_handler_t handler) {
295 SCOPED_TSAN_INTERCEPTOR(xpc_connection_set_event_handler, connection,
297 Release(thr, pc, (uptr)connection);
301 Acquire(thr, pc, (uptr)connection);
305 REAL(xpc_connection_set_event_handler)(connection, new_handler);
308 TSAN_INTERCEPTOR(void, xpc_connection_send_barrier, xpc_connection_t connection, argument
310 SCOPED_TSAN_INTERCEPTOR(xpc_connection_send_barrier, connection, barrier);
311 Release(thr, pc, (uptr)connection);
315 Acquire(thr, pc, (uptr)connection);
319 REAL(xpc_connection_send_barrier)(connection, new_barrie
293 TSAN_INTERCEPTOR(void, xpc_connection_set_event_handler, xpc_connection_t connection, xpc_handler_t handler) argument
322 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
339 TSAN_INTERCEPTOR(void, xpc_connection_cancel, xpc_connection_t connection) argument
[all...]
/freebsd-current/contrib/lib9p/
H A DMakefile8 connection.c \
/freebsd-current/lib/lib9p/
H A DMakefile18 SRCS= connection.c \
/freebsd-current/contrib/ntp/sntp/libevent/
H A Devrpc.c504 static int evrpc_schedule_request(struct evhttp_connection *connection,
540 struct evhttp_connection *connection; local
556 while ((connection = TAILQ_FIRST(&pool->connections)) != NULL) {
557 TAILQ_REMOVE(&pool->connections, connection, next);
558 evhttp_connection_free(connection);
575 * Add a connection to the RPC pool. A request scheduled on the pool
576 * may use any available connection.
581 struct evhttp_connection *connection)
583 EVUTIL_ASSERT(connection->http_server == NULL);
584 TAILQ_INSERT_TAIL(&pool->connections, connection, nex
580 evrpc_pool_add_connection(struct evrpc_pool *pool, struct evhttp_connection *connection) argument
613 evrpc_pool_remove_connection(struct evrpc_pool *pool, struct evhttp_connection *connection) argument
640 struct evhttp_connection *connection; local
659 evrpc_schedule_request(struct evhttp_connection *connection, struct evrpc_request_wrapper *ctx) argument
721 struct evhttp_connection *connection = ctx->evcon; local
[all...]
/freebsd-current/contrib/libevent/
H A Devrpc.c504 static int evrpc_schedule_request(struct evhttp_connection *connection,
540 struct evhttp_connection *connection; local
556 while ((connection = TAILQ_FIRST(&pool->connections)) != NULL) {
557 TAILQ_REMOVE(&pool->connections, connection, next);
558 evhttp_connection_free(connection);
575 * Add a connection to the RPC pool. A request scheduled on the pool
576 * may use any available connection.
581 struct evhttp_connection *connection)
583 EVUTIL_ASSERT(connection->http_server == NULL);
584 TAILQ_INSERT_TAIL(&pool->connections, connection, nex
580 evrpc_pool_add_connection(struct evrpc_pool *pool, struct evhttp_connection *connection) argument
613 evrpc_pool_remove_connection(struct evrpc_pool *pool, struct evhttp_connection *connection) argument
640 struct evhttp_connection *connection; local
659 evrpc_schedule_request(struct evhttp_connection *connection, struct evrpc_request_wrapper *ctx) argument
721 struct evhttp_connection *connection = ctx->evcon; local
[all...]
/freebsd-current/tools/tools/netrate/tcpp/
H A Dtcpp_server.c53 * port number for new connections. The first 8 bytes of each connection
62 struct connection { struct
74 static struct connection *
77 struct connection *conn;
109 tcpp_server_closeconn(struct connection *conn)
128 struct connection *conn;
160 * Drain up to a buffer from the connection, so that we pay
H A Dtcpp_client.c65 struct connection { struct
81 static struct connection *
85 struct connection *conn;
144 tcpp_client_closeconn(struct connection *conn)
156 struct connection *conn;
/freebsd-current/tools/test/stress2/misc/
H A Dtmpfs7.sh49 int f, listener, connection;
61 if ((connection = accept_unix_socket(listener)) >= 0) {
62 real_sendfile(f, connection);
H A Dsendfile6.sh49 int f, listener, connection;
61 if ((connection = accept_unix_socket(listener)) >= 0) {
62 real_sendfile(f, connection);
/freebsd-current/sys/contrib/xen/io/
H A Dxs_wire.h126 uint32_t connection; member in struct:xenstore_domain_interface
139 /* Valid values for the connection field */
/freebsd-current/contrib/llvm-project/lldb/include/lldb/Core/
H A DCommunication.h32 /// class to be used even though its connection can change. Connections could
51 /// Connect using the current connection by passing \a url to its connect
67 /// Disconnect the communications connection if one is currently connected.
78 /// Check if the connection is valid.
89 /// Read bytes from the current connection.
91 /// If no read thread is running, this function call the connection's
147 /// Sets the connection that it to be used by this class.
151 /// connection without any interruption to the client. It also allows the
154 /// \param[in] connection
155 /// A connection tha
[all...]

Completed in 237 milliseconds

123