- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 64 for NeXT (0.13 sec)
-
internal/dsync/dsync_test.go
mu := PaddedMutex{NewDRWMutex(ds, "")} for pb.Next() { mu.Lock(id, source) mu.Unlock(context.Background()) } }) } func benchmarkMutex(b *testing.B, slack, work bool) { b.ResetTimer() b.ReportAllocs() mu := NewDRWMutex(ds, "") if slack { b.SetParallelism(10) } b.RunParallel(func(pb *testing.PB) { foo := 0 for pb.Next() { mu.Lock(id, source)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
src/cmd/asm/internal/asm/parse.go
} tok = p.next() if tok.ScanToken == '+' { if p.next().ScanToken != scanner.Int { return "", obj.ABI0, false } tok = p.next() } if tok.ScanToken != '(' { return "", obj.ABI0, false } if reg := p.next(); reg.ScanToken != scanner.Ident || reg.String() != "SB" { return "", obj.ABI0, false } if p.next().ScanToken != ')' || p.peek() != scanner.EOF {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 14:34:57 GMT 2024 - 36.9K bytes - Viewed (0) -
scan.go
onConflictDonothing = mode&ScanOnConflictDoNothing != 0 ) db.RowsAffected = 0 switch dest := db.Statement.Dest.(type) { case map[string]interface{}, *map[string]interface{}: if initialized || rows.Next() { columnTypes, _ := rows.ColumnTypes() prepareValues(values, db, columnTypes, columns) db.RowsAffected++ db.AddError(rows.Scan(values...)) mapValue, ok := dest.(map[string]interface{})
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Apr 26 09:53:11 GMT 2024 - 9.8K bytes - Viewed (0) -
src/cmd/asm/internal/lex/input.go
return len(in.ifdefStack) == 0 || in.ifdefStack[len(in.ifdefStack)-1] } func (in *Input) expectNewline(directive string) { tok := in.Stack.Next() if tok != '\n' { in.expectText("expected newline after", directive) } } func (in *Input) Next() ScanToken { if in.peek { in.peek = false tok := in.peekToken in.text = in.peekText return tok }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Aug 29 07:48:38 GMT 2023 - 12.6K bytes - Viewed (0) -
src/bytes/example_test.go
var b bytes.Buffer b.Grow(64) b.Write([]byte("abcde")) fmt.Printf("%d", b.Len()) // Output: 5 } func ExampleBuffer_Next() { var b bytes.Buffer b.Grow(64) b.Write([]byte("abcde")) fmt.Printf("%s\n", b.Next(2)) fmt.Printf("%s\n", b.Next(2)) fmt.Printf("%s", b.Next(2)) // Output: // ab // cd // e } func ExampleBuffer_Read() { var b bytes.Buffer b.Grow(64)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Mar 04 15:54:40 GMT 2024 - 15K bytes - Viewed (1) -
cmd/object-api-datatypes.go
// A character used to truncate the object prefixes. // NOTE: only supported delimiter is '/'. Delimiter string // CommonPrefixes contains all (if there are any) keys between Prefix and the // next occurrence of the string specified by delimiter. CommonPrefixes []string EncodingType string // Not supported yet. } // TransitionedObject transitioned object tier and status.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
src/cmd/asm/internal/asm/asm.go
if !p.validSymbol("GLOBL", &nameAddr, false) { return } next := 1 // Next operand is the optional flag, a literal integer. var flag = int64(0) if len(operands) == 3 { flag = p.evalInteger("GLOBL", operands[1]) next++ } // Final operand is an immediate constant. addr := p.address(operands[next]) if !p.validImmediate("GLOBL", &addr) { return }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 14:34:57 GMT 2024 - 25.3K bytes - Viewed (0) -
internal/grid/benchmark_test.go
b.RunParallel(func(pb *testing.PB) { rng := rand.New(rand.NewSource(time.Now().UnixNano())) n := 0 var latency int64 managers := grid.Managers hosts := grid.Hosts for pb.Next() { // Pick a random manager. src, dst := rng.Intn(len(managers)), rng.Intn(len(managers)) if src == dst { dst = (dst + 1) % len(managers) } local := managers[src]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
internal/grid/connection.go
cancel(ErrDisconnected) return } var next []byte next, remain, err = msgp.ReadBytesZC(remain) if err != nil { gridLogIf(ctx, fmt.Errorf("ws read merged: %w", err)) cancel(ErrDisconnected) return } m.Payload = nil subID, _, err = m.parse(next) if err != nil { gridLogIf(ctx, fmt.Errorf("ws parse merged: %w", err))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/api-response.go
// request to get next set of objects. Server lists objects in alphabetical // order Note: This element is returned only if you have delimiter request parameter // specified. If response does not include the NextMaker and it is truncated, // you can use the value of the last Key in the response as the marker in the // subsequent request to get the next set of object keys.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 33.3K bytes - Viewed (2)