| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/nearby_sharing/ |
| H A D | nearby_connection_impl.cc | 21 if (read_callback_) in ~NearbyConnectionImpl()
22 std::move(read_callback_).Run(base::nullopt); in ~NearbyConnectionImpl()
27 read_callback_ = std::move(callback); in Read()
34 std::move(read_callback_).Run(std::move(bytes)); in Read()
64 if (read_callback_) { in WriteMessage()
65 std::move(read_callback_).Run(std::move(bytes)); in WriteMessage()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/remoting/protocol/ |
| H A D | channel_socket_adapter.cc | 48 CHECK(read_callback_.is_null()); in Recv()
55 read_callback_ = callback; in Recv()
112 if (!read_callback_.is_null()) { in Close()
113 net::CompletionRepeatingCallback callback = read_callback_; in Close()
114 read_callback_.Reset(); in Close()
135 if (!read_callback_.is_null()) { in OnNewPacket()
147 net::CompletionRepeatingCallback callback = read_callback_; in OnNewPacket()
148 read_callback_.Reset(); in OnNewPacket()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/spdy/ |
| H A D | spdy_proxy_client_socket.cc | 117 DCHECK(read_callback_.is_null()); in Connect()
126 read_callback_ = std::move(callback); in Connect()
134 read_callback_.Reset(); in Disconnect()
214 DCHECK(!read_callback_); in ReadIfReady()
228 read_callback_ = std::move(callback); in ReadIfReady()
237 read_callback_.Reset(); in CancelReadIfReady()
296 std::move(read_callback_).Run(rv); in OnIOComplete()
482 if (read_callback_) { in OnDataReceived()
487 std::move(read_callback_).Run(rv); in OnDataReceived()
491 std::move(read_callback_).Run(OK); in OnDataReceived()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/net/spdy/ |
| H A D | spdy_proxy_client_socket.cc | 117 DCHECK(read_callback_.is_null()); in Connect()
126 read_callback_ = std::move(callback); in Connect()
134 read_callback_.Reset(); in Disconnect()
214 DCHECK(!read_callback_); in ReadIfReady()
228 read_callback_ = std::move(callback); in ReadIfReady()
237 read_callback_.Reset(); in CancelReadIfReady()
296 std::move(read_callback_).Run(rv); in OnIOComplete()
482 if (read_callback_) { in OnDataReceived()
487 std::move(read_callback_).Run(rv); in OnDataReceived()
491 std::move(read_callback_).Run(OK); in OnDataReceived()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/socket/ |
| H A D | sequenced_socket_data_unittest.cc | 223 TestCompletionCallback read_callback_; member in net::__anon61f0d71f0111::SequencedSocketDataTest
280 ASSERT_FALSE(read_callback_.have_result()); in AssertReadReturns()
302 EXPECT_FALSE(read_callback_.have_result()); in AssertAsyncWriteEquals()
537 ASSERT_FALSE(read_callback_.have_result()); in TEST_F()
606 ASSERT_FALSE(read_callback_.have_result()); in TEST_F()
611 ASSERT_FALSE(read_callback_.have_result()); in TEST_F()
953 ASSERT_FALSE(read_callback_.have_result()); in TEST_F()
963 ASSERT_FALSE(read_callback_.have_result()); in TEST_F()
989 ASSERT_FALSE(read_callback_.have_result()); in TEST_F()
1143 ASSERT_TRUE(read_callback_.have_result()); in TEST_F()
[all …]
|
| H A D | tcp_client_socket.cc | 108 DCHECK(!read_callback_); in Connect()
159 DCHECK(read_callback_.is_null()); in ReadCommon()
174 read_callback_ = std::move(callback); in ReadCommon()
296 read_callback_.Reset(); in Disconnect()
373 DCHECK(read_callback_); in CancelReadIfReady()
374 read_callback_.Reset(); in CancelReadIfReady()
473 if (read_callback_) in OnSuspend()
493 DCHECK(!read_callback_.is_null()); in DidCompleteRead()
497 DidCompleteReadWrite(std::move(read_callback_), result); in DidCompleteRead()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/net/socket/ |
| H A D | sequenced_socket_data_unittest.cc | 223 TestCompletionCallback read_callback_; member in net::__anone8ca24c40111::SequencedSocketDataTest
281 ASSERT_FALSE(read_callback_.have_result()); in AssertReadReturns()
303 EXPECT_FALSE(read_callback_.have_result()); in AssertAsyncWriteEquals()
538 ASSERT_FALSE(read_callback_.have_result()); in TEST_F()
607 ASSERT_FALSE(read_callback_.have_result()); in TEST_F()
612 ASSERT_FALSE(read_callback_.have_result()); in TEST_F()
954 ASSERT_FALSE(read_callback_.have_result()); in TEST_F()
964 ASSERT_FALSE(read_callback_.have_result()); in TEST_F()
990 ASSERT_FALSE(read_callback_.have_result()); in TEST_F()
1144 ASSERT_TRUE(read_callback_.have_result()); in TEST_F()
[all …]
|
| H A D | tcp_client_socket.cc | 117 DCHECK(!read_callback_); in Connect()
171 DCHECK(read_callback_.is_null()); in ReadCommon()
186 read_callback_ = std::move(callback); in ReadCommon()
330 read_callback_.Reset(); in Disconnect()
413 DCHECK(read_callback_); in CancelReadIfReady()
414 read_callback_.Reset(); in CancelReadIfReady()
513 if (read_callback_) in OnSuspend()
533 DCHECK(!read_callback_.is_null()); in DidCompleteRead()
537 DidCompleteReadWrite(std::move(read_callback_), result); in DidCompleteRead()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/extensions/browser/api/socket/ |
| H A D | tls_socket.cc | 59 if (read_callback_) { in Disconnect()
60 std::move(read_callback_) in Disconnect()
67 DCHECK(!read_callback_); in Read()
79 read_callback_ = std::move(callback); in Read()
141 DCHECK(read_callback_); in OnReadComplete()
146 ReadCompletionCallback callback = std::move(read_callback_); in OnReadComplete()
|
| H A D | mojo_data_pump.cc | 43 DCHECK(!read_callback_); in Read()
51 read_callback_ = std::move(callback); in Read()
70 DCHECK(read_callback_); in ReceiveMore()
89 std::move(read_callback_).Run(0, nullptr); in ReceiveMore()
92 std::move(read_callback_).Run(num_bytes, io_buffer); in ReceiveMore()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/extensions/browser/api/socket/ |
| H A D | tls_socket.cc | 59 if (read_callback_) { in Disconnect()
60 std::move(read_callback_) in Disconnect()
67 DCHECK(!read_callback_); in Read()
79 read_callback_ = std::move(callback); in Read()
141 DCHECK(read_callback_); in OnReadComplete()
146 ReadCompletionCallback callback = std::move(read_callback_); in OnReadComplete()
|
| H A D | mojo_data_pump.cc | 43 DCHECK(!read_callback_); in Read()
51 read_callback_ = std::move(callback); in Read()
70 DCHECK(read_callback_); in ReceiveMore()
89 std::move(read_callback_).Run(0, nullptr); in ReceiveMore()
92 std::move(read_callback_).Run(num_bytes, io_buffer); in ReceiveMore()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/storage/browser/file_system/ |
| H A D | file_system_file_stream_reader.cc | 58 read_callback_ = std::move(callback); in Read()
90 if (read_callback_) { in DidCreateSnapshot()
92 std::move(read_callback_).Run(net::FileErrorToNetError(file_error)); in DidCreateSnapshot()
124 if (read_callback_) { in DidCreateSnapshot()
130 std::move(read_callback_).Run(rv); in DidCreateSnapshot()
141 std::move(read_callback_).Run(rv); in OnRead()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/storage/browser/file_system/ |
| H A D | file_system_file_stream_reader.cc | 58 read_callback_ = std::move(callback); in Read()
90 if (read_callback_) { in DidCreateSnapshot()
92 std::move(read_callback_).Run(net::FileErrorToNetError(file_error)); in DidCreateSnapshot()
124 if (read_callback_) { in DidCreateSnapshot()
130 std::move(read_callback_).Run(rv); in DidCreateSnapshot()
141 std::move(read_callback_).Run(rv); in OnRead()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/websockets/ |
| H A D | websocket_basic_stream_adapters.cc | 78 DCHECK(!read_callback_); in Read()
92 read_callback_ = std::move(callback); in Read()
143 if (read_callback_) in OnDataReceived()
144 std::move(read_callback_).Run(CopySavedReadDataIntoBuffer()); in OnDataReceived()
164 if (read_callback_) { in OnClose()
167 std::move(read_callback_).Run(status); in OnClose()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/net/websockets/ |
| H A D | websocket_basic_stream_adapters.cc | 78 DCHECK(!read_callback_); in Read()
92 read_callback_ = std::move(callback); in Read()
143 if (read_callback_) in OnDataReceived()
144 std::move(read_callback_).Run(CopySavedReadDataIntoBuffer()); in OnDataReceived()
169 if (read_callback_) { in OnClose()
172 std::move(read_callback_).Run(status); in OnClose()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/cast_channel/ |
| H A D | mojo_data_pump.cc | 45 DCHECK(!read_callback_); in Read()
54 read_callback_ = std::move(callback); in Read()
72 DCHECK(read_callback_); in ReceiveMore()
87 std::move(read_callback_).Run(net::ERR_FAILED); in ReceiveMore()
90 std::move(read_callback_).Run(num_bytes); in ReceiveMore()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/components/cast_channel/ |
| H A D | mojo_data_pump.cc | 45 DCHECK(!read_callback_); in Read()
54 read_callback_ = std::move(callback); in Read()
72 DCHECK(read_callback_); in ReceiveMore()
87 std::move(read_callback_).Run(net::ERR_FAILED); in ReceiveMore()
90 std::move(read_callback_).Run(num_bytes); in ReceiveMore()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/services/network/ |
| H A D | data_pipe_element_reader.cc | 32 read_callback_.Reset(); in Init()
69 DCHECK(!read_callback_); in Read()
77 read_callback_ = std::move(callback); in Read()
90 DCHECK(read_callback_); in OnHandleReadable()
105 std::move(read_callback_).Run(read_result); in OnHandleReadable()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/services/network/ |
| H A D | data_pipe_element_reader.cc | 32 read_callback_.Reset(); in Init()
69 DCHECK(!read_callback_); in Read()
77 read_callback_ = std::move(callback); in Read()
90 DCHECK(read_callback_); in OnHandleReadable()
105 std::move(read_callback_).Run(read_result); in OnHandleReadable()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/mock_server/src/ |
| H A D | mysql_protocol_decoder.cc | 51 : read_callback_(read_clb) {} in MySQLProtocolDecoder()
58 read_callback_(client_socket, &header_buf[0], sizeof(header_buf), flags); in read_message()
77 read_callback_(client_socket, &packet_.packet_buffer[0], pkt_len, flags); in read_message()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/media_galleries/fileapi/ |
| H A D | mtp_file_stream_reader.cc | 51 read_callback_ = std::move(callback); in Read()
136 std::move(read_callback_).Run(net::ERR_UPLOAD_FILE_CHANGED); in FinishRead()
142 std::move(read_callback_).Run(bytes_read); in FinishRead()
159 std::move(read_callback_).Run(net::FileErrorToNetError(file_error)); in CallReadCallbackwithPlatformFileError()
176 std::move(read_callback_).Run(net::ERR_FAILED); in ReadBytes()
|
| /dports/multimedia/zoneminder/zoneminder-1.36.5/dep/RtspServer/src/net/ |
| H A D | Channel.h | 41 { read_callback_ = cb; } in SetReadCallback()
76 read_callback_(); in HandleEvent()
94 EventCallback read_callback_ = []{};
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/google_apis/gcm/engine/ |
| H A D | fake_connection_handler.cc | 34 : read_callback_(read_callback), in FakeConnectionHandler()
54 read_callback_.Run(BuildLoginResponse(fail_login_)); in Init()
95 read_callback_.Run(message.CloneProtobuf()); in ReceiveMessage()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/google_apis/gcm/engine/ |
| H A D | fake_connection_handler.cc | 34 : read_callback_(read_callback), in FakeConnectionHandler()
54 read_callback_.Run(BuildLoginResponse(fail_login_)); in Init()
95 read_callback_.Run(message.CloneProtobuf()); in ReceiveMessage()
|