- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for qS (0.04 sec)
-
src/crypto/tls/quic.go
func (q *QUICConn) NextEvent() QUICEvent { qs := q.conn.quic if last := qs.nextEvent - 1; last >= 0 && len(qs.events[last].Data) > 0 { // Write over some of the previous event's data, // to catch callers erroniously retaining it. qs.events[last].Data[0] = 0 } if qs.nextEvent >= len(qs.events) && qs.waitingForDrain { qs.waitingForDrain = false <-qs.signalc <-qs.blockedc } if qs.nextEvent >= len(qs.events) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 15.1K bytes - Viewed (0) -
cmd/metrics-v3-replication.go
m.Set(replicationLastMinuteQueuedCount, float64(qt.Curr.Count)) qa := qs.ActiveWorkers m.Set(replicationAverageActiveWorkers, float64(qa.Avg)) m.Set(replicationCurrentActiveWorkers, float64(qa.Curr)) m.Set(replicationMaxActiveWorkers, float64(qa.Max)) if len(qs.XferStats) > 0 { tots := qs.XferStats[Total] m.Set(replicationAverageDataTransferRate, tots.Avg)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 07:41:18 UTC 2024 - 4.4K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
} var qs ReplicationQueueStats for _, bs := range bucketStats { qs.Nodes = append(qs.Nodes, bs.QueueStats.Nodes...) } qs.Uptime = UTCNow().Unix() - globalBootTime.Unix() var ps ProxyMetric for _, bs := range bucketStats { ps.add(bs.ProxyStats) } bs = BucketStats{ ReplicationStats: s, QueueStats: qs, ProxyStats: ps, }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.4K bytes - Viewed (0) -
src/cmd/vendor/github.com/ianlancetaylor/demangle/ast.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 105.8K bytes - Viewed (0) -
src/crypto/tls/testdata/Client-TLSv13-Ed25519
00000150 a1 73 68 fb 87 2c 9d d2 d3 cf d7 3a bb 36 7e 83 |.sh..,.....:.6~.| 00000160 c3 3f bc e2 61 d9 c2 8b 15 a2 cc bf 14 a0 69 f4 |.?..a.........i.| 00000170 22 02 a9 ff 5e 55 37 6e 61 86 71 73 94 2f 7e 50 |"...^U7na.qs./~P| 00000180 45 96 cf 23 dd 39 90 5d 57 04 a3 d0 9f 97 f8 56 |E..#.9.]W......V| 00000190 fa cf 7a a9 e6 57 1f cb 33 a0 82 7a 84 94 1f 6d |..z..W..3..z...m|
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:33:38 UTC 2024 - 5.2K bytes - Viewed (0) -
tests/query_test.go
t.Errorf("failed to create:%v", err) } var qs []QueryResetNullValue err = DB.Joins("Item1").Joins("Item2").Find(&qs).Error if err != nil { t.Errorf("failed to find:%v", err) } if len(qs) != 2 { t.Fatalf("find count not equal:%d", len(qs)) } AssertEqual(t, q1, qs[0]) AssertEqual(t, q2, qs[1]) } func TestQueryError(t *testing.T) { type P struct{}
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed May 08 04:07:58 UTC 2024 - 49.8K bytes - Viewed (0) -
cmd/metrics-v2.go
maxQueueCount.Value = qt.Max.Count } activeWorkersCount.Value = float64(qs.ActiveWorkers.Curr) avgActiveWorkersCount.Value = float64(qs.ActiveWorkers.Avg) maxActiveWorkersCount.Value = float64(qs.ActiveWorkers.Max) if len(qs.XferStats) > 0 { tots := qs.XferStats[Total] currTransferRate.Value = tots.Curr avgTransferRate.Value = tots.Avg
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0) -
src/net/http/request_test.go
} if bz := req.PostFormValue("z"); bz != "post" { t.Errorf(`req.PostFormValue("z") = %q, want "post"`, bz) } if qs := req.Form["q"]; !reflect.DeepEqual(qs, []string{"foo", "bar"}) { t.Errorf(`req.Form["q"] = %q, want ["foo", "bar"]`, qs) } if both := req.Form["both"]; !reflect.DeepEqual(both, []string{"y", "x"}) { t.Errorf(`req.Form["both"] = %q, want ["y", "x"]`, both) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 18:42:34 UTC 2024 - 44K bytes - Viewed (0) -
src/vendor/golang.org/x/net/dns/dnsmessage/message.go
// be at most one question here. // // Do not pre-allocate based on info in p.header, since // the data is untrusted. qs := []Question{} for { q, err := p.Question() if err == ErrSectionDone { return qs, nil } if err != nil { return nil, err } qs = append(qs, q) } } // SkipQuestion skips a single Question. func (p *Parser) SkipQuestion() error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Mar 09 00:09:40 UTC 2024 - 69K bytes - Viewed (0) -
src/net/mail/message.go
} phrase = strings.Join(words, " ") return phrase, nil } // consumeQuotedString parses the quoted string at the start of p. func (p *addrParser) consumeQuotedString() (qs string, err error) { // Assume first byte is '"'. i := 1 qsb := make([]rune, 0, 10) escaped := false Loop: for { r, size := utf8.DecodeRuneInString(p.s[i:]) switch {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 19 11:31:03 UTC 2024 - 23.5K bytes - Viewed (0)