- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for getStatus (0.23 sec)
-
src/main/java/jcifs/smb/SmbFile.java
// make sure that the handle is closed when one of the requests fails Smb2CreateResponse createResp = cr.getResponse(); if ( createResp.isReceived() && createResp.getStatus() == NtStatus.NT_STATUS_OK ) { th.send(new Smb2CloseRequest(th.getConfig(), createResp.getFileId()), RequestParam.NO_RETRY); } } catch ( Exception e2 ) {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Thu May 23 01:50:13 UTC 2024 - 82.3K bytes - Viewed (1) -
subprojects/core-api/src/main/java/org/gradle/api/Project.java
* * @return The status of this project. Never returns null. */ Object getStatus(); /** * Sets the status of this project. * * @param status The status. Must not be null. */ void setStatus(Object status); /** * <p>Returns the direct children of this project.</p> *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 04:56:22 UTC 2024 - 74.3K bytes - Viewed (0) -
pkg/workloadapi/workload.pb.go
return x.Services } return nil } func (x *Workload) GetAuthorizationPolicies() []string { if x != nil { return x.AuthorizationPolicies } return nil } func (x *Workload) GetStatus() WorkloadStatus { if x != nil { return x.Status } return WorkloadStatus_HEALTHY } func (x *Workload) GetClusterId() string { if x != nil { return x.ClusterId } return "" }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 65.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit_test.go
if !preFilterStatus.IsSuccess() { t.Errorf("prefilter failed with status: %v", preFilterStatus) } gotStatus := p.(framework.FilterPlugin).Filter(ctx, cycleState, test.pod, test.nodeInfo) if !reflect.DeepEqual(gotStatus, test.wantStatus) { t.Errorf("status does not match: %v, want: %v", gotStatus, test.wantStatus) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 57.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/filtering_test.go
cycleState := framework.NewCycleState() gotStatus := p.(framework.FilterPlugin).Filter(context.Background(), cycleState, pod, nodeInfo) wantStatus := framework.AsStatus(fmt.Errorf(`error reading "PreFilterInterPodAffinity" from cycleState: %w`, framework.ErrNotFound)) if !reflect.DeepEqual(gotStatus, wantStatus) { t.Errorf("status does not match: %v, want: %v", gotStatus, wantStatus) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 01 10:24:54 UTC 2023 - 58.2K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
a.setStatus(hpa, currentReplicas, hpa.Status.DesiredReplicas, metricStatuses, false) } // setStatus recreates the status of the given HPA, updating the current and // desired replicas, as well as the metric statuses
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go
} gotResult, gotStatus := p.PostFilter(ctx, state, tt.pod, tt.filteredNodesStatuses) // As we cannot compare two errors directly due to miss the equal method for how to compare two errors, so just need to compare the reasons. if gotStatus.Code() == framework.Error { if diff := cmp.Diff(tt.wantStatus.Reasons(), gotStatus.Reasons()); diff != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
pod := getTestPod() pod.Status = tc.status syncer.TerminatePod(pod) gotStatus := expectPodStatus(t, syncer, pod.DeepCopy()) if diff := cmp.Diff(tc.wantStatus, gotStatus, cmpopts.IgnoreFields(v1.PodStatus{}, "StartTime")); diff != "" { t.Fatalf("unexpected status: %s", diff) } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
tensorflow/c/eager/c_api_test.cc
public: explicit TestUnavailableErrorOp(tensorflow::OpKernelConstruction* ctx) : tensorflow::OpKernel(ctx) {} void Compute(tensorflow::OpKernelContext* ctx) override { ctx->SetStatus(tensorflow::errors::Unavailable("Test error.")); } }; REGISTER_KERNEL_BUILDER( Name("TestNonCommUnavailable").Device(tensorflow::DEVICE_DEFAULT), TestUnavailableErrorOp); REGISTER_KERNEL_BUILDER(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Aug 03 20:50:20 UTC 2023 - 94.6K bytes - Viewed (0)