- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 59 for errorCode (0.24 sec)
-
cmd/object-api-options.go
argumentName = strings.ToLower(xhttp.AmzPartNumberMarker) valid = false return } opts.ObjectAttributes = parseObjectAttributes(r.Header) if len(opts.ObjectAttributes) < 1 { apiErr = errorCodes.ToAPIErr(ErrInvalidAttributeName) argumentName = strings.ToLower(xhttp.AmzObjectAttributes) valid = false return } for tag := range opts.ObjectAttributes { switch tag { case xhttp.ETag:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 14.3K bytes - Viewed (0) -
tensorflow/cc/training/queue_runner_test.cc
} *queue_runner_def.mutable_close_op_name() = close_op; *queue_runner_def.mutable_cancel_op_name() = cancel_op; for (const auto& error_code : queue_closed_error_codes) { *queue_runner_def.mutable_queue_closed_exception_types()->Add() = error_code; } return queue_runner_def; } std::unique_ptr<Session> BuildSessionAndInitVariable( const GraphDef& graph_def) { SessionOptions options;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Sep 21 06:27:51 UTC 2019 - 14.7K bytes - Viewed (0) -
cmd/bucket-handlers_test.go
getDeleteErrorList := func(objects []ObjectToDelete) (deleteErrorList []DeleteError) { for _, obj := range objects { deleteErrorList = append(deleteErrorList, DeleteError{ Code: errorCodes[ErrAccessDenied].Code, Message: errorCodes[ErrAccessDenied].Description, Key: obj.ObjectName, }) } return deleteErrorList } objects := []ObjectToDelete{} objects = append(objects, ObjectToDelete{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 39.8K bytes - Viewed (0) -
tensorflow/c/eager/c_api_distributed_test.cc
return def.SerializeAsString(); } class FunctionErrorInjectionPass : public tensorflow::FunctionOptimizationPass { public: FunctionErrorInjectionPass(string error_node, string error_device) : error_node_(error_node), error_device_(error_device) {} tensorflow::Status Run(const std::string& function_name, const tensorflow::DeviceSet& device_set,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 15 09:49:45 UTC 2024 - 23.5K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental.cc
"Coordination service is not enabled."); return; } status->status = coord_agent->DeleteKeyValue(key); } void TFE_ReportErrorToCluster(TFE_Context* ctx, int error_code, const char* error_message, TF_Status* status) { tensorflow::ImmediateExecutionDistributedManager* dist_mgr = tensorflow::unwrap(ctx)->GetDistributedManager();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 11 23:52:39 UTC 2024 - 35.9K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
t.Fatal(err) } _, owner, s3Err := checkKeyValid(req, globalActiveCred.AccessKey) if s3Err != ErrNone { t.Fatalf("Unexpected failure with %v", errorCodes.ToAPIErr(s3Err)) } if !owner { t.Fatalf("Expected owner to be 'true', found %t", owner) } _, _, s3Err = checkKeyValid(req, "does-not-exist") if s3Err != ErrInvalidAccessKeyID {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 05 21:26:41 UTC 2024 - 14.3K bytes - Viewed (0) -
cmd/auth-handler.go
// header, for all requests where Date header is not // present we will reject such clients. defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r)) writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(errCode), r.URL) atomic.AddUint64(&globalHTTPStats.rejectedRequestsTime, 1) return } // Verify if the request date header is shifted by less than globalMaxSkewTime parameter in the past
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 26K bytes - Viewed (0) -
cmd/signature-v4-parser_test.go
// validating the credential fields. if testCase.expectedErrCode != actualErrCode { t.Fatalf("Test %d: Expected the APIErrCode to be %s, got %s", i+1, errorCodes[testCase.expectedErrCode].Code, errorCodes[actualErrCode].Code) } if actualErrCode == ErrNone { validateCredentialfields(t, i+1, testCase.expectedCredentials, actualCredential) } } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 27.4K bytes - Viewed (0) -
cmd/handler-api.go
case <-deadlineTimer.C: globalHTTPStats.addRequestsInQueue(-1) if contextCanceled(ctx) { w.WriteHeader(499) return } // Send a http timeout message writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrTooManyRequests), r.URL) case <-r.Context().Done(): globalHTTPStats.addRequestsInQueue(-1) // When the client disconnects before getting the S3 handler
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 12 08:13:12 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/admin-heal-ops.go
"(use force-start option to stop and start afresh). " + fmt.Sprintf("The heal was started by IP %s at %s, token is %s", h.clientAddress, h.startTime.Format(http.TimeFormat), h.clientToken) return nil, errorCodes.ToAPIErr(ErrHealAlreadyRunning), errMsg } } ahs.Lock() defer ahs.Unlock() // Check if new heal sequence to be started overlaps with any // existing, running sequence
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 18:04:41 UTC 2024 - 25.1K bytes - Viewed (0)