Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for notifyFailed (0.05 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractService.java

       * 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
       * convenient. It is invoked exactly once on service startup, even when {@link #startAsync} is
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

              toReturn = new FutureAsCancellable(immediateCancelledFuture());
            } finally {
              lock.unlock();
            }
            // Call notifyFailed outside the lock to avoid lock ordering issues.
            if (scheduleFailure != null) {
              service.notifyFailed(scheduleFailure);
            }
            return toReturn;
          }
    
          @GuardedBy("lock")
          /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractService.java

       * 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
       * convenient. It is invoked exactly once on service startup, even when {@link #startAsync} is
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

                          }
                          notifyFailed(t);
                          return;
                        }
                      }
    
                      shutDown();
                      notifyStopped();
                    } catch (Throwable t) {
                      restoreInterruptIfIsInterruptedException(t);
                      notifyFailed(t);
                    }
                  });
            }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

              toReturn = new FutureAsCancellable(immediateCancelledFuture());
            } finally {
              lock.unlock();
            }
            // Call notifyFailed outside the lock to avoid lock ordering issues.
            if (scheduleFailure != null) {
              service.notifyFailed(scheduleFailure);
            }
            return toReturn;
          }
    
          @GuardedBy("lock")
          /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  6. 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"));
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 20:34:52 UTC 2025
    - 25.5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

                          }
                          notifyFailed(t);
                          return;
                        }
                      }
    
                      shutDown();
                      notifyStopped();
                    } catch (Throwable t) {
                      restoreInterruptIfIsInterruptedException(t);
                      notifyFailed(t);
                    }
                  });
            }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.5K bytes
    - Viewed (0)
Back to top