Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 310 for Binding (0.06 sec)

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

          InCompletionOrderState<T> localState = state;
          if (super.cancel(interruptIfRunning)) {
            /*
             * requireNonNull is generally safe: If cancel succeeded, then this Future was still
             * pending, so its `state` field hasn't been nulled out yet.
             *
             * OK, it's technically possible for this to fail in the presence of unsafe publishing, as
    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. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       (However, cancellation can prevent an <i>unstarted</i> task from running.) Therefore, the
     *       next task will wait for any running callable (or pending {@code Future} returned by an
     *       {@code AsyncCallable}) to complete, without interrupting it (and without calling {@code
     *       cancel} on the {@code Future}). So beware: <i>Even if you cancel every preceding {@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/hash/HashTestUtils.java

       * 1-bit characteristics.
       *
       * <p>There is more general code provided by Bob Jenkins to test arbitrarily sized characteristics
       * using the magic of gaussian elimination: http://burtleburtle.net/bob/crypto/findingc.html.
       */
      static void checkNo2BitCharacteristics(HashFunction function) {
        Random rand = new Random(0);
        int keyBits = 32;
    
        // get every one of (keyBits choose 2) deltas:
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  4. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelBuilder.java

            if (request.isProcessPlugins()) {
                if (lifecycleBindingsInjector == null) {
                    throw new IllegalStateException("lifecycle bindings injector is missing");
                }
    
                // lifecycle bindings injection
                lifecycleBindingsInjector.injectLifecycleBindings(resultModel, request, problems);
            }
    
            // dependency management import
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 83.6K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

        return editor
      }
    
      /**
       * Returns the number of bytes currently being used to store the values in this cache. This may be
       * greater than the max size if a background deletion is pending.
       */
      @Synchronized
      @Throws(IOException::class)
      fun size(): Long {
        initialize()
        return size
      }
    
      @Synchronized
      @Throws(IOException::class)
      internal fun completeEdit(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  6. cmd/batch-expire.go

    					time.Sleep(delay)
    				}
    			}
    		}(toExpire)
    	}
    }
    
    type expireObjInfo struct {
    	ObjectInfo
    	ExpireAll bool
    }
    
    // Start the batch expiration job, resumes if there was a pending job via "job.ID"
    func (r *BatchJobExpire) Start(ctx context.Context, api ObjectLayer, job BatchJobRequest) error {
    	ri := &batchJobInfo{
    		JobID:     job.ID,
    		JobType:   string(job.Type()),
    		StartTime: job.Started,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  7. src/main/java/jcifs/ntlmssp/Type3Message.java

                }
                else {
                    setLMResponse(new byte[24]);
                }
    
                if ( avPairs != null ) {
                    // make sure to set the TARGET_INFO flag as we are sending
                    setFlag(NtlmFlags.NTLMSSP_NEGOTIATE_TARGET_INFO, true);
                }
    
                byte[] responseKeyNT = NtlmUtil.nTOWFv2(domain, user, passwordHash);
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 12:07:20 UTC 2020
    - 30.6K bytes
    - Viewed (0)
  8. apache-maven/src/main/appended-resources/licenses/CDDL+GPLv2-with-classpath-exception.txt

        Ty Coon, President of Vice
    
    This General Public License does not permit incorporating your program
    into proprietary programs. If your program is a subroutine library, you
    may consider it more useful to permit linking proprietary applications
    with the library. If this is what you want to do, use the GNU Library
    General Public License instead of this License.
    
    #
    
    Certain source files distributed by Oracle America, Inc. and/or its
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri May 17 19:14:22 UTC 2024
    - 38.5K bytes
    - Viewed (0)
  9. common-protos/k8s.io/api/batch/v1/generated.proto

      // The completion time is only set when the job finishes successfully.
      // +optional
      optional k8s.io.apimachinery.pkg.apis.meta.v1.Time completionTime = 3;
    
      // The number of pending and running pods.
      // +optional
      optional int32 active = 4;
    
      // The number of pods which reached phase Succeeded.
      // +optional
      optional int32 succeeded = 5;
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

              stream.withLock {
                stream.addBytesToWriteWindow(delta)
              }
            }
          }
        }
    
        override fun ackSettings() {
          // TODO: If we don't get this callback after sending settings to the peer, SETTINGS_TIMEOUT.
        }
    
        override fun ping(
          ack: Boolean,
          payload1: Int,
          payload2: Int,
        ) {
          if (ack) {
            ******@****.***ck {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
Back to top