- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 44 for new_context (0.22 sec)
-
cmd/listen-notification-handlers.go
"github.com/minio/minio/internal/pubsub" "github.com/minio/mux" "github.com/minio/pkg/v2/policy" ) func (api objectAPIHandlers) ListenNotificationHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "ListenNotification") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r)) // Validate if bucket exists. objAPI := api.ObjectAPI() if objAPI == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/peer-rest-server.go
func (s *peerRESTServer) DownloadProfilingDataHandler(w http.ResponseWriter, r *http.Request) { if !s.IsValid(w, r) { s.writeErrorResponse(w, errors.New("Invalid request")) return } ctx := newContext(r, w, "DownloadProfiling") profileData, err := getProfileData() if err != nil { s.writeErrorResponse(w, err) return } peersLogIf(ctx, gob.NewEncoder(w).Encode(profileData)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/object-lambda-handlers.go
// response generated via the lambda functions. To use this API, you must have READ access // to the object. func (api objectAPIHandlers) GetObjectLambdaHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "GetObjectLambda") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r)) objectAPI := api.ObjectAPI() if objectAPI == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Sep 15 04:58:17 GMT 2023 - 10.2K bytes - Viewed (1) -
api/go1.18.txt
pkg go/constant, method (Kind) String() string pkg go/token, const TILDE = 88 pkg go/token, const TILDE Token pkg go/types, func Instantiate(*Context, Type, []Type, bool) (Type, error) pkg go/types, func NewContext() *Context pkg go/types, func NewSignature //deprecated pkg go/types, func NewSignatureType(*Var, []*TypeParam, []*TypeParam, *Tuple, *Tuple, bool) *Signature pkg go/types, func NewTerm(bool, Type) *Term
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Fri Feb 17 20:31:46 GMT 2023 - 13K bytes - Viewed (0) -
cmd/generic-handlers.go
r.URL.Host = remote.EndpointURL.Host // Make sure we remove any existing headers before // proxying the request to another node. for k := range w.Header() { w.Header().Del(k) } ctx := newContext(r, w, "SiteReplicationUploadForwarding") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r)) globalForwarder.ServeHTTP(w, r) return } h.ServeHTTP(w, r) })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/admin-router.go
handlerName := getHandlerName(f, "adminAPIHandlers") var handler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) { // Update request context with `logger.ReqInfo`. r = r.WithContext(newContext(r, w, handlerName)) defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r)) // Check if object layer is available, if not return error early. if !handlerFlags.Has(noObjLayerFlag) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
tensorflow/c/c_api_experimental_test.cc
EXPECT_EQ(id, 0); } class ShapeInferenceTest : public ::testing::Test { protected: ShapeInferenceTest() : status_(TF_NewStatus()), tfe_context_options_(TFE_NewContextOptions()) { tfe_context_ = TFE_NewContext(tfe_context_options_, status_); CHECK_EQ(TF_OK, TF_GetCode(status_)) << TF_Message(status_); } ~ShapeInferenceTest() override { TFE_DeleteContextOptions(tfe_context_options_);
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Tue Jan 17 22:27:52 GMT 2023 - 13.1K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/helper/ViewHelper.java
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 40.1K bytes - Viewed (2) -
tensorflow/c/eager/c_api.h
// been deleted (with TFE_DeleteTensorHandle). // // TODO(ashankar): Merge with TF_Session? typedef struct TFE_Context TFE_Context; TF_CAPI_EXPORT extern TFE_Context* TFE_NewContext( const TFE_ContextOptions* opts, TF_Status* status); TF_CAPI_EXPORT extern void TFE_DeleteContext(TFE_Context* ctx); TF_CAPI_EXPORT extern TF_DeviceList* TFE_ContextListDevices(TFE_Context* ctx,
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Apr 27 21:07:00 GMT 2023 - 22.8K bytes - Viewed (1) -
tensorflow/c/eager/c_api_test_util.cc
isolate_session_state); TFE_ContextOptionsSetAsync(opts, static_cast<unsigned char>(false)); TFE_ContextOptionsSetDevicePlacementPolicy(opts, TFE_DEVICE_PLACEMENT_SILENT); TFE_Context* ctx = TFE_NewContext(opts, status); EXPECT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status); TFE_ContextSetServerDefWithTimeout(ctx, 0, serialized_server_def.data(), serialized_server_def.size(),
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Feb 21 22:37:46 GMT 2024 - 23.5K bytes - Viewed (2)