Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for endIndex (0.19 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/-UtilCommon.kt

    internal fun String.indexOfFirstNonAsciiWhitespace(
      startIndex: Int = 0,
      endIndex: Int = length,
    ): Int {
      for (i in startIndex until endIndex) {
        when (this[i]) {
          '\t', '\n', '\u000C', '\r', ' ' -> Unit
          else -> return i
        }
      }
      return endIndex
    }
    
    /**
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon May 13 13:42:37 UTC 2024
    - 11K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval.go

    }
    
    func (wci *watchCacheInterval) fillBuffer() {
    	wci.buffer.startIndex = 0
    	wci.buffer.endIndex = 0
    	for wci.startIndex < wci.endIndex && !wci.buffer.isFull() {
    		event := wci.indexer(wci.startIndex)
    		if event == nil {
    			break
    		}
    		wci.buffer.buffer[wci.buffer.endIndex] = event
    		wci.buffer.endIndex++
    		wci.startIndex++
    	}
    }
    
    const bufferSize = 100
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval_test.go

    }
    
    func TestIntervalBufferIsFull(t *testing.T) {
    	cases := []struct {
    		endIndex int
    		expected bool
    	}{
    		{endIndex: bufferSize - 1, expected: false},
    		{endIndex: bufferSize, expected: true},
    		{endIndex: bufferSize + 1, expected: true},
    	}
    
    	for _, c := range cases {
    		wcib := &watchCacheIntervalBuffer{endIndex: c.endIndex}
    		actual := wcib.isFull()
    		if actual != c.expected {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  4. src/encoding/pem/pem.go

    			rest = next
    		}
    
    		var endIndex, endTrailerIndex int
    
    		// If there were no headers, the END line might occur
    		// immediately, without a leading newline.
    		if len(p.Headers) == 0 && bytes.HasPrefix(rest, pemEnd[1:]) {
    			endIndex = 0
    			endTrailerIndex = len(pemEnd) - 1
    		} else {
    			endIndex = bytes.Index(rest, pemEnd)
    			endTrailerIndex = endIndex + len(pemEnd)
    		}
    
    		if endIndex < 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go

    	// cache is used a cyclic buffer - the "current" contents of it are
    	// stored in [start_index%capacity, end_index%capacity) - so the
    	// "current" contents have exactly end_index-start_index items.
    	cache      []*watchCacheEvent
    	startIndex int
    	endIndex   int
    	// removedEventSinceRelist holds the information whether any of the events
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 10:20:57 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  6. platforms/core-runtime/logging/src/main/java/org/gradle/internal/featurelifecycle/LoggingDeprecatedFeatureHandler.java

            final String lineSeparator = SystemProperties.getInstance().getLineSeparator();
    
            int endIndex = Math.min(stack.size(), endIndexExclusive);
            if (isTraceLoggingEnabled()) {
                // append full stack trace
                for (int i = startIndexInclusive; i < endIndex; ++i) {
                    StackTraceElement frame = stack.get(i);
                    appendStackTraceElement(frame, message, lineSeparator);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 13:09:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  7. helm/minio/templates/statefulset.yaml

                "-ce",
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Apr 26 07:50:24 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go

    			}
    
    			// check cache's startIndex, endIndex and all elements.
    			if store.startIndex != test.expectStartIndex {
    				t.Errorf("expect startIndex %d, but get %d", test.expectStartIndex, store.startIndex)
    			}
    			if store.endIndex != test.startIndex+test.eventCount {
    				t.Errorf("expect endIndex %d get %d", test.startIndex+test.eventCount, store.endIndex)
    			}
    			if !checkCacheElements(store) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/Cookie.kt

        ): Cookie? {
          val cookiePairEnd = setCookie.delimiterOffset(';')
    
          val pairEqualsSign = setCookie.delimiterOffset('=', endIndex = cookiePairEnd)
          if (pairEqualsSign == cookiePairEnd) return null
    
          val cookieName = setCookie.trimSubstring(endIndex = pairEqualsSign)
          if (cookieName.isEmpty() || cookieName.indexOfControlOrNonAscii() != -1) return null
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 06 04:12:05 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  10. helm-releases/minio-5.0.15.tgz

    .Values.image.pullPolicy }} command: [ "/bin/sh", "-ce", "/usr/bin/docker-entrypoint.sh minio server {{- range $i := until $poolCount }}{{ $factor := mul $i $nodeCount }}{{ $endIndex := add $factor $nodeCount }}{{ $beginIndex := mul $i $nodeCount }} {{ $scheme }}://{{ template `minio.fullname` $ }}-{{ `{` }}{{ $beginIndex }}...{{ sub $endIndex 1 }}{{ `}`}}.{{ template `minio.fullname` $ }}-svc.{{ $.Release.Namespace }}.svc.{{ $.Values.clusterDomain }}{{if (gt $drivesPerNode 1)}}{{ $bucketRoot }}-{{ `{` }}0...{{...
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jan 12 18:18:57 UTC 2024
    - 20.8K bytes
    - Viewed (0)
Back to top