/illumos-gate/usr/src/uts/common/io/ib/clients/rdsv3/ |
H A D | rdma_transport.c | 61 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 D | threads.c | 86 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 D | loop.c | 68 * 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 D | bind.c | 144 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 D | ib.c | 274 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 D | cong.c | 104 * - 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 D | connection.c | 66 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 D | ib_cm.c | 60 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 D | rds_recv.c | 51 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 D | send.c | 73 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 D | main.c | 98 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 D | server.c | 64 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 D | seterror.c | 113 * 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 D | canonusr.c | 82 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 D | checkpw.c | 150 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 D | LMEConnectionCompat.cpp | 174 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 D | changepw.c | 102 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 D | ev_connects.c | 195 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 D | sdp_parse_helper.c | 146 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 D | ex_dscp.c | 71 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 D | sfsasl.c | 30 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 D | hal-device.c | 103 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 D | lshal.c | 579 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 D | rdma_subr.c | 262 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 D | rdma_cm.h | 118 struct rdma_conn_param conn; member in union:rdma_cm_event::__anon7922
|