- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 75 for StatusCode (0.15 sec)
-
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) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/oidc.go
req = req.WithContext(ctx) response, err := client.Do(req) if err != nil { return "", err } defer response.Body.Close() // Report non-OK status code as an error. if response.StatusCode < http.StatusOK || response.StatusCode > http.StatusIMUsed { return "", fmt.Errorf("error while getting distributed claim JWT: %v", response.Status) } responseBytes, err := ioutil.ReadAll(response.Body) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 19:29:33 UTC 2024 - 37.9K 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) -
src/cmd/vendor/github.com/google/pprof/internal/driver/fetch.go
client := &http.Client{ Transport: tr, Timeout: timeout + 5*time.Second, } resp, err := client.Get(source) if err != nil { return nil, fmt.Errorf("http fetch: %v", err) } if resp.StatusCode != http.StatusOK { defer resp.Body.Close() return nil, statusCodeError(resp) } return resp.Body, nil } 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 - 19K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental.cc
if (coord_agent == nullptr) { status->status = tensorflow::errors::FailedPrecondition( "Coordination service is not enabled."); return; } tensorflow::Status s(static_cast<absl::StatusCode>(error_code), error_message); status->status = coord_agent->ReportError(s); } void TFE_GetTaskStates(TFE_Context* ctx, const TF_Buffer& tasks, void* states,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 11 23:52:39 UTC 2024 - 35.9K bytes - Viewed (0)