Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 111 - 120 of 143 for propagated (0.13 seconds)

  1. docs/smb3-features/02-persistent-handles-design.md

                log.error("Failed to reconnect durable handle", reconnectError);
                throw new IOException("Connection lost and reconnection failed", e);
            }
        } else {
            throw e;  // No durable handle, propagate error
        }
    }
    ```
    
    ### 6.3 Session Integration
    ```java
    // In SmbSession.java
    private PersistentHandleManager handleManager;
    
    public SmbSession(CIFSContext context, SmbTransport transport) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 31.6K bytes
    - Click Count (0)
  2. src/test/java/org/codelibs/fess/exec/CrawlerTest.java

                // Should catch the exception and return EXIT_FAIL
                assertEquals(Constants.EXIT_FAIL, result);
            } catch (RuntimeException e) {
                // Expected behavior - test exception propagates
                assertEquals("Test exception", e.getMessage());
            }
        }
    
        // Test writeTimeToSessionInfo method
        @Test
        public void test_writeTimeToSessionInfo_withValidHelper() {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 30.8K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/graph/ValueGraphTest.java

                     * we read one of the fields declared in that class.
                     */
                    Set<Integer> unused = graph.successors(first);
                    return null; // so the lambda is a Callable to propagate checked await() exceptions
                  }));
        }
    
        // For more about this test, see the equivalent in AbstractNetworkTest.
        for (Future<?> future : futures.build()) {
          future.get();
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 20.5K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

        serverListener.assertFailure(EOFException::class.java)
        serverListener.assertExhausted()
        clientListener.assertFailure(e)
      }
    
      @Disabled("AsyncCall currently lets runtime exceptions propagate.")
      @Test
      @Throws(
        Exception::class,
      )
      fun throwingOnFailLogs() {
        webServer.enqueue(
          MockResponse
            .Builder()
            .code(200)
            .body("Body")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 35.5K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

          val lastGoodStreamId: Int
          withLock {
            if (isShutdown) {
              return
            }
            isShutdown = true
            lastGoodStreamId = this.lastGoodStreamId
          }
          // TODO: propagate exception message into debugData.
          // TODO: configure a timeout on the reader so that it doesn’t block forever.
          writer.goAway(lastGoodStreamId, statusCode, EMPTY_BYTE_ARRAY)
        }
      }
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 31.9K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

       *     fetchCounters().catchingAsync(
       *         FetchException.class, x -> immediateFuture(0), directExecutor());
       * }
       *
       * <p>The fallback can also choose to propagate the original exception when desired:
       *
       * {@snippet :
       * // Falling back to a zero counter only in case the exception was a
       * // TimeoutException.
       * ListenableFuture<Integer> faultTolerantFuture =
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 19.8K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

            // service or listener). Our contract says it is safe to call this method if
            // all services were NEW when it was called, and this has already been verified above, so we
            // don't propagate the exception.
            logger.get().log(Level.WARNING, "Unable to start Service " + service, e);
          }
        }
        return this;
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 33.2K bytes
    - Click Count (1)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

              WARN,
              journalIsCorrupt,
            )
          }
    
          // The cache is corrupted, attempt to delete the contents of the directory. This can throw and
          // we'll let that propagate out as it likely means there is a severe filesystem problem.
          try {
            delete()
          } finally {
            closed = false
          }
        }
    
        rebuildJournal()
    
        initialized = true
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 34.7K bytes
    - Click Count (0)
  9. cmd/common-main.go

    		return true
    	default:
    		return false
    	}
    }
    
    // bgContext returns a context that can be used for async operations.
    // Cancellation/timeouts are removed, so parent cancellations/timeout will
    // not propagate from parent.
    // Context values are preserved.
    // This can be used for goroutines that live beyond the parent context.
    func bgContext(parent context.Context) context.Context {
    	return bgCtx{parent: parent}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.5K bytes
    - Click Count (3)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        for (int i = 0; i < 100000; i++) {
          SettableFuture<String> curr = SettableFuture.create();
          prev.setFuture(curr);
          prev = curr;
        }
        // orig is the 'outermost future', this should propagate fully down the stack of futures.
        orig.cancel(true);
        assertTrue(orig.isCancelled());
        assertTrue(prev.isCancelled());
        assertTrue(prev.wasInterrupted());
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
Back to Top