- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 45 for StatusCode (0.54 sec)
-
src/cmd/vendor/github.com/google/pprof/internal/symbolizer/symbolizer.go
} resp, err := client.Post(source, "application/octet-stream", strings.NewReader(post)) if err != nil { return nil, fmt.Errorf("http post %s: %v", source, err) } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { return nil, fmt.Errorf("http post %s: %v", source, statusCodeError(resp)) } return io.ReadAll(resp.Body) } func statusCodeError(resp *http.Response) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 10K bytes - Viewed (0) -
cmd/perf-tests.go
t := time.Now() r, _, _, err := c.GetObject(downloadsCtx, opts.bucketName, tmpObjName, gopts) if err != nil { errResp, ok := err.(minio.ErrorResponse) if ok && errResp.StatusCode == http.StatusNotFound { continue } if !contextCanceled(downloadsCtx) && !errors.Is(err, context.Canceled) { errOnce.Do(func() { retError = err.Error() }) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
} else { feasibleNodes[length-1] = nodeInfo } } else { result[i] = &nodeStatus{node: nodeInfo.Node().Name, status: status} } } beginCheckNode := time.Now() statusCode := framework.Success defer func() { // We record Filter extension point latency here instead of in framework.go because framework.RunFilterPlugins
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
internal/logger/target/http/http.go
if err != nil { return fmt.Errorf("%s returned '%w', please check your endpoint configuration", h.Endpoint(), err) } // Drain any response. xhttp.DrainBody(resp.Body) switch resp.StatusCode { case http.StatusOK, http.StatusCreated, http.StatusAccepted, http.StatusNoContent: // accepted HTTP status codes. return nil case http.StatusForbidden:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 14.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/common/attrs_and_constraints_test.cc
return %0 : tensor<2x2x2xf32> } } )mlir"; TEST_F(AttrsAndConstraintsTest, IsDotGeneralFullyConnectedReturnsError) { DotGeneralOp dot_general_op = nullptr; StatusIs(absl::StatusCode::kInvalidArgument, "Given dot_general op cannot be null when checking " "`IsDotGeneralBatchMatmul`"); } TEST_F(AttrsAndConstraintsTest, IsDotGeneralFullyConnectedReturnsTrue) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue May 14 17:10:32 UTC 2024 - 22.9K bytes - Viewed (0) -
cmd/kube-apiserver/app/testing/testserver.go
storageVersionCheck := fmt.Sprintf("poststarthook/%s", apiserver.StorageVersionPostStartHookName) req.Param("exclude", storageVersionCheck) } result := req.Do(context.TODO()) status := 0 result.StatusCode(&status) if status == 200 { return true, nil } return false, nil }) if err != nil { return result, fmt.Errorf("failed to wait for /healthz to return ok: %v", err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 17.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/common/lift_as_function_call.cc
} return quantization_method; } Method GetQuantizationMethodOrDefault(absl::Nonnull<Operation*> op) { absl::StatusOr<Method> method = GetQuantizationMethod(op); if (method.status().code() == absl::StatusCode::kInternal) { // This indicates that the `Method` protobuf string is corrupt, but this // function ignores it and returns the default instance. op->emitError(absl::StrCat("Failed to get quantization method: ",
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 17:58:54 UTC 2024 - 21.8K bytes - Viewed (0) -
pkg/kube/client.go
} resp, err := c.http.Do(req.WithContext(ctx)) if err != nil { return nil, formatError(err) } defer closeQuietly(resp.Body) if resp.StatusCode != http.StatusOK { return nil, fmt.Errorf("unexpected status code: %d", resp.StatusCode) } out, err := io.ReadAll(resp.Body) if err != nil { return nil, formatError(err) } return out, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
cmd/kubeadm/app/preflight/checks.go
} stopRetry, err = func() (stopRetry bool, err error) { r, err := client.Get(url) if err != nil { loopCount-- return false, err } defer r.Body.Close() if r.StatusCode >= 500 && r.StatusCode <= 599 { loopCount-- return false, errors.Errorf("server responded with non-successful status: %s", r.Status) } return true, json.NewDecoder(r.Body).Decode(target) }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:20:55 UTC 2024 - 39.5K bytes - Viewed (0) -
cmd/batch-expire.go
} clnt := http.Client{Transport: getRemoteInstanceTransport()} resp, err := clnt.Do(req) if err != nil { return err } xhttp.DrainBody(resp.Body) if resp.StatusCode != http.StatusOK { return errors.New(resp.Status) } return nil } // Expire expires object versions which have already matched supplied filter conditions
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 13:50:53 UTC 2024 - 21.1K bytes - Viewed (0)