| /external/chromium_org/net/url_request/ |
| url_request_http_job_unittest.cc | 56 scoped_refptr<TestURLRequestHttpJob> job(new TestURLRequestHttpJob(&req_));
57 EXPECT_EQ(DEFAULT_PRIORITY, job->priority());
59 job->SetPriority(LOWEST);
60 EXPECT_EQ(LOWEST, job->priority());
62 job->SetPriority(LOW);
63 EXPECT_EQ(LOW, job->priority());
65 job->Start();
66 EXPECT_EQ(LOW, job->priority());
68 job->SetPriority(MEDIUM);
69 EXPECT_EQ(MEDIUM, job->priority())
[all...] |
| /external/chromium/net/url_request/ |
| url_request_job_tracker.cc | 26 void URLRequestJobTracker::AddNewJob(URLRequestJob* job) {
27 active_jobs_.push_back(job);
28 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobAdded(job));
31 void URLRequestJobTracker::RemoveJob(URLRequestJob* job) {
33 job);
35 NOTREACHED() << "Removing a non-active job";
40 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobRemoved(job));
43 void URLRequestJobTracker::OnJobDone(URLRequestJob* job,
45 FOR_EACH_OBSERVER(JobObserver, observers_, OnJobDone(job, status));
48 void URLRequestJobTracker::OnJobRedirect(URLRequestJob* job,
[all...] |
| url_request_job_tracker.h | 37 // Called after the given job has been added to the list
38 virtual void OnJobAdded(URLRequestJob* job) = 0;
40 // Called after the given job has been removed from the list
41 virtual void OnJobRemoved(URLRequestJob* job) = 0;
43 // Called when the given job has completed, before notifying the request
44 virtual void OnJobDone(URLRequestJob* job,
47 // Called when the given job is about to follow a redirect to the given
49 virtual void OnJobRedirect(URLRequestJob* job, const GURL& location,
53 // the given job. |byte_count| is the number of bytes for that
57 virtual void OnBytesRead(URLRequestJob* job, const char* buf
[all...] |
| /external/chromium_org/chrome_frame/test/net/ |
| test_automation_resource_message_filter.cc | 19 URLRequestAutomationJob* job, IPC::Message* msg) {
20 job->OnMessage(*msg);
37 RequestJob& job = it->second; local
46 // URLRequestAutomationJob was created on, we could destroy the job on
49 // on the correct thread here since we post to job.loop_ which is set as
52 job.loop_->PostTask(FROM_HERE,
53 base::Bind(OnRequestMessage, job.job_, msg));
63 URLRequestAutomationJob* job) {
68 DCHECK(requests_.end() == requests_.find(job->id()));
69 RequestJob request_job = { base::MessageLoop::current(), job };
[all...] |
| test_automation_resource_message_filter.h | 33 static void OnRequestMessage(URLRequestAutomationJob* job,
39 virtual bool RegisterRequest(URLRequestAutomationJob* job);
41 virtual void UnRegisterRequest(URLRequestAutomationJob* job);
|
| /external/chromium/net/http/ |
| http_stream_factory_impl_request.cc | 40 for (std::set<Job*>::iterator it = jobs_.begin(); it != jobs_.end(); ++it)
58 void HttpStreamFactoryImpl::Request::AttachJob(Job* job) {
59 DCHECK(job);
60 jobs_.insert(job);
61 factory_->request_map_[job] = this;
79 Job* job,
86 // |job| should only be NULL if we're being serviced by a late bound
87 // SpdySession (one that was not created by a job in our |jobs_| set)
[all...] |
| http_stream_factory_impl_request.h | 27 // Called when the Job determines the appropriate |spdy_session_key| for the
33 // Attaches |job| to this request. Does not mean that Request will use |job|,
34 // but Request will own |job|.
35 void AttachJob(HttpStreamFactoryImpl::Job* job);
38 // |source| is the NetLog::Source generated by the Job that fulfilled this
48 // Called by an attached Job if it sets up a SpdySession.
49 void OnSpdySessionReady(Job* job,
[all...] |
| http_stream_factory_impl.cc | 41 std::set<const Job*> tmp_job_set;
62 Job* alternate_job = NULL;
67 new Job(this, session_, alternate_request_info, ssl_config, net_log);
72 Job* job = new Job(this, session_, request_info, ssl_config, net_log); local
73 request->AttachJob(job);
75 job->WaitFor(alternate_job);
77 // |alternate_job|, otherwise |alternate_job| will not notify |job|
83 // so starting |job| is always safe
96 Job* job = NULL; local
[all...] |
| /system/core/sh/ |
| jobs.h | 50 #define SHOW_ISSIG 0x20 /* job was signalled */
51 #define SHOW_NO_FREE 0x40 /* do not free job */
55 * A job structure contains information about a job. A job is either a
68 struct job { struct
72 pid_t pgrp; /* process group of this job */
80 char jobctl; /* job running under job control */
81 int prev_job; /* previous job index *
[all...] |
| /external/chromium_org/net/http/ |
| http_stream_factory_impl_request.cc | 45 for (std::set<Job*>::iterator it = jobs_.begin(); it != jobs_.end(); ++it)
76 void HttpStreamFactoryImpl::Request::AttachJob(Job* job) {
77 DCHECK(job);
78 jobs_.insert(job);
79 factory_->request_map_[job] = this;
101 Job* job,
109 OnJobSucceeded(job);
114 Job* job
[all...] |
| http_stream_factory_impl_request.h | 33 // Called when the Job determines the appropriate |spdy_session_key| for the
39 // Called when the Job determines the appropriate |http_pipelining_key| for
45 // Attaches |job| to this request. Does not mean that Request will use |job|,
46 // but Request will own |job|.
47 void AttachJob(HttpStreamFactoryImpl::Job* job);
50 // |job_net_log| is the BoundNetLog of the Job that fulfilled this request.
64 // Called by an attached Job if it sets up a SpdySession.
65 void OnNewSpdySessionReady(Job* job
[all...] |
| /external/chromium/net/socket_stream/ |
| socket_stream_job_manager.cc | 27 SocketStreamJob* job = new SocketStreamJob(); local
28 job->InitSocketStream(new SocketStream(url, delegate));
29 return job;
37 SocketStreamJob* job = found->second(url, delegate); local
38 if (job)
39 return job;
41 SocketStreamJob* job = new SocketStreamJob(); local
42 job->InitSocketStream(new SocketStream(url, delegate));
43 return job;
|
| /external/chromium_org/net/socket_stream/ |
| socket_stream_job_manager.cc | 27 SocketStreamJob* job = new SocketStreamJob(); local
28 job->InitSocketStream(new SocketStream(url, delegate));
29 return job;
37 SocketStreamJob* job = found->second(url, delegate); local
38 if (job)
39 return job;
41 SocketStreamJob* job = new SocketStreamJob(); local
42 job->InitSocketStream(new SocketStream(url, delegate));
43 return job;
|
| /external/chromium_org/chrome/browser/policy/cloud/ |
| device_management_service_browsertest.cc | 125 scoped_ptr<DeviceManagementRequestJob> job(
127 job->SetGaiaToken("gaia_auth_token");
128 job->SetOAuthToken("oauth_token");
129 job->SetClientID("testid");
130 job->GetRequest()->mutable_register_request();
131 job->Start(base::Bind(&DeviceManagementServiceIntegrationTest::OnJobDone,
183 scoped_ptr<DeviceManagementRequestJob> job(service_->CreateJob(
185 job->SetDMToken(token_);
186 job->SetClientID("testid");
188 job->GetRequest()->mutable_service_api_access_request()
[all...] |
| external_policy_data_updater.cc | 152 // If |fetcher_| exists, the job is currently running and must call back to
203 // This job is currently running. Inform the updater that it was canceled.
308 // This function may have been invoked because the job was obsoleted and is
349 // Check whether a job exists for this |key| already.
350 FetchJob* job = job_map_[key]; local
351 if (job) {
352 // If the current |job| is handling the given |request| already, nothing
354 if (job->request() == request)
357 // Otherwise, the current |job| is obsolete. If the |job| is on the queue
377 std::map<std::string, FetchJob*>::iterator job = job_map_.find(key); local
389 FetchJob* job = job_queue_.front().get(); local
[all...] |
| /external/chromium_org/chrome/browser/printing/ |
| print_job_unittest.cc | 103 scoped_refptr<printing::PrintJob> job(new TestPrintJob(&check));
104 EXPECT_EQ(base::MessageLoop::current(), job->message_loop());
107 job->Initialize(owner.get(), &source, 1);
108 job->Stop();
109 EXPECT_FALSE(job->is_stopped());
110 EXPECT_TRUE(job->is_stopping());
111 while (!job->is_stopped())
115 EXPECT_TRUE(job->is_stopped());
116 EXPECT_FALSE(job->is_stopping());
117 job = NULL
[all...] |
| print_job_manager.cc | 36 for (PrintJobs::const_iterator job = to_stop.begin(); job != to_stop.end();
37 ++job) {
38 // Wait for two minutes for the print job to be spooled.
40 (*job)->FlushJob(base::TimeDelta::FromMinutes(2));
41 (*job)->Stop();
50 void PrintJobManager::QueuePrinterQuery(PrinterQuery* job) {
52 DCHECK(job);
53 queued_queries_.push_back(make_scoped_refptr(job));
54 DCHECK(job->is_valid())
[all...] |
| /external/chromium/chrome/browser/policy/ |
| device_management_service.cc | 131 for (JobFetcherMap::iterator job(pending_jobs_.begin());
132 job != pending_jobs_.end();
133 ++job) {
134 delete job->first;
135 queued_jobs_.push_back(job->second);
145 void DeviceManagementService::AddJob(DeviceManagementJob* job) {
147 StartJob(job);
149 queued_jobs_.push_back(job);
152 void DeviceManagementService::RemoveJob(DeviceManagementJob* job) {
156 if (entry->second == job) {
190 DeviceManagementJob* job = entry->second; local
[all...] |
| /external/chromium_org/tools/gyp/test/mac/ |
| gyptest-postbuild-fail.py | 36 job = subprocess.Popen(['xcodebuild', '-version'], variable
39 out, err = job.communicate()
40 if job.returncode != 0:
42 raise Exception('Error %d running xcodebuild' % job.returncode)
|
| /external/chromium/net/websockets/ |
| websocket_throttle.h | 34 // Puts |job| in |queue_| and queues for the destination addresses
35 // of |job|.
36 // If other job is using the same destination address, set |job| waiting.
37 void PutInQueue(WebSocketJob* job);
39 // Removes |job| from |queue_| and queues for the destination addresses
40 // of |job|.
41 void RemoveFromQueue(WebSocketJob* job);
|
| websocket_throttle.cc | 62 void WebSocketThrottle::PutInQueue(WebSocketJob* job) {
63 queue_.push_back(job);
64 const AddressList& address_list = job->address_list();
79 queue->push_back(job);
82 iter->second->push_back(job);
83 job->SetWaiting();
89 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) {
94 if (*iter == job) {
102 const AddressList& address_list = job->address_list();
117 // Job may not be front of queue when job is closed early while waiting
137 WebSocketJob* job = *iter; local
[all...] |
| /external/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| Dispatcher.java | 35 private final Map<Object, List<Job>> enqueuedJobs = new LinkedHashMap<Object, List<Job>>();
39 Job job = new Job(this, connection, request, responseReceiver); local
40 List<Job> jobsForTag = enqueuedJobs.get(request.tag());
42 jobsForTag = new ArrayList<Job>(2);
45 jobsForTag.add(job);
46 executorService.execute(job);
50 List<Job> jobs = enqueuedJobs.remove(tag)
[all...] |
| /external/chromium_org/content/browser/download/ |
| mhtml_generation_manager.cc | 19 MHTMLGenerationManager::Job::Job()
26 MHTMLGenerationManager::Job::~Job() {
47 Job job; local
48 job.file_path = file;
49 job.process_id = web_contents->GetRenderProcessHost()->GetID();
50 job.routing_id = web_contents->GetRenderViewHost()->GetRoutingID();
51 job.callback = callback
110 Job& job = iter->second; local
133 Job& job = iter->second; local
[all...] |
| /external/chromium_org/net/websockets/ |
| websocket_throttle.cc | 42 bool WebSocketThrottle::PutInQueue(WebSocketJob* job) {
46 queue_.push_back(job);
47 const AddressList& address_list = job->address_list();
61 new_queue->second.push_back(job);
64 iter->second.push_back(job);
65 job->SetWaiting();
73 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) {
75 std::find(queue_.begin(), queue_.end(), job);
82 const AddressList& resolved_address_list = job->address_list();
97 // Job may not be front of the queue if the socket is closed while waiting
121 WebSocketJob* job = *iter; local
[all...] |
| /external/chromium_org/net/base/ |
| prioritized_dispatcher.cc | 37 Job* job, Priority priority) {
38 DCHECK(job);
42 job->Start();
45 return queue_.Insert(job, priority);
52 PrioritizedDispatcher::Job* PrioritizedDispatcher::EvictOldestLowest() {
56 Job* job = handle.value();
58 return job;
66 "Job should not be in queue when limits permit it to start."
[all...] |
