- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 200 for Closed (0.16 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) -
internal/lock/lock.go
r.mutex.Lock() r.refs++ r.mutex.Unlock() } // Close - this closer implements a special closer // closes the underlying fd only when the refs // reach zero. func (r *RLockedFile) Close() (err error) { r.mutex.Lock() defer r.mutex.Unlock() if r.refs == 0 { return os.ErrInvalid } r.refs-- if r.refs == 0 { err = r.File.Close() } return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.5K 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/s3select/select.go
} } return rsc.reader.Read(p) } // Close call to implement io.Closer. Calling Read/Seek after Close reopens the // object for reading and a subsequent Close call is required to ensure // resources are freed. func (rsc *ObjectReadSeekCloser) Close() error { rsc.closerOnce.Do(func() { if rsc.reader != nil { rsc.closerErr = rsc.reader.Close() rsc.reader = nil } }) return rsc.closerErr
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
internal/s3select/message.go
// Flush collected records before sending error message if !writer.flushRecords() { break } writer.write(data) case payload, ok := <-writer.payloadCh: if !ok { // payloadCh is closed by caller to // indicate finish with success quitFlag = true if !writer.flushRecords() { break } // Write Stats message, then End message
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} func (p *xlStorageDiskIDCheck) GetDiskLoc() (poolIdx, setIdx, diskIdx int) { return p.storage.GetDiskLoc() } func (p *xlStorageDiskIDCheck) Close() error { p.diskCancel() return p.storage.Close() } func (p *xlStorageDiskIDCheck) GetDiskID() (string, error) { return p.storage.GetDiskID() } func (p *xlStorageDiskIDCheck) SetDiskID(id string) { p.diskID.Store(&id)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
.github/stale.yml
# Number of days of inactivity before an Issue or Pull Request becomes stale daysUntilStale: 30 # Number of days of inactivity before an Issue or Pull Request with the stale label is closed. # Set to false to disable. If disabled, issues still need to be closed manually, but will remain marked as stale. daysUntilClose: 15 # Only issues or pull requests with all of these labels are check if stale. Defaults to `[]` (disabled) onlyLabels: []
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 24 04:36:59 GMT 2022 - 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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/erasure-object.go
if err != nil { if errors.Is(err, errFileNotFound) { // An in-quorum errFileNotFound means that client stream // prematurely closed and we do not find any xl.meta or // part.1's - in such a scenario we must return as if client // disconnected. This means that erasure.Encode() CreateFile() // did not do anything.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2)