Search Options

Results per page
Sort
Preferred Languages
Advance

Results 501 - 510 of 1,269 for afterFn (0.03 sec)

  1. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/MetadataResolutionResult.java

    import org.codehaus.plexus.PlexusContainer;
    import org.codehaus.plexus.component.repository.exception.ComponentLookupException;
    
    /**
     * This object is tinted with ClasspathTransformation and GraphConflictResolver.
     * Get rid of them after debugging
     *
     */
    @Deprecated
    public class MetadataResolutionResult {
        MetadataTreeNode treeRoot;
    
        /**
         * these components are initialized on demand by
         * explicit call of the initTreeProcessing()
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  2. buildscripts/minio-upgrade.sh

    	docker volume rm $(docker volume ls -q -f dangling=true) || true
    }
    
    verify_checksum_after_heal() {
    	local sum1
    	sum1=$(curl -s "$2" | sha256sum)
    	mc admin heal --json -r "$1" >/dev/null # test after healing
    	local sum1_heal
    	sum1_heal=$(curl -s "$2" | sha256sum)
    
    	if [ "${sum1_heal}" != "${sum1}" ]; then
    		echo "mismatch expected ${sum1_heal}, got ${sum1}"
    		exit 1
    	fi
    }
    
    verify_checksum_mc() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Apr 21 16:24:31 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  3. cmd/tier-last-day-stats.go

    	}
    	copy(clone.Bins[:], l.Bins[:])
    	return clone
    }
    
    func (l lastDayTierStats) merge(m lastDayTierStats) (merged lastDayTierStats) {
    	cl := l.clone()
    	cm := m.clone()
    
    	if cl.UpdatedAt.After(cm.UpdatedAt) {
    		cm.forwardTo(cl.UpdatedAt)
    		merged.UpdatedAt = cl.UpdatedAt
    	} else {
    		cl.forwardTo(cm.UpdatedAt)
    		merged.UpdatedAt = cm.UpdatedAt
    	}
    
    	for i := range cl.Bins {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractService.java

      /**
       * This method is called by {@link #startAsync} to initiate service startup. The invocation of
       * this method should cause a call to {@link #notifyStarted()}, either during this method's run,
       * or after it has returned. If startup fails, the invocation should cause a call to {@link
       * #notifyFailed(Throwable)} instead.
       *
       * <p>This method should return promptly; prefer to do work on a different thread where it is
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/xml/ParametricNullness.java

     *       annotations that {@code ParametricNullness} was counteracting.
     * </ul>
     *
     * <p>This annotation is a temporary hack. We will remove it after <a
     * href="https://github.com/google/guava/issues/6126#issuecomment-1203145963">tools no longer need
     * it</a>.
     */
    @GwtCompatible
    @Retention(CLASS)
    @Target({FIELD, METHOD, PARAMETER})
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 16:20:21 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/io/ParametricNullness.java

     *       annotations that {@code ParametricNullness} was counteracting.
     * </ul>
     *
     * <p>This annotation is a temporary hack. We will remove it after <a
     * href="https://github.com/google/guava/issues/6126#issuecomment-1203145963">tools no longer need
     * it</a>.
     */
    @GwtCompatible
    @Retention(CLASS)
    @Target({FIELD, METHOD, PARAMETER})
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 16:20:21 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  7. internal/s3select/jstream/scanner_test.go

    		}
    		if c != mockData {
    			t.Fatalf("expected \"%s\", got \"%s\"", string(mockData), string(c))
    		}
    		i++
    	}
    	c := scanner.next()
    	if scanner.readerErr == nil {
    		t.Fatalf("failed to receive expected error after %d bytes", failAfter)
    	}
    	if c != byte(0) {
    		t.Fatalf("expected null byte, got %v", c)
    	}
    }
    
    func BenchmarkBufioScanner(b *testing.B) {
    	b.Run("small", func(b *testing.B) {
    		for b.Loop() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  8. cmd/object-api-datatypes.go

    type ListMultipartsInfo struct {
    	// Together with upload-id-marker, this parameter specifies the multipart upload
    	// after which listing should begin.
    	KeyMarker string
    
    	// Together with key-marker, specifies the multipart upload after which listing
    	// should begin. If key-marker is not specified, the upload-id-marker parameter
    	// is ignored.
    	UploadIDMarker string
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  9. src/test/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaProviderTest.java

            assertFalse(region.hasAccess(RdmaAccess.REMOTE_READ), "Should not have remote read access");
    
            // Test cleanup
            region.close();
            assertFalse(region.isValid(), "Region should be invalid after close");
        }
    
        @Test
        public void testGetProviderName() {
            assertEquals("TCP Fallback", provider.getProviderName());
        }
    
        @Test
        public void testGetMaxMessageSize() {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

              break;
            }
            interruptee.interrupt();
          }
        }
    
        void stopInterrupting() {
          shouldStop = true;
        }
      }
    
      /** Interrupts the current thread after sleeping for the specified delay. */
      static void requestInterruptIn(long time, TimeUnit unit) {
        checkNotNull(unit);
        Thread interruptee = Thread.currentThread();
        new Thread(
                new Runnable() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
Back to top