- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 264 for handle1_ (0.27 sec)
-
cmd/generic-handlers.go
} h.ServeHTTP(w, r) }) } // criticalErrorHandler handles panics and fatal errors by // `panic(logger.ErrCritical)` as done by `logger.CriticalIf`. // // It should be always the first / highest HTTP handler. func setCriticalErrorHandler(h http.Handler) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { defer func() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 01:01:15 UTC 2024 - 20.4K bytes - Viewed (0) -
internal/grid/grid_test.go
handler2 := func(req *testRequest) (resp *testResponse, err *RemoteErr) { r := RemoteErr(req.String) return nil, &r } errFatal(h1.Register(local, handler1)) errFatal(h2.Register(local, handler2)) errFatal(h1.Register(remote, handler1)) errFatal(h2.Register(remote, handler2)) // local to remote connection
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
cmd/auth-handler.go
_, ok := supportedS3AuthTypes[aType] return ok } // setAuthMiddleware to validate authorization header for the incoming request. func setAuthMiddleware(h http.Handler) http.Handler { // handler for validating incoming authorization headers. return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 26K bytes - Viewed (0) -
cmd/handler-api.go
writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrTooManyRequests), r.URL) case <-r.Context().Done(): globalHTTPStats.addRequestsInQueue(-1) // When the client disconnects before getting the S3 handler // status code response, set the status code to 499 so this request // will be properly audited and traced. w.WriteHeader(499) } } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 12 08:13:12 UTC 2024 - 10.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/watch.go
} if isWatchListLatencyRecordingRequired { metrics.RecordWatchListLatency(req.Context(), s.Scope.Resource, s.metricsScope) } } } } // HandleWS serves a series of encoded events over a websocket connection. func (s *WatchServer) HandleWS(ws *websocket.Conn) { defer func() { if s.MemoryAllocator != nil { runtime.AllocatorPool.Put(s.MemoryAllocator) } }() defer ws.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 14 16:37:25 UTC 2023 - 11.4K bytes - Viewed (0) -
cmd/admin-handlers-users_test.go
} s.adm, err = madmin.New(s.endpoint, s.accessKey, s.secretKey, s.secure) if err != nil { c.Fatalf("error creating admin client: %v", err) } // Set transport, so that TLS is handled correctly. s.adm.SetCustomTransport(s.TestSuiteCommon.client.Transport) s.client, err = minio.New(s.endpoint, &minio.Options{ Creds: credentials.NewStaticV4(s.accessKey, s.secretKey, ""), Secure: s.secure,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 45.7K bytes - Viewed (0) -
pkg/kube/krt/collection.go
} events = append(events, e) } } } h.mu.Unlock() // Short circuit if we have nothing to do if len(events) == 0 { return } handlers := h.eventHandlers.Get() if h.log.DebugEnabled() { h.log.WithLabels("events", len(events), "handlers", len(handlers)).Debugf("calling handlers") } for _, handler := range handlers {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 19.4K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
Aditya Manthramurthy <******@****.***> 1716591923 -0700
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.2K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental_test.cc
float value = 0.0f; TF_Tensor* t = TFE_TensorHandleResolve(handle_1, status); ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); ASSERT_EQ(sizeof(float), TF_TensorByteSize(t)); memcpy(&value, TF_TensorData(t), sizeof(float)); TF_DeleteTensor(t); EXPECT_EQ(1.2f, value); TFE_DeleteTensorHandle(handle_1); TF_DeleteStatus(status);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Aug 03 03:14:26 UTC 2023 - 31.5K bytes - Viewed (0) -
cmd/object-lambda-handlers.go
Aditya Manthramurthy <******@****.***> 1716591923 -0700
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10.2K bytes - Viewed (0)