/dports/math/gap/gap-4.11.0/hpcgap/demo/ |
H A D | testparkit.g | 23 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 D | parkit.g | 63 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 D | MinimalJobshopSat.cs | 29 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 D | MinimalJobshopSat.java | 89 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 D | tasks.go | 55 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 D | tasks.go | 55 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 D | fdbrpc.h | 50 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 D | Q3_Interface.cpp | 117 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 D | reporter.go | 15 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 D | reporter.go | 15 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 D | reporter.go | 15 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 D | reporter.go | 15 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 D | reporter.go | 15 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 D | reporter.go | 15 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 D | reporter.go | 15 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 D | reporter.go | 15 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 D | reporter.go | 15 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 D | reporter.go | 15 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 D | reporter.go | 15 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 D | reporter.go | 15 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 D | driver_handle.go | 14 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 D | driver_handle.go | 14 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 D | g_ICARUScb.h | 25 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 D | TaskInfoImpl.java | 37 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 D | JobMapTaskRescheduledEvent.java | 27 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()
|