102 lines
3.7 KiB
Java
102 lines
3.7 KiB
Java
package io.grpc.internal;
|
|
|
|
import com.google.common.base.Preconditions;
|
|
import io.grpc.CallCredentials;
|
|
import io.grpc.CallOptions;
|
|
import io.grpc.ClientStreamTracer;
|
|
import io.grpc.Context;
|
|
import io.grpc.Metadata;
|
|
import io.grpc.MethodDescriptor;
|
|
import io.grpc.Status;
|
|
|
|
/* loaded from: classes6.dex */
|
|
final class MetadataApplierImpl extends CallCredentials.MetadataApplier {
|
|
private final CallOptions callOptions;
|
|
DelayedStream delayedStream;
|
|
boolean finalized;
|
|
private final MetadataApplierListener listener;
|
|
private final MethodDescriptor<?, ?> method;
|
|
private final Metadata origHeaders;
|
|
private ClientStream returnedStream;
|
|
private final ClientStreamTracer[] tracers;
|
|
private final ClientTransport transport;
|
|
private final Object lock = new Object();
|
|
private final Context ctx = Context.current();
|
|
|
|
/* loaded from: classes6.dex */
|
|
public interface MetadataApplierListener {
|
|
void onComplete();
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
|
public MetadataApplierImpl(ClientTransport clientTransport, MethodDescriptor<?, ?> methodDescriptor, Metadata metadata, CallOptions callOptions, MetadataApplierListener metadataApplierListener, ClientStreamTracer[] clientStreamTracerArr) {
|
|
this.transport = clientTransport;
|
|
this.method = methodDescriptor;
|
|
this.origHeaders = metadata;
|
|
this.callOptions = callOptions;
|
|
this.listener = metadataApplierListener;
|
|
this.tracers = clientStreamTracerArr;
|
|
}
|
|
|
|
@Override // io.grpc.CallCredentials.MetadataApplier
|
|
public final void apply(Metadata metadata) {
|
|
Preconditions.checkState(!this.finalized, "apply() or fail() already called");
|
|
Preconditions.checkNotNull(metadata, "headers");
|
|
this.origHeaders.merge(metadata);
|
|
Context attach = this.ctx.attach();
|
|
try {
|
|
ClientStream newStream = this.transport.newStream(this.method, this.origHeaders, this.callOptions, this.tracers);
|
|
this.ctx.detach(attach);
|
|
finalizeWith(newStream);
|
|
} catch (Throwable th) {
|
|
this.ctx.detach(attach);
|
|
throw th;
|
|
}
|
|
}
|
|
|
|
@Override // io.grpc.CallCredentials.MetadataApplier
|
|
public final void fail(Status status) {
|
|
Preconditions.checkArgument(!status.isOk(), "Cannot fail with OK status");
|
|
Preconditions.checkState(!this.finalized, "apply() or fail() already called");
|
|
finalizeWith(new FailingClientStream(status, this.tracers));
|
|
}
|
|
|
|
private void finalizeWith(ClientStream clientStream) {
|
|
boolean z;
|
|
Preconditions.checkState(!this.finalized, "already finalized");
|
|
this.finalized = true;
|
|
synchronized (this.lock) {
|
|
if (this.returnedStream == null) {
|
|
this.returnedStream = clientStream;
|
|
z = true;
|
|
} else {
|
|
z = false;
|
|
}
|
|
}
|
|
if (z) {
|
|
this.listener.onComplete();
|
|
return;
|
|
}
|
|
Preconditions.checkState(this.delayedStream != null, "delayedStream is null");
|
|
Runnable stream = this.delayedStream.setStream(clientStream);
|
|
if (stream != null) {
|
|
stream.run();
|
|
}
|
|
this.listener.onComplete();
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
|
public final ClientStream returnStream() {
|
|
synchronized (this.lock) {
|
|
ClientStream clientStream = this.returnedStream;
|
|
if (clientStream != null) {
|
|
return clientStream;
|
|
}
|
|
DelayedStream delayedStream = new DelayedStream();
|
|
this.delayedStream = delayedStream;
|
|
this.returnedStream = delayedStream;
|
|
return delayedStream;
|
|
}
|
|
}
|
|
}
|