- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 68 for lastID (0.13 sec)
-
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt
import okio.BufferedSource import okio.ByteString.Companion.encodeUtf8 import okio.Options class ServerSentEventReader( private val source: BufferedSource, private val callback: Callback, ) { private var lastId: String? = null interface Callback { fun onEvent( id: String?, type: String?, data: String, ) fun onRetryChange(timeMs: Long) } /**
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.3K bytes - Viewed (0) -
src/cmd/compile/internal/types2/typeparam.go
// respective 64 bit atomic instructions are not available // on all platforms. var lastID atomic.Uint32 // nextID returns a value increasing monotonically by 1 with // each call, starting with 1. It may be called concurrently. func nextID() uint64 { return uint64(lastID.Add(1)) } // A TypeParam represents a type parameter type. type TypeParam struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 20:03:31 UTC 2024 - 4.9K bytes - Viewed (0) -
src/go/types/typeparam.go
// respective 64 bit atomic instructions are not available // on all platforms. var lastID atomic.Uint32 // nextID returns a value increasing monotonically by 1 with // each call, starting with 1. It may be called concurrently. func nextID() uint64 { return uint64(lastID.Add(1)) } // A TypeParam represents a type parameter type. type TypeParam struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 20:03:31 UTC 2024 - 5.1K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
} func TestCipherSuites(t *testing.T) { var lastID uint16 for _, c := range CipherSuites() { if lastID > c.ID { t.Errorf("CipherSuites are not ordered by ID: got %#04x after %#04x", c.ID, lastID) } else { lastID = c.ID } if c.Insecure { t.Errorf("%#04x: Insecure CipherSuite returned by CipherSuites()", c.ID) } } lastID = 0 for _, c := range InsecureCipherSuites() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
tests/migrate_test.go
t.Fatalf("find auto_increment_struct fail, err: %v", err) } ids := make([]int64, 0, len(rows)) for _, row := range rows { ids = append(ids, row.ID) } lastID := ids[len(ids)-1] if err := DB.Where("id IN (?)", ids).Delete(&AutoIncrementStruct{}).Error; err != nil { t.Fatalf("delete auto_increment_struct fail, err: %v", err) } newRow := &AutoIncrementStruct{}
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Mon Mar 18 11:24:16 UTC 2024 - 56.2K bytes - Viewed (0) -
src/internal/trace/gc.go
} handleSweep := func(r Range) bool { return flags&UtilSweep != 0 && isGCSweep(r) } // Iterate through the trace, tracking mutator utilization. var lastEv *Event for i := range events { ev := &events[i] lastEv = ev // Process the event. switch ev.Kind() { case EventSync: seenSync = true case EventMetric: m := ev.Metric() if m.Name != "/sched/gomaxprocs:threads" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 26K bytes - Viewed (0) -
src/sort/sort_test.go
} } // InOrder checks if a-equal elements were not reordered. func (d intPairs) inOrder() bool { lastA, lastB := -1, 0 for i := 0; i < len(d); i++ { if lastA != d[i].a { lastA = d[i].a lastB = d[i].b continue } if d[i].b <= lastB { return false } lastB = d[i].b } return true } func TestStability(t *testing.T) { n, m := 100000, 1000
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 19:41:04 UTC 2024 - 16.9K bytes - Viewed (0) -
src/internal/trace/batchcursor.go
for b.idx < len(batches) && len(batches[b.idx].data) == b.dataOff { b.idx++ b.dataOff = 0 b.lastTs = 0 } // Have we reached the end of the batches? if b.idx == len(batches) { return false, nil } // Initialize lastTs if it hasn't been yet. if b.lastTs == 0 { b.lastTs = freq.mul(batches[b.idx].time) } // Read an event out.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 4.1K bytes - Viewed (0) -
src/runtime/time_fake.go
var faketimeState struct { lock mutex // lastfaketime is the last faketime value written to fd 1 or 2. lastfaketime int64 // lastfd is the fd to which lastfaketime was written. // // Subsequent writes to the same fd may use the same // timestamp, but the timestamp must increase if the fd // changes. lastfd uintptr } //go:linkname nanotime //go:nosplit func nanotime() int64 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:15:13 UTC 2024 - 2.5K bytes - Viewed (0) -
cmd/kubeadm/app/phases/certs/certlist_test.go
t.Run(test.name, func(t *testing.T) { var lastCA *KubeadmCert for i, cert := range test.certs { if i > 0 && lastCA == nil { t.Fatalf("CA not present in list before certificate %q", cert.Name) } if cert.CAName == "" { lastCA = cert } else { if cert.CAName != lastCA.Name { t.Fatalf("expected CA name %q, got %q, for certificate %q", lastCA.Name, cert.CAName, cert.Name) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 16:01:49 UTC 2024 - 8.8K bytes - Viewed (0)