package kotlinx.coroutines.debug.internal; import java.lang.ref.Reference; import java.lang.ref.ReferenceQueue; import java.util.Iterator; import java.util.Map; import java.util.NoSuchElementException; import java.util.Set; import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; import java.util.concurrent.atomic.AtomicReferenceArray; import kotlin.KotlinNothingValueException; import kotlin.Metadata; import kotlin.Unit; import kotlin.collections.AbstractMutableMap; import kotlin.collections.AbstractMutableSet; import kotlin.jvm.functions.Function2; import kotlin.jvm.internal.DefaultConstructorMarker; import kotlin.jvm.internal.Intrinsics; import kotlin.jvm.internal.markers.KMutableIterator; import kotlin.jvm.internal.markers.KMutableMap; import kotlin.ranges.RangesKt; import kotlinx.coroutines.debug.internal.ConcurrentWeakMap; /* JADX INFO: compiled from: ConcurrentWeakMap.kt */ /* JADX INFO: loaded from: classes2.dex */ @Metadata(d1 = {"\u0000B\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u000e\n\u0002\u0010#\n\u0002\u0010'\n\u0002\b\u0005\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\b\u0000\u0018\u0000*\b\b\u0000\u0010\u0002*\u00020\u0001*\b\b\u0001\u0010\u0003*\u00020\u00012\u000e\u0012\u0004\u0012\u00028\u0000\u0012\u0004\u0012\u00028\u00010*:\u0003&'(B\u0011\u0012\b\b\u0002\u0010\u0005\u001a\u00020\u0004¢\u0006\u0004\b\u0006\u0010\u0007J\u001b\u0010\u000b\u001a\u00020\n2\n\u0010\t\u001a\u0006\u0012\u0002\b\u00030\bH\u0002¢\u0006\u0004\b\u000b\u0010\fJ\u000f\u0010\r\u001a\u00020\nH\u0016¢\u0006\u0004\b\r\u0010\u000eJ\u000f\u0010\u000f\u001a\u00020\nH\u0002¢\u0006\u0004\b\u000f\u0010\u000eJ\u001a\u0010\u0011\u001a\u0004\u0018\u00018\u00012\u0006\u0010\u0010\u001a\u00028\u0000H\u0096\u0002¢\u0006\u0004\b\u0011\u0010\u0012J!\u0010\u0014\u001a\u0004\u0018\u00018\u00012\u0006\u0010\u0010\u001a\u00028\u00002\u0006\u0010\u0013\u001a\u00028\u0001H\u0016¢\u0006\u0004\b\u0014\u0010\u0015J#\u0010\u0016\u001a\u0004\u0018\u00018\u00012\u0006\u0010\u0010\u001a\u00028\u00002\b\u0010\u0013\u001a\u0004\u0018\u00018\u0001H\u0002¢\u0006\u0004\b\u0016\u0010\u0015J\u0019\u0010\u0017\u001a\u0004\u0018\u00018\u00012\u0006\u0010\u0010\u001a\u00028\u0000H\u0016¢\u0006\u0004\b\u0017\u0010\u0012J\r\u0010\u0018\u001a\u00020\n¢\u0006\u0004\b\u0018\u0010\u000eR&\u0010\u001d\u001a\u0014\u0012\u0010\u0012\u000e\u0012\u0004\u0012\u00028\u0000\u0012\u0004\u0012\u00028\u00010\u001a0\u00198VX\u0096\u0004¢\u0006\u0006\u001a\u0004\b\u001b\u0010\u001cR\u001a\u0010\u001f\u001a\b\u0012\u0004\u0012\u00028\u00000\u00198VX\u0096\u0004¢\u0006\u0006\u001a\u0004\b\u001e\u0010\u001cR\u0014\u0010#\u001a\u00020 8VX\u0096\u0004¢\u0006\u0006\u001a\u0004\b!\u0010\"R\u001c\u0010\u0005\u001a\n\u0012\u0004\u0012\u00028\u0000\u0018\u00010$8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0005\u0010%¨\u0006)"}, d2 = {"Lkotlinx/coroutines/debug/internal/ConcurrentWeakMap;", "", "K", "V", "", "weakRefQueue", "", "(Z)V", "Lkotlinx/coroutines/debug/internal/HashedWeakRef;", "w", "", "cleanWeakRef", "(Lkotlinx/coroutines/debug/internal/HashedWeakRef;)V", "clear", "()V", "decrementSize", "key", "get", "(Ljava/lang/Object;)Ljava/lang/Object;", "value", "put", "(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;", "putSynchronized", "remove", "runWeakRefQueueCleaningLoopUntilInterrupted", "", "", "getEntries", "()Ljava/util/Set;", "entries", "getKeys", "keys", "", "getSize", "()I", "size", "Ljava/lang/ref/ReferenceQueue;", "Ljava/lang/ref/ReferenceQueue;", "Core", "Entry", "KeyValueSet", "kotlinx-coroutines-core", "Lkotlin/collections/AbstractMutableMap;"}, k = 1, mv = {1, 6, 0}, xi = 48) public final class ConcurrentWeakMap extends AbstractMutableMap { private static final /* synthetic */ AtomicIntegerFieldUpdater _size$FU = AtomicIntegerFieldUpdater.newUpdater(ConcurrentWeakMap.class, "_size"); private volatile /* synthetic */ int _size; volatile /* synthetic */ Object core; private final ReferenceQueue weakRefQueue; public ConcurrentWeakMap() { this(false, 1, null); } public /* synthetic */ ConcurrentWeakMap(boolean z, int i, DefaultConstructorMarker defaultConstructorMarker) { this((i & 1) != 0 ? false : z); } public ConcurrentWeakMap(boolean z) { this._size = 0; this.core = new Core(16); this.weakRefQueue = z ? new ReferenceQueue<>() : null; } @Override // kotlin.collections.AbstractMutableMap /* JADX INFO: renamed from: getSize, reason: from getter */ public int get_size() { return this._size; } /* JADX INFO: Access modifiers changed from: private */ public final void decrementSize() { _size$FU.decrementAndGet(this); } @Override // java.util.AbstractMap, java.util.Map public V get(Object key) { if (key == null) { return null; } return (V) ((Core) this.core).getImpl(key); } @Override // kotlin.collections.AbstractMutableMap, java.util.AbstractMap, java.util.Map public V put(K key, V value) { V vPutSynchronized = (V) Core.putImpl$default((Core) this.core, key, value, null, 4, null); if (vPutSynchronized == ConcurrentWeakMapKt.REHASH) { vPutSynchronized = putSynchronized(key, value); } if (vPutSynchronized == null) { _size$FU.incrementAndGet(this); } return vPutSynchronized; } /* JADX WARN: Multi-variable type inference failed */ @Override // java.util.AbstractMap, java.util.Map public V remove(Object key) { if (key == 0) { return null; } V vPutSynchronized = (V) Core.putImpl$default((Core) this.core, key, null, null, 4, null); if (vPutSynchronized == ConcurrentWeakMapKt.REHASH) { vPutSynchronized = putSynchronized(key, null); } if (vPutSynchronized != null) { _size$FU.decrementAndGet(this); } return vPutSynchronized; } private final synchronized V putSynchronized(K key, V value) { V v; Core coreRehash = (Core) this.core; while (true) { v = (V) Core.putImpl$default(coreRehash, key, value, null, 4, null); if (v == ConcurrentWeakMapKt.REHASH) { coreRehash = coreRehash.rehash(); this.core = coreRehash; } } return v; } @Override // kotlin.collections.AbstractMutableMap public Set getKeys() { return new KeyValueSet(new Function2() { // from class: kotlinx.coroutines.debug.internal.ConcurrentWeakMap$keys$1 @Override // kotlin.jvm.functions.Function2 public final K invoke(K k, V v) { return k; } }); } @Override // kotlin.collections.AbstractMutableMap public Set> getEntries() { return new KeyValueSet(new Function2>() { // from class: kotlinx.coroutines.debug.internal.ConcurrentWeakMap$entries$1 @Override // kotlin.jvm.functions.Function2 public final Map.Entry invoke(K k, V v) { return new ConcurrentWeakMap.Entry(k, v); } }); } @Override // java.util.AbstractMap, java.util.Map public void clear() { Iterator it = keySet().iterator(); while (it.hasNext()) { remove(it.next()); } } public final void runWeakRefQueueCleaningLoopUntilInterrupted() { if (this.weakRefQueue == null) { throw new IllegalStateException("Must be created with weakRefQueue = true".toString()); } while (true) { try { Reference referenceRemove = this.weakRefQueue.remove(); if (referenceRemove == null) { throw new NullPointerException("null cannot be cast to non-null type kotlinx.coroutines.debug.internal.HashedWeakRef<*>"); } cleanWeakRef((HashedWeakRef) referenceRemove); } catch (InterruptedException unused) { Thread.currentThread().interrupt(); return; } } } private final void cleanWeakRef(HashedWeakRef w) { ((Core) this.core).cleanWeakRef(w); } /* JADX INFO: compiled from: ConcurrentWeakMap.kt */ @Metadata(d1 = {"\u00008\n\u0002\u0018\u0002\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\t\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010)\n\u0002\b\u0004\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\t\b\u0082\u0004\u0018\u00002\u00020\u0018:\u0001#B\u000f\u0012\u0006\u0010\u0002\u001a\u00020\u0001¢\u0006\u0004\b\u0003\u0010\u0004J\u0019\u0010\b\u001a\u00020\u00072\n\u0010\u0006\u001a\u0006\u0012\u0002\b\u00030\u0005¢\u0006\u0004\b\b\u0010\tJ\u0017\u0010\u000b\u001a\u0004\u0018\u00018\u00012\u0006\u0010\n\u001a\u00028\u0000¢\u0006\u0004\b\u000b\u0010\fJ\u0017\u0010\u000e\u001a\u00020\u00012\u0006\u0010\r\u001a\u00020\u0001H\u0002¢\u0006\u0004\b\u000e\u0010\u000fJ3\u0010\u0014\u001a\b\u0012\u0004\u0012\u00028\u00020\u0013\"\u0004\b\u0002\u0010\u00102\u0018\u0010\u0012\u001a\u0014\u0012\u0004\u0012\u00028\u0000\u0012\u0004\u0012\u00028\u0001\u0012\u0004\u0012\u00028\u00020\u0011¢\u0006\u0004\b\u0014\u0010\u0015J3\u0010\u0019\u001a\u0004\u0018\u00010\u00182\u0006\u0010\n\u001a\u00028\u00002\b\u0010\u0016\u001a\u0004\u0018\u00018\u00012\u0010\b\u0002\u0010\u0017\u001a\n\u0012\u0004\u0012\u00028\u0000\u0018\u00010\u0005¢\u0006\u0004\b\u0019\u0010\u001aJ\u001d\u0010\u001c\u001a\u00120\u0000R\u000e\u0012\u0004\u0012\u00028\u0000\u0012\u0004\u0012\u00028\u00010\u001b¢\u0006\u0004\b\u001c\u0010\u001dJ\u0017\u0010\u001e\u001a\u00020\u00072\u0006\u0010\u000e\u001a\u00020\u0001H\u0002¢\u0006\u0004\b\u001e\u0010\u001fR\u0014\u0010\u0002\u001a\u00020\u00018\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0002\u0010 R\u0014\u0010!\u001a\u00020\u00018\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b!\u0010 R\u0014\u0010\"\u001a\u00020\u00018\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\"\u0010 ¨\u0006$"}, d2 = {"Lkotlinx/coroutines/debug/internal/ConcurrentWeakMap$Core;", "", "allocated", "", "(Lkotlinx/coroutines/debug/internal/ConcurrentWeakMap;I)V", "Lkotlinx/coroutines/debug/internal/HashedWeakRef;", "weakRef", "", "cleanWeakRef", "(Lkotlinx/coroutines/debug/internal/HashedWeakRef;)V", "key", "getImpl", "(Ljava/lang/Object;)Ljava/lang/Object;", "hash", "index", "(I)I", "E", "Lkotlin/Function2;", "factory", "", "keyValueIterator", "(Lkotlin/jvm/functions/Function2;)Ljava/util/Iterator;", "value", "weakKey0", "", "putImpl", "(Ljava/lang/Object;Ljava/lang/Object;Lkotlinx/coroutines/debug/internal/HashedWeakRef;)Ljava/lang/Object;", "Lkotlinx/coroutines/debug/internal/ConcurrentWeakMap;", "rehash", "()Lkotlinx/coroutines/debug/internal/ConcurrentWeakMap$Core;", "removeCleanedAt", "(I)V", "I", "shift", "threshold", "KeyValueIterator", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48) private final class Core { private static final /* synthetic */ AtomicIntegerFieldUpdater load$FU = AtomicIntegerFieldUpdater.newUpdater(Core.class, "load"); private final int allocated; /* synthetic */ AtomicReferenceArray keys; private volatile /* synthetic */ int load = 0; private final int shift; private final int threshold; /* synthetic */ AtomicReferenceArray values; public Core(int i) { this.allocated = i; this.shift = Integer.numberOfLeadingZeros(i) + 1; this.threshold = (i * 2) / 3; this.keys = new AtomicReferenceArray(i); this.values = new AtomicReferenceArray(i); } private final int index(int hash) { return (hash * (-1640531527)) >>> this.shift; } /* JADX WARN: Multi-variable type inference failed */ public final V getImpl(K key) { int iIndex = index(key.hashCode()); while (true) { HashedWeakRef hashedWeakRef = (HashedWeakRef) this.keys.get(iIndex); if (hashedWeakRef == null) { return null; } Object obj = hashedWeakRef.get(); if (Intrinsics.areEqual(key, obj)) { V v = (V) this.values.get(iIndex); return v instanceof Marked ? (V) ((Marked) v).ref : v; } if (obj == null) { removeCleanedAt(iIndex); } if (iIndex == 0) { iIndex = this.allocated; } iIndex--; } } private final void removeCleanedAt(int index) { Object obj; do { obj = this.values.get(index); if (obj == null || (obj instanceof Marked)) { return; } } while (!ConcurrentWeakMap$Core$$ExternalSyntheticBackportWithForwarding0.m(this.values, index, obj, null)); ConcurrentWeakMap.this.decrementSize(); } /* JADX WARN: Multi-variable type inference failed */ public static /* synthetic */ Object putImpl$default(Core core, Object obj, Object obj2, HashedWeakRef hashedWeakRef, int i, Object obj3) { if ((i & 4) != 0) { hashedWeakRef = null; } return core.putImpl(obj, obj2, hashedWeakRef); } public final Object putImpl(K key, V value, HashedWeakRef weakKey0) { int i; Object obj; int iIndex = index(key.hashCode()); boolean z = false; while (true) { HashedWeakRef hashedWeakRef = (HashedWeakRef) this.keys.get(iIndex); if (hashedWeakRef != null) { Object obj2 = hashedWeakRef.get(); if (!Intrinsics.areEqual(key, obj2)) { if (obj2 == null) { removeCleanedAt(iIndex); } if (iIndex == 0) { iIndex = this.allocated; } iIndex--; } else if (z) { load$FU.decrementAndGet(this); } } else if (value != null) { if (!z) { do { i = this.load; if (i >= this.threshold) { return ConcurrentWeakMapKt.REHASH; } } while (!load$FU.compareAndSet(this, i, i + 1)); z = true; } if (weakKey0 == null) { weakKey0 = new HashedWeakRef<>(key, ((ConcurrentWeakMap) ConcurrentWeakMap.this).weakRefQueue); } if (ConcurrentWeakMap$Core$$ExternalSyntheticBackportWithForwarding0.m(this.keys, iIndex, null, weakKey0)) { break; } } else { return null; } } do { obj = this.values.get(iIndex); if (obj instanceof Marked) { return ConcurrentWeakMapKt.REHASH; } } while (!ConcurrentWeakMap$Core$$ExternalSyntheticBackportWithForwarding0.m(this.values, iIndex, obj, value)); return obj; } /* JADX WARN: Multi-variable type inference failed */ public final ConcurrentWeakMap.Core rehash() { int i; Object obj; while (true) { ConcurrentWeakMap.Core core = (ConcurrentWeakMap.Core) ConcurrentWeakMap.this.new Core(Integer.highestOneBit(RangesKt.coerceAtLeast(ConcurrentWeakMap.this.size(), 4)) * 4); int i2 = this.allocated; while (i < i2) { HashedWeakRef hashedWeakRef = (HashedWeakRef) this.keys.get(i); Object obj2 = hashedWeakRef != null ? hashedWeakRef.get() : null; if (hashedWeakRef != null && obj2 == null) { removeCleanedAt(i); } while (true) { obj = this.values.get(i); if (!(obj instanceof Marked)) { if (ConcurrentWeakMap$Core$$ExternalSyntheticBackportWithForwarding0.m(this.values, i, obj, ConcurrentWeakMapKt.mark(obj))) { break; } } else { obj = ((Marked) obj).ref; break; } } i = (obj2 == null || obj == null || core.putImpl(obj2, obj, hashedWeakRef) != ConcurrentWeakMapKt.REHASH) ? i + 1 : 0; } return core; } } public final void cleanWeakRef(HashedWeakRef weakRef) { int iIndex = index(weakRef.hash); while (true) { HashedWeakRef hashedWeakRef = (HashedWeakRef) this.keys.get(iIndex); if (hashedWeakRef == null) { return; } if (hashedWeakRef == weakRef) { removeCleanedAt(iIndex); return; } else { if (iIndex == 0) { iIndex = this.allocated; } iIndex--; } } } public final Iterator keyValueIterator(Function2 factory) { return new KeyValueIterator(factory); } /* JADX INFO: compiled from: ConcurrentWeakMap.kt */ @Metadata(d1 = {"\u00000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010)\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0004\n\u0002\u0010\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0010\u0001\n\u0000\b\u0082\u0004\u0018\u0000*\u0004\b\u0002\u0010\u00012\b\u0012\u0004\u0012\u0002H\u00010\u0002B\u001f\u0012\u0018\u0010\u0003\u001a\u0014\u0012\u0004\u0012\u00028\u0000\u0012\u0004\u0012\u00028\u0001\u0012\u0004\u0012\u00028\u00020\u0004¢\u0006\u0002\u0010\u0005J\b\u0010\u000b\u001a\u00020\fH\u0002J\t\u0010\r\u001a\u00020\u000eH\u0096\u0002J\u000e\u0010\u000f\u001a\u00028\u0002H\u0096\u0002¢\u0006\u0002\u0010\u0010J\b\u0010\u0011\u001a\u00020\u0012H\u0016R \u0010\u0003\u001a\u0014\u0012\u0004\u0012\u00028\u0000\u0012\u0004\u0012\u00028\u0001\u0012\u0004\u0012\u00028\u00020\u0004X\u0082\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0006\u001a\u00020\u0007X\u0082\u000e¢\u0006\u0002\n\u0000R\u0010\u0010\b\u001a\u00028\u0000X\u0082.¢\u0006\u0004\n\u0002\u0010\tR\u0010\u0010\n\u001a\u00028\u0001X\u0082.¢\u0006\u0004\n\u0002\u0010\t¨\u0006\u0013"}, d2 = {"Lkotlinx/coroutines/debug/internal/ConcurrentWeakMap$Core$KeyValueIterator;", "E", "", "factory", "Lkotlin/Function2;", "(Lkotlinx/coroutines/debug/internal/ConcurrentWeakMap$Core;Lkotlin/jvm/functions/Function2;)V", "index", "", "key", "Ljava/lang/Object;", "value", "findNext", "", "hasNext", "", "next", "()Ljava/lang/Object;", "remove", "", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48) private final class KeyValueIterator implements Iterator, KMutableIterator { private final Function2 factory; private int index = -1; private K key; private V value; /* JADX WARN: Multi-variable type inference failed */ public KeyValueIterator(Function2 function2) { this.factory = function2; findNext(); } private final void findNext() { K k; while (true) { int i = this.index + 1; this.index = i; if (i >= ((Core) Core.this).allocated) { return; } HashedWeakRef hashedWeakRef = (HashedWeakRef) Core.this.keys.get(this.index); if (hashedWeakRef != null && (k = (K) hashedWeakRef.get()) != null) { this.key = k; Object obj = (V) Core.this.values.get(this.index); if (obj instanceof Marked) { obj = (V) ((Marked) obj).ref; } if (obj != null) { this.value = (V) obj; return; } } } } @Override // java.util.Iterator public boolean hasNext() { return this.index < ((Core) Core.this).allocated; } /* JADX WARN: Type inference fix 'apply assigned field type' failed java.lang.UnsupportedOperationException: ArgType.getObject(), call class: class jadx.core.dex.instructions.args.ArgType$UnknownArg at jadx.core.dex.instructions.args.ArgType.getObject(ArgType.java:593) at jadx.core.dex.attributes.nodes.ClassTypeVarsAttr.getTypeVarsMapFor(ClassTypeVarsAttr.java:35) at jadx.core.dex.nodes.utils.TypeUtils.replaceClassGenerics(TypeUtils.java:177) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.insertExplicitUseCast(FixTypesVisitor.java:397) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.tryFieldTypeWithNewCasts(FixTypesVisitor.java:359) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.applyFieldType(FixTypesVisitor.java:309) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.visit(FixTypesVisitor.java:94) */ @Override // java.util.Iterator public E next() { if (this.index >= ((Core) Core.this).allocated) { throw new NoSuchElementException(); } Function2 function2 = this.factory; K k = this.key; if (k == false) { Intrinsics.throwUninitializedPropertyAccessException("key"); k = (K) Unit.INSTANCE; } V v = this.value; if (v == false) { Intrinsics.throwUninitializedPropertyAccessException("value"); v = (V) Unit.INSTANCE; } E e = (E) function2.invoke(k, v); findNext(); return e; } @Override // java.util.Iterator public Void remove() { ConcurrentWeakMapKt.noImpl(); throw new KotlinNothingValueException(); } } } /* JADX INFO: Access modifiers changed from: private */ /* JADX INFO: compiled from: ConcurrentWeakMap.kt */ @Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010'\n\u0002\b\u000b\b\u0002\u0018\u0000*\u0004\b\u0002\u0010\u0001*\u0004\b\u0003\u0010\u00022\u000e\u0012\u0004\u0012\u0002H\u0001\u0012\u0004\u0012\u0002H\u00020\u0003B\u0015\u0012\u0006\u0010\u0004\u001a\u00028\u0002\u0012\u0006\u0010\u0005\u001a\u00028\u0003¢\u0006\u0002\u0010\u0006J\u0015\u0010\u000b\u001a\u00028\u00032\u0006\u0010\f\u001a\u00028\u0003H\u0016¢\u0006\u0002\u0010\rR\u0016\u0010\u0004\u001a\u00028\u0002X\u0096\u0004¢\u0006\n\n\u0002\u0010\t\u001a\u0004\b\u0007\u0010\bR\u0016\u0010\u0005\u001a\u00028\u0003X\u0096\u0004¢\u0006\n\n\u0002\u0010\t\u001a\u0004\b\n\u0010\b¨\u0006\u000e"}, d2 = {"Lkotlinx/coroutines/debug/internal/ConcurrentWeakMap$Entry;", "K", "V", "", "key", "value", "(Ljava/lang/Object;Ljava/lang/Object;)V", "getKey", "()Ljava/lang/Object;", "Ljava/lang/Object;", "getValue", "setValue", "newValue", "(Ljava/lang/Object;)Ljava/lang/Object;", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48) static final class Entry implements Map.Entry, KMutableMap.Entry { private final K key; private final V value; public Entry(K k, V v) { this.key = k; this.value = v; } @Override // java.util.Map.Entry public K getKey() { return this.key; } @Override // java.util.Map.Entry public V getValue() { return this.value; } @Override // java.util.Map.Entry public V setValue(V newValue) { ConcurrentWeakMapKt.noImpl(); throw new KotlinNothingValueException(); } } /* JADX INFO: compiled from: ConcurrentWeakMap.kt */ @Metadata(d1 = {"\u0000*\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0010)\n\u0000\b\u0082\u0004\u0018\u0000*\u0004\b\u0002\u0010\u00012\b\u0012\u0004\u0012\u0002H\u00010\u0002B\u001f\u0012\u0018\u0010\u0003\u001a\u0014\u0012\u0004\u0012\u00028\u0000\u0012\u0004\u0012\u00028\u0001\u0012\u0004\u0012\u00028\u00020\u0004¢\u0006\u0002\u0010\u0005J\u0015\u0010\n\u001a\u00020\u000b2\u0006\u0010\f\u001a\u00028\u0002H\u0016¢\u0006\u0002\u0010\rJ\u000f\u0010\u000e\u001a\b\u0012\u0004\u0012\u00028\u00020\u000fH\u0096\u0002R \u0010\u0003\u001a\u0014\u0012\u0004\u0012\u00028\u0000\u0012\u0004\u0012\u00028\u0001\u0012\u0004\u0012\u00028\u00020\u0004X\u0082\u0004¢\u0006\u0002\n\u0000R\u0014\u0010\u0006\u001a\u00020\u00078VX\u0096\u0004¢\u0006\u0006\u001a\u0004\b\b\u0010\t¨\u0006\u0010"}, d2 = {"Lkotlinx/coroutines/debug/internal/ConcurrentWeakMap$KeyValueSet;", "E", "Lkotlin/collections/AbstractMutableSet;", "factory", "Lkotlin/Function2;", "(Lkotlinx/coroutines/debug/internal/ConcurrentWeakMap;Lkotlin/jvm/functions/Function2;)V", "size", "", "getSize", "()I", "add", "", "element", "(Ljava/lang/Object;)Z", "iterator", "", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48) private final class KeyValueSet extends AbstractMutableSet { private final Function2 factory; /* JADX WARN: Multi-variable type inference failed */ public KeyValueSet(Function2 function2) { this.factory = function2; } @Override // kotlin.collections.AbstractMutableSet public int getSize() { return ConcurrentWeakMap.this.size(); } @Override // kotlin.collections.AbstractMutableSet, java.util.AbstractCollection, java.util.Collection, java.util.Set public boolean add(E element) { ConcurrentWeakMapKt.noImpl(); throw new KotlinNothingValueException(); } @Override // java.util.AbstractCollection, java.util.Collection, java.lang.Iterable, java.util.Set public Iterator iterator() { return ((Core) ConcurrentWeakMap.this.core).keyValueIterator(this.factory); } } }