Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 806 for proceed (0.08 sec)

  1. okhttp/src/test/java/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()
        val call = client.newCall(Request.Builder().url(server.url("/")).build())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (2)
  2. cmd/data-scanner.go

    			item.heal.bitrot = f.scanMode == madmin.HealDeepScan
    
    			sz, err := f.getSize(item)
    			if err != nil && err != errIgnoreFileContrib {
    				wait() // wait to proceed to next entry.
    				if err != errSkipFile && f.dataUsageScannerDebug {
    					console.Debugf(scannerLogPrefix+" getSize \"%v/%v\" returned err: %v\n", bucket, item.objectPath(), err)
    				}
    				return nil
    			}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/CallHandshakeTest.kt

            }
          }
          .addNetworkInterceptor {
            val socket = it.connection()!!.socket() as SSLSocket
    
            handshakeEnabledCipherSuites = socket.enabledCipherSuites.toList()
    
            it.proceed(it.request())
          }
          .build()
      }
    
      private fun makeRequest(client: OkHttpClient): Handshake {
        val call = client.newCall(Request(server.url("/")))
        return call.execute().use { it.handshake!! }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/CallKotlinTest.kt

        client =
          client.newBuilder()
            .addNetworkInterceptor(
              Interceptor { chain ->
                connection = chain.connection() as RealConnection
                chain.proceed(chain.request())
              },
            )
            .build()
    
        server.enqueue(
          MockResponse(
            body = "a",
            socketPolicy = ShutdownOutputAtEnd,
          ),
        )
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. cmd/bucket-metadata.go

    			if err = b.convertLegacyConfigs(ctx, objectAPI, configs); err != nil {
    				return b, err
    			}
    		}
    	}
    
    	if parse {
    		// nothing to update, parse and proceed.
    		if err = b.parseAllConfigs(ctx, objectAPI); err != nil {
    			return b, err
    		}
    	}
    
    	// migrate unencrypted remote targets
    	if err = b.migrateTargetConfig(ctx, objectAPI); err != nil {
    		return b, err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/net.go

    	log := log.WithLabels("ns", pod.Namespace, "name", pod.Name)
    	log.WithLabels("delete", isDelete).Debugf("removing pod from the mesh")
    
    	// Aggregate errors together, so that if part of the cleanup fails we still proceed with other steps.
    	var errs []error
    
    	// Whether pod is already deleted or not, we need to let go of our netns ref.
    	openNetns := s.currentPodSnapshot.Take(string(pod.UID))
    	if openNetns == nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  7. docs/sts/README.md

    ### Setup MinIO with Identity Provider
    
    Make sure we have followed the previous step and configured each software independently, once done we can now proceed to use MinIO STS API and MinIO server to use these credentials to perform object API operations.
    
    #### KeyCloak
    
    ```
    export MINIO_ROOT_USER=minio
    export MINIO_ROOT_PASSWORD=minio123
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 7.8K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

            readTimeoutMillis = client.readTimeoutMillis,
            writeTimeoutMillis = client.writeTimeoutMillis,
          )
    
        var calledNoMoreExchanges = false
        try {
          val response = chain.proceed(originalRequest)
          if (isCanceled()) {
            response.closeQuietly()
            throw IOException("Canceled")
          }
          return response
        } catch (e: IOException) {
          calledNoMoreExchanges = true
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  9. cmd/signature-v4_test.go

    				"X-Amz-Content-Sha256": payloadSHA256,
    			},
    			region:   region,
    			expected: ErrRequestNotReadyYet,
    		},
    		// (7) Should not error with invalid region instead, call should proceed
    		// with signature does not match.
    		{
    			queryParams: map[string]string{
    				"X-Amz-Algorithm":      signV4Algorithm,
    				"X-Amz-Date":           now.Format(iso8601Format),
    				"X-Amz-Expires":        "60",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  10. cmd/format-erasure.go

    	}
    	// Erasure backend found, proceed to detect version.
    	format := &formatErasureVersionDetect{}
    	if err := json.Unmarshal(b, format); err != nil {
    		return "", err
    	}
    	return format.Erasure.Version, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
Back to top