Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1241 - 1250 of 1,605 for var1 (0.02 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt

      internal val exchange: Exchange?,
      internal val request: Request,
      internal val connectTimeoutMillis: Int,
      internal val readTimeoutMillis: Int,
      internal val writeTimeoutMillis: Int,
    ) : Interceptor.Chain {
      private var calls: Int = 0
    
      internal fun copy(
        index: Int = this.index,
        exchange: Exchange? = this.exchange,
        request: Request = this.request,
        connectTimeoutMillis: Int = this.connectTimeoutMillis,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  2. cni/pkg/plugin/sidecar_iptables_linux.go

    	"istio.io/istio/tools/istio-iptables/pkg/cmd"
    	"istio.io/istio/tools/istio-iptables/pkg/config"
    	"istio.io/istio/tools/istio-iptables/pkg/dependencies"
    )
    
    // getNs is a unit test override variable for interface create.
    var getNs = ns.GetNS
    
    // Program defines a method which programs iptables based on the parameters
    // provided in Redirect.
    func (ipt *iptables) Program(podName, netns string, rdrct *Redirect) error {
    	cfg := config.DefaultConfig()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Jun 29 01:24:47 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt

     * Settings describe characteristics of the sending peer, which are used by the receiving peer.
     * Settings are [connection][Http2Connection] scoped.
     */
    class Settings {
      /** Bitfield of which flags that values. */
      private var set: Int = 0
    
      /** Flag values. */
      private val values = IntArray(COUNT)
    
      /** Returns -1 if unset. */
      val headerTableSize: Int
        get() {
          val bit = 1 shl HEADER_TABLE_SIZE
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  4. docs/debugging/hash-set/main.go

    	keyCrc := crc32.Checksum([]byte(key), crc32.IEEETable)
    
    	start := int(keyCrc % uint32(cardinality))
    	for i := 1; i <= cardinality; i++ {
    		nums[i-1] = 1 + ((start + i) % cardinality)
    	}
    	return nums
    }
    
    var (
    	file, object, deploymentID, prefix string
    	setCount, shards                   int
    	verbose                            bool
    )
    
    func main() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.7K bytes
    - Viewed (0)
  5. internal/s3select/sql/utils.go

    	if e.strippedTableAlias == tableAlias {
    		return e.strippedPathExpr
    	}
    
    	hasTableAlias := e.BaseKey.String() == tableAlias || strings.EqualFold(e.BaseKey.String(), baseTableName)
    	var pathExpr []*JSONPathElement
    	if hasTableAlias {
    		pathExpr = e.PathExpr
    	} else {
    		pathExpr = make([]*JSONPathElement, len(e.PathExpr)+1)
    		pathExpr[0] = &JSONPathElement{Key: &ObjectKey{ID: e.BaseKey}}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Nov 10 16:12:50 UTC 2021
    - 3.6K bytes
    - Viewed (0)
  6. internal/event/target/mysql.go

    		if err != nil {
    			return err
    		}
    		key := eventData.S3.Bucket.Name + "/" + objectName
    
    		if eventData.EventName == event.ObjectRemovedDelete {
    			_, err = target.deleteStmt.Exec(key)
    		} else {
    			var data []byte
    			if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil {
    				return err
    			}
    
    			_, err = target.updateStmt.Exec(key, data)
    		}
    
    		return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  7. cmd/admin-heal-ops.go

    	// completes.
    	keepHealSeqStateDuration = time.Minute * 10
    
    	// nopHeal is a no operating healing action to
    	// wait for the current healing operation to finish
    	nopHeal = ""
    )
    
    var (
    	errHealIdleTimeout   = errors.New("healing results were not consumed for too long")
    	errHealStopSignalled = errors.New("heal stop signaled")
    
    	errFnHealFromAPIErr = func(ctx context.Context, err error) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  8. cmd/erasure-object_test.go

    	"github.com/minio/minio/internal/config/storageclass"
    )
    
    func TestRepeatPutObjectPart(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	var objLayer ObjectLayer
    	var disks []string
    	var err error
    	var opts ObjectOptions
    
    	objLayer, disks, err = prepareErasure16(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// cleaning up of temporary test directories
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  9. docs/site-replication/run-multi-site-minio-idp.sh

    fi
    
    set +x
    
    # "Test if most recent tag update is replicated"
    ./mc tag set minio2/newbucket "key=val1"
    if [ $? -ne 0 ]; then
    	echo "expecting tag set to be successful. exiting.."
    	exit_1
    fi
    sleep 5
    
    val=$(./mc tag list minio1/newbucket --json | jq -r .tagset | jq -r .key)
    if [ "${val}" != "val1" ]; then
    	echo "expected bucket tag to have replicated, exiting..."
    	exit_1
    fi
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 08:03:58 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt

        )
    }
    
    @Timeout(60)
    @Tag("Slow")
    class DiskLruCacheTest {
      private lateinit var filesystem: FaultyFileSystem
      private var windows: Boolean = false
    
      @TempDir lateinit var cacheDirFile: File
      lateinit var cacheDir: Path
      private val appVersion = 100
      private lateinit var journalFile: Path
      private lateinit var journalBkpFile: Path
      private val taskFaker = TaskFaker()
      private val taskRunner = taskFaker.taskRunner
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 14:55:09 UTC 2024
    - 75.8K bytes
    - Viewed (0)
Back to top