lib/libisns/isns_pdu.c

363 	struct isns_trans_s *trans_p;
378 	trans_p = (struct isns_trans_s *)isns_buffer_data(buf_p, 0);
379 	trans_p->id = isns_get_next_trans_id();
380 	trans_p->func_id = func_id;
381 	trans_p->flags = 0;
382 	trans_p->cfg_p = (struct isns_config_s *)isns_handle;
383 	trans_p->pdu_req_list = NULL;
384 	trans_p->pdu_rsp_list = NULL;
385 	trans_p->disconnect_cnt = 0;
387 	trans_p->get_tlv_info.pdu_p = NULL;
388 	trans_p->get_tlv_info.buf_p = NULL;
389 	trans_p->get_tlv_info.extra_buf_list = NULL;
390 	trans_p->get_tlv_info.buf_ofs = 0;
404 	if (trans_p->cfg_p->is_server)
409 	pdu_p = isns_new_pdu(trans_p->cfg_p, trans_p->id, func_id, pdu_flags);
416 	isns_add_pdu_request((ISNS_TRANS)trans_p, pdu_p);
418 	DBG("isns_new_trans: %p\n", trans_p);
420 	return (ISNS_TRANS)trans_p;
430 	struct isns_trans_s *trans_p;
438 		trans_p = (struct isns_trans_s *)trans;
440 		trans_flags = isns_set_trans_flags(trans_p,
449 		    trans_p->pdu_req_list);
450 		while ((pdu_p = trans_p->pdu_req_list) != NULL) {
451 			trans_p->pdu_req_list = pdu_p->next;
455 		    trans_p->pdu_rsp_list);
456 		while ((pdu_p = trans_p->pdu_rsp_list) != NULL) {
457 			trans_p->pdu_rsp_list = pdu_p->next;
461 		    trans_p->get_tlv_info.extra_buf_list);
462 		buf_p = trans_p->get_tlv_info.extra_buf_list;
470 		buf_p = ((struct isns_buffer_s *)(void *)(trans_p))-1;
488 	struct isns_trans_s *trans_p;
492 	trans_p = (struct isns_trans_s *)trans;
494 	DBG("isns_send_trans: trans_p=%p, timeout_p=%p\n", trans_p, timeout_p);
499 	if (!isns_is_socket_init_done(trans_p->cfg_p)) {
501 		isns_complete_trans(trans_p);
532 isns_complete_trans(struct isns_trans_s *trans_p)
536 	DBG("isns_complete_trans: trans_p=%p\n", trans_p);
538 	flags = isns_set_trans_flags(trans_p, ISNS_TRANSF_COMPLETE);
541 		isns_free_trans(trans_p);
553 	    && (task_p->var.send_pdu.trans_p->id == trans_id)) {
554 		isns_complete_trans(task_p->var.send_pdu.trans_p);
562 		isns_complete_trans(task_p->var.send_pdu.trans_p);
590 	struct isns_trans_s *trans_p;
609 	trans_p = (struct isns_trans_s *)trans;
612 	rval = isns_add_pdu_payload_data(trans_p, tlv_buf, ISNS_TLV_HDR_SIZE);
616 		rval = isns_add_pdu_payload_data(trans_p, data_p, data_len);
636 	struct isns_trans_s *trans_p;
646 	trans_p = (struct isns_trans_s *)trans;
647 	if ((isns_get_trans_flags(trans_p) & ISNS_TRANSF_COMPLETE) == 0) {
653 	pdu_p = isns_get_pdu_response(trans_p);
665 	info_p = &trans_p->get_tlv_info;
718 isns_set_trans_flags(struct isns_trans_s *trans_p, uint32_t flags)
720 	pthread_mutex_lock(&trans_p->cfg_p->trans_mutex);
721 	trans_p->flags |= flags;
722 	flags = trans_p->flags;
723 	pthread_mutex_unlock(&trans_p->cfg_p->trans_mutex);
733 isns_add_pdu_request(struct isns_trans_s *trans_p, struct isns_pdu_s *pdu_p)
735 	DBG("isns_add_pdu_request: trans_p=%p, pdu_p=%p\n", trans_p, pdu_p);
737 	isns_add_pdu_list(&trans_p->pdu_req_list, pdu_p);
745 isns_add_pdu_response(struct isns_trans_s *trans_p, struct isns_pdu_s *pdu_p)
747 	DBG("isns_add_pdu_response: trans_p=%p, pdu_p=%p\n", trans_p, pdu_p);
749 	isns_add_pdu_list(&trans_p->pdu_rsp_list, pdu_p);
757 isns_get_pdu_request_tail(struct isns_trans_s *trans_p)
761 	if ((pdu_p = isns_get_pdu_request(trans_p)) != NULL) {
830 	struct isns_trans_s *trans_p;
844 	trans_p = (struct isns_trans_s *)trans;
849 	task_p->var.send_pdu.trans_p = trans_p;
863 			     trans_p->id);
866 			    ISNS_CMD_ABORT_TRANS, (void *)&trans_p->id,
867 			    (int)sizeof(trans_p->id));
925 isns_add_pdu_payload_data(struct isns_trans_s *trans_p, const void *data_p,
935 	if ((pdu_p = isns_get_pdu_request_tail(trans_p)) == NULL) {
954 			new_pdu_p = isns_new_pdu(trans_p->cfg_p,
955 			    trans_p->id, trans_p->func_id, pdu_p->hdr.flags);
958 			isns_add_pdu_request(trans_p, new_pdu_p);
1138 isns_get_pdu_response_status(struct isns_trans_s *trans_p, uint32_t *status_p)
1142 	if ((isns_get_trans_flags(trans_p) & ISNS_TRANSF_COMPLETE) == 0)
1145 	pdu_p = isns_get_pdu_response(trans_p);