Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1871 - 1880 of 2,683 for batch (0.14 seconds)

  1. cmd/routers.go

    var globalMiddlewares = []mux.MiddlewareFunc{
    	// set x-amz-request-id header and others
    	addCustomHeadersMiddleware,
    	// The generic tracer needs to be the first middleware to catch all requests
    	// returned early by any other middleware (but after the middleware that
    	// sets the amz request id).
    	httpTracerMiddleware,
    	// Auth middleware verifies incoming authorization headers and routes them
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jul 29 18:10:04 GMT 2024
    - 3.9K bytes
    - Click Count (0)
  2. internal/arn/arn.go

    	if ps[2] != string(arnServiceIAM) {
    		err = errors.New("invalid ARN - bad service field")
    		return arn, err
    	}
    
    	// ps[3] is region and is not validated here. If the region is invalid,
    	// the ARN would not match any configured ARNs in the server.
    	if ps[4] != "" {
    		err = errors.New("invalid ARN - unsupported account-id field")
    		return arn, err
    	}
    
    	res := strings.SplitN(ps[5], "/", 2)
    	if len(res) != 2 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.5K bytes
    - Click Count (0)
  3. internal/config/crypto_test.go

    		}
    		data, err = io.ReadAll(plaintext)
    		if err != nil {
    			t.Fatalf("Test %d: failed to decrypt stream: %v", i, err)
    		}
    
    		if !bytes.Equal(data, test.Data) {
    			t.Fatalf("Test %d: decrypted data does not match original data", i)
    		}
    	}
    }
    
    func BenchmarkEncrypt(b *testing.B) {
    	key, err := hex.DecodeString("ddedadb867afa3f73bd33c25499a723ed7f9f51172ee7b1b679e08dc795debcc")
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  4. lib/wasm/wasm_exec.js

    							const result = Reflect.apply(m, v, args);
    							sp = this._inst.exports.getsp() >>> 0; // see comment above
    							storeValue(sp + 56, result);
    							this.mem.setUint8(sp + 64, 1);
    						} catch (err) {
    							sp = this._inst.exports.getsp() >>> 0; // see comment above
    							storeValue(sp + 56, err);
    							this.mem.setUint8(sp + 64, 0);
    						}
    					},
    
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Sun Dec 08 15:34:47 GMT 2024
    - 16.6K bytes
    - Click Count (0)
  5. src/main/java/jcifs/smb1/dcerpc/ndr/NdrBuffer.java

            Encdec.enc_uint32le(0, buf, i);
            i += 4;
            Encdec.enc_uint32le(len + 1, buf, i);
            i += 4;
            try {
                System.arraycopy(s.getBytes("UTF-16LE"), 0, buf, i, len * 2);
            } catch (final UnsupportedEncodingException uee) {}
            i += len * 2;
            buf[i] = (byte) '\0';
            i++;
            buf[i++] = (byte) '\0';
            advance(i - index);
        }
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/DateFormatting.kt

      if (isEmpty()) return null
    
      val position = ParsePosition(0)
      var result = STANDARD_DATE_FORMAT.get().parse(this, position)
      if (position.index == length) {
        // STANDARD_DATE_FORMAT must match exactly; all text must be consumed, e.g. no ignored
        // non-standard trailing "+01:00". Those cases are covered below.
        return result
      }
      synchronized(BROWSER_COMPATIBLE_DATE_FORMAT_STRINGS) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 4.1K bytes
    - Click Count (0)
  7. android/guava-testlib/src/com/google/common/collect/testing/testers/MapComputeIfPresentTester.java

        try {
          getMap()
              .computeIfPresent(
                  k3(),
                  (k, v) -> {
                    throw new AssertionFailedError();
                  });
        } catch (UnsupportedOperationException tolerated) {
        }
        expectUnchanged();
      }
    
      @MapFeature.Require(absent = SUPPORTS_PUT)
      @CollectionSize.Require(absent = ZERO)
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Oct 31 14:51:04 GMT 2024
    - 6.1K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/collect/WriteReplaceOverridesTest.java

          ) {
            continue;
          }
          Class<?> clazz = info.load();
          try {
            Method unused = clazz.getDeclaredMethod("writeReplace");
            continue; // It overrides writeReplace, so it's safe.
          } catch (NoSuchMethodException e) {
            // This is a class whose supertypes we want to examine. We'll do that below.
          }
          Optional<Class<?>> supersWithPackagePrivateWriteReplace =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Jul 01 03:07:54 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/base/Enums.java

       *
       * @since 12.0
       */
      public static Field getField(Enum<?> enumValue) {
        Class<?>
            clazz = enumValue.getDeclaringClass();
        try {
          return clazz.getDeclaredField(enumValue.name());
        } catch (NoSuchFieldException impossible) {
          throw new AssertionError(impossible);
        }
      }
    
      /**
       * Returns an optional enum constant for the given type, using {@link Enum#valueOf}. If the
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Jul 01 13:41:58 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/ListeningScheduledExecutorServiceTest.java

            Callable<V> callable, long delay, TimeUnit unit) {
          recordedDelay = delay;
          recordedTimeUnit = unit;
          try {
            return ImmediateScheduledFuture.of(callable.call());
          } catch (Exception e) {
            return ImmediateScheduledFuture.failed(e);
          }
        }
    
        @Override
        public ListenableScheduledFuture<?> scheduleAtFixedRate(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 6.5K bytes
    - Click Count (0)
Back to Top