Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 47 for skipLen (0.08 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/encryption-v1_test.go

    	// `isFromEnd` is true, `skipLen` argument is ignored.
    	decryptedRangeRef := func(s []int64, skipLen, readLen int64, isFromEnd bool) (o, l, skip int64, sn uint32, ps int) {
    		oSize := lsum(s)
    		if isFromEnd {
    			skipLen = oSize - readLen
    		}
    		if skipLen < 0 || readLen < 0 || oSize < 0 || skipLen+readLen > oSize {
    			t.Fatalf("Impossible read specified: %d %d %d", skipLen, readLen, oSize)
    		}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19.9K bytes
    - Click Count (0)
  2. cmd/encryption-v1.go

    func (o *ObjectInfo) GetDecryptedRange(rs *HTTPRangeSpec) (encOff, encLength, skipLen int64, seqNumber uint32, partStart int, err error) {
    	if _, ok := crypto.IsEncrypted(o.UserDefined); !ok {
    		err = errors.New("Object is not encrypted")
    		return encOff, encLength, skipLen, seqNumber, partStart, err
    	}
    
    	if rs == nil {
    		// No range, so offsets refer to the whole object.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 38K bytes
    - Click Count (0)
  3. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlanExecutor.java

                    boolean anyPredecessorFailed = step.predecessors.stream().anyMatch(s -> s.status.get() == FAILED);
    
                    // If any predecessor failed, we'll use a special status transition: CREATED -> SKIPPED
                    // This ensures the step runs for cleanup but is marked as skipped in the end
                    if (shouldExecute && anyPredecessorFailed) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Oct 16 06:12:36 GMT 2025
    - 55.1K bytes
    - Click Count (0)
  4. .github/workflows/arm-cd.yml

          - name: Checkout repository for nightly (skipped for releases)
            if: ${{ github.event_name == 'schedule' }}
            uses: actions/checkout@1af3b93b6815bc44a9784bd300feb67ff0d1eeb3 # v6.0.0
            with:
              ref: 'nightly'
          - name: Checkout repository for releases (skipped for nightly)
            if: ${{ github.event_name == 'push' }}
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Mon Dec 01 09:57:00 GMT 2025
    - 3K bytes
    - Click Count (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java

         * Skips over and discards {@code n} bytes of data from this input stream.
         * This method delegates to {@link FileInputStream#skip(long)}.
         *
         * @param n the number of bytes to be skipped
         * @return the actual number of bytes skipped
         * @throws IOException if an I/O error occurs.
         */
        @Override
        public long skip(final long n) throws IOException {
            return fileInputStream.skip(n);
        }
    
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sat Nov 22 13:28:22 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  6. docs/debugging/s3-check-md5/main.go

    				continue
    			}
    			if object.IsDeleteMarker {
    				log.Println("SKIPPED: DELETE marker object:", objFullPath(object))
    				continue
    			}
    			if _, ok := object.UserMetadata["X-Amz-Server-Side-Encryption-Customer-Algorithm"]; ok {
    				log.Println("SKIPPED: Objects encrypted with SSE-C do not have md5sum as ETag:", objFullPath(object))
    				continue
    			}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  7. cmd/background-newdisks-heal-ops.go

    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.Object = object
    }
    
    func (h *healingTracker) updateProgress(success, skipped bool, bytes uint64) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	switch {
    	case success:
    		h.ItemsHealed++
    		h.BytesDone += bytes
    	case skipped:
    		h.ItemsSkipped++
    		h.BytesSkipped += bytes
    	default:
    		h.ItemsFailed++
    		h.BytesFailed += bytes
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

              if (forgetMeNot == null || skipMe == null) {
                forgetMeNot = new ArrayDeque<>();
                skipMe = new ArrayList<>(3);
              }
              if (!foundAndRemovedExactReference(skipMe, moved.toTrickle)) {
                forgetMeNot.add(moved.toTrickle);
              }
              if (!foundAndRemovedExactReference(forgetMeNot, moved.replaced)) {
                skipMe.add(moved.replaced);
              }
            }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 33.9K bytes
    - Click Count (0)
  9. fess-crawler/src/test/java/org/codelibs/fess/crawler/util/IgnoreCloseInputStreamTest.java

            InputStream underlyingStream = new ByteArrayInputStream(data);
            IgnoreCloseInputStream stream = new IgnoreCloseInputStream(underlyingStream);
    
            long skipped = stream.skip(5);
            assertEquals(5, skipped);
            assertEquals('5', stream.read());
        }
    
        public void test_markSupported_delegatesToUnderlying() {
            // Test that markSupported() delegates to underlying stream
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sat Nov 22 13:28:22 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/IgnoreCloseInputStream.java

            inputStream.reset();
        }
    
        /**
         * Skips over and discards n bytes of data from this input stream.
         *
         * @param n the number of bytes to be skipped
         * @return the actual number of bytes skipped
         * @throws IOException if an I/O error occurs
         */
        @Override
        public long skip(final long n) throws IOException {
            return inputStream.skip(n);
        }
    
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sat Nov 22 13:28:22 GMT 2025
    - 4.7K bytes
    - Click Count (0)
Back to Top