Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 441 - 450 of 523 for Callback0 (0.14 seconds)

  1. impl/maven-core/src/main/java/org/apache/maven/ReactorReader.java

                            || isPackagedArtifactUpToDate(project, packagedArtifactFile))) {
                return packagedArtifactFile;
            }
    
            if (!hasBeenPackagedDuringThisSession(project)) {
                // fallback to loose class files only if artifacts haven't been packaged yet
                // and only for plain old jars. Not war files, not ear files, not anything else.
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Dec 15 11:20:38 GMT 2025
    - 24.4K bytes
    - Click Count (0)
  2. internal/lru/lru.go

    package lru
    
    // golang -lru
    // https://github.com/hashicorp/golang-lru
    import (
    	"sync"
    	"time"
    )
    
    // EvictCallback is used to get a callback when a cache entry is evicted
    type EvictCallback[K comparable, V any] func(key K, value V)
    
    // LRU implements a thread-safe LRU with expirable entries.
    type LRU[K comparable, V any] struct {
    	size      int
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 12.6K bytes
    - Click Count (0)
  3. docs/smb3-features/04-directory-leasing-design.md

                if (entry.getInconsistencyCount() > 5) {
                    entry.invalidate();
                }
            }
        }
    }
    ```
    
    ### 9.2 Fallback Mechanisms
    ```java
    public class DirectoryOperationFallback {
        public SmbFile[] safeListFiles(SmbFile directory) throws IOException {
            try {
                // Try cached listing first
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 36.2K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

      }
    
      /**
       * This tests for a bug where if {@link Service#stopAsync()} was called while the service was
       * {@link State#STARTING} more than once, the {@link Listener#stopping(State)} callback would get
       * called multiple times.
       */
      public void testManualServiceStopMultipleTimesWhileStarting() throws Exception {
        ManualSwitchedService service = new ManualSwitchedService();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 28.7K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

      }
    
      /**
       * This tests for a bug where if {@link Service#stopAsync()} was called while the service was
       * {@link State#STARTING} more than once, the {@link Listener#stopping(State)} callback would get
       * called multiple times.
       */
      public void testManualServiceStopMultipleTimesWhileStarting() throws Exception {
        ManualSwitchedService service = new ManualSwitchedService();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 28.7K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb/NtlmPasswordAuthenticator.java

             * Login with no credentials
             */
            NULL,
            /**
             * Guest authentication
             *
             * Allows login with invalid credentials (username and/or password)
             * Fallback to anonymous authentication is permitted
             */
            GUEST,
            /**
             * Regular user authentication
             */
            USER
        }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 30.3K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

        server.protocolNegotiationEnabled = true
        server.protocols = client.protocols
      }
    
      /**
       * Used during tests that involve TLS connection fallback attempts. OkHttp includes the
       * TLS_FALLBACK_SCSV cipher on fallback connections. See [FallbackTestClientSocketFactory]
       * for details.
       */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 133.3K bytes
    - Click Count (0)
  8. src/test/java/org/codelibs/fess/job/SuggestJobTest.java

                    org.dbflute.helper.jprop.JavaPropertiesResult result = reader.read();
                    propField.set(this, result);
                } catch (Exception e) {
                    // Fallback: ignore initialization errors since we override methods anyway
                }
            }
        }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 31.6K bytes
    - Click Count (0)
  9. internal/s3select/select.go

    	if s3Select.progressReader != nil {
    		return s3Select.progressReader.Stats()
    	}
    
    	return -1, -1
    }
    
    // Open - opens S3 object by using callback for SQL selection query.
    // Currently CSV, JSON and Apache Parquet formats are supported.
    func (s3Select *S3Select) Open(rsc io.ReadSeekCloser) error {
    	offset, length, err := s3Select.ScanRange.StartLen()
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  10. cmd/erasure-multipart.go

    				if split := strings.Split(string(b64), "x"); len(split) == 2 {
    					t, err := strconv.ParseInt(split[1], 10, 64)
    					if err == nil {
    						modTime = time.Unix(0, t)
    					}
    				}
    			}
    			// Fallback for older uploads without time in the ID.
    			if modTime.IsZero() {
    				wait := deleteMultipartCleanupSleeper.Timer(ctx)
    				fi, err := disk.ReadVersion(ctx, "", minioMetaMultipartBucket, uploadIDPath, "", ReadOptions{})
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
Back to Top