92.0 - Alpha (92200)

This commit is contained in:
Juby210 2021-09-07 08:52:02 +02:00
parent 4732f627f5
commit cb3469a254
1107 changed files with 7486 additions and 7048 deletions

View File

@ -10,8 +10,8 @@ android {
applicationId 'com.discord'
minSdkVersion 21
targetSdkVersion 29
versionCode 91204
versionName "91.4 - Alpha"
versionCode 92200
versionName "92.0 - Alpha"
testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
}

View File

@ -1,5 +1,5 @@
<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android" android:versionCode="91204" android:versionName="91.4 - Alpha" android:installLocation="auto" android:compileSdkVersion="30" android:compileSdkVersionCodename="11" package="com.discord" platformBuildVersionCode="30" platformBuildVersionName="11">
<manifest xmlns:android="http://schemas.android.com/apk/res/android" android:versionCode="92200" android:versionName="92.0 - Alpha" android:installLocation="auto" android:compileSdkVersion="30" android:compileSdkVersionCodename="11" package="com.discord" platformBuildVersionCode="30" platformBuildVersionName="11">
<uses-sdk android:minSdkVersion="21" android:targetSdkVersion="29"/>
<uses-feature android:name="android.hardware.camera" android:required="false"/>
<uses-feature android:name="android.hardware.camera.autofocus" android:required="false"/>
@ -174,7 +174,7 @@
<meta-data android:name="firebase_crashlytics_collection_enabled" android:value="true"/>
<meta-data android:name="com.google.android.nearby.messages.API_KEY" android:value="AIzaSyD-4L6bgKMixqBRtrG2UktVXK6IexXlsog"/>
<meta-data android:name="com.google.android.actions" android:resource="@xml/actions"/>
<meta-data android:name="libdiscord_version" android:value="89.0.11-remove-gameaudio-param"/>
<meta-data android:name="libdiscord_version" android:value="89.0.13-echo-cancellation-stats-jni"/>
<activity android:theme="@style/res_2131952266_theme_appcompat_light_noactionbar" android:name="com.yalantis.ucrop.UCropActivity"/>
<service android:name="androidx.sharetarget.ChooserTargetServiceCompat" android:permission="android.permission.BIND_CHOOSER_TARGET_SERVICE">
<intent-filter>

View File

