Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 410 for Callbacks (0.05 sec)

  1. misc/go_android_exec/main.go

    		gorootPath = runtime.GOROOT()
    		if gorootPath != "" {
    			return
    		}
    
    		// runtime.GOROOT is empty — perhaps go_android_exec was built with
    		// -trimpath and GOROOT is unset. Try 'go env GOROOT' as a fallback,
    		// assuming that the 'go' command in $PATH is the correct one.
    
    		cmd := exec.Command("go", "env", "GOROOT")
    		cmd.Stderr = os.Stderr
    		out, err := cmd.Output()
    		if err != nil {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Aug 21 17:46:57 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  2. cmd/bucket-metadata-sys.go

    	}
    
    	meta, err := loadBucketMetadataParse(ctx, objAPI, bucket, parse)
    	if err != nil {
    		if !globalIsErasure && !globalIsDistErasure && errors.Is(err, errVolumeNotFound) {
    			// Only single drive mode needs this fallback.
    			meta = newBucketMetadata(bucket)
    		} else {
    			return updatedAt, err
    		}
    	}
    	updatedAt = UTCNow()
    	switch configFile {
    	case bucketPolicyConfig:
    		meta.PolicyConfigJSON = configData
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  3. docs/smb3-features/01-smb3-lease-design.md

        } catch (TimeoutException e) {
            // Force lease release if break handling times out
            releaseLease(key);
            log.warn("Lease break timeout for key: {}", key);
        }
    }
    ```
    
    ### 10.2 Fallback to Oplocks
    ```java
    if (!context.getConfig().isUseLeases() || !session.supports(SMB3_0)) {
        // Fall back to traditional oplock mechanism
        useOplockInstead();
    }
    ```
    
    ## 11. Monitoring and Metrics
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 22K bytes
    - Viewed (0)
  4. 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.
       */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

            if (startBracket != -1 && endBracket != -1 && endBracket > startBracket) {
                return transportStr.substring(startBracket + 1, endBracket);
            }
            // Fallback: just use address
            return transport.getRemoteAddress().getHostAddress();
        }
    
        /**
         * Get connection key from address and port
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbTreeConnection.java

            try (SmbSessionImpl treesess = t.getSession()) {
                if (treesess.getCredentials().isAnonymous() || treesess.getCredentials().isGuest()) {
                    // refresh anonymous session or fallback to anonymous from guest login
                    try (SmbSessionInternal s =
                            trans.getSmbSession(this.ctx.withAnonymousCredentials(), treesess.getTargetHost(), treesess.getTargetDomain())
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 30.4K bytes
    - Viewed (1)
  7. 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
    	evictList *LruList[K, V]
    	items     map[K]*Entry[K, V]
    	onEvict   EvictCallback[K, V]
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/helper/OsddHelperTest.java

            final StreamResponse streamResponse = osddHelper.asStream();
            assertEquals("text/xml; charset=UTF-8", streamResponse.getContentType());
            streamResponse.getStreamCall().callback(new WrittenStreamOut() {
    
                @Override
                public void write(final InputStream ins) throws IOException {
                    assertEquals("""
                            <?xml version="1.0" encoding="UTF-8"?>
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 19 23:49:30 UTC 2025
    - 23.9K bytes
    - Viewed (0)
  9. 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
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 36.2K bytes
    - Viewed (0)
  10. 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
                }
            }
        }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 31.4K bytes
    - Viewed (0)
Back to top