/illumos-gate/usr/src/uts/common/io/ib/clients/rdsv3/ |
H A D | connection.c | 82 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 D | threads.c | 107 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 D | send.c | 104 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 D | ib_cm.c | 63 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 D | loop.c | 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() 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 D | ib_recv.c | 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() 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 D | rdma_transport.c | 61 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 D | cong.c | 194 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 D | common.c | 353 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 D | server.c | 163 (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; 1590 if ((conn->props.min_ssf <= conn->external.ssf) && 1686 (conn == NULL) ? _sasl_gbl_ctx() : conn->gctx; 1927 (conn == NULL) ? _sasl_gbl_ctx() : conn->gctx; 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 D | client.c | 339 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 D | saslint.h | 73 #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 …]
|
H A D | checkpw.c | 149 static int auxprop_verify_password(sasl_conn_t *conn, in auxprop_verify_password() argument 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 282 PARAMERROR(conn) in _sasl_auxprop_verify_apop() 303 sasl_seterror(conn, 0, "could not find password"); in _sasl_auxprop_verify_apop() 459 sasl_seterror(conn,0,response); in pwcheck_verify_password() 637 sasl_seterror(conn, 0, "size read failed"); in saslauthd_verify_password() 651 sasl_seterror(conn, 0, "read failed"); in saslauthd_verify_password() [all …]
|
/illumos-gate/usr/src/uts/common/rpc/ |
H A D | rpc_rdma.h | 370 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 D | rpcib.c | 1009 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/cmd/isns/isnsd/ |
H A D | func.c | 288 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 D | server.c | 64 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 D | request.c | 195 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 D | connection.c | 61 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 D | hald_dbus.h | 33 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 D | sendto_kdc.c | 926 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 D | network.c | 951 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 D | sdp_itf.h | 84 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); 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); 104 extern int sdp_send(struct sdp_conn_struct_t *conn, struct msghdr *msg, [all …]
|
/illumos-gate/usr/src/lib/libsasl/include/ |
H A D | sasl.h | 609 typedef int sasl_authorize_t(sasl_conn_t *conn, 685 typedef int sasl_canon_user_t(sasl_conn_t *conn, 809 LIBSASL_API int sasl_setprop(sasl_conn_t *conn, 828 LIBSASL_API int sasl_idle(sasl_conn_t *conn); 1026 LIBSASL_API int sasl_listmech(sasl_conn_t *conn, 1098 LIBSASL_API int sasl_checkapop(sasl_conn_t *conn, 1116 LIBSASL_API int sasl_checkpass(sasl_conn_t *conn, 1161 LIBSASL_API int sasl_setpass(sasl_conn_t *conn, 1237 LIBSASL_API int sasl_encode(sasl_conn_t *conn, 1250 LIBSASL_API int sasl_encodev(sasl_conn_t *conn, [all …]
|
/illumos-gate/usr/src/uts/common/sys/ib/clients/rdsv3/ |
H A D | rdsv3.h | 362 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 …]
|