Lines Matching refs:rv
42 int rv = stream.Open(temp_file_path(), in TEST_F() local
44 EXPECT_EQ(OK, rv); in TEST_F()
99 int rv = stream.Read(buf, arraysize(buf), NULL); in TEST_F() local
100 EXPECT_EQ(ERR_UNEXPECTED, rv); in TEST_F()
111 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
112 EXPECT_EQ(OK, rv); in TEST_F()
122 rv = stream.Read(buf, arraysize(buf), NULL); in TEST_F()
123 EXPECT_LE(0, rv); in TEST_F()
124 if (rv <= 0) in TEST_F()
126 total_bytes_read += rv; in TEST_F()
127 data_read.append(buf, rv); in TEST_F()
142 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
143 EXPECT_EQ(OK, rv); in TEST_F()
155 rv = stream.Read(buf, arraysize(buf), &callback); in TEST_F()
156 if (rv == ERR_IO_PENDING) in TEST_F()
157 rv = callback.WaitForResult(); in TEST_F()
158 EXPECT_LE(0, rv); in TEST_F()
159 if (rv <= 0) in TEST_F()
161 total_bytes_read += rv; in TEST_F()
162 data_read.append(buf, rv); in TEST_F()
177 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
178 EXPECT_EQ(OK, rv); in TEST_F()
186 rv = stream.Read(buf, arraysize(buf), &callback); in TEST_F()
188 if (rv < 0) { in TEST_F()
189 EXPECT_EQ(ERR_IO_PENDING, rv); in TEST_F()
194 EXPECT_EQ(std::string(kTestData, rv), std::string(buf, rv)); in TEST_F()
206 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
207 EXPECT_EQ(OK, rv); in TEST_F()
221 rv = stream.Read(buf, arraysize(buf), NULL); in TEST_F()
222 EXPECT_LE(0, rv); in TEST_F()
223 if (rv <= 0) in TEST_F()
225 total_bytes_read += rv; in TEST_F()
226 data_read.append(buf, rv); in TEST_F()
242 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
243 EXPECT_EQ(OK, rv); in TEST_F()
259 rv = stream.Read(buf, arraysize(buf), &callback); in TEST_F()
260 if (rv == ERR_IO_PENDING) in TEST_F()
261 rv = callback.WaitForResult(); in TEST_F()
262 EXPECT_LE(0, rv); in TEST_F()
263 if (rv <= 0) in TEST_F()
265 total_bytes_read += rv; in TEST_F()
266 data_read.append(buf, rv); in TEST_F()
276 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
277 EXPECT_EQ(OK, rv); in TEST_F()
299 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
300 EXPECT_EQ(OK, rv); in TEST_F()
307 rv = stream.Write(kTestData, kTestDataSize, NULL); in TEST_F()
308 EXPECT_EQ(kTestDataSize, rv); in TEST_F()
321 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
322 EXPECT_EQ(OK, rv); in TEST_F()
333 rv = stream.Write(kTestData + total_bytes_written, in TEST_F()
336 if (rv == ERR_IO_PENDING) in TEST_F()
337 rv = callback.WaitForResult(); in TEST_F()
338 EXPECT_LT(0, rv); in TEST_F()
339 if (rv <= 0) in TEST_F()
341 total_bytes_written += rv; in TEST_F()
353 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
354 EXPECT_EQ(OK, rv); in TEST_F()
364 rv = stream.Write(kTestData + total_bytes_written, in TEST_F()
368 if (rv < 0) { in TEST_F()
369 EXPECT_EQ(ERR_IO_PENDING, rv); in TEST_F()
376 EXPECT_EQ(file_size, rv); in TEST_F()
384 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
385 EXPECT_EQ(OK, rv); in TEST_F()
396 rv = stream.Write(kTestData, kTestDataSize, NULL); in TEST_F()
397 EXPECT_EQ(kTestDataSize, rv); in TEST_F()
414 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
415 EXPECT_EQ(OK, rv); in TEST_F()
425 rv = stream.Write(kTestData + total_bytes_written, in TEST_F()
428 if (rv == ERR_IO_PENDING) in TEST_F()
429 rv = callback.WaitForResult(); in TEST_F()
430 EXPECT_LT(0, rv); in TEST_F()
431 if (rv <= 0) in TEST_F()
433 total_bytes_written += rv; in TEST_F()
449 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
450 EXPECT_EQ(OK, rv); in TEST_F()
460 rv = stream.Read(buf, arraysize(buf), NULL); in TEST_F()
461 EXPECT_LE(0, rv); in TEST_F()
462 if (rv <= 0) in TEST_F()
464 total_bytes_read += rv; in TEST_F()
465 data_read.append(buf, rv); in TEST_F()
470 rv = stream.Write(kTestData, kTestDataSize, NULL); in TEST_F()
471 EXPECT_EQ(kTestDataSize, rv); in TEST_F()
488 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
489 EXPECT_EQ(OK, rv); in TEST_F()
497 rv = stream.Write(kTestData, kTestDataSize, NULL); in TEST_F()
498 EXPECT_EQ(kTestDataSize, rv); in TEST_F()
508 rv = stream.Read(buf, arraysize(buf), NULL); in TEST_F()
509 EXPECT_LE(0, rv); in TEST_F()
510 if (rv <= 0) in TEST_F()
512 total_bytes_read += rv; in TEST_F()
513 data_read.append(buf, rv); in TEST_F()
537 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
538 EXPECT_EQ(OK, rv); in TEST_F()
549 rv = stream.Read(buf, arraysize(buf), &callback); in TEST_F()
550 if (rv == ERR_IO_PENDING) in TEST_F()
551 rv = callback.WaitForResult(); in TEST_F()
552 EXPECT_LE(0, rv); in TEST_F()
553 if (rv <= 0) in TEST_F()
555 total_bytes_read += rv; in TEST_F()
556 data_read.append(buf, rv); in TEST_F()
564 rv = stream.Write(kTestData + total_bytes_written, in TEST_F()
567 if (rv == ERR_IO_PENDING) in TEST_F()
568 rv = callback.WaitForResult(); in TEST_F()
569 EXPECT_LT(0, rv); in TEST_F()
570 if (rv <= 0) in TEST_F()
572 total_bytes_written += rv; in TEST_F()
592 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
593 EXPECT_EQ(OK, rv); in TEST_F()
605 rv = stream.Write(kTestData + total_bytes_written, in TEST_F()
608 if (rv == ERR_IO_PENDING) in TEST_F()
609 rv = callback.WaitForResult(); in TEST_F()
610 EXPECT_LT(0, rv); in TEST_F()
611 if (rv <= 0) in TEST_F()
613 total_bytes_written += rv; in TEST_F()
626 rv = stream.Read(buf, arraysize(buf), &callback); in TEST_F()
627 if (rv == ERR_IO_PENDING) in TEST_F()
628 rv = callback.WaitForResult(); in TEST_F()
629 EXPECT_LE(0, rv); in TEST_F()
630 if (rv <= 0) in TEST_F()
632 total_bytes_read += rv; in TEST_F()
633 data_read.append(buf, rv); in TEST_F()
678 int rv; in RunWithParams() local
686 rv = stream_->Write(kTestData + *total_bytes_written_, in RunWithParams()
689 DCHECK_EQ(ERR_IO_PENDING, rv); in RunWithParams()
690 rv = callback.WaitForResult(); in RunWithParams()
700 rv = stream_->Read(buf, arraysize(buf), &callback); in RunWithParams()
701 if (rv == ERR_IO_PENDING) { in RunWithParams()
704 rv = callback.WaitForResult(); in RunWithParams()
707 EXPECT_LE(0, rv); in RunWithParams()
708 if (rv <= 0) in RunWithParams()
710 *total_bytes_read_ += rv; in RunWithParams()
711 data_read_->append(buf, rv); in RunWithParams()
742 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
743 EXPECT_EQ(OK, rv); in TEST_F()
757 rv = stream.Write(kTestData + total_bytes_written, in TEST_F()
760 if (rv == ERR_IO_PENDING) in TEST_F()
761 rv = callback.WaitForResult(); in TEST_F()
762 EXPECT_LT(0, rv); in TEST_F()
803 int rv; in RunWithParams() local
809 rv = stream_->Write(kTestData + *total_bytes_written_, in RunWithParams()
812 DCHECK_EQ(ERR_IO_PENDING, rv); in RunWithParams()
813 rv = callback.WaitForResult(); in RunWithParams()
844 int rv = stream.Open(temp_file_path(), flags); in TEST_F() local
845 EXPECT_EQ(OK, rv); in TEST_F()
856 rv = stream.Write(kTestData, kTestDataSize, &callback); in TEST_F()
857 if (rv == ERR_IO_PENDING) in TEST_F()