Lines Matching defs:next_rrd
1830 struct receive_record_arg *next_rrd;
2430 * Allocate ra->next_rrd and read the next record's header into
2431 * ra->next_rrd->header.
2456 ra->next_rrd = kmem_zalloc(sizeof (*ra->next_rrd), KM_SLEEP);
2457 err = receive_read(ra, sizeof (ra->next_rrd->header),
2458 &ra->next_rrd->header);
2459 ra->next_rrd->bytes_read = ra->bytes_read;
2461 kmem_free(ra->next_rrd, sizeof (*ra->next_rrd));
2462 ra->next_rrd = NULL;
2465 if (ra->next_rrd->header.drr_type == DRR_BEGIN) {
2466 kmem_free(ra->next_rrd, sizeof (*ra->next_rrd));
2467 ra->next_rrd = NULL;
2479 &ra->next_rrd->header);
2482 ra->next_rrd->header.drr_u.drr_checksum.drr_checksum;
2484 &ra->next_rrd->header.drr_u.drr_checksum.drr_checksum;
2487 byteswap_record(&ra->next_rrd->header);
2491 kmem_free(ra->next_rrd, sizeof (*ra->next_rrd));
2492 ra->next_rrd = NULL;
2986 ra.rrd = ra.next_rrd;
2987 ra.next_rrd = NULL;
2988 /* Allocates and loads header into ra.next_rrd */
3001 if (ra.next_rrd == NULL)
3002 ra.next_rrd = kmem_zalloc(sizeof (*ra.next_rrd), KM_SLEEP);
3003 ra.next_rrd->eos_marker = B_TRUE;
3004 bqueue_enqueue(&rwa.q, ra.next_rrd, 1);