| /third_party/boost/libs/beast/test/beast/websocket/ |
| D | read1.cpp | 34 stream<tcp::socket> ws1(ioc); in testTimeout() local
36 test::connect(ws1.next_layer(), ws2.next_layer()); in testTimeout()
37 ws1.async_handshake("test", "/", test::success_handler()); in testTimeout()
42 ws1.async_write(net::const_buffer("Hello, world!", 13), in testTimeout()
49 stream<test::stream> ws1(ioc); in testTimeout() local
51 test::connect(ws1.next_layer(), ws2.next_layer()); in testTimeout()
52 ws1.async_handshake("test", "/", test::success_handler()); in testTimeout()
57 ws1.async_write(net::const_buffer("Hello, world!", 13), in testTimeout()
66 stream<tcp::socket> ws1(ioc); in testTimeout() local
68 test::connect(ws1.next_layer(), ws2.next_layer()); in testTimeout()
[all …]
|
| D | timer.cpp | 36 stream<tcp::socket> ws1(ioc); in testIdlePing() local
38 test::connect(ws1.next_layer(), ws2.next_layer()); in testIdlePing()
39 ws1.async_accept(test::success_handler()); in testIdlePing()
50 ws1.control_callback( in testIdlePing()
56 ws1.async_read(b1, test::fail_handler( in testIdlePing()
69 stream<tcp::socket> ws1(ioc); in testIdlePing() local
71 test::connect(ws1.next_layer(), ws2.next_layer()); in testIdlePing()
72 ws1.async_accept(test::success_handler()); in testIdlePing()
95 stream<tcp::socket> ws1(ioc); in testIssue1729() local
97 test::connect(ws1.next_layer(), ws2.next_layer()); in testIssue1729()
[all …]
|
| D | handshake.cpp | 526 stream<tcp::socket> ws1(ioc); in testAsync() local
528 test::connect(ws1.next_layer(), ws2.next_layer()); in testAsync()
530 ws1.async_handshake("test", "/", test::success_handler()); in testAsync()
536 stream<test::stream> ws1(ioc); in testAsync() local
538 test::connect(ws1.next_layer(), ws2.next_layer()); in testAsync()
540 ws1.async_handshake("test", "/", test::success_handler()); in testAsync()
548 stream<tcp::socket> ws1(ioc); in testAsync() local
550 test::connect(ws1.next_layer(), ws2.next_layer()); in testAsync()
552 ws1.set_option(stream_base::timeout{ in testAsync()
556 ws1.async_handshake("test", "/", test::success_handler()); in testAsync()
[all …]
|
| D | accept.cpp | 710 stream<tcp::socket> ws1(ioc); in testAsync() local
712 test::connect(ws1.next_layer(), ws2.next_layer()); in testAsync()
714 ws1.async_handshake("test", "/", test::success_handler()); in testAsync()
720 stream<test::basic_stream<net::io_context::executor_type>> ws1(ioc); in testAsync() local
722 test::connect(ws1.next_layer(), ws2.next_layer()); in testAsync()
724 ws1.async_handshake("test", "/", test::success_handler()); in testAsync()
732 stream<tcp::socket> ws1(ioc); in testAsync() local
734 test::connect(ws1.next_layer(), ws2.next_layer()); in testAsync()
736 ws1.set_option(stream_base::timeout{ in testAsync()
740 ws1.async_accept(test::success_handler()); in testAsync()
[all …]
|
| D | close.cpp | 186 stream<tcp::socket> ws1(ioc); in testTimeout() local
188 test::connect(ws1.next_layer(), ws2.next_layer()); in testTimeout()
189 ws1.async_handshake("test", "/", test::success_handler()); in testTimeout()
193 ws1.async_close({}, test::success_handler()); in testTimeout()
199 stream<test::stream> ws1(ioc); in testTimeout() local
201 test::connect(ws1.next_layer(), ws2.next_layer()); in testTimeout()
202 ws1.async_handshake("test", "/", test::success_handler()); in testTimeout()
206 ws1.async_close({}, test::success_handler()); in testTimeout()
214 stream<tcp::socket> ws1(ioc); in testTimeout() local
216 test::connect(ws1.next_layer(), ws2.next_layer()); in testTimeout()
[all …]
|
| D | ping.cpp | 383 stream<socket_type> ws1(ioc); in testSuspend() local
385 ws1.set_option(stream_base::timeout{ in testSuspend()
390 ws1.next_layer(), in testSuspend()
392 ws1.async_handshake("localhost", "/", in testSuspend()
401 ws1.async_write(b1.data(), in testSuspend()
404 ws1.impl_->wr_block.is_locked()); in testSuspend()
405 ws1.async_read_some(net::mutable_buffer{}, in testSuspend()
|
| D | write.cpp | 695 stream<test::stream> ws1{ioc}; in testIssue1666() local
696 ws0.next_layer().connect(ws1.next_layer()); in testIssue1666()
698 ws1.set_option(pmd); in testIssue1666()
699 ws1.async_accept( in testIssue1666()
716 ws1.write(net::buffer(s), ec); in testIssue1666()
|
| /third_party/boost/libs/process/test/ |
| D | pipe.cpp | 310 bp::wpstream ws1(p);
313 ws2.pipe(std::move(ws1.pipe()));
317 ws1 = p2;
321 ws1.pipe(ws2c.pipe());
326 bp::wpipebuf ws1(p);
329 ws2.pipe(std::move(ws1.pipe()));
333 ws1 = p2;
337 ws1.pipe(ws2c.pipe());
|
| /third_party/boost/libs/io/test/ |
| D | quoted_manip_test.cpp | 90 wstring ws1(L"foo$bar, \" *"); in main() local
94 wss << quoted(ws1, L'$'); in main()
96 BOOST_TEST(wr == ws1); in main()
|
| D | quoted_test.cpp | 76 const std::wstring ws1(L"foo$bar, \" *"); in main() local
80 wss << boost::io::quoted(ws1, L'$'); in main()
82 BOOST_TEST(wr == ws1); in main()
|
| /third_party/jerryscript/tests/jerry/es2015/ |
| D | new-target-for-containers.js | 81 var ws1= new MyWeakSet(); variable
86 assert(Object.getPrototypeOf(ws1) == MyWeakSet.prototype)
|
| /third_party/boost/libs/date_time/test/gregorian/ |
| D | testfacet.cpp | 287 std::wstringstream ws1(L"Dec"); in main() local
288 ws1 >> m; in main()
316 std::wstringstream ws1(L"Saturday"); in main() local
317 ws1 >> wd; in main()
|
| /third_party/python/Modules/ |
| D | _localemodule.c | 360 wchar_t *ws1 = NULL, *ws2 = NULL; in _locale_strcoll_impl() local
363 ws1 = PyUnicode_AsWideCharString(os1, NULL); in _locale_strcoll_impl()
364 if (ws1 == NULL) in _locale_strcoll_impl()
370 result = PyLong_FromLong(wcscoll(ws1, ws2)); in _locale_strcoll_impl()
373 if (ws1) PyMem_Free(ws1); in _locale_strcoll_impl()
|
| /third_party/boost/libs/regex/example/timer/ |
| D | regex_timer.cpp | 139 std::wstring ws1, ws2; in main() local
164 ws1.erase(); in main()
165 std::copy(s1.begin(), s1.end(), string_out_iterator<std::wstring>(ws1)); in main()
170 wex.assign(ws1); in main()
|
| /third_party/boost/libs/filesystem/test/ |
| D | path_unit_test.cpp | 865 const std::wstring ws1(L"b2"); // off-by-one mimics test_codecvt in test_codecvt_argument() local
877 NATIVE_IS(p, s1, ws1); in test_codecvt_argument()
881 NATIVE_IS(p1, s1, ws1); in test_codecvt_argument()
897 NATIVE_IS(p1, s1, ws1); in test_codecvt_argument()
901 NATIVE_IS(p1, s1, ws1); in test_codecvt_argument()
908 NATIVE_IS(p1, s1, ws1); in test_codecvt_argument()
912 NATIVE_IS(p1, s1, ws1); in test_codecvt_argument()
921 CHECK(p.string<std::wstring>(cvt) == ws1); in test_codecvt_argument()
923 CHECK(p.wstring(cvt) == ws1); in test_codecvt_argument()
931 CHECK(p.generic_string<std::wstring>(cvt) == ws1); in test_codecvt_argument()
[all …]
|
| /third_party/boost/libs/spirit/classic/test/ |
| D | symbols_tests.cpp | 104 symbols<int, wchar_t> ws1; in default_constructible() local
108 (void)ns1; (void)ws1; (void)ns2; (void)ws2; in default_constructible()
|
| /third_party/boost/tools/quickbook/test/unit/ |
| D | symbols_tests.cpp | 85 symbols<int, wchar_t, quickbook::tst<int, wchar_t> > ws1; in default_constructible() local
90 (void)ws1; in default_constructible()
|
| /third_party/flutter/flutter/packages/flutter_driver/lib/src/driver/ |
| D | driver.dart | 1143 WebSocket ws1;
1146 ws1 = await WebSocket.connect(webSocketUrl);
1149 ws1.done.whenComplete(() => _checkCloseCode(ws1));
1153 VMServiceClient(IOWebSocketChannel(ws1).cast()),
1160 await ws1?.close();
|