| /external/ims/rcs/rcsservice/src/com/android/service/ims/ |
| D | TaskManager.java | 99 public void putTask(int taskId, Task task){ in putTask() argument
101 putTaskInternal(taskId, task); in putTask()
105 private synchronized void putTaskInternal(int taskId, Task task){ in putTaskInternal() argument
106 Task sameKeyTask = mTaskMap.put(String.valueOf(taskId), task); in putTaskInternal()
113 int taskId = TaskManager.getDefault().generateTaskId(); in addCapabilityTask() local
115 Task task = new PresenceCapabilityTask(context, taskId, TASK_TYPE_GET_CAPABILITY, in addCapabilityTask()
117 putTaskInternal(taskId, task); in addCapabilityTask()
120 return taskId; in addCapabilityTask()
124 int taskId = TaskManager.getDefault().generateTaskId(); in addAvailabilityTask() local
128 Task task = new PresenceAvailabilityTask(taskId, TASK_TYPE_GET_AVAILABILITY, in addAvailabilityTask()
[all …]
|
| D | Task.java | 67 public Task(int taskId, int cmdId, ContactCapabilityResponse listener) { in Task() argument
68 mTaskId = taskId; in Task()
|
| D | RcsStackAdaptor.java | 311 public int requestCapability(String[] formattedContacts, int taskId) { in requestCapability() argument
320 mStackPresenceServiceHandle, formattedContacts[0], taskId); in requestCapability()
323 mStackPresenceServiceHandle, formattedContacts, taskId); in requestCapability()
341 public int requestAvailability(String formattedContact, int taskId) { in requestAvailability() argument
348 mStackPresenceServiceHandle, formattedContact, taskId); in requestAvailability()
363 public int requestPublication(RcsContactUceCapability capabilities, String myUri, int taskId) { in requestPublication() argument
401 mStackPresenceServiceHandle, pMyCapInfo, taskId); in requestPublication()
408 logger.error("requestPublication remove taskId=" + taskId); in requestPublication()
414 logger.error("requestPublication remove taskId=" + taskId); in requestPublication()
|
| D | AlarmBroadcastReceiver.java | 59 int taskId = intent.getIntExtra("taskId", -1); in onReceive() local
60 TaskManager.getDefault().onTimeout(taskId); in onReceive()
|
| /external/exoplayer/tree/testutils/src/main/java/com/google/android/exoplayer2/testutil/ |
| D | TestDownloadManagerListener.java | 64 public Integer pollStateChange(String taskId, long timeoutMs) throws InterruptedException { in pollStateChange() argument
65 return getStateQueue(taskId).poll(timeoutMs, TimeUnit.MILLISECONDS); in pollStateChange()
125 private ArrayBlockingQueue<Integer> getStateQueue(String taskId) { in getStateQueue() argument
127 @Nullable ArrayBlockingQueue<Integer> stateQueue = downloadStates.get(taskId); in getStateQueue()
130 downloadStates.put(taskId, stateQueue); in getStateQueue()
136 public void assertRemoved(String taskId, int timeoutMs) { in assertRemoved() argument
137 assertStateInternal(taskId, STATE_REMOVED, timeoutMs); in assertRemoved()
140 public void assertState(String taskId, @State int expectedState, int timeoutMs) { in assertState() argument
141 assertStateInternal(taskId, expectedState, timeoutMs); in assertState()
144 private void assertStateInternal(String taskId, int expectedState, int timeoutMs) { in assertStateInternal() argument
[all …]
|
| /external/ims/rcs/rcsservice/src/com/android/service/ims/presence/ |
| D | PresenceSubscriber.java | 184 int taskId = TaskManager.getDefault().addCapabilityTask(mContext, formatedNumbers, in requestCapability() local
186 logger.print("taskId=" + taskId); in requestCapability()
188 ret = subscriber.requestCapability(formatedContacts, taskId); in requestCapability()
190 logger.error("requestCapability ret=" + ret + " remove taskId=" + taskId); in requestCapability()
191 TaskManager.getDefault().removeTask(taskId); in requestCapability()
194 ret = taskId; in requestCapability()
264 int taskId = TaskManager.getDefault().addAvailabilityTask(formatedContact, listener); in requestAvailability() local
271 ret = subscriber.requestAvailability(formatedContact, taskId); in requestAvailability()
273 logger.error("requestAvailability ret=" + ret + " remove taskId=" + taskId); in requestAvailability()
274 TaskManager.getDefault().removeTask(taskId); in requestAvailability()
[all …]
|
| D | SubscribePublisher.java | 36 int requestCapability(String[] formatedContacts, int taskId); in requestCapability() argument
41 int requestAvailability(String formattedContact, int taskId); in requestAvailability() argument
|
| D | PresencePublishTask.java | 40 public PresencePublishTask(int taskId, int cmdId, ContactCapabilityResponse listener, in PresencePublishTask() argument
42 super(taskId, cmdId, listener, contacts); in PresencePublishTask()
|
| D | PresenceTask.java | 41 public PresenceTask(int taskId, int cmdId, ContactCapabilityResponse listener, in PresenceTask() argument
43 super(taskId, cmdId, listener); in PresenceTask()
|
| D | PresenceAvailabilityTask.java | 47 public PresenceAvailabilityTask(int taskId, int cmdId, ContactCapabilityResponse listener, in PresenceAvailabilityTask() argument
49 super(taskId, cmdId, listener, contacts); in PresenceAvailabilityTask()
|
| D | PresenceCapabilityTask.java | 73 public PresenceCapabilityTask(Context context, int taskId, int cmdId, in PresenceCapabilityTask() argument
76 super(taskId, cmdId, listener, contacts); in PresenceCapabilityTask()
|
| D | PresencePublication.java | 466 public void onCommandStatusUpdated(int taskId, int requestId, int resultCode) { in onCommandStatusUpdated() argument
468 super.onCommandStatusUpdated(taskId, requestId, resultCode); in onCommandStatusUpdated()
923 int taskId = TaskManager.getDefault().addPublishTask(myNumber); in doPublish() local
924 logger.print("doPublish, uri=" + myUri + ", myNumber=" + myNumber + ", taskId=" + taskId); in doPublish()
925 int ret = presencePublisher.requestPublication(presenceInfo, myUri.toString(), taskId); in doPublish()
927 logger.print("doPublish, task=" + taskId + " failed with code=" + ret); in doPublish()
928 TaskManager.getDefault().removeTask(taskId); in doPublish()
|
| D | PresenceBase.java | 173 public void onCommandStatusUpdated(int taskId, int requestId, int resultCode) { in onCommandStatusUpdated() argument
174 Task task = TaskManager.getDefault().getTask(taskId); in onCommandStatusUpdated()
|
| D | PresencePublisher.java | 47 int requestPublication(RcsContactUceCapability capabilities, String contactUri, int taskId); in requestPublication() argument
|
| /external/exoplayer/tree/library/core/src/test/java/com/google/android/exoplayer2/offline/ |
| D | DownloadManagerTest.java | 383 String[] taskIds = {task1.taskId, task2.taskId, task3.taskId}; in getCurrentDownloads_returnsCurrentDownloads()
433 runOnMainThread(() -> downloadManager.setStopReason(task.taskId, APP_STOP_REASON)); in setAndClearSingleDownloadStopReason()
437 runOnMainThread(() -> downloadManager.setStopReason(task.taskId, Download.STOP_REASON_NONE)); in setAndClearSingleDownloadStopReason()
451 runOnMainThread(() -> downloadManager.setStopReason(task.taskId, APP_STOP_REASON)); in setSingleDownloadStopReasonThenRemove_removesDownload()
471 runOnMainThread(() -> downloadManager.setStopReason(runner1.getTask().taskId, APP_STOP_REASON)); in setSingleDownloadStopReason_doesNotAffectOtherDownloads()
678 private final String taskId; field in DownloadManagerTest.TaskWrapper
680 private TaskWrapper(String taskId) { in TaskWrapper() argument
681 this.taskId = taskId; in TaskWrapper()
709 downloadManagerListener.assertState(taskId, expectedState, ASSERT_TRUE_TIMEOUT); in assertState()
714 downloadManagerListener.assertRemoved(taskId, ASSERT_TRUE_TIMEOUT); in assertRemoved()
[all …]
|
| /external/skia/infra/bots/task_drivers/run_gn_to_bp/ |
| D | run_gn_to_bp.go | 21 taskId = flag.String("task_id", "", "ID of this task.")
28 ctx := td.StartRun(projectId, taskId, taskName, output, local)
|
| /external/skqp/infra/pathkit/perf/ |
| D | wasm_perf_aggregator.go | 52 taskId = flag.String("task_id", "", "swarming task id") var
178 SwarmingTaskID: *taskId,
|
| /external/skia/infra/wasm-common/perf/ |
| D | wasm_perf_aggregator.go | 53 taskId = flag.String("task_id", "", "swarming task id") var
181 SwarmingTaskID: *taskId,
|
| /external/skia/infra/lottiecap/gold/ |
| D | lottie-web-aggregator.go | 49 taskId = flag.String("task_id", "", "Skia task id") var
174 TaskID: *taskId,
|
| /external/skia/infra/bots/task_drivers/canary/ |
| D | canary.go | 40 taskId = flag.String("task_id", "", "ID of this task.")
49 ctx := td.StartRun(projectId, taskId, taskName, output, local)
|
| /external/skqp/infra/pathkit/gold/ |
| D | wasm_gold_aggregator.go | 48 taskId = flag.String("task_id", "", "swarming task id") var
184 SwarmingTaskID: *taskId,
|
| /external/skqp/infra/lottiecap/gold/ |
| D | lottie-web-aggregator.go | 50 taskId = flag.String("task_id", "", "swarming task id") var
177 SwarmingTaskID: *taskId,
|
| /external/skia/infra/bots/task_drivers/g3_canary/ |
| D | g3_canary.go | 62 taskId = flag.String("task_id", "", "ID of this task.")
69 ctx := td.StartRun(projectId, taskId, taskName, output, local)
|
| /external/python/apitools/samples/fusiontables_sample/fusiontables_v1/ |
| D | fusiontables_v1_messages.py | 396 taskId = _messages.StringField(2, required=True) variable in FusiontablesTaskDeleteRequest
412 taskId = _messages.StringField(2, required=True) variable in FusiontablesTaskGetRequest
871 taskId = _messages.IntegerField(4) variable in Task
|
| /external/skia/infra/bots/task_drivers/fm_driver/ |
| D | fm_driver.go | 31 taskId = flag.String("task_id", "", "ID of this task.")
59 ctx = td.StartRun(projectId, taskId, bot, output, local)
|