- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 216 for getStatus (0.39 sec)
-
pkg/scheduler/framework/plugins/nodename/node_name_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 1.8K bytes - Viewed (0) -
samples/static-server/src/main/java/okhttp3/sample/SampleServer.java
} catch (FileNotFoundException e) { return new MockResponse() .setStatus("HTTP/1.1 404") .addHeader("content-type: text/plain; charset=utf-8") .setBody("NOT FOUND: " + path); } catch (IOException e) { return new MockResponse() .setStatus("HTTP/1.1 500") .addHeader("content-type: text/plain; charset=utf-8") .setBody("SERVER ERROR: " + e);
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Jan 02 02:50:44 UTC 2019 - 4.7K bytes - Viewed (0) -
tensorflow/cc/experimental/base/public/status.h
std::string message() const; // Returns the error message in Status. bool ok() const; // Record <code, msg> in Status. Any previous information is lost. // A common use is to clear a status: SetStatus(TF_OK, ""); void SetStatus(TF_Code code, const std::string& msg); // Status is movable, but not copyable. Status(Status&&) = default; Status& operator=(Status&&) = default; private: friend class RuntimeBuilder;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue May 12 19:37:48 UTC 2020 - 3.1K bytes - Viewed (0) -
cmd/speedtest.go
var throughputHighestResults []SpeedTestResult sendResult := func() { var result madmin.SpeedTestResult durationSecs := opts.duration.Seconds() result.GETStats.ThroughputPerSec = throughputHighestGet / uint64(durationSecs) result.GETStats.ObjectsPerSec = throughputHighestGet / uint64(opts.objectSize) / uint64(durationSecs) result.PUTStats.ThroughputPerSec = throughputHighestPut / uint64(durationSecs)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 09:45:10 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions_test.go
} // If PreFilter fails, then Filter will not run. if test.preFilterWantStatus.IsSuccess() { gotStatus := p.(framework.FilterPlugin).Filter(ctx, cycleState, test.pod, test.nodeInfo) if diff := cmp.Diff(test.wantStatus, gotStatus); diff != "" { t.Errorf("Unexpected Filter status (-want, +got): %s", diff) } } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 17:40:39 UTC 2023 - 17.3K bytes - Viewed (0) -
tools/bug-report/pkg/processlog/processlog.go
func Process(config *config.BugReportConfig, logStr string) (string, *Stats) { if !config.TimeFilterApplied { return logStr, getStats(config, logStr) } out := getTimeRange(logStr, config.StartTime, config.EndTime) return out, getStats(config, out) } // getTimeRange returns the log lines that fall inside the start to end time range, inclusive.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 19 21:44:33 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeports/node_ports_test.go
} cycleState := framework.NewCycleState() gotStatus := p.(framework.FilterPlugin).Filter(ctx, cycleState, pod, nodeInfo) wantStatus := framework.AsStatus(fmt.Errorf(`reading "PreFilterNodePorts" from cycleState: %w`, framework.ErrNotFound)) if !reflect.DeepEqual(gotStatus, wantStatus) { t.Errorf("status does not match: %v, want: %v", gotStatus, wantStatus) } } func TestGetContainerPorts(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 11:02:11 UTC 2023 - 10.1K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java
public void addExcludeFilter(final String regexp) { if (StringUtil.isNotBlank(regexp)) { urlFilter.addExclude(regexp); } } public void stop() { crawlerContext.setStatus(CrawlerStatus.DONE); try { if (crawlerThreadGroup != null) { crawlerThreadGroup.interrupt(); } } catch (final Exception e) { // ignore
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 7.9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/DaemonLogFileStateProbe.groovy
} DaemonContext getContext() { return context } State getCurrentState() { getStates().last() } List<State> getStates() { def states = new LinkedList<State>() states << Idle log.lines().withCloseable { stream -> stream.forEach {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 2.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeunschedulable/node_unschedulable_test.go
p, err := New(ctx, nil, nil) if err != nil { t.Fatalf("creating plugin: %v", err) } gotStatus := p.(framework.FilterPlugin).Filter(ctx, nil, test.pod, nodeInfo) if !reflect.DeepEqual(gotStatus, test.wantStatus) { t.Errorf("status does not match: %v, want: %v", gotStatus, test.wantStatus) } } } func TestIsSchedulableAfterNodeChange(t *testing.T) { testCases := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 12:50:11 UTC 2023 - 4.3K bytes - Viewed (0)