909 lines
34 KiB
Java
909 lines
34 KiB
Java
|
package io.grpc;
|
||
|
|
|
||
|
|
import com.google.common.base.MoreObjects;
|
||
|
|
import com.google.common.base.Objects;
|
||
|
|
import com.google.common.base.Preconditions;
|
||
|
|
import java.net.SocketAddress;
|
||
|
|
import java.security.cert.Certificate;
|
||
|
|
import java.util.ArrayList;
|
||
|
|
import java.util.Collections;
|
||
|
|
import java.util.HashMap;
|
||
|
|
import java.util.Iterator;
|
||
|
|
import java.util.List;
|
||
|
|
import java.util.Map;
|
||
|
|
import java.util.concurrent.ConcurrentHashMap;
|
||
|
|
import java.util.concurrent.ConcurrentMap;
|
||
|
|
import java.util.concurrent.ConcurrentNavigableMap;
|
||
|
|
import java.util.concurrent.ConcurrentSkipListMap;
|
||
|
|
import java.util.logging.Level;
|
||
|
|
import java.util.logging.Logger;
|
||
|
|
import javax.net.ssl.SSLPeerUnverifiedException;
|
||
|
|
import javax.net.ssl.SSLSession;
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public final class InternalChannelz {
|
||
|
|
static final boolean $assertionsDisabled = false;
|
||
|
|
private static final Logger log = Logger.getLogger(InternalChannelz.class.getName());
|
||
|
|
private static final InternalChannelz INSTANCE = new InternalChannelz();
|
||
|
|
private final ConcurrentNavigableMap<Long, InternalInstrumented<ServerStats>> servers = new ConcurrentSkipListMap();
|
||
|
|
private final ConcurrentNavigableMap<Long, InternalInstrumented<ChannelStats>> rootChannels = new ConcurrentSkipListMap();
|
||
|
|
private final ConcurrentMap<Long, InternalInstrumented<ChannelStats>> subchannels = new ConcurrentHashMap();
|
||
|
|
private final ConcurrentMap<Long, InternalInstrumented<SocketStats>> otherSockets = new ConcurrentHashMap();
|
||
|
|
private final ConcurrentMap<Long, ServerSocketMap> perServerSockets = new ConcurrentHashMap();
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class ServerSocketMap extends ConcurrentSkipListMap<Long, InternalInstrumented<SocketStats>> {
|
||
|
|
private static final long serialVersionUID = -7883772124944661414L;
|
||
|
|
|
||
|
|
private ServerSocketMap() {
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void addServer(InternalInstrumented<ServerStats> internalInstrumented) {
|
||
|
|
this.perServerSockets.put(Long.valueOf(id(internalInstrumented)), new ServerSocketMap());
|
||
|
|
add(this.servers, internalInstrumented);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void addSubchannel(InternalInstrumented<ChannelStats> internalInstrumented) {
|
||
|
|
add(this.subchannels, internalInstrumented);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void addRootChannel(InternalInstrumented<ChannelStats> internalInstrumented) {
|
||
|
|
add(this.rootChannels, internalInstrumented);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void addClientSocket(InternalInstrumented<SocketStats> internalInstrumented) {
|
||
|
|
add(this.otherSockets, internalInstrumented);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void addListenSocket(InternalInstrumented<SocketStats> internalInstrumented) {
|
||
|
|
add(this.otherSockets, internalInstrumented);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void addServerSocket(InternalInstrumented<ServerStats> internalInstrumented, InternalInstrumented<SocketStats> internalInstrumented2) {
|
||
|
|
add(this.perServerSockets.get(Long.valueOf(id(internalInstrumented))), internalInstrumented2);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void removeServer(InternalInstrumented<ServerStats> internalInstrumented) {
|
||
|
|
remove(this.servers, internalInstrumented);
|
||
|
|
this.perServerSockets.remove(Long.valueOf(id(internalInstrumented)));
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void removeSubchannel(InternalInstrumented<ChannelStats> internalInstrumented) {
|
||
|
|
remove(this.subchannels, internalInstrumented);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void removeRootChannel(InternalInstrumented<ChannelStats> internalInstrumented) {
|
||
|
|
remove(this.rootChannels, internalInstrumented);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void removeClientSocket(InternalInstrumented<SocketStats> internalInstrumented) {
|
||
|
|
remove(this.otherSockets, internalInstrumented);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void removeListenSocket(InternalInstrumented<SocketStats> internalInstrumented) {
|
||
|
|
remove(this.otherSockets, internalInstrumented);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void removeServerSocket(InternalInstrumented<ServerStats> internalInstrumented, InternalInstrumented<SocketStats> internalInstrumented2) {
|
||
|
|
remove(this.perServerSockets.get(Long.valueOf(id(internalInstrumented))), internalInstrumented2);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final RootChannelList getRootChannels(long j, int i) {
|
||
|
|
ArrayList arrayList = new ArrayList();
|
||
|
|
Iterator it = this.rootChannels.tailMap((ConcurrentNavigableMap<Long, InternalInstrumented<ChannelStats>>) Long.valueOf(j)).values().iterator();
|
||
|
|
while (it.hasNext() && arrayList.size() < i) {
|
||
|
|
arrayList.add((InternalInstrumented) it.next());
|
||
|
|
}
|
||
|
|
return new RootChannelList(arrayList, !it.hasNext());
|
||
|
|
}
|
||
|
|
|
||
|
|
public final InternalInstrumented<ChannelStats> getChannel(long j) {
|
||
|
|
return (InternalInstrumented) this.rootChannels.get(Long.valueOf(j));
|
||
|
|
}
|
||
|
|
|
||
|
|
public final InternalInstrumented<ChannelStats> getSubchannel(long j) {
|
||
|
|
return this.subchannels.get(Long.valueOf(j));
|
||
|
|
}
|
||
|
|
|
||
|
|
public final ServerList getServers(long j, int i) {
|
||
|
|
ArrayList arrayList = new ArrayList(i);
|
||
|
|
Iterator it = this.servers.tailMap((ConcurrentNavigableMap<Long, InternalInstrumented<ServerStats>>) Long.valueOf(j)).values().iterator();
|
||
|
|
while (it.hasNext() && arrayList.size() < i) {
|
||
|
|
arrayList.add((InternalInstrumented) it.next());
|
||
|
|
}
|
||
|
|
return new ServerList(arrayList, !it.hasNext());
|
||
|
|
}
|
||
|
|
|
||
|
|
public final InternalInstrumented<ServerStats> getServer(long j) {
|
||
|
|
return (InternalInstrumented) this.servers.get(Long.valueOf(j));
|
||
|
|
}
|
||
|
|
|
||
|
|
public final ServerSocketsList getServerSockets(long j, long j2, int i) {
|
||
|
|
ServerSocketMap serverSocketMap = this.perServerSockets.get(Long.valueOf(j));
|
||
|
|
if (serverSocketMap == null) {
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
ArrayList arrayList = new ArrayList(i);
|
||
|
|
Iterator it = serverSocketMap.tailMap((ServerSocketMap) Long.valueOf(j2)).values().iterator();
|
||
|
|
while (arrayList.size() < i && it.hasNext()) {
|
||
|
|
arrayList.add((InternalWithLogId) it.next());
|
||
|
|
}
|
||
|
|
return new ServerSocketsList(arrayList, !it.hasNext());
|
||
|
|
}
|
||
|
|
|
||
|
|
public final InternalInstrumented<SocketStats> getSocket(long j) {
|
||
|
|
InternalInstrumented<SocketStats> internalInstrumented = this.otherSockets.get(Long.valueOf(j));
|
||
|
|
return internalInstrumented != null ? internalInstrumented : getServerSocket(j);
|
||
|
|
}
|
||
|
|
|
||
|
|
private InternalInstrumented<SocketStats> getServerSocket(long j) {
|
||
|
|
Iterator<ServerSocketMap> it = this.perServerSockets.values().iterator();
|
||
|
|
while (it.hasNext()) {
|
||
|
|
InternalInstrumented<SocketStats> internalInstrumented = it.next().get(Long.valueOf(j));
|
||
|
|
if (internalInstrumented != null) {
|
||
|
|
return internalInstrumented;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final boolean containsServer(InternalLogId internalLogId) {
|
||
|
|
return contains(this.servers, internalLogId);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final boolean containsSubchannel(InternalLogId internalLogId) {
|
||
|
|
return contains(this.subchannels, internalLogId);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final InternalInstrumented<ChannelStats> getRootChannel(long j) {
|
||
|
|
return (InternalInstrumented) this.rootChannels.get(Long.valueOf(j));
|
||
|
|
}
|
||
|
|
|
||
|
|
public final boolean containsClientSocket(InternalLogId internalLogId) {
|
||
|
|
return contains(this.otherSockets, internalLogId);
|
||
|
|
}
|
||
|
|
|
||
|
|
private static <T extends InternalInstrumented<?>> void add(Map<Long, T> map, T t) {
|
||
|
|
map.put(Long.valueOf(t.getLogId().getId()), t);
|
||
|
|
}
|
||
|
|
|
||
|
|
private static <T extends InternalInstrumented<?>> void remove(Map<Long, T> map, T t) {
|
||
|
|
map.remove(Long.valueOf(id(t)));
|
||
|
|
}
|
||
|
|
|
||
|
|
private static <T extends InternalInstrumented<?>> boolean contains(Map<Long, T> map, InternalLogId internalLogId) {
|
||
|
|
return map.containsKey(Long.valueOf(internalLogId.getId()));
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class RootChannelList {
|
||
|
|
public final List<InternalInstrumented<ChannelStats>> channels;
|
||
|
|
public final boolean end;
|
||
|
|
|
||
|
|
public RootChannelList(List<InternalInstrumented<ChannelStats>> list, boolean z) {
|
||
|
|
this.channels = (List) Preconditions.checkNotNull(list);
|
||
|
|
this.end = z;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class ServerList {
|
||
|
|
public final boolean end;
|
||
|
|
public final List<InternalInstrumented<ServerStats>> servers;
|
||
|
|
|
||
|
|
public ServerList(List<InternalInstrumented<ServerStats>> list, boolean z) {
|
||
|
|
this.servers = (List) Preconditions.checkNotNull(list);
|
||
|
|
this.end = z;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class ServerSocketsList {
|
||
|
|
public final boolean end;
|
||
|
|
public final List<InternalWithLogId> sockets;
|
||
|
|
|
||
|
|
public ServerSocketsList(List<InternalWithLogId> list, boolean z) {
|
||
|
|
this.sockets = list;
|
||
|
|
this.end = z;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class ServerStats {
|
||
|
|
public final long callsFailed;
|
||
|
|
public final long callsStarted;
|
||
|
|
public final long callsSucceeded;
|
||
|
|
public final long lastCallStartedNanos;
|
||
|
|
public final List<InternalInstrumented<SocketStats>> listenSockets;
|
||
|
|
|
||
|
|
public ServerStats(long j, long j2, long j3, long j4, List<InternalInstrumented<SocketStats>> list) {
|
||
|
|
this.callsStarted = j;
|
||
|
|
this.callsSucceeded = j2;
|
||
|
|
this.callsFailed = j3;
|
||
|
|
this.lastCallStartedNanos = j4;
|
||
|
|
this.listenSockets = (List) Preconditions.checkNotNull(list);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class Builder {
|
||
|
|
private long callsFailed;
|
||
|
|
private long callsStarted;
|
||
|
|
private long callsSucceeded;
|
||
|
|
private long lastCallStartedNanos;
|
||
|
|
public List<InternalInstrumented<SocketStats>> listenSockets = new ArrayList();
|
||
|
|
|
||
|
|
public final Builder addListenSockets(List<InternalInstrumented<SocketStats>> list) {
|
||
|
|
Preconditions.checkNotNull(list, "listenSockets");
|
||
|
|
Iterator<InternalInstrumented<SocketStats>> it = list.iterator();
|
||
|
|
while (it.hasNext()) {
|
||
|
|
this.listenSockets.add((InternalInstrumented) Preconditions.checkNotNull(it.next(), "null listen socket"));
|
||
|
|
}
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final ServerStats build() {
|
||
|
|
return new ServerStats(this.callsStarted, this.callsSucceeded, this.callsFailed, this.lastCallStartedNanos, this.listenSockets);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setLastCallStartedNanos(long j) {
|
||
|
|
this.lastCallStartedNanos = j;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setCallsSucceeded(long j) {
|
||
|
|
this.callsSucceeded = j;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setCallsStarted(long j) {
|
||
|
|
this.callsStarted = j;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setCallsFailed(long j) {
|
||
|
|
this.callsFailed = j;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class ChannelStats {
|
||
|
|
public final long callsFailed;
|
||
|
|
public final long callsStarted;
|
||
|
|
public final long callsSucceeded;
|
||
|
|
public final ChannelTrace channelTrace;
|
||
|
|
public final long lastCallStartedNanos;
|
||
|
|
public final List<InternalWithLogId> sockets;
|
||
|
|
public final ConnectivityState state;
|
||
|
|
public final List<InternalWithLogId> subchannels;
|
||
|
|
public final String target;
|
||
|
|
|
||
|
|
private ChannelStats(String str, ConnectivityState connectivityState, ChannelTrace channelTrace, long j, long j2, long j3, long j4, List<InternalWithLogId> list, List<InternalWithLogId> list2) {
|
||
|
|
Preconditions.checkState(list.isEmpty() || list2.isEmpty(), "channels can have subchannels only, subchannels can have either sockets OR subchannels, neither can have both");
|
||
|
|
this.target = str;
|
||
|
|
this.state = connectivityState;
|
||
|
|
this.channelTrace = channelTrace;
|
||
|
|
this.callsStarted = j;
|
||
|
|
this.callsSucceeded = j2;
|
||
|
|
this.callsFailed = j3;
|
||
|
|
this.lastCallStartedNanos = j4;
|
||
|
|
this.subchannels = (List) Preconditions.checkNotNull(list);
|
||
|
|
this.sockets = (List) Preconditions.checkNotNull(list2);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class Builder {
|
||
|
|
private long callsFailed;
|
||
|
|
private long callsStarted;
|
||
|
|
private long callsSucceeded;
|
||
|
|
private ChannelTrace channelTrace;
|
||
|
|
private long lastCallStartedNanos;
|
||
|
|
private ConnectivityState state;
|
||
|
|
private String target;
|
||
|
|
private List<InternalWithLogId> subchannels = Collections.emptyList();
|
||
|
|
private List<InternalWithLogId> sockets = Collections.emptyList();
|
||
|
|
|
||
|
|
public final Builder setSubchannels(List<InternalWithLogId> list) {
|
||
|
|
Preconditions.checkState(this.sockets.isEmpty());
|
||
|
|
this.subchannels = Collections.unmodifiableList((List) Preconditions.checkNotNull(list));
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setSockets(List<InternalWithLogId> list) {
|
||
|
|
Preconditions.checkState(this.subchannels.isEmpty());
|
||
|
|
this.sockets = Collections.unmodifiableList((List) Preconditions.checkNotNull(list));
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final ChannelStats build() {
|
||
|
|
return new ChannelStats(this.target, this.state, this.channelTrace, this.callsStarted, this.callsSucceeded, this.callsFailed, this.lastCallStartedNanos, this.subchannels, this.sockets);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setTarget(String str) {
|
||
|
|
this.target = str;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setState(ConnectivityState connectivityState) {
|
||
|
|
this.state = connectivityState;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setLastCallStartedNanos(long j) {
|
||
|
|
this.lastCallStartedNanos = j;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setChannelTrace(ChannelTrace channelTrace) {
|
||
|
|
this.channelTrace = channelTrace;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setCallsSucceeded(long j) {
|
||
|
|
this.callsSucceeded = j;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setCallsStarted(long j) {
|
||
|
|
this.callsStarted = j;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setCallsFailed(long j) {
|
||
|
|
this.callsFailed = j;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class ChannelTrace {
|
||
|
|
public final long creationTimeNanos;
|
||
|
|
public final List<Event> events;
|
||
|
|
public final long numEventsLogged;
|
||
|
|
|
||
|
|
private ChannelTrace(long j, long j2, List<Event> list) {
|
||
|
|
this.numEventsLogged = j;
|
||
|
|
this.creationTimeNanos = j2;
|
||
|
|
this.events = list;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class Builder {
|
||
|
|
private Long creationTimeNanos;
|
||
|
|
private List<Event> events = Collections.emptyList();
|
||
|
|
private Long numEventsLogged;
|
||
|
|
|
||
|
|
public final Builder setNumEventsLogged(long j) {
|
||
|
|
this.numEventsLogged = Long.valueOf(j);
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setCreationTimeNanos(long j) {
|
||
|
|
this.creationTimeNanos = Long.valueOf(j);
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setEvents(List<Event> list) {
|
||
|
|
this.events = Collections.unmodifiableList(new ArrayList(list));
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final ChannelTrace build() {
|
||
|
|
Preconditions.checkNotNull(this.numEventsLogged, "numEventsLogged");
|
||
|
|
Preconditions.checkNotNull(this.creationTimeNanos, "creationTimeNanos");
|
||
|
|
return new ChannelTrace(this.numEventsLogged.longValue(), this.creationTimeNanos.longValue(), this.events);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class Event {
|
||
|
|
public final InternalWithLogId channelRef;
|
||
|
|
public final String description;
|
||
|
|
public final Severity severity;
|
||
|
|
public final InternalWithLogId subchannelRef;
|
||
|
|
public final long timestampNanos;
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public enum Severity {
|
||
|
|
CT_UNKNOWN,
|
||
|
|
CT_INFO,
|
||
|
|
CT_WARNING,
|
||
|
|
CT_ERROR
|
||
|
|
}
|
||
|
|
|
||
|
|
private Event(String str, Severity severity, long j, InternalWithLogId internalWithLogId, InternalWithLogId internalWithLogId2) {
|
||
|
|
this.description = str;
|
||
|
|
this.severity = (Severity) Preconditions.checkNotNull(severity, "severity");
|
||
|
|
this.timestampNanos = j;
|
||
|
|
this.channelRef = internalWithLogId;
|
||
|
|
this.subchannelRef = internalWithLogId2;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final int hashCode() {
|
||
|
|
String str = this.description;
|
||
|
|
Severity severity = this.severity;
|
||
|
|
long j = this.timestampNanos;
|
||
|
|
return Objects.hashCode(str, severity, Long.valueOf(j), this.channelRef, this.subchannelRef);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final boolean equals(Object obj) {
|
||
|
|
if (!(obj instanceof Event)) {
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
Event event = (Event) obj;
|
||
|
|
return Objects.equal(this.description, event.description) && Objects.equal(this.severity, event.severity) && this.timestampNanos == event.timestampNanos && Objects.equal(this.channelRef, event.channelRef) && Objects.equal(this.subchannelRef, event.subchannelRef);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final String toString() {
|
||
|
|
return MoreObjects.toStringHelper(this).add("description", this.description).add("severity", this.severity).add("timestampNanos", this.timestampNanos).add("channelRef", this.channelRef).add("subchannelRef", this.subchannelRef).toString();
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class Builder {
|
||
|
|
private InternalWithLogId channelRef;
|
||
|
|
private String description;
|
||
|
|
private Severity severity;
|
||
|
|
private InternalWithLogId subchannelRef;
|
||
|
|
private Long timestampNanos;
|
||
|
|
|
||
|
|
public final Builder setTimestampNanos(long j) {
|
||
|
|
this.timestampNanos = Long.valueOf(j);
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Event build() {
|
||
|
|
Preconditions.checkNotNull(this.description, "description");
|
||
|
|
Preconditions.checkNotNull(this.severity, "severity");
|
||
|
|
Preconditions.checkNotNull(this.timestampNanos, "timestampNanos");
|
||
|
|
Preconditions.checkState(this.channelRef == null || this.subchannelRef == null, "at least one of channelRef and subchannelRef must be null");
|
||
|
|
return new Event(this.description, this.severity, this.timestampNanos.longValue(), this.channelRef, this.subchannelRef);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setSubchannelRef(InternalWithLogId internalWithLogId) {
|
||
|
|
this.subchannelRef = internalWithLogId;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setSeverity(Severity severity) {
|
||
|
|
this.severity = severity;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setDescription(String str) {
|
||
|
|
this.description = str;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setChannelRef(InternalWithLogId internalWithLogId) {
|
||
|
|
this.channelRef = internalWithLogId;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class Security {
|
||
|
|
public final OtherSecurity other;
|
||
|
|
public final Tls tls;
|
||
|
|
|
||
|
|
public Security(Tls tls) {
|
||
|
|
this.tls = (Tls) Preconditions.checkNotNull(tls);
|
||
|
|
this.other = null;
|
||
|
|
}
|
||
|
|
|
||
|
|
public Security(OtherSecurity otherSecurity) {
|
||
|
|
this.tls = null;
|
||
|
|
this.other = (OtherSecurity) Preconditions.checkNotNull(otherSecurity);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class OtherSecurity {
|
||
|
|
public final Object any;
|
||
|
|
public final String name;
|
||
|
|
|
||
|
|
public OtherSecurity(String str, Object obj) {
|
||
|
|
this.name = (String) Preconditions.checkNotNull(str);
|
||
|
|
Preconditions.checkState(obj == null || obj.getClass().getName().endsWith("o.ljJ"), "the 'any' object must be of type com.google.protobuf.Any");
|
||
|
|
this.any = obj;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class Tls {
|
||
|
|
public final String cipherSuiteStandardName;
|
||
|
|
public final Certificate localCert;
|
||
|
|
public final Certificate remoteCert;
|
||
|
|
|
||
|
|
public Tls(String str, Certificate certificate, Certificate certificate2) {
|
||
|
|
this.cipherSuiteStandardName = str;
|
||
|
|
this.localCert = certificate;
|
||
|
|
this.remoteCert = certificate2;
|
||
|
|
}
|
||
|
|
|
||
|
|
public Tls(SSLSession sSLSession) {
|
||
|
|
String cipherSuite = sSLSession.getCipherSuite();
|
||
|
|
Certificate[] localCertificates = sSLSession.getLocalCertificates();
|
||
|
|
Certificate certificate = null;
|
||
|
|
Certificate certificate2 = localCertificates != null ? localCertificates[0] : null;
|
||
|
|
try {
|
||
|
|
Certificate[] peerCertificates = sSLSession.getPeerCertificates();
|
||
|
|
if (peerCertificates != null) {
|
||
|
|
certificate = peerCertificates[0];
|
||
|
|
}
|
||
|
|
} catch (SSLPeerUnverifiedException e) {
|
||
|
|
InternalChannelz.log.log(Level.FINE, String.format("Peer cert not available for peerHost=%s", sSLSession.getPeerHost()), (Throwable) e);
|
||
|
|
}
|
||
|
|
this.cipherSuiteStandardName = cipherSuite;
|
||
|
|
this.localCert = certificate2;
|
||
|
|
this.remoteCert = certificate;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class SocketStats {
|
||
|
|
public final TransportStats data;
|
||
|
|
public final SocketAddress local;
|
||
|
|
public final SocketAddress remote;
|
||
|
|
public final Security security;
|
||
|
|
public final SocketOptions socketOptions;
|
||
|
|
|
||
|
|
public SocketStats(TransportStats transportStats, SocketAddress socketAddress, SocketAddress socketAddress2, SocketOptions socketOptions, Security security) {
|
||
|
|
this.data = transportStats;
|
||
|
|
this.local = (SocketAddress) Preconditions.checkNotNull(socketAddress, "local socket");
|
||
|
|
this.remote = socketAddress2;
|
||
|
|
this.socketOptions = (SocketOptions) Preconditions.checkNotNull(socketOptions);
|
||
|
|
this.security = security;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class TcpInfo {
|
||
|
|
public final int advmss;
|
||
|
|
public final int ato;
|
||
|
|
public final int backoff;
|
||
|
|
public final int caState;
|
||
|
|
public final int fackets;
|
||
|
|
public final int lastAckRecv;
|
||
|
|
public final int lastAckSent;
|
||
|
|
public final int lastDataRecv;
|
||
|
|
public final int lastDataSent;
|
||
|
|
public final int lost;
|
||
|
|
public final int options;
|
||
|
|
public final int pmtu;
|
||
|
|
public final int probes;
|
||
|
|
public final int rcvMss;
|
||
|
|
public final int rcvSsthresh;
|
||
|
|
public final int rcvWscale;
|
||
|
|
public final int reordering;
|
||
|
|
public final int retrans;
|
||
|
|
public final int retransmits;
|
||
|
|
public final int rto;
|
||
|
|
public final int rtt;
|
||
|
|
public final int rttvar;
|
||
|
|
public final int sacked;
|
||
|
|
public final int sndCwnd;
|
||
|
|
public final int sndMss;
|
||
|
|
public final int sndSsthresh;
|
||
|
|
public final int sndWscale;
|
||
|
|
public final int state;
|
||
|
|
public final int unacked;
|
||
|
|
|
||
|
|
TcpInfo(int i, int i2, int i3, int i4, int i5, int i6, int i7, int i8, int i9, int i10, int i11, int i12, int i13, int i14, int i15, int i16, int i17, int i18, int i19, int i20, int i21, int i22, int i23, int i24, int i25, int i26, int i27, int i28, int i29) {
|
||
|
|
this.state = i;
|
||
|
|
this.caState = i2;
|
||
|
|
this.retransmits = i3;
|
||
|
|
this.probes = i4;
|
||
|
|
this.backoff = i5;
|
||
|
|
this.options = i6;
|
||
|
|
this.sndWscale = i7;
|
||
|
|
this.rcvWscale = i8;
|
||
|
|
this.rto = i9;
|
||
|
|
this.ato = i10;
|
||
|
|
this.sndMss = i11;
|
||
|
|
this.rcvMss = i12;
|
||
|
|
this.unacked = i13;
|
||
|
|
this.sacked = i14;
|
||
|
|
this.lost = i15;
|
||
|
|
this.retrans = i16;
|
||
|
|
this.fackets = i17;
|
||
|
|
this.lastDataSent = i18;
|
||
|
|
this.lastAckSent = i19;
|
||
|
|
this.lastDataRecv = i20;
|
||
|
|
this.lastAckRecv = i21;
|
||
|
|
this.pmtu = i22;
|
||
|
|
this.rcvSsthresh = i23;
|
||
|
|
this.rtt = i24;
|
||
|
|
this.rttvar = i25;
|
||
|
|
this.sndSsthresh = i26;
|
||
|
|
this.sndCwnd = i27;
|
||
|
|
this.advmss = i28;
|
||
|
|
this.reordering = i29;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class Builder {
|
||
|
|
private int advmss;
|
||
|
|
private int ato;
|
||
|
|
private int backoff;
|
||
|
|
private int caState;
|
||
|
|
private int fackets;
|
||
|
|
private int lastAckRecv;
|
||
|
|
private int lastAckSent;
|
||
|
|
private int lastDataRecv;
|
||
|
|
private int lastDataSent;
|
||
|
|
private int lost;
|
||
|
|
private int options;
|
||
|
|
private int pmtu;
|
||
|
|
private int probes;
|
||
|
|
private int rcvMss;
|
||
|
|
private int rcvSsthresh;
|
||
|
|
private int rcvWscale;
|
||
|
|
private int reordering;
|
||
|
|
private int retrans;
|
||
|
|
private int retransmits;
|
||
|
|
private int rto;
|
||
|
|
private int rtt;
|
||
|
|
private int rttvar;
|
||
|
|
private int sacked;
|
||
|
|
private int sndCwnd;
|
||
|
|
private int sndMss;
|
||
|
|
private int sndSsthresh;
|
||
|
|
private int sndWscale;
|
||
|
|
private int state;
|
||
|
|
private int unacked;
|
||
|
|
|
||
|
|
public final TcpInfo build() {
|
||
|
|
return new TcpInfo(this.state, this.caState, this.retransmits, this.probes, this.backoff, this.options, this.sndWscale, this.rcvWscale, this.rto, this.ato, this.sndMss, this.rcvMss, this.unacked, this.sacked, this.lost, this.retrans, this.fackets, this.lastDataSent, this.lastAckSent, this.lastDataRecv, this.lastAckRecv, this.pmtu, this.rcvSsthresh, this.rtt, this.rttvar, this.sndSsthresh, this.sndCwnd, this.advmss, this.reordering);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setUnacked(int i) {
|
||
|
|
this.unacked = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setState(int i) {
|
||
|
|
this.state = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setSndWscale(int i) {
|
||
|
|
this.sndWscale = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setSndSsthresh(int i) {
|
||
|
|
this.sndSsthresh = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setSndMss(int i) {
|
||
|
|
this.sndMss = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setSndCwnd(int i) {
|
||
|
|
this.sndCwnd = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setSacked(int i) {
|
||
|
|
this.sacked = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setRttvar(int i) {
|
||
|
|
this.rttvar = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setRtt(int i) {
|
||
|
|
this.rtt = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setRto(int i) {
|
||
|
|
this.rto = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setRetransmits(int i) {
|
||
|
|
this.retransmits = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setRetrans(int i) {
|
||
|
|
this.retrans = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setReordering(int i) {
|
||
|
|
this.reordering = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setRcvWscale(int i) {
|
||
|
|
this.rcvWscale = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setRcvSsthresh(int i) {
|
||
|
|
this.rcvSsthresh = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setRcvMss(int i) {
|
||
|
|
this.rcvMss = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setProbes(int i) {
|
||
|
|
this.probes = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setPmtu(int i) {
|
||
|
|
this.pmtu = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setOptions(int i) {
|
||
|
|
this.options = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setLost(int i) {
|
||
|
|
this.lost = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setLastDataSent(int i) {
|
||
|
|
this.lastDataSent = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setLastDataRecv(int i) {
|
||
|
|
this.lastDataRecv = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setLastAckSent(int i) {
|
||
|
|
this.lastAckSent = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setLastAckRecv(int i) {
|
||
|
|
this.lastAckRecv = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setFackets(int i) {
|
||
|
|
this.fackets = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setCaState(int i) {
|
||
|
|
this.caState = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setBackoff(int i) {
|
||
|
|
this.backoff = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setAto(int i) {
|
||
|
|
this.ato = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setAdvmss(int i) {
|
||
|
|
this.advmss = i;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class SocketOptions {
|
||
|
|
public final Integer lingerSeconds;
|
||
|
|
public final Map<String, String> others;
|
||
|
|
public final Integer soTimeoutMillis;
|
||
|
|
public final TcpInfo tcpInfo;
|
||
|
|
|
||
|
|
public SocketOptions(Integer num, Integer num2, TcpInfo tcpInfo, Map<String, String> map) {
|
||
|
|
Preconditions.checkNotNull(map);
|
||
|
|
this.soTimeoutMillis = num;
|
||
|
|
this.lingerSeconds = num2;
|
||
|
|
this.tcpInfo = tcpInfo;
|
||
|
|
this.others = Collections.unmodifiableMap(new HashMap(map));
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class Builder {
|
||
|
|
private Integer lingerSeconds;
|
||
|
|
private final Map<String, String> others = new HashMap();
|
||
|
|
private TcpInfo tcpInfo;
|
||
|
|
private Integer timeoutMillis;
|
||
|
|
|
||
|
|
public final Builder addOption(String str, String str2) {
|
||
|
|
this.others.put(str, (String) Preconditions.checkNotNull(str2));
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder addOption(String str, int i) {
|
||
|
|
this.others.put(str, Integer.toString(i));
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder addOption(String str, boolean z) {
|
||
|
|
this.others.put(str, Boolean.toString(z));
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final SocketOptions build() {
|
||
|
|
return new SocketOptions(this.timeoutMillis, this.lingerSeconds, this.tcpInfo, this.others);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setTcpInfo(TcpInfo tcpInfo) {
|
||
|
|
this.tcpInfo = tcpInfo;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setSocketOptionTimeoutMillis(Integer num) {
|
||
|
|
this.timeoutMillis = num;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
|
||
|
|
public final Builder setSocketOptionLingerSeconds(Integer num) {
|
||
|
|
this.lingerSeconds = num;
|
||
|
|
return this;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public static final class TransportStats {
|
||
|
|
public final long keepAlivesSent;
|
||
|
|
public final long lastLocalStreamCreatedTimeNanos;
|
||
|
|
public final long lastMessageReceivedTimeNanos;
|
||
|
|
public final long lastMessageSentTimeNanos;
|
||
|
|
public final long lastRemoteStreamCreatedTimeNanos;
|
||
|
|
public final long localFlowControlWindow;
|
||
|
|
public final long messagesReceived;
|
||
|
|
public final long messagesSent;
|
||
|
|
public final long remoteFlowControlWindow;
|
||
|
|
public final long streamsFailed;
|
||
|
|
public final long streamsStarted;
|
||
|
|
public final long streamsSucceeded;
|
||
|
|
|
||
|
|
public TransportStats(long j, long j2, long j3, long j4, long j5, long j6, long j7, long j8, long j9, long j10, long j11, long j12) {
|
||
|
|
this.streamsStarted = j;
|
||
|
|
this.lastLocalStreamCreatedTimeNanos = j2;
|
||
|
|
this.lastRemoteStreamCreatedTimeNanos = j3;
|
||
|
|
this.streamsSucceeded = j4;
|
||
|
|
this.streamsFailed = j5;
|
||
|
|
this.messagesSent = j6;
|
||
|
|
this.messagesReceived = j7;
|
||
|
|
this.keepAlivesSent = j8;
|
||
|
|
this.lastMessageSentTimeNanos = j9;
|
||
|
|
this.lastMessageReceivedTimeNanos = j10;
|
||
|
|
this.localFlowControlWindow = j11;
|
||
|
|
this.remoteFlowControlWindow = j12;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public static long id(InternalWithLogId internalWithLogId) {
|
||
|
|
return internalWithLogId.getLogId().getId();
|
||
|
|
}
|
||
|
|
|
||
|
|
public static InternalChannelz instance() {
|
||
|
|
return INSTANCE;
|
||
|
|
}
|
||
|
|
}
|