Searched defs:conn (Results 1 - 25 of 86) sorted by relevance

1234

/illumos-gate/usr/src/uts/common/io/ib/clients/rdsv3/
H A Drdma_transport.c61 struct rdsv3_connection *conn = cm_id->context; local
66 "conn %p id %p handling event %u", conn, cm_id, event->event);
74 if (conn) {
75 mutex_enter(&conn->c_cm_lock);
82 if (rdsv3_conn_state(conn) == RDSV3_CONN_DISCONNECTING) {
90 "conn %p id %p incoming event %u when "
91 "disconnecting", conn, cm_id, event->event);
113 trans->cm_connect_complete(conn, event);
123 if (conn)
[all...]
H A Dthreads.c86 rdsv3_connect_complete(struct rdsv3_connection *conn) argument
88 RDSV3_DPRINTF4("rdsv3_connect_complete", "Enter(conn: %p)", conn);
90 if (!rdsv3_conn_transition(conn, RDSV3_CONN_CONNECTING,
97 atomic_get(&conn->c_state));
99 conn->c_state = RDSV3_CONN_ERROR;
100 rdsv3_queue_work(rdsv3_wq, &conn->c_down_w);
105 "conn %p for %u.%u.%u.%u to %u.%u.%u.%u complete",
106 conn, NIPQUAD(conn
137 rdsv3_queue_reconnect(struct rdsv3_connection *conn) argument
170 struct rdsv3_connection *conn = container_of(work, local
208 struct rdsv3_connection *conn = container_of(work, local
236 struct rdsv3_connection *conn = container_of(work, local
264 struct rdsv3_connection *conn = container_of(work, local
274 struct rdsv3_connection *conn = container_of(work, local
[all...]
H A Dloop.c68 * is handed the sending conn so the sense of the addresses is reversed.
71 rdsv3_loop_xmit(struct rdsv3_connection *conn, struct rdsv3_message *rm, argument
77 rdsv3_cong_map_updated(conn->c_fcong, ~(uint64_t)0);
82 RDSV3_DPRINTF4("rdsv3_loop_xmit", "Enter(conn: %p, rm: %p)", conn, rm);
84 rdsv3_inc_init(&rm->m_inc, conn, conn->c_laddr);
88 rdsv3_recv_incoming(conn, conn->c_laddr, conn
115 rdsv3_loop_xmit_cong_map(struct rdsv3_connection *conn, struct rdsv3_cong_map *map, unsigned long offset) argument
134 rdsv3_loop_recv(struct rdsv3_connection *conn) argument
141 struct rdsv3_connection *conn; member in struct:rdsv3_loop_connection
152 rdsv3_loop_conn_alloc(struct rdsv3_connection *conn, int gfp) argument
185 rdsv3_loop_conn_connect(struct rdsv3_connection *conn) argument
193 rdsv3_loop_conn_shutdown(struct rdsv3_connection *conn) argument
[all...]
H A Dbind.c144 rdsv3_find_bound(struct rdsv3_connection *conn, uint16_be_t port) argument
149 NIPQUAD(conn->c_laddr), ntohs(port));
151 rw_enter(&conn->c_bucketp->rwlock, RW_READER);
152 ASSERT(ntohl(conn->c_laddr) == conn->c_bucketp->ip);
153 rs = conn->c_bucketp->port[ntohs(port)];
158 rw_exit(&conn->c_bucketp->rwlock);
161 rs, NIPQUAD(conn->c_laddr), ntohs(port));
H A Dib.c274 rds_ib_conn_info_visitor(struct rdsv3_connection *conn, argument
280 RDSV3_DPRINTF4("rds_ib_conn_info_visitor", "conn: %p buffer: %p",
281 conn, buffer);
284 if (conn->c_trans != &rdsv3_ib_transport)
287 iinfo->src_addr = conn->c_laddr;
288 iinfo->dst_addr = conn->c_faddr;
292 if (rdsv3_conn_state(conn) == RDSV3_CONN_UP) {
296 ic = conn->c_transport_data;
309 RDSV3_DPRINTF4("rds_ib_conn_info_visitor", "conn: %p buffer: %p",
310 conn, buffe
[all...]
H A Dcong.c104 * - on connection buildup to associate a conn with its maps
190 * Put the conn on its local map's list. This is called when the conn is
194 rdsv3_cong_add_conn(struct rdsv3_connection *conn) argument
196 RDSV3_DPRINTF4("rdsv3_cong_add_conn", "Enter(conn: %p)", conn);
198 RDSV3_DPRINTF5("rdsv3_cong_add_conn", "conn %p now on map %p",
199 conn, conn->c_lcong);
201 list_insert_tail(&conn
208 rdsv3_cong_remove_conn(struct rdsv3_connection *conn) argument
222 rdsv3_cong_get_maps(struct rdsv3_connection *conn) argument
236 struct rdsv3_connection *conn; local
467 rdsv3_cong_update_alloc(struct rdsv3_connection *conn) argument
[all...]
H A Dconnection.c66 struct rdsv3_connection *conn; local
73 conn = avl_find(&rdsv3_conn_hash, &conn_info, &place);
76 "returning conn %p for %u.%u.%u.%u -> %u.%u.%u.%u",
77 conn, NIPQUAD(laddr), NIPQUAD(faddr));
82 return (conn);
92 rdsv3_conn_reset(struct rdsv3_connection *conn) argument
96 NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr));
99 rdsv3_send_reset(conn);
100 conn
122 struct rdsv3_connection *conn, *parent = NULL; local
275 rdsv3_conn_shutdown(struct rdsv3_connection *conn) argument
357 rdsv3_conn_destroy(struct rdsv3_connection *conn) argument
421 struct rdsv3_connection *conn; local
493 struct rdsv3_connection *conn; local
536 rdsv3_conn_info_visitor(struct rdsv3_connection *conn, void *buffer) argument
622 rdsv3_conn_drop(struct rdsv3_connection *conn) argument
[all...]
H A Dib_cm.c60 rdsv3_ib_set_protocol(struct rdsv3_connection *conn, unsigned int version) argument
62 RDSV3_DPRINTF4("rdsv3_ib_set_protocol", "conn: %p version: %d",
63 conn, version);
64 conn->c_version = version;
71 rdsv3_ib_set_flow_control(struct rdsv3_connection *conn, uint32_t credits) argument
73 struct rdsv3_ib_connection *ic = conn->c_transport_data;
76 "Enter: conn: %p credits: %d", conn, credits);
81 rdsv3_ib_send_add_credits(conn, credits);
87 "Return: conn
125 rdsv3_ib_cm_connect_complete(struct rdsv3_connection *conn, struct rdma_cm_event *event) argument
233 rdsv3_ib_cm_fill_conn_param(struct rdsv3_connection *conn, struct rdma_conn_param *conn_param, struct rdsv3_ib_connect_private *dp, uint32_t protocol_version, uint32_t max_responder_resources, uint32_t max_initiator_depth) argument
298 struct rdsv3_connection *conn = context; local
311 struct rdsv3_connection *conn = ic->conn; local
349 struct rdsv3_connection *conn = context; local
363 struct rdsv3_connection *conn = (struct rdsv3_connection *)data; local
372 struct rdsv3_connection *conn = ic->conn; local
443 struct rdsv3_connection *conn = data; local
484 rdsv3_ib_setup_qp(struct rdsv3_connection *conn) argument
709 struct rdsv3_connection *conn = NULL; local
837 struct rdsv3_connection *conn = cm_id->context; local
889 rdsv3_ib_conn_connect(struct rdsv3_connection *conn) argument
954 rdsv3_ib_conn_shutdown(struct rdsv3_connection *conn) argument
1092 rdsv3_ib_conn_alloc(struct rdsv3_connection *conn, int gfp) argument
1158 __rdsv3_ib_conn_error(struct rdsv3_connection *conn) argument
[all...]
H A Drds_recv.c51 rdsv3_inc_init(struct rdsv3_incoming *inc, struct rdsv3_connection *conn, argument
54 RDSV3_DPRINTF5("rdsv3_inc_init", "Enter(inc: %p, conn: %p)", inc, conn);
57 inc->i_conn = conn;
175 * rx and conn reset on this specific conn.
178 * down a connection at a time. This lets us reassemble in the conn
180 * flows to tear down partial reassembly progress on conn failure and
186 * conn. This lets loopback, who only has one conn fo
191 rdsv3_recv_incoming(struct rdsv3_connection *conn, uint32_be_t saddr, uint32_be_t daddr, struct rdsv3_incoming *inc, int gfp) argument
[all...]
H A Dsend.c73 rdsv3_send_reset(struct rdsv3_connection *conn) argument
78 RDSV3_DPRINTF4("rdsv3_send_reset", "Enter(conn: %p)", conn);
80 ASSERT(MUTEX_HELD(&conn->c_send_lock));
82 if (conn->c_xmit_rm) {
83 rm = conn->c_xmit_rm;
91 rdsv3_ib_send_unmap_rdma(conn->c_transport_data, ro);
99 rdsv3_message_unmapped(conn->c_xmit_rm);
100 rdsv3_message_put(conn->c_xmit_rm);
101 conn
146 rdsv3_send_xmit(struct rdsv3_connection *conn) argument
449 rdsv3_send_acked_before(struct rdsv3_connection *conn, uint64_t seq) argument
559 rdsv3_send_get_message(struct rdsv3_connection *conn, struct rdsv3_rdma_op *op) argument
682 rdsv3_send_drop_acked(struct rdsv3_connection *conn, uint64_t ack, is_acked_func is_acked) argument
723 struct rdsv3_connection *conn; local
807 rdsv3_send_queue_rm(struct rdsv3_sock *rs, struct rdsv3_connection *conn, struct rdsv3_message *rm, uint16_be_t sport, uint16_be_t dport, int *queued) argument
942 struct rdsv3_connection *conn; local
1145 rdsv3_send_pong(struct rdsv3_connection *conn, uint16_be_t dport) argument
[all...]
/illumos-gate/usr/src/cmd/sendmail/libmilter/
H A Dmain.c98 static char *conn = NULL; variable
119 if (smfi == NULL || conn == NULL)
122 return mi_opensocket(conn, backlog, dbg, rmsocket, smfi);
180 if ((conn = (char *) malloc(l)) == NULL)
182 if (sm_strlcpy(conn, oconn, l) >= l)
224 if (conn == NULL)
242 if (mi_listener(conn, dbg, smfi, timeout, backlog) != MI_SUCCESS)
/illumos-gate/usr/src/cmd/isns/isnsd/
H A Dserver.c64 conn_arg_t *conn; local
70 conn = (conn_arg_t *)arg;
72 conn->out_packet.pdu = NULL;
73 conn->out_packet.sz = 0;
79 isns_rcv_pdu(conn->so, &pdu, &pdu_sz, ISNS_RCV_TIMEOUT) > 0) {
83 struct sockaddr_storage *ssp = &conn->ss;
146 conn->in_packet.pdu = combined_pdu;
147 conn->out_packet.pl = 0;
148 conn->ec = 0;
150 if (packet_split_verify(conn)
238 conn_arg_t *conn; local
[all...]
/illumos-gate/usr/src/lib/libsasl/lib/
H A Dseterror.c113 * if conn is NULL, function does nothing
115 void sasl_seterror(sasl_conn_t *conn, argument
145 if(!conn) {
163 gctx = conn->gctx;
167 if (conn->type == SASL_CONN_SERVER) {
168 utils = ((sasl_server_conn_t *)conn)->sparams->utils;
170 } else if (conn->type == SASL_CONN_CLIENT) {
171 utils = ((sasl_client_conn_t *)conn)->cparams->utils;
177 ret = utils->getcallback(conn, SASL_CB_LANGUAGE, &simple_cb,
190 _sasl_get_errorbuf(conn,
[all...]
H A Dcanonusr.c82 int _sasl_canon_user(sasl_conn_t *conn, argument
98 if(!conn) return SASL_BADPARAM;
102 user_buf = conn->authid_buf;
105 user_buf = conn->user_buf;
111 if(conn->type == SASL_CONN_SERVER) sconn = (sasl_server_conn_t *)conn;
112 else if(conn->type == SASL_CONN_CLIENT) cconn = (sasl_client_conn_t *)conn;
118 result = _sasl_getcallback(conn, SASL_CB_CANON_USER,
121 result = cuser_cb(conn, contex
[all...]
H A Dcheckpw.c150 static int auxprop_verify_password(sasl_conn_t *conn, argument
162 sasl_server_conn_t *sconn = (sasl_server_conn_t *)conn;
168 if (!conn || !userstr)
181 result = _sasl_canon_user(conn, userstr, 0,
183 &(conn->oparams));
263 int _sasl_auxprop_verify_apop(sasl_conn_t *conn, argument
278 sasl_server_conn_t *sconn = (sasl_server_conn_t *)conn;
282 if (!conn || !userstr || !challenge || !response)
283 PARAMERROR(conn)
291 _sasl_log(conn, SASL_LOG_ER
407 pwcheck_verify_password(sasl_conn_t *conn, const char *userid, const char *passwd, const char *service __attribute__((unused)), const char *user_realm __attribute__((unused))) argument
497 saslauthd_verify_password(sasl_conn_t *conn, const char *userid, const char *passwd, const char *service, const char *user_realm) argument
672 always_true(sasl_conn_t *conn, const char *userstr, const char *passwd __attribute__((unused)), const char *service __attribute__((unused)), const char *user_realm __attribute__((unused))) argument
[all...]
/illumos-gate/usr/src/cmd/lms/
H A DLMEConnectionCompat.cpp174 CompatConnection conn; local
175 conn.event = new Event();
176 conn.status = LMS_CONNECTION_STATUS_FAILED;
177 conn.connID = 0;
180 _compatPendingConnections[currReqID] = conn;
189 if (conn.event->wait(10000) == false) {
208 delete conn.event;
209 conn.event = NULL;
/illumos-gate/usr/src/lib/gss_mechs/mech_krb5/krb5/os/
H A Dchangepw.c102 static int kpasswd_sendto_msg_callback(struct conn_state *conn, void *callback_context, krb5_data* message) argument
118 if (getsockname(conn->fd, ss2sa(&local_addr), &addrlen) < 0) {
154 * to break us? Yes - provide 1 per conn-state / host...
/illumos-gate/usr/src/lib/libresolv2/common/isc/
H A Dev_connects.c195 if (acc->conn == this) {
240 evConn *conn = id.opaque; local
243 if ((conn->flags & EV_CONN_LISTEN) == 0) {
248 new->conn = conn;
250 new->fd = accept(conn->fd, &new->ra.sa, &new->ralen);
282 evConn *conn = uap; local
312 (*conn->func)(opaqueCtx, conn->uap, new, &la.sa, lalen, &ra.sa, ralen);
317 evConn *conn local
[all...]
/illumos-gate/usr/src/lib/libcommputil/common/
H A Dsdp_parse_helper.c146 sdp_free_connection(sdp_conn_t *conn) argument
150 while (conn != NULL) {
151 next_conn = conn->c_next;
152 if (conn->c_nettype != NULL)
153 free(conn->c_nettype);
154 if (conn->c_addrtype != NULL)
155 free(conn->c_addrtype);
156 if (conn->c_address != NULL)
157 free(conn->c_address);
158 free(conn);
[all...]
/illumos-gate/usr/src/cmd/fm/modules/SUNW,SPARC-Enterprise/event-transport/
H A Dex_dscp.c71 int (*cb_func)(fmd_hdl_t *hdl, etm_xport_conn_t conn, etm_cb_flag_t flag,
488 int (*cb_func)(fmd_hdl_t *hdl, etm_xport_conn_t conn, etm_cb_flag_t flag,
646 etm_xport_close(fmd_hdl_t *hdl, etm_xport_conn_t conn) argument
648 exs_conn_t *cp = (exs_conn_t *)conn;
670 etm_xport_read(fmd_hdl_t *hdl, etm_xport_conn_t conn, hrtime_t timeout, argument
677 exs_conn_t *cp = (exs_conn_t *)conn;
729 etm_xport_write(fmd_hdl_t *hdl, etm_xport_conn_t conn, hrtime_t timeout, argument
736 exs_conn_t *cp = (exs_conn_t *)conn;
70 exs_hdl_alloc(fmd_hdl_t *hdl, char *endpoint_id, int (*cb_func)(fmd_hdl_t *hdl, etm_xport_conn_t conn, etm_cb_flag_t flag, void *arg), void *cb_func_arg, int dom) argument
487 etm_xport_init(fmd_hdl_t *hdl, char *endpoint_id, int (*cb_func)(fmd_hdl_t *hdl, etm_xport_conn_t conn, etm_cb_flag_t flag, void *arg), void *cb_func_arg) argument
/illumos-gate/usr/src/cmd/sendmail/src/
H A Dsfsasl.c30 sasl_conn_t *conn; member in struct:sasl_obj
36 sasl_conn_t *conn; member in struct:sasl_info
117 so->conn = si->conn;
223 result = sasl_decode(so->conn, buf,
310 result = sasl_getprop(so->conn, SASL_MAXOUTBUF,
315 result = sasl_encode(so->conn, buf,
353 ** conn -- the sasl connection pointer
366 sfdcsasl(fin, fout, conn, tmo)
369 sasl_conn_t *conn;
[all...]
/illumos-gate/usr/src/cmd/hal/tools/
H A Dhal-device.c103 DBusConnection *conn; local
133 if (!(conn = dbus_bus_get(DBUS_BUS_SYSTEM, &error))) {
139 /* fprintf(stderr, "connected to: %s\n", dbus_bus_get_unique_name(conn)); */
141 if (!libhal_ctx_set_dbus_connection(hal_ctx, conn)) return 4;
164 dbus_connection_unref(conn);
H A Dlshal.c579 DBusConnection *conn; local
664 conn = dbus_bus_get (DBUS_BUS_SYSTEM, &error);
665 if (conn == NULL) {
673 dbus_connection_setup_with_g_main (conn, NULL);
679 if (!libhal_ctx_set_dbus_connection (hal_ctx, conn)) {
726 dbus_connection_unref (conn);
/illumos-gate/usr/src/uts/common/rpc/
H A Drdma_subr.c262 clist_register(CONN *conn, struct clist *cl, clist_dstsrc dstsrc) argument
275 status = RDMA_REGMEMSYNC(conn,
282 status = RDMA_REGMEMSYNC(conn,
292 (void) clist_deregister(conn, cl);
301 clist_deregister(CONN *conn, struct clist *cl) argument
309 (void) RDMA_DEREGMEMSYNC(conn,
320 (void) RDMA_DEREGMEMSYNC(conn,
339 clist_syncmem(CONN *conn, struct clist *cl, clist_dstsrc dstsrc) argument
349 status = RDMA_SYNCMEM(conn,
362 status = RDMA_SYNCMEM(conn,
395 rdma_clnt_postrecv(CONN *conn, uint32_t xid) argument
415 rdma_clnt_postrecv_remove(CONN *conn, uint32_t xid) argument
421 rdma_svc_postrecv(CONN *conn) argument
440 rdma_buf_alloc(CONN *conn, rdma_buf_t *rbuf) argument
446 rdma_buf_free(CONN *conn, rdma_buf_t *rbuf) argument
[all...]
/illumos-gate/usr/src/uts/common/sys/ib/clients/of/rdma/
H A Drdma_cm.h118 struct rdma_conn_param conn; member in union:rdma_cm_event::__anon7922

Completed in 257 milliseconds

1234