Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 35 for Completer (0.07 sec)

  1. android/guava/src/com/google/common/util/concurrent/Futures.java

       *
       * <p>Cancelling a delegate future propagates to input futures once all the delegates complete,
       * either from cancellation or because an input future has completed. If N futures are passed in,
       * and M delegates are cancelled, the remaining M input futures will be cancelled once N - M of
       * the input futures complete. If all the delegates are cancelled, all the input futures will be
       * too.
       *
       * @since 17.0
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/Futures.java

       *
       * <p>Cancelling a delegate future propagates to input futures once all the delegates complete,
       * either from cancellation or because an input future has completed. If N futures are passed in,
       * and M delegates are cancelled, the remaining M input futures will be cancelled once N - M of
       * the input futures complete. If all the delegates are cancelled, all the input futures will be
       * too.
       *
       * @since 17.0
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt

        // But they disappear when the edit completes.
        sink0.close()
        editor.commit()
        assertThat(readFileOrNull(getCleanFile("k1", 0))).isNull()
        assertThat(readFileOrNull(getDirtyFile("k1", 0))).isNull()
      }
    
      @ParameterizedTest
      @ArgumentsSource(FileSystemParamProvider::class)
      fun `close with completed zombie write`(parameters: Pair<FileSystem, Boolean>) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 14:55:09 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  4. cmd/batch-handlers.go

    	LastUpdate    time.Time `json:"lastUpdate" msg:"lu"`
    	RetryAttempts int       `json:"retryAttempts" msg:"ra"`
    	Attempts      int       `json:"attempts" msg:"at"`
    
    	Complete bool `json:"complete" msg:"cmp"`
    	Failed   bool `json:"failed" msg:"fld"`
    
    	// Last bucket/object batch replicated
    	Bucket string `json:"-" msg:"lbkt"`
    	Object string `json:"-" msg:"lobj"`
    
    	// Verbose information
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/cache/CacheBuilder.java

       * segments, each governed by its own write lock. The segment lock is taken once for each explicit
       * write, and twice for each cache loading computation (once prior to loading the new value, and
       * once after loading completes). Much internal cache management is performed at the segment
       * granularity. For example, access queues and write queues are kept per segment when they are
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 52K bytes
    - Viewed (0)
  6. src/cmd/cgo/gcc.go

    			}
    			continue
    		}
    
    		switch filename {
    		case "completed":
    			// Strictly speaking, there is no guarantee that seeing the error at completed:1
    			// (at the end of the file) means we've seen all the errors from earlier in the file,
    			// but usually it does. Certainly if we don't see the completed:1 error, we did
    			// not get all the errors we expected.
    			completed = true
    
    		case "not-declared":
    			sniff[i] |= notDeclared
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 18 15:07:34 UTC 2024
    - 97.1K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

         * all must complete within one timeout period.
         *
         * The default value is 0 which imposes no timeout.
         */
        fun callTimeout(
          timeout: Long,
          unit: TimeUnit,
        ) = apply {
          callTimeout = checkDuration("timeout", timeout, unit)
        }
    
        /**
         * Sets the default timeout for complete calls. A value of 0 means no timeout, otherwise values
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbSessionImpl.java

                        log.debug("Session setup failed", se);
                        if ( this.connectionState.compareAndSet(1, 0) ) {
                            // only try to logoff if we have not completed the session setup, ignore errors from chained
                            // responses
                            logoff(true, true);
                        }
                        throw se;
                    }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 17:41:04 UTC 2021
    - 49K bytes
    - Viewed (0)
  9. guava/src/com/google/common/cache/CacheBuilder.java

       * segments, each governed by its own write lock. The segment lock is taken once for each explicit
       * write, and twice for each cache loading computation (once prior to loading the new value, and
       * once after loading completes). Much internal cache management is performed at the segment
       * granularity. For example, access queues and write queues are kept per segment when they are
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  10. cmd/erasure-healing_test.go

    			ETag:       pInfo.ETag,
    		})
    	}
    
    	_, err = objLayer.CompleteMultipartUpload(ctx, bucket, object, res.UploadID, uploadedParts, ObjectOptions{})
    	if err != nil {
    		t.Fatalf("Failed to complete multipart upload - got: %v", err)
    	}
    
    	cfgFile := pathJoin(bucketMetaPrefix, bucket, ".test.bin")
    	if err = saveConfig(ctx, objLayer, cfgFile, data); err != nil {
    		t.Fatal(err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
Back to top