- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for close1 (0.16 sec)
-
pilot/pkg/xds/delta.go
} func (s *DiscoveryServer) receiveDelta(con *Connection, identities []string) { defer func() { close(con.deltaReqChan) close(con.ErrorCh()) // Close the initialized channel, if its not already closed, to prevent blocking the stream select { case <-con.InitializedCh(): default: close(con.InitializedCh()) } }() firstRequest := true for { req, err := con.deltaStream.Recv()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/pkg/bootstrap/server_test.go
s := &Server{ fileWatcher: filewatcher.NewWatcher(), server: server.New(), istiodCertBundleWatcher: keycertbundle.NewWatcher(), } defer func() { close(stop) _ = s.fileWatcher.Close() }() certFile := filepath.Join(dir, "cert-file.yaml") keyFile := filepath.Join(dir, "key-file.yaml") caFile := filepath.Join(dir, "ca-file.yaml") // load key and cert files.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 23.1K bytes - Viewed (0) -
pilot/pkg/bootstrap/options.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
return nil }) } // Wait for the stop, and do cleanups func (s *Server) waitForShutdown(stop <-chan struct{}) { go func() { <-stop close(s.internalStop) _ = s.fileWatcher.Close() if s.cacertsWatcher != nil { _ = s.cacertsWatcher.Close() } // Stop gRPC services. If gRPC services fail to stop in the shutdown duration, // force stop them. This does not happen normally.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
} // A push should get a response s.Discovery.ConfigUpdate(&model.PushRequest{Full: true}) ads.ExpectResponse() // Close the connection ads.Cleanup() // Service is removed while connection is closed s.MemRegistry.RemoveService("adsupdate.example.com") s.Discovery.ConfigUpdate(&model.PushRequest{ Full: true,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
cmd/metrics-v2.go
for _, mf := range mfs { if err := enc.Encode(mf); err != nil { // client may disconnect for any reasons // we do not have to log this. return } } if closer, ok := enc.(expfmt.Closer); ok { closer.Close() } }) } func metricsBucketHandler() http.Handler { return metricsHTTPHandler(bucketCollector, "handler.MetricsBucket") }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0) -
cmd/object-handlers.go
Start: offset, End: -1, } opts.NoLock = true return getObjectNInfo(ctx, bucket, object, rs, r.Header, opts) }, actualSize, ) defer objectRSC.Close() s3Select, err := s3select.NewS3Select(r.Body) if err != nil { if serr, ok := err.(s3select.SelectError); ok { encodedErrorResponse := encodeResponse(APIErrorResponse{ Code: serr.ErrorCode(),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
w.Header()[xhttp.AmzDeleteMarker] = []string{strconv.FormatBool(gr.ObjInfo.DeleteMarker)} } } writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } defer gr.Close() srcInfo := gr.ObjInfo actualPartSize, err := srcInfo.GetActualSize() if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 38.8K bytes - Viewed (0) -
cmd/bucket-handlers.go
if err := dec.Decode(&m); err != nil { part.Close() apiErr := errorCodes.ToAPIErr(ErrMalformedPOSTRequest) apiErr.Description = fmt.Sprintf("%s (%v)", apiErr.Description, multipart.ErrMessageTooLarge) writeErrorResponse(ctx, w, apiErr, r.URL) return } fanOutEntries = append(fanOutEntries, m) } part.Close() continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0) -
cmd/iam.go
usersSysType UsersSysType rolesMap map[arn.ARN]string // Persistence layer for IAM subsystem store *IAMStoreSys // configLoaded will be closed and remain so after first load. configLoaded chan struct{} } // IAMUserType represents a user type inside MinIO server type IAMUserType int const ( unknownIAMUserType IAMUserType = iota - 1
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 71.9K bytes - Viewed (0)