Cross Reference: /external/chromium_org/mojo/system/local_data_pipe

Lines Matching refs:dp
31     scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(default_options));
32     dp->ProducerClose();
33     dp->ConsumerClose();
48     scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
49     dp->ProducerClose();
50     dp->ConsumerClose();
63     scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
64     dp->ProducerClose();
65     dp->ConsumerClose();
78     scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
79     dp->ProducerClose();
80     dp->ConsumerClose();
94     scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
95     dp->ProducerClose();
96     dp->ConsumerClose();
112   scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
121       dp->ConsumerReadData(
126   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
132             dp->ConsumerDiscardData(MakeUserPointer(&num_bytes), false));
138       dp->ConsumerReadData(
146             dp->ProducerWriteData(UserPointer<const void>(elements),
154   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
163       dp->ConsumerReadData(
171   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
180       dp->ConsumerReadData(
191       dp->ConsumerReadData(
198   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
201   dp->ProducerClose();
202   dp->ConsumerClose();
223   scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
233       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 12, &hss));
242       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 34, &hss));
248             dp->ProducerWriteData(UserPointer<const void>(elements),
257       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 56, nullptr));
261   dp->ProducerRemoveWaiter(&waiter, &hss);
269       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 78, nullptr));
277       dp->ConsumerReadData(
287   dp->ProducerRemoveWaiter(&waiter, &hss);
295             dp->ProducerBeginWriteData(
302             dp->ProducerEndWriteData(
309       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 90, nullptr));
316       dp->ConsumerBeginReadData(
326       dp->ConsumerEndReadData(static_cast<uint32_t>(1u * sizeof(elements[0]))));
332   dp->ProducerRemoveWaiter(&waiter, &hss);
340             dp->ProducerWriteData(UserPointer<const void>(elements),
349       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 12, nullptr));
352   dp->ConsumerClose();
358   dp->ProducerRemoveWaiter(&waiter, &hss);
362   dp->ProducerClose();
378     scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
388         dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 12, &hss));
395               dp->ConsumerAddWaiter(
399     dp->ConsumerRemoveWaiter(&waiter, &hss);
407               dp->ProducerWriteData(UserPointer<const void>(elements),
416         dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 56, &hss));
423               dp->ConsumerDiscardData(MakeUserPointer(&num_bytes), true));
431         dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 78, &hss));
441         dp->ConsumerReadData(
450               dp->ConsumerAddWaiter(
458               dp->ProducerWriteData(UserPointer<const void>(elements),
466     dp->ConsumerRemoveWaiter(&waiter, &hss);
471     dp->ProducerClose();
478         dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 12, &hss));
488         dp->ConsumerReadData(
499         dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 34, &hss));
503     dp->ConsumerClose();
509     scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
520               dp->ProducerBeginWriteData(
528               dp->ProducerEndWriteData(
536         dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 12, &hss));
546         dp->ConsumerBeginReadData(
553               dp->ConsumerEndReadData(
561         dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 34, &hss));
571         dp->ConsumerBeginReadData(
578               dp->ConsumerEndReadData(
584               dp->ConsumerAddWaiter(
588     dp->ProducerClose();
594     dp->ConsumerRemoveWaiter(&waiter, &hss);
598     dp->ConsumerClose();
615   scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
624       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 0, &hss));
632       dp->ProducerBeginWriteData(
641       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 1, nullptr));
644   dp->ProducerRemoveWaiter(&waiter, &hss);
652       dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 2, nullptr));
655   dp->ConsumerRemoveWaiter(&waiter, &hss);
662       dp->ProducerEndWriteData(static_cast<uint32_t>(1u * sizeof(int32_t))));
669       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 3, &hss));
678       dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 4, &hss));
688       dp->ProducerBeginWriteData(
698       dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 5, &hss));
703   EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(0u));
710       dp->ConsumerBeginReadData(
720       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 6, &hss));
728       dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 7, nullptr));
731   dp->ConsumerRemoveWaiter(&waiter, &hss);
736   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(0u));
743       dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 8, &hss));
747   dp->ProducerClose();
748   dp->ConsumerClose();
764   scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
773       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 0, &hss));
781       dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 1, nullptr));
784   dp->ConsumerRemoveWaiter(&waiter, &hss);
791             dp->ProducerWriteData(UserPointer<const void>(&element),
801       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 2, &hss));
810       dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 3, &hss));
818             dp->ProducerWriteData(UserPointer<const void>(&element),
828       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 4, &hss));
837       dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 5, &hss));
846       dp->ConsumerReadData(
856       dp->ProducerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_WRITABLE, 6, &hss));
864       dp->ConsumerAddWaiter(&waiter, MOJO_HANDLE_SIGNAL_READABLE, 7, nullptr));
867   dp->ConsumerRemoveWaiter(&waiter, &hss);
871   dp->ProducerClose();
872   dp->ConsumerClose();
892   scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
903       dp->ProducerWriteData(
911             dp->ConsumerReadData(
926       dp->ProducerWriteData(
936             dp->ConsumerReadData(
954       dp->ProducerWriteData(
965       dp->ProducerWriteData(
975             dp->ConsumerReadData(
1000       dp->ProducerBeginWriteData(
1005   EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(6u * sizeof(int32_t)));
1015       dp->ProducerBeginWriteData(
1019   EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(1u * sizeof(int32_t)));
1028       dp->ProducerBeginWriteData(
1037       dp->ProducerBeginWriteData(
1042   EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(4u * sizeof(int32_t)));
1052       dp->ProducerBeginWriteData(
1057   EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(3u * sizeof(int32_t)));
1065             dp->ConsumerReadData(
1079   dp->ProducerClose();
1080   dp->ConsumerClose();
1095   scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
1103       dp->ProducerWriteData(
1108   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1116       dp->ProducerWriteData(
1122   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1130       dp->ProducerWriteData(
1137             dp->ConsumerReadData(
1146             dp->ConsumerDiscardData(MakeUserPointer(&num_bytes), true));
1153       dp->ProducerWriteData(
1162       dp->ProducerWriteData(
1168   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1175             dp->ConsumerReadData(
1186             dp->ConsumerReadData(
1194             dp->ConsumerDiscardData(MakeUserPointer(&num_bytes), true));
1199             dp->ConsumerDiscardData(MakeUserPointer(&num_bytes), true));
1204   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1208   dp->ProducerClose();
1214             dp->ConsumerReadData(
1222             dp->ConsumerDiscardData(MakeUserPointer(&num_bytes), true));
1228             dp->ConsumerReadData(
1238             dp->ConsumerDiscardData(MakeUserPointer(&num_bytes), true));
1243   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1246   dp->ConsumerClose();
1261   scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
1269       dp->ProducerWriteData(
1277       dp->ProducerWriteData(
1286       dp->ProducerWriteData(
1294             dp->ConsumerReadData(
1306             dp->ConsumerReadData(
1314             dp->ConsumerDiscardData(MakeUserPointer(&num_bytes), true));
1319             dp->ConsumerDiscardData(MakeUserPointer(&num_bytes), true));
1323   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1331       dp->ProducerWriteData(
1339             dp->ConsumerReadData(
1349   dp->ProducerClose();
1350   dp->ConsumerClose();
1365   scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
1372       dp->ProducerBeginWriteData(
1382       dp->ProducerBeginWriteData(
1389             dp->ConsumerBeginReadData(
1397       dp->ProducerBeginWriteData(
1403   EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(5u * sizeof(int32_t)));
1410             dp->ConsumerBeginReadData(
1417             dp->ConsumerBeginReadData(
1421   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(1u * sizeof(int32_t)));
1425   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1434       dp->ProducerBeginWriteData(
1443       dp->ProducerWriteData(
1449   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1456             dp->ConsumerBeginReadData(
1460   dp->ProducerClose();
1466             dp->ConsumerBeginReadData(
1478   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(9u * sizeof(int32_t)));
1484             dp->ConsumerBeginReadData(
1487   dp->ConsumerClose();
1513   scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
1518             dp->ProducerWriteData(UserPointer<const void>(&test_data[0]),
1528       dp->ConsumerReadData(
1539             dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr),
1544   EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(0u));
1550             dp->ProducerWriteData(UserPointer<const void>(&test_data[20]),
1561             dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr),
1566   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(0u));
1575       dp->ConsumerReadData(
1580   dp->ProducerClose();
1581   dp->ConsumerClose();
1603     scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
1608               dp->ProducerWriteData(UserPointer<const void>(kTestData),
1616               dp->ProducerWriteData(UserPointer<const void>(kTestData),
1625               dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr),
1635               dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr),
1642     dp->ProducerClose();
1646     EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(kTestDataSize));
1652               dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr),
1659     dp->ConsumerClose();
1664     scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
1669               dp->ProducerWriteData(UserPointer<const void>(kTestData),
1678               dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr),
1688               dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr),
1695     dp->ConsumerClose();
1702     EXPECT_EQ(MOJO_RESULT_OK, dp->ProducerEndWriteData(kTestDataSize));
1707               dp->ProducerWriteData(UserPointer<const void>(kTestData),
1715               dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr),
1719     dp->ProducerClose();
1725     scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
1731               dp->ProducerBeginWriteData(MakeUserPointer(&write_buffer_ptr),
1737     dp->ConsumerClose();
1738     dp->ProducerClose();
1743     scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
1748               dp->ProducerWriteData(UserPointer<const void>(kTestData),
1754     dp->ProducerClose();
1761         dp->ConsumerReadData(
1770         dp->ConsumerReadData(
1777               dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr),
1784               dp->ConsumerDiscardData(MakeUserPointer(&num_bytes), false));
1786     dp->ConsumerClose();
1802   scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
1806   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1811             dp->ProducerEndWriteData(1u * sizeof(int32_t)));
1815   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1823       dp->ProducerBeginWriteData(
1826             dp->ProducerEndWriteData(num_bytes +
1830   EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, dp->ProducerEndWriteData(0u));
1834   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1843       dp->ProducerBeginWriteData(
1846   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, dp->ProducerEndWriteData(1u));
1849   EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, dp->ProducerEndWriteData(0u));
1853   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1860             dp->ProducerWriteData(UserPointer<const void>(&element),
1866   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1871             dp->ConsumerEndReadData(1u * sizeof(int32_t)));
1875   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1883       dp->ConsumerBeginReadData(
1886             dp->ConsumerEndReadData(num_bytes +
1891   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1900       dp->ConsumerBeginReadData(
1904   EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, dp->ConsumerEndReadData(1u));
1908   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerQueryData(MakeUserPointer(&num_bytes)));
1911   dp->ProducerClose();
1912   dp->ConsumerClose();
1934   scoped_refptr<LocalDataPipe> dp(new LocalDataPipe(validated_options));
1940             dp->ProducerWriteData(UserPointer<const void>(elements),
1950       dp->ConsumerBeginReadData(
1962   //            dp->ProducerWriteData(elements, &num_bytes, false));
1966             dp->ProducerWriteData(UserPointer<const void>(elements),
1975   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(2u));
1979             dp->ProducerWriteData(UserPointer<const void>(elements),
1988       dp->ConsumerBeginReadData(
1995   EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(2u));
1997   dp->ProducerClose();
1998   dp->ConsumerClose();