Search Options

Results per page
Sort
Preferred Languages
Advance

Results 2471 - 2480 of 3,649 for Code (0.06 sec)

  1. cmd/format-erasure.go

    	if err := json.Unmarshal(b, format); err != nil {
    		return "", err
    	}
    	return format.Erasure.Version, nil
    }
    
    // Migrates all previous versions to latest version of `format.json`,
    // this code calls migration in sequence, such as V1 is migrated to V2
    // first before it V2 migrates to V3.n
    func formatErasureMigrate(export string) ([]byte, fs.FileInfo, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  2. cmd/api-utils.go

    		return false
    	}
    
    	switch c {
    	case '-', '_', '.', '/', '*':
    		return false
    	}
    	return true
    }
    
    // s3URLEncode is based on Golang's url.QueryEscape() code,
    // while considering some S3 exceptions:
    //   - Avoid encoding '/' and '*'
    //   - Force encoding of '~'
    func s3URLEncode(s string) string {
    	spaceCount, hexCount := 0, 0
    	for i := 0; i < len(s); i++ {
    		c := s[i]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 04 18:05:56 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  3. src/cmd/asm/internal/asm/pseudo_test.go

    // Copyright 2015 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package asm
    
    import (
    	"strings"
    	"testing"
    
    	"cmd/asm/internal/lex"
    )
    
    func tokenize(s string) [][]lex.Token {
    	res := [][]lex.Token{}
    	if len(s) == 0 {
    		return res
    	}
    	for _, o := range strings.Split(s, ",") {
    		res = append(res, lex.Tokenize(o))
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  4. misc/ios/detect.go

    // Copyright 2015 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    //go:build ignore
    
    // detect attempts to autodetect the correct
    // values of the environment variables
    // used by go_ios_exec.
    // detect shells out to ideviceinfo, a third party program that can
    // be obtained by following the instructions at
    // https://github.com/libimobiledevice/libimobiledevice.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 19 23:33:30 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  5. android/guava-testlib/src/com/google/common/collect/testing/google/MultisetAddTester.java

    import com.google.common.annotations.GwtCompatible;
    import com.google.common.collect.testing.features.CollectionFeature;
    import java.util.Collections;
    import org.junit.Ignore;
    
    /**
     * Tests for {@code Multiset.add}.
     *
     * @author Jared Levy
     */
    @GwtCompatible
    @Ignore // Affects only Android test runner, which respects JUnit 4 annotations on JUnit 3 tests.
    @SuppressWarnings("JUnit4ClassUsedInJUnit3")
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 4K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/collect/testing/testers/ConcurrentMapReplaceTester.java

    import com.google.common.collect.testing.features.MapFeature;
    import java.util.concurrent.ConcurrentMap;
    import org.junit.Ignore;
    
    /**
     * A generic JUnit test which tests {@code replace(K, V)} operations on a concurrent map. Can't be
     * invoked directly; please see {@link
     * com.google.common.collect.testing.ConcurrentMapTestSuiteBuilder}.
     *
     * @author Louis Wasserman
     */
    @GwtCompatible
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 20:00:30 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  7. samples/guide/src/main/java/okhttp3/recipes/RequestBodyCompression.java

            .post(jsonRequestBody)
            .build();
    
        try (Response response = client.newCall(request).execute()) {
          if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);
    
          System.out.println(response.body().string());
        }
      }
    
      public static void main(String... args) throws Exception {
        new RequestBodyCompression().run();
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat May 25 18:02:55 UTC 2019
    - 3.8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/hash/MacHashFunction.java

        }
        return new MacHasher(getMac(prototype.getAlgorithm(), key));
      }
    
      @Override
      public String toString() {
        return toString;
      }
    
      /** Hasher that updates a {@link Mac} (message authentication code). */
      private static final class MacHasher extends AbstractByteHasher {
        private final Mac mac;
        private boolean done;
    
        private MacHasher(Mac mac) {
          this.mac = mac;
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 15 22:31:55 UTC 2022
    - 3.6K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

        val errorCodeInt = source.readInt()
        val errorCode =
          ErrorCode.fromHttp2(errorCodeInt) ?: throw IOException(
            "TYPE_RST_STREAM unexpected error code: $errorCodeInt",
          )
        handler.rstStream(streamId, errorCode)
      }
    
      @Throws(IOException::class)
      private fun readSettings(
        handler: Handler,
        length: Int,
        flags: Int,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/DuplexTest.kt

            .sendResponse("/a has moved!\n", duplexResponseSent)
            .requestIOException()
            .exhaustResponse()
        server.enqueue(
          MockResponse.Builder()
            .clearHeaders()
            .code(HttpURLConnection.HTTP_MOVED_PERM)
            .addHeader("Location: /b")
            .streamHandler(body)
            .build(),
        )
        server.enqueue(
          MockResponse.Builder()
            .body("this is /b")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
Back to top