Home
last modified time | relevance | path

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

123456

/illumos-gate/usr/src/uts/common/io/ib/clients/rdsv3/
H A Dconnection.c66 struct rdsv3_connection *conn; in rdsv3_conn_lookup() local
73 conn = avl_find(&rdsv3_conn_hash, &conn_info, &place); in rdsv3_conn_lookup()
77 conn, NIPQUAD(laddr), NIPQUAD(faddr)); in rdsv3_conn_lookup()
82 return (conn); in rdsv3_conn_lookup()
92 rdsv3_conn_reset(struct rdsv3_connection *conn) in rdsv3_conn_reset() argument
96 NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr)); in rdsv3_conn_reset()
99 rdsv3_send_reset(conn); in rdsv3_conn_reset()
100 conn->c_flags = 0; in rdsv3_conn_reset()
122 struct rdsv3_connection *conn, *parent = NULL; in __rdsv3_conn_create() local
127 conn = rdsv3_conn_lookup(laddr, faddr, &pos); in __rdsv3_conn_create()
[all …]
H A Dthreads.c87 rdsv3_connect_complete(struct rdsv3_connection *conn) in rdsv3_connect_complete() argument
89 RDSV3_DPRINTF4("rdsv3_connect_complete", "Enter(conn: %p)", conn); in rdsv3_connect_complete()
91 if (!rdsv3_conn_transition(conn, RDSV3_CONN_CONNECTING, in rdsv3_connect_complete()
98 atomic_get(&conn->c_state)); in rdsv3_connect_complete()
100 conn->c_state = RDSV3_CONN_ERROR; in rdsv3_connect_complete()
101 rdsv3_queue_work(rdsv3_wq, &conn->c_down_w); in rdsv3_connect_complete()
107 conn, NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr)); in rdsv3_connect_complete()
109 conn->c_reconnect_jiffies = 0; in rdsv3_connect_complete()
110 conn->c_last_connect_jiffies = ddi_get_lbolt(); in rdsv3_connect_complete()
112 set_bit(0, &conn->c_map_queued); in rdsv3_connect_complete()
[all …]
H A Dsend.c73 rdsv3_send_reset(struct rdsv3_connection *conn) in rdsv3_send_reset() argument
78 RDSV3_DPRINTF4("rdsv3_send_reset", "Enter(conn: %p)", conn); in rdsv3_send_reset()
80 ASSERT(MUTEX_HELD(&conn->c_send_lock)); in rdsv3_send_reset()
82 if (conn->c_xmit_rm) { in rdsv3_send_reset()
83 rm = conn->c_xmit_rm; in rdsv3_send_reset()
91 rdsv3_ib_send_unmap_rdma(conn->c_transport_data, ro); in rdsv3_send_reset()
99 rdsv3_message_unmapped(conn->c_xmit_rm); in rdsv3_send_reset()
100 rdsv3_message_put(conn->c_xmit_rm); in rdsv3_send_reset()
101 conn->c_xmit_rm = NULL; in rdsv3_send_reset()
104 conn->c_xmit_sg = 0; in rdsv3_send_reset()
[all …]
H A Dib_cm.c60 rdsv3_ib_set_protocol(struct rdsv3_connection *conn, unsigned int version) in rdsv3_ib_set_protocol() argument
63 conn, version); in rdsv3_ib_set_protocol()
64 conn->c_version = version; in rdsv3_ib_set_protocol()
71 rdsv3_ib_set_flow_control(struct rdsv3_connection *conn, uint32_t credits) in rdsv3_ib_set_flow_control() argument
73 struct rdsv3_ib_connection *ic = conn->c_transport_data; in rdsv3_ib_set_flow_control()
76 "Enter: conn: %p credits: %d", conn, credits); in rdsv3_ib_set_flow_control()
81 rdsv3_ib_send_add_credits(conn, credits); in rdsv3_ib_set_flow_control()
88 conn, credits); in rdsv3_ib_set_flow_control()
125 rdsv3_ib_cm_connect_complete(struct rdsv3_connection *conn, in rdsv3_ib_cm_connect_complete() argument
129 struct rdsv3_ib_connection *ic = conn->c_transport_data; in rdsv3_ib_cm_connect_complete()
[all …]
H A Dloop.c72 rdsv3_loop_xmit(struct rdsv3_connection *conn, struct rdsv3_message *rm, in rdsv3_loop_xmit() argument
78 rdsv3_cong_map_updated(conn->c_fcong, ~(uint64_t)0); in rdsv3_loop_xmit()
83 RDSV3_DPRINTF4("rdsv3_loop_xmit", "Enter(conn: %p, rm: %p)", conn, rm); in rdsv3_loop_xmit()
85 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()
92 rdsv3_send_drop_acked(conn, ntohll(rm->m_inc.i_hdr.h_sequence), in rdsv3_loop_xmit()
97 RDSV3_DPRINTF4("rdsv3_loop_xmit", "Return(conn: %p, rm: %p)", conn, rm); in rdsv3_loop_xmit()
116 rdsv3_loop_xmit_cong_map(struct rdsv3_connection *conn, in rdsv3_loop_xmit_cong_map() argument
120 RDSV3_DPRINTF4("rdsv3_loop_xmit_cong_map", "Enter(conn: %p)", conn); in rdsv3_loop_xmit_cong_map()
123 ASSERT(map == conn->c_lcong); in rdsv3_loop_xmit_cong_map()
[all …]
H A Dib_recv.c113 rdsv3_ib_recv_refill_one(struct rdsv3_connection *conn, in rdsv3_ib_recv_refill_one() argument
116 struct rdsv3_ib_connection *ic = conn->c_transport_data; in rdsv3_ib_recv_refill_one()
122 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()
173 rdsv3_ib_recv_refill(struct rdsv3_connection *conn, int prefill) in rdsv3_ib_recv_refill() argument
175 struct rdsv3_ib_connection *ic = conn->c_transport_data; in rdsv3_ib_recv_refill()
182 conn, prefill); in rdsv3_ib_recv_refill()
184 if (prefill || rdsv3_conn_up(conn)) { in rdsv3_ib_recv_refill()
198 ret = rdsv3_ib_recv_refill_one(conn, recv); in rdsv3_ib_recv_refill()
[all …]
H A Dcong.c194 rdsv3_cong_add_conn(struct rdsv3_connection *conn) in rdsv3_cong_add_conn() argument
196 RDSV3_DPRINTF4("rdsv3_cong_add_conn", "Enter(conn: %p)", conn); in rdsv3_cong_add_conn()
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()
204 RDSV3_DPRINTF4("rdsv3_cong_add_conn", "Return(conn: %p)", conn); in rdsv3_cong_add_conn()
208 rdsv3_cong_remove_conn(struct rdsv3_connection *conn) in rdsv3_cong_remove_conn() argument
210 RDSV3_DPRINTF4("rdsv3_cong_remove_conn", "Enter(conn: %p)", conn); in rdsv3_cong_remove_conn()
213 conn, conn->c_lcong); in rdsv3_cong_remove_conn()
215 list_remove_node(&conn->c_map_item); in rdsv3_cong_remove_conn()
218 RDSV3_DPRINTF4("rdsv3_cong_remove_conn", "Return(conn: %p)", conn); in rdsv3_cong_remove_conn()
[all …]
H A Drdma_transport.c61 struct rdsv3_connection *conn = cm_id->context; in rdsv3_rdma_cm_event_handler() local
66 "conn %p id %p handling event %u", conn, cm_id, event->event); in rdsv3_rdma_cm_event_handler()
74 if (conn) { in rdsv3_rdma_cm_event_handler()
75 mutex_enter(&conn->c_cm_lock); in rdsv3_rdma_cm_event_handler()
82 if (rdsv3_conn_state(conn) == RDSV3_CONN_DISCONNECTING) { in rdsv3_rdma_cm_event_handler()
91 "disconnecting", conn, cm_id, event->event); 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()
[all …]
/illumos-gate/usr/src/lib/libsasl/lib/
H A Dcommon.c109 int (*_sasl_client_idle_hook)(sasl_conn_t *conn) = NULL;
110 int (*_sasl_server_idle_hook)(sasl_conn_t *conn) = NULL;
270 int sasl_encode(sasl_conn_t *conn, const char *input, in sasl_encode() argument
277 if(!conn) return SASL_BADPARAM; in sasl_encode()
279 PARAMERROR(conn); in sasl_encode()
289 result = sasl_encodev(conn, &tmp, 1, output, outputlen); in sasl_encode()
291 RETURN(conn, result); in sasl_encode()
296 int sasl_encodev(sasl_conn_t *conn, in sasl_encodev() argument
308 if (!conn) return SASL_BADPARAM; in sasl_encodev()
310 PARAMERROR(conn); in sasl_encodev()
[all …]
H A Dserver.c116 static int _sasl_checkpass(sasl_conn_t *conn,
148 int sasl_setpass(sasl_conn_t *conn, in sasl_setpass() argument
156 sasl_server_conn_t *s_conn = (sasl_server_conn_t *) conn; in sasl_setpass()
163 (conn == NULL) ? _sasl_gbl_ctx() : conn->gctx; in sasl_setpass()
172 if (!conn) return SASL_BADPARAM; in sasl_setpass()
173 if (conn->type != SASL_CONN_SERVER) PARAMERROR(conn); in sasl_setpass()
177 PARAMERROR(conn); in sasl_setpass()
180 result = _sasl_getcallback(conn, SASL_CB_SERVER_USERDB_SETPASS, in sasl_setpass()
183 tmpresult = setpass_cb(conn, context, user, pass, passlen, in sasl_setpass()
186 _sasl_log(conn, SASL_LOG_ERR, in sasl_setpass()
[all …]
H A Dclient.c319 client_idle(sasl_conn_t *conn) argument
323 _sasl_global_context_t *gctx = conn == NULL ? _sasl_gbl_ctx() : conn->gctx;
339 conn,
340 conn ? ((sasl_client_conn_t *)conn)->cparams : NULL))
583 sasl_client_conn_t *conn; local
618 conn = (sasl_client_conn_t *)*pconn;
620 conn->mech = NULL;
622 conn->cparams=sasl_ALLOC(sizeof(sasl_client_params_t));
623 if (conn->cparams==NULL)
625 memset(conn->cparams,0,sizeof(sasl_client_params_t));
[all …]
H A Dsaslint.h73 #define RETURN(conn, val) { if(conn && (val) < SASL_OK) \ argument
74 (conn)->error_code = (val); \
77 #define MEMERROR(conn) {\ argument
78 if(conn) sasl_seterror( (conn), 0, \
80 RETURN(conn, SASL_NOMEM) }
81 #define PARAMERROR(conn) {\ argument
82 if(conn) sasl_seterror( (conn), SASL_NOLOG, \
84 RETURN(conn, SASL_BADPARAM) }
85 #define INTERROR(conn, val) {\ argument
86 if(conn) sasl_seterror( (conn), 0, \
[all …]
H A Dcheckpw.c149 static int auxprop_verify_password(sasl_conn_t *conn, in auxprop_verify_password() argument
161 sasl_server_conn_t *sconn = (sasl_server_conn_t *)conn; in auxprop_verify_password()
167 if (!conn || !userstr) in auxprop_verify_password()
180 result = _sasl_canon_user(conn, userstr, 0, in auxprop_verify_password()
182 &(conn->oparams)); in auxprop_verify_password()
262 int _sasl_auxprop_verify_apop(sasl_conn_t *conn, in _sasl_auxprop_verify_apop() argument
277 sasl_server_conn_t *sconn = (sasl_server_conn_t *)conn; in _sasl_auxprop_verify_apop()
281 if (!conn || !userstr || !challenge || !response) in _sasl_auxprop_verify_apop()
282 PARAMERROR(conn) in _sasl_auxprop_verify_apop()
290 _sasl_log(conn, SASL_LOG_ERR, "could not perform password lookup"); in _sasl_auxprop_verify_apop()
[all …]
/illumos-gate/usr/src/uts/common/rpc/
H A Drpc_rdma.h342 typedef struct conn { struct
349 struct conn *c_next; /* next in list of connections */ argument
350 struct conn *c_prev; /* prev in list of connections */ argument
370 CONN *conn; member
456 #define RDMA_GET_CONN(rdma_ops, saddr, daddr, addr_type, handle, conn) \ argument
457 (*(rdma_ops)->rdma_get_conn)(saddr, daddr, addr_type, handle, conn)
459 #define RDMA_REL_CONN(conn) \ argument
460 (*(conn)->c_rdmamod->rdma_ops->rdma_rel_conn)(conn)
462 #define RDMA_REGMEM(conn, adsp, buff, len, handle) \ argument
463 (*(conn)->c_rdmamod->rdma_ops->rdma_regmem)(conn, adsp, \
[all …]
H A Drpcib.c120 struct netbuf *d_svcaddr, CONN **conn);
270 static rdma_stat rib_disconnect(CONN *conn);
273 static rdma_stat rib_registermem(CONN *conn, caddr_t adsp, caddr_t buf,
275 static rdma_stat rib_deregistermem(CONN *conn, caddr_t buf,
281 static rdma_stat rib_registermemsync(CONN *conn, caddr_t adsp, caddr_t buf,
284 static rdma_stat rib_deregistermemsync(CONN *conn, caddr_t buf,
286 static rdma_stat rib_syncmem(CONN *conn, RIB_SYNCMEM_HANDLE shandle,
289 static rdma_stat rib_reg_buf_alloc(CONN *conn, rdma_buf_t *rdbuf);
291 static void rib_reg_buf_free(CONN *conn, rdma_buf_t *rdbuf);
294 static void rib_rbuf_free(CONN *conn, int ptype, void *buf);
[all …]
/illumos-gate/usr/src/cmd/isns/isnsd/
H A Dfunc.c100 packet_get_source(conn_arg_t *conn) in packet_get_source() argument
104 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_get_source()
115 conn->in_packet.source = source; in packet_get_source()
133 packet_get_key(conn_arg_t *conn) in packet_get_key() argument
137 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_get_key()
143 conn->in_packet.key = key; in packet_get_key()
144 conn->in_packet.key_len = key_len; in packet_get_key()
161 packet_get_operand(conn_arg_t *conn) in packet_get_operand() argument
165 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_get_operand()
171 conn->in_packet.op = op; in packet_get_operand()
[all …]
H A Dserver.c64 conn_arg_t *conn; in isns_connection() local
70 conn = (conn_arg_t *)arg; in isns_connection()
72 conn->out_packet.pdu = NULL; in isns_connection()
73 conn->out_packet.sz = 0; in isns_connection()
79 isns_rcv_pdu(conn->so, &pdu, &pdu_sz, ISNS_RCV_TIMEOUT) > 0) { in isns_connection()
83 struct sockaddr_storage *ssp = &conn->ss; in isns_connection()
146 conn->in_packet.pdu = combined_pdu; in isns_connection()
147 conn->out_packet.pl = 0; in isns_connection()
148 conn->ec = 0; in isns_connection()
150 if (packet_split_verify(conn) == 0) { in isns_connection()
[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()
206 handlers = l9p_versions[conn->lc_version].handlers; in l9p_dispatch_request()
207 n = (size_t)l9p_versions[conn->lc_version].n_handlers; in l9p_dispatch_request()
222 l9p_describe_fcall(&req->lr_req, conn->lc_version, sb); in l9p_dispatch_request()
368 struct l9p_connection *conn = req->lr_conn; in l9p_respond() local
382 if (conn->lc_version == L9P_2000L) { in l9p_respond()
394 l9p_describe_fcall(&req->lr_resp, conn->lc_version, sb); in l9p_respond()
418 l9p_pufcall(&req->lr_resp_msg, &req->lr_resp, conn->lc_version); in l9p_respond()
420 ht_remove(&conn->lc_requests, req->lr_req.hdr.tag); in l9p_respond()
[all …]
H A Dconnection.c56 l9p_connection_init(struct l9p_server *server, struct l9p_connection **conn) in l9p_connection_init() argument
61 assert(conn != NULL); in l9p_connection_init()
75 *conn = newconn; in l9p_connection_init()
81 l9p_connection_free(struct l9p_connection *conn) in l9p_connection_free() argument
84 LIST_REMOVE(conn, lc_link); in l9p_connection_free()
85 free(conn); in l9p_connection_free()
89 l9p_connection_recv(struct l9p_connection *conn, const struct iovec *iov, in l9p_connection_recv() argument
97 req->lr_conn = conn; in l9p_connection_recv()
105 if (l9p_pufcall(&req->lr_req_msg, &req->lr_req, conn->lc_version) != 0) { in l9p_connection_recv()
112 if (ht_add(&conn->lc_requests, req->lr_req.hdr.tag, req)) { in l9p_connection_recv()
[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,
45 DBusHandlerResult device_get_property_type (DBusConnection *conn,
47 DBusHandlerResult device_set_property (DBusConnection *conn,
49 DBusHandlerResult device_add_capability (DBusConnection *conn,
51 DBusHandlerResult device_remove_capability (DBusConnection *conn,
[all …]
/illumos-gate/usr/src/lib/gss_mechs/mech_krb5/krb5/os/
H A Dsendto_kdc.c648 static int service_tcp_fd (struct conn_state *conn,
650 static int service_udp_fd (struct conn_state *conn,
873 maybe_send (struct conn_state *conn, in maybe_send() argument
881 dprint("maybe_send(@%p) state=%s type=%s\n", conn, in maybe_send()
883 state_strings[conn->state], in maybe_send()
884 conn->is_udp ? "udp" : "tcp"); in maybe_send()
885 if (conn->state == INITIALIZING) in maybe_send()
886 return start_connection(conn, selstate, callback_info, callback_buffer); in maybe_send()
889 if (conn->state == FAILED) { in maybe_send()
894 if (conn->addr->ai_socktype == SOCK_STREAM) { in maybe_send()
[all …]
/illumos-gate/usr/src/cmd/krb5/krb5kdc/
H A Dnetwork.c337 struct connection *conn; in delete_fd() local
340 FOREACH_ELT(connections, i, conn) in delete_fd()
341 if (conn == xconn) { in delete_fd()
726 static void process_packet(struct connection *conn, const char *prog, in process_packet() argument
738 int port_fd = conn->fd; in process_packet()
795 static void accept_tcp_connection(struct connection *conn, const char *prog, in accept_tcp_connection() argument
806 s = accept(conn->fd, addr, &addrlen); in accept_tcp_connection()
891 kill_tcp_connection(struct connection *conn) in kill_tcp_connection() argument
893 if (conn->u.tcp.response) in kill_tcp_connection()
894 krb5_free_data(kdc_context, conn->u.tcp.response); in kill_tcp_connection()
[all …]
/illumos-gate/usr/src/uts/common/inet/
H A Dsdp_itf.h84 extern int sdp_bind(struct sdp_conn_struct_t *conn, struct sockaddr *addr,
86 extern void sdp_close(struct sdp_conn_struct_t *conn);
87 extern int sdp_connect(struct sdp_conn_struct_t *conn,
93 extern int sdp_disconnect(struct sdp_conn_struct_t *conn, int flags);
94 extern int sdp_shutdown(struct sdp_conn_struct_t *conn, int flag);
95 extern int sdp_polldata(struct sdp_conn_struct_t *conn, int flag);
96 extern int sdp_get_opt(struct sdp_conn_struct_t *conn, int level, int opt,
98 extern int sdp_getpeername(struct sdp_conn_struct_t *conn,
100 extern int sdp_getsockname(struct sdp_conn_struct_t *conn,
103 extern int sdp_listen(struct sdp_conn_struct_t *conn, int backlog);
[all …]
/illumos-gate/usr/src/lib/libsasl/include/
H A Dsasl.h552 typedef int sasl_getsecret_t(sasl_conn_t *conn, void *context, int id,
609 typedef int sasl_authorize_t(sasl_conn_t *conn,
632 typedef int sasl_server_userdb_checkpass_t(sasl_conn_t *conn,
648 typedef int sasl_server_userdb_setpass_t(sasl_conn_t *conn,
685 typedef int sasl_canon_user_t(sasl_conn_t *conn,
743 LIBSASL_API const char *sasl_errdetail(sasl_conn_t *conn);
762 LIBSASL_API void sasl_seterror(sasl_conn_t *conn, unsigned flags,
775 LIBSASL_API int sasl_getprop(sasl_conn_t *conn, int propnum,
809 LIBSASL_API int sasl_setprop(sasl_conn_t *conn,
828 LIBSASL_API int sasl_idle(sasl_conn_t *conn);
[all …]
/illumos-gate/usr/src/uts/common/sys/ib/clients/rdsv3/
H A Drdsv3.h360 int (*conn_alloc)(struct rdsv3_connection *conn, int gfp);
362 int (*conn_connect)(struct rdsv3_connection *conn);
363 void (*conn_shutdown)(struct rdsv3_connection *conn);
364 void (*xmit_prepare)(struct rdsv3_connection *conn);
365 void (*xmit_complete)(struct rdsv3_connection *conn);
366 int (*xmit)(struct rdsv3_connection *conn, struct rdsv3_message *rm,
368 int (*xmit_cong_map)(struct rdsv3_connection *conn,
370 int (*xmit_rdma)(struct rdsv3_connection *conn,
372 int (*recv)(struct rdsv3_connection *conn);
380 void (*cm_connect_complete)(struct rdsv3_connection *conn,
[all …]

123456