@ -30,7 +30,7 @@ public class ResultReceiver implements Parcelable {
}
}
public class b extends a.AbstractBinderC0358a {
public class b extends a.AbstractBinderC0359a {
public b() {
}
@ -44,12 +44,12 @@ public class ResultReceiver implements Parcelable {
public ResultReceiver(Parcel parcel) {
x.a.b.c.a aVar;
IBinder readStrongBinder = parcel.readStrongBinder();
int i = a.AbstractBinderC0358a.a;
int i = a.AbstractBinderC0359a.a;
if (readStrongBinder == null) {
aVar = null;
} else {
IInterface queryLocalInterface = readStrongBinder.queryLocalInterface("android.support.v4.os.IResultReceiver");
aVar = (queryLocalInterface == null || !(queryLocalInterface instanceof x.a.b.c.a)) ? new a.AbstractBinderC0358a.C0359a(readStrongBinder) : (x.a.b.c.a) queryLocalInterface;
aVar = (queryLocalInterface == null || !(queryLocalInterface instanceof x.a.b.c.a)) ? new a.AbstractBinderC0359a.C0360a(readStrongBinder) : (x.a.b.c.a) queryLocalInterface;
}
this.i = aVar;
}

View File

@ -48,7 +48,7 @@ public class CustomTabsClient {
}
/* renamed from: androidx.browser.customtabs.CustomTabsClient$2 reason: invalid class name */
public class AnonymousClass2 extends a.AbstractBinderC0347a {
public class AnonymousClass2 extends a.AbstractBinderC0348a {
private Handler mHandler = new Handler(Looper.getMainLooper());
public final /* synthetic */ CustomTabsCallback val$callback;
@ -219,7 +219,7 @@ public class CustomTabsClient {
}
}
private a.AbstractBinderC0347a createCallbackWrapper(@Nullable CustomTabsCallback customTabsCallback) {
private a.AbstractBinderC0348a createCallbackWrapper(@Nullable CustomTabsCallback customTabsCallback) {
return new AnonymousClass2(customTabsCallback);
}
@ -270,7 +270,7 @@ public class CustomTabsClient {
@Nullable
private CustomTabsSession newSessionInternal(@Nullable CustomTabsCallback customTabsCallback, @Nullable PendingIntent pendingIntent) {
boolean z2;
a.AbstractBinderC0347a createCallbackWrapper = createCallbackWrapper(customTabsCallback);
a.AbstractBinderC0348a createCallbackWrapper = createCallbackWrapper(customTabsCallback);
if (pendingIntent != null) {
try {
Bundle bundle = new Bundle();

View File

@ -83,8 +83,8 @@ public class CustomTabsSessionToken {
}
}
public static class MockCallback extends a.AbstractBinderC0347a {
@Override // x.a.a.a.AbstractBinderC0347a, android.os.IInterface
public static class MockCallback extends a.AbstractBinderC0348a {
@Override // x.a.a.a.AbstractBinderC0348a, android.os.IInterface
public IBinder asBinder() {
return this;
}
@ -150,7 +150,7 @@ public class CustomTabsSessionToken {
return null;
}
if (binder != null) {
aVar = a.AbstractBinderC0347a.asInterface(binder);
aVar = a.AbstractBinderC0348a.asInterface(binder);
}
return new CustomTabsSessionToken(aVar, pendingIntent);
}

View File

@ -26,7 +26,7 @@ public abstract class PostMessageServiceConnection implements PostMessageBackend
public PostMessageServiceConnection(@NonNull CustomTabsSessionToken customTabsSessionToken) {
IBinder callbackBinder = customTabsSessionToken.getCallbackBinder();
if (callbackBinder != null) {
this.mSessionBinder = a.AbstractBinderC0347a.asInterface(callbackBinder);
this.mSessionBinder = a.AbstractBinderC0348a.asInterface(callbackBinder);
return;
}
throw new IllegalArgumentException("Provided session must have binder.");

View File

@ -15,7 +15,7 @@ public class TrustedWebActivityCallbackRemote {
@Nullable
public static TrustedWebActivityCallbackRemote fromBinder(@Nullable IBinder iBinder) {
a asInterface = iBinder == null ? null : a.AbstractBinderC0351a.asInterface(iBinder);
a asInterface = iBinder == null ? null : a.AbstractBinderC0352a.asInterface(iBinder);
if (asInterface == null) {
return null;
}

View File

@ -23,7 +23,7 @@ public final class TrustedWebActivityServiceConnection {
private final b mService;
/* renamed from: androidx.browser.trusted.TrustedWebActivityServiceConnection$1 reason: invalid class name */
public class AnonymousClass1 extends a.AbstractBinderC0351a {
public class AnonymousClass1 extends a.AbstractBinderC0352a {
public final /* synthetic */ TrustedWebActivityCallback val$callback;
public AnonymousClass1(TrustedWebActivityCallback trustedWebActivityCallback) {

View File

@ -9,7 +9,7 @@ import android.os.RemoteException;
import x.a.b.a.a;
public abstract class NotificationCompatSideChannelService extends Service {
public class NotificationSideChannelStub extends a.AbstractBinderC0354a {
public class NotificationSideChannelStub extends a.AbstractBinderC0355a {
public NotificationSideChannelStub() {
}

View File

@ -224,7 +224,7 @@ public final class NotificationManagerCompat {
private void handleServiceConnected(ComponentName componentName, IBinder iBinder) {
ListenerRecord listenerRecord = this.mRecordMap.get(componentName);
if (listenerRecord != null) {
listenerRecord.service = a.AbstractBinderC0354a.asInterface(iBinder);
listenerRecord.service = a.AbstractBinderC0355a.asInterface(iBinder);
listenerRecord.retryCount = 0;
processListenerQueue(listenerRecord);
}

View File

@ -14,7 +14,7 @@ public final class RangeKt$toClosedRange$1 implements a<T> {
@Override // d0.d0.a
public boolean contains(T t) {
m.checkParameterIsNotNull(t, "value");
return a.C0194a.contains(this, t);
return a.C0195a.contains(this, t);
}
/* JADX WARNING: Unknown variable types count: 1 */
@ -30,6 +30,6 @@ public final class RangeKt$toClosedRange$1 implements a<T> {
}
public boolean isEmpty() {
return a.C0194a.isEmpty(this);
return a.C0195a.isEmpty(this);
}
}

View File

@ -37,9 +37,9 @@ public final /* synthetic */ class a0 extends k implements Function1<Pair<? exte
linkedHashMap.put(entry.getKey(), Integer.valueOf(((EncodeQuality) entry.getValue()).getValue()));
}
m.checkNotNullParameter(linkedHashMap, "wants");
aVar.b();
aVar.G.a();
if (aVar.q >= 5) {
aVar.o(15, linkedHashMap);
aVar.n(15, linkedHashMap);
}
}
}

View File

@ -53,9 +53,9 @@ public final class b0 implements MediaEngineConnection.d {
rtcConnection.n = dVar;
rtcConnection.o = false;
}
if (transportInfo.f2174c.ordinal() != 0) {
if (transportInfo.f2175c.ordinal() != 0) {
StringBuilder P = c.d.b.a.a.P("Unsupported protocol: ");
P.append(transportInfo.f2174c);
P.append(transportInfo.f2175c);
P.append('.');
RtcConnection.j(rtcConnection, true, P.toString(), null, false, 12);
} else {
@ -71,13 +71,13 @@ public final class b0 implements MediaEngineConnection.d {
m.checkNotNullParameter(str, "address");
m.checkNotNullParameter("xsalsa20_poly1305", "mode");
m.checkNotNullParameter(list, "codecs");
aVar.b();
aVar.G.a();
Payloads.Protocol.ProtocolInfo protocolInfo = new Payloads.Protocol.ProtocolInfo(str, i, "xsalsa20_poly1305");
ArrayList arrayList = new ArrayList(o.collectionSizeOrDefault(list, 10));
for (a aVar2 : list) {
arrayList.add(new Payloads.Protocol.CodecInfo(aVar2.a, aVar2.b, aVar2.f220c, aVar2.d, aVar2.e));
}
aVar.o(1, new Payloads.Protocol("udp", protocolInfo, arrayList));
aVar.n(1, new Payloads.Protocol("udp", protocolInfo, arrayList));
}
for (RtcConnection.c cVar : rtcConnection.m) {
cVar.onMediaEngineConnectionConnected(rtcConnection);
@ -172,8 +172,8 @@ public final class b0 implements MediaEngineConnection.d {
c.a.q.n0.a aVar;
RtcConnection rtcConnection = this.a;
if (j == rtcConnection.S && (aVar = rtcConnection.v) != null) {
aVar.b();
aVar.o(5, new Payloads.Speaking(i, Integer.valueOf(z2 ? 1 : 0), 0, null, 8, null));
aVar.G.a();
aVar.n(5, new Payloads.Speaking(i, Integer.valueOf(z2 ? 1 : 0), 0, null, 8, null));
}
for (RtcConnection.c cVar : rtcConnection.m) {
cVar.onSpeaking(j, z2);
@ -210,8 +210,8 @@ public final class b0 implements MediaEngineConnection.d {
arrayList.add(new Payloads.Stream(str, rid, valueOf6, valueOf5, valueOf, valueOf2, new Payloads.Stream.MaxResolution(resolutionType, bVar.a, bVar.b), valueOf3, valueOf4));
}
m.checkNotNullParameter(arrayList, "streams");
aVar.b();
aVar.o(12, new Payloads.Video(i, i2, i3, null, arrayList));
aVar.G.a();
aVar.n(12, new Payloads.Video(i, i2, i3, null, arrayList));
}
MediaSinkWantsManager mediaSinkWantsManager = rtcConnection.G;
if (mediaSinkWantsManager != null) {

View File

@ -1,6 +1,9 @@
package c.a.q;
import android.os.Handler;
import android.os.Looper;
import android.os.Process;
import com.airbnb.lottie.parser.AnimatableValueParser;
import d0.z.d.m;
import java.util.Collection;
import java.util.List;
@ -40,6 +43,16 @@ public final class c implements ExecutorService {
executorService.submit(new a(this));
}
public final void a() {
if (Process.myTid() != this.j) {
IllegalStateException illegalStateException = new IllegalStateException("oops! not called on the MediaEngineExecutor");
AnimatableValueParser.F1("MediaEngineExecutor", "oops! not called on the MediaEngineExecutor", illegalStateException);
if (this.l) {
new Handler(Looper.getMainLooper()).post(new d(illegalStateException));
}
}
}
@Override // java.util.concurrent.ExecutorService
public boolean awaitTermination(long j, TimeUnit timeUnit) {
return this.k.awaitTermination(j, timeUnit);

View File

@ -293,11 +293,11 @@ public final class h0 implements a.d {
m.checkNotNullParameter(str, "serverId");
m.checkNotNullParameter(str2, "sessionId");
m.checkNotNullParameter(listOf, "streams");
aVar.b();
aVar.G.a();
aVar.f226s = str;
aVar.t = str2;
aVar.A = a.c.IDENTIFYING;
aVar.o(0, new Payloads.Identify(str, j, str2, aVar.D, z2, listOf));
aVar.n(0, new Payloads.Identify(str, j, str2, aVar.D, z2, listOf));
rtcConnection.u(RtcConnection.State.a.a);
}

View File

@ -216,7 +216,7 @@ public final class b extends ScreenCapturerAndroid {
if (thumbnailEmitter != null) {
synchronized (thumbnailEmitter) {
thumbnailEmitter.d.release();
thumbnailEmitter.f2177c.release();
thumbnailEmitter.f2178c.release();
JniCommon.nativeFreeByteBuffer(thumbnailEmitter.b);
thumbnailEmitter.a = RecyclerView.FOREVER_NS;
}

View File

@ -46,7 +46,7 @@ public final class e implements MediaEngineConnection {
public final Connection j;
public final c.a.q.c k;
public final Logger l;
public final t m;
public final u m;
public final Discord n;
public final List<c.a.q.m0.a> o;
public final MediaEngineConnection.Type p;
@ -288,7 +288,7 @@ public final class e implements MediaEngineConnection {
Connection connection2 = connection;
d0.z.d.m.checkNotNullParameter(connection2, "$receiver");
connection2.setVADLeadingFramesToBuffer(this.$inputModeOptions.b);
connection2.setVADTrailingFramesToSend(this.$inputModeOptions.f2176c);
connection2.setVADTrailingFramesToSend(this.$inputModeOptions.f2177c);
connection2.setVADTriggerThreshold((float) this.$inputModeOptions.a);
connection2.setVADAutoThreshold(this.$inputModeOptions.d ? 3 : -1);
connection2.setVADUseKrisp(this.$inputModeOptions.e);
@ -431,7 +431,7 @@ public final class e implements MediaEngineConnection {
Connection connection2 = connection;
d0.z.d.m.checkNotNullParameter(connection2, "$receiver");
MediaEngineConnection.b bVar = this.$quality;
connection2.setEncodingQuality(bVar.a, bVar.b, bVar.f2175c, bVar.d, this.$framerate);
connection2.setEncodingQuality(bVar.a, bVar.b, bVar.f2176c, bVar.d, this.$framerate);
return Unit.a;
}
}
@ -547,10 +547,10 @@ public final class e implements MediaEngineConnection {
}
}
public e(c.a.q.c cVar, Logger logger, t tVar, Discord discord, List<c.a.q.m0.a> list, MediaEngineConnection.Type type, long j2, MediaEngine.a aVar, List<? extends MediaEngineConnection.d> list2) {
public e(c.a.q.c cVar, Logger logger, u uVar, Discord discord, List<c.a.q.m0.a> list, MediaEngineConnection.Type type, long j2, MediaEngine.a aVar, List<? extends MediaEngineConnection.d> list2) {
d0.z.d.m.checkNotNullParameter(cVar, "mediaEngineThreadExecutor");
d0.z.d.m.checkNotNullParameter(logger, "logger");
d0.z.d.m.checkNotNullParameter(tVar, "noiseCancellationConfig");
d0.z.d.m.checkNotNullParameter(uVar, "noiseCancellationConfig");
d0.z.d.m.checkNotNullParameter(discord, "voiceEngineLegacy");
d0.z.d.m.checkNotNullParameter(list, "supportedVideoCodecs");
d0.z.d.m.checkNotNullParameter(type, "type");
@ -558,7 +558,7 @@ public final class e implements MediaEngineConnection {
d0.z.d.m.checkNotNullParameter(list2, "listeners");
this.k = cVar;
this.l = logger;
this.m = tVar;
this.m = uVar;
this.n = discord;
this.o = list;
this.p = type;
@ -568,7 +568,7 @@ public final class e implements MediaEngineConnection {
this.d = h0.mutableMapOf(d0.o.to(Long.valueOf(j2), Integer.valueOf(aVar.a)));
int i2 = aVar.a;
String str = aVar.b;
int i3 = aVar.f2173c;
int i3 = aVar.f2174c;
Object[] array = aVar.d.toArray(new StreamParameters[0]);
Objects.requireNonNull(array, "null cannot be cast to non-null type kotlin.Array<T>");
Connection connectToServer = discord.connectToServer(i2, j2, str, i3, (StreamParameters[]) array, new d(this));
@ -660,11 +660,11 @@ public final class e implements MediaEngineConnection {
public void k(MediaEngineConnection.InputMode inputMode, MediaEngineConnection.c cVar) {
d0.z.d.m.checkNotNullParameter(inputMode, "inputMode");
d0.z.d.m.checkNotNullParameter(cVar, "inputModeOptions");
t tVar = this.m;
u uVar = this.m;
if (inputMode == MediaEngineConnection.InputMode.VOICE_ACTIVITY) {
boolean z2 = cVar.d;
}
Objects.requireNonNull(tVar);
Objects.requireNonNull(uVar);
z(new j(cVar, inputMode));
}

View File

@ -6,7 +6,7 @@ import d0.z.d.o;
import kotlin.Unit;
import kotlin.jvm.functions.Function1;
/* compiled from: MediaEngineLegacy.kt */
public final class j extends o implements Function1<MediaEngine.b, Unit> {
public final class j extends o implements Function1<MediaEngine.c, Unit> {
public static final j i = new j();
public j() {
@ -16,10 +16,10 @@ public final class j extends o implements Function1<MediaEngine.b, Unit> {
/* Return type fixed from 'java.lang.Object' to match base method */
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [java.lang.Object] */
@Override // kotlin.jvm.functions.Function1
public Unit invoke(MediaEngine.b bVar) {
MediaEngine.b bVar2 = bVar;
m.checkNotNullParameter(bVar2, "it");
bVar2.onConnecting();
public Unit invoke(MediaEngine.c cVar) {
MediaEngine.c cVar2 = cVar;
m.checkNotNullParameter(cVar2, "it");
cVar2.onConnecting();
return Unit.a;
}
}

View File

@ -17,6 +17,7 @@ import d0.z.d.m;
import d0.z.d.o;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.Set;
import java.util.concurrent.Future;
import kotlin.Unit;
@ -34,20 +35,22 @@ public final class k implements MediaEngine {
public static final Set<String> b = n0.setOf((Object[]) new String[]{"Pixel 3a", "Redmi Note 8 Pro", "Redmi Note 8 pro"});
/* renamed from: c reason: collision with root package name */
public final t f224c;
public final u f224c;
public final List<MediaEngineConnection> d;
public boolean e;
public Discord f;
public List<c.a.q.m0.a> g;
public MediaEngine.OpenSLUsageMode h;
public final Context i;
public final MediaEngine.b j;
public final c.a.q.c k;
public final MediaEngine.OpenSLESConfig l;
public final Logger m;
public final c.a.q.k0.g n;
public final Set<String> o;
public final Set<String> p;
public MediaEngine.EchoCancellationInfo i;
public final Context j;
public final MediaEngine.c k;
public final c.a.q.c l;
public final MediaEngine.OpenSLESConfig m;
public final Logger n;
public final c.a.q.k0.g o;
public final MediaEngine.b p;
public final Set<String> q;
public final Set<String> r;
/* compiled from: MediaEngineLegacy.kt */
public static final class a extends o implements Function0<Unit> {
@ -72,7 +75,7 @@ public final class k implements MediaEngine {
}
/* compiled from: MediaEngineLegacy.kt */
public static final class b extends o implements Function1<MediaEngine.b, Unit> {
public static final class b extends o implements Function1<MediaEngine.c, Unit> {
public final /* synthetic */ e $connection;
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
@ -84,10 +87,10 @@ public final class k implements MediaEngine {
/* Return type fixed from 'java.lang.Object' to match base method */
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [java.lang.Object] */
@Override // kotlin.jvm.functions.Function1
public Unit invoke(MediaEngine.b bVar) {
MediaEngine.b bVar2 = bVar;
m.checkNotNullParameter(bVar2, "it");
bVar2.onNewConnection(this.$connection);
public Unit invoke(MediaEngine.c cVar) {
MediaEngine.c cVar2 = cVar;
m.checkNotNullParameter(cVar2, "it");
cVar2.onNewConnection(this.$connection);
return Unit.a;
}
}
@ -231,7 +234,7 @@ public final class k implements MediaEngine {
Emitter<MediaEngine.AudioInfo> emitter2 = emitter;
Discord discord = this.i.f;
if (discord != null) {
discord.getAudioSubsystem(new n(emitter2));
discord.getAudioSubsystem(new o(emitter2));
}
}
}
@ -287,16 +290,62 @@ public final class k implements MediaEngine {
}
/* compiled from: MediaEngineLegacy.kt */
public static final class h implements Logging.ExternalReporter {
public static final class h implements Discord.BuiltinAECCallback {
public final /* synthetic */ c.a.q.k0.g a;
public final /* synthetic */ k b;
/* compiled from: MediaEngineLegacy.kt */
public static final class a extends o implements Function0<Unit> {
public final /* synthetic */ boolean $available;
public final /* synthetic */ boolean $enabled;
public final /* synthetic */ boolean $requestEnabled;
public final /* synthetic */ h this$0;
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
public a(h hVar, boolean z2, boolean z3, boolean z4) {
super(0);
this.this$0 = hVar;
this.$enabled = z2;
this.$requestEnabled = z3;
this.$available = z4;
}
/* Return type fixed from 'java.lang.Object' to match base method */
@Override // kotlin.jvm.functions.Function0
/* renamed from: invoke */
public Unit mo1invoke() {
this.this$0.a.d = this.$enabled;
k kVar = this.this$0.b;
boolean z2 = this.$requestEnabled;
boolean z3 = this.$available;
Objects.requireNonNull(kVar.o);
kVar.i = new MediaEngine.EchoCancellationInfo(z2, z3, WebRtcAudioUtils.isAcousticEchoCancelerSupported(), this.$enabled, false, false, false, false, false, 496);
return Unit.a;
}
}
public h(c.a.q.k0.g gVar, Discord discord, k kVar) {
this.a = gVar;
this.b = kVar;
}
@Override // com.hammerandchisel.libdiscord.Discord.BuiltinAECCallback
public final void onConfigureBuiltinAEC(boolean z2, boolean z3, boolean z4) {
this.b.o(new a(this, z4, z2, z3));
}
}
/* compiled from: MediaEngineLegacy.kt */
public static final class i implements Logging.ExternalReporter {
public final /* synthetic */ k a;
public h(k kVar) {
public i(k kVar) {
this.a = kVar;
}
@Override // org.webrtc.Logging.ExternalReporter
public final void e(String str, String str2, Throwable th) {
Logger logger = this.a.m;
Logger logger = this.a.n;
m.checkNotNullExpressionValue(str, "tag");
m.checkNotNullExpressionValue(str2, "message");
Logger.e$default(logger, str, str2, th, null, 8, null);
@ -304,31 +353,32 @@ public final class k implements MediaEngine {
}
/* compiled from: MediaEngineLegacy.kt */
public static final /* synthetic */ class i extends d0.z.d.k implements Function1<MediaEngine.b, Unit> {
public static final i i = new i();
public static final /* synthetic */ class j extends d0.z.d.k implements Function1<MediaEngine.c, Unit> {
public static final j i = new j();
public i() {
super(1, MediaEngine.b.class, "onNativeEngineInitialized", "onNativeEngineInitialized()V", 0);
public j() {
super(1, MediaEngine.c.class, "onNativeEngineInitialized", "onNativeEngineInitialized()V", 0);
}
/* Return type fixed from 'java.lang.Object' to match base method */
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [java.lang.Object] */
@Override // kotlin.jvm.functions.Function1
public Unit invoke(MediaEngine.b bVar) {
MediaEngine.b bVar2 = bVar;
m.checkNotNullParameter(bVar2, "p1");
bVar2.onNativeEngineInitialized();
public Unit invoke(MediaEngine.c cVar) {
MediaEngine.c cVar2 = cVar;
m.checkNotNullParameter(cVar2, "p1");
cVar2.onNativeEngineInitialized();
return Unit.a;
}
}
/* compiled from: MediaEngineLegacy.kt */
public static final class j extends o implements Function0<Unit> {
/* renamed from: c.a.q.m0.c.k$k reason: collision with other inner class name */
public static final class C0040k extends o implements Function0<Unit> {
public final /* synthetic */ MediaEngine.VoiceConfig $voiceConfig;
public final /* synthetic */ k this$0;
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
public j(k kVar, MediaEngine.VoiceConfig voiceConfig) {
public C0040k(k kVar, MediaEngine.VoiceConfig voiceConfig) {
super(0);
this.this$0 = kVar;
this.$voiceConfig = voiceConfig;
@ -351,22 +401,23 @@ public final class k implements MediaEngine {
}
k kVar2 = this.this$0;
boolean z3 = voiceConfig.b;
c.a.q.k0.g gVar = kVar2.n;
kVar2.l.a();
c.a.q.k0.g gVar = kVar2.o;
if (gVar.g && gVar.d) {
z2 = false;
} else {
c.a.q.k0.g gVar2 = kVar2.n;
c.a.q.k0.g gVar2 = kVar2.o;
z2 = gVar2.f && !gVar2.d ? true : z3;
}
if (z2 != z3) {
AnimatableValueParser.E1("MediaEngineLegacy", "ignoring call to setEchoCancellation(" + z3 + "), config=" + kVar2.n);
AnimatableValueParser.E1("MediaEngineLegacy", "ignoring call to setEchoCancellation(" + z3 + "), config=" + kVar2.o);
}
Discord discord2 = kVar2.f;
if (discord2 != null) {
discord2.setEchoCancellation(z2);
discord2.setEchoCancellation(z2, false, new m(kVar2));
}
k kVar3 = this.this$0;
boolean z4 = voiceConfig.f2172c;
boolean z4 = voiceConfig.f2173c;
Discord discord3 = kVar3.f;
if (discord3 != null) {
discord3.setNoiseSuppression(z4);
@ -393,27 +444,29 @@ public final class k implements MediaEngine {
}
}
public k(Context context, MediaEngine.b bVar, c.a.q.c cVar, MediaEngine.OpenSLESConfig openSLESConfig, Logger logger, c.a.q.k0.g gVar, Set set, Set set2, int i2) {
public k(Context context, MediaEngine.c cVar, c.a.q.c cVar2, MediaEngine.OpenSLESConfig openSLESConfig, Logger logger, c.a.q.k0.g gVar, MediaEngine.b bVar, Set set, Set set2, int i2) {
Set<String> set3 = null;
Set<String> set4 = (i2 & 64) != 0 ? a : null;
set3 = (i2 & 128) != 0 ? b : set3;
Set<String> set4 = (i2 & 128) != 0 ? a : null;
set3 = (i2 & 256) != 0 ? b : set3;
m.checkNotNullParameter(context, "context");
m.checkNotNullParameter(bVar, "listener");
m.checkNotNullParameter(cVar, "mediaEngineThreadExecutor");
m.checkNotNullParameter(cVar, "listener");
m.checkNotNullParameter(cVar2, "mediaEngineThreadExecutor");
m.checkNotNullParameter(openSLESConfig, "openSLESConfig");
m.checkNotNullParameter(logger, "logger");
m.checkNotNullParameter(gVar, "echoCancellation");
m.checkNotNullParameter(bVar, "echoCancellationCallback");
m.checkNotNullParameter(set4, "defaultOpenSLAllowList");
m.checkNotNullParameter(set3, "defaultOpenSLExcludeList");
this.i = context;
this.j = bVar;
this.j = context;
this.k = cVar;
this.l = openSLESConfig;
this.m = logger;
this.n = gVar;
this.o = set4;
this.p = set3;
this.f224c = new t();
this.l = cVar2;
this.m = openSLESConfig;
this.n = logger;
this.o = gVar;
this.p = bVar;
this.q = set4;
this.r = set3;
this.f224c = new u();
this.d = new ArrayList();
this.e = true;
this.h = MediaEngine.OpenSLUsageMode.ALLOW_LIST;
@ -442,7 +495,7 @@ public final class k implements MediaEngine {
m.checkNotNullExpressionValue(w, "Observable.error(Illegal…ze native media engine\"))");
return w;
}
Observable n = Observable.n(new p(this), Emitter.BackpressureMode.NONE);
Observable n = Observable.n(new q(this), Emitter.BackpressureMode.NONE);
m.checkNotNullExpressionValue(n, "Observable.create({ emit…er.BackpressureMode.NONE)");
Observable<Unit> F = n.t(new e(this)).F(f.i);
m.checkNotNullExpressionValue(F, "getSupportedVideoCodecs(…s }\n .map { Unit }");
@ -456,20 +509,20 @@ public final class k implements MediaEngine {
p();
Discord discord = this.f;
if (discord != null) {
discord.getRankedRtcRegions(rtcRegionArr, new q(function1));
discord.getRankedRtcRegions(rtcRegionArr, new r(function1));
}
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngine
public c.a.q.c c() {
return this.k;
return this.l;
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngine
@AnyThread
public void d(MediaEngine.VoiceConfig voiceConfig) {
m.checkNotNullParameter(voiceConfig, "voiceConfig");
o(new j(this, voiceConfig));
o(new C0040k(this, voiceConfig));
}
@Override // com.discord.rtcconnection.mediaengine.MediaEngine
@ -498,21 +551,21 @@ public final class k implements MediaEngine {
}
Discord discord = this.f;
if (discord == null) {
Logger.e$default(this.m, "MediaEngineLegacy", "connect() called without voiceEngineLegacy.", null, null, 12, null);
Logger.e$default(this.n, "MediaEngineLegacy", "connect() called without voiceEngineLegacy.", null, null, 12, null);
return null;
}
o(new a(this));
Logger logger = this.m;
Logger logger = this.n;
Logger.i$default(logger, "MediaEngineLegacy", "Connecting with options: " + aVar, null, 4, null);
c cVar = new c(this);
c.a.q.c cVar2 = this.k;
Logger logger2 = this.m;
t tVar = this.f224c;
c.a.q.c cVar2 = this.l;
Logger logger2 = this.n;
u uVar = this.f224c;
List<c.a.q.m0.a> list = this.g;
if (list == null) {
m.throwUninitializedPropertyAccessException("supportedVideoCodecs");
}
e eVar = new e(cVar2, logger2, tVar, discord, list, type, j2, aVar, d0.t.m.listOf(cVar));
e eVar = new e(cVar2, logger2, uVar, discord, list, type, j2, aVar, d0.t.m.listOf(cVar));
this.d.add(eVar);
n(new b(eVar));
return eVar;
@ -527,7 +580,7 @@ public final class k implements MediaEngine {
public void h(MediaEngine.OpenSLUsageMode openSLUsageMode) {
m.checkNotNullParameter(openSLUsageMode, "openSLUsageMode");
if (this.f != null) {
Logger.e$default(this.m, "MediaEngineLegacy", "setting openSLUsageMode too late", null, null, 12, null);
Logger.e$default(this.n, "MediaEngineLegacy", "setting openSLUsageMode too late", null, null, 12, null);
}
this.h = openSLUsageMode;
}
@ -543,7 +596,7 @@ public final class k implements MediaEngine {
p();
Discord discord = this.f;
if (discord != null) {
discord.getVideoInputDevices(new r(function1));
discord.getVideoInputDevices(new s(function1));
}
}
@ -573,41 +626,41 @@ public final class k implements MediaEngine {
}
}
public final void n(Function1<? super MediaEngine.b, Unit> function1) {
public final void n(Function1<? super MediaEngine.c, Unit> function1) {
try {
function1.invoke(this.j);
function1.invoke(this.k);
} catch (Exception e2) {
Logger.e$default(this.m, "MediaEngineLegacy", "Error in listener", e2, null, 8, null);
Logger.e$default(this.n, "MediaEngineLegacy", "Error in listener", e2, null, 8, null);
}
}
/* JADX WARN: Multi-variable type inference failed */
/* JADX WARNING: Unknown variable types count: 1 */
public final Future<?> o(Function0<Unit> function0) {
c.a.q.c cVar = this.k;
c.a.q.c cVar = this.l;
if (function0 != null) {
function0 = new s(function0);
function0 = new t(function0);
}
return cVar.submit((Runnable) function0);
}
public final void p() {
if (this.f == null) {
Logger logger = this.m;
Logger logger = this.n;
StringBuilder P = c.d.b.a.a.P("initializing voice engine. OpenSL ES: ");
P.append(this.l);
P.append(this.m);
P.append(", OpenSL usage mode: ");
P.append(this.h);
Logger.i$default(logger, "MediaEngineLegacy", P.toString(), null, 4, null);
int ordinal = this.l.ordinal();
int ordinal = this.m.ordinal();
boolean z2 = false;
if (ordinal == 0) {
if (this.h == MediaEngine.OpenSLUsageMode.ALLOW_LIST) {
z2 = this.o.contains(Build.MODEL);
} else if (!this.p.contains(Build.MODEL)) {
z2 = this.q.contains(Build.MODEL);
} else if (!this.r.contains(Build.MODEL)) {
z2 = true;
}
Logger logger2 = this.m;
Logger logger2 = this.n;
StringBuilder P2 = c.d.b.a.a.P("OpenSL ES default. mode: ");
P2.append(this.h);
P2.append(", enableOpenSL: ");
@ -620,27 +673,24 @@ public final class k implements MediaEngine {
} else if (ordinal == 2) {
WebRtcAudioManager.setBlacklistDeviceForOpenSLESUsage(true);
}
Logging.externalReporter = new h(this);
Logging.externalReporter = new i(this);
try {
Discord discord = new Discord(this.i, 2);
c.a.q.k0.g gVar = this.n;
Discord discord = new Discord(this.j, 2);
c.a.q.k0.g gVar = this.o;
if (gVar.e) {
discord.enableBuiltInAEC(true);
if (WebRtcAudioUtils.isAcousticEchoCancelerSupported()) {
gVar.d = true;
}
discord.enableBuiltInAEC(true, new h(gVar, discord, this));
}
discord.setAudioInputEnabled(this.e);
this.f = discord;
} catch (ExceptionInInitializerError e2) {
Logger.e$default(this.m, "MediaEngineLegacy", "Unable to initialize voice engine.", e2, null, 8, null);
Logger.e$default(this.n, "MediaEngineLegacy", "Unable to initialize voice engine.", e2, null, 8, null);
} catch (UnsatisfiedLinkError e3) {
Logger.e$default(this.m, "MediaEngineLegacy", "Unable to initialize voice engine.", e3, null, 8, null);
Logger.e$default(this.n, "MediaEngineLegacy", "Unable to initialize voice engine.", e3, null, 8, null);
} catch (Throwable th) {
Logger.e$default(this.m, "MediaEngineLegacy", "Unable to initialize voice engine, new error discovered", th, null, 8, null);
Logger.e$default(this.n, "MediaEngineLegacy", "Unable to initialize voice engine, new error discovered", th, null, 8, null);
}
if (this.f != null) {
n(i.i);
n(j.i);
}
}
}

View File

@ -6,7 +6,7 @@ import d0.z.d.o;
import kotlin.Unit;
import kotlin.jvm.functions.Function1;
/* compiled from: MediaEngineLegacy.kt */
public final class l extends o implements Function1<MediaEngine.b, Unit> {
public final class l extends o implements Function1<MediaEngine.c, Unit> {
public static final l i = new l();
public l() {
@ -16,10 +16,10 @@ public final class l extends o implements Function1<MediaEngine.b, Unit> {
/* Return type fixed from 'java.lang.Object' to match base method */
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [java.lang.Object] */
@Override // kotlin.jvm.functions.Function1
public Unit invoke(MediaEngine.b bVar) {
MediaEngine.b bVar2 = bVar;
m.checkNotNullParameter(bVar2, "it");
bVar2.onConnected();
public Unit invoke(MediaEngine.c cVar) {
MediaEngine.c cVar2 = cVar;
m.checkNotNullParameter(cVar2, "it");
cVar2.onConnected();
return Unit.a;
}
}

View File

@ -1,11 +1,57 @@
package c.a.q.m0.c;
import d0.u.a;
import java.util.Comparator;
/* compiled from: Comparisons.kt */
public final class m<T> implements Comparator<T> {
@Override // java.util.Comparator
public final int compare(T t, T t2) {
return a.compareValues(Integer.valueOf(!d0.z.d.m.areEqual(t, "H264") ? 1 : 0), Integer.valueOf(!d0.z.d.m.areEqual(t2, "H264") ? 1 : 0));
import com.airbnb.lottie.parser.AnimatableValueParser;
import com.discord.rtcconnection.mediaengine.MediaEngine;
import com.hammerandchisel.libdiscord.Discord;
import d0.z.d.o;
import kotlin.Unit;
import kotlin.jvm.functions.Function0;
/* compiled from: MediaEngineLegacy.kt */
public final class m implements Discord.AecConfigCallback {
public final /* synthetic */ k a;
/* compiled from: MediaEngineLegacy.kt */
public static final class a extends o implements Function0<Unit> {
public final /* synthetic */ boolean $enabled;
public final /* synthetic */ boolean $previouslyEnabled;
public final /* synthetic */ boolean $previouslyMobileMode;
public final /* synthetic */ boolean $requestEnable;
public final /* synthetic */ boolean $requestMobileMode;
public final /* synthetic */ m this$0;
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
public a(m mVar, boolean z2, boolean z3, boolean z4, boolean z5, boolean z6) {
super(0);
this.this$0 = mVar;
this.$requestEnable = z2;
this.$enabled = z3;
this.$requestMobileMode = z4;
this.$previouslyEnabled = z5;
this.$previouslyMobileMode = z6;
}
/* Return type fixed from 'java.lang.Object' to match base method */
@Override // kotlin.jvm.functions.Function0
/* renamed from: invoke */
public Unit mo1invoke() {
k kVar = this.this$0.a;
MediaEngine.EchoCancellationInfo echoCancellationInfo = kVar.i;
kVar.i = null;
if (echoCancellationInfo != null) {
MediaEngine.EchoCancellationInfo echoCancellationInfo2 = new MediaEngine.EchoCancellationInfo(echoCancellationInfo.a, echoCancellationInfo.b, echoCancellationInfo.f2172c, echoCancellationInfo.d, this.$requestEnable, this.$enabled, this.$requestMobileMode, this.$previouslyEnabled, this.$previouslyMobileMode);
AnimatableValueParser.G1("MediaEngineLegacy", "onEchoCancellationUpdated: " + echoCancellationInfo2);
this.this$0.a.p.onEchoCancellationUpdated(echoCancellationInfo2);
}
return Unit.a;
}
}
public m(k kVar) {
this.a = kVar;
}
@Override // com.hammerandchisel.libdiscord.Discord.AecConfigCallback
public final void onConfigureAEC(boolean z2, boolean z3, boolean z4, boolean z5, boolean z6) {
this.a.o(new a(this, z2, z4, z3, z5, z6));
}
}

View File

@ -1,22 +1,12 @@
package c.a.q.m0.c;
import com.discord.rtcconnection.mediaengine.MediaEngine;
import com.hammerandchisel.libdiscord.Discord;
import d0.u.a;
import d0.z.d.m;
import rx.Emitter;
/* compiled from: MediaEngineLegacy.kt */
public final class n implements Discord.GetAudioSubsystemCallback {
public final /* synthetic */ Emitter a;
public n(Emitter emitter) {
this.a = emitter;
}
@Override // com.hammerandchisel.libdiscord.Discord.GetAudioSubsystemCallback
public final void onAudioSubsystem(String str, String str2) {
m.checkNotNullParameter(str, "audioSubsystem");
m.checkNotNullParameter(str2, "audioLayer");
this.a.onNext(new MediaEngine.AudioInfo(str, str2));
this.a.onCompleted();
import java.util.Comparator;
/* compiled from: Comparisons.kt */
public final class n<T> implements Comparator<T> {
@Override // java.util.Comparator
public final int compare(T t, T t2) {
return a.compareValues(Integer.valueOf(!m.areEqual(t, "H264") ? 1 : 0), Integer.valueOf(!m.areEqual(t2, "H264") ? 1 : 0));
}
}

View File

@ -1,55 +1,22 @@
package c.a.q.m0.c;
import c.a.q.m0.a;
import com.discord.rtcconnection.mediaengine.MediaEngine;
import com.hammerandchisel.libdiscord.Discord;
import d0.t.n;
import d0.t.u;
import d0.z.d.m;
import java.util.ArrayList;
import java.util.List;
import java.util.Locale;
import java.util.Objects;
import java.util.Set;
import org.webrtc.MediaStreamTrack;
import rx.Emitter;
/* compiled from: MediaEngineLegacy.kt */
public final class o implements Discord.GetSupportedVideoCodecsCallback {
public final /* synthetic */ p a;
public final /* synthetic */ Emitter b;
public final class o implements Discord.GetAudioSubsystemCallback {
public final /* synthetic */ Emitter a;
public o(p pVar, Emitter emitter) {
this.a = pVar;
this.b = emitter;
public o(Emitter emitter) {
this.a = emitter;
}
@Override // com.hammerandchisel.libdiscord.Discord.GetSupportedVideoCodecsCallback
public final void onSupportedVideoCodecs(String[] strArr) {
m.checkNotNullParameter(strArr, "videoCodecsStringArray");
k kVar = this.a.i;
Set<String> set = k.a;
Objects.requireNonNull(kVar);
ArrayList arrayList = new ArrayList(strArr.length);
int i = 0;
for (String str : strArr) {
Locale locale = Locale.ROOT;
m.checkNotNullExpressionValue(locale, "Locale.ROOT");
Objects.requireNonNull(str, "null cannot be cast to non-null type java.lang.String");
String upperCase = str.toUpperCase(locale);
m.checkNotNullExpressionValue(upperCase, "(this as java.lang.String).toUpperCase(locale)");
arrayList.add(upperCase);
}
List sortedWith = u.sortedWith(arrayList, new m());
ArrayList arrayList2 = new ArrayList(d0.t.o.collectionSizeOrDefault(sortedWith, 10));
for (Object obj : sortedWith) {
int i2 = i + 1;
if (i < 0) {
n.throwIndexOverflow();
}
int i3 = (i * 2) + 101;
arrayList2.add(new a((String) obj, i2, MediaStreamTrack.VIDEO_TRACK_KIND, i3, Integer.valueOf(i3 + 1)));
i = i2;
}
this.b.onNext(arrayList2);
this.b.onCompleted();
@Override // com.hammerandchisel.libdiscord.Discord.GetAudioSubsystemCallback
public final void onAudioSubsystem(String str, String str2) {
m.checkNotNullParameter(str, "audioSubsystem");
m.checkNotNullParameter(str2, "audioLayer");
this.a.onNext(new MediaEngine.AudioInfo(str, str2));
this.a.onCompleted();
}
}

View File

@ -2,24 +2,55 @@ package c.a.q.m0.c;
import c.a.q.m0.a;
import com.hammerandchisel.libdiscord.Discord;
import d0.t.n;
import d0.t.o;
import d0.t.u;
import d0.z.d.m;
import java.util.ArrayList;
import java.util.List;
import java.util.Locale;
import java.util.Objects;
import java.util.Set;
import org.webrtc.MediaStreamTrack;
import rx.Emitter;
import rx.functions.Action1;
/* compiled from: MediaEngineLegacy.kt */
public final class p<T> implements Action1<Emitter<List<? extends a>>> {
public final /* synthetic */ k i;
public final class p implements Discord.GetSupportedVideoCodecsCallback {
public final /* synthetic */ q a;
public final /* synthetic */ Emitter b;
public p(k kVar) {
this.i = kVar;
public p(q qVar, Emitter emitter) {
this.a = qVar;
this.b = emitter;
}
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [java.lang.Object] */
@Override // rx.functions.Action1
public void call(Emitter<List<? extends a>> emitter) {
Emitter<List<? extends a>> emitter2 = emitter;
Discord discord = this.i.f;
if (discord != null) {
discord.getSupportedVideoCodecs(new o(this, emitter2));
@Override // com.hammerandchisel.libdiscord.Discord.GetSupportedVideoCodecsCallback
public final void onSupportedVideoCodecs(String[] strArr) {
m.checkNotNullParameter(strArr, "videoCodecsStringArray");
k kVar = this.a.i;
Set<String> set = k.a;
Objects.requireNonNull(kVar);
ArrayList arrayList = new ArrayList(strArr.length);
int i = 0;
for (String str : strArr) {
Locale locale = Locale.ROOT;
m.checkNotNullExpressionValue(locale, "Locale.ROOT");
Objects.requireNonNull(str, "null cannot be cast to non-null type java.lang.String");
String upperCase = str.toUpperCase(locale);
m.checkNotNullExpressionValue(upperCase, "(this as java.lang.String).toUpperCase(locale)");
arrayList.add(upperCase);
}
List sortedWith = u.sortedWith(arrayList, new n());
ArrayList arrayList2 = new ArrayList(o.collectionSizeOrDefault(sortedWith, 10));
for (Object obj : sortedWith) {
int i2 = i + 1;
if (i < 0) {
n.throwIndexOverflow();
}
int i3 = (i * 2) + 101;
arrayList2.add(new a((String) obj, i2, MediaStreamTrack.VIDEO_TRACK_KIND, i3, Integer.valueOf(i3 + 1)));
i = i2;
}
this.b.onNext(arrayList2);
this.b.onCompleted();
}
}

View File

@ -1,20 +1,25 @@
package c.a.q.m0.c;
import androidx.annotation.NonNull;
import c.a.q.m0.a;
import com.hammerandchisel.libdiscord.Discord;
import d0.z.d.m;
import kotlin.jvm.functions.Function1;
import java.util.List;
import rx.Emitter;
import rx.functions.Action1;
/* compiled from: MediaEngineLegacy.kt */
public final class q implements Discord.GetRankedRtcRegionsCallback {
public final /* synthetic */ Function1 a;
public final class q<T> implements Action1<Emitter<List<? extends a>>> {
public final /* synthetic */ k i;
public q(Function1 function1) {
this.a = function1;
public q(k kVar) {
this.i = kVar;
}
@Override // com.hammerandchisel.libdiscord.Discord.GetRankedRtcRegionsCallback
public final /* synthetic */ void onRankedRtcRegions(@NonNull String[] strArr) {
m.checkNotNullParameter(strArr, "p0");
m.checkNotNullExpressionValue(this.a.invoke(strArr), "invoke(...)");
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [java.lang.Object] */
@Override // rx.functions.Action1
public void call(Emitter<List<? extends a>> emitter) {
Emitter<List<? extends a>> emitter2 = emitter;
Discord discord = this.i.f;
if (discord != null) {
discord.getSupportedVideoCodecs(new p(this, emitter2));
}
}
}

View File

@ -1,21 +1,20 @@
package c.a.q.m0.c;
import androidx.annotation.NonNull;
import co.discord.media_engine.VideoInputDeviceDescription;
import com.hammerandchisel.libdiscord.Discord;
import d0.z.d.m;
import kotlin.jvm.functions.Function1;
/* compiled from: MediaEngineLegacy.kt */
public final class r implements Discord.GetVideoInputDevicesCallback {
public final class r implements Discord.GetRankedRtcRegionsCallback {
public final /* synthetic */ Function1 a;
public r(Function1 function1) {
this.a = function1;
}
@Override // com.hammerandchisel.libdiscord.Discord.GetVideoInputDevicesCallback
public final /* synthetic */ void onDevices(@NonNull VideoInputDeviceDescription[] videoInputDeviceDescriptionArr) {
m.checkNotNullParameter(videoInputDeviceDescriptionArr, "p0");
m.checkNotNullExpressionValue(this.a.invoke(videoInputDeviceDescriptionArr), "invoke(...)");
@Override // com.hammerandchisel.libdiscord.Discord.GetRankedRtcRegionsCallback
public final /* synthetic */ void onRankedRtcRegions(@NonNull String[] strArr) {
m.checkNotNullParameter(strArr, "p0");
m.checkNotNullExpressionValue(this.a.invoke(strArr), "invoke(...)");
}
}

View File

@ -1,17 +1,21 @@
package c.a.q.m0.c;
import androidx.annotation.NonNull;
import co.discord.media_engine.VideoInputDeviceDescription;
import com.hammerandchisel.libdiscord.Discord;
import d0.z.d.m;
import kotlin.jvm.functions.Function0;
import kotlin.jvm.functions.Function1;
/* compiled from: MediaEngineLegacy.kt */
public final class s implements Runnable {
public final /* synthetic */ Function0 i;
public final class s implements Discord.GetVideoInputDevicesCallback {
public final /* synthetic */ Function1 a;
public s(Function0 function0) {
this.i = function0;
public s(Function1 function1) {
this.a = function1;
}
@Override // java.lang.Runnable
public final /* synthetic */ void run() {
m.checkNotNullExpressionValue(this.i.mo1invoke(), "invoke(...)");
@Override // com.hammerandchisel.libdiscord.Discord.GetVideoInputDevicesCallback
public final /* synthetic */ void onDevices(@NonNull VideoInputDeviceDescription[] videoInputDeviceDescriptionArr) {
m.checkNotNullParameter(videoInputDeviceDescriptionArr, "p0");
m.checkNotNullExpressionValue(this.a.invoke(videoInputDeviceDescriptionArr), "invoke(...)");
}
}

View File

@ -1,5 +1,17 @@
package c.a.q.m0.c;
/* compiled from: NoiseCancellationConfig.kt */
public final class t {
public boolean a;
import d0.z.d.m;
import kotlin.jvm.functions.Function0;
/* compiled from: MediaEngineLegacy.kt */
public final class t implements Runnable {
public final /* synthetic */ Function0 i;
public t(Function0 function0) {
this.i = function0;
}
@Override // java.lang.Runnable
public final /* synthetic */ void run() {
m.checkNotNullExpressionValue(this.i.mo1invoke(), "invoke(...)");
}
}

View File

@ -0,0 +1,5 @@
package c.a.q.m0.c;
/* compiled from: NoiseCancellationConfig.kt */
public final class u {
public boolean a;
}

View File

@ -1,11 +1,7 @@
package c.a.q.n0;
import android.os.Handler;
import android.os.Looper;
import android.os.Process;
import androidx.annotation.AnyThread;
import androidx.core.app.NotificationCompat;
import com.airbnb.lottie.parser.AnimatableValueParser;
import com.discord.models.domain.ModelAuditLogEntry;
import com.discord.rtcconnection.socket.io.Opcodes;
import com.discord.rtcconnection.socket.io.Payloads;
@ -42,7 +38,7 @@ import okhttp3.WebSocketListener;
/* compiled from: RtcControlSocket.kt */
public final class a extends WebSocketListener implements DebugPrintable {
public static int i;
public static final Type j = new C0040a().getType();
public static final Type j = new C0041a().getType();
public static final b k = new b(null);
public c A;
public boolean B;
@ -79,7 +75,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
/* compiled from: RtcControlSocket.kt */
/* renamed from: c.a.q.n0.a$a reason: collision with other inner class name */
public static final class C0040a extends TypeToken<Map<String, ? extends Integer>> {
public static final class C0041a extends TypeToken<Map<String, ? extends Integer>> {
}
/* compiled from: RtcControlSocket.kt */
@ -171,11 +167,11 @@ public final class a extends WebSocketListener implements DebugPrintable {
/* compiled from: RtcControlSocket.kt */
/* renamed from: c.a.q.n0.a$g$a reason: collision with other inner class name */
public static final class C0041a extends o implements Function0<Unit> {
public static final class C0042a extends o implements Function0<Unit> {
public final /* synthetic */ g this$0;
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
public C0041a(g gVar) {
public C0042a(g gVar) {
super(0);
this.this$0 = gVar;
}
@ -195,7 +191,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
@Override // java.util.TimerTask, java.lang.Runnable
public void run() {
this.i.n(new C0041a(this));
this.i.m(new C0042a(this));
}
}
@ -284,8 +280,8 @@ public final class a extends WebSocketListener implements DebugPrintable {
long currentTimeMillis = aVar.H.currentTimeMillis();
Long l = aVar.f229z;
long longValue = currentTimeMillis - (l != null ? l.longValue() : 0);
aVar.j("[READY] took " + longValue + " ms");
aVar.b();
aVar.i("[READY] took " + longValue + " ms");
aVar.G.a();
for (d dVar : aVar.p) {
m.checkNotNullExpressionValue(dVar, "it");
dVar.k(ready.getPort(), ready.getSsrc(), ready.getIp(), ready.getStreams());
@ -293,14 +289,14 @@ public final class a extends WebSocketListener implements DebugPrintable {
break;
case 3:
a aVar2 = this.this$0;
aVar2.o(3, String.valueOf(aVar2.H.currentTimeMillis()));
aVar2.n(3, String.valueOf(aVar2.H.currentTimeMillis()));
break;
case 4:
a aVar3 = this.this$0;
Object c3 = aVar3.m.c(this.$message.getData(), Payloads.Description.class);
m.checkNotNullExpressionValue(c3, "gson.fromJson(message.da….Description::class.java)");
Payloads.Description description = (Payloads.Description) c3;
aVar3.b();
aVar3.G.a();
for (d dVar2 : aVar3.p) {
m.checkNotNullExpressionValue(dVar2, "it");
dVar2.c(description.getMode(), description.getSecretKey());
@ -322,7 +318,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
if (speaking2 == null || speaking2.intValue() != 1) {
z2 = false;
}
aVar4.b();
aVar4.G.a();
for (d dVar3 : aVar4.p) {
m.checkNotNullExpressionValue(dVar3, "it");
dVar3.onSpeaking(speaking.getUserId().longValue(), speaking.getSsrc(), z2);
@ -336,10 +332,10 @@ public final class a extends WebSocketListener implements DebugPrintable {
long longValue2 = ((Number) c5).longValue();
long currentTimeMillis2 = aVar5.H.currentTimeMillis();
long j = currentTimeMillis2 - longValue2;
aVar5.i("got heartbeat ack after " + j + " ms");
aVar5.h("got heartbeat ack after " + j + " ms");
aVar5.f227x = Long.valueOf(currentTimeMillis2);
aVar5.v = true;
aVar5.b();
aVar5.G.a();
for (d dVar4 : aVar5.p) {
m.checkNotNullExpressionValue(dVar4, "it");
dVar4.g(j);
@ -352,7 +348,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
a aVar6 = this.this$0;
StringBuilder P = c.d.b.a.a.P("unknown opcode: ");
P.append(this.$message.getOpcode());
aVar6.j(P.toString());
aVar6.i(P.toString());
break;
case 8:
a aVar7 = this.this$0;
@ -363,12 +359,12 @@ public final class a extends WebSocketListener implements DebugPrintable {
if (timerTask != null) {
timerTask.cancel();
}
aVar7.j("[HELLO] raw: " + hello);
aVar7.i("[HELLO] raw: " + hello);
aVar7.u = Long.valueOf(hello.getHeartbeatIntervalMs());
aVar7.q = hello.getServerVersion();
aVar7.w.cancel();
aVar7.v = true;
aVar7.l();
aVar7.k();
break;
case 9:
this.this$0.o.succeed();
@ -379,7 +375,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
m.checkNotNullExpressionValue(c7, "gson.fromJson(message.da…yloads.Video::class.java)");
Payloads.Video video = (Payloads.Video) c7;
if (video.getUserId() != null) {
aVar8.b();
aVar8.G.a();
for (d dVar5 : aVar8.p) {
m.checkNotNullExpressionValue(dVar5, "it");
dVar5.e(video.getUserId().longValue(), video.getAudioSsrc(), video.getVideoSsrc(), video.getStreams());
@ -392,7 +388,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
Object c8 = aVar9.m.c(this.$message.getData(), Payloads.ClientDisconnect.class);
m.checkNotNullExpressionValue(c8, "gson.fromJson(message.da…ntDisconnect::class.java)");
Payloads.ClientDisconnect clientDisconnect = (Payloads.ClientDisconnect) c8;
aVar9.b();
aVar9.G.a();
for (d dVar6 : aVar9.p) {
m.checkNotNullExpressionValue(dVar6, "it");
dVar6.j(clientDisconnect.getUserId());
@ -403,7 +399,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
Object c9 = aVar10.m.c(this.$message.getData(), Payloads.SessionUpdate.class);
m.checkNotNullExpressionValue(c9, "gson.fromJson(message.da…essionUpdate::class.java)");
Payloads.SessionUpdate sessionUpdate = (Payloads.SessionUpdate) c9;
aVar10.b();
aVar10.G.a();
for (d dVar7 : aVar10.p) {
m.checkNotNullExpressionValue(dVar7, "it");
String mediaSessionId2 = sessionUpdate.getMediaSessionId();
@ -421,7 +417,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
Object d = data == null ? null : gson.d(new c.i.d.q.x.a(data), type);
m.checkNotNullExpressionValue(d, "gson.fromJson(message.data, MEDIA_SINK_WANTS_TYPE)");
Map<String, Integer> map = (Map) d;
aVar11.b();
aVar11.G.a();
for (d dVar8 : aVar11.p) {
m.checkNotNullExpressionValue(dVar8, "it");
dVar8.f(map);
@ -454,7 +450,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
a aVar = this.this$0;
c cVar = aVar.A;
if (cVar == c.CONNECTING) {
aVar.b();
aVar.G.a();
for (d dVar : aVar.p) {
m.checkNotNullExpressionValue(dVar, "it");
dVar.i();
@ -472,16 +468,16 @@ public final class a extends WebSocketListener implements DebugPrintable {
P.append(aVar.B);
P.append(" -- isHeartbeatRecentEnough: ");
P.append(z2);
aVar.g(false, 4801, P.toString());
aVar.f(false, 4801, P.toString());
} else {
aVar.j("[RESUME] resuming session. serverId=" + str2 + " sessionId=" + str);
aVar.b();
aVar.i("[RESUME] resuming session. serverId=" + str2 + " sessionId=" + str);
aVar.G.a();
for (d dVar2 : aVar.p) {
m.checkNotNullExpressionValue(dVar2, "it");
dVar2.h();
}
aVar.A = c.RESUMING;
aVar.o(7, new Payloads.Resume(str3, str, str2));
aVar.n(7, new Payloads.Resume(str3, str, str2));
}
}
a aVar2 = this.this$0;
@ -492,9 +488,9 @@ public final class a extends WebSocketListener implements DebugPrintable {
a aVar3 = this.this$0;
StringBuilder P2 = c.d.b.a.a.P("[CONNECTED] to ");
P2.append(this.this$0.C);
aVar3.j(P2.toString());
aVar3.i(P2.toString());
a aVar4 = this.this$0;
aVar4.b();
aVar4.G.a();
for (d dVar3 : aVar4.p) {
m.checkNotNullExpressionValue(dVar3, "it");
dVar3.g(longValue / ((long) 2));
@ -553,30 +549,18 @@ public final class a extends WebSocketListener implements DebugPrintable {
public static final void a(a aVar, boolean z2, Integer num, String str) {
aVar.A = c.DISCONNECTED;
if ((num != null && num.intValue() == 4004) || ((num != null && num.intValue() == 4015) || ((num != null && num.intValue() == 4011) || (num != null && num.intValue() == 4006)))) {
aVar.g(true, num, str);
aVar.f(true, num, str);
} else if (aVar.o.hasReachedFailureThreshold()) {
aVar.k("[WS CLOSED] Backoff exceeded. Resetting.");
aVar.g(z2, num, str);
aVar.j("[WS CLOSED] Backoff exceeded. Resetting.");
aVar.f(z2, num, str);
} else {
aVar.c(null);
aVar.b(null);
String M = c.d.b.a.a.M(new Object[]{Double.valueOf(((double) aVar.o.fail(new c(aVar, z2, num, str))) / 1000.0d)}, 1, "%.2f", "java.lang.String.format(this, *args)");
aVar.k("`[WS CLOSED] (" + z2 + ", " + num + ", " + str + ") retrying in " + M + " seconds.");
aVar.j("`[WS CLOSED] (" + z2 + ", " + num + ", " + str + ") retrying in " + M + " seconds.");
}
}
public final void b() {
c.a.q.c cVar = this.G;
Objects.requireNonNull(cVar);
if (Process.myTid() != cVar.j) {
IllegalStateException illegalStateException = new IllegalStateException("oops! not called on the MediaEngineExecutor");
AnimatableValueParser.F1("MediaEngineExecutor", "oops! not called on the MediaEngineExecutor", illegalStateException);
if (cVar.l) {
new Handler(Looper.getMainLooper()).post(new c.a.q.d(illegalStateException));
}
}
}
public final void c(Function1<? super WebSocket, Unit> function1) {
public final void b(Function1<? super WebSocket, Unit> function1) {
this.o.cancel();
this.w.cancel();
TimerTask timerTask = this.f228y;
@ -590,21 +574,37 @@ public final class a extends WebSocketListener implements DebugPrintable {
this.r = null;
}
public final void d() {
b();
j("[CLOSE]");
c(e.i);
public final void c() {
this.G.a();
i("[CLOSE]");
b(e.i);
this.f226s = null;
this.t = null;
this.B = false;
this.A = c.DISCONNECTED;
b();
this.G.a();
for (d dVar : this.p) {
m.checkNotNullExpressionValue(dVar, "it");
dVar.b(false, 1000, "Force Close");
}
}
public final boolean d() {
this.G.a();
if (this.A != c.DISCONNECTED) {
j("Cannot start a new connection, connection state is not disconnected");
return false;
}
this.A = c.CONNECTING;
e();
this.G.a();
for (d dVar : this.p) {
m.checkNotNullExpressionValue(dVar, "it");
dVar.onConnecting();
}
return true;
}
@Override // com.discord.utilities.debug.DebugPrintable
public void debugPrint(DebugPrintBuilder debugPrintBuilder) {
m.checkNotNullParameter(debugPrintBuilder, "dp");
@ -617,29 +617,13 @@ public final class a extends WebSocketListener implements DebugPrintable {
debugPrintBuilder.appendKeyValue("resumable", Boolean.valueOf(this.B));
}
public final boolean e() {
b();
if (this.A != c.DISCONNECTED) {
k("Cannot start a new connection, connection state is not disconnected");
return false;
}
this.A = c.CONNECTING;
f();
b();
for (d dVar : this.p) {
m.checkNotNullExpressionValue(dVar, "it");
dVar.onConnecting();
}
return true;
}
public final void f() {
public final void e() {
StringBuilder P = c.d.b.a.a.P("[CONNECT] ");
P.append(this.C);
j(P.toString());
i(P.toString());
if (this.r != null) {
this.F.e(this.l, "Connect called with already existing websocket", null, null);
c(f.i);
b(f.i);
return;
}
this.f229z = Long.valueOf(this.H.currentTimeMillis());
@ -654,65 +638,65 @@ public final class a extends WebSocketListener implements DebugPrintable {
aVar.a(1, TimeUnit.MINUTES);
SSLSocketFactory sSLSocketFactory = this.E;
if (sSLSocketFactory != null) {
h.a aVar2 = f0.e0.k.h.f2826c;
h.a aVar2 = f0.e0.k.h.f2827c;
aVar.b(sSLSocketFactory, f0.e0.k.h.a.n());
}
String H = c.d.b.a.a.H(new StringBuilder(), this.C, "?v=5");
j("attempting WSS connection with " + H);
i("attempting WSS connection with " + H);
x xVar = new x(aVar);
Request.a aVar3 = new Request.a();
aVar3.f(H);
this.r = xVar.g(aVar3.a(), this);
}
public final void g(boolean z2, Integer num, String str) {
k("[DISCONNECT] (" + z2 + ", " + num + ", " + str + ')');
c(null);
public final void f(boolean z2, Integer num, String str) {
j("[DISCONNECT] (" + z2 + ", " + num + ", " + str + ')');
b(null);
this.f226s = null;
this.t = null;
this.B = false;
this.A = c.DISCONNECTED;
b();
this.G.a();
for (d dVar : this.p) {
m.checkNotNullExpressionValue(dVar, "it");
dVar.b(z2, num, str);
}
}
public final void h(long j2, String str, boolean z2) {
public final void g(long j2, String str, boolean z2) {
m.checkNotNullParameter(str, ModelAuditLogEntry.CHANGE_KEY_REASON);
b();
this.G.a();
if (this.r != null) {
j("Performing an immediate heartbeat on existing socket: " + str);
i("Performing an immediate heartbeat on existing socket: " + str);
this.w.cancel();
b bVar = new b(this);
this.w = bVar;
this.n.schedule(bVar, j2);
} else if (!z2) {
j("Immediate heartbeat requested, but is disconnected and a reset was not requested: " + str);
i("Immediate heartbeat requested, but is disconnected and a reset was not requested: " + str);
} else if (this.o.isPending() && this.r == null) {
j("Connection backoff reset Immediate heartbeat when socket was disconnected.");
i("Connection backoff reset Immediate heartbeat when socket was disconnected.");
this.o.succeed();
m(false, 4802, "Reset backoff.");
l(false, 4802, "Reset backoff.");
}
}
public final void i(String str) {
public final void h(String str) {
Logger.d$default(this.F, this.l, str, null, 4, null);
}
public final void j(String str) {
public final void i(String str) {
Logger.i$default(this.F, this.l, str, null, 4, null);
}
public final void k(String str) {
public final void j(String str) {
Logger.w$default(this.F, this.l, str, null, 4, null);
}
public final void l() {
public final void k() {
if (this.v) {
this.v = false;
o(3, String.valueOf(this.H.currentTimeMillis()));
n(3, String.valueOf(this.H.currentTimeMillis()));
Long l2 = this.u;
if (l2 != null) {
b bVar = new b(this);
@ -720,25 +704,25 @@ public final class a extends WebSocketListener implements DebugPrintable {
this.n.schedule(bVar, l2.longValue());
return;
}
k("onHeartbeatInterval called when heartbeatInterval was null");
j("onHeartbeatInterval called when heartbeatInterval was null");
return;
}
c(d.i);
b(d.i);
String M = c.d.b.a.a.M(new Object[]{Double.valueOf(((double) this.o.fail(new e(this))) / 1000.0d)}, 1, "%.2f", "java.lang.String.format(this, *args)");
k("[ACK TIMEOUT] reconnecting in " + M + " seconds.");
j("[ACK TIMEOUT] reconnecting in " + M + " seconds.");
}
public final void m(boolean z2, Integer num, String str) {
j("[RECONNECT] wasFatal=" + z2 + " code=" + num + " reason=" + str);
c(l.i);
public final void l(boolean z2, Integer num, String str) {
i("[RECONNECT] wasFatal=" + z2 + " code=" + num + " reason=" + str);
b(l.i);
this.A = c.RECONNECTING;
f();
e();
}
/* JADX WARN: Multi-variable type inference failed */
/* JADX WARNING: Unknown variable types count: 1 */
@AnyThread
public final void n(Function0<Unit> function0) {
public final void m(Function0<Unit> function0) {
c.a.q.c cVar = this.G;
if (function0 != null) {
function0 = new f(function0);
@ -746,7 +730,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
cVar.k.execute((Runnable) function0);
}
public final void o(int i2, Object obj) {
public final void n(int i2, Object obj) {
WebSocket webSocket = this.r;
if (webSocket == null) {
StringBuilder P = c.d.b.a.a.P("opcode() websocket null. opcode: ");
@ -756,11 +740,11 @@ public final class a extends WebSocketListener implements DebugPrintable {
}
try {
String m = this.m.m(new Payloads.Outgoing(i2, obj));
i("sending (" + Opcodes.INSTANCE.getNameOf(i2) + "): " + m);
h("sending (" + Opcodes.INSTANCE.getNameOf(i2) + "): " + m);
m.checkNotNullExpressionValue(m, "json");
webSocket.a(m);
} catch (Exception unused) {
k("exception sending opcode: " + i2 + " and payload: " + obj);
j("exception sending opcode: " + i2 + " and payload: " + obj);
}
}
@ -769,7 +753,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
m.checkNotNullParameter(webSocket, "webSocket");
m.checkNotNullParameter(str, ModelAuditLogEntry.CHANGE_KEY_REASON);
super.onClosed(webSocket, i2, str);
n(new h(this, webSocket, i2, str));
m(new h(this, webSocket, i2, str));
}
@Override // okhttp3.WebSocketListener
@ -784,7 +768,7 @@ public final class a extends WebSocketListener implements DebugPrintable {
m.checkNotNullParameter(webSocket, "webSocket");
m.checkNotNullParameter(th, "t");
super.onFailure(webSocket, th, response);
n(new i(this, webSocket, th));
m(new i(this, webSocket, th));
}
@Override // okhttp3.WebSocketListener
@ -797,8 +781,8 @@ public final class a extends WebSocketListener implements DebugPrintable {
P.append(Opcodes.INSTANCE.getNameOf(incoming.getOpcode()));
P.append("): ");
P.append(incoming);
i(P.toString());
n(new j(this, webSocket, incoming));
h(P.toString());
m(new j(this, webSocket, incoming));
}
@Override // okhttp3.WebSocketListener
@ -806,6 +790,6 @@ public final class a extends WebSocketListener implements DebugPrintable {
m.checkNotNullParameter(webSocket, "webSocket");
m.checkNotNullParameter(response, "response");
super.onOpen(webSocket, response);
n(new k(this, webSocket));
m(new k(this, webSocket));
}
}

View File

@ -24,7 +24,7 @@ public final class b extends TimerTask {
public Unit mo1invoke() {
a aVar = this.this$0.i;
int i = a.i;
aVar.l();
aVar.k();
return Unit.a;
}
}
@ -35,6 +35,6 @@ public final class b extends TimerTask {
@Override // java.util.TimerTask, java.lang.Runnable
public void run() {
this.i.n(new a(this));
this.i.m(new a(this));
}
}

View File

@ -28,7 +28,7 @@ public final class c extends o implements Function0<Unit> {
Integer num = this.$code;
String str = this.$reason;
int i = a.i;
aVar.m(z2, num, str);
aVar.l(z2, num, str);
return Unit.a;
}
}

View File

@ -19,7 +19,7 @@ public final class e extends o implements Function0<Unit> {
public Unit mo1invoke() {
a aVar = this.this$0;
int i = a.i;
aVar.m(true, 4800, "Heartbeat timeout.");
aVar.l(true, 4800, "Heartbeat timeout.");
return Unit.a;
}
}

View File

@ -29,9 +29,9 @@ public final class o extends d0.z.d.o implements Function0<Unit> {
if (aVar == null) {
RtcConnection.o(rtcConnection, "handleConnectivityChange() socket was null.", null, null, 6);
} else if (booleanValue) {
aVar.h(5000, "network detected online", true);
aVar.g(5000, "network detected online", true);
} else {
aVar.h(15000, "network detected offline", false);
aVar.g(15000, "network detected offline", false);
}
return Unit.a;
}

View File

@ -64,13 +64,13 @@ public final /* synthetic */ class a extends k implements Function1<Stats, Unit>
Map.Entry<String, InboundRtpVideo> next = it.next();
String key = next.getKey();
InboundRtpVideo value = next.getValue();
Map<String, e.C0042e> map = eVar2.m;
e.C0042e eVar3 = map.get(key);
Map<String, e.C0043e> map = eVar2.m;
e.C0043e eVar3 = map.get(key);
if (eVar3 == null) {
eVar3 = new e.C0042e();
eVar3 = new e.C0043e();
map.put(key, eVar3);
}
e.C0042e eVar4 = eVar3;
e.C0043e eVar4 = eVar3;
try {
eVar = eVar2;
} catch (Throwable th2) {

View File

@ -38,8 +38,8 @@ public final class e {
public final d i;
public final d j;
public final d k;
public final C0042e l = new C0042e();
public final Map<String, C0042e> m = new LinkedHashMap();
public final C0043e l = new C0043e();
public final Map<String, C0043e> m = new LinkedHashMap();
public final Map<Long, Long> n = new LinkedHashMap();
public int o;
public final DeviceResourceUsageMonitor p;
@ -176,7 +176,7 @@ public final class e {
/* compiled from: VideoQuality.kt */
/* renamed from: c.a.q.o0.e$e reason: collision with other inner class name */
public static final class C0042e {
public static final class C0043e {
public List<g> a = new ArrayList();
public final Histogram b = new Histogram(5, 0, 2, null);
@ -190,7 +190,7 @@ public final class e {
public float i;
public Map<Integer, Float> j = new LinkedHashMap();
public C0042e() {
public C0043e() {
for (Number number : e.a) {
this.g.put(Integer.valueOf(number.intValue()), Float.valueOf(0.0f));
}
@ -277,8 +277,8 @@ public final class e {
e eVar = this.this$0;
List<Integer> list = e.a;
synchronized (eVar) {
for (Map.Entry<String, C0042e> entry : eVar.m.entrySet()) {
C0042e value = entry.getValue();
for (Map.Entry<String, C0043e> entry : eVar.m.entrySet()) {
C0043e value = entry.getValue();
value.b.addSample((long) resourceUsage2.getCpuUsagePercent());
value.f233c.addSample(resourceUsage2.getMemoryRssBytes());
}
@ -307,7 +307,7 @@ public final class e {
deviceResourceUsageMonitor.start();
}
public final void a(C0042e eVar, g gVar) {
public final void a(C0043e eVar, g gVar) {
eVar.a.add(gVar);
if (eVar.a.size() >= 2) {
List<g> list = eVar.a;
@ -388,7 +388,7 @@ public final class e {
@AnyThread
public final synchronized Map<String, Object> b(String str) {
C0042e eVar;
C0043e eVar;
m.checkNotNullParameter(str, "userId");
eVar = this.m.get(str);
return eVar != null ? d(eVar) : null;
@ -407,7 +407,7 @@ public final class e {
(wrap: java.lang.Long : 0x04d4: INVOKE (r1v2 java.lang.Long) = (r4v22 long) type: STATIC call: java.lang.Long.valueOf(long):java.lang.Long)
type: STATIC call: d0.o.to(java.lang.Object, java.lang.Object):kotlin.Pair)
*/
public final Map<String, Object> d(C0042e eVar) {
public final Map<String, Object> d(C0043e eVar) {
Float valueOf;
long currentTimeMillis = this.r.currentTimeMillis();
Long l = this.h;

View File

@ -34,7 +34,7 @@ public final class s extends o implements Function0<Unit> {
if (str == null || str.length() == 0) {
a aVar = rtcConnection.v;
if (aVar != null) {
aVar.d();
aVar.c();
}
rtcConnection.u(RtcConnection.State.b.a);
} else {
@ -43,7 +43,7 @@ public final class s extends o implements Function0<Unit> {
String replace$default2 = t.replace$default(v, ":80", ":443", false, 4, (Object) null);
a aVar2 = rtcConnection.v;
if (aVar2 != null) {
aVar2.d();
aVar2.c();
}
if (rtcConnection.t) {
RtcConnection.j(rtcConnection, false, "Connect called on destroyed instance.", null, false, 4);
@ -62,7 +62,7 @@ public final class s extends o implements Function0<Unit> {
h0 h0Var = rtcConnection.L;
m.checkNotNullParameter(h0Var, "listener");
aVar3.p.add(h0Var);
aVar3.e();
aVar3.d();
rtcConnection.v = aVar3;
}
}

View File

@ -77,7 +77,7 @@ public final class b extends k implements Function2<CoroutineScope, Continuation
}
String joinToString$default = u.joinToString$default(arrayList, "&", null, null, 0, null, null, 62, null);
RequestBody.Companion companion = RequestBody.Companion;
MediaType.a aVar = MediaType.f2943c;
MediaType.a aVar = MediaType.f2944c;
RequestBody a = companion.a(joinToString$default, MediaType.a.a(ShareTarget.ENCODING_TYPE_URL_ENCODED));
Request.a aVar2 = new Request.a();
m.checkParameterIsNotNull(a, "body");

View File

@ -3,7 +3,7 @@ package c.a.r;
import c.n.a.a.a;
import com.discord.samsung.SamsungConnectActivity;
/* compiled from: SamsungConnectActivity.kt */
public final class d extends a.AbstractBinderC0157a {
public final class d extends a.AbstractBinderC0158a {
public final /* synthetic */ SamsungConnectActivity a;
public d(SamsungConnectActivity samsungConnectActivity) {

View File

@ -39,7 +39,7 @@ public final class b extends ContentObserver {
/* compiled from: ScreenshotContentObserver.kt */
/* renamed from: c.a.s.b$b reason: collision with other inner class name */
public static final class C0043b {
public static final class C0044b {
public final String a;
public final long b;
@ -49,7 +49,7 @@ public final class b extends ContentObserver {
public final Uri e;
public final long f;
public C0043b(long j, String str, String str2, Uri uri, long j2) {
public C0044b(long j, String str, String str2, Uri uri, long j2) {
m.checkNotNullParameter(str, "fileName");
m.checkNotNullParameter(str2, "relativePath");
m.checkNotNullParameter(uri, NotificationCompat.MessagingStyle.Message.KEY_DATA_URI);
@ -65,10 +65,10 @@ public final class b extends ContentObserver {
if (this == obj) {
return true;
}
if (!(obj instanceof C0043b)) {
if (!(obj instanceof C0044b)) {
return false;
}
C0043b bVar = (C0043b) obj;
C0044b bVar = (C0044b) obj;
return this.b == bVar.b && m.areEqual(this.f236c, bVar.f236c) && m.areEqual(this.d, bVar.d) && m.areEqual(this.e, bVar.e) && this.f == bVar.f;
}
@ -126,7 +126,7 @@ public final class b extends ContentObserver {
/* JADX WARNING: Removed duplicated region for block: B:31:0x00c3 */
/* JADX WARNING: Removed duplicated region for block: B:45:? A[RETURN, SYNTHETIC] */
public final void a(Uri uri) {
C0043b bVar;
C0044b bVar;
String str;
ContentResolver contentResolver = this.d;
int i = Build.VERSION.SDK_INT;
@ -145,7 +145,7 @@ public final class b extends ContentObserver {
String string2 = query.getString(query.getColumnIndex("_display_name"));
m.checkNotNullExpressionValue(string2, "cursor.getString(cursor.…ages.Media.DISPLAY_NAME))");
m.checkNotNullExpressionValue(str, "relativePath");
bVar = new C0043b(j, string2, str, uri, query.getLong(query.getColumnIndex("date_added")));
bVar = new C0044b(j, string2, str, uri, query.getLong(query.getColumnIndex("date_added")));
d0.y.b.closeFinally(query, null);
if (bVar != null) {
String str2 = this.b;

View File

@ -52,7 +52,7 @@ public final class a extends Rule<R, Node<R>, S> {
if (list != null) {
List parse = parser.parse(group2, s2, list);
Objects.requireNonNull(parse, "null cannot be cast to non-null type kotlin.collections.List<com.discord.simpleast.core.node.Node<R>>");
aVar = new CodeNode.a.C0177a(group2, parse);
aVar = new CodeNode.a.C0178a(group2, parse);
} else {
aVar = new CodeNode.a.b(group2);
}

View File

@ -13,7 +13,7 @@ public final class h extends Rule<RC, Node<RC>, S> {
public final /* synthetic */ f a;
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
public h(i.a.C0044a aVar, f fVar, Pattern pattern) {
public h(i.a.C0045a aVar, f fVar, Pattern pattern) {
super(pattern);
this.a = fVar;
}

View File

@ -22,12 +22,12 @@ public final class i {
/* compiled from: JavaScript.kt */
public static final class a<RC> extends Node.a<RC> {
public static final Pattern a = Pattern.compile("^(var|let|const)(\\s+[a-zA-Z_$](?:[a-zA-Z0-9_$])*)", 32);
public static final C0044a b = new C0044a(null);
public static final C0045a b = new C0045a(null);
/* compiled from: JavaScript.kt */
/* renamed from: c.a.t.a.i$a$a reason: collision with other inner class name */
public static final class C0044a {
public C0044a(DefaultConstructorMarker defaultConstructorMarker) {
public static final class C0045a {
public C0045a(DefaultConstructorMarker defaultConstructorMarker) {
}
}

View File

@ -12,7 +12,7 @@ public final class l extends Rule<RC, Node<RC>, S> {
public final /* synthetic */ f a;
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
public l(m.a.C0045a aVar, f fVar, Pattern pattern) {
public l(m.a.C0046a aVar, f fVar, Pattern pattern) {
super(pattern);
this.a = fVar;
}

View File

@ -21,12 +21,12 @@ public final class m {
/* compiled from: Kotlin.kt */
public static final class a<RC> extends Node.a<RC> {
public static final Pattern a = Pattern.compile("^(val|var)(\\s+\\w+)", 32);
public static final C0045a b = new C0045a(null);
public static final C0046a b = new C0046a(null);
/* compiled from: Kotlin.kt */
/* renamed from: c.a.t.a.m$a$a reason: collision with other inner class name */
public static final class C0045a {
public C0045a(DefaultConstructorMarker defaultConstructorMarker) {
public static final class C0046a {
public C0046a(DefaultConstructorMarker defaultConstructorMarker) {
}
}

View File

@ -28,8 +28,8 @@ public final class o {
/* compiled from: Xml.kt */
/* renamed from: c.a.t.a.o$a$a reason: collision with other inner class name */
public static final /* synthetic */ class C0046a extends k implements Function1<RC, Iterable<?>> {
public C0046a(StyleNode.a aVar) {
public static final /* synthetic */ class C0047a extends k implements Function1<RC, Iterable<?>> {
public C0047a(StyleNode.a aVar) {
super(1, aVar, StyleNode.a.class, "get", "get(Ljava/lang/Object;)Ljava/lang/Iterable;", 0);
}
@ -83,7 +83,7 @@ public final class o {
pair = d0.o.to(this.a, "");
}
String str4 = (String) pair.component2();
C0046a aVar = new C0046a(this.f243c.g);
C0047a aVar = new C0047a(this.f243c.g);
int length2 = spannableStringBuilder.length();
spannableStringBuilder.append((CharSequence) ('<' + ((String) pair.component1())));
Iterator<?> it = aVar.invoke(rc).iterator();

View File

@ -32,12 +32,12 @@ public final class a {
/* compiled from: MarkdownRules.kt */
/* renamed from: c.a.t.c.a$a reason: collision with other inner class name */
public static class C0047a<RC, T, S> extends b<RC, S> {
public static class C0048a<RC, T, S> extends b<RC, S> {
private final Function1<String, T> classSpanProvider;
private final List<Rule<RC, Node<RC>, S>> innerRules;
/* JADX INFO: this call moved to the top of the method (can break code semantics) */
public C0047a(Function1<? super Integer, ? extends CharacterStyle> function1, Function1<? super String, ? extends T> function12) {
public C0048a(Function1<? super Integer, ? extends CharacterStyle> function1, Function1<? super String, ? extends T> function12) {
this(function1, function12, u.plus((Collection<? extends Rule>) e.b(false, false, 2), e.h.d()));
m.checkNotNullParameter(function1, "styleSpanProvider");
m.checkNotNullParameter(function12, "classSpanProvider");
@ -47,7 +47,7 @@ public final class a {
/* JADX DEBUG: Multi-variable search result rejected for r4v0, resolved type: java.util.List<? extends com.discord.simpleast.core.parser.Rule<RC, com.discord.simpleast.core.node.Node<RC>, S>> */
/* JADX WARN: Multi-variable type inference failed */
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
public C0047a(Function1<? super Integer, ? extends CharacterStyle> function1, Function1<? super String, ? extends T> function12, List<? extends Rule<RC, Node<RC>, S>> list) {
public C0048a(Function1<? super Integer, ? extends CharacterStyle> function1, Function1<? super String, ? extends T> function12, List<? extends Rule<RC, Node<RC>, S>> list) {
super(a.d, function1);
m.checkNotNullParameter(function1, "styleSpanProvider");
m.checkNotNullParameter(function12, "classSpanProvider");

View File

@ -10,11 +10,11 @@ public final class a {
/* compiled from: TypeTokens.kt */
/* renamed from: c.a.w.a$a reason: collision with other inner class name */
public static final class C0048a extends TypeToken<List<? extends String>> {
public static final class C0049a extends TypeToken<List<? extends String>> {
}
static {
Type type = new C0048a().getType();
Type type = new C0049a().getType();
m.checkNotNullExpressionValue(type, "object : TypeToken<List<String>>() {}.type");
a = type;
}

View File

@ -44,10 +44,10 @@ public final class b0 extends AppBottomSheet implements i {
/* compiled from: SelectorBottomSheet.kt */
/* renamed from: c.a.y.b0$a$a reason: collision with other inner class name */
public static final class C0049a extends o implements Function1<Integer, Unit> {
public static final C0049a i = new C0049a();
public static final class C0050a extends o implements Function1<Integer, Unit> {
public static final C0050a i = new C0050a();
public C0049a() {
public C0050a() {
super(1);
}
@ -68,7 +68,7 @@ public final class b0 extends AppBottomSheet implements i {
public static /* synthetic */ b0 b(a aVar, FragmentManager fragmentManager, String str, List list, boolean z2, Function1 function1, int i) {
boolean z3 = (i & 8) != 0 ? true : z2;
if ((i & 16) != 0) {
function1 = C0049a.i;
function1 = C0050a.i;
}
return aVar.a(fragmentManager, str, list, z3, function1);
}

View File

@ -64,11 +64,11 @@ public class a extends AppCompatDialogFragment {
/* compiled from: java-style lambda group */
/* renamed from: c.b.a.a.a$a reason: collision with other inner class name */
public static final class View$OnClickListenerC0050a implements View.OnClickListener {
public static final class View$OnClickListenerC0051a implements View.OnClickListener {
public final /* synthetic */ int i;
public final /* synthetic */ Object j;
public View$OnClickListenerC0050a(int i, Object obj) {
public View$OnClickListenerC0051a(int i, Object obj) {
this.i = i;
this.j = obj;
}
@ -313,14 +313,14 @@ public class a extends AppCompatDialogFragment {
m.checkNotNullParameter(layoutInflater, "inflater");
View inflate = layoutInflater.inflate(R.f.dialog_add_content_pager_with_fab, viewGroup, false);
if (inflate != null) {
inflate.setOnClickListener(new View$OnClickListenerC0050a(0, this));
inflate.setOnClickListener(new View$OnClickListenerC0051a(0, this));
this.j = (ViewPager) inflate.findViewById(R.e.content_pager);
this.k = (TabLayout) inflate.findViewById(R.e.content_tabs);
this.l = (FloatingActionButton) inflate.findViewById(R.e.action_btn);
ImageView imageView = (ImageView) inflate.findViewById(R.e.launch_btn);
this.m = imageView;
if (imageView != null) {
imageView.setOnClickListener(new View$OnClickListenerC0050a(1, this));
imageView.setOnClickListener(new View$OnClickListenerC0051a(1, this));
}
FloatingActionButton floatingActionButton = this.l;
Objects.requireNonNull(floatingActionButton, "null cannot be cast to non-null type com.google.android.material.floatingactionbutton.FloatingActionButton");
@ -405,7 +405,7 @@ public class a extends AppCompatDialogFragment {
}
FloatingActionButton floatingActionButton2 = this.l;
if (floatingActionButton2 != null) {
floatingActionButton2.setOnClickListener(new View$OnClickListenerC0050a(2, parentFragment));
floatingActionButton2.setOnClickListener(new View$OnClickListenerC0051a(2, parentFragment));
}
this.n = flexInputFragment.b().addItemSelectionListener(this.q);
FloatingActionButton floatingActionButton3 = this.l;

View File

@ -56,11 +56,11 @@ public final class i extends RecyclerView.Adapter<a> {
/* compiled from: MediaCursorAdapter.kt */
/* renamed from: c.b.a.d.i$a$a reason: collision with other inner class name */
public static final class C0051a extends o implements Function1<AnimatorSet, Unit> {
public static final class C0052a extends o implements Function1<AnimatorSet, Unit> {
public final /* synthetic */ boolean $isAnimationRequested;
/* JADX INFO: super call moved to the top of the method (can break code semantics) */
public C0051a(boolean z2) {
public C0052a(boolean z2) {
super(1);
this.$isAnimationRequested = z2;
}
@ -118,7 +118,7 @@ public final class i extends RecyclerView.Adapter<a> {
FrameLayout frameLayout = this.r.a;
m.checkNotNullExpressionValue(frameLayout, "binding.root");
frameLayout.setSelected(z2);
C0051a aVar = new C0051a(z3);
C0052a aVar = new C0052a(z3);
if (z2) {
SimpleDraweeView simpleDraweeView = this.r.d;
m.checkNotNullExpressionValue(simpleDraweeView, "binding.itemCheckIndicator");

View File

@ -9,10 +9,10 @@ public abstract class a {
/* compiled from: FlexInputEvent.kt */
/* renamed from: c.b.a.h.a$a reason: collision with other inner class name */
public static final class C0052a extends a {
public static final C0052a a = new C0052a();
public static final class C0053a extends a {
public static final C0053a a = new C0053a();
public C0052a() {
public C0053a() {
super(null);
}
}

View File

@ -192,10 +192,10 @@ public class j extends Drawable implements Drawable.Callback, Animatable {
/* compiled from: LottieDrawable */
/* renamed from: c.c.a.j$j reason: collision with other inner class name */
public class C0053j implements o {
public class C0054j implements o {
public final /* synthetic */ float a;
public C0053j(float f) {
public C0054j(float f) {
this.a = f;
}
@ -670,7 +670,7 @@ public class j extends Drawable implements Drawable.Callback, Animatable {
public void t(float f2) {
d dVar = this.j;
if (dVar == null) {
this.o.add(new C0053j(f2));
this.o.add(new C0054j(f2));
} else {
r((int) c.c.a.b0.f.e(dVar.k, dVar.l, f2));
}

View File

@ -48,7 +48,7 @@ public abstract class a implements a.b, k, e {
@Nullable
public final s b;
public b(s sVar, C0054a aVar) {
public b(s sVar, C0055a aVar) {
this.b = sVar;
}
}

View File

@ -28,7 +28,7 @@ public abstract class a<K, A> {
/* compiled from: BaseKeyframeAnimation */
public static final class c<T> implements d<T> {
public c(C0055a aVar) {
public c(C0056a aVar) {
}
@Override // c.c.a.w.c.a.d

View File

@ -396,7 +396,7 @@ public class a {
return str + j + str2;
}
public static boolean r0(b.C0256b bVar, int i, String str) {
public static boolean r0(b.C0257b bVar, int i, String str) {
Boolean bool = bVar.get(i);
m.checkNotNullExpressionValue(bool, str);
return bool.booleanValue();

View File

@ -4,11 +4,11 @@ import com.discord.widgets.chat.input.MentionUtilsKt;
import java.util.Date;
/* compiled from: Log */
public class a {
public static C0056a a = new C0056a();
public static C0057a a = new C0057a();
/* compiled from: Log */
/* renamed from: c.e.a.a$a reason: collision with other inner class name */
public static class C0056a {
public static class C0057a {
public long a = new Date().getTime();
public void a(int i, String str, String str2, Throwable th) {

View File

@ -77,8 +77,8 @@ public abstract class c {
q(fVar, replace2, arrayList, w.i);
n(fVar, replace2, arrayList, w.g);
q(fVar, replace2, arrayList, w.g);
n(fVar, replace2, arrayList, w.f2893c);
q(fVar, replace2, arrayList, w.f2893c);
n(fVar, replace2, arrayList, w.f2894c);
q(fVar, replace2, arrayList, w.f2894c);
o(fVar, replace2, arrayList);
cls2 = b.a(u, fVar.b());
}

View File

@ -34,7 +34,7 @@ public class a implements c {
public class b implements c.f.d.c.a {
public final List<c.a> a = new ArrayList();
public b(C0057a aVar) {
public b(C0058a aVar) {
}
@Override // c.f.d.c.a
@ -64,7 +64,7 @@ public class a implements c {
public long f357c = -1;
public long d = -1;
public c(String str, File file, C0057a aVar) {
public c(String str, File file, C0058a aVar) {
Objects.requireNonNull(str);
this.a = str;
this.b = new c.f.a.a(file);
@ -194,7 +194,7 @@ public class a implements c {
public class g implements c.f.d.c.a {
public boolean a;
public g(C0057a aVar) {
public g(C0058a aVar) {
}
/* JADX WARNING: Code restructure failed: missing block: B:7:0x002b, code lost:

View File

@ -15,14 +15,14 @@ public class b extends AbstractExecutorService {
public final Executor k;
public volatile int l;
public final BlockingQueue<Runnable> m;
public final RunnableC0058b n;
public final RunnableC0059b n;
public final AtomicInteger o;
public final AtomicInteger p;
/* compiled from: ConstrainedExecutorService */
/* renamed from: c.f.d.b.b$b reason: collision with other inner class name */
public class RunnableC0058b implements Runnable {
public RunnableC0058b(a aVar) {
public class RunnableC0059b implements Runnable {
public RunnableC0059b(a aVar) {
}
@Override // java.lang.Runnable
@ -64,7 +64,7 @@ public class b extends AbstractExecutorService {
this.k = executor;
this.l = i2;
this.m = blockingQueue;
this.n = new RunnableC0058b(null);
this.n = new RunnableC0059b(null);
this.o = new AtomicInteger(0);
this.p = new AtomicInteger(0);
return;

View File

@ -311,13 +311,13 @@ public class c extends AbstractDraweeController<CloseableReference<c.f.j.j.c>, I
ImageRequest imageRequest = this.I;
ImageRequest imageRequest2 = this.K;
ImageRequest[] imageRequestArr = this.J;
if (imageRequest == null || (uri = imageRequest.f2262c) == null) {
if (imageRequest == null || (uri = imageRequest.f2263c) == null) {
if (!(imageRequestArr == null || imageRequestArr.length <= 0 || imageRequestArr[0] == null)) {
ImageRequest imageRequest3 = imageRequestArr[0];
uri = imageRequest3 != null ? imageRequest3.f2262c : null;
uri = imageRequest3 != null ? imageRequest3.f2263c : null;
}
if (imageRequest2 != null) {
return imageRequest2.f2262c;
return imageRequest2.f2263c;
}
return null;
}

View File

@ -85,7 +85,7 @@ public class d extends AbstractDraweeControllerBuilder<d, ImageRequest, Closeabl
c.f.j.r.b.b();
try {
DraweeController draweeController = this.n;
String valueOf = String.valueOf(AbstractDraweeControllerBuilder.f2249c.getAndIncrement());
String valueOf = String.valueOf(AbstractDraweeControllerBuilder.f2250c.getAndIncrement());
if (draweeController instanceof c) {
cVar = (c) draweeController;
} else {

View File

@ -26,10 +26,10 @@ public class a extends c.f.h.b.a.a<ImageInfo> {
/* compiled from: ImagePerfControllerListener2 */
/* renamed from: c.f.g.a.a.h.i.a$a reason: collision with other inner class name */
public static class HandlerC0059a extends Handler {
public static class HandlerC0060a extends Handler {
public final g a;
public HandlerC0059a(@NonNull Looper looper, @NonNull g gVar) {
public HandlerC0060a(@NonNull Looper looper, @NonNull g gVar) {
super(looper);
this.a = gVar;
}
@ -126,7 +126,7 @@ public class a extends c.f.h.b.a.a<ImageInfo> {
handlerThread.start();
Looper looper = handlerThread.getLooper();
Objects.requireNonNull(looper);
this.f = new HandlerC0059a(looper, this.f381c);
this.f = new HandlerC0060a(looper, this.f381c);
}
}
}

View File

@ -5,9 +5,9 @@ public abstract class a {
/* compiled from: DeferredReleaser */
/* renamed from: c.f.g.b.a$a reason: collision with other inner class name */
public interface AbstractC0060a {
public interface AbstractC0061a {
void release();
}
public abstract void a(AbstractC0060a aVar);
public abstract void a(AbstractC0061a aVar);
}

View File

@ -12,8 +12,8 @@ public class b extends a {
/* renamed from: c reason: collision with root package name */
public final Handler f382c = new Handler(Looper.getMainLooper());
public ArrayList<a.AbstractC0060a> d = new ArrayList<>();
public ArrayList<a.AbstractC0060a> e = new ArrayList<>();
public ArrayList<a.AbstractC0061a> d = new ArrayList<>();
public ArrayList<a.AbstractC0061a> e = new ArrayList<>();
public final Runnable f = new a();
/* compiled from: DeferredReleaserConcurrentImpl */
@ -24,10 +24,10 @@ public class b extends a {
@Override // java.lang.Runnable
@MainThread
public void run() {
ArrayList<a.AbstractC0060a> arrayList;
ArrayList<a.AbstractC0061a> arrayList;
synchronized (b.this.b) {
b bVar = b.this;
ArrayList<a.AbstractC0060a> arrayList2 = bVar.e;
ArrayList<a.AbstractC0061a> arrayList2 = bVar.e;
arrayList = bVar.d;
bVar.e = arrayList;
bVar.d = arrayList2;
@ -42,7 +42,7 @@ public class b extends a {
@Override // c.f.g.b.a
@AnyThread
public void a(a.AbstractC0060a aVar) {
public void a(a.AbstractC0061a aVar) {
synchronized (this.b) {
this.d.remove(aVar);
}

View File

@ -30,7 +30,7 @@ public class b extends g implements f0 {
if (!draweeHolder.a) {
a.m(c.class, "%x: Draw requested for a non-attached controller %x. %s", Integer.valueOf(System.identityHashCode(draweeHolder)), Integer.valueOf(System.identityHashCode(draweeHolder.e)), draweeHolder.toString());
draweeHolder.b = true;
draweeHolder.f2253c = true;
draweeHolder.f2254c = true;
draweeHolder.b();
}
}

View File

@ -6,7 +6,7 @@ import androidx.annotation.VisibleForTesting;
/* compiled from: GestureDetector */
public class a {
@VisibleForTesting
public AbstractC0061a a = null;
public AbstractC0062a a = null;
@VisibleForTesting
public final float b;
@VisibleForTesting
@ -24,7 +24,7 @@ public class a {
/* compiled from: GestureDetector */
/* renamed from: c.f.g.g.a$a reason: collision with other inner class name */
public interface AbstractC0061a {
public interface AbstractC0062a {
}
public a(Context context) {

View File

@ -36,8 +36,8 @@ public class a extends Drawable implements Animatable, c.f.f.a.a {
/* compiled from: AnimatedDrawable2 */
/* renamed from: c.f.h.a.c.a$a reason: collision with other inner class name */
public class RunnableC0062a implements Runnable {
public RunnableC0062a() {
public class RunnableC0063a implements Runnable {
public RunnableC0063a() {
}
@Override // java.lang.Runnable
@ -55,7 +55,7 @@ public class a extends Drawable implements Animatable, c.f.f.a.a {
public a(c.f.h.a.a.a aVar) {
this.u = 8;
this.w = j;
this.f420y = new RunnableC0062a();
this.f420y = new RunnableC0063a();
this.k = aVar;
this.l = aVar == null ? null : new c.f.h.a.e.a(aVar);
}

View File

@ -156,7 +156,7 @@ public class f {
Objects.requireNonNull((z) this.g);
Executor executor = z.g.a;
if (eVar instanceof Boolean) {
return ((Boolean) eVar).booleanValue() ? z.g.f2974c : z.g.d;
return ((Boolean) eVar).booleanValue() ? z.g.f2975c : z.g.d;
}
z.g<e> gVar = new z.g<>();
if (gVar.h(eVar)) {

View File

@ -9,11 +9,11 @@ public class n implements i {
public static n a;
public CacheKey a(ImageRequest imageRequest, Object obj) {
return new b(imageRequest.f2262c.toString(), imageRequest.i, imageRequest.j, imageRequest.h, null, null, obj);
return new b(imageRequest.f2263c.toString(), imageRequest.i, imageRequest.j, imageRequest.h, null, null, obj);
}
public CacheKey b(ImageRequest imageRequest, Object obj) {
return new f(imageRequest.f2262c.toString());
return new f(imageRequest.f2263c.toString());
}
public CacheKey c(ImageRequest imageRequest, Object obj) {
@ -28,6 +28,6 @@ public class n implements i {
cacheKey = null;
str = null;
}
return new b(imageRequest.f2262c.toString(), imageRequest.i, imageRequest.j, imageRequest.h, cacheKey, str, obj);
return new b(imageRequest.f2263c.toString(), imageRequest.i, imageRequest.j, imageRequest.h, cacheKey, str, obj);
}
}

View File

@ -262,7 +262,7 @@ public class v<K, V> implements m<K, V>, w<K, V> {
MemoryCacheParams memoryCacheParams = this.f;
int min = Math.min(memoryCacheParams.d, memoryCacheParams.b - e());
MemoryCacheParams memoryCacheParams2 = this.f;
p = p(min, Math.min(memoryCacheParams2.f2255c, memoryCacheParams2.a - f()));
p = p(min, Math.min(memoryCacheParams2.f2256c, memoryCacheParams2.a - f()));
h(p);
}
i(p);

View File

@ -11,10 +11,10 @@ public class a {
/* compiled from: CloseableReferenceFactory */
/* renamed from: c.f.j.e.a$a reason: collision with other inner class name */
public class C0063a implements CloseableReference.c {
public class C0064a implements CloseableReference.c {
public final /* synthetic */ c.f.j.g.a a;
public C0063a(a aVar, c.f.j.g.a aVar2) {
public C0064a(a aVar, c.f.j.g.a aVar2) {
this.a = aVar2;
}
@ -48,6 +48,6 @@ public class a {
}
public a(c.f.j.g.a aVar) {
this.a = new C0063a(this, aVar);
this.a = new C0064a(this, aVar);
}
}

View File

@ -17,7 +17,7 @@ public class c implements f {
public h a(DiskCacheConfig diskCacheConfig) {
Objects.requireNonNull(this.a);
e eVar = new e(diskCacheConfig.a, diskCacheConfig.f2243c, diskCacheConfig.b, diskCacheConfig.h);
e eVar = new e(diskCacheConfig.a, diskCacheConfig.f2244c, diskCacheConfig.b, diskCacheConfig.h);
ExecutorService newSingleThreadExecutor = Executors.newSingleThreadExecutor();
return new d(eVar, diskCacheConfig.g, new d.c(diskCacheConfig.f, diskCacheConfig.e, diskCacheConfig.d), diskCacheConfig.i, diskCacheConfig.h, diskCacheConfig.j, newSingleThreadExecutor, false);
}

View File

@ -85,7 +85,7 @@ public class h {
ImageRequest.c f = ImageRequest.c.f(imageRequest.m, cVar);
String valueOf = String.valueOf(this.i.getAndIncrement());
if (!imageRequest.f) {
if (c.f.d.l.b.e(imageRequest.f2262c)) {
if (c.f.d.l.b.e(imageRequest.f2263c)) {
z2 = false;
c1 c1Var = new c1(imageRequest, valueOf, str, b0Var, obj, f, false, z2, imageRequest.l, this.l);
c.f.j.r.b.b();

View File

@ -153,7 +153,7 @@ public class p {
try {
b.b();
Objects.requireNonNull(imageRequest);
Uri uri = imageRequest.f2262c;
Uri uri = imageRequest.f2263c;
AnimatableValueParser.y(uri, "Uri is null.");
int i = imageRequest.d;
if (i != 0) {
@ -247,7 +247,7 @@ public class p {
}
}
}
if (this.m && imageRequest.f2263s > 0) {
if (this.m && imageRequest.f2264s > 0) {
synchronized (this) {
oVar = new o(r0Var, this.b.j.g());
}

View File

@ -17,12 +17,12 @@ public class a implements b {
/* renamed from: c reason: collision with root package name */
public final d f460c;
public final b d = new C0064a();
public final b d = new C0065a();
/* compiled from: DefaultImageDecoder */
/* renamed from: c.f.j.h.a$a reason: collision with other inner class name */
public class C0064a implements b {
public C0064a() {
public class C0065a implements b {
public C0065a() {
}
@Override // c.f.j.h.b

View File

@ -7,7 +7,7 @@ public class a implements v0<e> {
/* compiled from: AddImageTransformMetaDataProducer */
public static class b extends p<e, e> {
public b(l lVar, C0065a aVar) {
public b(l lVar, C0066a aVar) {
super(lVar);
}

View File

@ -19,7 +19,7 @@ public class a1 extends g0 {
@Override // c.f.j.p.g0
public e d(ImageRequest imageRequest) throws IOException {
return c(this.f475c.openInputStream(imageRequest.f2262c), -1);
return c(this.f475c.openInputStream(imageRequest.f2263c), -1);
}
@Override // c.f.j.p.g0

View File

@ -36,8 +36,8 @@ public class b1 implements v0<e> {
/* compiled from: ResizeAndRotateProducer */
/* renamed from: c.f.j.p.b1$a$a reason: collision with other inner class name */
public class C0066a implements c0.c {
public C0066a(b1 b1Var) {
public class C0067a implements c0.c {
public C0067a(b1 b1Var) {
}
@Override // c.f.j.p.c0.c
@ -118,7 +118,7 @@ public class b1 implements v0<e> {
Objects.requireNonNull(w0Var.e());
this.f478c = z2;
this.d = cVar;
this.g = new c0(b1.this.a, new C0066a(b1.this), 100);
this.g = new c0(b1.this.a, new C0067a(b1.this), 100);
w0Var.f(new b(b1.this, lVar));
}

View File

@ -45,7 +45,7 @@ public class d implements w0 {
HashMap hashMap = new HashMap();
this.h = hashMap;
hashMap.put(ModelAuditLogEntry.CHANGE_KEY_ID, str);
hashMap.put("uri_source", imageRequest == null ? "null-request" : imageRequest.f2262c);
hashMap.put("uri_source", imageRequest == null ? "null-request" : imageRequest.f2263c);
this.d = str2;
this.e = y0Var;
this.f = obj;

View File

@ -25,10 +25,10 @@ public class d0 extends g0 {
@Override // c.f.j.p.g0
public e d(ImageRequest imageRequest) throws IOException {
int i;
InputStream open = this.f481c.open(imageRequest.f2262c.getPath().substring(1), 2);
InputStream open = this.f481c.open(imageRequest.f2263c.getPath().substring(1), 2);
AssetFileDescriptor assetFileDescriptor = null;
try {
assetFileDescriptor = this.f481c.openFd(imageRequest.f2262c.getPath().substring(1));
assetFileDescriptor = this.f481c.openFd(imageRequest.f2263c.getPath().substring(1));
i = (int) assetFileDescriptor.getLength();
} catch (IOException unused) {
i = -1;

View File

@ -28,7 +28,7 @@ public class e0 extends g0 {
@Override // c.f.j.p.g0
public e d(ImageRequest imageRequest) throws IOException {
InputStream inputStream;
Uri uri = imageRequest.f2262c;
Uri uri = imageRequest.f2263c;
Uri uri2 = b.a;
boolean z2 = false;
if (uri.getPath() != null && b.c(uri) && "com.android.contacts".equals(uri.getAuthority()) && !uri.getPath().startsWith(b.a.getPath())) {

View File

@ -42,7 +42,7 @@ public class f0 extends g0 implements j1<e> {
c.f.j.d.e eVar;
Cursor query;
e f2;
Uri uri = imageRequest.f2262c;
Uri uri = imageRequest.f2263c;
if (!b.b(uri) || (eVar = imageRequest.i) == null || (query = this.g.query(uri, f483c, null, null, null)) == null) {
return null;
}

View File

@ -25,10 +25,10 @@ public class i0 extends g0 {
@Override // c.f.j.p.g0
public e d(ImageRequest imageRequest) throws IOException {
int i;
InputStream openRawResource = this.f490c.openRawResource(Integer.parseInt(imageRequest.f2262c.getPath().substring(1)));
InputStream openRawResource = this.f490c.openRawResource(Integer.parseInt(imageRequest.f2263c.getPath().substring(1)));
AssetFileDescriptor assetFileDescriptor = null;
try {
assetFileDescriptor = this.f490c.openRawResourceFd(Integer.parseInt(imageRequest.f2262c.getPath().substring(1)));
assetFileDescriptor = this.f490c.openRawResourceFd(Integer.parseInt(imageRequest.f2263c.getPath().substring(1)));
i = (int) assetFileDescriptor.getLength();
} catch (Resources.NotFoundException unused) {
i = -1;

View File

@ -83,7 +83,7 @@ public class j0 implements v0<CloseableReference<c>> {
bitmap = ThumbnailUtils.createVideoThumbnail(str, i);
} else {
try {
ParcelFileDescriptor openFileDescriptor = j0.this.b.openFileDescriptor(this.p.f2262c, "r");
ParcelFileDescriptor openFileDescriptor = j0.this.b.openFileDescriptor(this.p.f2263c, "r");
MediaMetadataRetriever mediaMetadataRetriever = new MediaMetadataRetriever();
mediaMetadataRetriever.setDataSource(openFileDescriptor.getFileDescriptor());
bitmap = mediaMetadataRetriever.getFrameAtTime(-1);
@ -141,7 +141,7 @@ public class j0 implements v0<CloseableReference<c>> {
String str;
Uri uri;
Objects.requireNonNull(j0Var);
Uri uri2 = imageRequest.f2262c;
Uri uri2 = imageRequest.f2263c;
if (c.f.d.l.b.d(uri2)) {
return imageRequest.a().getPath();
}

View File

@ -18,7 +18,7 @@ public class m extends g0 {
@Override // c.f.j.p.g0
public e d(ImageRequest imageRequest) throws IOException {
boolean z2;
String uri = imageRequest.f2262c.toString();
String uri = imageRequest.f2263c.toString();
AnimatableValueParser.j(Boolean.valueOf(uri.substring(0, 5).equals("data:")));
int indexOf = uri.indexOf(44);
String substring = uri.substring(indexOf + 1, uri.length());

View File

@ -142,7 +142,7 @@ public class n implements v0<CloseableReference<c.f.j.j.c>> {
w0Var.d("image_format", eVar.k.b);
if (n.this.f || !b.m(i2, 16)) {
ImageRequest e2 = this.a.e();
if (n.this.g || !c.f.d.l.b.e(e2.f2262c)) {
if (n.this.g || !c.f.d.l.b.e(e2.f2263c)) {
eVar.p = AnimatableValueParser.c0(e2.j, e2.i, eVar, this.b);
}
}
@ -180,7 +180,7 @@ public class n implements v0<CloseableReference<c.f.j.j.c>> {
synchronized (c0Var) {
j = c0Var.j - c0Var.i;
}
String valueOf2 = String.valueOf(cVar2.f499c.e().f2262c);
String valueOf2 = String.valueOf(cVar2.f499c.e().f2263c);
int f = (z3 || m) ? eVar.f() : cVar2.o(eVar);
i p = (z3 || m) ? h.a : cVar2.p();
cVar2.d.e(cVar2.f499c, "DecodeProducer");
@ -440,7 +440,7 @@ public class n implements v0<CloseableReference<c.f.j.j.c>> {
public void b(l<CloseableReference<c.f.j.j.c>> lVar, w0 w0Var) {
try {
c.f.j.r.b.b();
this.e.b(!c.f.d.l.b.e(w0Var.e().f2262c) ? new a(this, lVar, w0Var, this.h, this.i) : new b(this, lVar, w0Var, new d(this.a), this.d, this.h, this.i), w0Var);
this.e.b(!c.f.d.l.b.e(w0Var.e().f2263c) ? new a(this, lVar, w0Var, this.h, this.i) : new b(this, lVar, w0Var, new d(this.a), this.d, this.h, this.i), w0Var);
c.f.j.r.b.b();
} catch (Throwable th) {
c.f.j.r.b.b();

View File

@ -36,7 +36,7 @@ public class o implements v0<CloseableReference<c>> {
ImageRequest e = w0Var.e();
ScheduledExecutorService scheduledExecutorService = this.b;
if (scheduledExecutorService != null) {
scheduledExecutorService.schedule(new a(lVar, w0Var), (long) e.f2263s, TimeUnit.MILLISECONDS);
scheduledExecutorService.schedule(new a(lVar, w0Var), (long) e.f2264s, TimeUnit.MILLISECONDS);
} else {
this.a.b(lVar, w0Var);
}

View File

@ -64,7 +64,7 @@ public class o0 implements c<e, Void> {
this.f501c.b(eVar2, 9);
} else {
this.f501c.b(eVar2, 8);
ImageRequestBuilder b = ImageRequestBuilder.b(e.f2262c);
ImageRequestBuilder b = ImageRequestBuilder.b(e.f2263c);
b.e = e.h;
b.o = e.k;
b.f = e.b;
@ -73,11 +73,11 @@ public class o0 implements c<e, Void> {
b.j = e.q;
b.g = e.f;
b.i = e.l;
b.f2264c = e.i;
b.f2265c = e.i;
b.n = e.r;
b.d = e.j;
b.m = e.p;
b.p = e.f2263s;
b.p = e.f2264s;
int i = f2 - 1;
if (i >= 0) {
z3 = true;

View File

@ -185,7 +185,7 @@ public class q0 implements v0<e> {
return;
}
w0Var.o().e(w0Var, "PartialDiskCacheProducer");
Uri build = e.f2262c.buildUpon().appendQueryParameter("fresco_partial", "true").build();
Uri build = e.f2263c.buildUpon().appendQueryParameter("fresco_partial", "true").build();
i iVar = this.b;
w0Var.b();
Objects.requireNonNull((n) iVar);

View File

@ -34,7 +34,7 @@ public class y implements Runnable {
Objects.requireNonNull(a0Var);
InputStream inputStream = null;
try {
httpURLConnection = a0Var.a(aVar.b.e().f2262c, 5);
httpURLConnection = a0Var.a(aVar.b.e().f2263c, 5);
try {
aVar.e = a0Var.f474c.now();
if (httpURLConnection != null) {

View File

@ -15,7 +15,7 @@ public final class a {
/* compiled from: BitmapUtil */
/* renamed from: c.f.k.a$a reason: collision with other inner class name */
public static /* synthetic */ class C0067a {
public static /* synthetic */ class C0068a {
public static final /* synthetic */ int[] a;
static {
@ -74,7 +74,7 @@ public final class a {
}
public static int b(Bitmap.Config config) {
switch (C0067a.a[config.ordinal()]) {
switch (C0068a.a[config.ordinal()]) {
case 1:
return 4;
case 2:

View File

@ -13,11 +13,11 @@ public class a {
public final float[] e = new float[2];
public final float[] f = new float[2];
public final float[] g = new float[2];
public AbstractC0068a h = null;
public AbstractC0069a h = null;
/* compiled from: MultiPointerGestureDetector */
/* renamed from: c.f.l.a.a$a reason: collision with other inner class name */
public interface AbstractC0068a {
public interface AbstractC0069a {
}
public a() {
@ -36,7 +36,7 @@ public class a {
b bVar;
b.a aVar;
if (!this.a) {
AbstractC0068a aVar2 = this.h;
AbstractC0069a aVar2 = this.h;
if (!(aVar2 == null || (aVar = (bVar = (b) aVar2).b) == null)) {
aVar.c(bVar);
}
@ -48,7 +48,7 @@ public class a {
b.a aVar;
if (this.a) {
this.a = false;
AbstractC0068a aVar2 = this.h;
AbstractC0069a aVar2 = this.h;
if (aVar2 != null && (aVar = ((b) aVar2).b) != null) {
c cVar = (c) aVar;
c.f.d.e.a.i(c.class, "onGestureEnd");

View File

@ -2,7 +2,7 @@ package c.f.l.a;
import c.f.l.a.a;
/* compiled from: TransformGestureDetector */
public class b implements a.AbstractC0068a {
public class b implements a.AbstractC0069a {
public final a a;
public a b = null;

View File

@ -39,10 +39,10 @@ public class b extends a {
/* compiled from: AnimatedZoomableController */
/* renamed from: c.f.l.b.b$b reason: collision with other inner class name */
public class C0069b extends AnimatorListenerAdapter {
public class C0070b extends AnimatorListenerAdapter {
public final /* synthetic */ Runnable a;
public C0069b(Runnable runnable) {
public C0070b(Runnable runnable) {
this.a = runnable;
}
@ -98,7 +98,7 @@ public class b extends a {
this.h.getValues(this.n);
matrix.getValues(this.o);
this.f519s.addUpdateListener(new a());
this.f519s.addListener(new C0069b(runnable));
this.f519s.addListener(new C0070b(runnable));
this.f519s.start();
}

View File

@ -177,7 +177,7 @@ public class c implements e, b.a {
if (r2 != 6) goto L_0x00ca;
*/
public boolean h(MotionEvent motionEvent) {
a.AbstractC0068a aVar;
a.AbstractC0069a aVar;
b bVar;
b.a aVar2;
motionEvent.getAction();

View File

@ -13,11 +13,11 @@ public class a extends f {
/* compiled from: ApkSoSource */
/* renamed from: c.f.m.a$a reason: collision with other inner class name */
public class C0070a extends f.c {
public class C0071a extends f.c {
public File m;
public final int n;
public C0070a(f fVar) throws IOException {
public C0071a(f fVar) throws IOException {
super(fVar);
this.m = new File(a.this.f522c.getApplicationInfo().nativeLibraryDir);
this.n = a.this.h;
@ -84,6 +84,6 @@ public class a extends f {
@Override // c.f.m.m
public m.f h() throws IOException {
return new C0070a(this);
return new C0071a(this);
}
}

View File

@ -144,7 +144,7 @@ public class f extends m {
b bVar2 = bVarArr[i3];
ZipEntry zipEntry2 = bVar2.k;
String str2 = bVar2.i;
a.C0070a aVar = (a.C0070a) this;
a.C0071a aVar = (a.C0071a) this;
String name = zipEntry2.getName();
if (str2.equals(a.this.d)) {
a.this.d = null;

View File

@ -12,7 +12,7 @@ public class j implements b {
boolean z2;
boolean contains;
int i2 = ((i & 1) != 0 ? 16 : 0) | 0;
ReentrantReadWriteLock reentrantReadWriteLock = SoLoader.f2266c;
ReentrantReadWriteLock reentrantReadWriteLock = SoLoader.f2267c;
reentrantReadWriteLock.readLock().lock();
try {
if (SoLoader.d == null) {
@ -49,7 +49,7 @@ public class j implements b {
continue;
} catch (UnsatisfiedLinkError e) {
int i3 = SoLoader.e;
SoLoader.f2266c.writeLock().lock();
SoLoader.f2267c.writeLock().lock();
try {
if (SoLoader.g == null || !SoLoader.g.c()) {
z2 = false;
@ -58,21 +58,21 @@ public class j implements b {
SoLoader.e = SoLoader.e + 1;
z2 = true;
}
SoLoader.f2266c.writeLock().unlock();
SoLoader.f2267c.writeLock().unlock();
if (SoLoader.e == i3) {
throw e;
}
} catch (IOException e2) {
throw new RuntimeException(e2);
} catch (Throwable th2) {
SoLoader.f2266c.writeLock().unlock();
SoLoader.f2267c.writeLock().unlock();
throw th2;
}
}
} while (z2);
return z5;
} finally {
SoLoader.f2266c.readLock().unlock();
SoLoader.f2267c.readLock().unlock();
}
}
}

View File

@ -8,7 +8,7 @@ public final class a implements Serializable {
private final int _maxLineLength;
public final String _name;
private final char _paddingChar;
private final EnumC0071a _paddingReadBehaviour;
private final EnumC0072a _paddingReadBehaviour;
private final boolean _writePadding;
public final transient int[] i;
public final transient char[] j;
@ -16,7 +16,7 @@ public final class a implements Serializable {
/* compiled from: Base64Variant */
/* renamed from: c.g.a.b.a$a reason: collision with other inner class name */
public enum EnumC0071a {
public enum EnumC0072a {
PADDING_FORBIDDEN,
PADDING_REQUIRED,
PADDING_ALLOWED
@ -30,7 +30,7 @@ public final class a implements Serializable {
this(aVar, str, z2, c2, aVar._paddingReadBehaviour, i);
}
public a(a aVar, String str, boolean z2, char c2, EnumC0071a aVar2, int i) {
public a(a aVar, String str, boolean z2, char c2, EnumC0072a aVar2, int i) {
int[] iArr = new int[128];
this.i = iArr;
char[] cArr = new char[64];
@ -72,7 +72,7 @@ public final class a implements Serializable {
if (z2) {
this.i[c2] = -2;
}
this._paddingReadBehaviour = z2 ? EnumC0071a.PADDING_REQUIRED : EnumC0071a.PADDING_FORBIDDEN;
this._paddingReadBehaviour = z2 ? EnumC0072a.PADDING_REQUIRED : EnumC0072a.PADDING_FORBIDDEN;
return;
}
throw new IllegalArgumentException(c.d.b.a.a.n("Base64Alphabet length must be exactly 64 (was ", length, ")"));

Some files were not shown because too many files have changed in this diff Show More