Home
last modified time | relevance | path

Searched refs:pdu (Results 1 – 25 of 38) sorted by relevance

12

/titanic_50/usr/src/cmd/isns/isnsd/
H A Dpdu.c61 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 Dserver.c66 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 Ddump.c209 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 Dfunc.c106 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_get_source() local
107 isns_tlv_t *source = pdu_get_source(pdu); in packet_get_source()
141 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_get_key() local
145 key = pdu_get_key(pdu, &key_len); in packet_get_key()
171 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_get_operand() local
175 op = pdu_get_operand(pdu, &op_len); in packet_get_operand()
202 isns_pdu_t *pdu = conn->in_packet.pdu; in packet_split_verify() local
207 if (pdu->version != ISNSP_VERSION) { in packet_split_verify()
210 switch (pdu->func_id) { in packet_split_verify()
279 ISNS_OPERATION_TYPE((uintptr_t)buf, pdu->func_id); in packet_split_verify()
[all …]
H A Desi.c1247 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 Disns_func.h41 isns_pdu_t *pdu; member
49 isns_pdu_t *pdu; member
/titanic_50/usr/src/uts/common/io/idm/
H A Didm_so.c66 static void idm_sorx_cache_pdu_cb(idm_pdu_t *pdu, idm_status_t status);
67 static void idm_sorx_addl_pdu_cb(idm_pdu_t *pdu, idm_status_t status);
68 static void idm_sotx_cache_pdu_cb(idm_pdu_t *pdu, idm_status_t status);
77 static idm_status_t idm_i_so_tx(idm_pdu_t *pdu);
79 static idm_status_t idm_sorecvdata(idm_conn_t *ic, idm_pdu_t *pdu);
86 static uint32_t idm_fill_iov(idm_pdu_t *pdu, idm_buf_t *idb,
98 static void idm_so_tx(idm_conn_t *ic, idm_pdu_t *pdu);
101 static void idm_so_rx_datain(idm_conn_t *ic, idm_pdu_t *pdu);
102 static void idm_so_rx_rtt(idm_conn_t *ic, idm_pdu_t *pdu);
103 static void idm_so_rx_dataout(idm_conn_t *ic, idm_pdu_t *pdu);
[all …]
H A Didm_conn_sm.c81 idm_state_s9b_wait_snd_done_cb(idm_pdu_t *pdu,
109 idm_pdu_t *pdu);
283 idm_pdu_t *pdu = (idm_pdu_t *)event_ctx->iec_info; in idm_conn_event_handler() local
314 ASSERT(pdu != NULL); in idm_conn_event_handler()
315 action = idm_conn_sm_validate_pdu(ic, event_ctx, pdu); in idm_conn_event_handler()
340 IDM_SM_LOG(CE_NOTE, "*** drop PDU %p", (void *) pdu); in idm_conn_event_handler()
341 idm_pdu_complete(pdu, IDM_STATUS_FAIL); in idm_conn_event_handler()
406 idm_pdu_tx_protocol_error(ic, pdu); in idm_conn_event_handler()
409 idm_pdu_rx_protocol_error(ic, pdu); in idm_conn_event_handler()
415 idm_pdu_rx_forward(ic, pdu); in idm_conn_event_handler()
[all …]
H A Didm_impl.c51 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 Didm.c1717 idm_pdu_tx(idm_pdu_t *pdu) in idm_pdu_tx() argument
1719 idm_conn_t *ic = pdu->isp_ic; in idm_pdu_tx()
1742 switch (IDM_PDU_OPCODE(pdu)) { in idm_pdu_tx()
1747 (iscsi_scsi_rsp_hdr_t *)pdu->isp_hdr); in idm_pdu_tx()
1748 idm_pdu_tx_forward(ic, pdu); in idm_pdu_tx()
1754 (iscsi_text_rsp_hdr_t *)pdu->isp_hdr); in idm_pdu_tx()
1755 idm_pdu_tx_forward(ic, pdu); in idm_pdu_tx()
1761 (iscsi_data_rsp_hdr_t *)pdu->isp_hdr); in idm_pdu_tx()
1762 idm_pdu_tx_forward(ic, pdu); in idm_pdu_tx()
1768 (iscsi_rtt_hdr_t *)pdu->isp_hdr); in idm_pdu_tx()
[all …]
H A Didm_text.c1373 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 …]
/titanic_50/usr/src/cmd/picl/plugins/sun4v/lib/snmp/
H A Dpdu.c62 snmp_pdu_t *pdu; in snmp_create_pdu() local
69 pdu = (snmp_pdu_t *)calloc(1, sizeof (snmp_pdu_t)); in snmp_create_pdu()
70 if (pdu == NULL) in snmp_create_pdu()
74 pdu->version = SNMP_VERSION_1; in snmp_create_pdu()
75 pdu->errstat = 0; in snmp_create_pdu()
76 pdu->errindex = 0; in snmp_create_pdu()
78 pdu->version = SNMP_VERSION_2c; in snmp_create_pdu()
79 pdu->non_repeaters = 0; in snmp_create_pdu()
80 pdu->max_repetitions = max_reps ? in snmp_create_pdu()
84 pdu->command = cmd; in snmp_create_pdu()
[all …]
H A Dsnmplib.c878 snmp_pdu_t *pdu, *reply_pdu; in fetch_single() local
882 if ((pdu = snmp_create_pdu(SNMP_MSG_GET, 0, prefix, 1, row)) == NULL) in fetch_single()
885 LOGPDU(TAG_REQUEST_PDU, pdu); in fetch_single()
887 if (snmp_make_packet(pdu) < 0) { in fetch_single()
888 snmp_free_pdu(pdu); in fetch_single()
892 LOGPKT(TAG_REQUEST_PKT, pdu->req_pkt, pdu->req_pktsz); in fetch_single()
894 if (snmp_send_request(smd, pdu, snmp_syserr) < 0) { in fetch_single()
895 snmp_free_pdu(pdu); in fetch_single()
899 if (snmp_recv_reply(smd, pdu, snmp_syserr) < 0) { in fetch_single()
900 snmp_free_pdu(pdu); in fetch_single()
[all …]
H A Ddebug.c274 snmp_log_pdu(uint_t tag, snmp_pdu_t *pdu) in snmp_log_pdu() argument
278 if (pdu == NULL) in snmp_log_pdu()
298 SNMP_DPDU_INDENT, ' ', SNMP_DTEXT_PREFIX, pdu->version); in snmp_log_pdu()
301 if (pdu->community) { in snmp_log_pdu()
304 SNMP_DTEXT_PREFIX, pdu->community); in snmp_log_pdu()
308 SNMP_DTEXT_PREFIX, pdu->community); in snmp_log_pdu()
313 SNMP_DPDU_INDENT, ' ', SNMP_DTEXT_PREFIX, pdu->community_len); in snmp_log_pdu()
316 if ((cmdstr = snmp_cmdstr_lookup(pdu->command)) == NULL) { in snmp_log_pdu()
319 SNMP_DTEXT_PREFIX, pdu->command); in snmp_log_pdu()
328 SNMP_DPDU_INDENT, ' ', SNMP_DTEXT_PREFIX, pdu->reqid); in snmp_log_pdu()
[all …]
H A Ddebug.h82 #define LOGPDU(tag, pdu) \ argument
83 snmp_log_pdu(tag, pdu)
116 extern void snmp_log_pdu(uint_t tag, snmp_pdu_t *pdu);
128 #define LOGPDU(tag, pdu)
/titanic_50/usr/src/uts/common/io/comstar/port/iscsit/
H A Discsit_isns.c305 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 Discsit_login.c104 login_sm_send_ack(iscsit_conn_t *ict, idm_pdu_t *pdu);
107 login_sm_validate_ack(iscsit_conn_t *ict, idm_pdu_t *pdu);
110 login_sm_is_last_response(idm_pdu_t *pdu);
113 login_sm_handle_initial_login(iscsit_conn_t *ict, idm_pdu_t *pdu);
116 login_sm_send_next_response(iscsit_conn_t *ict, idm_pdu_t *pdu);
122 login_sm_req_pdu_check(iscsit_conn_t *ict, idm_pdu_t *pdu);
192 login_resp_complete_cb(idm_pdu_t *pdu, idm_status_t status);
264 login_resp_complete_cb(idm_pdu_t *pdu, idm_status_t status) in login_resp_complete_cb() argument
266 iscsit_conn_t *ict = pdu->isp_private; in login_resp_complete_cb()
271 ASSERT((pdu->isp_flags & IDM_PDU_LOGIN_TX) != 0); in login_resp_complete_cb()
[all …]
H A Discsit.c206 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);
1051 iscsit_update_statsn(idm_task_t *idm_task, idm_pdu_t *pdu) in iscsit_update_statsn() argument
1053 iscsi_scsi_rsp_hdr_t *rsp = (iscsi_scsi_rsp_hdr_t *)pdu->isp_hdr; in iscsit_update_statsn()
1054 iscsit_conn_t *ict = (iscsit_conn_t *)pdu->isp_ic->ic_handle; in iscsit_update_statsn()
1060 if (pdu->isp_flags & IDM_PDU_ADVANCE_STATSN) in iscsit_update_statsn()
1094 iscsit_build_hdr(idm_task_t *idm_task, idm_pdu_t *pdu, uint8_t opcode) in iscsit_build_hdr() argument
1097 iscsi_data_rsp_hdr_t *dh = (iscsi_data_rsp_hdr_t *)pdu->isp_hdr; in iscsit_build_hdr()
1631 idm_pdu_t *pdu; in iscsit_send_scsi_status() local
1685 pdu = kmem_cache_alloc(iscsit_status_pdu_cache, KM_SLEEP); in iscsit_send_scsi_status()
[all …]
/titanic_50/usr/src/uts/common/io/scsi/adapters/iscsi/
H A Disns_client.c149 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 Discsi_io.c81 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 …]
/titanic_50/usr/src/uts/common/io/ib/clients/iser/
H A Diser_cq.c581 iser_rx_pdu_cb(idm_pdu_t *pdu, idm_status_t status) in iser_rx_pdu_cb() argument
584 iser_msg_free((iser_msg_t *)pdu->isp_transport_private); in iser_rx_pdu_cb()
585 idm_pdu_free(pdu); in iser_rx_pdu_cb()
591 idm_pdu_t *pdu; in iser_iscsihdr_handle() local
596 pdu = idm_pdu_alloc_nosleep(sizeof (iscsi_hdr_t), 0); in iser_iscsihdr_handle()
597 pdu->isp_ic = chan->ic_conn->ic_idmc; in iser_iscsihdr_handle()
598 ASSERT(pdu->isp_ic != NULL); in iser_iscsihdr_handle()
601 pdu->isp_transport_private = (void *)msg; in iser_iscsihdr_handle()
607 idm_pdu_free(pdu); in iser_iscsihdr_handle()
610 pdu->isp_transport_hdr = (void *)iser_hdrp; in iser_iscsihdr_handle()
[all …]
H A Diser_xfer.c225 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 …]
/titanic_50/usr/src/uts/common/sys/idm/
H A Didm.h138 typedef void (idm_rx_pdu_cb_t)(struct idm_conn_s *ic, struct idm_pdu_s *pdu);
141 struct idm_pdu_s *pdu, idm_status_t status);
145 typedef void (idm_pdu_cb_t)(struct idm_pdu_s *pdu, idm_status_t status);
150 struct idm_task_s *task, struct idm_pdu_s *pdu, uint8_t opcode);
153 struct idm_task_s *task, struct idm_pdu_s *pdu);
482 idm_pdu_free(idm_pdu_t *pdu);
485 idm_pdu_init(idm_pdu_t *pdu, idm_conn_t *ic, void *private, idm_pdu_cb_t *cb);
488 idm_pdu_init_hdr(idm_pdu_t *pdu, uint8_t *hdr, uint_t hdrlen);
491 idm_pdu_init_data(idm_pdu_t *pdu, uint8_t *data, uint_t datalen);
494 idm_pdu_complete(idm_pdu_t *pdu, idm_status_t status);
[all …]
H A Didm_transport.h68 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 Didm_impl.h480 idm_pdu_rx(idm_conn_t *ic, idm_pdu_t *pdu);
483 idm_pdu_tx_forward(idm_conn_t *ic, idm_pdu_t *pdu);
486 idm_pdu_rx_forward_ffp(idm_conn_t *ic, idm_pdu_t *pdu);
489 idm_pdu_rx_forward(idm_conn_t *ic, idm_pdu_t *pdu);
492 idm_pdu_tx_protocol_error(idm_conn_t *ic, idm_pdu_t *pdu);
495 idm_pdu_rx_protocol_error(idm_conn_t *ic, idm_pdu_t *pdu);

12