Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 391 - 400 of 1,311 for var0 (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt

                    override fun close() {
                      responseClosed = true
                    }
                  }.buffer()
              },
            ).build()
    
        var responseClosed = false
        var canceled = false
        var afterCallbackOnResponse: () -> Unit = {}
    
        override fun cancel() {
          canceled = true
        }
    
        override fun enqueue(responseCallback: Callback) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  2. .github/workflows/people.yml

              GITHUB_TOKEN: ${{ secrets.FASTAPI_PEOPLE }}
          - name: FastAPI People Experts
            run: uv run ./scripts/people.py
            env:
              GITHUB_TOKEN: ${{ secrets.FASTAPI_PEOPLE }}
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sat Jan 10 22:02:57 GMT 2026
    - 1.5K bytes
    - Click Count (0)
  3. cmd/iam-store.go

    // of policies if not in the memory
    func (store *IAMStoreSys) MergePolicies(policyName string) (string, policy.Policy) {
    	var policies []string
    	var missingPolicies []string
    	var toMerge []policy.Policy
    
    	cache := store.rlock()
    	for _, policy := range newMappedPolicy(policyName).toSlice() {
    		if policy == "" {
    			continue
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 87.1K bytes
    - Click Count (0)
  4. .ci/jobs.t/elastic+elasticsearch+periodic+java-fips-matrix.yml

    ---
    jjbb-template: matrix-gradle-unix.yml
    vars:
      - job-name: elastic+elasticsearch+%BRANCH%+periodic+java-fips-matrix
      - job-display-name: "elastic / elasticsearch # %BRANCH% - java fips compatibility matrix"
      - job-description: "Testing of the Elasticsearch %BRANCH% branch java FIPS compatibility matrix.\n"
      - matrix-yaml-file: ".ci/matrix-runtime-javas-fips.yml"
      - matrix-variable: ES_RUNTIME_JAVA
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu Jun 24 17:56:51 GMT 2021
    - 485 bytes
    - Click Count (0)
  5. doc/go_mem.html

    </p>
    
    <p class="rule">
    A send on a channel is synchronized before the completion of the
    corresponding receive from that channel.
    </p>
    
    <p>
    This program:
    </p>
    
    <pre>
    var c = make(chan int, 10)
    var a string
    
    func f() {
    	a = "hello, world"
    	c &lt;- 0
    }
    
    func main() {
    	go f()
    	&lt;-c
    	print(a)
    }
    </pre>
    
    <p>
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Aug 05 15:41:37 GMT 2025
    - 26.6K bytes
    - Click Count (0)
  6. cmd/storage-rest-client.go

    		DiskID:   *client.diskID.Load(),
    		ScanMode: int(scanMode),
    		Cache:    &cache,
    	})
    	if err != nil {
    		return cache, toStorageErr(err)
    	}
    	var final *dataUsageCache
    	err = st.Results(func(resp *nsScannerResp) error {
    		if resp.Update != nil {
    			select {
    			case <-ctx.Done():
    			case updates <- *resp.Update:
    			}
    		}
    		if resp.Final != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  7. cmd/osmetric_string.go

    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[osMetricRemoveAll-0]
    	_ = x[osMetricMkdirAll-1]
    	_ = x[osMetricMkdir-2]
    	_ = x[osMetricRename-3]
    	_ = x[osMetricOpenFileW-4]
    	_ = x[osMetricOpenFileR-5]
    	_ = x[osMetricOpenFileWFd-6]
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Feb 15 01:09:38 GMT 2024
    - 1.3K bytes
    - Click Count (0)
  8. internal/s3select/message.go

    		return false
    	}
    
    	xhttp.Flush(writer.writer)
    	return true
    }
    
    func (writer *messageWriter) start() {
    	keepAliveTicker := time.NewTicker(1 * time.Second)
    	var progressTicker *time.Ticker
    	var progressTickerC <-chan time.Time
    	if writer.getProgressFunc != nil {
    		progressTicker = time.NewTicker(1 * time.Minute)
    		progressTickerC = progressTicker.C
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  9. cmd/benchmark-utils_test.go

    )
    
    // Benchmark utility functions for ObjectLayer.PutObject().
    // Creates Object layer setup ( MakeBucket ) and then runs the PutObject benchmark.
    func runPutObjectBenchmark(b *testing.B, obj ObjectLayer, objSize int) {
    	var err error
    	// obtains random bucket name.
    	bucket := getRandomBucketName()
    	// create bucket.
    	err = obj.MakeBucket(b.Context(), bucket, MakeBucketOptions{})
    	if err != nil {
    		b.Fatal(err)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  10. cmd/storage-datatypes_test.go

    	"encoding/gob"
    	"io"
    	"testing"
    	"time"
    
    	"github.com/tinylib/msgp/msgp"
    )
    
    func BenchmarkDecodeVolInfoMsgp(b *testing.B) {
    	v := VolInfo{
    		Name:    "uuid",
    		Created: time.Now(),
    	}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.Log("Size:", buf.Len(), "bytes")
    	b.SetBytes(1)
    	b.ReportAllocs()
    
    	for b.Loop() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 9.1K bytes
    - Click Count (0)
Back to Top