- Sort Score
- Num 10 results
- Language All
Results 501 - 510 of 1,305 for var0 (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
private val http2Connection: Http2Connection, ) : ExchangeCodec { @Volatile private var stream: Http2Stream? = null private val protocol: Protocol = if (Protocol.H2_PRIOR_KNOWLEDGE in client.protocols) { Protocol.H2_PRIOR_KNOWLEDGE } else { Protocol.HTTP_2 } @Volatile private var canceled = false override val isResponseComplete: BooleanCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jul 29 21:11:09 GMT 2025 - 7K bytes - Click Count (0) -
internal/config/lambda/parse.go
} } } return targetList, nil } // DefaultLambdaKVS - default notification list of kvs. var ( DefaultLambdaKVS = map[string]config.KVS{ config.LambdaWebhookSubSys: DefaultWebhookKVS, } ) // DefaultWebhookKVS - default KV for webhook config var ( DefaultWebhookKVS = config.KVS{ config.KV{ Key: config.Enable, Value: config.EnableOff, }, config.KV{
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6K bytes - Click Count (0) -
internal/http/response-recorder.go
n, _ := fmt.Fprintf(w, "%s: %s\n", k, v[0]) lrw.headerBytesWritten += n } } // blobBody returns a dummy body placeholder for blob (binary stream) var blobBody = []byte("<BLOB>") // gzippedBody returns a dummy body placeholder for gzipped content var gzippedBody = []byte("<GZIP>") // Body - Return response body. func (lrw *ResponseRecorder) Body() []byte { if lrw.Header().Get("Content-Encoding") == "gzip" {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 5.5K bytes - Click Count (0) -
internal/s3select/csv/reader_contrib_test.go
fieldDelimiter string }{ {"1,2,3\na,b,c\n", "\n", ","}, {"1,2,3\ta,b,c\t", "\t", ","}, {"1,2,3\r\na,b,c\r\n", "\r\n", ","}, } for i, c := range cases { var err error var record sql.Record var result bytes.Buffer r, _ := NewReader(io.NopCloser(strings.NewReader(c.content)), &ReaderArgs{ FileHeaderInfo: none, RecordDelimiter: c.recordDelimiter,Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 38.4K bytes - Click Count (0) -
tests/lru_test.go
func BenchmarkLRU_Rand_NoExpire(b *testing.B) { l := lru.NewLRU[int64, int64](8192, nil, 0) trace := make([]int64, b.N*2) for i := 0; i < b.N*2; i++ { trace[i] = getRand(b) % 32768 } b.ResetTimer() var hit, miss int for i := 0; i < 2*b.N; i++ { if i%2 == 0 { l.Add(trace[i], trace[i]) } else { if _, ok := l.Get(trace[i]); ok { hit++ } else { miss++ } } }
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Mon Sep 08 09:19:22 GMT 2025 - 10.4K bytes - Click Count (0) -
cmd/batch-handlers_gen.go
for zb0003 := range z { s += msgp.StringPrefixSize + len(z[zb0003]) } return } // DecodeMsg implements msgp.Decodable func (z *BatchJobRequest) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 20.4K bytes - Click Count (0) -
cmd/metacache-walk.go
w := newMetacacheWriter(wr, 16<<10) w.reuseBlocks = true // We are not sharing results, so reuse buffers. defer w.Close() out, err := w.stream() if err != nil { return err } defer xioutil.SafeClose(out) var objsReturned int objReturned := func(metadata []byte) { if opts.Limit <= 0 { return } if m, _, _ := isIndexedMetaV2(metadata); m != nil && !m.AllHidden(true) { objsReturned++ } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon May 26 07:06:43 GMT 2025 - 12.6K bytes - Click Count (0) -
cmd/mrf.go
healingLogEvent(context.Background(), "Saving MRF healing data (%d entries)", len(m.opCh)) } newReader := func() io.ReadCloser { r, w := io.Pipe() go func() { // Initialize MRF meta header. var data [4]byte binary.LittleEndian.PutUint16(data[0:2], healMRFMetaFormat) binary.LittleEndian.PutUint16(data[2:4], healMRFMetaVersionV1) mw := msgp.NewWriter(w) n, err := mw.Write(data[:]) if err != nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 6.5K bytes - Click Count (0) -
internal/config/callhome/callhome.go
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 2.6K bytes - Click Count (0) -
internal/config/identity/ldap/config.go
EnvLookupBindPassword = "MINIO_IDENTITY_LDAP_LOOKUP_BIND_PASSWORD" ) var removedKeys = []string{ "sts_expiry", "username_format", "username_search_filter", "username_search_base_dn", "group_name_attribute", } // DefaultKVS - default config for LDAP config var ( DefaultKVS = config.KVS{ config.KV{ Key: config.Enable, Value: "", }, config.KV{
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Sep 18 11:47:48 GMT 2025 - 8.6K bytes - Click Count (0)