- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 137 for Closed (0.21 sec)
-
internal/grid/README.md
out <- []byte("response") // Return the request for reuse grid.PutByteBuffer(req) } } // out is closed by the caller and should never be closed by the handler. return nil } err := manager.RegisterStreamingHandler(grid.HandlerDiskInfo, StreamHandler{ Handle: handler, Subroute: "asubroute",
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/tier-journal.go
if err != nil { // Do not leak fd here, close the file properly. Fdatasync(jd.file) _ = jd.file.Close() jd.file = nil // reset to allow subsequent reopen when file/disk is available. } return err } // Close closes the active journal and renames it to read-only for pending // deletes processing. Note: calling Close on a closed journal is a no-op. func (jd *tierDiskJournal) Close() error {
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/untar.go
// the upstream reader after close has been called. type disconnectReader struct { r io.Reader mu sync.Mutex } func (d *disconnectReader) Read(p []byte) (n int, err error) { d.mu.Lock() defer d.mu.Unlock() if d.r != nil { return d.r.Read(p) } return 0, errors.New("reader closed") } func (d *disconnectReader) Close() error { d.mu.Lock() d.r = 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) -
internal/http/server.go
} srv.listenerMutex.Unlock() if atomic.AddUint32(&srv.inShutdown, 1) > 1 { // shutdown in progress return http.ErrServerClosed } // Close underneath HTTP listener. srv.listenerMutex.Lock() err := srv.listener.Close() srv.listenerMutex.Unlock() if err != nil { return err } pollIntervalBase := time.Millisecond nextPollInterval := func() time.Duration {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
internal/grid/muxclient.go
} } // send the message. msg.Seq and msg.MuxID will be set func (m *muxClient) send(msg message) error { m.respMu.Lock() defer m.respMu.Unlock() if m.closed { return errors.New("mux client closed") } return m.sendLocked(msg) } // sendLocked the message. msg.Seq and msg.MuxID will be set. // m.respMu must be held. func (m *muxClient) sendLocked(msg message) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/rest/client.go
return } // ErrClientClosed returned when *Client is closed. var ErrClientClosed = errors.New("rest client is closed") // Call - make a REST call with context. func (c *Client) Call(ctx context.Context, method string, values url.Values, body io.Reader, length int64) (reply io.ReadCloser, err error) { switch atomic.LoadInt32(&c.connected) { case closed: // client closed, this is usually a manual process
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
internal/grid/stream.go
// the appropriate error will be returned. type Stream struct { // responses from the remote server. // Channel will be closed after error or when remote closes. // All responses *must* be read by the caller until either an error is returned or the channel is closed. // Canceling the context will cause the context cancellation error to be returned. responses <-chan Response cancel context.CancelCauseFunc
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/http/listener.go
} case <-listener.ctx.Done(): } return nil, syscall.EINVAL } // Close - closes underneath all TCP listeners. func (listener *httpListener) Close() (err error) { listener.ctxCanceler() for i := range listener.listeners { listener.listeners[i].Close() } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/storage-rest-client.go
if err != nil { return err } defer xhttp.DrainBody(respBody) _, err = waitForHTTPResponse(respBody) return toStorageErr(err) } // Close - marks the client as closed. func (client *storageRESTClient) Close() error { client.restClient.Close() return nil } var emptyDiskID = "" // Returns a storage rest client.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/grid.go
"github.com/minio/minio/internal/rest" ) // globalGrid is the global grid manager. var globalGrid atomic.Pointer[grid.Manager] // globalGridStart is a channel that will block startup of grid connections until closed. var globalGridStart = make(chan struct{}) func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error { hosts, local := eps.GridHosts() g, err := grid.NewManager(ctx, grid.ManagerOptions{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 2K bytes - Viewed (0)