Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 379 for SELECT (0.06 sec)

  1. misc/ios/README

    the go_ios_$GOARCH_exec wrapper is found. For example, to run the archive/tar tests:
    
    	export PATH=$GOROOT/bin:$PATH
    	GOOS=ios GOARCH=amd64 CGO_ENABLED=1 go test archive/tar
    
    The go_ios_exec wrapper uses GOARCH to select the emulator (amd64) or the device (arm64).
    However, further setup is required to run tests or programs directly on a device.
    
    First make sure you have a valid developer certificate and have setup your device properly
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Dec 29 21:49:26 UTC 2020
    - 2.7K bytes
    - Viewed (0)
  2. internal/bucket/bandwidth/monitor.go

    	if !ok {
    		tm = &bucketMeasurement{}
    	}
    	tm.incrementBytes(bytes)
    	m.bucketsMeasurement[opts] = tm
    }
    
    // SelectionFunction for buckets
    type SelectionFunction func(bucket string) bool
    
    // SelectBuckets will select all the buckets passed in.
    func SelectBuckets(buckets ...string) SelectionFunction {
    	if len(buckets) == 0 {
    		return func(bucket string) bool {
    			return true
    		}
    	}
    	return func(bucket string) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. internal/s3select/simdj/reader.go

    // On errors, r.err will be set. This should only be accessed after r.decoded has been closed.
    func (r *Reader) startReader() {
    	defer r.onReaderExit()
    	var tmpObj simdjson.Object
    	for {
    		var in simdjson.Stream
    		select {
    		case in = <-r.input:
    		case <-r.exitReader:
    			return
    		}
    		if in.Error != nil && in.Error != io.EOF {
    			r.err = &in.Error
    			return
    		}
    		if in.Value == nil {
    			if in.Error == io.EOF {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  4. cmd/batch-expire.go

    			toDelCopy := make([]ObjectToDelete, len(toDel))
    			for attempts := 1; attempts <= retryAttempts; attempts++ {
    				select {
    				case <-ctx.Done():
    					return
    				default:
    				}
    
    				stopFn := globalBatchJobsMetrics.trace(batchJobMetricExpire, ri.JobID, attempts)
    				// Copying toDel to select from objects whose
    				// deletion failed
    				copy(toDelCopy, toDel)
    				var failed int
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/FakeProxySelector.kt

    class FakeProxySelector : ProxySelector() {
      val proxies: MutableList<Proxy> = mutableListOf()
    
      fun addProxy(proxy: Proxy): FakeProxySelector {
        proxies.add(proxy)
        return this
      }
    
      override fun select(uri: URI): List<Proxy> {
        // Don't handle 'socket' schemes, which the RI's Socket class may request (for SOCKS).
        return if (uri.scheme == "http" || uri.scheme == "https") proxies else listOf(Proxy.NO_PROXY)
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  6. android-test/README.md

    ...
    BUILD SUCCESSFUL in 1m 30s
    63 actionable tasks: 61 executed, 2 up-to-date
    
    ```
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Feb 14 08:26:50 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  7. cmd/metacache-walk.go

    			return
    		}
    		if m, _, _ := isIndexedMetaV2(metadata); m != nil && !m.AllHidden(true) {
    			objsReturned++
    		}
    	}
    	send := func(entry metaCacheEntry) error {
    		objReturned(entry.metadata)
    		select {
    		case <-ctx.Done():
    			return ctx.Err()
    		case out <- entry:
    		}
    		return nil
    	}
    
    	// Fast exit track to check if we are listing an object with
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  8. finisher_api.go

    			tx.Statement.Model = nil
    		}()
    	}
    
    	if selectClause, ok := db.Statement.Clauses["SELECT"]; ok {
    		defer func() {
    			tx.Statement.Clauses["SELECT"] = selectClause
    		}()
    	} else {
    		defer delete(tx.Statement.Clauses, "SELECT")
    	}
    
    	if len(tx.Statement.Selects) == 0 {
    		tx.Statement.AddClause(clause.Select{Expression: clause.Expr{SQL: "count(*)"}})
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 22.8K bytes
    - Viewed (0)
  9. internal/dsync/dsync_test.go

    	if !dm.GetLock(ctx, cancel, id, source, Options{Timeout: 5 * time.Minute}) {
    		t.Fatal("GetLock() should be successful")
    	}
    
    	// Make it run twice.
    	timer := time.NewTimer(testDrwMutexRefreshInterval * 2)
    
    	select {
    	case <-ctx.Done():
    		t.Fatal("Lock context canceled which is not expected")
    	case <-timer.C:
    	}
    
    	// Should be safe operation in all cases
    	dm.Unlock(context.Background())
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  10. ci/official/containers/linux_arm64/devel.usertools/code_check_full.bats

      # Column 1 is left only, Column 2 is right only, Column 3 is shared lines
      # Select lines unique to actual_licenses, i.e. extra licenses.
      comm -1 -3 $BATS_TEST_TMPDIR/expected_licenses $BATS_TEST_TMPDIR/actual_licenses | grep -v -f $BATS_TEST_TMPDIR/allowed_to_be_extra > $BATS_TEST_TMPDIR/actual_extra_licenses || true
      # Select lines unique to expected_licenses, i.e. missing licenses
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Aug 14 18:47:44 UTC 2024
    - 12.9K bytes
    - Viewed (0)
Back to top