- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for reportStatus (0.26 sec)
-
platforms/core-runtime/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/ReportStatus.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 830 bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/api/HandleReportStatus.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.launcher.daemon.server.api; import org.gradle.launcher.daemon.protocol.ReportStatus; import org.gradle.launcher.daemon.protocol.Status; import org.gradle.launcher.daemon.protocol.Success; import org.gradle.util.GradleVersion; import java.util.Locale;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 1.5K bytes - Viewed (0) -
tensorflow/cc/training/coordinator.cc
} } { mutex_lock l(runners_lock_); for (const auto& t : runners_) { ReportStatus(t->Join()); } runners_.clear(); } return GetStatus(); } void Coordinator::ReportStatus(const Status& status) { mutex_lock l(status_lock_); if (status.ok() || !status_.ok() || clean_stop_errors_.count(static_cast<int>(status.code())) > 0) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 3.2K bytes - Viewed (0) -
operator/pkg/verifier/verifier.go
generatedCrds, generatedDeployments, generatedDaemonSets, err := v.verifyPostInstall( visitor, fmt.Sprintf("generated from %s", "default")) if err != nil { return err } return v.reportStatus(generatedCrds, generatedDeployments, generatedDaemonSets, nil) } func (v *StatusVerifier) getRevision() (string, error) { var revision string var revs string revCount := 0
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 19:23:44 UTC 2024 - 15K bytes - Viewed (0) -
tensorflow/cc/training/queue_runner.cc
{ mutex_lock l(mu_); if (!status_.ok() || status.ok() || IsQueueClosed(status)) { return; } status_ = status; } if (coord_) { coord_->ReportStatus(status); } mutex_lock l(cb_mu_); for (auto& cb : callbacks_) { cb(status); } } void QueueRunner::Run(Session* sess, const string& enqueue_op) { bool first_iteration = true;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 7K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion.go
) { route := obj.Spec.(*k8s.HTTPRouteSpec) parentRefs := extractParentReferenceInfo(ctx.GatewayReferences, route.ParentRefs, route.Hostnames, gvk.HTTPRoute, obj.Namespace) reportStatus := func(results []RouteParentResult) { obj.Status.(*kstatus.WrappedStatus).Mutate(func(s config.Status) config.Status { rs := s.(*k8s.HTTPRouteStatus) rs.Parents = createRouteStatus(results, obj, rs.Parents)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 84.7K bytes - Viewed (0) -
platforms/core-runtime/daemon-protocol/src/test/groovy/org/gradle/launcher/daemon/protocol/DaemonMessageSerializerTest.groovy
message | _ new Stop(UUID.randomUUID(), [1, 2, 3] as byte[]) | _ new StopWhenIdle(UUID.randomUUID(), [1, 2, 3] as byte[]) | _ new ReportStatus(UUID.randomUUID(), [1, 2, 3] as byte[]) | _ } OutputEvent serialize(OutputEvent event, Serializer<Object> serializer) { def result = serialize(new OutputMessage(event), serializer)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 12.3K bytes - Viewed (0) -
testing/architecture-test/src/changes/archunit-store/internal-api-nullability.txt
Class <org.gradle.launcher.daemon.protocol.ReportStatus> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (ReportStatus.java:0) Class <org.gradle.launcher.daemon.protocol.Result> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (Result.java:0)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 967.9K bytes - Viewed (0)