Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 226 for dispatch (0.11 sec)

  1. samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt

            sendTestRequest(twitterRequest)
            Thread.sleep(1000)
            sendTestRequest(googleRequest)
            Thread.sleep(2000)
          }
        } finally {
          client.connectionPool.evictAll()
          client.dispatcher.executorService.shutdownNow()
    
          if (launch == CommandLine) {
            process?.destroyForcibly()
          }
        }
      }
    
      private fun sendTestRequest(request: Request) {
        try {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/scopes/Maven4ScopeManagerConfiguration.java

            // == sanity check
            if (result.size() != org.apache.maven.api.DependencyScope.values().length - 1) { // sans "undefined"
                throw new IllegalStateException("Maven4 API dependency scope mismatch");
            }
    
            return result;
        }
    
        @Override
        public Collection<org.eclipse.aether.scope.ResolutionScope> buildResolutionScopes(
                InternalScopeManager internalScopeManager) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/Dfs.java

             * in such a way that there can be a slash at the end of the path. This
             * causes problems matching keys in resolve() where an extra slash causes
             * a mismatch. This strips trailing slashes from all keys to eliminate
             * this problem.
             */
            int ki = key.length();
            while (ki > 1 && key.charAt(ki - 1) == '\\') {
                ki--;
            }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 11.7K bytes
    - Viewed (0)
  4. docs/debugging/s3-verify/main.go

    	sobj.Close()
    	tobj.Close()
    
    	if !sourceFailed && !targetFailed {
    		ssum := srcSha256.Sum(nil)
    		tsum := tgtSha256.Sum(nil)
    		allgood = bytes.Equal(ssum, tsum)
    		if !allgood {
    			fmt.Printf("sha256 sum mismatch: %s -> Expected(%x), Found(%x)\n", srcCtnt.Key, ssum, tsum)
    		}
    	}
    
    	return allgood
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 22 15:12:47 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  5. cmd/storage-interface.go

    	RenameData(ctx context.Context, srcVolume, srcPath string, fi FileInfo, dstVolume, dstPath string, opts RenameOptions) (RenameDataResp, error)
    
    	// File operations.
    	ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) ([]string, error)
    	ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. cmd/xl-storage-disk-id-check.go

    }
    
    func (p *xlStorageDiskIDCheck) ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) (s []string, err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricListDir, volume, dirPath)
    	if err != nil {
    		return nil, err
    	}
    	defer done(0, &err)
    
    	return p.storage.ListDir(ctx, origvolume, volume, dirPath, count)
    }
    
    // Legacy API - does not have any deadlines
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  7. docs/en/docs/advanced/generate-clients.md

    This also means that if something changed it will be **reflected** on the client code automatically. And if you **build** the client it will error out if you have any **mismatch** in the data used.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  8. cmd/storage-rest-client.go

    }
    
    // ListDir - lists a directory.
    func (client *storageRESTClient) ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) (entries []string, err error) {
    	values := grid.NewMSS()
    	values.Set(storageRESTVolume, volume)
    	values.Set(storageRESTDirPath, dirPath)
    	values.Set(storageRESTCount, strconv.Itoa(count))
    	values.Set(storageRESTOrigVolume, origvolume)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  9. cmd/object-handlers_test.go

    			accessKey:          credentials.AccessKey,
    			secretKey:          credentials.SecretKey,
    			expectedRespStatus: http.StatusNotFound,
    		},
    		// Test case - 3.
    		// Test case to induce a signature mismatch.
    		// Using invalid accessID.
    		{
    			bucketName:         bucketName,
    			objectName:         objectName,
    			accessKey:          "Invalid-AccessID",
    			secretKey:          credentials.SecretKey,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/InterceptorTest.kt

        val boom = RuntimeException("boom!")
        addInterceptor(network) { chain: Interceptor.Chain? -> throw boom }
        val executor = ExceptionCatchingExecutor()
        client =
          client.newBuilder()
            .dispatcher(Dispatcher(executor))
            .build()
        val request =
          Request.Builder()
            .url(server.url("/"))
            .build()
        val call = client.newCall(request)
        call.enqueue(callback)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 27.8K bytes
    - Viewed (0)
Back to top