META-INF/
META-INF/MANIFEST.MF
io/
io/grpc/
io/grpc/Context$1.classContext.java
package io.grpc
final io.grpc.Context$1 extends java.lang.ThreadLocal {
void ()
protected io.grpc.Context initialValue ()
protected volatile java.lang.Object initialValue ()
}
io/grpc/Context$2.classContext.java
package io.grpc
io.grpc.Context$2 extends java.lang.Object implements java.lang.Runnable {
final Runnable val$r
final io.grpc.Context this$0
void (io.grpc.Context, java.lang.Runnable)
io.grpc.Context this$0
public void run ()
io.grpc.Context previous
}
io/grpc/Context$3.classContext.java
package io.grpc
io.grpc.Context$3 extends java.lang.Object implements java.util.concurrent.Callable {
final java.util.concurrent.Callable val$c
final io.grpc.Context this$0
void (io.grpc.Context, java.util.concurrent.Callable)
io.grpc.Context this$0
public java.lang.Object call () throws java.lang.Exception
io.grpc.Context previous
}
io/grpc/Context$1FixedContextExecutor.classContext.java
package io.grpc
io.grpc.Context$1FixedContextExecutor extends java.lang.Object implements java.util.concurrent.Executor {
final java.util.concurrent.Executor val$e
final io.grpc.Context this$0
void (io.grpc.Context, java.util.concurrent.Executor)
io.grpc.Context this$0
public void execute (java.lang.Runnable)
Runnable r
}
io/grpc/Context$1CurrentContextExecutor.classContext.java
package io.grpc
io.grpc.Context$1CurrentContextExecutor extends java.lang.Object implements java.util.concurrent.Executor {
final java.util.concurrent.Executor val$e
void (java.util.concurrent.Executor)
public void execute (java.lang.Runnable)
Runnable r
}
io/grpc/Context$CancellableContext$1.classContext.java
package io.grpc
io.grpc.Context$CancellableContext$1 extends java.lang.Object implements java.lang.Runnable {
final java.util.concurrent.TimeoutException val$cause
final io.grpc.Context$CancellableContext this$0
void (io.grpc.Context$CancellableContext, java.util.concurrent.TimeoutException)
io.grpc.Context$CancellableContext this$0
public void run ()
}
io/grpc/Context$CancellableContext.classContext.java
package io.grpc
public final io.grpc.Context$CancellableContext extends io.grpc.Context {
private boolean cancelled
private Throwable cancellationCause
private final io.grpc.Context uncancellableSurrogate
private java.util.concurrent.ScheduledFuture pendingDeadline
private static java.lang.Object[][] deriveDeadline (io.grpc.Context, io.grpc.Deadline)
io.grpc.Context parent
io.grpc.Deadline deadline
io.grpc.Deadline parentDeadline
private void (io.grpc.Context)
io.grpc.Context parent
private void (io.grpc.Context, io.grpc.Deadline, java.util.concurrent.ScheduledExecutorService)
java.util.concurrent.TimeoutException cause
io.grpc.Context parent
io.grpc.Deadline deadline
java.util.concurrent.ScheduledExecutorService scheduler
public io.grpc.Context attach ()
public void detach (io.grpc.Context)
io.grpc.Context toAttach
public boolean isCurrent ()
public boolean cancel (java.lang.Throwable)
Throwable cause
boolean triggeredCancel
public void detachAndCancel (io.grpc.Context, java.lang.Throwable)
io.grpc.Context toAttach
Throwable cause
public boolean isCancelled ()
public java.lang.Throwable cancellationCause ()
void (io.grpc.Context, io.grpc.Context$1)
io.grpc.Context x0
io.grpc.Context$1 x1
void (io.grpc.Context, io.grpc.Deadline, java.util.concurrent.ScheduledExecutorService, io.grpc.Context$1)
io.grpc.Context x0
io.grpc.Deadline x1
java.util.concurrent.ScheduledExecutorService x2
io.grpc.Context$1 x3
}
io/grpc/Context$CancellationListener.classContext.java
package io.grpc
public abstract io.grpc.Context$CancellationListener extends java.lang.Object {
public abstract void cancelled (io.grpc.Context)
}
io/grpc/Context$Key.classContext.java
package io.grpc
public io.grpc.Context$Key extends java.lang.Object {
private final String name
private final Object defaultValue
void (java.lang.String)
String name
void (java.lang.String, java.lang.Object)
String name
Object defaultValue
public java.lang.Object get ()
public java.lang.Object get (io.grpc.Context)
io.grpc.Context context
Object value
public java.lang.String toString ()
}
io/grpc/Context$ExecutableListener.classContext.java
package io.grpc
io.grpc.Context$ExecutableListener extends java.lang.Object implements java.lang.Runnable {
private final java.util.concurrent.Executor executor
private final io.grpc.Context$CancellationListener listener
final io.grpc.Context this$0
private void (io.grpc.Context, java.util.concurrent.Executor, io.grpc.Context$CancellationListener)
java.util.concurrent.Executor executor
io.grpc.Context$CancellationListener listener
private void deliver ()
Throwable t
public void run ()
void (io.grpc.Context, java.util.concurrent.Executor, io.grpc.Context$CancellationListener, io.grpc.Context$1)
io.grpc.Context x0
java.util.concurrent.Executor x1
io.grpc.Context$CancellationListener x2
io.grpc.Context$1 x3
static void access$400 (io.grpc.Context$ExecutableListener)
io.grpc.Context$ExecutableListener x0
static io.grpc.Context$CancellationListener access$500 (io.grpc.Context$ExecutableListener)
io.grpc.Context$ExecutableListener x0
}
io/grpc/Context$ParentListener.classContext.java
package io.grpc
io.grpc.Context$ParentListener extends java.lang.Object implements io.grpc.Context$CancellationListener {
final io.grpc.Context this$0
private void (io.grpc.Context)
public void cancelled (io.grpc.Context)
io.grpc.Context context
void (io.grpc.Context, io.grpc.Context$1)
io.grpc.Context x0
io.grpc.Context$1 x1
}
io/grpc/Context$DirectExecutor.classContext.java
package io.grpc
final io.grpc.Context$DirectExecutor extends java.lang.Enum implements java.util.concurrent.Executor {
public static final io.grpc.Context$DirectExecutor INSTANCE
private static final io.grpc.Context$DirectExecutor[] $VALUES
public static io.grpc.Context$DirectExecutor[] values ()
public static io.grpc.Context$DirectExecutor valueOf (java.lang.String)
String name
private void (java.lang.String, int)
public void execute (java.lang.Runnable)
Runnable command
public java.lang.String toString ()
static void ()
}
io/grpc/Context.classContext.java
package io.grpc
public io.grpc.Context extends java.lang.Object {
private static final java.util.logging.Logger LOG
private static final Object[][] EMPTY_ENTRIES
private static final io.grpc.Context$Key DEADLINE_KEY
public static final io.grpc.Context ROOT
private static final ThreadLocal localContext
private final io.grpc.Context parent
private final Object[][] keyValueEntries
private final boolean cascadesCancellation
private java.util.ArrayList listeners
private io.grpc.Context$CancellationListener parentListener
private final boolean canBeCancelled
public static io.grpc.Context$Key key (java.lang.String)
String name
public static io.grpc.Context$Key keyWithDefault (java.lang.String, java.lang.Object)
String name
Object defaultValue
public static io.grpc.Context current ()
io.grpc.Context current
private void (io.grpc.Context)
io.grpc.Context parent
private void (io.grpc.Context, java.lang.Object[][])
io.grpc.Context parent
Object[][] keyValueEntries
private void (io.grpc.Context, java.lang.Object[][], boolean)
io.grpc.Context parent
Object[][] keyValueEntries
boolean isCancellable
public io.grpc.Context$CancellableContext withCancellation ()
public io.grpc.Context$CancellableContext withDeadlineAfter (long, java.util.concurrent.TimeUnit, java.util.concurrent.ScheduledExecutorService)
long duration
java.util.concurrent.TimeUnit unit
java.util.concurrent.ScheduledExecutorService scheduler
public io.grpc.Context$CancellableContext withDeadline (io.grpc.Deadline, java.util.concurrent.ScheduledExecutorService)
io.grpc.Deadline deadline
java.util.concurrent.ScheduledExecutorService scheduler
public io.grpc.Context withValue (io.grpc.Context$Key, java.lang.Object)
io.grpc.Context$Key k1
Object v1
public io.grpc.Context withValues (io.grpc.Context$Key, java.lang.Object, io.grpc.Context$Key, java.lang.Object)
io.grpc.Context$Key k1
Object v1
io.grpc.Context$Key k2
Object v2
public io.grpc.Context withValues (io.grpc.Context$Key, java.lang.Object, io.grpc.Context$Key, java.lang.Object, io.grpc.Context$Key, java.lang.Object)
io.grpc.Context$Key k1
Object v1
io.grpc.Context$Key k2
Object v2
io.grpc.Context$Key k3
Object v3
public io.grpc.Context fork ()
boolean canBeCancelled ()
public io.grpc.Context attach ()
io.grpc.Context previous
public void detach (io.grpc.Context)
io.grpc.Context toAttach
boolean isCurrent ()
public boolean isCancelled ()
public java.lang.Throwable cancellationCause ()
public io.grpc.Deadline getDeadline ()
public void addListener (io.grpc.Context$CancellationListener, java.util.concurrent.Executor)
io.grpc.Context$ExecutableListener executableListener
io.grpc.Context$CancellationListener cancellationListener
java.util.concurrent.Executor executor
public void removeListener (io.grpc.Context$CancellationListener)
int i
io.grpc.Context$CancellationListener cancellationListener
void notifyAndClearListeners ()
int i
int i
java.util.ArrayList tmpListeners
int listenerCount ()
public void run (java.lang.Runnable)
Runnable r
io.grpc.Context previous
public java.lang.Object call (java.util.concurrent.Callable) throws java.lang.Exception
java.util.concurrent.Callable c
io.grpc.Context previous
public java.lang.Runnable wrap (java.lang.Runnable)
Runnable r
public java.util.concurrent.Callable wrap (java.util.concurrent.Callable)
java.util.concurrent.Callable c
public java.util.concurrent.Executor fixedContextExecutor (java.util.concurrent.Executor)
java.util.concurrent.Executor e
public static java.util.concurrent.Executor currentContextExecutor (java.util.concurrent.Executor)
java.util.concurrent.Executor e
private java.lang.Object lookup (io.grpc.Context$Key)
int i
io.grpc.Context$Key key
private static java.lang.Object checkNotNull (java.lang.Object, java.lang.Object)
Object reference
Object errorMessage
static io.grpc.Context$Key access$600 ()
static java.lang.Object[][] access$700 ()
void (io.grpc.Context, java.lang.Object[][], boolean, io.grpc.Context$1)
io.grpc.Context x0
Object[][] x1
boolean x2
io.grpc.Context$1 x3
void (io.grpc.Context, java.lang.Object[][], io.grpc.Context$1)
io.grpc.Context x0
Object[][] x1
io.grpc.Context$1 x2
static java.lang.Object access$1000 (java.lang.Object, java.lang.Object)
Object x0
Object x1
static java.lang.Object access$1100 (io.grpc.Context, io.grpc.Context$Key)
io.grpc.Context x0
io.grpc.Context$Key x1
static java.util.logging.Logger access$1200 ()
static void ()
}
io/grpc/Deadline$Ticker.classDeadline.java
package io.grpc
abstract io.grpc.Deadline$Ticker extends java.lang.Object {
void ()
public abstract long read ()
}
io/grpc/Deadline$SystemTicker.classDeadline.java
package io.grpc
io.grpc.Deadline$SystemTicker extends io.grpc.Deadline$Ticker {
private void ()
public long read ()
void (io.grpc.Deadline$1)
io.grpc.Deadline$1 x0
}
io/grpc/Deadline$LogExceptionRunnable.classDeadline.java
package io.grpc
io.grpc.Deadline$LogExceptionRunnable extends java.lang.Object implements java.lang.Runnable {
private static final java.util.logging.Logger log
private final Runnable task
public void (java.lang.Runnable)
Runnable task
public void run ()
Throwable t
public java.lang.String toString ()
static void ()
}
io/grpc/Deadline$1.classDeadline.java
package io.grpc
io.grpc.Deadline$1 extends java.lang.Object {
}
io/grpc/Deadline.classDeadline.java
package io.grpc
public final io.grpc.Deadline extends java.lang.Object implements java.lang.Comparable {
private static final io.grpc.Deadline$SystemTicker SYSTEM_TICKER
private static final long MAX_OFFSET
private static final long MIN_OFFSET
private final io.grpc.Deadline$Ticker ticker
private final long deadlineNanos
private volatile boolean expired
public static io.grpc.Deadline after (long, java.util.concurrent.TimeUnit)
long duration
java.util.concurrent.TimeUnit units
static io.grpc.Deadline after (long, java.util.concurrent.TimeUnit, io.grpc.Deadline$Ticker)
long duration
java.util.concurrent.TimeUnit units
io.grpc.Deadline$Ticker ticker
private void (io.grpc.Deadline$Ticker, long, boolean)
io.grpc.Deadline$Ticker ticker
long offset
boolean baseInstantAlreadyExpired
private void (io.grpc.Deadline$Ticker, long, long, boolean)
io.grpc.Deadline$Ticker ticker
long baseInstant
long offset
boolean baseInstantAlreadyExpired
public boolean isExpired ()
public boolean isBefore (io.grpc.Deadline)
io.grpc.Deadline other
public io.grpc.Deadline minimum (io.grpc.Deadline)
io.grpc.Deadline other
public io.grpc.Deadline offset (long, java.util.concurrent.TimeUnit)
long offset
java.util.concurrent.TimeUnit units
public long timeRemaining (java.util.concurrent.TimeUnit)
java.util.concurrent.TimeUnit unit
long nowNanos
public java.util.concurrent.ScheduledFuture runOnExpiration (java.lang.Runnable, java.util.concurrent.ScheduledExecutorService)
Runnable task
java.util.concurrent.ScheduledExecutorService scheduler
public java.lang.String toString ()
public int compareTo (io.grpc.Deadline)
io.grpc.Deadline that
long diff
private static java.lang.Object checkNotNull (java.lang.Object, java.lang.Object)
Object reference
Object errorMessage
public volatile int compareTo (java.lang.Object)
static java.lang.Object access$100 (java.lang.Object, java.lang.Object)
Object x0
Object x1
static void ()
}