| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks/tests/ |
| H A D | UnwrapTests.cs | 122 [InlineData(TaskStatus.Faulted)]
123 [InlineData(TaskStatus.Canceled)]
138 case TaskStatus.Faulted: in NonGeneric_Completed_NotCompleted()
141 case TaskStatus.Canceled: in NonGeneric_Completed_NotCompleted()
155 [InlineData(TaskStatus.Faulted)]
156 [InlineData(TaskStatus.Canceled)]
171 case TaskStatus.Faulted: in Generic_Completed_NotCompleted()
174 case TaskStatus.Canceled: in Generic_Completed_NotCompleted()
216 case TaskStatus.Faulted: in NonGeneric_NotCompleted_NotCompleted()
267 case TaskStatus.Faulted: in Generic_NotCompleted_NotCompleted()
[all …]
|
| /dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/aws-cpp-sdk-datasync/source/model/ |
| H A D | TaskStatus.cpp | 35 return TaskStatus::AVAILABLE; in GetTaskStatusForName()
39 return TaskStatus::CREATING; in GetTaskStatusForName()
43 return TaskStatus::QUEUED; in GetTaskStatusForName()
47 return TaskStatus::RUNNING; in GetTaskStatusForName()
51 return TaskStatus::UNAVAILABLE; in GetTaskStatusForName()
60 return TaskStatus::NOT_SET; in GetTaskStatusForName()
67 case TaskStatus::AVAILABLE: in GetNameForTaskStatus()
69 case TaskStatus::CREATING: in GetNameForTaskStatus()
71 case TaskStatus::QUEUED: in GetNameForTaskStatus()
73 case TaskStatus::RUNNING: in GetNameForTaskStatus()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks/tests/Task/ |
| H A D | TaskStatusTest.cs | 22 public TaskStatus? FinalTaskStatus;
23 public TaskStatus? FinalChildTaskStatus;
24 public TaskStatus? FinalPromiseStatus;
68 private TaskStatus? _finalTaskStatus;
69 private TaskStatus? _finalChildTaskStatus;
70 private TaskStatus? _finalPromiseStatus;
416 FinalTaskStatus = TaskStatus.Created, in TaskStatus0()
549 FinalTaskStatus = TaskStatus.Faulted, in TaskStatus11()
562 FinalTaskStatus = TaskStatus.Faulted, in TaskStatus12()
575 FinalTaskStatus = TaskStatus.Faulted, in TaskStatus13()
[all …]
|
| /dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/aws-cpp-sdk-polly/source/model/ |
| H A D | TaskStatus.cpp | 29 TaskStatus GetTaskStatusForName(const Aws::String& name) in GetTaskStatusForName()
34 return TaskStatus::scheduled; in GetTaskStatusForName()
38 return TaskStatus::inProgress; in GetTaskStatusForName()
42 return TaskStatus::completed; in GetTaskStatusForName()
46 return TaskStatus::failed; in GetTaskStatusForName()
52 return static_cast<TaskStatus>(hashCode); in GetTaskStatusForName()
55 return TaskStatus::NOT_SET; in GetTaskStatusForName()
62 case TaskStatus::scheduled: in GetNameForTaskStatus()
64 case TaskStatus::inProgress: in GetNameForTaskStatus()
66 case TaskStatus::completed: in GetNameForTaskStatus()
[all …]
|
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
| H A D | TaskInProgress.java | 35 import org.apache.hadoop.mapred.TaskStatus.State;
113 new TreeMap<TaskAttemptID,TaskStatus>();
216 for (TaskStatus t : taskStatuses.values()) { in isOnlyCommitPending()
225 TaskStatus t = taskStatuses.get(taskId); in isCommitPending()
456 TaskStatus ts = taskStatuses.get(taskid); in shouldClose()
621 if (oldState == TaskStatus.State.FAILED || in updateStatus()
622 oldState == TaskStatus.State.KILLED) { in updateStatus()
666 TaskStatus.State taskState = TaskStatus.State.FAILED; in incompleteSubTask()
695 taskState = TaskStatus.State.FAILED; in incompleteSubTask()
825 public TaskStatus[] getTaskStatuses() { in getTaskStatuses()
[all …]
|
| /dports/net-mgmt/semaphore/semaphore-2.6.8/web2/src/components/ |
| H A D | TaskStatus.vue | 11 const TaskStatus = Object.freeze({
27 case TaskStatus.WAITING:
29 case TaskStatus.RUNNING:
31 case TaskStatus.SUCCESS:
33 case TaskStatus.ERROR:
42 case TaskStatus.WAITING:
44 case TaskStatus.RUNNING:
46 case TaskStatus.SUCCESS:
48 case TaskStatus.ERROR:
57 case TaskStatus.WAITING:
[all …]
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/cli/cli-20.10.2/internal/test/builders/ |
| H A D | task.go | 27 Status: *TaskStatus(),
83 task.Status = *TaskStatus(statusBuilders...)
89 func TaskStatus(statusBuilders ...func(*swarm.TaskStatus)) *swarm.TaskStatus { argument
91 taskStatus := &swarm.TaskStatus{
104 func Timestamp(t time.Time) func(*swarm.TaskStatus) {
105 return func(taskStatus *swarm.TaskStatus) {
111 func StatusErr(err string) func(*swarm.TaskStatus) {
112 return func(taskStatus *swarm.TaskStatus) {
118 func TaskState(state swarm.TaskState) func(*swarm.TaskStatus) {
119 return func(taskStatus *swarm.TaskStatus) {
[all …]
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/cli/internal/test/builders/ |
| H A D | task.go | 27 Status: *TaskStatus(),
83 task.Status = *TaskStatus(statusBuilders...)
89 func TaskStatus(statusBuilders ...func(*swarm.TaskStatus)) *swarm.TaskStatus { argument
91 taskStatus := &swarm.TaskStatus{
104 func Timestamp(t time.Time) func(*swarm.TaskStatus) {
105 return func(taskStatus *swarm.TaskStatus) {
111 func StatusErr(err string) func(*swarm.TaskStatus) {
112 return func(taskStatus *swarm.TaskStatus) {
118 func TaskState(state swarm.TaskState) func(*swarm.TaskStatus) {
119 return func(taskStatus *swarm.TaskStatus) {
[all …]
|
| /dports/sysutils/docker/docker-ce-18.09.5/components/cli/internal/test/builders/ |
| H A D | task.go | 27 Status: *TaskStatus(),
83 task.Status = *TaskStatus(statusBuilders...)
89 func TaskStatus(statusBuilders ...func(*swarm.TaskStatus)) *swarm.TaskStatus { func
91 taskStatus := &swarm.TaskStatus{
104 func Timestamp(t time.Time) func(*swarm.TaskStatus) {
105 return func(taskStatus *swarm.TaskStatus) {
111 func StatusErr(err string) func(*swarm.TaskStatus) {
112 return func(taskStatus *swarm.TaskStatus) {
118 func TaskState(state swarm.TaskState) func(*swarm.TaskStatus) {
119 return func(taskStatus *swarm.TaskStatus) {
[all …]
|
| /dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/aws-cpp-sdk-datapipeline/source/model/ |
| H A D | TaskStatus.cpp | 28 TaskStatus GetTaskStatusForName(const Aws::String& name) in GetTaskStatusForName()
33 return TaskStatus::FINISHED; in GetTaskStatusForName()
37 return TaskStatus::FAILED; in GetTaskStatusForName()
41 return TaskStatus::FALSE; in GetTaskStatusForName()
47 return static_cast<TaskStatus>(hashCode); in GetTaskStatusForName()
50 return TaskStatus::NOT_SET; in GetTaskStatusForName()
53 Aws::String GetNameForTaskStatus(TaskStatus enumValue) in GetNameForTaskStatus()
57 case TaskStatus::FINISHED: in GetNameForTaskStatus()
59 case TaskStatus::FAILED: in GetNameForTaskStatus()
61 case TaskStatus::FALSE: in GetNameForTaskStatus()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/ |
| H A D | TestClusterStatus.java | 154 List<TaskStatus> taskStatuses) { in getTTStatus()
164 List<TaskStatus> list = new ArrayList<TaskStatus>(); in testClusterMetrics()
173 reduceSlotsPerTask, TaskStatus.State.RUNNING); in testClusterMetrics()
213 reduceSlotsPerTask, TaskStatus.State.RUNNING); in testClusterMetrics()
222 reduceSlotsPerTask, TaskStatus.State.SUCCEEDED); in testClusterMetrics()
241 int reduceSlotsPerTask, TaskStatus.State state) { in addReduceTaskAttemptToList()
242 TaskStatus ts = TaskStatus.createTaskStatus(false, in addReduceTaskAttemptToList()
246 TaskStatus.Phase.REDUCE, null); in addReduceTaskAttemptToList()
251 int mapSlotsPerTask, TaskStatus.State state) { in addMapTaskAttemptToList()
252 TaskStatus ts = TaskStatus.createTaskStatus(true, in addMapTaskAttemptToList()
[all …]
|
| /dports/irc/smuxi/smuxi-1.1/lib/SignalR/src/Microsoft.AspNet.SignalR.Core/ |
| H A D | TaskAsyncHelper.cs | 184 case TaskStatus.Faulted: in ContinueWithNotComplete()
185 case TaskStatus.Canceled: in ContinueWithNotComplete()
303 case TaskStatus.Faulted: in Then()
320 case TaskStatus.Faulted: in Then()
370 case TaskStatus.Faulted: in Then()
387 case TaskStatus.Faulted: in Then()
404 case TaskStatus.Faulted: in Then()
422 case TaskStatus.Faulted: in Then()
440 case TaskStatus.Faulted: in Then()
460 case TaskStatus.Faulted: in Then()
[all …]
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2/ |
| H A D | task.pb.go | 223 func (m *Task) GetStatus() *TaskStatus {
246 type TaskStatus struct { struct
278 func (m *TaskStatus) Reset() { *m = TaskStatus{} } argument
280 func (*TaskStatus) ProtoMessage() {} argument
281 func (*TaskStatus) Descriptor() ([]byte, []int) { argument
285 func (m *TaskStatus) XXX_Unmarshal(b []byte) error { argument
291 func (m *TaskStatus) XXX_Merge(src proto.Message) { argument
294 func (m *TaskStatus) XXX_Size() int { argument
297 func (m *TaskStatus) XXX_DiscardUnknown() { argument
303 func (m *TaskStatus) GetAttemptDispatchCount() int32 { argument
[all …]
|
| /dports/net/grpcui/grpcui-1.1.0/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2/ |
| H A D | task.pb.go | 217 func (m *Task) GetStatus() *TaskStatus {
240 type TaskStatus struct { struct
266 func (m *TaskStatus) Reset() { *m = TaskStatus{} } argument
268 func (*TaskStatus) ProtoMessage() {} argument
269 func (*TaskStatus) Descriptor() ([]byte, []int) { argument
273 func (m *TaskStatus) XXX_Unmarshal(b []byte) error { argument
279 func (m *TaskStatus) XXX_Merge(src proto.Message) { argument
282 func (m *TaskStatus) XXX_Size() int { argument
285 func (m *TaskStatus) XXX_DiscardUnknown() { argument
291 func (m *TaskStatus) GetAttemptDispatchCount() int32 { argument
[all …]
|
| /dports/security/lego/lego-4.5.3/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2/ |
| H A D | task.pb.go | 217 func (m *Task) GetStatus() *TaskStatus {
240 type TaskStatus struct { struct
266 func (m *TaskStatus) Reset() { *m = TaskStatus{} } argument
268 func (*TaskStatus) ProtoMessage() {} argument
269 func (*TaskStatus) Descriptor() ([]byte, []int) { argument
273 func (m *TaskStatus) XXX_Unmarshal(b []byte) error { argument
279 func (m *TaskStatus) XXX_Merge(src proto.Message) { argument
282 func (m *TaskStatus) XXX_Size() int { argument
285 func (m *TaskStatus) XXX_DiscardUnknown() { argument
291 func (m *TaskStatus) GetAttemptDispatchCount() int32 { argument
[all …]
|
| /dports/net/evans/evans-0.9.1/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2/ |
| H A D | task.pb.go | 217 func (m *Task) GetStatus() *TaskStatus {
240 type TaskStatus struct { struct
266 func (m *TaskStatus) Reset() { *m = TaskStatus{} } argument
268 func (*TaskStatus) ProtoMessage() {} argument
269 func (*TaskStatus) Descriptor() ([]byte, []int) { argument
273 func (m *TaskStatus) XXX_Unmarshal(b []byte) error { argument
279 func (m *TaskStatus) XXX_Merge(src proto.Message) { argument
282 func (m *TaskStatus) XXX_Size() int { argument
285 func (m *TaskStatus) XXX_DiscardUnknown() { argument
291 func (m *TaskStatus) GetAttemptDispatchCount() int32 { argument
[all …]
|
| /dports/www/pomerium/pomerium-0.8.3/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2/ |
| H A D | task.pb.go | 217 func (m *Task) GetStatus() *TaskStatus {
240 type TaskStatus struct { struct
266 func (m *TaskStatus) Reset() { *m = TaskStatus{} } argument
268 func (*TaskStatus) ProtoMessage() {} argument
269 func (*TaskStatus) Descriptor() ([]byte, []int) { argument
273 func (m *TaskStatus) XXX_Unmarshal(b []byte) error { argument
279 func (m *TaskStatus) XXX_Merge(src proto.Message) { argument
282 func (m *TaskStatus) XXX_Size() int { argument
285 func (m *TaskStatus) XXX_DiscardUnknown() { argument
291 func (m *TaskStatus) GetAttemptDispatchCount() int32 { argument
[all …]
|
| /dports/sysutils/go-wtf/wtf-0.21.0/vendor/google.golang.org/genproto/go-genproto-eb59cef1c072/googleapis/cloud/tasks/v2beta2/ |
| H A D | task.pb.go | 223 func (m *Task) GetStatus() *TaskStatus {
246 type TaskStatus struct { struct
278 func (m *TaskStatus) Reset() { *m = TaskStatus{} } argument
280 func (*TaskStatus) ProtoMessage() {} argument
281 func (*TaskStatus) Descriptor() ([]byte, []int) { argument
285 func (m *TaskStatus) XXX_Unmarshal(b []byte) error { argument
291 func (m *TaskStatus) XXX_Merge(src proto.Message) { argument
294 func (m *TaskStatus) XXX_Size() int { argument
297 func (m *TaskStatus) XXX_DiscardUnknown() { argument
303 func (m *TaskStatus) GetAttemptDispatchCount() int32 { argument
[all …]
|
| /dports/misc/concourse/concourse-6.7.2/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2/ |
| H A D | task.pb.go | 217 func (m *Task) GetStatus() *TaskStatus {
240 type TaskStatus struct { struct
266 func (m *TaskStatus) Reset() { *m = TaskStatus{} } argument
268 func (*TaskStatus) ProtoMessage() {} argument
269 func (*TaskStatus) Descriptor() ([]byte, []int) { argument
273 func (m *TaskStatus) XXX_Unmarshal(b []byte) error { argument
279 func (m *TaskStatus) XXX_Merge(src proto.Message) { argument
282 func (m *TaskStatus) XXX_Size() int { argument
285 func (m *TaskStatus) XXX_DiscardUnknown() { argument
291 func (m *TaskStatus) GetAttemptDispatchCount() int32 { argument
[all …]
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2/ |
| H A D | task.pb.go | 217 func (m *Task) GetStatus() *TaskStatus {
240 type TaskStatus struct { struct
266 func (m *TaskStatus) Reset() { *m = TaskStatus{} } argument
268 func (*TaskStatus) ProtoMessage() {} argument
269 func (*TaskStatus) Descriptor() ([]byte, []int) { argument
273 func (m *TaskStatus) XXX_Unmarshal(b []byte) error { argument
279 func (m *TaskStatus) XXX_Merge(src proto.Message) { argument
282 func (m *TaskStatus) XXX_Size() int { argument
285 func (m *TaskStatus) XXX_DiscardUnknown() { argument
291 func (m *TaskStatus) GetAttemptDispatchCount() int32 { argument
[all …]
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2/ |
| H A D | task.pb.go | 223 func (m *Task) GetStatus() *TaskStatus {
246 type TaskStatus struct { struct
278 func (m *TaskStatus) Reset() { *m = TaskStatus{} } argument
280 func (*TaskStatus) ProtoMessage() {} argument
281 func (*TaskStatus) Descriptor() ([]byte, []int) { argument
285 func (m *TaskStatus) XXX_Unmarshal(b []byte) error { argument
291 func (m *TaskStatus) XXX_Merge(src proto.Message) { argument
294 func (m *TaskStatus) XXX_Size() int { argument
297 func (m *TaskStatus) XXX_DiscardUnknown() { argument
303 func (m *TaskStatus) GetAttemptDispatchCount() int32 { argument
[all …]
|
| /dports/devel/mutagen/mutagen-0.11.8/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2/ |
| H A D | task.pb.go | 223 func (m *Task) GetStatus() *TaskStatus {
246 type TaskStatus struct { struct
278 func (m *TaskStatus) Reset() { *m = TaskStatus{} } argument
280 func (*TaskStatus) ProtoMessage() {} argument
281 func (*TaskStatus) Descriptor() ([]byte, []int) { argument
285 func (m *TaskStatus) XXX_Unmarshal(b []byte) error { argument
291 func (m *TaskStatus) XXX_Merge(src proto.Message) { argument
294 func (m *TaskStatus) XXX_Size() int { argument
297 func (m *TaskStatus) XXX_DiscardUnknown() { argument
303 func (m *TaskStatus) GetAttemptDispatchCount() int32 { argument
[all …]
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2/ |
| H A D | task.pb.go | 223 func (m *Task) GetStatus() *TaskStatus {
246 type TaskStatus struct { struct
278 func (m *TaskStatus) Reset() { *m = TaskStatus{} } argument
280 func (*TaskStatus) ProtoMessage() {} argument
281 func (*TaskStatus) Descriptor() ([]byte, []int) { argument
285 func (m *TaskStatus) XXX_Unmarshal(b []byte) error { argument
291 func (m *TaskStatus) XXX_Merge(src proto.Message) { argument
294 func (m *TaskStatus) XXX_Size() int { argument
297 func (m *TaskStatus) XXX_DiscardUnknown() { argument
303 func (m *TaskStatus) GetAttemptDispatchCount() int32 { argument
[all …]
|
| /dports/audio/murmur-cli/murmur-cli-8f83169/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2/ |
| H A D | task.pb.go | 223 func (m *Task) GetStatus() *TaskStatus {
246 type TaskStatus struct { struct
278 func (m *TaskStatus) Reset() { *m = TaskStatus{} } argument
280 func (*TaskStatus) ProtoMessage() {} argument
281 func (*TaskStatus) Descriptor() ([]byte, []int) { argument
285 func (m *TaskStatus) XXX_Unmarshal(b []byte) error { argument
291 func (m *TaskStatus) XXX_Merge(src proto.Message) { argument
294 func (m *TaskStatus) XXX_Size() int { argument
297 func (m *TaskStatus) XXX_DiscardUnknown() { argument
303 func (m *TaskStatus) GetAttemptDispatchCount() int32 { argument
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2/ |
| H A D | task.pb.go | 217 func (m *Task) GetStatus() *TaskStatus {
240 type TaskStatus struct { struct
266 func (m *TaskStatus) Reset() { *m = TaskStatus{} } argument
268 func (*TaskStatus) ProtoMessage() {} argument
269 func (*TaskStatus) Descriptor() ([]byte, []int) { argument
273 func (m *TaskStatus) XXX_Unmarshal(b []byte) error { argument
279 func (m *TaskStatus) XXX_Merge(src proto.Message) { argument
282 func (m *TaskStatus) XXX_Size() int { argument
285 func (m *TaskStatus) XXX_DiscardUnknown() { argument
291 func (m *TaskStatus) GetAttemptDispatchCount() int32 { argument
[all …]
|