| /prebuilt/ndk/android-ndk-r4/platforms/android-5/arch-x86/usr/include/linux/sunrpc/ |
| xprt.h | 79 int (*reserve_xprt)(struct rpc_task *task);
80 void (*release_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
82 void (*connect)(struct rpc_task *task);
83 void * (*buf_alloc)(struct rpc_task *task, size_t size);
84 void (*buf_free)(struct rpc_task *task);
85 int (*send_request)(struct rpc_task *task);
86 void (*set_retrans_timeout)(struct rpc_task *task);
87 void (*timer)(struct rpc_task *task);
88 void (*release_request)(struct rpc_task *task);
|
| /prebuilt/ndk/android-ndk-r4/platforms/android-8/arch-arm/usr/include/linux/sunrpc/ |
| xprt.h | 79 int (*reserve_xprt)(struct rpc_task *task);
80 void (*release_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
82 void (*connect)(struct rpc_task *task);
83 void * (*buf_alloc)(struct rpc_task *task, size_t size);
84 void (*buf_free)(struct rpc_task *task);
85 int (*send_request)(struct rpc_task *task);
86 void (*set_retrans_timeout)(struct rpc_task *task);
87 void (*timer)(struct rpc_task *task);
88 void (*release_request)(struct rpc_task *task);
|
| /prebuilt/ndk/android-ndk-r4/platforms/android-8/arch-x86/usr/include/linux/sunrpc/ |
| xprt.h | 79 int (*reserve_xprt)(struct rpc_task *task);
80 void (*release_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
82 void (*connect)(struct rpc_task *task);
83 void * (*buf_alloc)(struct rpc_task *task, size_t size);
84 void (*buf_free)(struct rpc_task *task);
85 int (*send_request)(struct rpc_task *task);
86 void (*set_retrans_timeout)(struct rpc_task *task);
87 void (*timer)(struct rpc_task *task);
88 void (*release_request)(struct rpc_task *task);
|
| /external/webkit/WebCore/page/ |
| XSSAuditor.cpp | 108 FindTask task;
109 task.string = code;
110 task.decodeEntities = false;
111 task.allowRequestIfNoIllegalURICharacters = true;
113 if (findInRequest(task)) {
126 FindTask task;
127 task.string = code;
128 task.decodeURLEscapeSequencesTwice = true;
130 if (findInRequest(task)) {
143 FindTask task;
[all...] |
| /external/webkit/WebCore/workers/ |
| WorkerRunLoop.cpp | 80 bool operator()(WorkerRunLoop::Task* task) const
82 return m_defaultMode || m_mode == task->mode();
151 double absoluteTime = (predicate.isDefaultMode() && m_sharedTimer->isActive()) ? m_sharedTimer->fireTime() : MessageQueue<Task>::infiniteTime();
153 OwnPtr<WorkerRunLoop::Task> task = m_messageQueue.waitForMessageFilteredWithTimeout(result, predicate, absoluteTime); local
162 task->performTask(context);
179 void WorkerRunLoop::postTask(PassOwnPtr<ScriptExecutionContext::Task> task)
181 postTaskForMode(task, defaultMode())
[all...] |
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| PerNameExecutor.java | 23 * Uses a separate executor for each task name.
49 public synchronized void execute(NamedTask task) {
53 String name = task.getName();
59 executor.execute(task);
|
| /external/chromium/base/ |
| message_loop.cc | 122 // Clean up any unprocessed tasks, but take care: deleting a task could
124 // limit on the number of times we will allow a deleted task to generate more
126 // we end up hitting the loop limit, then it is probably due to one task that
218 Task* task = deferred_non_nestable_work_queue_.front().task;
221 RunTask(task);
237 const tracked_objects::Location& from_here, Task* task) {
238 PostTask_Helper(from_here, task, 0, true)
394 Task* task = NULL; local
407 Task* task = delayed_work_queue_.top().task; local
[all...] |
| message_loop.h | 16 #include "base/task.h"
32 // Events include at a minimum Task instances submitted to PostTask or those
41 // NOTE: MessageLoop has task reentrancy protection. This means that if a
42 // task is being processed, a second task cannot start until the first task is
43 // finished. Reentrancy can happen when processing a task, and an inner
45 // which could implicitly start an inner task. Inner message pumps are created
49 // Sample workaround when inner task processing is needed:
56 // Please be SURE your task is reentrant (nestable) and all global variable
288 Task* task; \/\/ The task to run. member in struct:MessageLoop::PendingTask
[all...] |
| worker_pool_linux.h | 13 // task queue, it does not own the worker threads. The worker threads ask the
37 class Task;
56 // Adds |task| to the thread pool. LinuxDynamicThreadPool assumes ownership
57 // of |task|.
58 void PostTask(Task* task);
62 Task* WaitForTask();
77 std::queue<Task*> tasks_;
|
| /external/webkit/JavaScriptCore/wtf/ |
| MallocZoneSupport.h | 41 RemoteMemoryReader(task_t task, memory_reader_t* reader)
42 : m_task(task)
|
| /external/webkit/WebCore/storage/ |
| DatabaseThread.cpp | 98 while (OwnPtr<DatabaseTask> task = m_queue.waitForMessage()) {
99 task->performTask();
149 void DatabaseThread::scheduleTask(PassOwnPtr<DatabaseTask> task)
151 m_queue.append(task);
154 void DatabaseThread::scheduleImmediateTask(PassOwnPtr<DatabaseTask> task)
156 m_queue.prepend(task);
162 bool operator()(DatabaseTask* task) const { return task->database() == m_database; }
|
| LocalStorageThread.cpp | 68 while (OwnPtr<LocalStorageTask> task = m_queue.waitForMessage())
69 task->performTask();
74 void LocalStorageThread::scheduleTask(PassOwnPtr<LocalStorageTask> task)
78 m_queue.append(task);
|
| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
| MockExecutor.java | 23 * A simple executor that maintains a queue and executes one task synchronously every
33 public void execute(Runnable task) {
35 mQueue.addLast(task);
|
| /external/e2fsprogs/lib/blkid/ |
| devname.c | 170 struct dm_task *task; local
176 task = dm_task_create(DM_DEVICE_DEPS);
177 if (!task)
180 if (!dm_task_set_name(task, name))
183 if (!dm_task_run(task))
186 if (!dm_task_get_info(task, &info))
192 deps = dm_task_get_deps(task);
206 if (task)
207 dm_task_destroy(task);
214 struct dm_task *task; local
252 struct dm_task *task; local
283 struct dm_task *task; local
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/ |
| Executors.java | 99 * sequentially, and no more than one task will be active at any
180 * sequentially, and no more than one task will be active at any
197 * guaranteed to execute sequentially, and no more than one task
312 * any task runs in {@link ThreadPoolExecutor} subclasses using
331 * called, runs the given task and returns the given result. This
334 * @param task the task to run
337 * @throws NullPointerException if task null
339 public static <T> Callable<T> callable(Runnable task, T result) {
340 if (task == null
[all...] |
| ExecutorService.java | 102 * submission of a {@code Runnable} or {@code Callable} task to an
105 * any actions taken by that task, which in turn <i>happen-before</i> the
144 * task that fails to respond to interrupts may never terminate.
189 * Submits a value-returning task for execution and returns a
190 * Future representing the pending results of the task. The
191 * Future's <tt>get</tt> method will return the task's result upon
196 * for a task, you can use constructions of the form
204 * @param task the task to submit
205 * @return a Future representing pending completion of the task
[all...] |
| /external/v8/benchmarks/ |
| richards.js | 44 * The Richards benchmark simulates the task dispatcher of an
84 * how many times a task is put on hold in a correct run of richards.
95 * priorities. Scheduling is done by maintaining a list of task control blocks
120 * Add an idle task to this scheduler.
121 * @param {int} id the identity of the task
122 * @param {int} priority the task's priority
123 * @param {Packet} queue the queue of work to be processed by the task
124 * @param {int} count the number of times to schedule the task
131 * Add a work task to this scheduler.
132 * @param {int} id the identity of the task
[all...] |
| /external/webkit/SunSpider/tests/v8-v4/ |
| v8-richards.js | 39 * The Richards benchmark simulates the task dispatcher of an
79 * how many times a task is put on hold in a correct run of richards.
90 * priorities. Scheduling is done by maintaining a list of task control blocks
115 * Add an idle task to this scheduler.
116 * @param {int} id the identity of the task
117 * @param {int} priority the task's priority
118 * @param {Packet} queue the queue of work to be processed by the task
119 * @param {int} count the number of times to schedule the task
126 * Add a work task to this scheduler.
127 * @param {int} id the identity of the task
[all...] |
| /external/kernel-headers/original/linux/sunrpc/ |
| sched.h | 39 * This is the RPC task struct
80 unsigned char tk_priority : 2;/* Task priority */
81 unsigned long tk_runstate; /* Task run status */
86 struct work_struct tk_work; /* Async task work queue */
92 unsigned long tk_start; /* RPC task init timestamp */
103 #define task_for_each(task, pos, head) \
105 if ((task=list_entry(pos, struct rpc_task, u.tk_wait.list)),1)
107 #define task_for_first(task, head) \
109 ((task=list_entry((head)->next, struct rpc_task, u.tk_wait.list)),1))
112 #define alltask_for_each(task, pos, head)
[all...] |
| /external/webkit/WebCore/storage/wince/ |
| LocalStorageThreadWince.cpp | 49 RefPtr<LocalStorageTask> task = m_queue.first(); local
50 task->performTask();
|
| /frameworks/base/tools/aidl/ |
| options.h | 18 int task; member in struct:Options
|
| /external/webkit/WebCore/wml/ |
| WMLDoElement.cpp | 170 void WMLDoElement::registerTask(WMLTaskElement* task)
173 m_task = task;
176 void WMLDoElement::deregisterTask(WMLTaskElement* task)
178 ASSERT_UNUSED(task, m_task == task);
|
| /external/emma/ant/ant14/com/vladium/emma/report/ |
| ReportCfg.java | 26 import org.apache.tools.ant.Task;
113 Element (final Task task, final IProperties settings)
115 if (task == null)
116 throw new IllegalArgumentException ("null input: task");
120 m_task = task;
151 protected final Task m_task; // never null
167 Element_HTML (final Task task, final IProperties settings)
169 super (task, settings)
[all...] |
| /external/kernel-headers/original/linux/ |
| rtc.h | 194 struct rtc_task *task);
196 struct rtc_task *task);
198 struct rtc_task *task, int enabled);
200 struct rtc_task *task, int freq);
207 int rtc_register(rtc_task_t *task);
208 int rtc_unregister(rtc_task_t *task);
|
| /external/webkit/WebKit/chromium/src/ |
| WebWorkerBase.cpp | 141 void WebWorkerBase::dispatchTaskToMainThread(PassOwnPtr<ScriptExecutionContext::Task> task)
143 return callOnMainThread(invokeTaskMethod, task.release());
148 ScriptExecutionContext::Task* task = local
149 static_cast<ScriptExecutionContext::Task*>(param);
150 task->performTask(0);
151 delete task;
295 void WebWorkerBase::postTaskToLoader(PassOwnPtr<ScriptExecutionContext::Task> task)
[all...] |
