Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 448 for FAILURE (0.08 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        @Override
        protected void doStart() {
          notifyFailed(new IllegalStateException("start failure"));
        }
      }
    
      private static class FailRunService extends NoOpService {
        @Override
        protected void doStart() {
          super.doStart();
          notifyFailed(new IllegalStateException("run failure"));
        }
      }
    
      private static class FailStopService extends NoOpService {
        @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 20:34:52 UTC 2025
    - 25.5K bytes
    - Viewed (0)
  2. mockwebserver/src/main/kotlin/mockwebserver3/internal/RecordedRequestFactory.kt

        target = requestLine.target,
        version = requestLine.version,
        url = requestUrl,
        headers = headers,
        body = body,
        bodySize = bodySize,
        chunkSizes = chunkSizes,
        failure = failure,
      )
    }
    
    internal fun decodeRequestLine(requestLine: String?): RequestLine {
      val parts =
        when {
          requestLine != null -> requestLine.split(' ', limit = 3)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 12:43:16 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  3. futures/failureaccess/src/com/google/common/util/concurrent/internal/InternalFutureFailureAccess.java

      /** Constructor for use by subclasses. */
      protected InternalFutureFailureAccess() {}
    
      /**
       * Usually returns {@code null} but, if this {@code Future} has failed, may <i>optionally</i>
       * return the cause of the failure. "Failure" means specifically "completed with an exception"; it
       * does not include "was cancelled." To be explicit: If this method returns a non-null value,
       * then:
       *
       * <ul>
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Jan 18 02:54:30 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractService.java

          checkArgument(
              (failure != null) == (internalState == FAILED),
              "A failure cause should be set if and only if the state is failed.  Got %s and %s "
                  + "instead.",
              internalState,
              failure);
          this.state = internalState;
          this.shutdownWhenStartupFinishes = shutdownWhenStartupFinishes;
          this.failure = failure;
        }
    
        /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java

                }
            });
    
            handle.setNotificationFuture(future);
        }
    
        /**
         * Determine optimal polling interval based on directory activity and failure count
         *
         * Current strategy is based on failure count. In the future, this could be enhanced to consider:
         * - Recent event frequency (successful notifications)
         * - Time since last successful notification
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 13.7K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        assertTrue(future.setException(new Exception("failure")));
        tester.testFailedFuture("failure");
      }
    
      public void testSetFailureNull() throws Exception {
        assertThrows(NullPointerException.class, () -> future.setException(null));
        assertFalse(future.isDone());
        assertTrue(future.setException(new Exception("failure")));
        tester.testFailedFuture("failure");
      }
    
      public void testCancel() throws Exception {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java

                t.setDaemon(true);
                return t;
            });
            this.failoverStates = new ConcurrentHashMap<>();
        }
    
        /**
         * Handle channel failure
         *
         * @param failedChannel failed channel
         * @param error error that caused failure
         */
        public void handleFailure(ChannelInfo failedChannel, Exception error) {
            log.warn("Channel {} failed: {}", failedChannel.getChannelId(), error.getMessage());
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/base/Throwables.java

       *   try {
       *     foo.bar();
       *   } catch (BarException | RuntimeException | Error t) {
       *     failure = t;
       *   }
       * }
       * if (failure != null) {
       *   throwIfInstanceOf(failure, BarException.class);
       *   throwIfUnchecked(failure);
       *   throw new AssertionError(failure);
       * }
       * </pre>
       *
       * @since 20.0
       */
      @GwtIncompatible // Class.cast, Class.isInstance
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/app/web/api/admin/suggest/ApiAdminSuggestAction.java

        }
    
        /**
         * Deletes all suggest words from the system.
         *
         * @return JSON response indicating success or failure
         */
        // DELETE /api/admin/suggest/all
        @Execute
        public JsonResponse<ApiResult> delete$all() {
            if (!suggestHelper.deleteAllWords()) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  10. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt

        drainCancelQueue(eventSource)
      }
    
      override fun onFailure(
        eventSource: EventSource,
        t: Throwable?,
        response: Response?,
      ) {
        get().log("[ES] onFailure", Platform.INFO, t)
        events.add(Failure(t, response, t?.message ?: response?.body?.string()))
        drainCancelQueue(eventSource)
      }
    
      private fun drainCancelQueue(eventSource: EventSource) {
        if (cancel) {
          cancel = false
          eventSource.cancel()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:32:52 UTC 2025
    - 3.2K bytes
    - Viewed (0)
Back to top