core_ 60 base/ios/scoped_critical_action.h scoped_refptr<Core> core_; core_ 151 chrome/browser/chromeos/policy/device_local_account_policy_service.cc if (core_.client()) core_ 160 chrome/browser/chromeos/policy/device_local_account_policy_service.cc core_.Connect(client.Pass()); core_ 162 chrome/browser/chromeos/policy/device_local_account_policy_service.cc core_.StartRefreshScheduler(); core_ 167 chrome/browser/chromeos/policy/device_local_account_policy_service.cc if (core_.refresh_scheduler()) { core_ 172 chrome/browser/chromeos/policy/device_local_account_policy_service.cc core_.refresh_scheduler()->SetRefreshDelay(delay); core_ 68 chrome/browser/chromeos/policy/device_local_account_policy_service.h CloudPolicyCore* core() { return &core_; } core_ 69 chrome/browser/chromeos/policy/device_local_account_policy_service.h const CloudPolicyCore* core() const { return &core_; } core_ 96 chrome/browser/chromeos/policy/device_local_account_policy_service.h CloudPolicyCore core_; core_ 85 chrome/browser/extensions/api/messaging/native_process_launcher.cc scoped_refptr<Core> core_; core_ 234 chrome/browser/extensions/api/messaging/native_process_launcher.cc : core_(new Core(allow_user_level_hosts, window_handle)) { core_ 238 chrome/browser/extensions/api/messaging/native_process_launcher.cc core_->Detach(); core_ 244 chrome/browser/extensions/api/messaging/native_process_launcher.cc core_->Launch(origin, native_host_name, callback); core_ 176 chrome/browser/invalidation/gcm_invalidation_bridge.cc core_ = core; core_ 190 chrome/browser/invalidation/gcm_invalidation_bridge.cc core_, core_ 211 chrome/browser/invalidation/gcm_invalidation_bridge.cc core_, core_ 227 chrome/browser/invalidation/gcm_invalidation_bridge.cc core_, core_ 268 chrome/browser/invalidation/gcm_invalidation_bridge.cc core_, core_ 304 chrome/browser/invalidation/gcm_invalidation_bridge.cc core_, core_ 86 chrome/browser/invalidation/gcm_invalidation_bridge.h base::WeakPtr<Core> core_; core_ 114 chrome/browser/local_discovery/storage/privet_filesystem_operations.cc : core_(full_path, browser_context, this), core_ 128 chrome/browser/local_discovery/storage/privet_filesystem_operations.cc core_.Start(); core_ 220 chrome/browser/local_discovery/storage/privet_filesystem_operations.cc : core_(full_path, browser_context, this), core_ 240 chrome/browser/local_discovery/storage/privet_filesystem_operations.cc core_.Start(); core_ 135 chrome/browser/local_discovery/storage/privet_filesystem_operations.h PrivetFileSystemAsyncOperationUtil core_; core_ 167 chrome/browser/local_discovery/storage/privet_filesystem_operations.h PrivetFileSystemAsyncOperationUtil core_; core_ 942 chrome/browser/pepper_flash_settings_manager.cc if (core_.get()) core_ 943 chrome/browser/pepper_flash_settings_manager.cc core_->Detach(); core_ 995 chrome/browser/pepper_flash_settings_manager.cc core_->DeauthorizeContentLicenses(id); core_ 1005 chrome/browser/pepper_flash_settings_manager.cc core_->GetPermissionSettings(id, setting_type); core_ 1017 chrome/browser/pepper_flash_settings_manager.cc core_->SetDefaultPermission(id, setting_type, permission, core_ 1029 chrome/browser/pepper_flash_settings_manager.cc core_->SetSitePermission(id, setting_type, sites); core_ 1038 chrome/browser/pepper_flash_settings_manager.cc core_->GetSitesWithData(id); core_ 1049 chrome/browser/pepper_flash_settings_manager.cc core_->ClearSiteData(id, site, flags, max_age); core_ 1058 chrome/browser/pepper_flash_settings_manager.cc if (!core_.get()) { core_ 1059 chrome/browser/pepper_flash_settings_manager.cc core_ = new Core(weak_ptr_factory_.GetWeakPtr(), browser_context_); core_ 1060 chrome/browser/pepper_flash_settings_manager.cc core_->Initialize(); core_ 1066 chrome/browser/pepper_flash_settings_manager.cc if (core != core_.get()) core_ 1069 chrome/browser/pepper_flash_settings_manager.cc core_->Detach(); core_ 1070 chrome/browser/pepper_flash_settings_manager.cc core_ = NULL; core_ 127 chrome/browser/pepper_flash_settings_manager.h scoped_refptr<Core> core_; core_ 39 chrome/browser/policy/cloud/cloud_policy_invalidator.cc core_(core), core_ 67 chrome/browser/policy/cloud/cloud_policy_invalidator.cc core_->AddObserver(this); core_ 68 chrome/browser/policy/cloud/cloud_policy_invalidator.cc if (core_->refresh_scheduler()) core_ 69 chrome/browser/policy/cloud/cloud_policy_invalidator.cc OnRefreshSchedulerStarted(core_); core_ 78 chrome/browser/policy/cloud/cloud_policy_invalidator.cc core_->store()->RemoveObserver(this); core_ 82 chrome/browser/policy/cloud/cloud_policy_invalidator.cc core_->RemoveObserver(this); core_ 125 chrome/browser/policy/cloud/cloud_policy_invalidator.cc OnStoreLoaded(core_->store()); core_ 126 chrome/browser/policy/cloud/cloud_policy_invalidator.cc core_->store()->AddObserver(this); core_ 134 chrome/browser/policy/cloud/cloud_policy_invalidator.cc core_->store()->RemoveObserver(this); core_ 207 chrome/browser/policy/cloud/cloud_policy_invalidator.cc core_->client()->SetInvalidationInfo(invalidation_version_, payload); core_ 315 chrome/browser/policy/cloud/cloud_policy_invalidator.cc core_->refresh_scheduler()->SetInvalidationServiceAvailability( core_ 325 chrome/browser/policy/cloud/cloud_policy_invalidator.cc core_->client()->SetInvalidationInfo(invalidation_version_, std::string()); core_ 326 chrome/browser/policy/cloud/cloud_policy_invalidator.cc core_->refresh_scheduler()->RefreshSoon(); core_ 332 chrome/browser/policy/cloud/cloud_policy_invalidator.cc core_->client()->SetInvalidationInfo(0, std::string()); core_ 144 chrome/browser/policy/cloud/cloud_policy_invalidator.h CloudPolicyCore* core_; core_ 174 chrome/browser/policy/cloud/cloud_policy_invalidator_unittest.cc CloudPolicyCore core_; core_ 205 chrome/browser/policy/cloud/cloud_policy_invalidator_unittest.cc : core_(PolicyNamespaceKey(dm_protocol::kChromeUserPolicyType, core_ 228 chrome/browser/policy/cloud/cloud_policy_invalidator_unittest.cc core_.Disconnect(); core_ 235 chrome/browser/policy/cloud/cloud_policy_invalidator_unittest.cc &core_, core_ 261 chrome/browser/policy/cloud/cloud_policy_invalidator_unittest.cc core_.Connect(scoped_ptr<CloudPolicyClient>(client_)); core_ 265 chrome/browser/policy/cloud/cloud_policy_invalidator_unittest.cc core_.StartRefreshScheduler(); core_ 270 chrome/browser/policy/cloud/cloud_policy_invalidator_unittest.cc core_.Disconnect(); core_ 336 chrome/browser/policy/cloud/cloud_policy_invalidator_unittest.cc static_cast<MockCloudPolicyClient*>(core_.client()); core_ 360 chrome/browser/policy/cloud/cloud_policy_invalidator_unittest.cc return core_.refresh_scheduler()->invalidations_available(); core_ 220 chrome/browser/signin/profile_oauth2_token_service_request.cc core_->Start(account_id, scopes); core_ 225 chrome/browser/signin/profile_oauth2_token_service_request.cc core_->Stop(); core_ 229 chrome/browser/signin/profile_oauth2_token_service_request.cc return core_->request()->GetAccountId(); core_ 50 chrome/browser/signin/profile_oauth2_token_service_request.h scoped_refptr<Core> core_; core_ 64 chrome/browser/sync/glue/sync_backend_host_impl.cc core_ = new SyncBackendHostCore( core_ 72 chrome/browser/sync/glue/sync_backend_host_impl.cc DCHECK(!core_.get() && !frontend_) << "Must call Shutdown before destructor."; core_ 127 chrome/browser/sync/glue/sync_backend_host_impl.cc core_->GetRequestContextCancelationSignal()), core_ 146 chrome/browser/sync/glue/sync_backend_host_impl.cc core_.get(), core_ 158 chrome/browser/sync/glue/sync_backend_host_impl.cc core_.get(), routing_info)); core_ 184 chrome/browser/sync/glue/sync_backend_host_impl.cc core_.get(), core_ 214 chrome/browser/sync/glue/sync_backend_host_impl.cc core_.get(), core_ 246 chrome/browser/sync/glue/sync_backend_host_impl.cc core_->ShutdownOnUIThread(); core_ 272 chrome/browser/sync/glue/sync_backend_host_impl.cc core_.get(), sync_disabled)); core_ 273 chrome/browser/sync/glue/sync_backend_host_impl.cc core_ = NULL; core_ 418 chrome/browser/sync/glue/sync_backend_host_impl.cc core_.get())); core_ 432 chrome/browser/sync/glue/sync_backend_host_impl.cc return core_->sync_manager()->GetUserShare(); core_ 441 chrome/browser/sync/glue/sync_backend_host_impl.cc return core_->sync_manager()->GetDetailedStatus(); core_ 451 chrome/browser/sync/glue/sync_backend_host_impl.cc return core_->sync_manager()->HasUnsyncedItems(); core_ 484 chrome/browser/sync/glue/sync_backend_host_impl.cc return core_->synced_device_tracker(); core_ 493 chrome/browser/sync/glue/sync_backend_host_impl.cc core_)); core_ 502 chrome/browser/sync/glue/sync_backend_host_impl.cc core_)); core_ 508 chrome/browser/sync/glue/sync_backend_host_impl.cc core_.get(), base::Passed(&options))); core_ 529 chrome/browser/sync/glue/sync_backend_host_impl.cc core_.get(), core_ 564 chrome/browser/sync/glue/sync_backend_host_impl.cc base::Bind(&SyncBackendHostCore::DoRefreshTypes, core_.get(), types)); core_ 570 chrome/browser/sync/glue/sync_backend_host_impl.cc if (core_->sync_manager()->ReceivedExperiment(&experiments)) core_ 683 chrome/browser/sync/glue/sync_backend_host_impl.cc core_.get(), core_ 692 chrome/browser/sync/glue/sync_backend_host_impl.cc core_.get(), core_ 290 chrome/browser/sync/glue/sync_backend_host_impl.h scoped_refptr<SyncBackendHostCore> core_; core_ 278 chrome/browser/ui/webui/policy_ui.cc policy::CloudPolicyCore* core_; core_ 429 chrome/browser/ui/webui/policy_ui.cc policy::CloudPolicyCore* core) : core_(core) { core_ 430 chrome/browser/ui/webui/policy_ui.cc core_->store()->AddObserver(this); core_ 437 chrome/browser/ui/webui/policy_ui.cc core_->store()->RemoveObserver(this); core_ 458 chrome/browser/ui/webui/policy_ui.cc if (!core_->store()->is_managed()) core_ 460 chrome/browser/ui/webui/policy_ui.cc GetStatusFromCore(core_, dict); core_ 476 chrome/browser/ui/webui/policy_ui.cc GetStatusFromCore(core_, dict); core_ 91 chrome/renderer/net/net_error_helper.cc core_.set_auto_reload_enabled(auto_reload_enabled); core_ 100 chrome/renderer/net/net_error_helper.cc core_.OnStartLoad(GetFrameType(frame), GetLoadingPageType(frame)); core_ 105 chrome/renderer/net/net_error_helper.cc core_.OnCommitLoad(GetFrameType(frame)); core_ 110 chrome/renderer/net/net_error_helper.cc core_.OnFinishLoad(GetFrameType(frame)); core_ 114 chrome/renderer/net/net_error_helper.cc core_.OnStop(); core_ 131 chrome/renderer/net/net_error_helper.cc core_.NetworkStateChanged(enabled); core_ 139 chrome/renderer/net/net_error_helper.cc core_.GetErrorHTML(GetFrameType(frame), error, is_failed_post, error_html); core_ 144 chrome/renderer/net/net_error_helper.cc return core_.ShouldSuppressErrorPage(GetFrameType(frame), url); core_ 251 chrome/renderer/net/net_error_helper.cc core_.OnNetErrorInfo(static_cast<DnsProbeStatus>(status_num)); core_ 260 chrome/renderer/net/net_error_helper.cc core_.OnSetNavigationCorrectionInfo(navigation_correction_url, language, core_ 272 chrome/renderer/net/net_error_helper.cc core_.OnNavigationCorrectionsFetched( core_ 276 chrome/renderer/net/net_error_helper.cc core_.OnNavigationCorrectionsFetched( core_ 102 chrome/renderer/net/net_error_helper.h NetErrorHelperCore core_; core_ 118 chrome/renderer/net/net_error_helper_core_unittest.cc core_(this), core_ 123 chrome/renderer/net/net_error_helper_core_unittest.cc core_.set_auto_reload_enabled(false); core_ 124 chrome/renderer/net/net_error_helper_core_unittest.cc core_.set_timer_for_testing(scoped_ptr<base::Timer>(timer_)); core_ 132 chrome/renderer/net/net_error_helper_core_unittest.cc NetErrorHelperCore& core() { return core_; } core_ 272 chrome/renderer/net/net_error_helper_core_unittest.cc NetErrorHelperCore core_; core_ 168 chrome/service/cloud_print/cloud_print_proxy_backend.cc core_ = new Core(this, settings, oauth_client_info, enable_job_poll); core_ 171 chrome/service/cloud_print/cloud_print_proxy_backend.cc CloudPrintProxyBackend::~CloudPrintProxyBackend() { DCHECK(!core_.get()); } core_ 180 chrome/service/cloud_print/cloud_print_proxy_backend.cc core_.get(), cloud_print_token)); core_ 192 chrome/service/cloud_print/cloud_print_proxy_backend.cc core_.get(), robot_oauth_refresh_token, robot_email)); core_ 204 chrome/service/cloud_print/cloud_print_proxy_backend.cc core_.get(), robot_oauth_auth_code, robot_email)); core_ 211 chrome/service/cloud_print/cloud_print_proxy_backend.cc base::Bind(&CloudPrintProxyBackend::Core::DoShutdown, core_.get())); core_ 213 chrome/service/cloud_print/cloud_print_proxy_backend.cc core_ = NULL; // Releases reference to core_. core_ 220 chrome/service/cloud_print/cloud_print_proxy_backend.cc core_.get())); core_ 89 chrome/service/cloud_print/cloud_print_proxy_backend.h scoped_refptr<Core> core_; core_ 218 chrome/service/cloud_print/print_system_win.cc JobSpoolerWin() : core_(new Core) {} core_ 234 chrome/service/cloud_print/print_system_win.cc return core_->Spool(print_ticket, print_ticket_mime_type, core_ 531 chrome/service/cloud_print/print_system_win.cc scoped_refptr<Core> core_; core_ 18 chrome/test/chromedriver/net/sync_websocket_impl.cc : core_(new Core(context_getter)) {} core_ 23 chrome/test/chromedriver/net/sync_websocket_impl.cc return core_->IsConnected(); core_ 27 chrome/test/chromedriver/net/sync_websocket_impl.cc return core_->Connect(url); core_ 31 chrome/test/chromedriver/net/sync_websocket_impl.cc return core_->Send(message); core_ 36 chrome/test/chromedriver/net/sync_websocket_impl.cc return core_->ReceiveNextMessage(message, timeout); core_ 40 chrome/test/chromedriver/net/sync_websocket_impl.cc return core_->HasNextMessage(); core_ 103 chrome/test/chromedriver/net/sync_websocket_impl.h scoped_refptr<Core> core_; core_ 24 components/policy/core/common/cloud/cloud_policy_core_unittest.cc : core_(PolicyNamespaceKey(dm_protocol::kChromeUserPolicyType, core_ 35 components/policy/core/common/cloud/cloud_policy_core_unittest.cc core_.AddObserver(this); core_ 39 components/policy/core/common/cloud/cloud_policy_core_unittest.cc core_.RemoveObserver(this); core_ 44 components/policy/core/common/cloud/cloud_policy_core_unittest.cc if (core_.client()) core_ 52 components/policy/core/common/cloud/cloud_policy_core_unittest.cc if (core_.refresh_scheduler()) core_ 60 components/policy/core/common/cloud/cloud_policy_core_unittest.cc if (core_.client()) core_ 70 components/policy/core/common/cloud/cloud_policy_core_unittest.cc CloudPolicyCore core_; core_ 82 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_TRUE(core_.store()); core_ 83 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_FALSE(core_.client()); core_ 84 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_FALSE(core_.service()); core_ 85 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_FALSE(core_.refresh_scheduler()); core_ 88 components/policy/core/common/cloud/cloud_policy_core_unittest.cc core_.Connect(scoped_ptr<CloudPolicyClient>(new MockCloudPolicyClient())); core_ 89 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_TRUE(core_.client()); core_ 90 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_TRUE(core_.service()); core_ 91 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_FALSE(core_.refresh_scheduler()); core_ 97 components/policy/core/common/cloud/cloud_policy_core_unittest.cc core_.Disconnect(); core_ 98 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_FALSE(core_.client()); core_ 99 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_FALSE(core_.service()); core_ 100 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_FALSE(core_.refresh_scheduler()); core_ 106 components/policy/core/common/cloud/cloud_policy_core_unittest.cc core_.Disconnect(); core_ 107 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_FALSE(core_.client()); core_ 108 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_FALSE(core_.service()); core_ 109 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_FALSE(core_.refresh_scheduler()); core_ 117 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_FALSE(core_.refresh_scheduler()); core_ 118 components/policy/core/common/cloud/cloud_policy_core_unittest.cc core_.Connect(scoped_ptr<CloudPolicyClient>(new MockCloudPolicyClient())); core_ 119 components/policy/core/common/cloud/cloud_policy_core_unittest.cc core_.StartRefreshScheduler(); core_ 120 components/policy/core/common/cloud/cloud_policy_core_unittest.cc ASSERT_TRUE(core_.refresh_scheduler()); core_ 122 components/policy/core/common/cloud/cloud_policy_core_unittest.cc int default_refresh_delay = core_.refresh_scheduler()->refresh_delay(); core_ 126 components/policy/core/common/cloud/cloud_policy_core_unittest.cc core_.TrackRefreshDelayPref(&prefs_, policy_prefs::kUserPolicyRefreshRate); core_ 127 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_EQ(kRefreshRate, core_.refresh_scheduler()->refresh_delay()); core_ 130 components/policy/core/common/cloud/cloud_policy_core_unittest.cc EXPECT_EQ(default_refresh_delay, core_.refresh_scheduler()->refresh_delay()); core_ 31 components/policy/core/common/cloud/cloud_policy_manager.cc : core_(policy_ns_key, cloud_policy_store, task_runner), core_ 49 components/policy/core/common/cloud/cloud_policy_manager.cc core_.Disconnect(); core_ 58 components/policy/core/common/cloud/cloud_policy_manager.h CloudPolicyCore* core() { return &core_; } core_ 59 components/policy/core/common/cloud/cloud_policy_manager.h const CloudPolicyCore* core() const { return &core_; } core_ 85 components/policy/core/common/cloud/cloud_policy_manager.h CloudPolicyClient* client() { return core_.client(); } core_ 86 components/policy/core/common/cloud/cloud_policy_manager.h const CloudPolicyClient* client() const { return core_.client(); } core_ 87 components/policy/core/common/cloud/cloud_policy_manager.h CloudPolicyStore* store() { return core_.store(); } core_ 88 components/policy/core/common/cloud/cloud_policy_manager.h const CloudPolicyStore* store() const { return core_.store(); } core_ 89 components/policy/core/common/cloud/cloud_policy_manager.h CloudPolicyService* service() { return core_.service(); } core_ 90 components/policy/core/common/cloud/cloud_policy_manager.h const CloudPolicyService* service() const { return core_.service(); } core_ 99 components/policy/core/common/cloud/cloud_policy_manager.h CloudPolicyCore core_; core_ 222 components/policy/core/common/cloud/component_cloud_policy_service.cc core_(core), core_ 243 components/policy/core/common/cloud/component_cloud_policy_service.cc core_->store()->AddObserver(this); core_ 249 components/policy/core/common/cloud/component_cloud_policy_service.cc if (core_->store()->is_initialized()) core_ 250 components/policy/core/common/cloud/component_cloud_policy_service.cc OnStoreLoaded(core_->store()); core_ 257 components/policy/core/common/cloud/component_cloud_policy_service.cc core_->store()->RemoveObserver(this); core_ 258 components/policy/core/common/cloud/component_cloud_policy_service.cc core_->RemoveObserver(this); core_ 259 components/policy/core/common/cloud/component_cloud_policy_service.cc if (core_->client()) core_ 260 components/policy/core/common/cloud/component_cloud_policy_service.cc OnCoreDisconnecting(core_); core_ 301 components/policy/core/common/cloud/component_cloud_policy_service.cc DCHECK_EQ(core_, core); core_ 303 components/policy/core/common/cloud/component_cloud_policy_service.cc core_->client()->AddObserver(this); core_ 307 components/policy/core/common/cloud/component_cloud_policy_service.cc OnPolicyFetched(core_->client()); core_ 316 components/policy/core/common/cloud/component_cloud_policy_service.cc DCHECK_EQ(core_, core); core_ 318 components/policy/core/common/cloud/component_cloud_policy_service.cc core_->client()->RemoveObserver(this); core_ 328 components/policy/core/common/cloud/component_cloud_policy_service.cc core_->client()->RemoveNamespaceToFetch(key); core_ 339 components/policy/core/common/cloud/component_cloud_policy_service.cc DCHECK_EQ(core_->store(), store); core_ 346 components/policy/core/common/cloud/component_cloud_policy_service.cc const em::PolicyData* policy = core_->store()->policy(); core_ 379 components/policy/core/common/cloud/component_cloud_policy_service.cc if (core_->client()) core_ 380 components/policy/core/common/cloud/component_cloud_policy_service.cc OnPolicyFetched(core_->client()); core_ 391 components/policy/core/common/cloud/component_cloud_policy_service.cc DCHECK_EQ(core_->client(), client); core_ 403 components/policy/core/common/cloud/component_cloud_policy_service.cc core_->client()->responses(); core_ 435 components/policy/core/common/cloud/component_cloud_policy_service.cc !core_->store()->is_initialized()) { core_ 458 components/policy/core/common/cloud/component_cloud_policy_service.cc core_->AddObserver(this); core_ 460 components/policy/core/common/cloud/component_cloud_policy_service.cc if (core_->client()) { core_ 461 components/policy/core/common/cloud/component_cloud_policy_service.cc OnCoreConnected(core_); core_ 481 components/policy/core/common/cloud/component_cloud_policy_service.cc if (core_->client()) { core_ 485 components/policy/core/common/cloud/component_cloud_policy_service.cc core_->client()->RemoveNamespaceToFetch(key); core_ 492 components/policy/core/common/cloud/component_cloud_policy_service.cc core_->client()->AddNamespaceToFetch(key); core_ 498 components/policy/core/common/cloud/component_cloud_policy_service.cc core_->RefreshSoon(); core_ 129 components/policy/core/common/cloud/component_cloud_policy_service.h CloudPolicyCore* core_; core_ 125 components/policy/core/common/cloud/component_cloud_policy_service_unittest.cc &core_, core_ 158 components/policy/core/common/cloud/component_cloud_policy_service_unittest.cc core_.Connect(scoped_ptr<CloudPolicyClient>(client_)); core_ 173 components/policy/core/common/cloud/component_cloud_policy_service_unittest.cc core_.StartRefreshScheduler(); core_ 239 components/policy/core/common/cloud/component_cloud_policy_service_unittest.cc CloudPolicyCore core_; core_ 255 components/policy/core/common/cloud/component_cloud_policy_service_unittest.cc &core_, core_ 518 components/policy/core/common/cloud/component_cloud_policy_service_unittest.cc core_.Disconnect(); core_ 423 content/browser/media/capture/desktop_capture_device.cc : core_(new Core(task_runner, capturer.Pass())) {} core_ 432 content/browser/media/capture/desktop_capture_device.cc core_->AllocateAndStart(params, client.Pass()); core_ 436 content/browser/media/capture/desktop_capture_device.cc core_->StopAndDeAllocate(); core_ 441 content/browser/media/capture/desktop_capture_device.cc core_->SetNotificationWindowId(window_id); core_ 51 content/browser/media/capture/desktop_capture_device.h scoped_refptr<Core> core_; core_ 425 content/browser/media/capture/desktop_capture_device_aura.cc : core_(new ContentVideoCaptureDeviceCore(scoped_ptr<VideoCaptureMachine>( core_ 442 content/browser/media/capture/desktop_capture_device_aura.cc core_->AllocateAndStart(params, client.Pass()); core_ 446 content/browser/media/capture/desktop_capture_device_aura.cc core_->StopAndDeAllocate(); core_ 40 content/browser/media/capture/desktop_capture_device_aura.h const scoped_ptr<class ContentVideoCaptureDeviceCore> core_; core_ 803 content/browser/media/capture/web_contents_video_capture_device.cc : core_(new ContentVideoCaptureDeviceCore(scoped_ptr<VideoCaptureMachine>( core_ 828 content/browser/media/capture/web_contents_video_capture_device.cc core_->AllocateAndStart(params, client.Pass()); core_ 832 content/browser/media/capture/web_contents_video_capture_device.cc core_->StopAndDeAllocate(); core_ 52 content/browser/media/capture/web_contents_video_capture_device.h const scoped_ptr<ContentVideoCaptureDeviceCore> core_; core_ 30 content/browser/net/view_http_cache_job_factory.cc core_(new Core), core_ 40 content/browser/net/view_http_cache_job_factory.cc return core_->GetMimeType(mime_type); core_ 43 content/browser/net/view_http_cache_job_factory.cc return core_->GetCharset(charset); core_ 47 content/browser/net/view_http_cache_job_factory.cc return core_->ReadRawData(buf, buf_size, bytes_read); core_ 91 content/browser/net/view_http_cache_job_factory.cc scoped_refptr<Core> core_; core_ 106 content/browser/net/view_http_cache_job_factory.cc if (core_.get()) { core_ 107 content/browser/net/view_http_cache_job_factory.cc core_->Orphan(); core_ 108 content/browser/net/view_http_cache_job_factory.cc core_ = NULL; core_ 119 content/browser/net/view_http_cache_job_factory.cc int rv = core_->Start(*request(), callback_); core_ 126 content/browser/renderer_host/media/media_stream_ui_proxy.cc core_.reset(new Core(weak_factory_.GetWeakPtr(), test_render_delegate)); core_ 131 content/browser/renderer_host/media/media_stream_ui_proxy.cc BrowserThread::DeleteSoon(BrowserThread::UI, FROM_HERE, core_.release()); core_ 142 content/browser/renderer_host/media/media_stream_ui_proxy.cc base::Bind(&Core::RequestAccess, base::Unretained(core_.get()), request)); core_ 157 content/browser/renderer_host/media/media_stream_ui_proxy.cc base::Bind(&Core::OnStarted, base::Unretained(core_.get()), window_id), core_ 68 content/browser/renderer_host/media/media_stream_ui_proxy.h scoped_ptr<Core> core_; core_ 333 google_apis/gaia/gaia_oauth_client.cc core_ = new Core(context_getter); core_ 344 google_apis/gaia/gaia_oauth_client.cc return core_->GetTokensFromAuthCode(oauth_client_info, core_ 356 google_apis/gaia/gaia_oauth_client.cc return core_->RefreshToken(oauth_client_info, core_ 366 google_apis/gaia/gaia_oauth_client.cc return core_->GetUserEmail(access_token, max_retries, delegate); core_ 372 google_apis/gaia/gaia_oauth_client.cc return core_->GetUserId(access_token, max_retries, delegate); core_ 378 google_apis/gaia/gaia_oauth_client.cc return core_->GetTokenInfo(access_token, max_retries, delegate); core_ 121 google_apis/gaia/gaia_oauth_client.h scoped_refptr<Core> core_; core_ 54 google_apis/gcm/base/mcs_message.cc DCHECK_EQ(tag, GetMCSProtoTag(core_->Get())); core_ 61 google_apis/gcm/base/mcs_message.cc return core_.get() != NULL; core_ 65 google_apis/gcm/base/mcs_message.cc return core_->Get().SerializeAsString(); core_ 69 google_apis/gcm/base/mcs_message.cc return core_->Get(); core_ 80 google_apis/gcm/base/mcs_message.h scoped_refptr<const Core> core_; core_ 465 jingle/glue/pseudotcp_adapter.cc : core_(new Core(socket)) { core_ 472 jingle/glue/pseudotcp_adapter.cc core_->DeleteSocket(); core_ 478 jingle/glue/pseudotcp_adapter.cc return core_->Read(buffer, buffer_size, callback); core_ 484 jingle/glue/pseudotcp_adapter.cc return core_->Write(buffer, buffer_size, callback); core_ 490 jingle/glue/pseudotcp_adapter.cc core_->SetReceiveBufferSize(size); core_ 497 jingle/glue/pseudotcp_adapter.cc core_->SetSendBufferSize(size); core_ 508 jingle/glue/pseudotcp_adapter.cc return core_->Connect(callback); core_ 513 jingle/glue/pseudotcp_adapter.cc core_->Disconnect(); core_ 517 jingle/glue/pseudotcp_adapter.cc return core_->IsConnected(); core_ 585 jingle/glue/pseudotcp_adapter.cc core_->SetAckDelay(delay_ms); core_ 590 jingle/glue/pseudotcp_adapter.cc core_->SetNoDelay(no_delay); core_ 595 jingle/glue/pseudotcp_adapter.cc core_->SetWriteWaitsForSend(write_waits_for_send); core_ 83 jingle/glue/pseudotcp_adapter.h scoped_refptr<Core> core_; core_ 161 jingle/notifier/listener/non_blocking_push_client.cc core_ = new Core(delegate_task_runner_, weak_ptr_factory_.GetWeakPtr()); core_ 165 jingle/notifier/listener/non_blocking_push_client.cc core_.get(), create_blocking_push_client_callback)); core_ 173 jingle/notifier/listener/non_blocking_push_client.cc core_.get())); core_ 192 jingle/notifier/listener/non_blocking_push_client.cc core_.get(), subscriptions)); core_ 201 jingle/notifier/listener/non_blocking_push_client.cc core_.get(), email, token)); core_ 209 jingle/notifier/listener/non_blocking_push_client.cc base::Bind(&NonBlockingPushClient::Core::SendNotification, core_.get(), core_ 217 jingle/notifier/listener/non_blocking_push_client.cc base::Bind(&NonBlockingPushClient::Core::SendPing, core_.get())); core_ 64 jingle/notifier/listener/non_blocking_push_client.h scoped_refptr<Core> core_; core_ 103 media/base/user_input_monitor_linux.cc UserInputMonitorLinuxCore* core_; core_ 335 media/base/user_input_monitor_linux.cc if (!io_task_runner_->DeleteSoon(FROM_HERE, core_)) core_ 336 media/base/user_input_monitor_linux.cc delete core_; core_ 340 media/base/user_input_monitor_linux.cc return core_->GetKeyPressCount(); core_ 347 media/base/user_input_monitor_linux.cc core_->AsWeakPtr(), core_ 355 media/base/user_input_monitor_linux.cc core_->AsWeakPtr(), core_ 362 media/base/user_input_monitor_linux.cc core_->AsWeakPtr(), core_ 369 media/base/user_input_monitor_linux.cc core_->AsWeakPtr(), core_ 91 media/base/user_input_monitor_win.cc UserInputMonitorWinCore* core_; core_ 271 media/base/user_input_monitor_win.cc if (!ui_task_runner_->DeleteSoon(FROM_HERE, core_)) core_ 272 media/base/user_input_monitor_win.cc delete core_; core_ 276 media/base/user_input_monitor_win.cc return core_->GetKeyPressCount(); core_ 283 media/base/user_input_monitor_win.cc core_->AsWeakPtr(), core_ 291 media/base/user_input_monitor_win.cc core_->AsWeakPtr(), core_ 299 media/base/user_input_monitor_win.cc core_->AsWeakPtr(), core_ 307 media/base/user_input_monitor_win.cc core_->AsWeakPtr(), core_ 171 mojo/system/core_test_base.cc core_ = new CoreImpl(); core_ 175 mojo/system/core_test_base.cc delete core_; core_ 176 mojo/system/core_test_base.cc core_ = NULL; core_ 180 mojo/system/core_test_base.cc CHECK(core_); core_ 182 mojo/system/core_test_base.cc return core_->AddDispatcher(dispatcher); core_ 37 mojo/system/core_test_base.h CoreImpl* core() { return core_; } core_ 40 mojo/system/core_test_base.h CoreImpl* core_; core_ 90 net/base/directory_lister.cc : core_(new Core(dir, false, ALPHA_DIRS_FIRST, this)), core_ 100 net/base/directory_lister.cc : core_(new Core(dir, recursive, sort, this)), core_ 111 net/base/directory_lister.cc return core_->Start(); core_ 115 net/base/directory_lister.cc return core_->Cancel(); core_ 115 net/base/directory_lister.h const scoped_refptr<Core> core_; core_ 400 net/dns/mdns_client_impl.cc DCHECK(!core_.get()); core_ 401 net/dns/mdns_client_impl.cc core_.reset(new Core(this)); core_ 402 net/dns/mdns_client_impl.cc if (!core_->Init(socket_factory)) { core_ 403 net/dns/mdns_client_impl.cc core_.reset(); core_ 410 net/dns/mdns_client_impl.cc core_.reset(); core_ 414 net/dns/mdns_client_impl.cc return core_.get() != NULL; core_ 186 net/dns/mdns_client_impl.h Core* core() { return core_.get(); } core_ 189 net/dns/mdns_client_impl.h scoped_ptr<Core> core_; core_ 64 net/http/partial_data.cc DCHECK(!owner_->core_); core_ 65 net/http/partial_data.cc owner_->core_ = this; core_ 70 net/http/partial_data.cc owner_->core_ = NULL; core_ 109 net/http/partial_data.cc if (core_) core_ 110 net/http/partial_data.cc core_->Cancel(); core_ 137 net/http/partial_data.h Core* core_; core_ 70 net/proxy/network_delegate_error_observer.cc : core_(new Core(network_delegate, origin_loop)) {} core_ 73 net/proxy/network_delegate_error_observer.cc core_->Shutdown(); core_ 79 net/proxy/network_delegate_error_observer.cc core_->NotifyPACScriptError(line_number, error); core_ 36 net/proxy/network_delegate_error_observer.h scoped_refptr<Core> core_; core_ 164 net/proxy/polling_proxy_config_service.cc core_->AddObserver(observer); core_ 168 net/proxy/polling_proxy_config_service.cc core_->RemoveObserver(observer); core_ 173 net/proxy/polling_proxy_config_service.cc return core_->GetLatestProxyConfig(config) ? CONFIG_VALID : CONFIG_PENDING; core_ 177 net/proxy/polling_proxy_config_service.cc core_->OnLazyPoll(); core_ 183 net/proxy/polling_proxy_config_service.cc : core_(new Core(poll_interval, get_config_func)) { core_ 187 net/proxy/polling_proxy_config_service.cc core_->Orphan(); core_ 191 net/proxy/polling_proxy_config_service.cc core_->CheckForChangesNow(); core_ 48 net/proxy/polling_proxy_config_service.h scoped_refptr<Core> core_; core_ 2844 net/socket/ssl_client_socket_nss.cc if (core_->state().server_cert_chain.empty() || core_ 2845 net/socket/ssl_client_socket_nss.cc !core_->state().server_cert_chain[0]) { core_ 2855 net/socket/ssl_client_socket_nss.cc core_->state().ssl_connection_status; core_ 2864 net/socket/ssl_client_socket_nss.cc core_->state().ssl_connection_status); core_ 2876 net/socket/ssl_client_socket_nss.cc ssl_info->handshake_type = core_->state().resumed_handshake ? core_ 2887 net/socket/ssl_client_socket_nss.cc cert_request_info->cert_authorities = core_->state().cert_authorities; core_ 2931 net/socket/ssl_client_socket_nss.cc *proto = core_->state().next_proto; core_ 2932 net/socket/ssl_client_socket_nss.cc *server_protos = core_->state().server_protos; core_ 2933 net/socket/ssl_client_socket_nss.cc return core_->state().next_proto_status; core_ 2987 net/socket/ssl_client_socket_nss.cc core_->Detach(); core_ 3004 net/socket/ssl_client_socket_nss.cc (core_->HasPendingAsyncOperation() || core_ 3005 net/socket/ssl_client_socket_nss.cc (core_->IsConnected() && core_->HasUnhandledReceivedData()) || core_ 3014 net/socket/ssl_client_socket_nss.cc !core_->HasPendingAsyncOperation() && core_ 3015 net/socket/ssl_client_socket_nss.cc !(core_->IsConnected() && core_->HasUnhandledReceivedData()) && core_ 3050 net/socket/ssl_client_socket_nss.cc DCHECK(core_.get()); core_ 3052 net/socket/ssl_client_socket_nss.cc return core_->WasEverUsed(); core_ 3065 net/socket/ssl_client_socket_nss.cc DCHECK(core_.get()); core_ 3069 net/socket/ssl_client_socket_nss.cc int rv = core_->Read(buf, buf_len, callback); core_ 3077 net/socket/ssl_client_socket_nss.cc DCHECK(core_.get()); core_ 3081 net/socket/ssl_client_socket_nss.cc int rv = core_->Write(buf, buf_len, callback); core_ 3116 net/socket/ssl_client_socket_nss.cc core_ = new Core(base::ThreadTaskRunnerHandle::Get().get(), core_ 3245 net/socket/ssl_client_socket_nss.cc if (!core_->Init(nss_fd_, nss_bufs)) core_ 3358 net/socket/ssl_client_socket_nss.cc int rv = core_->Connect( core_ 3375 net/socket/ssl_client_socket_nss.cc set_channel_id_sent(core_->state().channel_id_sent); core_ 3377 net/socket/ssl_client_socket_nss.cc !core_->state().sct_list_from_tls_extension.empty()); core_ 3379 net/socket/ssl_client_socket_nss.cc !core_->state().stapled_ocsp_response.empty()); core_ 3386 net/socket/ssl_client_socket_nss.cc DCHECK(!core_->state().server_cert_chain.empty()); core_ 3387 net/socket/ssl_client_socket_nss.cc DCHECK(core_->state().server_cert_chain[0]); core_ 3395 net/socket/ssl_client_socket_nss.cc core_->state().server_cert_chain[0]->derCert.data), core_ 3396 net/socket/ssl_client_socket_nss.cc core_->state().server_cert_chain[0]->derCert.len); core_ 3403 net/socket/ssl_client_socket_nss.cc server_cert_verify_result_.verified_cert = core_->state().server_cert; core_ 3409 net/socket/ssl_client_socket_nss.cc if (!core_->state().server_cert.get()) { core_ 3428 net/socket/ssl_client_socket_nss.cc core_->state().server_cert.get(), core_ 3521 net/socket/ssl_client_socket_nss.cc core_->CacheSessionIfNecessary(); core_ 3540 net/socket/ssl_client_socket_nss.cc core_->state().stapled_ocsp_response, core_ 3541 net/socket/ssl_client_socket_nss.cc core_->state().sct_list_from_tls_extension, core_ 3557 net/socket/ssl_client_socket_nss.cc core_->state().ssl_connection_status); core_ 3614 net/socket/ssl_client_socket_nss.cc return core_->state().server_cert.get(); core_ 167 net/socket/ssl_client_socket_nss.h scoped_refptr<Core> core_; core_ 161 net/socket/tcp_socket_win.cc explicit ReadDelegate(Core* core) : core_(core) {} core_ 168 net/socket/tcp_socket_win.cc Core* const core_; core_ 173 net/socket/tcp_socket_win.cc explicit WriteDelegate(Core* core) : core_(core) {} core_ 180 net/socket/tcp_socket_win.cc Core* const core_; core_ 241 net/socket/tcp_socket_win.cc DCHECK_EQ(object, core_->read_overlapped_.hEvent); core_ 242 net/socket/tcp_socket_win.cc if (core_->socket_) { core_ 243 net/socket/tcp_socket_win.cc if (core_->socket_->waiting_connect_) core_ 244 net/socket/tcp_socket_win.cc core_->socket_->DidCompleteConnect(); core_ 246 net/socket/tcp_socket_win.cc core_->socket_->DidSignalRead(); core_ 249 net/socket/tcp_socket_win.cc core_->Release(); core_ 254 net/socket/tcp_socket_win.cc DCHECK_EQ(object, core_->write_overlapped_.hEvent); core_ 255 net/socket/tcp_socket_win.cc if (core_->socket_) core_ 256 net/socket/tcp_socket_win.cc core_->socket_->DidCompleteWrite(); core_ 258 net/socket/tcp_socket_win.cc core_->Release(); core_ 309 net/socket/tcp_socket_win.cc DCHECK(!core_); core_ 319 net/socket/tcp_socket_win.cc core_ = new Core(this); core_ 403 net/socket/tcp_socket_win.cc DCHECK(!peer_address_ && !core_); core_ 471 net/socket/tcp_socket_win.cc DCHECK(!core_->read_iobuffer_); core_ 484 net/socket/tcp_socket_win.cc DCHECK(!core_->write_iobuffer_); core_ 494 net/socket/tcp_socket_win.cc AssertEventNotSignaled(core_->write_overlapped_.hEvent); core_ 497 net/socket/tcp_socket_win.cc &core_->write_overlapped_, NULL); core_ 499 net/socket/tcp_socket_win.cc if (ResetEventIfSignaled(core_->write_overlapped_.hEvent)) { core_ 525 net/socket/tcp_socket_win.cc core_->write_iobuffer_ = buf; core_ 526 net/socket/tcp_socket_win.cc core_->write_buffer_length_ = buf_len; core_ 527 net/socket/tcp_socket_win.cc core_->WatchForWrite(); core_ 653 net/socket/tcp_socket_win.cc if (core_) { core_ 660 net/socket/tcp_socket_win.cc core_->Release(); core_ 662 net/socket/tcp_socket_win.cc core_->Detach(); core_ 663 net/socket/tcp_socket_win.cc core_ = NULL; core_ 761 net/socket/tcp_socket_win.cc DCHECK(!core_); core_ 766 net/socket/tcp_socket_win.cc core_ = new Core(this); core_ 769 net/socket/tcp_socket_win.cc WSAEventSelect(socket_, core_->read_overlapped_.hEvent, FD_CONNECT); core_ 787 net/socket/tcp_socket_win.cc if (ResetEventIfSignaled(core_->read_overlapped_.hEvent)) core_ 800 net/socket/tcp_socket_win.cc core_->WatchForRead(); core_ 857 net/socket/tcp_socket_win.cc if (!core_->non_blocking_reads_initialized_) { core_ 858 net/socket/tcp_socket_win.cc WSAEventSelect(socket_, core_->read_overlapped_.hEvent, core_ 860 net/socket/tcp_socket_win.cc core_->non_blocking_reads_initialized_ = true; core_ 883 net/socket/tcp_socket_win.cc core_->read_iobuffer_ = buf; core_ 884 net/socket/tcp_socket_win.cc core_->read_buffer_length_ = buf_len; core_ 885 net/socket/tcp_socket_win.cc core_->WatchForRead(); core_ 895 net/socket/tcp_socket_win.cc int rv = WSAEnumNetworkEvents(socket_, core_->read_overlapped_.hEvent, core_ 923 net/socket/tcp_socket_win.cc BOOL ok = WSAGetOverlappedResult(socket_, &core_->write_overlapped_, core_ 925 net/socket/tcp_socket_win.cc WSAResetEvent(core_->write_overlapped_.hEvent); core_ 935 net/socket/tcp_socket_win.cc if (rv > core_->write_buffer_length_ || rv < 0) { core_ 939 net/socket/tcp_socket_win.cc << core_->write_buffer_length_ << " bytes, but " << rv core_ 946 net/socket/tcp_socket_win.cc core_->write_iobuffer_->data()); core_ 950 net/socket/tcp_socket_win.cc core_->write_iobuffer_ = NULL; core_ 962 net/socket/tcp_socket_win.cc int rv = WSAEnumNetworkEvents(socket_, core_->read_overlapped_.hEvent, core_ 983 net/socket/tcp_socket_win.cc rv = DoRead(core_->read_iobuffer_, core_->read_buffer_length_, core_ 990 net/socket/tcp_socket_win.cc core_->WatchForRead(); core_ 995 net/socket/tcp_socket_win.cc core_->read_iobuffer_ = NULL; core_ 996 net/socket/tcp_socket_win.cc core_->read_buffer_length_ = 0; core_ 128 net/socket/tcp_socket_win.h scoped_refptr<Core> core_; core_ 68 net/udp/udp_socket_win.cc explicit ReadDelegate(Core* core) : core_(core) {} core_ 75 net/udp/udp_socket_win.cc Core* const core_; core_ 80 net/udp/udp_socket_win.cc explicit WriteDelegate(Core* core) : core_(core) {} core_ 87 net/udp/udp_socket_win.cc Core* const core_; core_ 145 net/udp/udp_socket_win.cc DCHECK_EQ(object, core_->read_overlapped_.hEvent); core_ 146 net/udp/udp_socket_win.cc if (core_->socket_) core_ 147 net/udp/udp_socket_win.cc core_->socket_->DidCompleteRead(); core_ 149 net/udp/udp_socket_win.cc core_->Release(); core_ 153 net/udp/udp_socket_win.cc DCHECK_EQ(object, core_->write_overlapped_.hEvent); core_ 154 net/udp/udp_socket_win.cc if (core_->socket_) core_ 155 net/udp/udp_socket_win.cc core_->socket_->DidCompleteWrite(); core_ 157 net/udp/udp_socket_win.cc core_->Release(); core_ 205 net/udp/udp_socket_win.cc core_->Detach(); core_ 206 net/udp/udp_socket_win.cc core_ = NULL; core_ 387 net/udp/udp_socket_win.cc core_ = new Core(this); core_ 470 net/udp/udp_socket_win.cc BOOL ok = WSAGetOverlappedResult(socket_, &core_->read_overlapped_, core_ 472 net/udp/udp_socket_win.cc WSAResetEvent(core_->read_overlapped_.hEvent); core_ 479 net/udp/udp_socket_win.cc LogRead(result, core_->read_iobuffer_->data()); core_ 480 net/udp/udp_socket_win.cc core_->read_iobuffer_ = NULL; core_ 508 net/udp/udp_socket_win.cc BOOL ok = WSAGetOverlappedResult(socket_, &core_->write_overlapped_, core_ 510 net/udp/udp_socket_win.cc WSAResetEvent(core_->write_overlapped_.hEvent); core_ 512 net/udp/udp_socket_win.cc LogWrite(result, core_->write_iobuffer_->data(), send_to_address_.get()); core_ 515 net/udp/udp_socket_win.cc core_->write_iobuffer_ = NULL; core_ 539 net/udp/udp_socket_win.cc DCHECK(!core_->read_iobuffer_); core_ 540 net/udp/udp_socket_win.cc SockaddrStorage& storage = core_->recv_addr_storage_; core_ 550 net/udp/udp_socket_win.cc AssertEventNotSignaled(core_->read_overlapped_.hEvent); core_ 552 net/udp/udp_socket_win.cc &storage.addr_len, &core_->read_overlapped_, NULL); core_ 554 net/udp/udp_socket_win.cc if (ResetEventIfSignaled(core_->read_overlapped_.hEvent)) { core_ 572 net/udp/udp_socket_win.cc core_->WatchForRead(); core_ 573 net/udp/udp_socket_win.cc core_->read_iobuffer_ = buf; core_ 579 net/udp/udp_socket_win.cc DCHECK(!core_->write_iobuffer_); core_ 600 net/udp/udp_socket_win.cc AssertEventNotSignaled(core_->write_overlapped_.hEvent); core_ 602 net/udp/udp_socket_win.cc addr, storage.addr_len, &core_->write_overlapped_, NULL); core_ 604 net/udp/udp_socket_win.cc if (ResetEventIfSignaled(core_->write_overlapped_.hEvent)) { core_ 618 net/udp/udp_socket_win.cc core_->WatchForWrite(); core_ 619 net/udp/udp_socket_win.cc core_->write_iobuffer_ = buf; core_ 723 net/udp/udp_socket_win.cc SockaddrStorage& storage = core_->recv_addr_storage_; core_ 244 net/udp/udp_socket_win.h scoped_refptr<Core> core_; core_ 21 net/url_request/url_fetcher_impl.cc : core_(new URLFetcherCore(this, url, request_type, d)) { core_ 25 net/url_request/url_fetcher_impl.cc core_->Stop(); core_ 30 net/url_request/url_fetcher_impl.cc core_->SetUploadData(upload_content_type, upload_content); core_ 39 net/url_request/url_fetcher_impl.cc core_->SetUploadFilePath(upload_content_type, core_ 47 net/url_request/url_fetcher_impl.cc core_->SetChunkedUpload(content_type); core_ 53 net/url_request/url_fetcher_impl.cc core_->AppendChunkToUpload(data, is_last_chunk); core_ 57 net/url_request/url_fetcher_impl.cc core_->SetReferrer(referrer); core_ 62 net/url_request/url_fetcher_impl.cc core_->SetReferrerPolicy(referrer_policy); core_ 66 net/url_request/url_fetcher_impl.cc core_->SetLoadFlags(load_flags); core_ 70 net/url_request/url_fetcher_impl.cc return core_->GetLoadFlags(); core_ 75 net/url_request/url_fetcher_impl.cc core_->SetExtraRequestHeaders(extra_request_headers); core_ 79 net/url_request/url_fetcher_impl.cc core_->AddExtraRequestHeader(header_line); core_ 84 net/url_request/url_fetcher_impl.cc core_->SetRequestContext(request_context_getter); core_ 89 net/url_request/url_fetcher_impl.cc core_->SetFirstPartyForCookies(first_party_for_cookies); core_ 95 net/url_request/url_fetcher_impl.cc core_->SetURLRequestUserData(key, create_data_callback); core_ 99 net/url_request/url_fetcher_impl.cc core_->SetStopOnRedirect(stop_on_redirect); core_ 103 net/url_request/url_fetcher_impl.cc core_->SetAutomaticallyRetryOn5xx(retry); core_ 107 net/url_request/url_fetcher_impl.cc core_->SetMaxRetriesOn5xx(max_retries); core_ 111 net/url_request/url_fetcher_impl.cc return core_->GetMaxRetriesOn5xx(); core_ 116 net/url_request/url_fetcher_impl.cc return core_->GetBackoffDelay(); core_ 120 net/url_request/url_fetcher_impl.cc core_->SetAutomaticallyRetryOnNetworkChanges(max_retries); core_ 126 net/url_request/url_fetcher_impl.cc core_->SaveResponseToFileAtPath(file_path, file_task_runner); core_ 131 net/url_request/url_fetcher_impl.cc core_->SaveResponseToTemporaryFile(file_task_runner); core_ 136 net/url_request/url_fetcher_impl.cc core_->SaveResponseWithWriter(response_writer.Pass()); core_ 140 net/url_request/url_fetcher_impl.cc return core_->GetResponseHeaders(); core_ 144 net/url_request/url_fetcher_impl.cc return core_->GetSocketAddress(); core_ 148 net/url_request/url_fetcher_impl.cc return core_->WasFetchedViaProxy(); core_ 152 net/url_request/url_fetcher_impl.cc core_->Start(); core_ 156 net/url_request/url_fetcher_impl.cc return core_->GetOriginalURL(); core_ 160 net/url_request/url_fetcher_impl.cc return core_->GetURL(); core_ 164 net/url_request/url_fetcher_impl.cc return core_->GetStatus(); core_ 168 net/url_request/url_fetcher_impl.cc return core_->GetResponseCode(); core_ 172 net/url_request/url_fetcher_impl.cc return core_->GetCookies(); core_ 176 net/url_request/url_fetcher_impl.cc core_->ReceivedContentWasMalformed(); core_ 181 net/url_request/url_fetcher_impl.cc return core_->GetResponseAsString(out_response_string); core_ 187 net/url_request/url_fetcher_impl.cc return core_->GetResponseAsFilePath(take_ownership, out_response_path); core_ 211 net/url_request/url_fetcher_impl.cc return core_->delegate(); core_ 122 net/url_request/url_fetcher_impl.h const scoped_refptr<URLFetcherCore> core_; core_ 154 ppapi/cpp/module.cc delete core_; core_ 155 ppapi/cpp/module.cc core_ = NULL; core_ 214 ppapi/cpp/module.cc core_ = new Core(core); core_ 74 ppapi/cpp/module.h Core* core() { return core_; } core_ 163 ppapi/cpp/module.h Core* core_; core_ 39 ppapi/shared_impl/thread_aware_callback.cc ThreadAwareCallbackBase::~ThreadAwareCallbackBase() { core_->MarkAsAborted(); } core_ 51 ppapi/shared_impl/thread_aware_callback.cc RunWhileLocked(base::Bind(&Core::RunIfNotAborted, core_, closure)), core_ 33 ppapi/shared_impl/thread_aware_callback.h scoped_refptr<Core> core_; core_ 106 remoting/client/audio_decode_scheduler.cc : core_(new Core(main_task_runner, audio_decode_task_runner, core_ 111 remoting/client/audio_decode_scheduler.cc core_->Detach(); core_ 115 remoting/client/audio_decode_scheduler.cc core_->Initialize(config); core_ 120 remoting/client/audio_decode_scheduler.cc core_->ProcessAudioPacket(packet.Pass(), done); core_ 44 remoting/client/audio_decode_scheduler.h scoped_refptr<Core> core_; core_ 13 remoting/client/plugin/pepper_plugin_thread_delegate.cc : core_(pp::Module::Get()->core()) { core_ 25 remoting/client/plugin/pepper_plugin_thread_delegate.cc core_->CallOnMainThread( core_ 25 remoting/client/plugin/pepper_plugin_thread_delegate.h pp::Core* core_; core_ 320 remoting/client/software_video_renderer.cc core_(new Core(main_task_runner, decode_task_runner, consumer)), core_ 328 remoting/client/software_video_renderer.cc decode_task_runner_->DeleteSoon(FROM_HERE, core_.release()); core_ 336 remoting/client/software_video_renderer.cc base::Unretained(core_.get()), config)); core_ 382 remoting/client/software_video_renderer.cc base::Unretained(core_.get()), base::Passed(&packet), decode_done)); core_ 388 remoting/client/software_video_renderer.cc base::Unretained(core_.get()), buffer)); core_ 395 remoting/client/software_video_renderer.cc base::Unretained(core_.get()), region)); core_ 402 remoting/client/software_video_renderer.cc base::Unretained(core_.get()), done)); core_ 411 remoting/client/software_video_renderer.cc base::Unretained(core_.get()), view_size, clip_area)); core_ 72 remoting/client/software_video_renderer.h scoped_ptr<Core> core_; core_ 97 remoting/host/desktop_session_proxy.cc scoped_refptr<IpcSharedBufferCore> core_; core_ 77 remoting/host/host_window_proxy.cc core_ = new Core(caller_task_runner, ui_task_runner, host_window.Pass()); core_ 83 remoting/host/host_window_proxy.cc core_->Stop(); core_ 90 remoting/host/host_window_proxy.cc core_->Start(client_session_control); core_ 37 remoting/host/host_window_proxy.h scoped_refptr<Core> core_; core_ 129 remoting/host/input_injector_linux.cc scoped_refptr<Core> core_; core_ 136 remoting/host/input_injector_linux.cc core_ = new Core(task_runner); core_ 139 remoting/host/input_injector_linux.cc core_->Stop(); core_ 143 remoting/host/input_injector_linux.cc return core_->Init(); core_ 147 remoting/host/input_injector_linux.cc core_->InjectClipboardEvent(event); core_ 151 remoting/host/input_injector_linux.cc core_->InjectKeyEvent(event); core_ 155 remoting/host/input_injector_linux.cc core_->InjectTextEvent(event); core_ 159 remoting/host/input_injector_linux.cc core_->InjectMouseEvent(event); core_ 164 remoting/host/input_injector_linux.cc core_->Start(client_clipboard.Pass()); core_ 110 remoting/host/input_injector_mac.cc scoped_refptr<Core> core_; core_ 117 remoting/host/input_injector_mac.cc core_ = new Core(task_runner); core_ 121 remoting/host/input_injector_mac.cc core_->Stop(); core_ 125 remoting/host/input_injector_mac.cc core_->InjectClipboardEvent(event); core_ 129 remoting/host/input_injector_mac.cc core_->InjectKeyEvent(event); core_ 133 remoting/host/input_injector_mac.cc core_->InjectTextEvent(event); core_ 137 remoting/host/input_injector_mac.cc core_->InjectMouseEvent(event); core_ 142 remoting/host/input_injector_mac.cc core_->Start(client_clipboard.Pass()); core_ 109 remoting/host/input_injector_win.cc scoped_refptr<Core> core_; core_ 117 remoting/host/input_injector_win.cc core_ = new Core(main_task_runner, ui_task_runner); core_ 121 remoting/host/input_injector_win.cc core_->Stop(); core_ 125 remoting/host/input_injector_win.cc core_->InjectClipboardEvent(event); core_ 129 remoting/host/input_injector_win.cc core_->InjectKeyEvent(event); core_ 133 remoting/host/input_injector_win.cc core_->InjectTextEvent(event); core_ 137 remoting/host/input_injector_win.cc core_->InjectMouseEvent(event); core_ 142 remoting/host/input_injector_win.cc core_->Start(client_clipboard.Pass()); core_ 100 remoting/host/local_input_monitor_linux.cc scoped_refptr<Core> core_; core_ 109 remoting/host/local_input_monitor_linux.cc : core_(new Core(caller_task_runner, core_ 112 remoting/host/local_input_monitor_linux.cc core_->Start(); core_ 116 remoting/host/local_input_monitor_linux.cc core_->Stop(); core_ 79 remoting/host/local_input_monitor_win.cc scoped_refptr<Core> core_; core_ 88 remoting/host/local_input_monitor_win.cc : core_(new Core(caller_task_runner, core_ 91 remoting/host/local_input_monitor_win.cc core_->Start(); core_ 95 remoting/host/local_input_monitor_win.cc core_->Stop(); core_ 138 remoting/host/native_messaging/native_messaging_reader.cc core_.reset(new Core(handle, base::ThreadTaskRunnerHandle::Get(), core_ 143 remoting/host/native_messaging/native_messaging_reader.cc read_task_runner_->DeleteSoon(FROM_HERE, core_.release()); core_ 155 remoting/host/native_messaging/native_messaging_reader.cc base::Unretained(core_.get()))); core_ 55 remoting/host/native_messaging/native_messaging_reader.h scoped_ptr<Core> core_; core_ 172 remoting/host/setup/service_client.cc core_ = new Core(chromoting_hosts_url, context_getter); core_ 185 remoting/host/setup/service_client.cc return core_->RegisterHost(host_id, host_name, public_key, host_client_id, core_ 193 remoting/host/setup/service_client.cc return core_->UnregisterHost(host_id, oauth_access_token, delegate); core_ 56 remoting/host/setup/service_client.h scoped_refptr<Core> core_; core_ 98 remoting/host/win/rdp_client.cc core_ = new Core(caller_task_runner, ui_task_runner, event_handler); core_ 99 remoting/host/win/rdp_client.cc core_->Connect(screen_size, terminal_id); core_ 105 remoting/host/win/rdp_client.cc core_->Disconnect(); core_ 111 remoting/host/win/rdp_client.cc core_->InjectSas(); core_ 54 remoting/host/win/rdp_client.h scoped_refptr<Core> core_; core_ 212 remoting/host/win/session_input_injector.cc core_ = new Core(input_task_runner, nested_executor.Pass(), core_ 221 remoting/host/win/session_input_injector.cc core_->Start(client_clipboard.Pass()); core_ 226 remoting/host/win/session_input_injector.cc core_->InjectClipboardEvent(event); core_ 230 remoting/host/win/session_input_injector.cc core_->InjectKeyEvent(event); core_ 235 remoting/host/win/session_input_injector.cc core_->InjectTextEvent(event); core_ 240 remoting/host/win/session_input_injector.cc core_->InjectMouseEvent(event); core_ 50 remoting/host/win/session_input_injector.h scoped_refptr<Core> core_; core_ 538 remoting/host/win/wts_session_process_delegate.cc core_ = new Core(io_task_runner, core_ 545 remoting/host/win/wts_session_process_delegate.cc core_->Stop(); core_ 549 remoting/host/win/wts_session_process_delegate.cc return core_->Initialize(session_id); core_ 554 remoting/host/win/wts_session_process_delegate.cc core_->LaunchProcess(event_handler); core_ 558 remoting/host/win/wts_session_process_delegate.cc core_->Send(message); core_ 562 remoting/host/win/wts_session_process_delegate.cc core_->CloseChannel(); core_ 566 remoting/host/win/wts_session_process_delegate.cc core_->KillProcess(); core_ 51 remoting/host/win/wts_session_process_delegate.h scoped_refptr<Core> core_; core_ 39 sync/internal_api/non_blocking_type_processor.cc core_ = base::WeakPtr<NonBlockingTypeProcessorCore>(); core_ 53 sync/internal_api/non_blocking_type_processor.cc core_ = core; core_ 52 sync/internal_api/public/non_blocking_type_processor.h base::WeakPtr<NonBlockingTypeProcessorCore> core_; core_ 236 sync/internal_api/public/util/immutable.h Immutable() : core_(new internal::ImmutableCore<T, Traits>()) {} core_ 242 sync/internal_api/public/util/immutable.h : core_(new internal::ImmutableCore<T, Traits>(t)) {} core_ 245 sync/internal_api/public/util/immutable.h return core_->Get(); core_ 249 sync/internal_api/public/util/immutable.h scoped_refptr<const internal::ImmutableCore<T, Traits> > core_; core_ 54 sync/internal_api/public/util/immutable_unittest.cc TokenBase() : core_(new TokenCore(kEmptyToken)) {} core_ 56 sync/internal_api/public/util/immutable_unittest.cc explicit TokenBase(const char* token) : core_(new TokenCore(token)) {} core_ 58 sync/internal_api/public/util/immutable_unittest.cc TokenBase(const TokenBase& other) : core_(other.core_) { core_ 59 sync/internal_api/public/util/immutable_unittest.cc core_->RecordCopy(); core_ 63 sync/internal_api/public/util/immutable_unittest.cc core_ = other.core_; core_ 64 sync/internal_api/public/util/immutable_unittest.cc core_->RecordCopy(); core_ 69 sync/internal_api/public/util/immutable_unittest.cc return core_->GetToken(); core_ 73 sync/internal_api/public/util/immutable_unittest.cc return core_->GetCopyCount(); core_ 84 sync/internal_api/public/util/immutable_unittest.cc swap(other.core_, core_); core_ 90 sync/internal_api/public/util/immutable_unittest.cc swap(other->core_, core_); core_ 94 sync/internal_api/public/util/immutable_unittest.cc scoped_refptr<TokenCore> core_; core_ 282 sync/internal_api/public/util/weak_handle.h : core_(new internal::WeakHandleCore<T>(ptr)) {} core_ 290 sync/internal_api/public/util/weak_handle.h : core_( core_ 299 sync/internal_api/public/util/weak_handle.h return core_.get() != NULL; core_ 304 sync/internal_api/public/util/weak_handle.h core_ = NULL; core_ 310 sync/internal_api/public/util/weak_handle.h CHECK(core_->IsOnOwnerThread()); core_ 311 sync/internal_api/public/util/weak_handle.h return core_->Get(); core_ 321 sync/internal_api/public/util/weak_handle.h core_->Call(from_here, fn); core_ 329 sync/internal_api/public/util/weak_handle.h core_->Call(from_here, fn, a1); core_ 338 sync/internal_api/public/util/weak_handle.h core_->Call(from_here, fn, a1, a2); core_ 348 sync/internal_api/public/util/weak_handle.h core_->Call(from_here, fn, a1, a2, a3); core_ 359 sync/internal_api/public/util/weak_handle.h core_->Call(from_here, fn, a1, a2, a3, a4); core_ 368 sync/internal_api/public/util/weak_handle.h scoped_refptr<internal::WeakHandleCore<T> > core_; core_ 280 sync/internal_api/public/util/weak_handle_unittest.cc EXPECT_EQ(weak_handle.core_.get(), derived_weak_handle.core_.get()); core_ 312 sync/internal_api/public/util/weak_handle_unittest.cc EXPECT_EQ(weak_handle.core_.get(), derived_weak_handle.core_.get()); core_ 23 sync/internal_api/sync_core_proxy_unittest.cc core_(new SyncCore(®istry_)), core_ 26 sync/internal_api/sync_core_proxy_unittest.cc core_->AsWeakPtr()) {} core_ 31 sync/internal_api/sync_core_proxy_unittest.cc core_.reset(); core_ 43 sync/internal_api/sync_core_proxy_unittest.cc scoped_ptr<SyncCore> core_; core_ 216 sync/notifier/non_blocking_invalidator.cc core_ = new Core(MakeWeakHandle(weak_ptr_factory_.GetWeakPtr())); core_ 231 sync/notifier/non_blocking_invalidator.cc core_.get(), core_ 242 sync/notifier/non_blocking_invalidator.cc core_.get()))) { core_ 260 sync/notifier/non_blocking_invalidator.cc core_.get(), core_ 282 sync/notifier/non_blocking_invalidator.cc core_.get(), email, token))) { core_ 295 sync/notifier/non_blocking_invalidator.cc core_.get(), core_ 93 sync/notifier/non_blocking_invalidator.h scoped_refptr<Core> core_;