- Sort Score
- Result 10 results
- Languages All
Results 291 - 300 of 2,574 for retorno (0.07 sec)
-
internal/s3select/jstream/scanner.go
case io.EOF: // reader is exhausted return case nil: // no data and no error, retry fill goto scan default: // unexpected reader error sr.readerErr = err return } } rpos += int64(n) sr.fillReady <- int64(n) } }() sr.fillReq <- struct{}{} // initial fill return sr } // remaining returns the number of unread bytes
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 2.5K bytes - Viewed (0) -
docs/debugging/inspect/export.go
func (x xlMetaInlineData) versionOK() bool { if len(x) == 0 { return true } return x[0] > 0 && x[0] <= xlMetaInlineDataVer } func (x xlMetaInlineData) json() ([]byte, error) { if len(x) == 0 { return []byte("{}"), nil } if !x.versionOK() { return nil, errors.New("xlMetaInlineData: unknown version") } sz, buf, e := msgp.ReadMapHeaderBytes(x.afterVersion())
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Nov 08 15:58:02 UTC 2022 - 9.1K bytes - Viewed (0) -
cmd/site-replication-utils_gen.go
return } err = en.WriteInt(z.Version) if err != nil { err = msgp.WrapError(err, "Version") return } // write "ss" err = en.Append(0xa2, 0x73, 0x73) if err != nil { return } err = z.Status.EncodeMsg(en) if err != nil { err = msgp.WrapError(err, "Status") return } // write "did" err = en.Append(0xa3, 0x64, 0x69, 0x64) if err != nil { return }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Nov 14 15:16:40 UTC 2022 - 7.2K bytes - Viewed (0) -
cmd/erasure-server-pool.go
if err != nil { return err } } } } } if found == 0 { return errFileNotFound } return nil } // Return the disks belonging to the poolIdx, and setIdx. func (z *erasureServerPools) GetDisks(poolIdx, setIdx int) ([]StorageAPI, error) { if poolIdx < len(z.serverPools) && setIdx < len(z.serverPools[poolIdx].sets) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 89.8K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
defer cancel() for { select { case <-retryCtx.Done(): // Caller context canceled or we timedout, // return false anyways for both situations. return false default: if lm.lock(id, source, isWriteLock) { return true } time.Sleep(time.Duration(r.Float64() * float64(lockRetryInterval))) } } } // Unlock unlocks the write lock. //
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 4.8K bytes - Viewed (0) -
internal/store/batch.go
defer b.Unlock() if b.isFull() { if b.store == nil { return ErrBatchFull } // commit batch to store if err := b.commit(); err != nil { return err } } b.items = append(b.items, item) return nil } // Len returns the no of items in the batch func (b *Batch[_]) Len() int { b.Lock() defer b.Unlock() return len(b.items) } func (b *Batch[_]) isFull() bool {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 2.9K bytes - Viewed (0) -
cmd/config-dir.go
} func getDefaultConfigDir() string { homeDir, err := homedir.Dir() if err != nil { return "" } return filepath.Join(homeDir, defaultMinioConfigDir) } func getDefaultCertsDir() string { return filepath.Join(getDefaultConfigDir(), certsDir) } func getDefaultCertsCADir() string { return filepath.Join(getDefaultCertsDir(), certsCADir) } var ( // Default config, certs and CA directories.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 3K bytes - Viewed (0) -
internal/lock/lock_solaris.go
f.Close() if err == syscall.EAGAIN { err = ErrAlreadyLocked } return nil, err } st, err := os.Stat(path) if err != nil { f.Close() return nil, err } if st.IsDir() { f.Close() return nil, &os.PathError{ Op: "open", Path: path, Err: syscall.EISDIR, } } return &LockedFile{f}, nil } // TryLockedOpenFile - tries a new write lock, functionality
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 2.8K bytes - Viewed (0) -
internal/s3select/sql/jsonpath.go
if kv.Key == key { return jsonpathEval(p[1:], kv.Value) } } // Key not found - return nil result return Missing{}, false, nil case simdjson.Object: elem := kvs.FindKey(key, nil) if elem == nil { // Key not found - return nil result return Missing{}, false, nil } val, err := IterToValue(elem.Iter) if err != nil { return nil, false, err }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 3.5K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
Err: err, }), r.URL) return } data, err := json.Marshal(rinfo) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } // Write success response. writeSuccessResponseJSON(w, data) } // ResetBucketReplicationStatusHandler - returns the status of replication reset. // This API is a MinIO only extension
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 23.3K bytes - Viewed (0)