Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 342 for chains (0.05 seconds)

  1. index.yaml

        - object-storage
        - s3
        - cluster
        maintainers:
        - email: ******@****.***
          name: MinIO, Inc
        name: minio
        sources:
        - https://github.com/minio/minio
        urls:
        - https://charts.min.io/helm-releases/minio-5.4.0.tgz
        version: 5.4.0
      - apiVersion: v1
        appVersion: RELEASE.2024-04-18T19-09-19Z
        created: "2025-01-02T21:34:25.231025201-08:00"
        description: High Performance Object Storage
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jan 03 05:34:47 GMT 2025
    - 55.1K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

        client =
          client
            .newBuilder()
            .addInterceptor(
              Interceptor { chain: Interceptor.Chain? ->
                chain!!
                  .proceed(chain.request())
                  .use { a -> assertThat(a.body.string()).isEqualTo("a") }
                chain.proceed(chain.request())
              },
            ).build()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 70.5K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

      internal fun newCodec(
        client: OkHttpClient,
        chain: RealInterceptorChain,
      ): ExchangeCodec {
        val okHttpSocket = this.socket
        val http2Connection = this.http2Connection
    
        return if (http2Connection != null) {
          Http2ExchangeCodec(client, this, chain, http2Connection)
        } else {
          javaNetSocket.soTimeout = chain.readTimeoutMillis()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 14.6K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

              break;
            }
          }
        }
      }
    
      /**
       * Represents a detected cycle in lock acquisition ordering. The exception includes a causal chain
       * of {@code ExampleStackTrace} instances to illustrate the cycle, e.g.
       *
       * <pre>
       * com....PotentialDeadlockException: Potential Deadlock from LockC -&gt; ReadWriteA
       *   at ...
       *   at ...
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 11 17:06:34 GMT 2025
    - 35.9K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/CallKotlinTest.kt

        var connection: RealConnection? = null
        client =
          client
            .newBuilder()
            .addNetworkInterceptor(
              Interceptor { chain ->
                connection = chain.connection() as RealConnection
                chain.proceed(chain.request())
              },
            ).build()
    
        server.enqueue(
          MockResponse
            .Builder()
            .body("a")
            .onResponseEnd(
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/OkHttpClientTest.kt

        } catch (ignored: IllegalArgumentException) {
        }
      }
    
      @Test fun clonedInterceptorsListsAreIndependent() {
        val interceptor =
          Interceptor { chain: Interceptor.Chain ->
            chain.proceed(chain.request())
          }
        val original = clientTestRule.newClient()
        original
          .newBuilder()
          .addInterceptor(interceptor)
          .addNetworkInterceptor(interceptor)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Jun 18 12:28:21 GMT 2025
    - 13.4K bytes
    - Click Count (1)
  7. okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt

          client
            .newBuilder()
            .addInterceptor(
              Interceptor { chain: Interceptor.Chain ->
                ready.countDown()
                try {
                  proceed.await(5, TimeUnit.SECONDS)
                } catch (e: InterruptedException) {
                  throw RuntimeException(e)
                }
                chain.proceed(chain.request())
              },
            ).build()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  8. internal/config/identity/openid/jwt.go

    // ErrTokenExpired - error token expired
    var (
    	ErrTokenExpired = errors.New("token expired")
    )
    
    func updateClaimsExpiry(dsecs string, claims map[string]any) error {
    	expStr := claims["exp"]
    	if expStr == "" {
    		return ErrTokenExpired
    	}
    
    	// No custom duration requested, the claims can be used as is.
    	if dsecs == "" {
    		return nil
    	}
    
    	if _, err := auth.ExpToInt64(expStr); err != nil {
    		return err
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        client =
          client
            .newBuilder()
            .addInterceptor(
              Interceptor { chain: Interceptor.Chain ->
                try {
                  chain.proceed(chain.request())
                  throw AssertionError()
                } catch (expected: IOException) {
                  chain.proceed(chain.request())
                }
              },
            ).build()
        val request = Request(server.url("/"))
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 147.4K bytes
    - Click Count (0)
  10. cmd/auth-handler.go

    		return token
    	}
    	return r.Form.Get(xhttp.AmzSecurityToken)
    }
    
    // Fetch claims in the security token returned by the client, doesn't return
    // errors - upon errors the returned claims map will be empty.
    func mustGetClaimsFromToken(r *http.Request) map[string]any {
    	claims, _ := getClaimsFromToken(getSessionToken(r))
    	return claims
    }
    
    func getClaimsFromTokenWithSecret(token, secret string) (*xjwt.MapClaims, error) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
Back to Top