- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for faso (0.16 sec)
-
src/bufio/scan.go
func ScanRunes(data []byte, atEOF bool) (advance int, token []byte, err error) { if atEOF && len(data) == 0 { return 0, nil, nil } // Fast path 1: ASCII. if data[0] < utf8.RuneSelf { return 1, data[0:1], nil } // Fast path 2: Correct UTF-8 decode without error. _, width := utf8.DecodeRune(data) if width > 1 { // It's a valid encoding. Width cannot be one for a correctly encoded
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Oct 23 09:06:30 GMT 2023 - 14.2K bytes - Viewed (0) -
internal/config/api/api.go
} cfg.ListQuorum = listQuorum replicationPriority := env.Get(EnvAPIReplicationPriority, kvs.GetWithDefault(apiReplicationPriority, DefaultKVS)) switch replicationPriority { case "slow", "fast", "auto": default: return cfg, fmt.Errorf("invalid value %v for replication_priority", replicationPriority) } cfg.ReplicationPriority = replicationPriority
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 01:08:07 GMT 2024 - 11.1K bytes - Viewed (1) -
cmd/bucket-replication.go
const ( // WorkerMaxLimit max number of workers per node for "fast" mode WorkerMaxLimit = 500 // WorkerMinLimit min number of workers per node for "slow" mode WorkerMinLimit = 50 // WorkerAutoDefault is default number of workers for "auto" mode WorkerAutoDefault = 100 // MRFWorkerMaxLimit max number of mrf workers per node for "fast" mode MRFWorkerMaxLimit = 8
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
src/bytes/bytes.go
n += wasSpace & ^isSpace wasSpace = isSpace } if setBits >= utf8.RuneSelf { // Some runes in the input slice are not ASCII. return FieldsFunc(s, unicode.IsSpace) } // ASCII fast path a := make([][]byte, n) na := 0 fieldStart := 0 i := 0 // Skip spaces in the front of the input. for i < len(s) && asciiSpace[s[i]] != 0 { i++ } fieldStart = i for i < len(s) {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Feb 19 19:51:15 GMT 2024 - 33.8K bytes - Viewed (0) -
src/archive/zip/zip_test.go
} last := &r.buf[len(r.buf)-1] return last.off + last.n } func (r *rleBuffer) Write(p []byte) (n int, err error) { var rp *repeatedByte if len(r.buf) > 0 { rp = &r.buf[len(r.buf)-1] // Fast path, if p is entirely the same byte repeated. if lastByte := rp.b; len(p) > 0 && p[0] == lastByte { if bytes.Count(p, []byte{lastByte}) == len(p) { rp.n += int64(len(p)) return len(p), nil } }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Mar 27 18:23:49 GMT 2024 - 19.5K bytes - Viewed (0) -
internal/http/dial_linux.go
// Enable TCP open // https://lwn.net/Articles/508865/ - 32k queue size. _ = syscall.SetsockoptInt(fd, syscall.SOL_TCP, unix.TCP_FASTOPEN, 32*1024) // Enable TCP fast connect // TCPFastOpenConnect sets the underlying socket to use // the TCP fast open connect. This feature is supported // since Linux 4.11. _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_FASTOPEN_CONNECT, 1)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 4.3K bytes - Viewed (3) -
internal/config/scanner/help.go
} // Help provides help for config values Help = config.HelpKVS{ config.HelpKV{ Key: Speed, Description: `customize scanner speed (default|slowest|slow|fast|fastest)` + defaultHelpPostfix(Speed), Optional: true, Type: "string", }, config.HelpKV{ Key: ExcessVersions,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 07:41:53 GMT 2024 - 1.6K bytes - Viewed (0) -
internal/config/scanner/scanner.go
return cfg, err } } } switch speed := env.Get(EnvSpeed, kvs.GetWithDefault(Speed, DefaultKVS)); speed { case "fastest": cfg.Delay, cfg.MaxWait, cfg.Cycle = 0, 0, time.Second case "fast": cfg.Delay, cfg.MaxWait, cfg.Cycle = 1, 100*time.Millisecond, time.Minute case "default": cfg.Delay, cfg.MaxWait, cfg.Cycle = 2, time.Second, time.Minute case "slow":
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/metacache-stream.go
if err == io.EOF { err = io.ErrUnexpectedEOF } r.err = err return r.current, err } // next will read one entry from the stream. // Generally not recommended for fast operation. func (r *metacacheReader) next() (metaCacheEntry, error) { r.checkInit() if r.err != nil { return metaCacheEntry{}, r.err } var m metaCacheEntry var err error if r.current.name != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
cmd/metacache-walk.go
} } send := func(entry metaCacheEntry) error { objReturned(entry.metadata) select { case <-ctx.Done(): return ctx.Err() case out <- entry: } return nil } // Fast exit track to check if we are listing an object with // a trailing slash, this will avoid to list the object content. if HasSuffix(opts.BaseDir, SlashSeparator) { metadata, err := s.readMetadata(ctx, pathJoin(volumeDir,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0)