Lines Matching defs:pdu_p
189 struct isns_pdu_s *pdu_p;
192 pdu_p = trans_p->pdu_rsp_list;
194 while (pdu_p->next != NULL) {
195 if (pdu_p->hdr.seq_id != count++) return 0;
196 pdu_p = pdu_p->next;
198 if ((pdu_p->hdr.seq_id != count) ||
199 !(pdu_p->hdr.flags & ISNS_FLAG_LAST_PDU))
209 isns_is_valid_resp(struct isns_trans_s *trans_p, struct isns_pdu_s *pdu_p)
213 if (pdu_p->hdr.trans_id != trans_p->id)
215 if (pdu_p->hdr.func_id != (trans_p->func_id | 0x8000))
219 if (curpdu_p->hdr.seq_id == pdu_p->hdr.seq_id) return 0;
263 struct isns_pdu_s *pdu_p;
293 pdu_p = isns_new_pdu(cfg_p, 0, 0, 0);
296 read_buf[0].iov_base = &(pdu_p->hdr);
318 pdu_p->hdr.isnsp_version = isns_ntohs(pdu_p->hdr.
320 pdu_p->hdr.func_id = isns_ntohs(pdu_p->hdr.func_id);
321 pdu_p->hdr.payload_len = isns_ntohs(pdu_p->hdr.
323 pdu_p->hdr.flags = isns_ntohs(pdu_p->hdr.flags);
324 pdu_p->hdr.trans_id = isns_ntohs(pdu_p->hdr.trans_id);
325 pdu_p->hdr.seq_id = isns_ntohs(pdu_p->hdr.seq_id);
326 pdu_p->byteorder_host = 1;
329 if (pdu_p->hdr.isnsp_version != ISNSP_VERSION) {
330 DBG("isns_kevent_socket: pdu_p->hdr."
332 isns_free_pdu(pdu_p);
339 payload_len = pdu_p->hdr.payload_len;
340 curbuf_p = pdu_p->payload_p;
351 cfg_p->pdu_in_p = pdu_p;
370 pdu_p = cfg_p->pdu_in_p;
374 curbuf_p = pdu_p->payload_p;
382 unread_len = pdu_p->hdr.payload_len - cur_len;
412 curbuf_p = pdu_p->payload_p;