Lines Matching refs:stream1
92 static struct tapdisk_stream stream1, stream2; variable
253 idx1 = (unsigned long)tapdisk_stream_request_idx(&stream1, in tapdisk_result_compare()
257 buf1 = (char *)MMAP_VADDR(stream1.vbd->ring.vstart, idx1, 0); in tapdisk_result_compare()
271 sreq1 = list_entry(stream1.completed_list.next, in tapdisk_stream_process_data()
280 &sreq1->next != &stream1.completed_list && in tapdisk_stream_process_data()
293 stream1.completed++; in tapdisk_stream_process_data()
297 list_add_tail(&sreq1->next, &stream1.free_list); in tapdisk_stream_process_data()
335 stream1.err = EINVAL; in tapdisk_stream_dequeue()
339 tapdisk_stream_poll_set(&stream1.poll); in tapdisk_stream_dequeue()
396 struct tapdisk_stream *s = &stream1; in tapdisk_stream_enqueue1()
477 list_for_each_entry(itr, &stream1.completed_list, next) { in tapdisk_stream_enqueue2()
484 list_for_each_entry(itr, &stream1.pending_list, next) { in tapdisk_stream_enqueue2()
491 stream2.cur = stream1.cur; in tapdisk_stream_enqueue2()
500 return (tapdisk_stream_stop(&stream1) && tapdisk_stream_stop(&stream2)); in tapdisk_diff_done()
506 tapdisk_stream_close_image(&stream1); in tapdisk_diff_stop()
522 if (s == &stream1) in tapdisk_stream_enqueue()
766 err = tapdisk_stream_open(&stream1, arg1); in main()
780 if (stream1.end != stream2.end) { in main()
782 stream1.end, stream2.end); in main()
792 tapdisk_stream_release(&stream1); in main()
797 return err ? : stream1.err; in main()