/external/libchrome/base/task/ |
D | cancelable_task_tracker_unittest.cc | 88 FROM_HERE, in TEST_F() 89 MakeExpectedRunClosure(FROM_HERE))); in TEST_F() 92 worker_thread.task_runner().get(), FROM_HERE, in TEST_F() 93 MakeExpectedRunClosure(FROM_HERE), MakeExpectedRunClosure(FROM_HERE))); in TEST_F() 112 test_task_runner.get(), FROM_HERE, MakeExpectedNotRunClosure(FROM_HERE)); in TEST_F() 131 FROM_HERE, in TEST_F() 132 MakeExpectedNotRunClosure(FROM_HERE), in TEST_F() 133 MakeExpectedNotRunClosure(FROM_HERE)); in TEST_F() 150 FROM_HERE, in TEST_F() 151 MakeExpectedRunClosure(FROM_HERE), in TEST_F() [all …]
|
/external/libchrome/base/message_loop/ |
D | message_loop_test.cc | 99 MessageLoop::current()->PostTask(FROM_HERE, Bind( in RunTest_PostTask() 101 MessageLoop::current()->PostTask(FROM_HERE, Bind( in RunTest_PostTask() 103 MessageLoop::current()->PostTask(FROM_HERE, Bind( in RunTest_PostTask() 105 MessageLoop::current()->PostTask(FROM_HERE, Bind( in RunTest_PostTask() 107 MessageLoop::current()->PostTask(FROM_HERE, Bind( in RunTest_PostTask() 109 MessageLoop::current()->PostTask(FROM_HERE, Bind( in RunTest_PostTask() 113 FROM_HERE, in RunTest_PostTask() 135 FROM_HERE, Bind(&RecordRunTimeFunc, &run_time, &num_tasks), in RunTest_PostDelayedTask_Basic() 155 FROM_HERE, in RunTest_PostDelayedTask_InDelayOrder() 161 FROM_HERE, in RunTest_PostDelayedTask_InDelayOrder() [all …]
|
D | message_pump_glib_unittest.cc | 212 Bind(&PostMessageLoopTask, FROM_HERE, check_task); in TEST_F() 223 posted_task = Bind(&PostMessageLoopTask, FROM_HERE, check_task); in TEST_F() 236 loop()->PostTask(FROM_HERE, Bind(&IncrementInt, &task_count)); in TEST_F() 241 FROM_HERE, in TEST_F() 253 FROM_HERE, in TEST_F() 262 FROM_HERE, in TEST_F() 283 Bind(&PostMessageLoopTask, FROM_HERE, check_task); in TEST_F() 314 FROM_HERE, Bind(&ConcurrentHelper::FromTask, this)); in FromTask() 365 FROM_HERE, Bind(&ConcurrentHelper::FromTask, helper.get())); in TEST_F() 367 FROM_HERE, Bind(&ConcurrentHelper::FromTask, helper.get())); in TEST_F() [all …]
|
D | message_loop_unittest.cc | 119 loop.PostTask(FROM_HERE, Bind(&SubPumpFunc)); in RunTest_PostDelayedTask_SharedTimer_SubPump() 123 FROM_HERE, in RunTest_PostDelayedTask_SharedTimer_SubPump() 129 FROM_HERE, in RunTest_PostDelayedTask_SharedTimer_SubPump() 263 FROM_HERE, in RecursiveFunc() 280 target->PostTask(FROM_HERE, in RecursiveFuncWin() 282 target->PostTask(FROM_HERE, in RecursiveFuncWin() 284 target->PostTask(FROM_HERE, in RecursiveFuncWin() 292 target->PostTask(FROM_HERE, in RecursiveFuncWin() 294 target->PostTask(FROM_HERE, in RecursiveFuncWin() 333 worker.message_loop()->PostTask(FROM_HERE, in RunTest_RecursiveDenial2() [all …]
|
D | message_loop_task_runner_unittest.cc | 37 FROM_HERE, Bind(&MessageLoopTaskRunnerTest::BlockTaskThreadHelper, in SetUp() 113 FROM_HERE, Bind(&RecordLoop, task_recoder), in TEST_F() 152 task_runner->PostTaskAndReply(FROM_HERE, Bind(&RecordLoop, task_recoder), in TEST_F() 181 FROM_HERE, Bind(&RecordLoop, task_recoder), in TEST_F() 214 FROM_HERE, Bind(&RecordLoop, task_recoder), in TEST_F() 256 loop_.PostTask(FROM_HERE, MessageLoop::QuitWhenIdleClosure()); in Quit() 311 EXPECT_TRUE(io_thread_->task_runner()->ReleaseSoon(FROM_HERE, this)); in TEST_F() 318 file_thread_->task_runner()->DeleteSoon(FROM_HERE, deleted_on_file)); in TEST_F() 324 FROM_HERE, Bind(&MessageLoopTaskRunnerThreadingTest::BasicFunction, in TEST_F() 338 FROM_HERE, Bind(&MessageLoopTaskRunnerThreadingTest::AssertNotRun)); in TEST_F() [all …]
|
/external/libbrillo/brillo/streams/ |
D | stream_utils_unittest.cc | 27 FROM_HERE, base::Bind(std::get<k>(args), size)); in ACTION_TEMPLATE() 34 brillo::MessageLoop::current()->PostTask(FROM_HERE, std::get<k>(args)); in ACTION_TEMPLATE() 42 brillo::Error::AddTo(&error, FROM_HERE, "test", code, "message"); in ACTION_TEMPLATE() 44 FROM_HERE, base::Bind(std::get<k>(args), base::Owned(error.release()))); in ACTION_TEMPLATE() 52 EXPECT_FALSE(stream_utils::ErrorStreamClosed(FROM_HERE, &error)); in TEST() 60 EXPECT_FALSE(stream_utils::ErrorOperationNotSupported(FROM_HERE, &error)); in TEST() 68 EXPECT_FALSE(stream_utils::ErrorReadPastEndOfStream(FROM_HERE, &error)); in TEST() 77 EXPECT_TRUE(stream_utils::CheckInt64Overflow(FROM_HERE, 0, 0, nullptr)); in TEST() 79 FROM_HERE, 0, max_int64, nullptr)); in TEST() 81 FROM_HERE, max_int64, 0, nullptr)); in TEST() [all …]
|
D | file_stream.cc | 89 FROM_HERE, in WaitForData() 96 Error::AddTo(error, FROM_HERE, errors::stream::kDomain, in WaitForData() 107 FROM_HERE, in WaitForData() 114 Error::AddTo(error, FROM_HERE, errors::stream::kDomain, in WaitForData() 244 brillo::errors::system::AddSystemError(error, FROM_HERE, errno); in Open() 248 brillo::errors::system::AddSystemError(error, FROM_HERE, errno); in Open() 269 brillo::errors::system::AddSystemError(error, FROM_HERE, errno); in CreateTemporary() 276 brillo::errors::system::AddSystemError(error, FROM_HERE, errno); in CreateTemporary() 292 Error::AddTo(error, FROM_HERE, errors::stream::kDomain, in FromFileDescriptor() 300 brillo::errors::system::AddSystemError(error, FROM_HERE, errno); in FromFileDescriptor() [all …]
|
D | input_stream_set.cc | 28 Error::AddTo(error, FROM_HERE, errors::stream::kDomain, in Create() 37 Error::AddTo(error, FROM_HERE, errors::stream::kDomain, in Create() 92 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in SetSizeBlocking() 106 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in Seek() 115 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in ReadNonBlocking() 141 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in WriteNonBlocking() 163 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in WaitForData() 166 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in WaitForData() 173 MessageLoop::current()->PostTask(FROM_HERE, base::Bind(callback, mode)); in WaitForData() 182 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in WaitForDataBlocking() [all …]
|
D | fake_stream.cc | 171 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in SetSizeBlocking() 178 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in Seek() 203 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in ReadNonBlocking() 206 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in ReadNonBlocking() 222 Error::AddTo(error, FROM_HERE, "fake_stream", "read_error", message); in ReadNonBlocking() 267 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in WriteNonBlocking() 270 return stream_utils::ErrorStreamClosed(FROM_HERE, error); in WriteNonBlocking() 287 Error::AddTo(error, FROM_HERE, "fake_stream", "write_error", message); in WriteNonBlocking() 302 Error::AddTo(error, FROM_HERE, "fake_stream", "data_mismatch", in WriteNonBlocking() 320 Error::AddTo(error, FROM_HERE, "fake_stream", "full", in WriteNonBlocking() [all …]
|
D | stream.cc | 22 if (!stream_utils::CheckInt64Overflow(FROM_HERE, position, 0, error)) in SetPosition() 33 Error::AddTo(error, FROM_HERE, errors::stream::kDomain, in ReadAsync() 52 Error::AddTo(error, FROM_HERE, errors::stream::kDomain, in ReadAllAsync() 94 return stream_utils::ErrorReadPastEndOfStream(FROM_HERE, error); in ReadAllBlocking() 108 Error::AddTo(error, FROM_HERE, errors::stream::kDomain, in WriteAsync() 125 Error::AddTo(error, FROM_HERE, errors::stream::kDomain, in WriteAllAsync() 166 Error::AddTo(error, FROM_HERE, errors::stream::kDomain, in WriteAllBlocking() 183 MessageLoop::current()->PostTask(FROM_HERE, callback); in FlushAsync() 215 FROM_HERE, in ReadAsyncImpl() 279 FROM_HERE, in WriteAsyncImpl() [all …]
|
D | tls_stream.cc | 173 return ReportError(error, FROM_HERE, "Error reading from TLS socket"); in ReadNonBlocking() 201 return ReportError(error, FROM_HERE, "Error writing to TLS socket"); in WriteNonBlocking() 236 ReportError(error, FROM_HERE, "Failed to shut down TLS socket"); in Close() 346 return ReportError(error, FROM_HERE, "Cannot create SSL_CTX"); in Init() 356 return ReportError(error, FROM_HERE, "Cannot set the cipher list"); in Init() 360 return ReportError(error, FROM_HERE, in Init() 389 FROM_HERE, in Init() 441 ReportError(&error, FROM_HERE, "TLS handshake failed."); in DoHandshake() 479 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in SetSizeBlocking() 486 return stream_utils::ErrorOperationNotSupported(FROM_HERE, error); in Seek() [all …]
|
/external/libweave/examples/provider/ |
D | ssl_stream.cc | 32 task_runner->PostDelayedTask(FROM_HERE, task, in RetryAsyncTask() 76 FROM_HERE, in Read() 87 task_runner_, FROM_HERE, in Read() 93 AddSslError(&weave_error, FROM_HERE, "read_failed", err); in Read() 95 FROM_HERE, in Read() 110 FROM_HERE, in Write() 117 task_runner_, FROM_HERE, in Write() 126 task_runner_, FROM_HERE, in Write() 132 AddSslError(&weave_error, FROM_HERE, "write_failed", err); in Write() 134 FROM_HERE, base::Bind(&SSLStream::RunTask, weak_ptr_factory_.GetWeakPtr(), in Write() [all …]
|
D | wifi_manager.cc | 100 return task_runner_->PostDelayedTask(FROM_HERE, in TryToConnect() 113 Error::AddTo(&error, FROM_HERE, "timeout", in TryToConnect() 116 FROM_HERE, base::Bind(callback, base::Passed(&error)), {}); in TryToConnect() 121 FROM_HERE, in TryToConnect() 134 Error::AddTo(&error, FROM_HERE, "busy", "Running Access Point."); in Connect() 136 FROM_HERE, base::Bind(callback, base::Passed(&error)), {}); in Connect()
|
/external/libbrillo/brillo/message_loops/ |
D | message_loop_unittest.cc | 77 TaskId task_id = this->loop_->PostTask(FROM_HERE, in TYPED_TEST() 87 TaskId task_id = this->loop_->PostTask(FROM_HERE, in TYPED_TEST() 99 FROM_HERE, in TYPED_TEST() 122 FROM_HERE, -1, MessageLoop::kWatchRead, true, in TYPED_TEST() 125 FROM_HERE, -1, MessageLoop::kWatchWrite, true, in TYPED_TEST() 135 FROM_HERE, pipe.reader, MessageLoop::kWatchRead, true, in TYPED_TEST() 154 FROM_HERE, pipe.reader, MessageLoop::kWatchRead, true, in TYPED_TEST() 172 FROM_HERE, pipe.reader, MessageLoop::kWatchRead, true, in TYPED_TEST() 189 FROM_HERE, pipe.reader, MessageLoop::kWatchRead, false, in TYPED_TEST() 208 FROM_HERE, socks.left, MessageLoop::kWatchRead, true, in TYPED_TEST() [all …]
|
/external/libchrome/base/threading/ |
D | worker_pool_posix_unittest.cc | 159 pool_->PostTask(FROM_HERE, CreateNewIncrementingTaskCallback()); in TEST_F() 170 pool_->PostTask(FROM_HERE, CreateNewIncrementingTaskCallback()); in TEST_F() 175 pool_->PostTask(FROM_HERE, CreateNewBlockingIncrementingTaskCallback()); in TEST_F() 176 pool_->PostTask(FROM_HERE, CreateNewBlockingIncrementingTaskCallback()); in TEST_F() 189 pool_->PostTask(FROM_HERE, CreateNewBlockingIncrementingTaskCallback()); in TEST_F() 190 pool_->PostTask(FROM_HERE, CreateNewBlockingIncrementingTaskCallback()); in TEST_F() 205 pool_->PostTask(FROM_HERE, CreateNewIncrementingTaskCallback()); in TEST_F() 211 pool_->PostTask(FROM_HERE, CreateNewBlockingIncrementingTaskCallback()); in TEST_F() 212 pool_->PostTask(FROM_HERE, CreateNewBlockingIncrementingTaskCallback()); in TEST_F() 232 pool_->PostTask(FROM_HERE, CreateNewIncrementingTaskCallback()); in TEST_F()
|
/external/libweave/src/privet/ |
D | security_manager.cc | 54 return Error::AddTo(error, FROM_HERE, errors::kInvalidClientCommitment, in ProcessMessage() 123 return Error::AddTo(error, FROM_HERE, errors::kInvalidAuthMode, in CreateAccessTokenImpl() 137 return Error::AddTo(error, FROM_HERE, errors::kInvalidAuthCode, in CreateAccessTokenImpl() 152 return Error::AddTo(error, FROM_HERE, errors::kInvalidAuthMode, in CreateAccessTokenImpl() 166 Error::AddToPrintf(error, FROM_HERE, errors::kInvalidAuthorization, in CreateAccessToken() 189 Error::AddToPrintf(error, FROM_HERE, errors::kInvalidAuthorization, in ParseAccessToken() 229 Error::AddToPrintf(error, FROM_HERE, errors::kInvalidFormat, in ConfirmClientAuthToken() 267 return Error::AddTo(error, FROM_HERE, errors::kInvalidParams, in StartPairing() 281 return Error::AddTo(error, FROM_HERE, errors::kInvalidParams, in StartPairing() 292 return Error::AddTo(error, FROM_HERE, errors::kInvalidParams, in StartPairing() [all …]
|
D | wifi_bootstrap_manager.cc | 85 FROM_HERE, base::Bind(&WifiBootstrapManager::OnBootstrapTimeout, in StartBootstrapping() 108 FROM_HERE, base::Bind(&WifiBootstrapManager::OnConnectTimeout, in StartConnecting() 139 FROM_HERE, base::Bind(&WifiBootstrapManager::OnMonitorTimeout, in ContinueMonitoring() 191 FROM_HERE, base::Bind(&WifiBootstrapManager::StartConnecting, in ConfigureCredentials() 218 Error::AddTo(&error, FROM_HERE, errors::kInvalidState, in OnConnectDone() 233 Error::AddTo(&error, FROM_HERE, errors::kInvalidState, in OnConnectTimeout() 278 Error::AddTo(&error, FROM_HERE, errors::kInvalidState, in UpdateConnectionState() 291 Error::AddToPrintf(&error, FROM_HERE, errors::kInvalidState, in UpdateConnectionState()
|
/external/libchrome/base/timer/ |
D | timer_unittest.cc | 40 timer_.Start(FROM_HERE, TimeDelta::FromMilliseconds(delay_ms_), this, in Start() 69 timer_->Start(FROM_HERE, TimeDelta::FromMilliseconds(10), this, in Start() 91 timer_.Start(FROM_HERE, delay_, this, &RepeatingTimerTester::Run); in Start() 128 base::MessageLoop::current()->DeleteSoon(FROM_HERE, a); in RunTest_OneShotTimer_Cancel() 177 base::MessageLoop::current()->DeleteSoon(FROM_HERE, a); in RunTest_RepeatingTimer_Cancel() 210 base::DelayTimer timer(FROM_HERE, TimeDelta::FromMilliseconds(1), &target, in RunTest_DelayTimer_NoCall() 225 base::DelayTimer timer(FROM_HERE, TimeDelta::FromMilliseconds(1), &target, in RunTest_DelayTimer_OneCall() 256 base::DelayTimer timer(FROM_HERE, TimeDelta::FromMilliseconds(50), &target, in RunTest_DelayTimer_Reset() 264 timers[i].Start(FROM_HERE, TimeDelta::FromMilliseconds(i * 10), in RunTest_DelayTimer_Reset() 290 base::DelayTimer timer(FROM_HERE, TimeDelta::FromMilliseconds(50), &target, in RunTest_DelayTimer_Deleted() [all …]
|
D | mock_timer_unittest.cc | 20 timer.Start(FROM_HERE, delay, in TEST() 34 timer.Start(FROM_HERE, delay, in TEST() 49 timer.Start(FROM_HERE, delay, in TEST() 75 timer.Start(FROM_HERE, delay, in TEST()
|
/external/libweave/src/ |
D | component_manager_impl.cc | 52 return Error::AddToPrintf(error, FROM_HERE, errors::commands::kInvalidState, in AddComponent() 60 return Error::AddToPrintf(error, FROM_HERE, in AddComponent() 112 return Error::AddToPrintf(error, FROM_HERE, errors::commands::kInvalidState, in RemoveComponent() 136 error, FROM_HERE, errors::commands::kInvalidState, in RemoveComponentArrayItem() 143 error, FROM_HERE, errors::commands::kInvalidState, in RemoveComponentArrayItem() 167 Error::AddToPrintf(error, FROM_HERE, errors::commands::kTypeMismatch, in LoadTraits() 175 Error::AddToPrintf(error, FROM_HERE, errors::commands::kTypeMismatch, in LoadTraits() 235 return Error::AddToPrintf(error, FROM_HERE, "access_denied", in ParseCommandInstance() 250 error, FROM_HERE, "unrouted_command", in ParseCommandInstance() 279 return Error::AddToPrintf(error, FROM_HERE, "trait_not_supported", in ParseCommandInstance() [all …]
|
/external/libchrome/base/ |
D | observer_list_unittest.cc | 112 FROM_HERE, in ThreadMain() 138 list_->Notify(FROM_HERE, &Foo::Observe, 10); in AddTask() 142 FROM_HERE, in AddTask() 147 loop_->task_runner()->PostTask(FROM_HERE, in Quit() 222 observer_list->Notify(FROM_HERE, &Foo::Observe, 10); in TEST() 229 observer_list->Notify(FROM_HERE, &Foo::Observe, 10); in TEST() 252 observer_list->Notify(FROM_HERE, &Foo::Observe, 10); in TEST() 263 observer_list->Notify(FROM_HERE, &Foo::Observe, 10); in TEST() 285 observer_list->Notify(FROM_HERE, &Foo::Observe, 10); in TEST() 299 observer_list->Notify(FROM_HERE, &Foo::Observe, 20); in TEST() [all …]
|
D | task_runner_util_unittest.cc | 74 PostTaskAndReplyWithResult(message_loop.task_runner().get(), FROM_HERE, in TEST() 87 PostTaskAndReplyWithResult(message_loop.task_runner().get(), FROM_HERE, in TEST() 101 PostTaskAndReplyWithResult(message_loop.task_runner().get(), FROM_HERE, in TEST() 115 PostTaskAndReplyWithResult(message_loop.task_runner().get(), FROM_HERE, in TEST()
|
/external/libbrillo/brillo/http/ |
D | http_transport_curl.cc | 127 brillo::Error::AddTo(error, FROM_HERE, http::kErrorDomain, in CreateConnection() 191 AddEasyCurlError(error, FROM_HERE, code, curl_interface_.get()); in CreateConnection() 215 FROM_HERE, base::Bind(error_callback, 0, base::Owned(error.release()))); in StartAsyncTransfer() 239 AddMultiCurlError(&error, FROM_HERE, code, curl_interface_.get()); in StartAsyncTransfer() 241 FROM_HERE, base::Bind(error_callback, 0, base::Owned(error.release()))); in StartAsyncTransfer() 292 brillo::Error::AddTo(error, FROM_HERE, http::kErrorDomain, in SetupAsyncCurl() 304 AddMultiCurlError(error, FROM_HERE, code, curl_interface_.get()); in SetupAsyncCurl() 355 base::MessageLoopForIO::current()->DeleteSoon(FROM_HERE, poll_data); in MultiSocketCallback() 399 FROM_HERE, in MultiTimerCallback() 444 AddEasyCurlError(&error, FROM_HERE, code, curl_interface_.get()); in OnTransferComplete() [all …]
|
/external/libbrillo/brillo/ |
D | process_reaper_unittest.cc | 77 EXPECT_TRUE(process_reaper_.WatchForChild(FROM_HERE, pid, base::Bind( in TEST_F() 94 EXPECT_TRUE(process_reaper_.WatchForChild(FROM_HERE, pid, base::Bind( in TEST_F() 112 EXPECT_TRUE(process_reaper_.WatchForChild(FROM_HERE, pid, base::Bind( in TEST_F() 123 EXPECT_TRUE(process_reaper_.WatchForChild(FROM_HERE, pid, base::Bind( in TEST_F() 134 brillo_loop_.PostDelayedTask(FROM_HERE, in TEST_F()
|
/external/libchrome/dbus/ |
D | object_proxy.cc | 144 bus_->GetOriginTaskRunner()->PostTask(FROM_HERE, task); in CallMethodWithErrorCallback() 166 bus_->GetDBusTaskRunner()->PostTask(FROM_HERE, task); in CallMethodWithErrorCallback() 177 bus_->GetDBusTaskRunner(), FROM_HERE, in ConnectToSignal() 204 FROM_HERE, in WaitForServiceToBeAvailable() 266 bus_->GetOriginTaskRunner()->PostTask(FROM_HERE, task); in StartAsyncMethodCall() 308 bus_->GetOriginTaskRunner()->PostTask(FROM_HERE, task); in OnPendingCallIsComplete() 333 FROM_HERE, in RunResponseCallback() 360 FROM_HERE, in RunResponseCallback() 442 FROM_HERE, in WaitForServiceToBeAvailableInternal() 451 FROM_HERE, in WaitForServiceToBeAvailableInternal() [all …]
|