Home
last modified time | relevance | path

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

123456

/titanic_41/usr/src/uts/common/io/ib/clients/rdsv3/
H A Dthreads.c86 rdsv3_connect_complete(struct rdsv3_connection *conn) in rdsv3_connect_complete() argument
88 RDSV3_DPRINTF4("rdsv3_connect_complete", "Enter(conn: %p)", conn); in rdsv3_connect_complete()
90 if (!rdsv3_conn_transition(conn, RDSV3_CONN_CONNECTING, in rdsv3_connect_complete()
97 atomic_get(&conn->c_state)); in rdsv3_connect_complete()
99 conn->c_state = RDSV3_CONN_ERROR; in rdsv3_connect_complete()
100 rdsv3_queue_work(rdsv3_wq, &conn->c_down_w); in rdsv3_connect_complete()
106 conn, NIPQUAD(conn->c_laddr), NIPQUAD(conn->c_faddr)); in rdsv3_connect_complete()
108 conn->c_reconnect_jiffies = 0; in rdsv3_connect_complete()
109 conn->c_last_connect_jiffies = ddi_get_lbolt(); in rdsv3_connect_complete()
111 set_bit(0, &conn->c_map_queued); in rdsv3_connect_complete()
[all …]
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 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.c71 rdsv3_loop_xmit(struct rdsv3_connection *conn, struct rdsv3_message *rm, in rdsv3_loop_xmit() argument
77 rdsv3_cong_map_updated(conn->c_fcong, ~(uint64_t)0); in rdsv3_loop_xmit()
82 RDSV3_DPRINTF4("rdsv3_loop_xmit", "Enter(conn: %p, rm: %p)", conn, rm); in rdsv3_loop_xmit()
84 rdsv3_inc_init(&rm->m_inc, conn, conn->c_laddr); in rdsv3_loop_xmit()
88 rdsv3_recv_incoming(conn, conn->c_laddr, conn->c_faddr, &rm->m_inc, in rdsv3_loop_xmit()
91 rdsv3_send_drop_acked(conn, ntohll(rm->m_inc.i_hdr.h_sequence), in rdsv3_loop_xmit()
96 RDSV3_DPRINTF4("rdsv3_loop_xmit", "Return(conn: %p, rm: %p)", conn, rm); in rdsv3_loop_xmit()
115 rdsv3_loop_xmit_cong_map(struct rdsv3_connection *conn, in rdsv3_loop_xmit_cong_map() argument
119 RDSV3_DPRINTF4("rdsv3_loop_xmit_cong_map", "Enter(conn: %p)", conn); in rdsv3_loop_xmit_cong_map()
122 ASSERT(map == conn->c_lcong); in rdsv3_loop_xmit_cong_map()
[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 …]
H A Dib_recv.c112 rdsv3_ib_recv_refill_one(struct rdsv3_connection *conn, in rdsv3_ib_recv_refill_one() argument
115 struct rdsv3_ib_connection *ic = conn->c_transport_data; in rdsv3_ib_recv_refill_one()
121 conn, recv); in rdsv3_ib_recv_refill_one()
135 rdsv3_inc_init(&recv->r_ibinc->ii_inc, conn, conn->c_faddr); in rdsv3_ib_recv_refill_one()
151 conn, recv); in rdsv3_ib_recv_refill_one()
172 rdsv3_ib_recv_refill(struct rdsv3_connection *conn, int prefill) in rdsv3_ib_recv_refill() argument
174 struct rdsv3_ib_connection *ic = conn->c_transport_data; in rdsv3_ib_recv_refill()
181 conn, prefill); in rdsv3_ib_recv_refill()
183 if (prefill || rdsv3_conn_up(conn)) { in rdsv3_ib_recv_refill()
197 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 …]
/titanic_41/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 Dexternal.c82 || !sparams->utils->conn) in external_server_mech_new()
85 if (!sparams->utils->conn->external.auth_id) in external_server_mech_new()
106 || !sparams->utils->conn in external_server_mech_step()
113 if (!sparams->utils->conn->external.auth_id) in external_server_mech_step()
117 (!strcmp(sparams->utils->conn->external.auth_id, "anonymous"))) { in external_server_mech_step()
119 sasl_seterror(sparams->utils->conn,0, in external_server_mech_step()
122 sasl_seterror(sparams->utils->conn,0,"anonymous login not allowed"); in external_server_mech_step()
139 result = sparams->canon_user(sparams->utils->conn, in external_server_mech_step()
143 result = sparams->canon_user(sparams->utils->conn, in external_server_mech_step()
144 sparams->utils->conn->external.auth_id, 0, in external_server_mech_step()
[all …]
/titanic_41/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 …]
/titanic_41/usr/src/lib/fm/libldom/sparc/
H A Dldom_xmpp_client.c72 static int iowrite(xmpp_conn_t *conn, char *buf, int size);
77 static void xmpp_close(xmpp_conn_t *conn);
78 static int start_tls(xmpp_conn_t *conn);
79 static void handle_ldm_resp(xmpp_conn_t *conn, char *buf, size_t buf_size);
80 static void handle_ldm_event(xmpp_conn_t *conn, char *buf, size_t buf_size);
195 xmpp_conn_t *conn = (xmpp_conn_t *)state; in end_element() local
198 conn->state = CONN_STATE_DONE; in end_element()
200 (void) iowrite(conn, START_TLS, strlen(START_TLS)); in end_element()
202 if (start_tls(conn)) { in end_element()
203 conn->state = CONN_STATE_FAILURE; in end_element()
[all …]
/titanic_41/usr/src/cmd/isns/isnsd/
H A Dfunc.c101 conn_arg_t *conn in packet_get_source() argument
106 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_get_source()
117 conn->in_packet.source = source; in packet_get_source()
136 conn_arg_t *conn in packet_get_key() argument
141 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_get_key()
147 conn->in_packet.key = key; in packet_get_key()
148 conn->in_packet.key_len = key_len; in packet_get_key()
166 conn_arg_t *conn in packet_get_operand() argument
171 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_get_operand()
177 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 …]
/titanic_41/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 …]
/titanic_41/usr/src/cmd/ssh/sftp/
H A Dsftp-client.c297 sftp_proto_version(struct sftp_conn *conn) in sftp_proto_version() argument
299 return(conn->version); in sftp_proto_version()
303 do_close(struct sftp_conn *conn, char *handle, u_int handle_len) in do_close() argument
310 id = conn->msg_id++; in do_close()
314 send_msg(conn->fd_out, &msg); in do_close()
317 status = get_status(conn->fd_in, id); in do_close()
328 do_lsreaddir(struct sftp_conn *conn, char *path, int printflag, in do_lsreaddir() argument
335 id = conn->msg_id++; in do_lsreaddir()
341 send_msg(conn->fd_out, &msg); in do_lsreaddir()
345 handle = get_handle(conn->fd_in, id, &handle_len); in do_lsreaddir()
[all …]
/titanic_41/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 …]
/titanic_41/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 …]
/titanic_41/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);
98 extern int sdp_get_opt(struct sdp_conn_struct_t *conn, int level, int opt,
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);
[all …]
H A Dsctp_itf.h80 extern int sctp_bind(struct sctp_s *conn, struct sockaddr *addr,
82 extern int sctp_bindx(struct sctp_s *conn, const void *addrs, int addrcnt,
84 extern void sctp_close(struct sctp_s *conn);
85 extern int sctp_connect(struct sctp_s *conn, const struct sockaddr *dst,
90 extern int sctp_disconnect(struct sctp_s *conn);
91 extern int sctp_get_opt(struct sctp_s *conn, int level, int opt, void *opts,
93 extern int sctp_getpeername(struct sctp_s *conn, struct sockaddr *addr,
95 extern int sctp_getsockname(struct sctp_s *conn, struct sockaddr *addr,
98 extern int sctp_listen(struct sctp_s *conn);
99 extern void sctp_recvd(struct sctp_s *conn, int len);
[all …]
/titanic_41/usr/src/lib/libsasl/include/
H A Dsasl.h554 typedef int sasl_getsecret_t(sasl_conn_t *conn, void *context, int id,
611 typedef int sasl_authorize_t(sasl_conn_t *conn,
634 typedef int sasl_server_userdb_checkpass_t(sasl_conn_t *conn,
650 typedef int sasl_server_userdb_setpass_t(sasl_conn_t *conn,
687 typedef int sasl_canon_user_t(sasl_conn_t *conn,
745 LIBSASL_API const char *sasl_errdetail(sasl_conn_t *conn);
764 LIBSASL_API void sasl_seterror(sasl_conn_t *conn, unsigned flags,
777 LIBSASL_API int sasl_getprop(sasl_conn_t *conn, int propnum,
811 LIBSASL_API int sasl_setprop(sasl_conn_t *conn,
830 LIBSASL_API int sasl_idle(sasl_conn_t *conn);
[all …]

123456