Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for reportStatus (0.26 sec)

  1. platforms/core-runtime/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/ReportStatus.java

     * limitations under the License.
     */
    
    package org.gradle.launcher.daemon.protocol;
    
    import java.util.UUID;
    
    public class ReportStatus extends Command {
        public ReportStatus(UUID identifier, byte[] token) {
            super(identifier, token);
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 09 04:50:46 UTC 2024
    - 830 bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
Back to top