Search Options

Results per page
Sort
Preferred Languages
Advance

Results 761 - 770 of 802 for process (0.05 sec)

  1. okhttp/src/main/kotlin/okhttp3/EventListener.kt

       * example, thread A may be executing [responseBodyStart] while thread B executes [canceled].
       * Implementations must support such concurrent calls.
       *
       * Note that cancellation is best-effort and that a call may proceed normally after it has been
       * canceled. For example, happy-path events like [requestHeadersStart] and [requestHeadersEnd] may
       * occur after a call is canceled. Typically cancellation takes effect when an expensive I/O
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  2. cmd/xl-storage-format_test.go

    // AddTestObjectPart - add a new object part in order.
    func (m *xlMetaV1Object) AddTestObjectPart(partNumber int, partSize int64) {
    	partInfo := ObjectPartInfo{
    		Number: partNumber,
    		Size:   partSize,
    	}
    
    	// Proceed to include new part info.
    	m.Parts[partNumber-1] = partInfo
    }
    
    // Constructs xlMetaV1Object{} for given number of parts and converts it into bytes.
    func getXLMetaBytes(totalParts int) []byte {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

                  }
                })
            .start();
    
        // wait for the computingEntry to be created
        computationStarted.await();
        cache.invalidateAll();
        // let the computation proceed
        computingLatch.countDown();
        // don't check cache.size() until we know the get("b") call is complete
        computationComplete.await();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 15:00:32 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  4. cmd/update.go

    	if err != nil {
    		return t, fmt.Errorf("Unable to get ModTime of %s. %w", absPath, err)
    	}
    
    	// Return the ModTime
    	return fi.ModTime().UTC(), nil
    }
    
    // GetCurrentReleaseTime - returns this process's release time.  If it
    // is official minio version, parsed version is returned else minio
    // binary's mod time is returned.
    func GetCurrentReleaseTime() (releaseTime time.Time, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  5. src/bufio/scan.go

    	maxTokenSize int       // Maximum size of a token; modified by tests.
    	token        []byte    // Last token returned by split.
    	buf          []byte    // Buffer used as argument to split.
    	start        int       // First non-processed byte in buf.
    	end          int       // End of data in buf.
    	err          error     // Sticky error.
    	empties      int       // Count of successive empty tokens.
    	scanCalled   bool      // Scan has been called; buffer is in use.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 23 09:06:30 UTC 2023
    - 14.2K bytes
    - Viewed (0)
  6. src/main/webapp/js/admin/bootstrap.min.js

    nfig.target+" .list-group-item,"+this._config.target+" .dropdown-item",this._offsets=[],this._targets=[],this._activeTarget=null,this._scrollHeight=0,o.default(this._scrollElement).on("scroll.bs.scrollspy",(function(t){return n._process(t)})),this.refresh(),this._process()}var e=t.prototype;return e.refresh=function(){var t=this,e=this._scrollElement===this._scrollElement.window?"offset":ne,n="auto"===this._config.method?e:this._config.method,i=n===ne?this._getScrollTop():0;this._offsets=[],this...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 61.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/primitives/Ints.java

        //     block of size n-d (a[d..n-1]), where in general these blocks have different sizes. If we
        //     imagine a line separating the first block from the second, we can proceed by exchanging
        //     the smaller of these blocks with the far end of the other one. That leaves us with a
        //     smaller version of the same problem.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 18:05:56 UTC 2024
    - 31K bytes
    - Viewed (0)
  8. cmd/erasure-metadata.go

    		Checksums:  checksums,
    	}
    
    	// Update part info if it already exists.
    	for i, part := range fi.Parts {
    		if partNumber == part.Number {
    			fi.Parts[i] = partInfo
    			return
    		}
    	}
    
    	// Proceed to include new part info.
    	fi.Parts = append(fi.Parts, partInfo)
    
    	// Parts in FileInfo should be in sorted order by part number.
    	sort.Slice(fi.Parts, func(i, j int) bool { return fi.Parts[i].Number < fi.Parts[j].Number })
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

                // If this CAS succeeds, we know that the provided callable will never be invoked,
                // so when oldFuture completes it is safe to allow the next submitted task to
                // proceed. Doing this immediately here lets the next task run without waiting for
                // the cancelled task's executor to run the noop AsyncCallable.
                //
                // ---
                //
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

        builder.interceptors.toImmutableList()
    
      /**
       * Returns an immutable list of interceptors that observe a single network request and response.
       * These interceptors must call [Interceptor.Chain.proceed] exactly once: it is an error for
       * a network interceptor to short-circuit or repeat a network request.
       */
      @get:JvmName("networkInterceptors")
      val networkInterceptors: List<Interceptor> =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
Back to top