Home
last modified time | relevance | path

Searched refs:taskID (Results 1 – 25 of 1104) sorted by relevance

12345678910>>...45

/dports/math/gap/gap-4.11.0/hpcgap/demo/
H A Dtestparkit.g23 emitter := function(taskID, m, ins)
24 m.provideOutput(1,l,taskID);
25 m.finished(taskID);
30 m.finished(taskID);
44 m.finished(taskID);
53 m.finished(taskID);
58 m.finished(taskID);
65 m.finished(taskID);
89 m.finished(taskID);
94 m.finished(taskID);
[all …]
H A Dparkit.g63 Assert(2, task.taskID = id);
126 command.taskID < 0 then
136 if command.taskID = 0 then
231 command.taskID < 0 then
384 taskID := taskID);
390 taskID := arg[1]);
403 taskID := taskID);
410 taskID := taskID);
416 taskID := taskID);
419 manager.stop := function(taskID)
[all …]
/dports/math/py-or-tools/or-tools-9.2/ortools/sat/samples/
H A DMinimalJobshopSat.cs29 public int taskID; field in ScheduleRequestsSat.AssignedTask
36 this.taskID = taskID; in AssignedTask()
121 for (int taskID = 0; taskID < job.Count(); ++taskID) in Main()
123 var task = job[taskID]; in Main()
128 var key = Tuple.Create(jobID, taskID); in Main()
150 for (int taskID = 0; taskID < job.Count() - 1; ++taskID) in Main()
152 var key = Tuple.Create(jobID, taskID); in Main()
153 var nextKey = Tuple.Create(jobID, taskID + 1); in Main()
190 for (int taskID = 0; taskID < job.Count(); ++taskID) in Main()
192 var task = job[taskID]; in Main()
[all …]
H A DMinimalJobshopSat.java89 for (int taskID = 0; taskID < job.size(); ++taskID) { in main()
90 Task task = job.get(taskID); in main()
91 String suffix = "_" + jobID + "_" + taskID; in main()
99 List<Integer> key = Arrays.asList(jobID, taskID); in main()
117 for (int taskID = 0; taskID < job.size() - 1; ++taskID) { in main()
118 List<Integer> prevKey = Arrays.asList(jobID, taskID); in main()
148 int taskID; in main() field in MinimalJobshopSat.AssignedTask
154 this.taskID = taskID; in main()
174 for (int taskID = 0; taskID < job.size(); ++taskID) { in main()
175 Task task = job.get(taskID); in main()
[all …]
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/influxdata/influxdb-client-go/v2/api/
H A Dtasks.go55 GetTaskByID(ctx context.Context, taskID string) (*domain.Task, error)
73 DeleteTaskWithID(ctx context.Context, taskID string) error
85 RemoveMemberWithID(ctx context.Context, taskID, memberID string) error argument
97 RemoveOwnerWithID(ctx context.Context, taskID, memberID string) error argument
121 CancelRunWithID(ctx context.Context, taskID, runID string) error argument
137 RemoveLabelWithID(ctx context.Context, taskID, labelID string) error argument
198 response, err := t.apiClient.GetTasksIDWithResponse(ctx, taskID, params)
308 return nil, fmt.Errorf("members for task '%s' not found", taskID)
360 return nil, fmt.Errorf("owners for task '%s' not found", taskID)
526 return nil, fmt.Errorf("logs for task '%s' not found", taskID)
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/influxdata/influxdb-client-go/v2/api/
H A Dtasks.go55 GetTaskByID(ctx context.Context, taskID string) (*domain.Task, error)
73 DeleteTaskWithID(ctx context.Context, taskID string) error
85 RemoveMemberWithID(ctx context.Context, taskID, memberID string) error argument
97 RemoveOwnerWithID(ctx context.Context, taskID, memberID string) error argument
121 CancelRunWithID(ctx context.Context, taskID, runID string) error argument
137 RemoveLabelWithID(ctx context.Context, taskID, labelID string) error argument
198 response, err := t.apiClient.GetTasksIDWithResponse(ctx, taskID, params)
308 return nil, fmt.Errorf("members for task '%s' not found", taskID)
360 return nil, fmt.Errorf("owners for task '%s' not found", taskID)
526 return nil, fmt.Errorf("logs for task '%s' not found", taskID)
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbrpc/
H A Dfdbrpc.h50 const Endpoint& getEndpoint(int taskID) { in getEndpoint()
179 void resetReply(Request& r, int taskID) { r.reply.reset(); r.reply.getEndpoint(taskID); } in resetReply() argument
182 void resetReply(ReplyPromise<Reply> & p, int taskID) { p.reset(); p.getEndpoint(taskID); } in resetReply() argument
185 void setReplyPriority(Request& r, int taskID) { r.reply.getEndpoint(taskID); } in setReplyPriority() argument
188 void setReplyPriority(ReplyPromise<Reply> & p, int taskID) { p.getEndpoint(taskID); } in setReplyPriority() argument
191 void setReplyPriority(const ReplyPromise<Reply> & p, int taskID) { p.getEndpoint(taskID); } in setReplyPriority() argument
250 setReplyPriority(value, taskID); in getReply()
260 reply.getEndpoint(taskID); in getReplyWithTaskID()
271 setReplyPriority(value, taskID); in tryGetReply()
316 getEndpoint(taskID)); in getReplyUnlessFailedFor()
[all …]
/dports/games/openjk/OpenJK-07675e2/codemp/icarus/
H A DQ3_Interface.cpp117 void Q3_TaskIDClear( int *taskID ) in Q3_TaskIDClear() argument
119 *taskID = -1; in Q3_TaskIDClear()
195 ent->taskID[taskType] = taskID; in Q3_TaskIDSet()
335 sharedMem->taskID = taskID; in Q3_PlaySound()
410 sharedMem->taskID = taskID; in Q3_Set()
785 sharedMem->taskID = taskID; in Q3_Lerp2Pos()
815 sharedMem->taskID = taskID; in Q3_Lerp2Origin()
828 sharedMem->taskID = taskID; in Q3_Lerp2Angles()
856 sharedMem->taskID = taskID; in Q3_Lerp2Start()
867 sharedMem->taskID = taskID; in Q3_Lerp2End()
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/
H A Dreporter.go15 UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskStatus) error
18 type statusReporterFunc func(ctx context.Context, taskID string, status *api.TaskStatus) error
20 func (fn statusReporterFunc) UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskS…
21 return fn(ctx, taskID, status)
52 current, ok := sr.statuses[taskID]
62 sr.statuses[taskID] = status
105 for taskID, status := range sr.statuses {
106 delete(sr.statuses, taskID) // delete the entry, while trying to send.
109 err := sr.reporter.UpdateTaskStatus(ctx, taskID, status)
123 if _, ok := sr.statuses[taskID]; !ok {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/swarmkit/agent/
H A Dreporter.go15 UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskStatus) error
18 type statusReporterFunc func(ctx context.Context, taskID string, status *api.TaskStatus) error
20 func (fn statusReporterFunc) UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskS…
21 return fn(ctx, taskID, status)
52 current, ok := sr.statuses[taskID]
62 sr.statuses[taskID] = status
105 for taskID, status := range sr.statuses {
106 delete(sr.statuses, taskID) // delete the entry, while trying to send.
109 err := sr.reporter.UpdateTaskStatus(ctx, taskID, status)
123 if _, ok := sr.statuses[taskID]; !ok {
[all …]
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/
H A Dreporter.go15 UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskStatus) error
18 type statusReporterFunc func(ctx context.Context, taskID string, status *api.TaskStatus) error
20 func (fn statusReporterFunc) UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskS…
21 return fn(ctx, taskID, status)
52 current, ok := sr.statuses[taskID]
62 sr.statuses[taskID] = status
105 for taskID, status := range sr.statuses {
106 delete(sr.statuses, taskID) // delete the entry, while trying to send.
109 err := sr.reporter.UpdateTaskStatus(ctx, taskID, status)
123 if _, ok := sr.statuses[taskID]; !ok {
[all …]
/dports/sysutils/docker/docker-ce-18.09.5/components/engine/vendor/github.com/docker/swarmkit/agent/
H A Dreporter.go15 UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskStatus) error
18 type statusReporterFunc func(ctx context.Context, taskID string, status *api.TaskStatus) error
20 func (fn statusReporterFunc) UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskS…
21 return fn(ctx, taskID, status)
52 current, ok := sr.statuses[taskID]
62 sr.statuses[taskID] = status
105 for taskID, status := range sr.statuses {
106 delete(sr.statuses, taskID) // delete the entry, while trying to send.
109 err := sr.reporter.UpdateTaskStatus(ctx, taskID, status)
123 if _, ok := sr.statuses[taskID]; !ok {
[all …]
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/
H A Dreporter.go15 UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskStatus) error
18 type statusReporterFunc func(ctx context.Context, taskID string, status *api.TaskStatus) error
20 func (fn statusReporterFunc) UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskS…
21 return fn(ctx, taskID, status)
52 current, ok := sr.statuses[taskID]
62 sr.statuses[taskID] = status
105 for taskID, status := range sr.statuses {
106 delete(sr.statuses, taskID) // delete the entry, while trying to send.
109 err := sr.reporter.UpdateTaskStatus(ctx, taskID, status)
123 if _, ok := sr.statuses[taskID]; !ok {
[all …]
/dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/
H A Dreporter.go15 UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskStatus) error
18 type statusReporterFunc func(ctx context.Context, taskID string, status *api.TaskStatus) error
20 func (fn statusReporterFunc) UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskS…
21 return fn(ctx, taskID, status)
52 current, ok := sr.statuses[taskID]
62 sr.statuses[taskID] = status
105 for taskID, status := range sr.statuses {
106 delete(sr.statuses, taskID) // delete the entry, while trying to send.
109 err := sr.reporter.UpdateTaskStatus(ctx, taskID, status)
123 if _, ok := sr.statuses[taskID]; !ok {
[all …]
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/
H A Dreporter.go15 UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskStatus) error
18 type statusReporterFunc func(ctx context.Context, taskID string, status *api.TaskStatus) error
20 func (fn statusReporterFunc) UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskS…
21 return fn(ctx, taskID, status)
52 current, ok := sr.statuses[taskID]
62 sr.statuses[taskID] = status
105 for taskID, status := range sr.statuses {
106 delete(sr.statuses, taskID) // delete the entry, while trying to send.
109 err := sr.reporter.UpdateTaskStatus(ctx, taskID, status)
123 if _, ok := sr.statuses[taskID]; !ok {
[all …]
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/
H A Dreporter.go15 UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskStatus) error
18 type statusReporterFunc func(ctx context.Context, taskID string, status *api.TaskStatus) error
20 func (fn statusReporterFunc) UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskS…
21 return fn(ctx, taskID, status)
52 current, ok := sr.statuses[taskID]
62 sr.statuses[taskID] = status
105 for taskID, status := range sr.statuses {
106 delete(sr.statuses, taskID) // delete the entry, while trying to send.
109 err := sr.reporter.UpdateTaskStatus(ctx, taskID, status)
123 if _, ok := sr.statuses[taskID]; !ok {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/
H A Dreporter.go15 UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskStatus) error
18 type statusReporterFunc func(ctx context.Context, taskID string, status *api.TaskStatus) error
20 func (fn statusReporterFunc) UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskS…
21 return fn(ctx, taskID, status)
52 current, ok := sr.statuses[taskID]
62 sr.statuses[taskID] = status
105 for taskID, status := range sr.statuses {
106 delete(sr.statuses, taskID) // delete the entry, while trying to send.
109 err := sr.reporter.UpdateTaskStatus(ctx, taskID, status)
123 if _, ok := sr.statuses[taskID]; !ok {
[all …]
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/
H A Dreporter.go15 UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskStatus) error
18 type statusReporterFunc func(ctx context.Context, taskID string, status *api.TaskStatus) error
20 func (fn statusReporterFunc) UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskS…
21 return fn(ctx, taskID, status)
52 current, ok := sr.statuses[taskID]
62 sr.statuses[taskID] = status
105 for taskID, status := range sr.statuses {
106 delete(sr.statuses, taskID) // delete the entry, while trying to send.
109 err := sr.reporter.UpdateTaskStatus(ctx, taskID, status)
123 if _, ok := sr.statuses[taskID]; !ok {
[all …]
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/agent/
H A Dreporter.go15 UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskStatus) error
18 type statusReporterFunc func(ctx context.Context, taskID string, status *api.TaskStatus) error
20 func (fn statusReporterFunc) UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskS…
21 return fn(ctx, taskID, status)
52 current, ok := sr.statuses[taskID]
62 sr.statuses[taskID] = status
105 for taskID, status := range sr.statuses {
106 delete(sr.statuses, taskID) // delete the entry, while trying to send.
109 err := sr.reporter.UpdateTaskStatus(ctx, taskID, status)
123 if _, ok := sr.statuses[taskID]; !ok {
[all …]
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/docker/swarmkit/agent/
H A Dreporter.go15 UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskStatus) error
18 type statusReporterFunc func(ctx context.Context, taskID string, status *api.TaskStatus) error
20 func (fn statusReporterFunc) UpdateTaskStatus(ctx context.Context, taskID string, status *api.TaskS…
21 return fn(ctx, taskID, status)
52 current, ok := sr.statuses[taskID]
62 sr.statuses[taskID] = status
105 for taskID, status := range sr.statuses {
106 delete(sr.statuses, taskID) // delete the entry, while trying to send.
109 err := sr.reporter.UpdateTaskStatus(ctx, taskID, status)
123 if _, ok := sr.statuses[taskID]; !ok {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/client/allocrunner/taskrunner/
H A Ddriver_handle.go14 func NewDriverHandle(driver drivers.DriverPlugin, taskID string, task *structs.Task, net *drivers.D…
18 taskID: taskID,
29 taskID string member
33 return h.taskID
37 return h.driver.WaitTask(ctx, h.taskID)
45 return h.driver.StopTask(h.taskID, h.task.KillTimeout, h.task.KillSignal)
49 return h.driver.TaskStats(ctx, h.taskID, interval)
53 return h.driver.SignalTask(h.taskID, s)
59 res, err := h.driver.ExecTask(h.taskID, command, timeout)
74 return impl.ExecTaskStreamingRaw(ctx, h.taskID, command, tty, stream)
[all …]
/dports/sysutils/nomad/nomad-1.1.0/client/allocrunner/taskrunner/
H A Ddriver_handle.go14 func NewDriverHandle(driver drivers.DriverPlugin, taskID string, task *structs.Task, net *drivers.D…
18 taskID: taskID,
29 taskID string member
35 return h.taskID
39 return h.driver.WaitTask(ctx, h.taskID)
48 return h.driver.StopTask(h.taskID, h.killTimeout, h.killSignal)
52 return h.driver.TaskStats(ctx, h.taskID, interval)
56 return h.driver.SignalTask(h.taskID, s)
62 res, err := h.driver.ExecTask(h.taskID, command, timeout)
77 return impl.ExecTaskStreamingRaw(ctx, h.taskID, command, tty, stream)
[all …]
/dports/games/openjk/OpenJK-07675e2/codemp/game/
H A Dg_ICARUScb.h25 int Q3_PlaySound( int taskID, int entID, const char *name, const char *channel );
26 qboolean Q3_Set( int taskID, int entID, const char *type_name, const char *data );
27 void Q3_Lerp2Pos( int taskID, int entID, vec3_t origin, vec3_t angles, float duration );
28 void Q3_Lerp2Origin( int taskID, int entID, vec3_t origin, float duration );
29 void Q3_Lerp2Angles( int taskID, int entID, vec3_t angles, float duration );
31 void Q3_Lerp2Start( int entID, int taskID, float duration );
32 void Q3_Lerp2End( int entID, int taskID, float duration );
36 void Q3_Play( int taskID, int entID, const char *type, const char *name );
/dports/devel/hadoop/hadoop-1.2.1/src/test/system/java/org/apache/hadoop/mapred/
H A DTaskInfoImpl.java37 private TaskID taskID; field in TaskInfoImpl
46 taskID = new TaskID(); in TaskInfoImpl()
50 TaskID taskID, double progress, int runningAttempts, int killedAttempts, in TaskInfoImpl() argument
54 this.taskID = taskID; in TaskInfoImpl()
61 if (taskID.isMap()) { in TaskInfoImpl()
78 return taskID; in getTaskID()
98 taskID.readFields(in); in readFields()
104 if (taskID.isMap()) { in readFields()
111 if (taskID.isMap()) { in readFields()
130 taskID.write(out); in write()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/event/
H A DJobMapTaskRescheduledEvent.java27 private TaskId taskID; field in JobMapTaskRescheduledEvent
29 public JobMapTaskRescheduledEvent(TaskId taskID) { in JobMapTaskRescheduledEvent() argument
30 super(taskID.getJobId(), JobEventType.JOB_MAP_TASK_RESCHEDULED); in JobMapTaskRescheduledEvent()
31 this.taskID = taskID; in JobMapTaskRescheduledEvent()
35 return taskID; in getTaskID()

12345678910>>...45