/illumos-gate/usr/src/uts/common/io/idm/ |
H A D | idm_so.c | 68 static void idm_sorx_cache_pdu_cb(idm_pdu_t *pdu, idm_status_t status); 69 static void idm_sorx_addl_pdu_cb(idm_pdu_t *pdu, idm_status_t status); 70 static void idm_sotx_cache_pdu_cb(idm_pdu_t *pdu, idm_status_t status); 79 static idm_status_t idm_i_so_tx(idm_pdu_t *pdu); 81 static idm_status_t idm_sorecvdata(idm_conn_t *ic, idm_pdu_t *pdu); 88 static uint32_t idm_fill_iov(idm_pdu_t *pdu, idm_buf_t *idb, 100 static void idm_so_tx(idm_conn_t *ic, idm_pdu_t *pdu); 103 static void idm_so_rx_datain(idm_conn_t *ic, idm_pdu_t *pdu); 104 static void idm_so_rx_rtt(idm_conn_t *ic, idm_pdu_t *pdu); 105 static void idm_so_rx_dataout(idm_conn_t *ic, idm_pdu_t *pdu); [all …]
|
H A D | idm_conn_sm.c | 83 idm_state_s9b_wait_snd_done_cb(idm_pdu_t *pdu, 111 idm_pdu_t *pdu); 286 idm_pdu_t *pdu = (idm_pdu_t *)event_ctx->iec_info; in idm_conn_event_handler() local 317 ASSERT(pdu != NULL); in idm_conn_event_handler() 318 action = idm_conn_sm_validate_pdu(ic, event_ctx, pdu); in idm_conn_event_handler() 343 IDM_SM_LOG(CE_NOTE, "*** drop PDU %p", (void *) pdu); in idm_conn_event_handler() 344 idm_pdu_complete(pdu, IDM_STATUS_FAIL); in idm_conn_event_handler() 410 idm_pdu_tx_protocol_error(ic, pdu); in idm_conn_event_handler() 413 idm_pdu_rx_protocol_error(ic, pdu); in idm_conn_event_handler() 419 idm_pdu_rx_forward(ic, pdu); in idm_conn_event_handler() [all …]
|
H A D | idm_impl.c | 51 idm_pdu_rx(idm_conn_t *ic, idm_pdu_t *pdu) in idm_pdu_rx() argument 64 if (idm_pdu_rx_forward_ffp(ic, pdu) == B_TRUE) { in idm_pdu_rx() 85 switch (IDM_PDU_OPCODE(pdu)) { in idm_pdu_rx() 88 iscsi_login_hdr_t *, (iscsi_login_hdr_t *)pdu->isp_hdr); in idm_pdu_rx() 89 idm_conn_rx_pdu_event(ic, CE_LOGIN_RCV, (uintptr_t)pdu); in idm_pdu_rx() 92 idm_parse_login_rsp(ic, pdu, /* RX */ B_TRUE); in idm_pdu_rx() 97 (iscsi_logout_hdr_t *)pdu->isp_hdr); in idm_pdu_rx() 98 idm_parse_logout_req(ic, pdu, /* RX */ B_TRUE); in idm_pdu_rx() 101 idm_parse_logout_rsp(ic, pdu, /* RX */ B_TRUE); in idm_pdu_rx() 104 async_evt = (iscsi_async_evt_hdr_t *)pdu->isp_hdr; in idm_pdu_rx() [all …]
|
H A D | idm.c | 1723 idm_pdu_tx(idm_pdu_t *pdu) in idm_pdu_tx() argument 1725 idm_conn_t *ic = pdu->isp_ic; in idm_pdu_tx() 1748 switch (IDM_PDU_OPCODE(pdu)) { in idm_pdu_tx() 1753 (iscsi_scsi_rsp_hdr_t *)pdu->isp_hdr); in idm_pdu_tx() 1754 idm_pdu_tx_forward(ic, pdu); in idm_pdu_tx() 1760 (iscsi_text_rsp_hdr_t *)pdu->isp_hdr); in idm_pdu_tx() 1761 idm_pdu_tx_forward(ic, pdu); in idm_pdu_tx() 1767 (iscsi_data_rsp_hdr_t *)pdu->isp_hdr); in idm_pdu_tx() 1768 idm_pdu_tx_forward(ic, pdu); in idm_pdu_tx() 1774 (iscsi_rtt_hdr_t *)pdu->isp_hdr); in idm_pdu_tx() [all …]
|
H A D | idm_text.c | 1373 idm_pdu_init_text_data(idm_pdu_t *pdu, void *arg, in idm_pdu_init_text_data() argument 1378 iscsi_hdr_t *ihp = pdu->isp_hdr; in idm_pdu_init_text_data() 1382 ASSERT(pdu != NULL); in idm_pdu_init_text_data() 1390 bcopy((uint8_t *)itb->itb_mem, pdu->isp_data, in idm_pdu_init_text_data() 1392 pdu->isp_datalen = itb->itb_offset; in idm_pdu_init_text_data() 1410 bcopy(bufptr, pdu->isp_data, (size_t)len); in idm_pdu_init_text_data() 1411 pdu->isp_datalen = len; in idm_pdu_init_text_data() 1433 bcopy(start_ptr, pdu->isp_data, in idm_pdu_init_text_data() 1435 pdu->isp_datalen = ((uintptr_t)ptr - (uintptr_t)start_ptr) + 1; in idm_pdu_init_text_data() 1458 idm_pdu_t *pdu, *next_pdu; in idm_pdu_list_to_nvlist() local [all …]
|
/illumos-gate/usr/src/cmd/isns/isnsd/ |
H A D | pdu.c | 61 isns_pdu_t **pdu, in isns_rcv_pdu() argument 77 *pdu = NULL; in isns_rcv_pdu() 174 (*pdu) = (isns_pdu_t *)malloc(*pdu_size); in isns_rcv_pdu() 175 if (*pdu == NULL) { in isns_rcv_pdu() 181 (*pdu)->version = ntohs(tmp_pdu_hdr->version); in isns_rcv_pdu() 182 (*pdu)->func_id = ntohs(tmp_pdu_hdr->func_id); in isns_rcv_pdu() 183 (*pdu)->payload_len = payload_len; in isns_rcv_pdu() 184 (*pdu)->flags = ntohs(tmp_pdu_hdr->flags); in isns_rcv_pdu() 185 (*pdu)->xid = ntohs(tmp_pdu_hdr->xid); in isns_rcv_pdu() 186 (*pdu)->seq = ntohs(tmp_pdu_hdr->seq); in isns_rcv_pdu() [all …]
|
H A D | server.c | 66 isns_pdu_t *pdu, *combined_pdu, *new_combined_pdu; in isns_connection() local 72 conn->out_packet.pdu = NULL; in isns_connection() 75 pdu = NULL; in isns_connection() 79 isns_rcv_pdu(conn->so, &pdu, &pdu_sz, ISNS_RCV_TIMEOUT) > 0) { in isns_connection() 80 uint16_t flags = pdu->flags; in isns_connection() 98 if (combined_pdu != NULL || pdu->seq != 0) { in isns_connection() 101 combined_pdu = pdu; in isns_connection() 102 pdu = NULL; in isns_connection() 105 combined_pdu->func_id != pdu->func_id || in isns_connection() 106 combined_pdu->xid != pdu->xid || in isns_connection() [all …]
|
H A D | dump.c | 209 isns_pdu_t *pdu, in dump_pdu() argument 215 uint8_t *payload = pdu->payload; in dump_pdu() 220 ver = ntohs(pdu->version); in dump_pdu() 221 id = ntohs(pdu->func_id); in dump_pdu() 222 len = ntohs(pdu->payload_len); in dump_pdu() 223 flags = ntohs(pdu->flags) & 0xFFFF; in dump_pdu() 224 xid = ntohs(pdu->xid); in dump_pdu() 225 seq = ntohs(pdu->seq); in dump_pdu() 227 ver = pdu->version; in dump_pdu() 228 id = pdu->func_id; in dump_pdu() [all …]
|
H A D | func.c | 104 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_get_source() local 105 isns_tlv_t *source = pdu_get_source(pdu); in packet_get_source() 137 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_get_key() local 141 key = pdu_get_key(pdu, &key_len); in packet_get_key() 165 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_get_operand() local 169 op = pdu_get_operand(pdu, &op_len); in packet_get_operand() 194 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_split_verify() local 199 if (pdu->version != ISNSP_VERSION) { in packet_split_verify() 202 switch (pdu->func_id) { in packet_split_verify() 271 ISNS_OPERATION_TYPE((uintptr_t)buf, pdu->func_id); in packet_split_verify() [all …]
|
H A D | esi.c | 1247 isns_pdu_t *pdu, in esi_ping() argument 1258 if (isns_send_pdu(so, pdu, pl) == 0) { in esi_ping() 1301 isns_pdu_t *pdu = NULL; in esi_monitor() local 1323 if (pdu_reset_esi(&pdu, &pl, &sz) != 0 || in esi_monitor() 1324 pdu_add_tlv(&pdu, &pl, &sz, in esi_monitor() 1326 pdu_add_tlv(&pdu, &pl, &sz, in esi_monitor() 1333 pdu->version = htons((uint16_t)ISNSP_VERSION); in esi_monitor() 1334 pdu->func_id = htons((uint16_t)ISNS_ESI); in esi_monitor() 1335 pdu->xid = htons(get_server_xid()); in esi_monitor() 1345 pdu_add_tlv(&pdu, &pl, &sz, in esi_monitor() [all …]
|
H A D | isns_func.h | 41 isns_pdu_t *pdu; member 49 isns_pdu_t *pdu; member
|
H A D | scn.c | 1631 isns_pdu_t *pdu, in emit_scn() argument 1642 pdu->version = htons((uint16_t)ISNSP_VERSION); in emit_scn() 1643 pdu->func_id = htons((uint16_t)ISNS_SCN); in emit_scn() 1644 pdu->xid = htons(get_server_xid()); in emit_scn() 1651 if (isns_send_pdu(so, pdu, pl) == 0) { in emit_scn() 1697 isns_pdu_t *pdu = NULL; in scn_trigger1() local 1715 ec = pdu_reset_scn(&pdu, &pl, &sz); in scn_trigger1() 1716 if (pdu == NULL) { in scn_trigger1() 1721 ec = pdu_add_tlv(&pdu, &pl, &sz, in scn_trigger1() 1736 ec = pdu_add_tlv(&pdu, &pl, &sz, in scn_trigger1() [all …]
|
/illumos-gate/usr/src/cmd/picl/plugins/sun4v/lib/snmp/ |
H A D | pdu.c | 60 snmp_pdu_t *pdu; in snmp_create_pdu() local 67 pdu = (snmp_pdu_t *)calloc(1, sizeof (snmp_pdu_t)); in snmp_create_pdu() 68 if (pdu == NULL) in snmp_create_pdu() 72 pdu->version = SNMP_VERSION_1; in snmp_create_pdu() 73 pdu->errstat = 0; in snmp_create_pdu() 74 pdu->errindex = 0; in snmp_create_pdu() 76 pdu->version = SNMP_VERSION_2c; in snmp_create_pdu() 77 pdu->non_repeaters = 0; in snmp_create_pdu() 78 pdu->max_repetitions = max_reps ? in snmp_create_pdu() 82 pdu->command = cmd; in snmp_create_pdu() [all …]
|
H A D | snmplib.c | 869 snmp_pdu_t *pdu, *reply_pdu; in fetch_single() local 871 if ((pdu = snmp_create_pdu(SNMP_MSG_GET, 0, prefix, 1, row)) == NULL) in fetch_single() 874 if (snmp_make_packet(pdu) < 0) { in fetch_single() 875 snmp_free_pdu(pdu); in fetch_single() 879 if (snmp_send_request(smd, pdu, snmp_syserr) < 0) { in fetch_single() 880 snmp_free_pdu(pdu); in fetch_single() 884 if (snmp_recv_reply(smd, pdu, snmp_syserr) < 0) { in fetch_single() 885 snmp_free_pdu(pdu); in fetch_single() 889 reply_pdu = snmp_parse_reply(pdu->reqid, pdu->reply_pkt, in fetch_single() 890 pdu->reply_pktsz); in fetch_single() [all …]
|
/illumos-gate/usr/src/uts/common/io/comstar/port/iscsit/ |
H A D | iscsit_isns.c | 305 isnst_make_dereg_pdu(iscsit_isns_svr_t *svr, isns_pdu_t **pdu, 310 isnst_make_keepalive_pdu(iscsit_isns_svr_t *svr, isns_pdu_t **pdu); 318 isnst_verify_rsp(iscsit_isns_svr_t *svr, isns_pdu_t *pdu, 322 isnst_pdu_get_op(isns_pdu_t *pdu, uint8_t **pp); 325 isnst_make_reg_pdu(isns_pdu_t **pdu, isns_target_t *target, 329 isnst_reg_pdu_add_entity_portals(isns_pdu_t *pdu, size_t pdu_size); 332 isnst_reg_pdu_add_pg(isns_pdu_t *pdu, size_t pdu_size, isns_target_t *target); 335 isnst_add_default_pg(isns_pdu_t *pdu, size_t pdu_size, 339 isnst_add_tpg_pg(isns_pdu_t *pdu, size_t pdu_size, 343 isnst_add_null_pg(isns_pdu_t *pdu, size_t pdu_size, [all …]
|
H A D | iscsit_login.c | 107 login_sm_send_ack(iscsit_conn_t *ict, idm_pdu_t *pdu); 110 login_sm_validate_ack(iscsit_conn_t *ict, idm_pdu_t *pdu); 113 login_sm_is_last_response(idm_pdu_t *pdu); 116 login_sm_handle_initial_login(iscsit_conn_t *ict, idm_pdu_t *pdu); 119 login_sm_send_next_response(iscsit_conn_t *ict, idm_pdu_t *pdu); 125 login_sm_req_pdu_check(iscsit_conn_t *ict, idm_pdu_t *pdu); 195 login_resp_complete_cb(idm_pdu_t *pdu, idm_status_t status); 270 login_resp_complete_cb(idm_pdu_t *pdu, idm_status_t status) in login_resp_complete_cb() argument 272 iscsit_conn_t *ict = pdu->isp_private; in login_resp_complete_cb() 277 ASSERT((pdu->isp_flags & IDM_PDU_LOGIN_TX) != 0); in login_resp_complete_cb() [all …]
|
H A D | iscsit.c | 206 iscsit_send_good_status_done(idm_pdu_t *pdu, idm_status_t status); 209 iscsit_send_status_done(idm_pdu_t *pdu, idm_status_t status); 1068 iscsit_update_statsn(idm_task_t *idm_task, idm_pdu_t *pdu) in iscsit_update_statsn() argument 1070 iscsi_scsi_rsp_hdr_t *rsp = (iscsi_scsi_rsp_hdr_t *)pdu->isp_hdr; in iscsit_update_statsn() 1071 iscsit_conn_t *ict = (iscsit_conn_t *)pdu->isp_ic->ic_handle; in iscsit_update_statsn() 1077 if (pdu->isp_flags & IDM_PDU_ADVANCE_STATSN) in iscsit_update_statsn() 1111 iscsit_build_hdr(idm_task_t *idm_task, idm_pdu_t *pdu, uint8_t opcode) in iscsit_build_hdr() argument 1114 iscsi_data_rsp_hdr_t *dh = (iscsi_data_rsp_hdr_t *)pdu->isp_hdr; in iscsit_build_hdr() 1652 idm_pdu_t *pdu; in iscsit_send_scsi_status() local 1706 pdu = kmem_cache_alloc(iscsit_status_pdu_cache, KM_SLEEP); in iscsit_send_scsi_status() [all …]
|
/illumos-gate/usr/src/uts/common/io/scsi/adapters/iscsi/ |
H A D | isns_client.c | 149 static ssize_t isns_send_pdu(void *socket, isns_pdu_t *pdu); 150 static size_t isns_rcv_pdu(void *so, isns_pdu_t **pdu, size_t *pdu_size); 158 uint16_t flags, isns_pdu_t **pdu); 159 static int isns_add_attr(isns_pdu_t *pdu, 175 isns_pdu_t *pdu, uint16_t *xid, isns_pdu_t **out_pdu); 181 isns_pdu_t *pdu, uint16_t *xid, isns_pdu_t **out_pdu); 1549 isns_send_pdu(void *socket, isns_pdu_t *pdu) in isns_send_pdu() argument 1558 iovec[iovlen].iov_base = (void *)pdu; in isns_send_pdu() 1564 iovec[iovlen].iov_base = (void *)pdu->payload; in isns_send_pdu() 1565 iovec[iovlen].iov_len = ntohs(pdu->payload_len); in isns_send_pdu() [all …]
|
H A D | iscsi_io.c | 81 static idm_status_t iscsi_rx_process_nop(idm_conn_t *ic, idm_pdu_t *pdu); 83 idm_pdu_t *pdu); 84 static idm_status_t iscsi_rx_process_cmd_rsp(idm_conn_t *ic, idm_pdu_t *pdu); 86 idm_pdu_t *pdu); 91 idm_pdu_t *pdu); 93 idm_pdu_t *pdu); 95 idm_pdu_t *pdu); 97 idm_pdu_t *pdu); 259 iscsi_rx_scsi_rsp(idm_conn_t *ic, idm_pdu_t *pdu) in iscsi_rx_scsi_rsp() argument 267 ASSERT(pdu != NULL); in iscsi_rx_scsi_rsp() [all …]
|
/illumos-gate/usr/src/uts/common/io/ib/clients/iser/ |
H A D | iser_cq.c | 582 iser_rx_pdu_cb(idm_pdu_t *pdu, idm_status_t status) in iser_rx_pdu_cb() argument 585 iser_msg_free((iser_msg_t *)pdu->isp_transport_private); in iser_rx_pdu_cb() 586 idm_pdu_free(pdu); in iser_rx_pdu_cb() 592 idm_pdu_t *pdu; in iser_iscsihdr_handle() local 597 pdu = idm_pdu_alloc_nosleep(sizeof (iscsi_hdr_t), 0); in iser_iscsihdr_handle() 598 pdu->isp_ic = chan->ic_conn->ic_idmc; in iser_iscsihdr_handle() 599 ASSERT(pdu->isp_ic != NULL); in iser_iscsihdr_handle() 602 pdu->isp_transport_private = (void *)msg; in iser_iscsihdr_handle() 608 idm_pdu_free(pdu); in iser_iscsihdr_handle() 611 pdu->isp_transport_hdr = (void *)iser_hdrp; in iser_iscsihdr_handle() [all …]
|
H A D | iser_xfer.c | 225 iser_xfer_ctrlpdu(iser_chan_t *chan, idm_pdu_t *pdu) in iser_xfer_ctrlpdu() argument 252 bhs = (iscsi_data_hdr_t *)pdu->isp_hdr; in iser_xfer_ctrlpdu() 261 if (pdu->isp_flags & IDM_PDU_SET_STATSN) { in iser_xfer_ctrlpdu() 262 (ic->ic_conn_ops.icb_update_statsn)(NULL, pdu); in iser_xfer_ctrlpdu() 328 bcopy(pdu->isp_hdr, in iser_xfer_ctrlpdu() 330 pdu->isp_hdrlen); in iser_xfer_ctrlpdu() 332 if (pdu->isp_datalen > 0) { in iser_xfer_ctrlpdu() 334 bcopy(pdu->isp_data, in iser_xfer_ctrlpdu() 336 ISER_HEADER_LENGTH + pdu->isp_hdrlen, in iser_xfer_ctrlpdu() 337 pdu->isp_datalen); in iser_xfer_ctrlpdu() [all …]
|
/illumos-gate/usr/src/uts/common/sys/idm/ |
H A D | idm.h | 139 typedef void (idm_rx_pdu_cb_t)(struct idm_conn_s *ic, struct idm_pdu_s *pdu); 142 struct idm_pdu_s *pdu, idm_status_t status); 146 typedef void (idm_pdu_cb_t)(struct idm_pdu_s *pdu, idm_status_t status); 151 struct idm_task_s *task, struct idm_pdu_s *pdu, uint8_t opcode); 154 struct idm_task_s *task, struct idm_pdu_s *pdu); 483 idm_pdu_free(idm_pdu_t *pdu); 486 idm_pdu_init(idm_pdu_t *pdu, idm_conn_t *ic, void *private, idm_pdu_cb_t *cb); 489 idm_pdu_init_hdr(idm_pdu_t *pdu, uint8_t *hdr, uint_t hdrlen); 492 idm_pdu_init_data(idm_pdu_t *pdu, uint8_t *data, uint_t datalen); 495 idm_pdu_complete(idm_pdu_t *pdu, idm_status_t status); [all …]
|
H A D | idm_transport.h | 68 typedef void (transport_tx_op_t)(struct idm_conn_s *ic, struct idm_pdu_s *pdu); 81 struct idm_pdu_s *pdu); 83 struct idm_pdu_s *pdu); 87 struct idm_pdu_s *pdu);
|
H A D | idm_impl.h | 490 idm_pdu_rx(idm_conn_t *ic, idm_pdu_t *pdu); 493 idm_pdu_tx_forward(idm_conn_t *ic, idm_pdu_t *pdu); 496 idm_pdu_rx_forward_ffp(idm_conn_t *ic, idm_pdu_t *pdu); 499 idm_pdu_rx_forward(idm_conn_t *ic, idm_pdu_t *pdu); 502 idm_pdu_tx_protocol_error(idm_conn_t *ic, idm_pdu_t *pdu); 505 idm_pdu_rx_protocol_error(idm_conn_t *ic, idm_pdu_t *pdu);
|
/illumos-gate/usr/src/uts/common/io/ |
H A D | gldutil.c | 1758 struct rde_pdu *pdu = (struct rde_pdu *)(llcpkt + LLC_HDR1_LEN); in gld_rcc_receive() local 1770 switch (pdu->rde_ptype) { in gld_rcc_receive() 1772 gld_send_rqr(macinfo, pktinfo->shost, rh, pdu, pdulen); in gld_rcc_receive() 1776 gld_rde_pdu_ind(macinfo, rh, pdu, pdulen); in gld_rcc_receive() 1816 struct rde_pdu *pdu, int pdulen) in gld_send_rqr() argument 1841 *npdu = *pdu; /* copy orig/target macaddr/saps */ in gld_send_rqr() 2182 gld_rde_pdu_ind(gld_mac_info_t *macinfo, struct gld_ri *rh, struct rde_pdu *pdu, in gld_rde_pdu_ind() argument 2191 if (pdu->rde_ptype == RDE_RQC) in gld_rde_pdu_ind() 2194 if (pdu->rde_ptype != RDE_RQR && pdu->rde_ptype != RDE_RS) { in gld_rde_pdu_ind() 2198 pdu->rde_ptype); in gld_rde_pdu_ind() [all …]
|