Home
last modified time | relevance | path

Searched refs:conn (Results 1 – 25 of 135) sorted by relevance

123456

/illumos-gate/usr/src/uts/common/io/ib/clients/rdsv3/
H A Dthreads.c107 conn, NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr)); in rdsv3_connect_complete()
144 conn, NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr), in rdsv3_queue_reconnect()
158 rand % conn->c_reconnect_jiffies, conn->c_reconnect_jiffies, in rdsv3_queue_reconnect()
159 conn, NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr)); in rdsv3_queue_reconnect()
164 conn->c_reconnect_jiffies = min(conn->c_reconnect_jiffies * 2, in rdsv3_queue_reconnect()
180 ret = conn->c_trans->conn_connect(conn); in rdsv3_connect_worker()
184 "ret %d", conn, NIPQUAD(conn->c_laddr), in rdsv3_connect_worker()
189 conn, NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr), ret); in rdsv3_connect_worker()
198 rdsv3_conn_drop(conn); in rdsv3_connect_worker()
244 ret = conn->c_trans->recv(conn); in rdsv3_recv_worker()
[all …]
H A Dconnection.c82 return (conn); in rdsv3_conn_lookup()
96 NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr)); in rdsv3_conn_reset()
128 if (conn && in __rdsv3_conn_create()
142 if (conn) in __rdsv3_conn_create()
149 if (!conn) { in __rdsv3_conn_create()
310 conn->c_trans->conn_shutdown(conn); in rdsv3_conn_shutdown()
364 conn, NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr)); in rdsv3_conn_destroy()
399 conn->c_trans->conn_free(conn->c_transport_data); in rdsv3_conn_destroy()
452 conn->c_laddr, conn->c_faddr, 0); in rdsv3_conn_message_info()
457 conn = AVL_NEXT(&rdsv3_conn_hash, conn); in rdsv3_conn_message_info()
[all …]
H A Dsend.c104 conn->c_xmit_sg = 0; in rdsv3_send_reset()
125 list_move_tail(&conn->c_send_queue, &conn->c_retrans); in rdsv3_send_reset()
182 conn->c_trans->xmit_prepare(conn); in rdsv3_send_xmit()
198 ret = conn->c_trans->xmit_cong_map(conn, conn->c_lcong, in rdsv3_send_xmit()
324 ret = conn->c_trans->xmit_rdma(conn, rm->m_rdma_op); in rdsv3_send_xmit()
337 ret = conn->c_trans->xmit(conn, rm, in rdsv3_send_xmit()
375 conn->c_trans->xmit_complete(conn); in rdsv3_send_xmit()
416 conn, ret); in rdsv3_send_xmit()
749 conn = NULL; in rdsv3_send_drop_to()
773 if (conn) in rdsv3_send_drop_to()
[all …]
H A Dib_cm.c63 conn, version); in rdsv3_ib_set_protocol()
88 conn, credits); in rdsv3_ib_set_flow_control()
229 conn, event); in rdsv3_ib_cm_connect_complete()
311 struct rdsv3_connection *conn = ic->conn; in rdsv3_ib_snd_tasklet_fn() local
372 struct rdsv3_connection *conn = ic->conn; in rdsv3_ib_tasklet_fn() local
454 if (conn) { in rdsv3_ib_qp_event_handler()
471 conn, event); in rdsv3_ib_qp_event_handler()
739 conn = NULL; in rdsv3_ib_cm_handle_connect()
756 conn); in rdsv3_ib_cm_handle_connect()
1115 ic->conn = conn; in rdsv3_ib_conn_alloc()
[all …]
H A Dloop.c85 rdsv3_inc_init(&rm->m_inc, conn, conn->c_laddr); in rdsv3_loop_xmit()
89 rdsv3_recv_incoming(conn, conn->c_laddr, conn->c_faddr, &rm->m_inc, in rdsv3_loop_xmit()
123 ASSERT(map == conn->c_lcong); in rdsv3_loop_xmit_cong_map()
125 rdsv3_cong_map_updated(conn->c_fcong, ~(uint64_t)0); in rdsv3_loop_xmit_cong_map()
135 rdsv3_loop_recv(struct rdsv3_connection *conn) in rdsv3_loop_recv() argument
142 struct rdsv3_connection *conn; member
164 lc->conn = conn; in rdsv3_loop_conn_alloc()
165 conn->c_transport_data = lc; in rdsv3_loop_conn_alloc()
188 rdsv3_connect_complete(conn); in rdsv3_loop_conn_connect()
215 ASSERT(!lc->conn->c_passive); in rdsv3_loop_exit()
[all …]
H A Dib_recv.c122 conn, recv); in rdsv3_ib_recv_refill_one()
136 rdsv3_inc_init(&recv->r_ibinc->ii_inc, conn, conn->c_faddr); in rdsv3_ib_recv_refill_one()
152 conn, recv); in rdsv3_ib_recv_refill_one()
182 conn, prefill); in rdsv3_ib_recv_refill()
234 conn, posted); in rdsv3_ib_recv_refill()
610 conn, ibinc); in rdsv3_ib_cong_recv()
616 map = conn->c_fcong; in rdsv3_ib_cong_recv()
673 conn, ibinc); in rdsv3_ib_cong_recv()
778 rdsv3_recv_incoming(conn, conn->c_faddr, conn->c_laddr, in rdsv3_ib_process_recv()
806 struct rdsv3_connection *conn = ic->conn; in rdsv3_ib_recv_cqe_handler() local
[all …]
H A Drdma_transport.c61 struct rdsv3_connection *conn = cm_id->context; in rdsv3_rdma_cm_event_handler() local
74 if (conn) { in rdsv3_rdma_cm_event_handler()
75 mutex_enter(&conn->c_cm_lock); in rdsv3_rdma_cm_event_handler()
113 trans->cm_connect_complete(conn, event); in rdsv3_rdma_cm_event_handler()
123 if (conn) in rdsv3_rdma_cm_event_handler()
124 rdsv3_conn_drop(conn); in rdsv3_rdma_cm_event_handler()
131 if (conn) { in rdsv3_rdma_cm_event_handler()
135 NIPQUAD(conn->c_faddr)); in rdsv3_rdma_cm_event_handler()
136 rdsv3_conn_drop(conn); in rdsv3_rdma_cm_event_handler()
149 if (conn) in rdsv3_rdma_cm_event_handler()
[all …]
H A Dcong.c194 rdsv3_cong_add_conn(struct rdsv3_connection *conn) in rdsv3_cong_add_conn() argument
199 conn, conn->c_lcong); in rdsv3_cong_add_conn()
201 list_insert_tail(&conn->c_lcong->m_conn_list, conn); in rdsv3_cong_add_conn()
213 conn, conn->c_lcong); in rdsv3_cong_remove_conn()
215 list_remove_node(&conn->c_map_item); in rdsv3_cong_remove_conn()
224 conn->c_lcong = rdsv3_cong_from_addr(conn->c_laddr); in rdsv3_cong_get_maps()
225 conn->c_fcong = rdsv3_cong_from_addr(conn->c_faddr); in rdsv3_cong_get_maps()
227 if (!(conn->c_lcong && conn->c_fcong)) in rdsv3_cong_get_maps()
236 struct rdsv3_connection *conn; in rdsv3_cong_queue_updates() local
245 (void) rdsv3_send_xmit(conn); in rdsv3_cong_queue_updates()
[all …]
/illumos-gate/usr/src/lib/libsasl/lib/
H A Dcommon.c353 result = conn->oparams.encode(conn->context, invec, numiov, in sasl_encodev()
544 memset(&conn->props, 0, sizeof(conn->props)); in _sasl_conn_init()
548 conn->errdetail_buf = conn->error_buf = NULL; in _sasl_conn_init()
549 conn->errdetail_buf_len = conn->error_buf_len = 150; in _sasl_conn_init()
887 if (!conn) in sasl_setprop()
1562 if (!conn) in _sasl_proxy_policy()
1614 if (conn && conn->callbacks) { in _sasl_getcallback()
1631 if (conn && conn->global_callbacks && conn->global_callbacks->callbacks) { in _sasl_getcallback()
1957 utils->conn = conn; in _sasl_alloc_utils()
1961 if (conn) { in _sasl_alloc_utils()
[all …]
H A Dserver.c163 (conn == NULL) ? _sasl_gbl_ctx() : conn->gctx; in sasl_setpass()
173 if (conn->type != SASL_CONN_SERVER) PARAMERROR(conn); in sasl_setpass()
1488 if (conn->props.min_ssf < conn->external.ssf) {
1491 minssf = conn->props.min_ssf - conn->external.ssf;
1686 (conn == NULL) ? _sasl_gbl_ctx() : conn->gctx;
1927 (conn == NULL) ? _sasl_gbl_ctx() : conn->gctx;
1977 conn->oparams.maxoutbuf = conn->props.maxbufsize;
2284 (conn == NULL) ? _sasl_gbl_ctx() : conn->gctx;
2308 if (conn->props.min_ssf > conn->external.ssf)
2378 (conn == NULL) ? _sasl_gbl_ctx() : conn->gctx;
[all …]
H A Dclient.c339 conn,
340 conn ? ((sasl_client_conn_t *)conn)->cparams : NULL))
762 PARAMERROR(conn);
786 if(conn->props.min_ssf < conn->external.ssf) {
789 minssf = conn->props.min_ssf - conn->external.ssf;
843 if ((conn->props.min_ssf <= conn->external.ssf) &&
1055 conn->oparams.maxoutbuf = conn->props.maxbufsize;
1121 if(conn->type != SASL_CONN_CLIENT) PARAMERROR(conn);
1124 PARAMERROR(conn);
1141 if(conn->props.min_ssf < conn->external.ssf) {
[all …]
H A Dsaslint.h73 #define RETURN(conn, val) { if(conn && (val) < SASL_OK) \ argument
77 #define MEMERROR(conn) {\ argument
78 if(conn) sasl_seterror( (conn), 0, \
82 if(conn) sasl_seterror( (conn), SASL_NOLOG, \
86 if(conn) sasl_seterror( (conn), 0, \
89 RETURN(conn, (val)) }
91 #define MEMERROR(conn) {\ argument
92 if(conn) _sasl_log((conn), SASL_LOG_WARN, "Out of Memory"); \
95 if(conn) _sasl_log((conn), SASL_LOG_WARN, "Parameter error"); \
98 if(conn) _sasl_log((conn), SASL_LOG_ERR, "Internal Error: %d", (val)); \
[all …]
/illumos-gate/usr/src/uts/common/rpc/
H A Drpc_rdma.h370 CONN *conn; member
460 (*(conn)->c_rdmamod->rdma_ops->rdma_rel_conn)(conn)
463 (*(conn)->c_rdmamod->rdma_ops->rdma_regmem)(conn, adsp, \
478 (*(conn)->c_rdmamod->rdma_ops->rdma_syncmem)(conn, handle, \
482 (*(conn)->c_rdmamod->rdma_ops->rdma_buf_alloc)(conn, rbuf)
485 (*(conn)->c_rdmamod->rdma_ops->rdma_buf_free)(conn, rbuf)
488 (*(conn)->c_rdmamod->rdma_ops->rdma_send)(conn, sendlist, xid)
500 (*(conn)->c_rdmamod->rdma_ops->rdma_svc_recvbuf)(conn, cl)
503 (*(conn)->c_rdmamod->rdma_ops->rdma_recv)(conn, recvlist, xid)
506 (*(conn)->c_rdmamod->rdma_ops->rdma_read)(conn, cl, wait)
[all …]
H A Drpcib.c1009 CONN *conn; in rib_clnt_scq_handler() local
1103 CONN *conn; in rib_svc_scq_handler() local
1322 CONN *conn; in rib_svc_rcq_handler() local
1417 rdp->conn = conn; in rib_svc_rcq_handler()
1584 conn->c_raddr.len = conn->c_raddr.maxlen = raddr->len; in rib_clnt_create_chan()
2034 cv_wait(&conn->c_cv, &conn->c_lock); in rib_disconnect_channel()
2085 kmem_free(conn->c_raddr.buf, conn->c_raddr.len); in rib_disconnect_channel()
2088 kmem_free(conn->c_laddr.buf, conn->c_laddr.len); in rib_disconnect_channel()
3077 conn->c_addrmask.maxlen = conn->c_addrmask.len = in rib_srv_cm_handler()
3115 conn->c_addrmask.maxlen = conn->c_addrmask.len = in rib_srv_cm_handler()
[all …]
/illumos-gate/usr/src/lib/fm/libldom/sparc/
H A Dldom_xmpp_client.c251 conn->fd = sock; in xmpp_connect()
254 conn->parser = xmlCreatePushParserCtxt(&xml_handler, (void *) conn, in xmpp_connect()
267 conn->fd = -1; in xmpp_close()
271 conn->parser = NULL; in xmpp_close()
275 conn->ssl = NULL; in xmpp_close()
345 xmpp_conn_t conn; in xmpp_client_thr() local
364 xmpp_close(&conn); in xmpp_client_thr()
423 xmpp_close(&conn); in xmpp_client_thr()
557 xmpp_conn_t conn; in xmpp_start() local
571 xmpp_close(&conn); in xmpp_start()
[all …]
/illumos-gate/usr/src/cmd/isns/isnsd/
H A Dfunc.c288 conn->ec = ec; in packet_split_verify()
773 conn->ec = ec;
946 conn->ec = ec;
1081 conn->ec = ec;
1204 conn->ec = ec;
1262 conn->ec = ec;
1304 conn->ec = ec;
1598 conn->ec = ec;
1797 conn->ec = ec;
1914 conn->ec = ec;
[all …]
H A Dserver.c64 conn_arg_t *conn; in isns_connection() local
148 conn->ec = 0; in isns_connection()
152 status = conn->handler(conn); in isns_connection()
153 conn->ec = cache_unlock(conn->lock, conn->ec); in isns_connection()
168 &conn->ss; in isns_connection()
211 (void) free(conn); in isns_connection()
238 conn_arg_t *conn; in isns_port_watcher() local
287 if (conn == NULL) { in isns_port_watcher()
292 ssp = &conn->ss; in isns_port_watcher()
316 conn->so = f; in isns_port_watcher()
[all …]
/illumos-gate/usr/src/lib/lib9p/common/
H A Drequest.c195 struct l9p_connection *conn; in l9p_dispatch_request() local
203 conn = req->lr_conn; in l9p_dispatch_request()
429 conn->lc_lt.lt_aux); in l9p_respond()
443 iosize, conn->lc_lt.lt_aux); in l9p_respond()
608 conn->lc_msize = MIN(req->lr_req.version.msize, conn->lc_msize); in l9p_dispatch_tversion()
609 conn->lc_max_io_size = conn->lc_msize - 24; in l9p_dispatch_tversion()
642 be = conn->lc_server->ls_backend; in l9p_dispatch_tattach()
647 if (conn->lc_version == L9P_2000) in l9p_dispatch_tattach()
678 be = conn->lc_server->ls_backend; in l9p_dispatch_tclunk()
714 be = conn->lc_server->ls_backend; in l9p_dispatch_tcreate()
[all …]
H A Dconnection.c61 assert(conn != NULL); in l9p_connection_init()
75 *conn = newconn; in l9p_connection_init()
84 LIST_REMOVE(conn, lc_link); in l9p_connection_free()
85 free(conn); in l9p_connection_free()
97 req->lr_conn = conn; in l9p_connection_recv()
123 conn->lc_lt.lt_aux); in l9p_connection_recv()
152 ht_iter(&conn->lc_requests, &iter); in l9p_connection_close()
168 ht_iter(&conn->lc_files, &iter); in l9p_connection_close()
176 ht_destroy(&conn->lc_requests); in l9p_connection_close()
177 ht_destroy(&conn->lc_files); in l9p_connection_close()
[all …]
/illumos-gate/usr/src/cmd/hal/hald/
H A Dhald_dbus.h33 DBusHandlerResult manager_get_all_devices (DBusConnection *conn,
35 DBusHandlerResult manager_find_device_string_match (DBusConnection *conn,
37 DBusHandlerResult manager_find_device_by_capability (DBusConnection *conn,
39 DBusHandlerResult manager_device_exists (DBusConnection *conn,
41 DBusHandlerResult device_get_all_properties (DBusConnection *conn,
43 DBusHandlerResult device_get_property (DBusConnection *conn,
63 DBusHandlerResult manager_new_device (DBusConnection *conn,
65 DBusHandlerResult manager_commit_to_gdl (DBusConnection *conn,
67 DBusHandlerResult manager_remove (DBusConnection *conn,
69 DBusHandlerResult merge_properties (DBusConnection *conn,
[all …]
/illumos-gate/usr/src/lib/gss_mechs/mech_krb5/krb5/os/
H A Dsendto_kdc.c926 conn->err = err; in kill_conn()
1030 ((conn->x.out.sg_count == 2 ? SG_LEN(&conn->x.out.sgp[1]) : 0) in service_tcp_fd()
1033 conn->fd); in service_tcp_fd()
1034 nwritten = SOCKET_WRITEV(conn->fd, conn->x.out.sgp, in service_tcp_fd()
1091 (int) conn->x.in.n_left, conn->fd); in service_tcp_fd()
1092 nread = SOCKET_READ(conn->fd, conn->x.in.pos, conn->x.in.n_left); in service_tcp_fd()
1109 conn->x.in.bufsizebytes + conn->x.in.bufsizebytes_read, in service_tcp_fd()
1129 conn->x.in.bufsize = conn->x.in.n_left = len; in service_tcp_fd()
1130 conn->x.in.buf = conn->x.in.pos = malloc(len); in service_tcp_fd()
1160 nread = recv(conn->fd, conn->x.in.buf, conn->x.in.bufsize, 0); in service_udp_fd()
[all …]
/illumos-gate/usr/src/cmd/krb5/krb5kdc/
H A Dnetwork.c951 nwrote = SOCKET_WRITEV(conn->fd, conn->u.tcp.sgp, conn->u.tcp.sgnum, in process_tcp_connection()
994 conn->u.tcp.buffer + conn->u.tcp.offset, len); in process_tcp_connection()
1008 if (conn->u.tcp.msglen > conn->u.tcp.bufsiz - 4) { in process_tcp_connection()
1012 conn->u.tcp.addrbuf, (unsigned long) conn->u.tcp.msglen, in process_tcp_connection()
1030 len = conn->u.tcp.msglen - (conn->u.tcp.offset - 4); in process_tcp_connection()
1032 conn->u.tcp.buffer + conn->u.tcp.offset, len); in process_tcp_connection()
1040 if (conn->u.tcp.offset < conn->u.tcp.msglen + 4) in process_tcp_connection()
1056 SG_SET(&conn->u.tcp.sgbuf[1], conn->u.tcp.response->data, in process_tcp_connection()
1058 conn->u.tcp.sgp = conn->u.tcp.sgbuf; in process_tcp_connection()
1075 conn->service(conn, prog, selflags); in service_conn()
[all …]
/illumos-gate/usr/src/uts/common/inet/
H A Dsdp_itf.h86 extern int sdp_bind(struct sdp_conn_struct_t *conn, struct sockaddr *addr,
88 extern void sdp_close(struct sdp_conn_struct_t *conn);
89 extern int sdp_connect(struct sdp_conn_struct_t *conn,
95 extern int sdp_disconnect(struct sdp_conn_struct_t *conn, int flags);
96 extern int sdp_shutdown(struct sdp_conn_struct_t *conn, int flag);
97 extern int sdp_polldata(struct sdp_conn_struct_t *conn, int flag);
100 extern int sdp_getpeername(struct sdp_conn_struct_t *conn,
102 extern int sdp_getsockname(struct sdp_conn_struct_t *conn,
105 extern int sdp_listen(struct sdp_conn_struct_t *conn, int backlog);
106 extern int sdp_send(struct sdp_conn_struct_t *conn, struct msghdr *msg,
[all …]
/illumos-gate/usr/src/lib/libsasl/include/
H A Dsasl.h611 typedef int sasl_authorize_t(sasl_conn_t *conn,
687 typedef int sasl_canon_user_t(sasl_conn_t *conn,
811 LIBSASL_API int sasl_setprop(sasl_conn_t *conn,
830 LIBSASL_API int sasl_idle(sasl_conn_t *conn);
1028 LIBSASL_API int sasl_listmech(sasl_conn_t *conn,
1100 LIBSASL_API int sasl_checkapop(sasl_conn_t *conn,
1118 LIBSASL_API int sasl_checkpass(sasl_conn_t *conn,
1163 LIBSASL_API int sasl_setpass(sasl_conn_t *conn,
1239 LIBSASL_API int sasl_encode(sasl_conn_t *conn,
1252 LIBSASL_API int sasl_encodev(sasl_conn_t *conn,
[all …]
/illumos-gate/usr/src/uts/common/sys/ib/clients/rdsv3/
H A Drdsv3.h362 int (*conn_connect)(struct rdsv3_connection *conn);
364 void (*xmit_prepare)(struct rdsv3_connection *conn);
368 int (*xmit_cong_map)(struct rdsv3_connection *conn,
370 int (*xmit_rdma)(struct rdsv3_connection *conn,
372 int (*recv)(struct rdsv3_connection *conn);
562 void rdsv3_conn_drop(struct rdsv3_connection *conn);
576 rdsv3_conn_state(struct rdsv3_connection *conn) in rdsv3_conn_state() argument
578 return (atomic_get(&conn->c_state)); in rdsv3_conn_state()
582 rdsv3_conn_up(struct rdsv3_connection *conn) in rdsv3_conn_up() argument
588 rdsv3_conn_connecting(struct rdsv3_connection *conn) in rdsv3_conn_connecting() argument
[all …]

123456