package com.netease.nrtc.engine.impl;
import android.annotation.SuppressLint;
import android.content.Context;
import android.graphics.Point;
import android.net.NetworkInfo;
import android.net.wifi.WifiInfo;
import android.net.wifi.WifiManager;
import android.os.Build;
import android.os.Handler;
import android.os.Looper;
import android.os.PowerManager;
import android.os.SystemClock;
import android.text.TextUtils;
import android.util.Log;
import android.util.LongSparseArray;
import android.util.Pair;
import android.util.SparseArray;
import android.view.Display;
import android.view.WindowManager;
import asmack.org.jivesoftware.smackx.GroupChatInvitation;
import com.alibaba.fastjson.asm.Opcodes;
import com.netease.nrtc.debug.INrtcDebugLocalEncodeDecodeVideo;
import com.netease.nrtc.engine.rawapi.IRtcEngine;
import com.netease.nrtc.engine.rawapi.IRtcEventHandler;
import com.netease.nrtc.engine.rawapi.IRtcRoomServerHandler;
import com.netease.nrtc.engine.rawapi.RtcAgcConfig;
import com.netease.nrtc.engine.rawapi.RtcCode;
import com.netease.nrtc.engine.rawapi.RtcConfig;
import com.netease.nrtc.engine.rawapi.RtcLiveCompositingLayout;
import com.netease.nrtc.engine.rawapi.RtcParameters;
import com.netease.nrtc.engine.rawapi.RtcServerAddresses;
import com.netease.nrtc.engine.rawapi.VoiceRxStatistics;
import com.netease.nrtc.internal.ClientSocks5Info;
import com.netease.nrtc.internal.ConnectInfo;
import com.netease.nrtc.internal.LoginExtraConfig;
import com.netease.nrtc.internal.LoginResInfo;
import com.netease.nrtc.internal.NEMediaEngine;
import com.netease.nrtc.internal.NEMediaEngineConfig;
import com.netease.nrtc.internal.NEMediaEngineSink;
import com.netease.nrtc.internal.PeopleJoinInfo;
import com.netease.nrtc.internal.PublishVideoProfile;
import com.netease.nrtc.internal.RemoteSubscribeLocalInfo;
import com.netease.nrtc.internal.SessionInfo;
import com.netease.nrtc.monitor.f;
import com.netease.nrtc.monitor.j;
import com.netease.nrtc.monitor.statistics.c;
import com.netease.nrtc.monitor.statistics.d;
import com.netease.nrtc.rec.a;
import com.netease.nrtc.sdk.audio.AudioFrame;
import com.netease.nrtc.sdk.audio.IPlayAudioCallBack;
import com.netease.nrtc.sdk.audio.IRemoteAudioCallBack;
import com.netease.nrtc.sdk.common.EglContextWrapper;
import com.netease.nrtc.sdk.common.VideoFilterParameter;
import com.netease.nrtc.sdk.common.VideoFrame;
import com.netease.nrtc.sdk.common.statistics.NetStats;
import com.netease.nrtc.sdk.common.statistics.RtcStats;
import com.netease.nrtc.sdk.common.statistics.SessionStats;
import com.netease.nrtc.sdk.video.IVideoCapturer;
import com.netease.nrtc.stats.AVSyncStat;
import com.netease.nrtc.stats.AudioConfigStats;
import com.netease.nrtc.stats.AudioRxInfo;
import com.netease.nrtc.stats.AudioStats;
import com.netease.nrtc.stats.EncodeStatInfo;
import com.netease.nrtc.stats.NetStatInfo;
import com.netease.nrtc.utility.a.c;
import com.netease.nrtc.utility.c.b;
import com.netease.nrtc.utility.i;
import com.netease.nrtc.utility.k;
import com.netease.nrtc.utility.l;
import com.netease.nrtc.utility.n;
import com.netease.nrtc.utility.video.VideoUtils;
import com.netease.nrtc.video.a.g;
import com.netease.nrtc.video.codec.b;
import com.netease.nrtc.video.render.IVideoRender;
import com.netease.nrtc.voice.AudioMixing;
import com.netease.nrtc.voice.device.AudioDeviceParameters;
import com.netease.nrtc.voice.device.b.e;
import com.netease.nrtc.voice.effect.AudioEffectLoader;
import com.netease.nrtc.voice.frame.WrappedNativeAudioFrame;
import com.netease.yunxin.base.annotation.Privilege;
import com.netease.yunxin.base.crypto.MD5;
import com.netease.yunxin.base.thread.ThreadUtils;
import com.netease.yunxin.base.trace.Trace;
import com.netease.yunxin.base.utils.Checker;
import com.netease.yunxin.base.utils.Compatibility;
import com.netease.yunxin.base.utils.FileUtils;
import com.netease.yunxin.base.utils.Size;
import com.netease.yunxin.base.utils.StringUtils;
import com.netease.yunxin.base.utils.SystemPermissionUtils;
import com.netease.yunxin.base.utils.jni.LibraryUtils;
import java.io.File;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import javax.microedition.khronos.egl.EGLContext;
import org.json.JSONObject;
public class e extends IRtcEngine implements k, NEMediaEngineSink, a.AbstractC0109a, a.b, c.a, b.c, com.netease.nrtc.video.a.c, com.netease.nrtc.voice.a, e.a {
/* renamed from: a reason: collision with root package name */
private static volatile int f10505a;
private AtomicBoolean A = new AtomicBoolean(false);
private AtomicBoolean B = new AtomicBoolean(false);
private AtomicBoolean C = new AtomicBoolean(false);
private AtomicInteger D = new AtomicInteger(0);
private AtomicBoolean E = new AtomicBoolean(false);
private n F;
private int G = -1;
private boolean H = false;
private boolean I = false;
private int J;
private String K = "";
private String L = "";
private final j M;
private final f N;
private com.netease.nrtc.utility.b.a O;
private volatile int P = 0;
private AtomicInteger Q = new AtomicInteger(-1);
private int R = 2;
private int S = 1;
private volatile SparseArray<com.netease.nrtc.monitor.statistics.e> T = new SparseArray<>(3);
private int U = 2;
private int V = 3;
private int W = 3;
private int X = 2;
private int Y = 1;
private boolean Z = false;
private int aA;
private int aB;
private boolean aC;
private boolean aD;
private int aE;
private boolean aF;
private int aG;
private boolean aH;
private String aI;
private int aJ;
private RtcLiveCompositingLayout aK;
private boolean aL;
private boolean aM;
private boolean aN;
private boolean aO;
private int aP;
private int aQ;
private int aR;
private int aS;
private int aT;
private int aU;
private String aV;
private boolean aW;
private boolean aX;
private boolean aY;
private final j.a aZ = new j.a() {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass29 */
/* renamed from: b reason: collision with root package name */
private HashSet<Long> f10568b = new HashSet<>();
@Override // com.netease.nrtc.monitor.j.a
public int a(long[] jArr) {
if (e.this.j != null) {
return e.this.j.a(jArr);
}
return 0;
}
@Override // com.netease.nrtc.monitor.j.a
public AudioRxInfo a(long j) {
if (e.this.f10511g == null) {
return AudioRxInfo.obtain();
}
AudioRxInfo c2 = e.this.f10511g.c(j);
if (!e.this.ag) {
c2.setStuckTimeInterval(-1);
}
return c2;
}
@Override // com.netease.nrtc.monitor.j.a
public void a(c.a aVar) {
aVar.a(e.this.R);
}
/* JADX WARNING: Code restructure failed: missing block: B:32:0x02d7, code lost:
r2.recycle();
r3.recycle();
r14.recycle();
r27.recycle();
r0 = r1.f10567a.f10509e.keySet().iterator();
*/
/* JADX WARNING: Code restructure failed: missing block: B:34:0x02f5, code lost:
if (r0.hasNext() == false) goto L_0x041e;
*/
/* JADX WARNING: Code restructure failed: missing block: B:35:0x02f7, code lost:
r10 = ((java.lang.Long) r0.next()).longValue();
*/
/* JADX WARNING: Code restructure failed: missing block: B:36:0x030b, code lost:
if (r10 == r1.f10567a.f10508d.userId) goto L_0x02f1;
*/
/* JADX WARNING: Code restructure failed: missing block: B:37:0x030d, code lost:
r3 = null;
*/
/* JADX WARNING: Code restructure failed: missing block: B:38:0x0314, code lost:
if (r1.f10567a.n == null) goto L_0x034d;
*/
/* JADX WARNING: Code restructure failed: missing block: B:40:0x031c, code lost:
if (r1.f10567a.f10511g == null) goto L_0x034d;
*/
/* JADX WARNING: Code restructure failed: missing block: B:41:0x031e, code lost:
r3 = r1.f10567a.n.j(r10);
r2 = r1.f10567a.n.k(r10);
r4 = r1.f10567a.f10511g.a(r10);
r5 = r1.f10567a.f10511g.b(r10);
r4 = r2;
r2 = r3;
r3 = r4;
*/
/* JADX WARNING: Code restructure failed: missing block: B:42:0x034d, code lost:
r2 = null;
r4 = null;
r5 = null;
*/
/* JADX WARNING: Code restructure failed: missing block: B:43:0x0350, code lost:
if (r3 != null) goto L_0x0356;
*/
/* JADX WARNING: Code restructure failed: missing block: B:44:0x0352, code lost:
r3 = com.netease.nrtc.stats.RemoteClientStats.obtain();
*/
/* JADX WARNING: Code restructure failed: missing block: B:46:0x0357, code lost:
if (r5 != null) goto L_0x035d;
*/
/* JADX WARNING: Code restructure failed: missing block: B:47:0x0359, code lost:
r5 = com.netease.nrtc.stats.VideoJitterStats.obtain();
*/
/* JADX WARNING: Code restructure failed: missing block: B:49:0x035e, code lost:
if (r2 != null) goto L_0x0365;
*/
/* JADX WARNING: Code restructure failed: missing block: B:50:0x0360, code lost:
r2 = new com.netease.nrtc.video.a.g();
*/
/* JADX WARNING: Code restructure failed: missing block: B:52:0x0366, code lost:
if (r4 != null) goto L_0x036c;
*/
/* JADX WARNING: Code restructure failed: missing block: B:53:0x0368, code lost:
r4 = com.netease.nrtc.stats.DecodeStatInfo.obtain();
*/
/* JADX WARNING: Code restructure failed: missing block: B:55:0x0374, code lost:
if (r1.f10567a.p((com.netease.nrtc.engine.impl.e) r10) != false) goto L_0x037e;
*/
/* JADX WARNING: Code restructure failed: missing block: B:56:0x0376, code lost:
r2.f11161f = -1;
r5.setVideoStuckTimes(-1);
*/
/* JADX WARNING: Code restructure failed: missing block: B:57:0x037e, code lost:
r34.a(r10, r3.a(), r3.b()).a(r10, (int) r5.a()).a(r10, r3.k(), r3.l()).a(r10, r2.f11159d, r2.f11160e, r2.f11158c).b(r10, r4.c(), r4.a(), r4.b()).b(r10, r5.c(), r5.b()).b(r10, r3.c(), (int) r3.d()).c(r10, r3.g(), r3.h()).d(r10, r3.f(), r3.e()).c(r10, (int) r5.d()).b(r10, r2.f11161f).e(r10, r3.i(), r3.j());
com.netease.nrtc.c.a.a().d(r10, r4.a());
r3.recycle();
r5.recycle();
r4.recycle();
*/
/* JADX WARNING: Code restructure failed: missing block: B:58:0x041e, code lost:
return;
*/
@Override // com.netease.nrtc.monitor.j.a
public void a(d.a aVar) {
AudioStats audioStats;
AudioConfigStats audioConfigStats;
SessionInfo sessionInfo;
NetStatInfo netStatInfo;
long j;
Throwable th;
AnonymousClass29 r1 = this;
d.a aVar2 = aVar;
if (e.this.j != null) {
audioConfigStats = e.this.j.m();
audioStats = e.this.j.n();
} else {
audioConfigStats = AudioConfigStats.obtain();
audioStats = AudioStats.obtain();
}
long j2 = 0;
if (e.this.f10511g != null) {
SessionInfo g2 = e.this.f10511g.g();
NetStatInfo h2 = e.this.f10511g.h();
long f2 = e.this.f10511g.f();
j = e.this.f10511g.e();
sessionInfo = g2;
netStatInfo = h2;
j2 = f2;
} else {
sessionInfo = SessionInfo.obtain();
j = 0;
netStatInfo = NetStatInfo.obtain();
}
com.netease.nrtc.video.a.a e2 = e.this.n.e(0);
String n = e.this.n.n();
com.netease.nrtc.profile.a.b().d(n);
aVar2.a(netStatInfo.e()).d(netStatInfo.e(), (int) netStatInfo.f()).c(e2.f11137c).a(audioStats.c(), netStatInfo.h(), audioStats.d()).b(audioStats.e()).d(netStatInfo.g()).a(audioStats.a(), audioStats.b()).b(netStatInfo.i(), netStatInfo.j(), netStatInfo.k()).b(netStatInfo.l(), netStatInfo.m()).e(netStatInfo.n()).f(netStatInfo.p()).g(netStatInfo.q()).b(j2).c(j).h(netStatInfo.a()).i(netStatInfo.d()).j(netStatInfo.b()).k(netStatInfo.c());
aVar.a().setTurnIp(sessionInfo.a()).setProxyIp(sessionInfo.b()).setChannelId(e.this.f10508d.channel).setAudioJBStrategy(e.this.U).setQosGrayScaleType1(e.this.Y).setQosGrayScaleType2(e.this.X).setQosGrayScaleType3(e.this.aa).setQosGrayScaleType4(e.this.V).setUid(e.this.f10508d.userId).setConnectState(e.this.J).setPushUrl((!e.this.aH || !e.this.aC) ? "" : e.this.aI).setPeerToPeer(e.this.I).setApmAecDelay(audioConfigStats.a()).setApmAecNonlinear(audioConfigStats.b()).setApmAecType(audioConfigStats.c()).setApmAecCompressLevel(audioConfigStats.d()).setApmNsType(audioConfigStats.e()).setApmNsLevel(audioConfigStats.f()).setLocalSimulcastModel(netStatInfo.o()).setVideoCaptureName(n);
synchronized (e.this.ae) {
try {
for (RemoteSubscribeLocalInfo remoteSubscribeLocalInfo : e.this.ae) {
int a2 = remoteSubscribeLocalInfo.a();
com.netease.nrtc.video.a.a e3 = e.this.n.e(a2);
try {
aVar.a(a2, netStatInfo.a(a2), netStatInfo.d(a2), netStatInfo.e(a2), netStatInfo.f(a2), netStatInfo.b(a2), netStatInfo.c(a2), e.this.s((e) a2).f10882b, (long) e.this.s((e) a2).f10881a, netStatInfo.g(a2), netStatInfo.h(a2), netStatInfo.i(a2), e3.f11135a, e3.f11136b, netStatInfo.j(a2), netStatInfo.k(a2), netStatInfo.l(a2), netStatInfo.m(a2));
r1 = this;
EncodeStatInfo g3 = e.this.n.g(a2);
if (g3 == null) {
g3 = EncodeStatInfo.obtain();
}
aVar.a(a2, netStatInfo.a(a2));
aVar.a(a2, g3.a(), g3.b(), g3.f(), g3.d(), g3.e(), g3.g(), g3.c());
com.netease.nrtc.c.a.a().a(a2, g3.c());
g3.recycle();
netStatInfo = netStatInfo;
aVar2 = aVar;
} catch (Throwable th2) {
th = th2;
throw th;
}
}
} catch (Throwable th3) {
th = th3;
throw th;
}
}
}
@Override // com.netease.nrtc.monitor.j.a
public void a(final SessionStats sessionStats) {
final int i = sessionStats.sessionState;
if (i == 0) {
Iterator<SessionStats.SimulcastVideo> it2 = sessionStats.simulcastVideos.iterator();
while (it2.hasNext()) {
SessionStats.SimulcastVideo next = it2.next();
e.this.f10511g.b(next.txVideoEncodedBitrate, next.videoType, next.txVideoEncodedFrameRate, next.txVideoSkipFrameRate);
}
}
e eVar = e.this;
eVar.a((e) eVar.v, (Handler) new a(e.this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass29.AnonymousClass1 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
int i = i;
if (i != 0) {
if (i == 1) {
iRtcEventHandler.onLeaveChannel(sessionStats);
return;
} else if (i != 2) {
return;
}
}
iRtcEventHandler.onSessionStats(sessionStats);
}
});
}
@Override // com.netease.nrtc.monitor.j.a
public void a(com.netease.nrtc.utility.d dVar, boolean z) {
for (Long l : e.this.f10509e.keySet()) {
long longValue = l.longValue();
if (!z || longValue != e.this.f10508d.userId) {
dVar.accept(longValue);
}
}
}
@Override // com.netease.nrtc.monitor.j.a
public boolean a() {
return e.this.A.get();
}
@Override // com.netease.nrtc.monitor.j.a
public AVSyncStat b(long j) {
return e.this.f10511g != null ? e.this.f10511g.d(j) : AVSyncStat.obtain();
}
@Override // com.netease.nrtc.monitor.j.a
public HashSet<Long> b() {
this.f10568b.clear();
for (C0374b bVar : e.this.ad.values()) {
if (bVar.c()) {
this.f10568b.add(Long.valueOf(bVar.a()));
}
}
return this.f10568b;
}
@Override // com.netease.nrtc.monitor.j.a
public g c(long j) {
g j2 = e.this.n.j(j);
return j2 == null ? new g() : j2;
}
@Override // com.netease.nrtc.monitor.j.a
public boolean c() {
return e.this.af;
}
};
private int aa = 1;
private LongSparseArray<PeopleJoinInfo> ab = new LongSparseArray<>();
private AudioEffectLoader ac;
private Map<Long, C0374b> ad = new ConcurrentHashMap(6);
private final List<RemoteSubscribeLocalInfo> ae = new ArrayList(3);
private volatile boolean af;
private volatile boolean ag;
private EglContextWrapper ah;
private com.netease.nrtc.internal.b ai = new com.netease.nrtc.internal.b();
private boolean aj = true;
private boolean ak = true;
private int al = 1;
private int am = 0;
private INrtcDebugLocalEncodeDecodeVideo an;
private int ao = 1;
private int ap = 1;
private com.netease.nrtc.video.a aq;
private int ar = 2;
private boolean as = false;
private boolean at;
private boolean au;
private boolean av;
private int aw;
private boolean ax;
private boolean ay;
private int az;
/* renamed from: b reason: collision with root package name */
private IRtcEventHandler f10506b;
/* renamed from: c reason: collision with root package name */
private String f10507c;
/* renamed from: d reason: collision with root package name */
private RtcConfig f10508d;
/* renamed from: e reason: collision with root package name */
private Map<Long, j> f10509e;
/* renamed from: f reason: collision with root package name */
private Map<Long, j> f10510f;
/* renamed from: g reason: collision with root package name */
private NEMediaEngine f10511g;
/* renamed from: h reason: collision with root package name */
private com.netease.nrtc.rec.a f10512h;
private boolean i;
private com.netease.nrtc.voice.b j;
private long[] k;
private int[] l;
private com.netease.nrtc.voice.device.b.e m;
private com.netease.nrtc.video.a.d n;
private g o = new g();
private int p;
private int q;
private int r;
private int s;
private boolean t;
private int u;
private Handler v;
private WifiManager.WifiLock w;
private PowerManager.WakeLock x;
private AtomicInteger y = new AtomicInteger(1);
private AtomicInteger z = new AtomicInteger(0);
/* access modifiers changed from: private */
public static abstract class a implements Runnable {
/* renamed from: a reason: collision with root package name */
private IRtcEventHandler f10622a;
public a(IRtcEventHandler iRtcEventHandler) {
this.f10622a = iRtcEventHandler;
}
/* access modifiers changed from: package-private */
public abstract void a(IRtcEventHandler iRtcEventHandler);
public void run() {
IRtcEventHandler iRtcEventHandler = this.f10622a;
if (iRtcEventHandler != null) {
a(iRtcEventHandler);
}
}
}
public e(Context context, String str, String str2, boolean z2, int i2, RtcServerAddresses rtcServerAddresses, IRtcEventHandler iRtcEventHandler) throws Exception {
if (Compatibility.runningOnJellyBeanOrHigher()) {
Checker.checkArgument(context != null, "Context is null!");
Checker.checkArgument(iRtcEventHandler != null, "Handler is null!");
Checker.checkArgument(StringUtils.isNotEmpty(str2), "Log dir is empty!");
Checker.checkArgument(StringUtils.isNotEmpty(str), "App key is empty!");
b();
a(context, str, z2, i2);
this.v = new Handler(Looper.getMainLooper());
this.f10506b = iRtcEventHandler;
this.f10507c = str2;
d();
l.f(C0373a.f10493b);
l.e(C0373a.f10493b);
com.netease.nrtc.utility.a.a();
j();
this.A.set(false);
this.f10509e = new ConcurrentHashMap();
this.f10510f = new ConcurrentHashMap();
String str3 = "http://statistic.live.126.net/statistic/realtime/sdkinfo";
String str4 = "https://lbs.netease.im/cc/nrtc/v2";
if (rtcServerAddresses != null) {
Trace.i("RtcEngineImpl", rtcServerAddresses.toString());
if (com.netease.nrtc.utility.a.a(rtcServerAddresses.roomServer)) {
h.a(rtcServerAddresses.roomServer);
}
str3 = com.netease.nrtc.utility.a.a(rtcServerAddresses.statisticsServer) ? rtcServerAddresses.statisticsServer : str3;
if (com.netease.nrtc.utility.a.a(rtcServerAddresses.functionServer)) {
com.netease.nrtc.monitor.d.a(rtcServerAddresses.functionServer);
}
if (com.netease.nrtc.utility.a.a(rtcServerAddresses.compatServer)) {
str4 = rtcServerAddresses.compatServer;
}
}
com.netease.nrtc.b.a.a(C0373a.f10493b, str4);
com.netease.nrtc.b.a.a(false, C0373a.j);
com.netease.nrtc.video.a.e.a();
f();
b.a().a(this);
b(true);
this.m = com.netease.nrtc.voice.device.b.e.a(C0373a.f10493b);
this.F = new n(context, this.v) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass1 */
@Override // com.netease.nrtc.utility.n
public void a(int i) {
e.this.g((e) i);
}
};
if (!C0373a.f10499h) {
this.M = new j(str, str3, this.aZ);
} else {
this.M = null;
this.aq = new com.netease.nrtc.video.a(new B(this));
}
this.O = com.netease.nrtc.utility.b.a.a(this.f10507c);
g();
h();
this.an = com.netease.nrtc.debug.b.a();
this.N = new f();
com.netease.nrtc.c.a(context, str, rtcServerAddresses, str2);
com.netease.nrtc.c.a(new com.netease.nrtc.c.c.a());
Trace.d("Connect-Status-Test-Log", "status : " + this.z.get());
return;
}
throw new RuntimeException("Require sdk level 16 or higher!");
}
private int A() {
WindowManager windowManager = (WindowManager) C0373a.f10493b.getSystemService("window");
if (windowManager == null) {
return -1;
}
Display defaultDisplay = windowManager.getDefaultDisplay();
Point point = new Point();
if (Compatibility.runningOnJellyBeanMR1OrHigher()) {
defaultDisplay.getRealSize(point);
} else {
defaultDisplay.getSize(point);
}
int i2 = point.x;
int i3 = point.y;
Trace.i("RtcEngineImpl", "Display id " + defaultDisplay.getDisplayId() + ":" + i2 + GroupChatInvitation.ELEMENT_NAME + i3);
return com.netease.nrtc.video.a.b.a(i2, i3);
}
private void B() {
Trace.i("RtcEngineImpl", "stopAllVoicePlayout");
com.netease.nrtc.voice.b bVar = this.j;
if (bVar != null) {
bVar.h();
}
}
private boolean C() {
Trace.i("RtcEngineImpl", "startVoiceSend");
com.netease.nrtc.utility.a.c.a().a(this.aL, D());
int i2 = 0;
if (y() && com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.Z, false)) {
i2 = 60;
}
com.netease.nrtc.voice.b.e a2 = com.netease.nrtc.voice.a.a.a(this.s, f10505a == 44 ? 80 : i2, com.netease.nrtc.utility.a.c.a().c().f11032c, this.aL, D(), true, true);
this.j.a(a2);
this.j.c(this.aN);
this.f10511g.c((int) a2.f11672a);
this.f10511g.e(a2.f11675d);
this.f10511g.d(a2.f11673b);
this.Q.set(D() ? 2 : 1);
boolean a3 = this.j.a(this.Q.get(), a2);
Checker.traceFuncState(a3, "RtcEngineImpl", "voe#startSend");
return a3;
}
private boolean D() {
return this.aL && this.P == 1;
}
private void E() {
Checker.traceFuncState(this.j.f(), "RtcEngineImpl", "voe#stopSend");
}
private void F() {
Trace.i("RtcEngineImpl", "startVideoSend");
if (!this.H) {
Trace.e("RtcEngineImpl", "video unsupported！");
return;
}
j jVar = this.f10509e.get(Long.valueOf(this.f10508d.userId));
if (jVar != null) {
int n2 = n(jVar.f10635b);
Trace.i("RtcEngineImpl", "local video protocol ver -> " + n2);
this.n.b(this.f10508d.userId, n2);
this.n.a(this.aQ);
this.n.a(this.f10508d.userId, this.r, this.t, G());
Z();
if (this.aM) {
this.n.d();
} else {
this.n.c();
}
}
}
private boolean G() {
int i2 = this.R;
return i2 == 2 || i2 == 1;
}
private boolean H() {
Trace.i("RtcEngineImpl", "stopVideoSend");
this.n.d();
Trace.i("RtcEngineImpl", "stopVideoSend done");
return true;
}
private int I() {
if (this.y.get() != 3) {
return -1;
}
int i2 = -1001;
StringBuilder sb = new StringBuilder();
if (k() || !this.H) {
if (this.aj || this.af) {
i2 = ad();
}
if (!this.H) {
sb.append(" unsub: [");
for (C0374b bVar : this.ad.values()) {
if (bVar.c()) {
int o2 = o(bVar.a());
sb.append(bVar.a());
sb.append(":");
sb.append(o2);
sb.append(StringUtils.SPACE);
}
}
}
Trace.i("RtcEngineImpl", -300000, "update auto publish status , video = " + this.H + " , audience = " + k() + " , set pub video = " + this.af + " , auto pub = " + this.aj + " , pubUnPubResult = " + i2 + ((Object) sb));
return i2;
}
if (this.aj && !this.af) {
i2 = Y();
}
if (this.ak) {
Collection<C0374b> values = this.ad.values();
sb.append(" sub: [");
for (C0374b bVar2 : values) {
int a2 = a(bVar2.d());
if (a2 != -1) {
int e2 = e(bVar2.a(), a2);
sb.append(bVar2.a());
sb.append(":");
sb.append(e2);
sb.append(StringUtils.SPACE);
}
}
}
Trace.i("RtcEngineImpl", -300000, "update auto publish status , video = " + this.H + " , audience = " + k() + " , set pub video = " + this.af + " , auto pub = " + this.aj + " , pubUnPubResult = " + i2 + ((Object) sb));
return i2;
sb.append("]");
Trace.i("RtcEngineImpl", -300000, "update auto publish status , video = " + this.H + " , audience = " + k() + " , set pub video = " + this.af + " , auto pub = " + this.aj + " , pubUnPubResult = " + i2 + ((Object) sb));
return i2;
}
private boolean J() {
Trace.i("RtcEngineImpl", "switchToVideoMode");
this.m.a(0);
this.m.a(false);
if (!k()) {
F();
}
k(-1L);
this.f10511g.b(this.H);
L();
return true;
}
private boolean K() {
Trace.i("RtcEngineImpl", "switchToAudioMode");
this.m.a(this.ax);
H();
stopVideoPreview();
n(-1L);
this.f10511g.b(this.H);
L();
return true;
}
private void L() {
if (!z()) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.f10785g);
}
}
private boolean M() {
String str;
if (this.i) {
return true;
}
if (!SystemPermissionUtils.checkWriteExternalStoragePermission(C0373a.f10493b)) {
str = "init local record error: no permission!";
} else if (C0373a.f10493b.getExternalFilesDir("record") != null) {
File externalFilesDir = C0373a.f10493b.getExternalFilesDir("record");
String str2 = null;
if (externalFilesDir != null) {
str2 = externalFilesDir.getAbsolutePath();
}
if (StringUtils.isEmpty(str2)) {
return false;
}
String format = new SimpleDateFormat("yyyyMMddHHmmss", Locale.getDefault()).format(new Date());
File file = new File(str2 + "/" + format);
if (file.exists()) {
file.delete();
}
if (!file.mkdirs()) {
return false;
}
this.f10512h.a(this.aT);
boolean a2 = this.f10512h.a(this, this, file.getAbsolutePath());
this.i = a2;
return a2;
} else {
str = "init local record error: can not find dir!";
}
Trace.e("RtcEngineImpl", str);
return false;
}
private void N() {
if (y()) {
com.netease.nrtc.video.a.a k2 = this.n.k();
com.netease.nrtc.video.a.a l2 = this.n.l();
if (this.f10509e.size() <= 1) {
this.n.b(k2.f11135a, k2.f11136b, l2.f11135a, l2.f11136b, this.aJ);
} else if (k2.f11137c > 15) {
this.n.b(k2.f11135a, k2.f11136b, l2.f11135a, l2.f11136b, 15);
}
}
}
private void O() {
com.netease.nrtc.c.o.a.a(C0373a.f10493b, this.f10508d, this.f10507c, w());
}
private void P() {
Q();
R();
}
private void Q() {
NEMediaEngine nEMediaEngine = this.f10511g;
if (nEMediaEngine != null) {
nEMediaEngine.a(this.R, this.S, com.netease.nrtc.utility.c.c.a(C0373a.f10493b), this.P, this.aL, this.Y, this.V, this.W, this.Z, this.X, this.aJ);
}
}
private void R() {
int i2 = this.aR;
this.f10511g.a(i2 > 0 ? i2 / 1000 : -1, -1);
}
private void S() {
if (this.y.get() != 3) {
Trace.e("RtcEngineImpl", "after login try publish , but status is :" + this.y.get());
return;
}
e(false);
int i2 = -1001;
int Y2 = (k() || !this.H || (!this.aj && !this.af)) ? -1001 : Y();
if (this.ak || this.ag) {
i2 = ae();
}
Trace.i("RtcEngineImpl", -300000, "after login , pub result = " + Y2 + ", sub audio = " + i2 + ", auto pub = " + this.aj + ", auto sub = " + this.ak + ", pre pub = " + this.af + ", pre sub = " + this.ag);
}
private void T() {
RtcConfig rtcConfig = this.f10508d;
if (rtcConfig != null) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.j.a(rtcConfig.channel, com.netease.nrtc.c.a.a().c(), com.netease.nrtc.c.a.a().b()));
}
}
private void U() {
ConnectInfo connectInfo = new ConnectInfo();
connectInfo.c((long) com.netease.nrtc.voice.a.a.h(this.aC));
connectInfo.b((long) com.netease.nrtc.video.a.e.a(this.aC));
connectInfo.a((long) com.netease.nrtc.video.a.e.f(this.aC));
connectInfo.d((long) NEMediaEngine.a());
connectInfo.e((long) NEMediaEngine.a());
connectInfo.b(0);
connectInfo.a(com.netease.nrtc.internal.a.a(10));
onConnected(connectInfo);
}
/* access modifiers changed from: private */
public void V() {
Trace.i("RtcEngineImpl", "onLogoutFinished");
NEMediaEngine.f10708a = true;
NEMediaEngine.f10710c = SystemClock.elapsedRealtime();
NEMediaEngine nEMediaEngine = this.f10511g;
if (nEMediaEngine != null) {
nEMediaEngine.a(false);
}
j jVar = this.M;
if (jVar != null) {
jVar.d();
} else {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass9 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onLeaveChannel(new SessionStats());
}
});
}
this.z.set(0);
Trace.d("Connect-Status-Test-Log", "status : " + this.z.get());
}
private long W() {
for (Long l2 : this.f10509e.keySet()) {
long longValue = l2.longValue();
if (longValue != this.f10508d.userId) {
return longValue;
}
}
return 0;
}
private void X() {
String str;
if (this.y.get() == 3 && !k() && this.H) {
if (this.aj || this.af) {
str = "try re publish video , result = " + Y();
} else {
Z();
str = "try re publish video , but not publish before";
}
Trace.i("RtcEngineImpl", -300000, str);
}
}
private int Y() {
String str;
if (this.y.get() != 3) {
str = "publish video inner err , status = " + this.y.get();
} else {
com.netease.nrtc.video.a.a ab2 = ab();
k.a(this.f10511g.b(com.netease.nrtc.video.a.f.a(ab2.f11135a, ab2.f11136b)));
ArrayList<PublishVideoProfile> arrayList = new ArrayList<>();
arrayList.add(new PublishVideoProfile(0, ab2.f11135a, ab2.f11136b, this.aJ));
if (this.al == 1) {
com.netease.nrtc.video.a.a a2 = k.a(ab2);
arrayList.add(new PublishVideoProfile(2, a2.f11135a, a2.f11136b, this.aJ));
}
int a3 = this.f10511g.a(arrayList);
if (a3 == 0) {
if (this.n == null) {
str = "publish video inner err , vie2 is null";
} else {
Z();
this.af = true;
}
}
return a3;
}
Trace.w("RtcEngineImpl", -300000, str);
return -1;
}
private void Z() {
com.netease.nrtc.video.a.a ab2 = ab();
com.netease.nrtc.video.a.a ac2 = ac();
this.n.b(ab2.f11135a, ab2.f11136b, ac2.f11135a, ac2.f11136b, this.aJ);
}
private int a(int[] iArr) {
if (iArr == null || iArr.length == 0) {
return -1;
}
int i2 = iArr[0];
for (int i3 : iArr) {
if (i3 == 0) {
return i3;
}
if (i2 > i3) {
i2 = i3;
}
}
return i2;
}
/* access modifiers changed from: private */
/* renamed from: a */
public void b(int i2, int i3, float f2, int i4) {
if (this.y.get() != 3) {
Trace.i("RtcEngineImpl", "status not running");
return;
}
if (i2 >= 0) {
s(i4).f10881a = i2;
s(i4).f10882b = i3;
}
if (this.n.f()) {
this.n.a(i2 * 1000, i3, f2, i4);
}
}
private void a(int i2, int i3, int i4) {
NEMediaEngine nEMediaEngine = this.f10511g;
if (nEMediaEngine != null) {
nEMediaEngine.a(i2, i3, i4);
}
}
/* access modifiers changed from: private */
public /* synthetic */ void a(int i2, long j2) {
if (this.y.get() == 3 && this.f10511g != null && !this.an.requestRemoteKeyFrame(i2)) {
this.f10511g.b(j2, i2);
}
}
/* access modifiers changed from: private */
/* renamed from: a */
public void b(final long j2, final int i2, NetStatInfo netStatInfo) {
Trace.i("RtcEngineImpl", "onNetQualityChange-> uid :" + j2 + ", stat: " + i2);
if (this.y.get() != 3) {
Trace.i("RtcEngineImpl", "status not running");
return;
}
final NetStats netStats = new NetStats();
if (netStatInfo != null) {
netStats.rtt = netStatInfo.a();
netStats.audioLostRate = netStatInfo.b();
netStats.videoLostRate = netStatInfo.c();
netStatInfo.recycle();
}
com.netease.nrtc.profile.a.b().a(j2, netStats.rtt, netStats.videoLostRate);
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass10 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onNetworkQuality(j2, i2, netStats);
}
});
}
/* access modifiers changed from: private */
/* renamed from: a */
public synchronized void b(final long j2, PeopleJoinInfo peopleJoinInfo) {
Trace.i("RtcEngineImpl", "onUserJoin->" + j2 + ", " + peopleJoinInfo.toString());
if (!this.A.get()) {
this.ab.put(j2, peopleJoinInfo);
Trace.i("RtcEngineImpl", "pending user");
} else if (this.y.get() != 3) {
Trace.i("RtcEngineImpl", "status not running");
} else {
if (this.f10509e.containsKey(Long.valueOf(j2))) {
this.n.d(j2);
this.n.g(j2);
this.n.b(j2);
this.j.g(j2);
this.j.b(j2);
this.j.e(j2);
} else {
j jVar = new j();
jVar.f10634a = j2;
jVar.f10635b = (int) peopleJoinInfo.a();
jVar.f10636c = peopleJoinInfo.b();
jVar.f10637d = peopleJoinInfo.c();
jVar.f10638e = SystemClock.elapsedRealtime();
this.f10509e.put(Long.valueOf(j2), jVar);
if (jVar.f10637d == 0) {
this.f10510f.put(Long.valueOf(j2), jVar);
Trace.i("RtcEngineImpl", "user " + j2 + " is low energy!");
}
}
if (this.M != null) {
this.M.a(j2);
}
g(j2);
k(j2);
N();
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass7 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onUserJoined(j2);
}
});
}
}
private void a(Context context, String str, boolean z2, int i2) {
C0373a.f10493b = context.getApplicationContext();
C0373a.f10495d = str;
C0373a.f10498g = false;
C0373a.f10494c = SystemClock.elapsedRealtime();
C0373a.j = this.P;
C0373a.f10499h = z2;
C0373a.k = i2;
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private void a(Handler handler, a aVar) {
if (handler != null) {
ThreadUtils.runOnThread(handler, aVar);
}
}
/* JADX WARNING: Removed duplicated region for block: B:12:0x0051 */
/* JADX WARNING: Removed duplicated region for block: B:15:0x005c */
private static void a(Pair pair) {
char c2;
int i2;
String valueOf = String.valueOf(pair.first);
String valueOf2 = String.valueOf(pair.second);
Trace.i("RtcEngineImpl", "external requesting feature, key:" + valueOf + ", ext:" + valueOf2);
int hashCode = valueOf.hashCode();
if (hashCode != 1280028623) {
if (hashCode == 1752661341 && valueOf.equals(RtcParameters.FEATURE_STATISTICS_KEEP_CALLING)) {
c2 = 1;
if (c2 == 0) {
i2 = com.netease.nrtc.monitor.d.f10782d;
} else if (c2 != 1) {
Trace.w("RtcEngineImpl", "Unknown requesting feature!");
return;
} else {
i2 = com.netease.nrtc.monitor.d.Z;
}
com.netease.nrtc.monitor.d.a(i2);
}
} else if (valueOf.equals(RtcParameters.FEATURE_STATISTICS_CALL_CONTROL)) {
c2 = 0;
if (c2 == 0) {
}
com.netease.nrtc.monitor.d.a(i2);
}
c2 = 65535;
if (c2 == 0) {
}
com.netease.nrtc.monitor.d.a(i2);
}
private void a(RtcConfig rtcConfig) throws IllegalArgumentException {
com.netease.nrtc.utility.g.a(rtcConfig);
this.f10508d = rtcConfig;
this.o.a(rtcConfig.limitVideoQuality);
this.m.a(this.ax);
this.n.a(rtcConfig.userId);
this.n.b(this.ay);
q();
boolean z2 = false;
C0373a.f10498g = l.a() ? C0373a.f10498g || rtcConfig.gpl : rtcConfig.gpl;
if (com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.X)) {
this.Y = com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.X, this.Y);
}
Trace.i("RtcEngineImpl", "qos qosVideoInitBitrateMode -> " + this.Y);
if (com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.Y)) {
if (com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.Y, 1) == 0) {
z2 = true;
}
this.Z = z2;
}
Trace.i("RtcEngineImpl", "qos qosMusicQosRollback -> " + this.Z);
if (com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.V)) {
this.V = com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.V, 3);
}
Trace.i("RtcEngineImpl", "qos qosTurnOffVideo -> " + this.V);
if (com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.W)) {
this.W = com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.W, 3);
}
Trace.i("RtcEngineImpl", "qos qosMinKeepAudioMode -> " + this.W);
if (C0373a.f10499h) {
this.U = 1;
}
if (com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.U)) {
this.U = com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.U, 2);
}
Trace.i("RtcEngineImpl", "audio jitter type -> " + this.U);
if (com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.ac)) {
this.X = com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.ac, 2);
}
Trace.i("RtcEngineImpl", "arq mode -> " + this.X);
if (com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.ad)) {
this.aa = com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.ad, 1);
}
Trace.i("RtcEngineImpl", "bwe mode -> " + this.aa);
C0373a.f10496e = rtcConfig.userId;
C0373a.f10497f = rtcConfig.channel;
}
/* access modifiers changed from: private */
/* renamed from: a */
public synchronized void b(ConnectInfo connectInfo) {
Trace.i("RtcEngineImpl", "onConnected");
Trace.i("RtcEngineImpl", connectInfo.toString());
if (this.y.get() != 3) {
Trace.i("RtcEngineImpl", "status not running");
return;
}
boolean z2 = true;
if (this.A.compareAndSet(false, true)) {
f10505a = (int) Math.min(connectInfo.d(), connectInfo.e());
Trace.i("RtcEngineImpl", "my protocol version -> " + connectInfo.d());
Trace.i("RtcEngineImpl", "remote protocol version -> " + connectInfo.e());
j jVar = new j();
jVar.f10634a = this.f10508d.userId;
jVar.f10635b = f10505a;
this.f10509e.put(Long.valueOf(this.f10508d.userId), jVar);
if (this.M != null) {
this.M.b(this.f10508d.userId);
}
int h2 = com.netease.nrtc.voice.a.a.h(this.aC);
if (this.aS != -1) {
Trace.e("RtcEngineImpl", "has special audio codec = " + this.aS);
h2 = this.aS;
}
this.s = c((int) connectInfo.c(), h2);
if (!com.netease.nrtc.engine.rawapi.b.a(this.s)) {
Trace.e("RtcEngineImpl", "confirm audio codec not supported(" + this.s + ")");
this.s = 4;
}
Trace.i("RtcEngineImpl", "audio codec for encoder = " + this.s);
this.r = (int) connectInfo.b();
Trace.i("RtcEngineImpl", "video codec index -> " + this.r);
Trace.i("RtcEngineImpl", "video other decode resolution index -> " + connectInfo.a());
this.u = (int) connectInfo.a();
Trace.i("RtcEngineImpl", "video encode resolution max = " + this.u);
if (f10505a < 24) {
Trace.i("RtcEngineImpl", "disable audio high quality");
this.aL = false;
}
if (f10505a >= 39 && !this.aC) {
Trace.i("RtcEngineImpl", "video use high profile!");
}
S();
this.m.a(this.H ? 0 : 2, this.ax, this);
com.netease.nrtc.voice.device.b.e eVar = this.m;
if (this.H || !this.ax) {
z2 = false;
}
eVar.a(z2);
com.netease.nrtc.utility.a.c.a().a(this.aC ? 0 : com.netease.nrtc.internal.a.b(connectInfo.f()));
if (k()) {
Trace.i("RtcEngineImpl", "role is audience");
} else {
if (!C()) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass4 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onDeviceEvent(3002, "start voice send error");
}
});
}
F();
}
b(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass5 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
Trace.i("RtcEngineImpl", "notify onCallEstablished");
iRtcEventHandler.onCallEstablished();
}
});
int size = this.ab.size();
for (int i2 = 0; i2 < size; i2++) {
long keyAt = this.ab.keyAt(i2);
onPeopleJoined(keyAt, this.ab.get(keyAt));
}
this.ab.clear();
if (this.aq != null) {
this.aq.a();
}
this.an.prepare(this, this.aC, this.al, this.ao, this.ap);
} else {
S();
Trace.i("RtcEngineImpl", "reConnecting");
}
this.z.set(2);
Trace.d("Connect-Status-Test-Log", "status : " + this.z.get());
}
/* access modifiers changed from: private */
/* JADX WARNING: Code restructure failed: missing block: B:48:0x012c, code lost:
if (r10.J == 101) goto L_0x012e;
*/
/* renamed from: a */
public void e(final LoginResInfo loginResInfo) {
String str;
NEMediaEngine nEMediaEngine = this.f10511g;
boolean z2 = true;
if (nEMediaEngine != null) {
nEMediaEngine.a(loginResInfo.a() == 200);
}
boolean compareAndSet = this.B.compareAndSet(true, false);
boolean compareAndSet2 = this.C.compareAndSet(true, false);
this.J = (int) loginResInfo.a();
if (StringUtils.isNotEmpty(loginResInfo.e())) {
this.K = loginResInfo.e();
}
if (this.J != 200) {
this.z.set(4);
Trace.d("Connect-Status-Test-Log", "status : " + this.z.get());
}
j jVar = this.M;
if (jVar != null) {
int i2 = this.J;
if (i2 == 101) {
jVar.e();
} else if (i2 == 200) {
this.N.b();
Trace.i("RtcEngineImpl", "onConnectedServer, signalElapsed->" + this.N.c() + ", connectElapsed->" + this.N.d());
}
}
final int e2 = this.N.e();
if (compareAndSet) {
c(loginResInfo);
}
if (compareAndSet || compareAndSet2) {
Trace.i("RtcEngineImpl", "onConnectedServer->" + loginResInfo.toString() + " , reconnected = " + compareAndSet2);
if (this.y.get() != 3) {
str = "status not running";
} else {
if (!this.aL || !loginResInfo.d() || !this.j.c()) {
z2 = false;
}
this.aL = z2;
int i3 = this.J;
if (i3 == 200) {
this.E.set(false);
this.D.set(0);
} else if (i3 == 101 && this.E.get()) {
Trace.i("RtcEngineImpl", "relogin from pending reconnect!");
if (v()) {
str = "pending consumed, relogining!";
}
}
if (compareAndSet) {
b(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass43 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onJoinedChannel((int) loginResInfo.a(), loginResInfo.b(), loginResInfo.c(), e2);
}
});
} else {
int i4 = this.J;
if (i4 == 101) {
if (this.D.get() < 2) {
Trace.i("RtcEngineImpl", "relogin timeout, try again!");
v();
} else {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass2 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onDisconnectServer(1);
}
});
RtcConfig rtcConfig = this.f10508d;
if (rtcConfig != null) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.d.a(rtcConfig.userId, "1"));
}
}
} else if (i4 != 200) {
b(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass3 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onJoinedChannel((int) loginResInfo.a(), loginResInfo.b(), loginResInfo.c(), e2);
}
});
}
if (this.J == 200 && this.aC) {
U();
return;
}
return;
}
O();
if (this.J == 200) {
return;
}
return;
}
Trace.i("RtcEngineImpl", str);
}
}
/* JADX INFO: Can't fix incorrect switch cases order, some code will duplicate */
/* JADX WARNING: Removed duplicated region for block: B:18:0x0042 A[ADDED_TO_REGION] */
/* JADX WARNING: Removed duplicated region for block: B:22:0x006a */
/* JADX WARNING: Removed duplicated region for block: B:28:0x0094 */
/* JADX WARNING: Removed duplicated region for block: B:302:0x0691 */
/* JADX WARNING: Removed duplicated region for block: B:306:0x06b1 */
/* JADX WARNING: Removed duplicated region for block: B:30:0x00b0 */
/* JADX WARNING: Removed duplicated region for block: B:322:0x06e4 */
/* JADX WARNING: Removed duplicated region for block: B:326:0x0704 */
/* JADX WARNING: Removed duplicated region for block: B:342:0x0737 */
/* JADX WARNING: Removed duplicated region for block: B:346:0x0757 */
/* JADX WARNING: Removed duplicated region for block: B:406:0x08cb */
/* JADX WARNING: Removed duplicated region for block: B:410:0x08e5 */
/* JADX WARNING: Removed duplicated region for block: B:414:0x08f8 */
/* JADX WARNING: Removed duplicated region for block: B:432:0x0937 */
/* JADX WARNING: Removed duplicated region for block: B:436:0x0951 */
/* JADX WARNING: Removed duplicated region for block: B:440:0x0964 */
/* JADX WARNING: Removed duplicated region for block: B:505:? A[RETURN, SYNTHETIC] */
/* JADX WARNING: Removed duplicated region for block: B:507:? A[RETURN, SYNTHETIC] */
private void a(String str, Object obj) {
char c2;
char c3;
char c4;
char c5;
int i2;
int i3;
int i4;
char c6;
char c7;
char c8;
StringBuilder sb;
int hashCode = str.hashCode();
if (hashCode != 311174625) {
if (hashCode != 955184389) {
if (hashCode == 1056765944 && str.equals(RtcParameters.KEY_VIDEO_ENCRYPT_TYPE)) {
c2 = 1;
if (c2 == 0) {
if (!(c2 == 1 || c2 == 2)) {
sb = new StringBuilder();
sb.append("set parameter: [");
sb.append(str.toUpperCase());
sb.append(", ");
sb.append(obj);
}
if (obj == null) {
Trace.i("RtcEngineImpl", "ignore parameter: [" + str.toUpperCase() + "]");
return;
}
switch (str.hashCode()) {
case -2071249850:
if (str.equals(RtcParameters.KEY_NETLIB_VIDEO_LOOPBACK)) {
c3 = '4';
break;
}
c3 = 65535;
break;
case -2071183187:
if (str.equals(RtcParameters.KEY_SERVER_RECORD_SPEAKER)) {
c3 = 5;
break;
}
c3 = 65535;
break;
case -1999908078:
if (str.equals(RtcParameters.KEY_DEVICE_FIXED_ROTATION)) {
c3 = 18;
break;
}
c3 = 65535;
break;
case -1979116379:
if (str.equals(RtcParameters.KEY_DEVICE_DEFAULT_ROTATION)) {
c3 = 17;
break;
}
c3 = 65535;
break;
case -1862587763:
if (str.equals(RtcParameters.KEY_VIDEO_FPS_REPORTED)) {
c3 = '\f';
break;
}
c3 = 65535;
break;
case -1791226945:
if (str.equals(RtcParameters.KEY_VIDEO_ROTATE_IN_RENDING)) {
c3 = '\t';
break;
}
c3 = 65535;
break;
case -1683085645:
if (str.equals(RtcParameters.KEY_VIDEO_CAPTURE_ORIENTATION)) {
c3 = '!';
break;
}
c3 = 65535;
break;
case -1679500112:
if (str.equals(RtcParameters.KEY_PROFILE_TRACE_FLAG_DEBUG)) {
c3 = '6';
break;
}
c3 = 65535;
break;
case -1639007703:
if (str.equals(RtcParameters.KEY_AUDIO_EFFECT_AGC_CONFIG)) {
c3 = '\'';
break;
}
c3 = 65535;
break;
case -1624428709:
if (str.equals(RtcParameters.KEY_VIDEO_QUALITY)) {
c3 = 7;
break;
}
c3 = 65535;
break;
case -1574984238:
if (str.equals(RtcParameters.KEY_AUDIO_PROCESS_DUMP_FLAG_DEBUG)) {
c3 = '0';
break;
}
c3 = 65535;
break;
case -1527914602:
if (str.equals(RtcParameters.KEY_DEVICE_ROTATION_FIXED_OFFSET)) {
c3 = 19;
break;
}
c3 = 65535;
break;
case -1460447772:
if (str.equals(RtcParameters.KEY_VIDEO_PREVIEW_QUALITY)) {
c3 = '\b';
break;
}
c3 = 65535;
break;
case -1443392620:
if (str.equals(RtcParameters.KEY_AUDIO_ADJUST_PLAYBACK_SIGNAL_VOLUME)) {
c3 = '%';
break;
}
c3 = 65535;
break;
case -1285199350:
if (str.equals(RtcParameters.KEY_VIDEO_ENCODER_MODE)) {
c3 = 0;
break;
}
c3 = 65535;
break;
case -1156683758:
if (str.equals(RtcParameters.KEY_SESSION_MULTI_MODE)) {
c3 = 11;
break;
}
c3 = 65535;
break;
case -1144049993:
if (str.equals(RtcParameters.KEY_PROFILES_ENABLE_ON_TEST_SERVER)) {
c3 = '7';
break;
}
c3 = 65535;
break;
case -830116030:
if (str.equals(RtcParameters.KEY_AUDIO_EFFECT_NOISE_SUPPRESSOR)) {
c3 = 15;
break;
}
c3 = 65535;
break;
case -773145927:
if (str.equals(RtcParameters.KEY_VIDEO_TRANSPORT_MIRROR)) {
c3 = '$';
break;
}
c3 = 65535;
break;
case -705087381:
if (str.equals(RtcParameters.KEY_VIDEO_FIXED_CROP_RATIO)) {
c3 = '\"';
break;
}
c3 = 65535;
break;
case -574756739:
if (str.equals(RtcParameters.KEY_SESSION_MULTI_MODE_USER_ROLE)) {
c3 = '\n';
break;
}
c3 = 65535;
break;
case -454296371:
if (str.equals(RtcParameters.KEY_SESSION_LIVE_MODE)) {
c3 = 20;
break;
}
c3 = 65535;
break;
case -334213656:
if (str.equals(RtcParameters.KEY_SERVER_LIVE_RECORD)) {
c3 = ' ';
break;
}
c3 = 65535;
break;
case -161968216:
if (str.equals(RtcParameters.KEY_VIDEO_FRAME_FILTER_FORMAT)) {
c3 = 27;
break;
}
c3 = 65535;
break;
case -157773497:
if (str.equals(RtcParameters.KEY_AUDIO_CALL_PROXIMITY)) {
c3 = 6;
break;
}
c3 = 65535;
break;
case -146319937:
if (str.equals(RtcParameters.KEY_LOCAL_ENCODE_DECODE_VIDEO)) {
c3 = '5';
break;
}
c3 = 65535;
break;
case -137287658:
if (str.equals(RtcParameters.KEY_AUDIO_EFFECT_AUTOMATIC_GAIN_CONTROL)) {
c3 = 16;
break;
}
c3 = 65535;
break;
case -112917522:
if (str.equals(RtcParameters.KEY_VIDEO_MAX_BITRATE)) {
c3 = '\r';
break;
}
c3 = 65535;
break;
case -70718756:
if (str.equals(RtcParameters.KEY_AUDIO_PLAYBACK_DEFAULT_SAMPLE_RATE)) {
c3 = '/';
break;
}
c3 = 65535;
break;
case 129341046:
if (str.equals(RtcParameters.KEY_SERVER_AUDIO_RECORD)) {
c3 = 2;
break;
}
c3 = 65535;
break;
case 237668859:
if (str.equals(RtcParameters.KEY_AUDIO_EXTERNAL_CAPTURE)) {
c3 = '*';
break;
}
c3 = 65535;
break;
case 311174625:
if (str.equals(RtcParameters.KEY_VIDEO_ENCRYPT_KEY)) {
c3 = '2';
break;
}
c3 = 65535;
break;
case 337397166:
if (str.equals(RtcParameters.KEY_VIDEO_FRAME_FILTER)) {
c3 = 25;
break;
}
c3 = 65535;
break;
case 372528241:
if (str.equals(RtcParameters.KEY_COMPATIBILITY_CONFIG_SERVER)) {
c3 = 23;
break;
}
c3 = 65535;
break;
case 412571665:
if (str.equals(RtcParameters.KEY_SDK_FEATURE_STATISTICS)) {
c3 = '+';
break;
}
c3 = 65535;
break;
case 419532311:
if (str.equals(RtcParameters.KEY_AUDIO_ADJUST_CAPTURED_SIGNAL_VOLUME)) {
c3 = '&';
break;
}
c3 = 65535;
break;
case 596167219:
if (str.equals(RtcParameters.KEY_AUDIO_FRAME_FILTER)) {
c3 = 28;
break;
}
c3 = 65535;
break;
case 698571901:
if (str.equals(RtcParameters.KEY_COMPATIBILITY_CONFIG_LOCAL)) {
c3 = 24;
break;
}
c3 = 65535;
break;
case 760558347:
if (str.equals(RtcParameters.KEY_AUDIO_HIGH_QUALITY)) {
c3 = 31;
break;
}
c3 = 65535;
break;
case 955184389:
if (str.equals(RtcParameters.KEY_SESSION_LIVE_URL)) {
c3 = 21;
break;
}
c3 = 65535;
break;
case 1056765944:
if (str.equals(RtcParameters.KEY_VIDEO_ENCRYPT_TYPE)) {
c3 = '1';
break;
}
c3 = 65535;
break;
case 1103225839:
if (str.equals(RtcParameters.KEY_SESSION_LIVE_COMPOSITING_LAYOUT)) {
c3 = 30;
break;
}
c3 = 65535;
break;
case 1285247325:
if (str.equals(RtcParameters.KEY_AUDIO_REPORT_SPEAKER)) {
c3 = 29;
break;
}
c3 = 65535;
break;
case 1464760610:
if (str.equals(RtcParameters.KEY_AUDIO_EFFECT_FAR_END_AUTOMATIC_GAIN_CONTROL)) {
c3 = '(';
break;
}
c3 = 65535;
break;
case 1568541233:
if (str.equals(RtcParameters.KEY_SERVER_VIDEO_RECORD)) {
c3 = 3;
break;
}
c3 = 65535;
break;
case 1658076469:
if (str.equals(RtcParameters.KEY_AUDIO_EFFECT_FAR_END_AGC_CONFIG)) {
c3 = ')';
break;
}
c3 = 65535;
break;
case 1823452394:
if (str.equals(RtcParameters.KEY_AUDIO_EFFECT_ACOUSTIC_ECHO_CANCELER)) {
c3 = 14;
break;
}
c3 = 65535;
break;
case 1873378274:
if (str.equals(RtcParameters.KEY_VIDEO_DECODER_MODE)) {
c3 = 1;
break;
}
c3 = 65535;
break;
case 1882245767:
if (str.equals(RtcParameters.KEY_AUDIO_SPECIAL_CODEC)) {
c3 = '-';
break;
}
c3 = 65535;
break;
case 2022851605:
if (str.equals(RtcParameters.KEY_AUDIO_CAPTURE_DEFAULT_SAMPLE_RATE)) {
c3 = '.';
break;
}
c3 = 65535;
break;
case 2061813685:
if (str.equals(RtcParameters.KEY_SERVER_RECORD_MODE)) {
c3 = 4;
break;
}
c3 = 65535;
break;
case 2083380374:
if (str.equals(RtcParameters.KEY_VIDEO_FRAME_RATE)) {
c3 = 22;
break;
}
c3 = 65535;
break;
case 2083690383:
if (str.equals(RtcParameters.KEY_VIDEO_FRAME_FILTER_NEW)) {
c3 = 26;
break;
}
c3 = 65535;
break;
case 2099798764:
if (str.equals(RtcParameters.KEY_SDK_ENABLE_GPL)) {
c3 = ',';
break;
}
c3 = 65535;
break;
case 2131807051:
if (str.equals(RtcParameters.KEY_NETLIB_AUDIO_LOOPBACK)) {
c3 = '3';
break;
}
c3 = 65535;
break;
case 2138662542:
if (str.equals(RtcParameters.KEY_VIDEO_LOCAL_PREVIEW_MIRROR)) {
c3 = '#';
break;
}
c3 = 65535;
break;
default:
c3 = 65535;
break;
}
switch (c3) {
case 0:
String str2 = (String) obj;
int hashCode2 = str2.hashCode();
if (hashCode2 != -1687096461) {
if (hashCode2 != -1021446805) {
if (hashCode2 == 2071099820 && str2.equals("media_codec_hardware")) {
c4 = 2;
if (c4 == 0) {
if (c4 == 1) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.A, 1);
com.netease.nrtc.video.a.e.b(false);
com.netease.nrtc.video.a.e.d(false);
} else if (c4 == 2) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.A, 2);
com.netease.nrtc.video.a.e.b(true);
}
if (this.y.get() == 3) {
this.n.c(true);
return;
}
return;
}
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.A, 0);
com.netease.nrtc.video.a.e.b(false);
com.netease.nrtc.video.a.e.d(true);
if (this.y.get() == 3) {
}
}
} else if (str2.equals("media_codec_software")) {
c4 = 1;
if (c4 == 0) {
}
com.netease.nrtc.video.a.e.d(true);
if (this.y.get() == 3) {
}
}
} else if (str2.equals("media_codec_auto")) {
c4 = 0;
if (c4 == 0) {
}
com.netease.nrtc.video.a.e.d(true);
if (this.y.get() == 3) {
}
}
c4 = 65535;
if (c4 == 0) {
}
com.netease.nrtc.video.a.e.d(true);
if (this.y.get() == 3) {
}
case 1:
String str3 = (String) obj;
int hashCode3 = str3.hashCode();
if (hashCode3 != -1687096461) {
if (hashCode3 != -1021446805) {
if (hashCode3 == 2071099820 && str3.equals("media_codec_hardware")) {
c5 = 2;
if (c5 == 0) {
if (c5 == 1) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.B, 1);
com.netease.nrtc.video.a.e.c(false);
com.netease.nrtc.video.a.e.e(false);
} else if (c5 == 2) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.B, 2);
com.netease.nrtc.video.a.e.c(true);
}
if (this.y.get() == 3) {
this.n.c(false);
return;
}
return;
}
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.B, 0);
com.netease.nrtc.video.a.e.c(false);
com.netease.nrtc.video.a.e.e(true);
if (this.y.get() == 3) {
}
}
} else if (str3.equals("media_codec_software")) {
c5 = 1;
if (c5 == 0) {
}
com.netease.nrtc.video.a.e.e(true);
if (this.y.get() == 3) {
}
}
} else if (str3.equals("media_codec_auto")) {
c5 = 0;
if (c5 == 0) {
}
com.netease.nrtc.video.a.e.e(true);
if (this.y.get() == 3) {
}
}
c5 = 65535;
if (c5 == 0) {
}
com.netease.nrtc.video.a.e.e(true);
if (this.y.get() == 3) {
}
case 2:
this.at = ((Boolean) obj).booleanValue();
if (this.at) {
i2 = com.netease.nrtc.monitor.d.aa;
com.netease.nrtc.monitor.d.a(i2);
return;
}
return;
case 3:
this.au = ((Boolean) obj).booleanValue();
if (this.au) {
i2 = com.netease.nrtc.monitor.d.ab;
com.netease.nrtc.monitor.d.a(i2);
return;
}
return;
case 4:
this.aw = ((Integer) obj).intValue();
i4 = com.netease.nrtc.monitor.d.ac;
i3 = this.aw;
com.netease.nrtc.monitor.d.a(i4, i3);
return;
case 5:
this.av = ((Boolean) obj).booleanValue();
return;
case 6:
this.ax = ((Boolean) obj).booleanValue();
return;
case 7:
if (this.al != 0 && this.y.get() == 3 && 1 == ((Integer) obj).intValue()) {
Trace.w("RtcEngineImpl", "QUALITY_LOW not allowed at multi stream");
return;
}
int i5 = this.az;
this.az = ((Integer) obj).intValue();
if (i5 != this.az) {
aa();
X();
}
if (this.f10508d != null) {
int i6 = com.netease.nrtc.c.g.b.i;
com.netease.nrtc.c.a(new com.netease.nrtc.c.g.a(i6, "1", o(this.az) + ""));
}
i4 = com.netease.nrtc.monitor.d.y;
i3 = o(this.az);
com.netease.nrtc.monitor.d.a(i4, i3);
return;
case '\b':
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.ag);
int intValue = ((Integer) obj).intValue();
if (this.aA != intValue) {
this.aA = intValue;
aa();
Z();
return;
}
return;
case '\t':
this.ay = ((Boolean) obj).booleanValue();
this.n.b(this.ay);
if (this.ay) {
i2 = com.netease.nrtc.monitor.d.L;
com.netease.nrtc.monitor.d.a(i2);
return;
}
return;
case '\n':
int intValue2 = ((Integer) obj).intValue();
if (this.y.get() != 3) {
this.aB = intValue2;
return;
} else {
setRole(intValue2);
return;
}
case 11:
this.aC = ((Boolean) obj).booleanValue();
return;
case '\f':
this.aD = ((Boolean) obj).booleanValue();
return;
case '\r':
this.aR = ((Integer) obj).intValue();
if (this.y.get() == 3) {
R();
}
com.netease.nrtc.c.a(new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.l, "1", String.valueOf(this.aR)));
i4 = com.netease.nrtc.monitor.d.C;
i3 = this.aR;
com.netease.nrtc.monitor.d.a(i4, i3);
return;
case 14:
String str4 = (String) obj;
int hashCode4 = str4.hashCode();
if (hashCode4 != -1143663023) {
if (hashCode4 != -900892964) {
if (hashCode4 == -489074763 && str4.equals("audio_effect_mode_platform_builtin_priority")) {
c6 = 1;
if (c6 != 0) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.I, 0);
com.netease.nrtc.voice.a.a.e(false);
return;
} else if (c6 == 1) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.I, 2);
com.netease.nrtc.voice.a.a.e(true);
com.netease.nrtc.voice.a.a.a(false);
return;
} else if (c6 == 2) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.I, 1);
com.netease.nrtc.voice.a.a.e(true);
com.netease.nrtc.voice.a.a.a(true);
return;
} else {
return;
}
}
} else if (str4.equals("audio_effect_mode_sdk_builtin_priority")) {
c6 = 2;
if (c6 != 0) {
}
}
} else if (str4.equals("audio_effect_mode_disable")) {
c6 = 0;
if (c6 != 0) {
}
}
c6 = 65535;
if (c6 != 0) {
}
case 15:
String str5 = (String) obj;
int hashCode5 = str5.hashCode();
if (hashCode5 != -1143663023) {
if (hashCode5 != -900892964) {
if (hashCode5 == -489074763 && str5.equals("audio_effect_mode_platform_builtin_priority")) {
c7 = 1;
if (c7 != 0) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.F, 0);
com.netease.nrtc.voice.a.a.d(false);
return;
} else if (c7 == 1) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.F, 2);
com.netease.nrtc.voice.a.a.d(true);
com.netease.nrtc.voice.a.a.c(false);
return;
} else if (c7 == 2) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.F, 1);
com.netease.nrtc.voice.a.a.d(true);
com.netease.nrtc.voice.a.a.c(true);
return;
} else {
return;
}
}
} else if (str5.equals("audio_effect_mode_sdk_builtin_priority")) {
c7 = 2;
if (c7 != 0) {
}
}
} else if (str5.equals("audio_effect_mode_disable")) {
c7 = 0;
if (c7 != 0) {
}
}
c7 = 65535;
if (c7 != 0) {
}
case 16:
String str6 = (String) obj;
int hashCode6 = str6.hashCode();
if (hashCode6 != -1143663023) {
if (hashCode6 != -900892964) {
if (hashCode6 == -489074763 && str6.equals("audio_effect_mode_platform_builtin_priority")) {
c8 = 1;
if (c8 != 0) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.G, 0);
com.netease.nrtc.voice.a.a.f(false);
return;
} else if (c8 == 1) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.G, 2);
com.netease.nrtc.voice.a.a.f(true);
com.netease.nrtc.voice.a.a.b(false);
return;
} else if (c8 == 2) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.G, 1);
com.netease.nrtc.voice.a.a.f(true);
com.netease.nrtc.voice.a.a.b(true);
return;
} else {
return;
}
}
} else if (str6.equals("audio_effect_mode_sdk_builtin_priority")) {
c8 = 2;
if (c8 != 0) {
}
}
} else if (str6.equals("audio_effect_mode_disable")) {
c8 = 0;
if (c8 != 0) {
}
}
c8 = 65535;
if (c8 != 0) {
}
case 17:
this.aE = ((Integer) obj).intValue();
this.n.c(VideoUtils.surfaceRotationToRealWorldRotation(this.aE));
return;
case 18:
this.aE = ((Integer) obj).intValue();
this.n.c(VideoUtils.surfaceRotationToRealWorldRotation(this.aE));
this.aF = true;
return;
case 19:
this.aG = ((Integer) obj).intValue();
return;
case 20:
this.aH = ((Boolean) obj).booleanValue();
return;
case 21:
e((String) obj);
return;
case 22:
if (this.y.get() != 3) {
int intValue3 = ((Integer) obj).intValue();
if (this.aJ != intValue3) {
this.aJ = intValue3;
Z();
}
} else {
Trace.e("RtcEngineImpl", "status is running , cannot change video rate");
}
com.netease.nrtc.c.a(new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.k, "1", String.valueOf(this.aJ)));
i4 = com.netease.nrtc.monitor.d.z;
i3 = (this.aJ / 5) + 1;
com.netease.nrtc.monitor.d.a(i4, i3);
return;
case 23:
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.w);
com.netease.nrtc.b.a.b(C0373a.f10493b, (String) obj);
return;
case 24:
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.w);
com.netease.nrtc.b.a.a((String) obj);
return;
case 25:
this.n.d(((Boolean) obj).booleanValue());
return;
case 26:
this.n.e(((Boolean) obj).booleanValue());
return;
case 27:
this.n.f(((Integer) obj).intValue());
return;
case 28:
this.j.g(((Boolean) obj).booleanValue());
return;
case 29:
this.j.d(((Boolean) obj).booleanValue());
return;
case 30:
this.aK = (RtcLiveCompositingLayout) obj;
return;
case 31:
this.aL = ((Boolean) obj).booleanValue();
i2 = com.netease.nrtc.monitor.d.x;
com.netease.nrtc.monitor.d.a(i2);
return;
case ' ':
this.aO = ((Boolean) obj).booleanValue();
return;
case '!':
this.aP = ((Integer) obj).intValue();
this.n.d(VideoUtils.surfaceRotationToRealWorldRotation(this.aP));
int i7 = this.aP;
if (i7 == 0 || i7 == 2) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.P, 2);
return;
} else if (i7 == 3 || i7 == 1) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.P, 1);
return;
} else {
return;
}
case '\"':
this.aQ = ((Integer) obj).intValue();
this.n.a(this.aQ);
com.netease.nrtc.c.a(new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.m, "1", String.valueOf(this.aQ)));
i4 = com.netease.nrtc.monitor.d.M;
i3 = this.aQ;
com.netease.nrtc.monitor.d.a(i4, i3);
return;
case '#':
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.n);
this.n.f(((Boolean) obj).booleanValue());
return;
case '$':
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.o);
this.n.g(((Boolean) obj).booleanValue());
return;
case '%':
this.j.b(((Integer) obj).intValue());
return;
case '&':
this.j.c(((Integer) obj).intValue());
return;
case '\'':
RtcAgcConfig rtcAgcConfig = (RtcAgcConfig) obj;
Integer num = rtcAgcConfig.mode;
if (num != null && com.netease.nrtc.engine.rawapi.a.a(num.intValue())) {
com.netease.nrtc.voice.a.a.a(rtcAgcConfig.mode.intValue());
}
Boolean bool = rtcAgcConfig.limiterEnabled;
if (bool != null) {
this.j.e(bool.booleanValue());
}
Integer num2 = rtcAgcConfig.compressionGainDb;
if (num2 != null) {
this.j.e(num2.intValue());
}
Integer num3 = rtcAgcConfig.targetLevelDbfs;
if (num3 != null) {
this.j.d(num3.intValue());
return;
}
return;
case '(':
com.netease.nrtc.voice.a.a.g("audio_effect_mode_sdk_builtin_priority".equals((String) obj));
return;
case ')':
RtcAgcConfig rtcAgcConfig2 = (RtcAgcConfig) obj;
Integer num4 = rtcAgcConfig2.mode;
if (num4 != null && com.netease.nrtc.engine.rawapi.a.a(num4.intValue())) {
com.netease.nrtc.voice.a.a.b(rtcAgcConfig2.mode.intValue());
}
Boolean bool2 = rtcAgcConfig2.limiterEnabled;
if (bool2 != null) {
this.j.f(bool2.booleanValue());
}
Integer num5 = rtcAgcConfig2.compressionGainDb;
if (num5 != null) {
this.j.g(num5.intValue());
}
Integer num6 = rtcAgcConfig2.targetLevelDbfs;
if (num6 != null) {
this.j.f(num6.intValue());
return;
}
return;
case '*':
this.j.b(((Boolean) obj).booleanValue());
return;
case '+':
a((Pair) obj);
return;
case ',':
C0373a.f10498g = ((Boolean) obj).booleanValue();
return;
case '-':
this.aS = ((Integer) obj).intValue();
return;
case '.':
AudioDeviceParameters.a(((Integer) obj).intValue());
return;
case '/':
AudioDeviceParameters.b(((Integer) obj).intValue());
return;
case '0':
this.j.h(((Integer) obj).intValue());
return;
case '1':
this.aU = ((Integer) obj).intValue();
return;
case '2':
this.aV = (String) obj;
return;
case '3':
this.aX = ((Boolean) obj).booleanValue();
return;
case '4':
this.aW = ((Boolean) obj).booleanValue();
return;
case '5':
try {
JSONObject jSONObject = new JSONObject((String) obj);
C0373a.s = jSONObject.optBoolean("local_encode_encode_video", false);
this.ao = jSONObject.optInt("high_res_count", 1);
this.ap = jSONObject.optInt("low_res_count", 1);
this.an = com.netease.nrtc.debug.b.a();
return;
} catch (Exception e2) {
e2.printStackTrace();
return;
}
case '6':
this.as = ((Boolean) obj).booleanValue();
int e3 = e();
Trace.nativeSetTraceFilter(e3);
NEMediaEngine nEMediaEngine = this.f10511g;
if (nEMediaEngine != null) {
nEMediaEngine.f(e3);
return;
}
return;
case '7':
this.aY = ((Boolean) obj).booleanValue();
return;
default:
Trace.e("RtcEngineImpl", "set parameter [" + str.toUpperCase() + "] unsupported!");
return;
}
} else {
sb = new StringBuilder();
sb.append("set parameter: [");
sb.append(str.toUpperCase());
sb.append(", ");
sb.append(StringUtils.isEmpty((String) obj) ? "null" : "url");
}
sb.append("]");
Trace.i("RtcEngineImpl", sb.toString());
if (obj == null) {
}
}
} else if (str.equals(RtcParameters.KEY_SESSION_LIVE_URL)) {
c2 = 0;
if (c2 == 0) {
}
sb.append("]");
Trace.i("RtcEngineImpl", sb.toString());
if (obj == null) {
}
}
} else if (str.equals(RtcParameters.KEY_VIDEO_ENCRYPT_KEY)) {
c2 = 2;
if (c2 == 0) {
}
sb.append("]");
Trace.i("RtcEngineImpl", sb.toString());
if (obj == null) {
}
}
c2 = 65535;
if (c2 == 0) {
}
sb.append("]");
Trace.i("RtcEngineImpl", sb.toString());
if (obj == null) {
}
}
/* access modifiers changed from: private */
/* renamed from: a */
public void b(String str, boolean z2) {
Trace.i("RtcEngineImpl", "onPublicIpChange:" + str + "@" + z2);
if (this.y.get() != 3) {
Trace.i("RtcEngineImpl", "status not running");
return;
}
if (this.f10508d != null && !this.L.equals(str)) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.h.a(this.f10508d.channel, str));
this.L = str;
}
if (z2 || !this.K.equals(str)) {
v();
}
}
/* access modifiers changed from: private */
public void a(Set<Integer> set) {
for (Integer num : set) {
int intValue = num.intValue();
EncodeStatInfo g2 = this.n.g(intValue);
if (g2 == null) {
g2 = EncodeStatInfo.obtain();
}
this.f10511g.b(this.aq.a(intValue), intValue, g2.a(), g2.b());
g2.recycle();
}
}
private void a(boolean z2, long j2, boolean z3, int[] iArr, boolean z4, int i2) {
C0374b bVar = this.ad.get(Long.valueOf(j2));
if (bVar == null && z2) {
bVar = new C0374b(j2);
this.ad.put(Long.valueOf(j2), bVar);
}
if (bVar != null) {
if (z3) {
bVar.a(iArr);
}
if (z4) {
bVar.a(i2);
}
}
}
private void aa() {
if (this.aA != 0) {
int a2 = com.netease.nrtc.video.a.e.a(C0373a.f10493b, this.aC);
if (com.netease.nrtc.video.a.e.b(this.az, a2) > com.netease.nrtc.video.a.e.b(this.aA, a2)) {
this.aA = this.az;
}
}
}
private com.netease.nrtc.video.a.a ab() {
int b2 = this.o.b(com.netease.nrtc.video.a.e.b(this.az, com.netease.nrtc.video.a.e.a(C0373a.f10493b, this.aC)));
int i2 = this.u;
if (i2 == 0) {
i2 = b2;
}
return com.netease.nrtc.video.a.f.a(p(Math.min(i2, b2)));
}
private com.netease.nrtc.video.a.a ac() {
int b2;
if (!this.A.get()) {
int i2 = this.aA;
if (i2 == 0) {
i2 = this.az;
}
if (!C0373a.f10499h) {
i2 = com.netease.nrtc.video.a.e.c(i2, 4);
}
b2 = com.netease.nrtc.video.a.e.b(i2, com.netease.nrtc.video.a.e.a(C0373a.f10493b, this.aC));
} else if (this.aA == 0) {
return ab();
} else {
b2 = p(com.netease.nrtc.video.a.e.b(this.aA, com.netease.nrtc.video.a.e.a(C0373a.f10493b, this.aC)));
}
return com.netease.nrtc.video.a.f.a(b2);
}
private int ad() {
int i2 = this.f10511g.i();
if (i2 == 0) {
this.af = false;
j jVar = this.M;
if (jVar != null) {
jVar.a(-1);
}
this.n.e();
}
return i2;
}
private int ae() {
return this.f10511g.j();
}
private int af() {
return this.f10511g.k();
}
private int ag() {
if (!this.aC) {
return -600;
}
if (k()) {
return -200;
}
if (this.aM) {
return -100;
}
return !this.H ? RtcCode.Subscribe.IS_AUDIO_MODE_ERR : this.aj ? -500 : 0;
}
private int ah() {
if (!this.aC) {
return -600;
}
if (this.ak) {
return -500;
}
return this.am == 70 ? -1 : 0;
}
private void b() throws Error {
LibraryUtils.loadLibrary("nrtc_sdk");
c();
}
/* access modifiers changed from: private */
/* renamed from: b */
public void c(int i2, int i3, int i4) {
String str;
if (this.y.get() != 3) {
str = "status not running";
} else {
this.n.a(i2, i3, i4);
str = "onVideoDropFrame->(flag=" + i2 + ", long time drop=" + i3 + " type = " + i4 + ")";
}
Trace.i("RtcEngineImpl", str);
}
private void b(final int i2, int i3, final Set<Integer> set, final boolean z2) {
com.netease.nrtc.b.a.a(i2);
com.netease.nrtc.voice.b bVar = this.j;
if (bVar != null) {
bVar.a(i2, i3);
}
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass12 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onAudioDeviceChanged(i2, set, z2);
}
});
}
private void b(Handler handler, a aVar) {
if (handler != null) {
ThreadUtils.runOnThreadBlocking(handler, aVar);
}
}
/* access modifiers changed from: private */
/* renamed from: b */
public void d(LoginResInfo loginResInfo) {
StringBuilder sb = new StringBuilder();
sb.append("re login call back , result = ");
sb.append(loginResInfo == null ? "null" : Long.valueOf(loginResInfo.a()));
Trace.i("RtcEngineImpl", sb.toString());
if (loginResInfo != null && loginResInfo.a() == 200) {
S();
}
}
private void b(boolean z2) {
if (SystemPermissionUtils.checkWakeLockPermission(C0373a.f10493b)) {
d(z2);
c(z2);
}
}
private static int c(int i2, int i3) {
int parseInt;
String valueOf = String.valueOf(i2);
String valueOf2 = String.valueOf(i3);
HashMap hashMap = new HashMap();
int i4 = 0;
for (int i5 = 0; i5 < valueOf.length(); i5++) {
hashMap.put(Character.valueOf(valueOf.charAt(i5)), Integer.valueOf(255 - i5));
}
for (int i6 = 0; i6 < valueOf2.length(); i6++) {
Character valueOf3 = Character.valueOf(valueOf2.charAt(i6));
Integer num = (Integer) hashMap.get(valueOf3);
hashMap.put(valueOf3, Integer.valueOf(num == null ? 255 - i6 : (num.intValue() + 255) - i6));
}
int i7 = -1;
for (Character ch : hashMap.keySet()) {
int intValue = ((Integer) hashMap.get(ch)).intValue();
if (intValue > i4) {
i7 = Integer.parseInt(Character.toString(ch.charValue()));
i4 = intValue;
}
if (intValue == i4 && i7 > (parseInt = Integer.parseInt(Character.toString(ch.charValue())))) {
i7 = parseInt;
}
}
String valueOf4 = String.valueOf(i7);
if (!valueOf.contains(valueOf4) || !valueOf2.contains(valueOf4)) {
Trace.w("RtcEngineImpl", "codec confirm cannot find all suitable , codec1 : " + valueOf + " , codec2 : " + valueOf2 + " , select : " + valueOf4);
}
return i7;
}
private String c(String str) {
if (TextUtils.isEmpty(str)) {
return null;
}
File file = new File(str, "audio_dump");
if (!file.exists()) {
file.mkdirs();
}
return file.getAbsolutePath();
}
private void c() throws Error {
if (IRtcEngine.versionCode() == NativeVersion.nativeBuildVersionCode()) {
Log.d("RtcEngineImpl", "check nrtc_sdk.so ok");
return;
}
throw new Error("native lib version wrong!!!");
}
private void c(LoginResInfo loginResInfo) {
com.netease.nrtc.c.i.a aVar = new com.netease.nrtc.c.i.a();
if (this.f10508d != null) {
aVar.a(this.f10508d.userId + "");
aVar.b(this.f10508d.channel + "");
}
aVar.a(this.aC);
aVar.b(this.at);
aVar.c(this.au);
aVar.a(this.aw);
aVar.d(this.av);
aVar.d(this.N.c());
aVar.e(this.N.d());
aVar.e(this.aH && this.aC);
NEMediaEngine nEMediaEngine = this.f10511g;
aVar.c((nEMediaEngine != null ? nEMediaEngine.g() : SessionInfo.obtain()).a());
aVar.b(this.aa);
aVar.c((int) loginResInfo.a());
aVar.a(com.netease.nrtc.video.a.e.i());
aVar.b(com.netease.nrtc.video.a.e.j());
com.netease.nrtc.c.a(aVar);
}
@SuppressLint({"WakelockTimeout"})
private void c(boolean z2) {
StringBuilder sb = new StringBuilder();
sb.append(z2 ? "acquire" : "release");
sb.append(" partial wake lock");
Trace.i("RtcEngineImpl", sb.toString());
if (z2) {
PowerManager powerManager = (PowerManager) C0373a.f10493b.getSystemService("power");
if (this.x == null && powerManager != null) {
this.x = powerManager.newWakeLock(1, "com.netease.nrtc::wakeLock");
this.x.setReferenceCounted(false);
}
PowerManager.WakeLock wakeLock = this.x;
if (wakeLock != null && !wakeLock.isHeld()) {
this.x.acquire();
return;
}
return;
}
PowerManager.WakeLock wakeLock2 = this.x;
if (wakeLock2 != null && wakeLock2.isHeld()) {
this.x.release();
this.x = null;
}
}
/* JADX INFO: Can't fix incorrect switch cases order, some code will duplicate */
private Object d(String str) {
char c2;
int i2 = 0;
switch (str.hashCode()) {
case -2071183187:
if (str.equals(RtcParameters.KEY_SERVER_RECORD_SPEAKER)) {
c2 = '\t';
break;
}
c2 = 65535;
break;
case -1999908078:
if (str.equals(RtcParameters.KEY_DEVICE_FIXED_ROTATION)) {
c2 = 19;
break;
}
c2 = 65535;
break;
case -1979116379:
if (str.equals(RtcParameters.KEY_DEVICE_DEFAULT_ROTATION)) {
c2 = 18;
break;
}
c2 = 65535;
break;
case -1862587763:
if (str.equals(RtcParameters.KEY_VIDEO_FPS_REPORTED)) {
c2 = 17;
break;
}
c2 = 65535;
break;
case -1791226945:
if (str.equals(RtcParameters.KEY_VIDEO_ROTATE_IN_RENDING)) {
c2 = 14;
break;
}
c2 = 65535;
break;
case -1683085645:
if (str.equals(RtcParameters.KEY_VIDEO_CAPTURE_ORIENTATION)) {
c2 = ' ';
break;
}
c2 = 65535;
break;
case -1624428709:
if (str.equals(RtcParameters.KEY_VIDEO_QUALITY)) {
c2 = '\f';
break;
}
c2 = 65535;
break;
case -1527914602:
if (str.equals(RtcParameters.KEY_DEVICE_ROTATION_FIXED_OFFSET)) {
c2 = 20;
break;
}
c2 = 65535;
break;
case -1460447772:
if (str.equals(RtcParameters.KEY_VIDEO_PREVIEW_QUALITY)) {
c2 = '\r';
break;
}
c2 = 65535;
break;
case -1459623615:
if (str.equals(RtcParameters.KEY_VIDEO_SUPPORTED_HW_ENCODER)) {
c2 = 2;
break;
}
c2 = 65535;
break;
case -1285199350:
if (str.equals(RtcParameters.KEY_VIDEO_ENCODER_MODE)) {
c2 = 0;
break;
}
c2 = 65535;
break;
case -1156683758:
if (str.equals(RtcParameters.KEY_SESSION_MULTI_MODE)) {
c2 = 16;
break;
}
c2 = 65535;
break;
case -1144049993:
if (str.equals(RtcParameters.KEY_PROFILES_ENABLE_ON_TEST_SERVER)) {
c2 = ')';
break;
}
c2 = 65535;
break;
case -830116030:
if (str.equals(RtcParameters.KEY_AUDIO_EFFECT_NOISE_SUPPRESSOR)) {
c2 = 5;
break;
}
c2 = 65535;
break;
case -773145927:
if (str.equals(RtcParameters.KEY_VIDEO_TRANSPORT_MIRROR)) {
c2 = '#';
break;
}
c2 = 65535;
break;
case -705087381:
if (str.equals(RtcParameters.KEY_VIDEO_FIXED_CROP_RATIO)) {
c2 = '!';
break;
}
c2 = 65535;
break;
case -574756739:
if (str.equals(RtcParameters.KEY_SESSION_MULTI_MODE_USER_ROLE)) {
c2 = 15;
break;
}
c2 = 65535;
break;
case -454296371:
if (str.equals(RtcParameters.KEY_SESSION_LIVE_MODE)) {
c2 = 22;
break;
}
c2 = 65535;
break;
case -334213656:
if (str.equals(RtcParameters.KEY_SERVER_LIVE_RECORD)) {
c2 = 31;
break;
}
c2 = 65535;
break;
case -161968216:
if (str.equals(RtcParameters.KEY_VIDEO_FRAME_FILTER_FORMAT)) {
c2 = 26;
break;
}
c2 = 65535;
break;
case -157773497:
if (str.equals(RtcParameters.KEY_AUDIO_CALL_PROXIMITY)) {
c2 = 11;
break;
}
c2 = 65535;
break;
case -137287658:
if (str.equals(RtcParameters.KEY_AUDIO_EFFECT_AUTOMATIC_GAIN_CONTROL)) {
c2 = 6;
break;
}
c2 = 65535;
break;
case -112917522:
if (str.equals(RtcParameters.KEY_VIDEO_MAX_BITRATE)) {
c2 = 21;
break;
}
c2 = 65535;
break;
case -70718756:
if (str.equals(RtcParameters.KEY_AUDIO_PLAYBACK_DEFAULT_SAMPLE_RATE)) {
c2 = '(';
break;
}
c2 = 65535;
break;
case 129341046:
if (str.equals(RtcParameters.KEY_SERVER_AUDIO_RECORD)) {
c2 = 7;
break;
}
c2 = 65535;
break;
case 237668859:
if (str.equals(RtcParameters.KEY_AUDIO_EXTERNAL_CAPTURE)) {
c2 = '$';
break;
}
c2 = 65535;
break;
case 337397166:
if (str.equals(RtcParameters.KEY_VIDEO_FRAME_FILTER)) {
c2 = 25;
break;
}
c2 = 65535;
break;
case 596167219:
if (str.equals(RtcParameters.KEY_AUDIO_FRAME_FILTER)) {
c2 = 27;
break;
}
c2 = 65535;
break;
case 760558347:
if (str.equals(RtcParameters.KEY_AUDIO_HIGH_QUALITY)) {
c2 = 30;
break;
}
c2 = 65535;
break;
case 955184389:
if (str.equals(RtcParameters.KEY_SESSION_LIVE_URL)) {
c2 = 23;
break;
}
c2 = 65535;
break;
case 1103225839:
if (str.equals(RtcParameters.KEY_SESSION_LIVE_COMPOSITING_LAYOUT)) {
c2 = 29;
break;
}
c2 = 65535;
break;
case 1285247325:
if (str.equals(RtcParameters.KEY_AUDIO_REPORT_SPEAKER)) {
c2 = 28;
break;
}
c2 = 65535;
break;
case 1568541233:
if (str.equals(RtcParameters.KEY_SERVER_VIDEO_RECORD)) {
c2 = '\b';
break;
}
c2 = 65535;
break;
case 1690177641:
if (str.equals(RtcParameters.KEY_VIDEO_SUPPORTED_HW_DECODER)) {
c2 = 3;
break;
}
c2 = 65535;
break;
case 1823452394:
if (str.equals(RtcParameters.KEY_AUDIO_EFFECT_ACOUSTIC_ECHO_CANCELER)) {
c2 = 4;
break;
}
c2 = 65535;
break;
case 1873378274:
if (str.equals(RtcParameters.KEY_VIDEO_DECODER_MODE)) {
c2 = 1;
break;
}
c2 = 65535;
break;
case 1882245767:
if (str.equals(RtcParameters.KEY_AUDIO_SPECIAL_CODEC)) {
c2 = '&';
break;
}
c2 = 65535;
break;
case 2022851605:
if (str.equals(RtcParameters.KEY_AUDIO_CAPTURE_DEFAULT_SAMPLE_RATE)) {
c2 = '\'';
break;
}
c2 = 65535;
break;
case 2061813685:
if (str.equals(RtcParameters.KEY_SERVER_RECORD_MODE)) {
c2 = '\n';
break;
}
c2 = 65535;
break;
case 2083380374:
if (str.equals(RtcParameters.KEY_VIDEO_FRAME_RATE)) {
c2 = 24;
break;
}
c2 = 65535;
break;
case 2099798764:
if (str.equals(RtcParameters.KEY_SDK_ENABLE_GPL)) {
c2 = '%';
break;
}
c2 = 65535;
break;
case 2138662542:
if (str.equals(RtcParameters.KEY_VIDEO_LOCAL_PREVIEW_MIRROR)) {
c2 = '\"';
break;
}
c2 = 65535;
break;
default:
c2 = 65535;
break;
}
switch (c2) {
case 0:
return this.y.get() == 3 ? this.n.j() ? "media_codec_hardware" : "media_codec_software" : l();
case 1:
return (this.y.get() != 3 || this.aC) ? m() : this.n.i(W()) ? "media_codec_hardware" : "media_codec_software";
case 2:
return Boolean.valueOf(com.netease.nrtc.video.a.e.d());
case 3:
return Boolean.valueOf(com.netease.nrtc.video.a.e.e());
case 4:
return n();
case 5:
return o();
case 6:
return p();
case 7:
return Boolean.valueOf(this.at);
case '\b':
return Boolean.valueOf(this.au);
case '\t':
return Boolean.valueOf(this.av);
case '\n':
return Integer.valueOf(this.aw);
case 11:
return Boolean.valueOf(this.ax);
case '\f':
com.netease.nrtc.video.a.a e2 = this.n.e(0);
return Integer.valueOf(this.n.m() ? com.netease.nrtc.video.a.e.a(e2.f11135a, e2.f11136b) : this.az);
case '\r':
com.netease.nrtc.video.a.a l2 = this.n.l();
return Integer.valueOf(this.n.m() ? com.netease.nrtc.video.a.e.a(l2.f11135a, l2.f11136b) : this.aA);
case 14:
return Boolean.valueOf(this.ay);
case 15:
return Integer.valueOf(this.aB);
case 16:
return Boolean.valueOf(this.aC);
case 17:
return Boolean.valueOf(this.aD);
case 18:
return Integer.valueOf(this.aE);
case 19:
if (this.aF) {
i2 = this.aE;
}
return Integer.valueOf(i2);
case 20:
return Integer.valueOf(this.aG);
case 21:
return Integer.valueOf(this.aR);
case 22:
return Boolean.valueOf(y());
case 23:
return this.aI;
case 24:
return Integer.valueOf(this.n.m() ? this.n.e(0).f11137c : this.aJ);
case 25:
return Boolean.valueOf(this.n.o());
case 26:
return Integer.valueOf(this.n.p());
case 27:
return Boolean.valueOf(this.j.u());
case 28:
return Boolean.valueOf(this.j.j());
case 29:
return this.aK;
case 30:
return Boolean.valueOf(this.aL);
case 31:
return Boolean.valueOf(this.aO);
case ' ':
return Integer.valueOf(this.aP);
case '!':
return Integer.valueOf(this.aQ);
case '\"':
return Boolean.valueOf(this.n.q());
case '#':
return Boolean.valueOf(this.n.r());
case '$':
return Boolean.valueOf(this.j.e());
case '%':
return Boolean.valueOf(C0373a.f10498g);
case '&':
return Integer.valueOf(this.aS);
case '\'':
return Integer.valueOf(AudioDeviceParameters.a());
case '(':
return Integer.valueOf(AudioDeviceParameters.b());
case ')':
return Boolean.valueOf(this.aY);
default:
Trace.e("RtcEngineImpl", "get parameter [" + str.toUpperCase() + "] unsupported!");
return null;
}
}
private void d() {
Trace.CreateTrace();
Trace.nativeSetTraceFilter(e());
if (!StringUtils.isEmpty(this.f10507c)) {
File file = new File(this.f10507c);
if (!file.exists()) {
file.mkdirs();
}
Trace.nativeSetTraceFile(new File(this.f10507c, "nrtc_sdk.log").getAbsolutePath(), false, (l.a(C0373a.f10493b) || l.a()) && l.c(C0373a.f10493b));
}
}
/* access modifiers changed from: private */
/* renamed from: d */
public synchronized void f(final long j2, final int i2) {
final RtcStats rtcStats;
Trace.i("RtcEngineImpl", "onUserLeave->" + j2 + " #" + i2);
if (this.y.get() != 3) {
Trace.i("RtcEngineImpl", "status not running");
return;
}
if (this.j != null) {
this.j.a(j2, (IRemoteAudioCallBack) null);
}
j(j2);
h(j2);
i(j2);
m(j2);
n(j2);
l(j2);
this.f10509e.remove(Long.valueOf(j2));
this.f10510f.remove(Long.valueOf(j2));
this.ad.remove(Long.valueOf(j2));
N();
Trace.i("RtcEngineImpl", "user remained->" + this.f10509e.size());
if (this.M != null) {
rtcStats = this.M.d(j2);
} else {
rtcStats = new RtcStats();
rtcStats.uid = j2;
rtcStats.duration = -1;
rtcStats.freezeSessionRate = -1;
}
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass8 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onUserLeave(j2, rtcStats, i2);
}
});
}
private void d(boolean z2) {
WifiInfo connectionInfo;
StringBuilder sb = new StringBuilder();
sb.append(z2 ? "acquire" : "release");
sb.append(" high performance wifi lock");
Trace.i("RtcEngineImpl", sb.toString());
if (z2) {
WifiManager wifiManager = (WifiManager) C0373a.f10493b.getSystemService("wifi");
if (wifiManager != null) {
this.w = wifiManager.createWifiLock(3, "com.netease.nrtc::wifiLock");
this.w.setReferenceCounted(false);
if (!this.w.isHeld() && (connectionInfo = wifiManager.getConnectionInfo()) != null) {
NetworkInfo.DetailedState detailedStateOf = WifiInfo.getDetailedStateOf(connectionInfo.getSupplicantState());
if (detailedStateOf == NetworkInfo.DetailedState.OBTAINING_IPADDR || detailedStateOf == NetworkInfo.DetailedState.CONNECTED) {
this.w.acquire();
return;
}
return;
}
return;
}
return;
}
WifiManager.WifiLock wifiLock = this.w;
if (wifiLock != null && wifiLock.isHeld()) {
this.w.release();
this.w = null;
}
}
private int e() {
boolean z2 = (l.a(C0373a.f10493b) || l.a()) && l.c(C0373a.f10493b);
if (!this.as || !z2) {
return z2 ? 2 : 5;
}
return 1;
}
private int e(long j2, int i2) {
return this.f10511g.c(j2, i2);
}
private void e(String str) {
if (!TextUtils.isEmpty(this.aI) && this.aI != str) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.ar);
}
this.aI = str;
if (this.y.get() == 3) {
this.f10511g.a(this.aI);
}
}
private void e(boolean z2) {
com.netease.nrtc.internal.b bVar = this.ai;
if (z2) {
bVar.d();
}
if (this.aC) {
this.aj = bVar.a();
this.ak = bVar.b();
this.al = bVar.c();
} else {
this.aj = true;
this.ak = true;
this.al = 0;
}
if (this.al != 0 && this.R == 3) {
this.al = 0;
Trace.w("RtcEngineImpl", -300000, " video qos strategy is screen sharing , only support PUBLISH_MODEL_SINGLE_STREAM");
}
}
private void f() throws RuntimeException {
this.f10511g = new NEMediaEngine(this);
this.j = new com.netease.nrtc.voice.b(C0373a.f10493b, this, this, c(this.f10507c));
this.n = new com.netease.nrtc.video.a.d(C0373a.f10493b, this, this);
this.f10512h = C0376d.a();
boolean b2 = this.f10511g.b();
Checker.traceFuncState(b2, "RtcEngineImpl", "net#init");
if (b2) {
com.netease.nrtc.monitor.e.a().b();
boolean a2 = this.j.a();
Checker.traceFuncState(a2, "RtcEngineImpl", "voe#create");
if (a2) {
com.netease.nrtc.video.a.d dVar = this.n;
if (dVar != null) {
Checker.traceFuncState(dVar.b(), "RtcEngineImpl", "vie#create");
return;
}
return;
}
throw new RuntimeException("voe create error");
}
throw new RuntimeException("net engine init error");
}
private void g() {
this.ah = EglContextWrapper.createEglContext();
if (!this.ah.isEGL14Supported() || Build.VERSION.SDK_INT < 17) {
updateSharedEGLContext((EGLContext) this.ah.getEglContext());
} else {
updateSharedEGLContext((android.opengl.EGLContext) this.ah.getEglContext());
}
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private void g(int i2) {
int i3 = 0;
if (i2 != 0) {
if (i2 == 1) {
i3 = 270;
} else if (i2 == 2) {
i3 = Opcodes.GETFIELD;
} else if (i2 == 3) {
i3 = 90;
}
}
int surfaceRotationToRealWorldRotation = (i3 + VideoUtils.surfaceRotationToRealWorldRotation(this.aG)) % 360;
if (surfaceRotationToRealWorldRotation != this.G) {
this.G = surfaceRotationToRealWorldRotation;
Trace.i("RtcEngineImpl", "orientationChanged -> " + this.G);
com.netease.nrtc.video.a.d dVar = this.n;
if (dVar != null) {
dVar.c(this.G);
}
}
VideoUtils.restDisplayRotationTime();
}
private void g(long j2) {
Trace.i("RtcEngineImpl", "startVoicePlayout ->" + j2);
RtcConfig rtcConfig = this.f10508d;
if (!(rtcConfig == null || rtcConfig.userId == j2)) {
if (j2 == -1) {
for (Long l2 : this.f10509e.keySet()) {
long longValue = l2.longValue();
if (longValue != this.f10508d.userId) {
try {
this.j.d(longValue);
this.j.a(longValue);
} catch (Exception e2) {
e2.printStackTrace();
}
}
}
this.j.g();
} else {
this.j.d(j2);
this.j.a(j2);
this.j.f(j2);
}
}
Trace.i("RtcEngineImpl", "startVoicePlayout done");
}
private void h() {
this.ac = AudioEffectLoader.a(this);
this.j.a(this.ac);
}
/* access modifiers changed from: private */
/* renamed from: h */
public void y(final int i2) {
Trace.i("RtcEngineImpl", "onDisconnectServer:" + i2);
if (this.y.get() != 3) {
Trace.i("RtcEngineImpl", "status not running");
return;
}
this.z.set(4);
Trace.d("Connect-Status-Test-Log", "status : " + this.z.get());
if (z() && i2 == 1 && u() && this.D.getAndIncrement() < 2) {
Trace.i("RtcEngineImpl", "disconnect server, login again!");
v();
}
if (i2 == 3 || i2 == 2) {
leaveChannel();
}
if (!this.C.get()) {
RtcConfig rtcConfig = this.f10508d;
if (rtcConfig != null) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.d.a(rtcConfig.userId, String.valueOf(i2)));
}
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass6 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onDisconnectServer(i2);
}
});
}
}
private void h(long j2) {
Trace.i("RtcEngineImpl", "stopVoiceReceiving ->" + j2);
if (this.f10508d.userId != j2) {
if (j2 == -1) {
for (Long l2 : this.f10509e.keySet()) {
long longValue = l2.longValue();
if (longValue != this.f10508d.userId) {
try {
this.j.b(longValue);
} catch (Exception e2) {
e2.printStackTrace();
}
}
}
} else {
this.j.b(j2);
}
}
Trace.i("RtcEngineImpl", "stopVoiceReceiving done");
}
private void i() {
this.ab.clear();
this.f10509e.clear();
this.f10510f.clear();
this.Q.set(-1);
this.ad.clear();
synchronized (this.ae) {
this.ae.clear();
}
this.af = false;
this.ag = false;
}
/* access modifiers changed from: private */
/* renamed from: i */
public void x(final int i2) {
Trace.i("RtcEngineImpl", "onProtocolIncompatible->" + i2);
if (this.y.get() != 3) {
Trace.i("RtcEngineImpl", "status not running");
} else {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass11 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onProtocolIncompatible(i2);
}
});
}
}
private void i(long j2) {
Trace.i("RtcEngineImpl", "deleteVoiceChannel ->" + j2);
if (this.f10508d.userId != j2) {
if (j2 == -1) {
for (Long l2 : this.f10509e.keySet()) {
long longValue = l2.longValue();
if (longValue != this.f10508d.userId) {
try {
if (this.M != null) {
this.M.c(longValue);
}
this.j.e(longValue);
} catch (Exception e2) {
e2.printStackTrace();
}
}
}
} else {
j jVar = this.M;
if (jVar != null) {
jVar.c(j2);
}
this.j.e(j2);
}
}
Trace.i("RtcEngineImpl", "deleteVoiceChannel done");
}
private void j() {
this.at = false;
this.au = false;
this.av = false;
this.aw = 0;
this.ax = true;
this.ay = true;
this.az = 0;
this.aA = 0;
this.aB = 1;
this.aC = false;
this.aD = false;
this.aE = 0;
this.aF = false;
this.aG = 0;
this.aH = false;
this.aI = null;
this.aJ = 15;
this.aK = null;
this.aL = true;
this.aM = false;
this.aN = false;
this.aO = false;
this.aP = 0;
this.aQ = 0;
this.aR = -1;
this.aS = -1;
this.aT = 4;
this.aU = 0;
this.aV = null;
this.as = false;
this.aY = false;
}
/* access modifiers changed from: private */
/* renamed from: j */
public void w(int i2) {
Trace.i("RtcEngineImpl", "onLiveEvent:" + i2);
IRtcEventHandler iRtcEventHandler = this.f10506b;
if (iRtcEventHandler != null) {
iRtcEventHandler.onLiveEvent(i2);
}
}
private void j(long j2) {
Trace.i("RtcEngineImpl", "stopVoicePlayout ->" + j2);
if (this.f10508d.userId != j2) {
if (j2 == -1) {
for (Long l2 : this.f10509e.keySet()) {
long longValue = l2.longValue();
if (longValue != this.f10508d.userId) {
this.j.g(longValue);
}
}
} else {
this.j.g(j2);
}
}
Trace.i("RtcEngineImpl", "stopVoicePlayout done");
}
/* access modifiers changed from: private */
public static int k(int i2) {
if (i2 == 1) {
return 3001;
}
if (i2 == 2) {
return 3002;
}
if (i2 == 3) {
return 3003;
}
if (i2 != 4) {
return i2 != 5 ? 0 : 3005;
}
return 3004;
}
private boolean k() {
return this.aC && this.aB == 1;
}
private boolean k(long j2) {
Trace.i("RtcEngineImpl", "startVideoReceive ->" + j2);
boolean z2 = true;
if (this.f10508d.userId == j2) {
z2 = false;
} else if (j2 == -1) {
for (j jVar : this.f10509e.values()) {
this.n.a(jVar.f10634a, n(Math.min(NEMediaEngine.a(), jVar.f10635b)));
this.n.a(jVar.f10634a, this.r, this.t, G());
this.n.b(jVar.f10634a, n(Math.min(NEMediaEngine.a(), jVar.f10635b)));
this.n.e(jVar.f10634a);
this.n.c(jVar.f10634a);
this.f10511g.g(jVar.f10634a);
}
} else {
j jVar2 = this.f10509e.get(Long.valueOf(j2));
if (jVar2 != null) {
this.n.a(jVar2.f10634a, n(Math.min(NEMediaEngine.a(), jVar2.f10635b)));
this.n.a(jVar2.f10634a, this.r, this.t, G());
this.n.b(jVar2.f10634a, n(Math.min(NEMediaEngine.a(), jVar2.f10635b)));
this.n.e(jVar2.f10634a);
this.n.c(jVar2.f10634a);
this.f10511g.g(jVar2.f10634a);
}
}
Trace.i("RtcEngineImpl", "startVideoReceive done");
return z2;
}
/* access modifiers changed from: private */
public static int l(int i2) {
if (i2 == 1) {
return 3101;
}
if (i2 != 2) {
return i2 != 4 ? 0 : 3104;
}
return 3102;
}
private String l() {
return !com.netease.nrtc.video.a.e.d() ? "media_codec_software" : com.netease.nrtc.video.a.e.b() ? "media_codec_hardware" : com.netease.nrtc.video.a.e.f() ? "media_codec_auto" : "media_codec_software";
}
private void l(long j2) {
Trace.i("RtcEngineImpl", "deleteVideoChannel ->" + j2);
if (j2 == -1) {
for (j jVar : this.f10509e.values()) {
this.n.b(jVar.f10634a);
}
} else {
this.n.b(j2);
}
Trace.i("RtcEngineImpl", "deleteVideoChannel done");
}
/* access modifiers changed from: private */
public static int m(int i2) {
if (i2 == 1) {
return 1001;
}
if (i2 == 2) {
return 1002;
}
if (i2 == 3) {
return 1003;
}
if (i2 == 4) {
return 1004;
}
if (i2 == 5) {
return 1005;
}
if (i2 != 10) {
return i2 != 11 ? 0 : 1111;
}
return 1110;
}
private String m() {
return !com.netease.nrtc.video.a.e.e() ? "media_codec_software" : com.netease.nrtc.video.a.e.c() ? "media_codec_hardware" : com.netease.nrtc.video.a.e.g() ? "media_codec_auto" : "media_codec_software";
}
private void m(long j2) {
Trace.i("RtcEngineImpl", "stopVideoRending(" + j2 + ") start");
if (j2 == -1) {
for (j jVar : this.f10509e.values()) {
this.n.d(jVar.f10634a);
}
} else {
this.n.d(j2);
}
Trace.i("RtcEngineImpl", "stopVideoRending(" + j2 + ") done");
}
private static int n(int i2) {
if (i2 == 12) {
return 1;
}
return i2 >= 13 ? 2 : 0;
}
private String n() {
return com.netease.nrtc.voice.a.a.d() ? !com.netease.nrtc.voice.a.a.a() ? "audio_effect_mode_platform_builtin_priority" : "audio_effect_mode_sdk_builtin_priority" : "audio_effect_mode_disable";
}
private void n(long j2) {
Trace.i("RtcEngineImpl", "stopVideoReceive(" + j2 + ") start");
if (j2 == -1) {
for (j jVar : this.f10509e.values()) {
this.f10511g.f(jVar.f10634a);
this.n.g(jVar.f10634a);
}
return;
}
this.f10511g.f(j2);
this.n.g(j2);
}
private static int o(int i2) {
if (i2 == 5) {
return 6;
}
if (i2 != 6) {
return i2;
}
return 5;
}
private int o(long j2) {
return this.f10511g.h(j2);
}
private String o() {
return com.netease.nrtc.voice.a.a.e() ? !com.netease.nrtc.voice.a.a.b() ? "audio_effect_mode_platform_builtin_priority" : "audio_effect_mode_sdk_builtin_priority" : "audio_effect_mode_disable";
}
private int p(int i2) {
if (this.al == 0 || i2 >= 4) {
return i2;
}
Trace.w("RtcEngineImpl", -300000, "resolution is too low , resolutionIndex : " + i2);
return 4;
}
private String p() {
return com.netease.nrtc.voice.a.a.f() ? !com.netease.nrtc.voice.a.a.c() ? "audio_effect_mode_platform_builtin_priority" : "audio_effect_mode_sdk_builtin_priority" : "audio_effect_mode_disable";
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private boolean p(long j2) {
C0374b bVar = this.ad.get(Long.valueOf(j2));
return bVar != null && bVar.c();
}
private void q() {
this.p = com.netease.nrtc.voice.a.a.i(this.aC);
this.q = com.netease.nrtc.video.a.e.a(this.aC);
Trace.i("RtcEngineImpl", "default audio codec=" + this.p + ", video codec=" + this.q);
this.t = false;
}
/* access modifiers changed from: private */
public /* synthetic */ void q(long j2) {
NEMediaEngine nEMediaEngine;
if (this.y.get() == 3 && (nEMediaEngine = this.f10511g) != null) {
nEMediaEngine.e(j2);
}
}
private boolean q(int i2) {
return (i2 == 0 || i2 == 1) ? false : true;
}
private int r() {
int a2 = com.netease.nrtc.video.a.e.a(C0373a.f10493b, this.aC);
int f2 = com.netease.nrtc.video.a.e.f(this.aC);
Trace.i("RtcEngineImpl", "default video encode res=" + a2 + ", video decode res=" + f2);
int b2 = com.netease.nrtc.video.a.e.b(this.az, a2);
int max = Math.max(f2, b2);
Trace.i("RtcEngineImpl", "user setting video encode res=" + b2 + ", video decode res=" + max);
int b3 = this.o.b(max);
StringBuilder sb = new StringBuilder();
sb.append("privilege video decode res=");
sb.append(b3);
Trace.i("RtcEngineImpl", sb.toString());
return b3;
}
/* access modifiers changed from: private */
/* renamed from: r */
public void u(int i2) {
Trace.i("RtcEngineImpl", "re login callback , reason : " + i2);
ThreadUtils.runOnThread(this.v, new x(this, i2));
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private com.netease.nrtc.monitor.statistics.e s(int i2) {
com.netease.nrtc.monitor.statistics.e eVar = this.T.get(i2);
if (eVar != null) {
return eVar;
}
com.netease.nrtc.monitor.statistics.e eVar2 = new com.netease.nrtc.monitor.statistics.e();
this.T.put(i2, eVar2);
return eVar2;
}
private void s() {
if (this.f10508d == null) {
m(-1L);
return;
}
for (j jVar : this.f10509e.values()) {
long j2 = jVar.f10634a;
if (j2 != this.f10508d.userId) {
this.n.d(j2);
}
}
}
/* access modifiers changed from: private */
public /* synthetic */ void t(int i2) {
this.f10506b.onReloginCallback(i2, this.f10508d);
}
private boolean t() {
if (u()) {
this.B.set(this.f10511g.a(w(), x()));
}
P();
if (this.f10511g != null) {
int i2 = 20;
int i3 = 32;
if (D()) {
i2 = 64;
} else if (this.aL) {
i2 = 48;
} else {
i3 = 8;
}
this.f10511g.a(i2, i3, 500, 300);
}
return this.B.get();
}
private boolean u() {
return !this.B.get() || !this.C.get();
}
/* access modifiers changed from: private */
public /* synthetic */ void v(int i2) {
if (this.y.get() == 3 && this.f10511g != null && this.S != i2) {
this.S = i2;
Q();
boolean c2 = new b.a(i2).c();
float f2 = c2 ? 0.75f : 0.5f;
int a2 = c2 ? com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.u, 200) : 85;
int i3 = (int) (((float) a2) * 1.0f * f2);
this.f10511g.b(i3, a2);
Trace.i("RtcEngineImpl", "overuse setEncodeUsageThresholdPercent->" + i3 + "," + a2);
}
}
private boolean v() {
if (this.y.get() == 3) {
if (u()) {
int incrementAndGet = this.D.incrementAndGet();
this.E.set(false);
this.C.set(this.f10511g.d());
if (this.C.get()) {
this.z.set(3);
Trace.d("Connect-Status-Test-Log", "status : " + this.z.get());
}
Trace.i("RtcEngineImpl", "try relogin, count=" + incrementAndGet);
} else {
this.E.set(true);
}
}
return this.C.get();
}
/* JADX WARNING: Removed duplicated region for block: B:44:0x00fa */
/* JADX WARNING: Removed duplicated region for block: B:45:0x00fc */
/* JADX WARNING: Removed duplicated region for block: B:48:0x0132 */
/* JADX WARNING: Removed duplicated region for block: B:51:0x0183 */
/* JADX WARNING: Removed duplicated region for block: B:52:0x0186 */
/* JADX WARNING: Removed duplicated region for block: B:55:0x01e0 */
/* JADX WARNING: Removed duplicated region for block: B:64:0x0221 */
/* JADX WARNING: Removed duplicated region for block: B:67:0x024d */
private NEMediaEngineConfig w() {
String str;
int i2;
RtcLiveCompositingLayout rtcLiveCompositingLayout;
if (com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.f10330e)) {
str = (String) com.netease.nrtc.b.a.b(com.netease.nrtc.b.c.f10330e);
} else {
StringBuilder sb = new StringBuilder();
List<String> list = this.f10508d.proxy;
if (list != null) {
for (String str2 : list) {
if (!StringUtils.isEmpty(str2)) {
if (sb.length() > 0) {
sb.append(",");
}
sb.append(str2);
}
}
}
str = sb.toString();
}
if (com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.f10329d)) {
ArrayList arrayList = new ArrayList();
ArrayList arrayList2 = new ArrayList();
arrayList2.add(com.netease.nrtc.b.a.b(com.netease.nrtc.b.c.f10329d));
arrayList.add(arrayList2);
this.f10508d.turn = arrayList;
}
StringBuilder sb2 = new StringBuilder();
for (List<String> list2 : this.f10508d.turn) {
if (sb2.length() > 0) {
sb2.append("#");
}
StringBuilder sb3 = new StringBuilder();
for (String str3 : list2) {
if (!StringUtils.isEmpty(str3)) {
if (sb3.length() > 0) {
sb3.append(",");
}
sb3.append(str3);
}
}
sb2.append(sb3.toString());
}
String b2 = com.netease.nrtc.utility.c.c.b(C0373a.f10493b);
boolean z2 = false;
if (StringUtils.isNotEmpty(b2) && b2.startsWith("460")) {
String substring = b2.substring(3);
if (StringUtils.isDigitsOnly(substring)) {
i2 = Integer.parseInt(substring);
NEMediaEngineConfig nEMediaEngineConfig = new NEMediaEngineConfig();
nEMediaEngineConfig.b((int) this.f10508d.userType);
nEMediaEngineConfig.m(this.f10508d.appKeyChannel);
nEMediaEngineConfig.d(!StringUtils.isEmpty(str) ? null : str);
nEMediaEngineConfig.e(sb2.toString());
nEMediaEngineConfig.a(!StringUtils.isEmpty(str));
nEMediaEngineConfig.a(this.f10508d.userId);
nEMediaEngineConfig.b(this.f10508d.channel);
nEMediaEngineConfig.b(this.f10508d.p2p);
nEMediaEngineConfig.i(this.f10508d.dTunnel);
if (this.f10508d.networkProxy != null) {
ClientSocks5Info clientSocks5Info = new ClientSocks5Info();
clientSocks5Info.a(this.f10508d.networkProxy.scheme);
clientSocks5Info.c(this.f10508d.networkProxy.userName);
clientSocks5Info.d(this.f10508d.networkProxy.userPassword);
clientSocks5Info.b(this.f10508d.networkProxy.host + ":" + this.f10508d.networkProxy.port);
nEMediaEngineConfig.j(true);
nEMediaEngineConfig.a(clientSocks5Info);
}
nEMediaEngineConfig.b(!StringUtils.isEmpty(this.f10507c) ? "" : this.f10507c);
nEMediaEngineConfig.a("nrtc_engine");
nEMediaEngineConfig.c(e());
nEMediaEngineConfig.f(this.q);
nEMediaEngineConfig.e(r());
nEMediaEngineConfig.d(this.p);
nEMediaEngineConfig.c(this.H);
nEMediaEngineConfig.d(k());
nEMediaEngineConfig.c(new String(this.f10508d.encryptToken));
nEMediaEngineConfig.a(this.f10508d.encrypt_type);
nEMediaEngineConfig.g(com.netease.nrtc.utility.c.c.a(C0373a.f10493b));
nEMediaEngineConfig.h(i2);
nEMediaEngineConfig.i(C0373a.k);
if (IRtcEngine.versionCode() >= 1011) {
nEMediaEngineConfig.j(A());
}
nEMediaEngineConfig.e(this.at);
nEMediaEngineConfig.f(this.au);
nEMediaEngineConfig.k(this.aw);
nEMediaEngineConfig.g(this.av);
nEMediaEngineConfig.h(this.aC);
nEMediaEngineConfig.m(!StringUtils.isEmpty(this.aI));
nEMediaEngineConfig.k(!this.aC && this.aH);
nEMediaEngineConfig.f(this.aI);
rtcLiveCompositingLayout = this.aK;
if (rtcLiveCompositingLayout != null) {
nEMediaEngineConfig.l(rtcLiveCompositingLayout.mode);
nEMediaEngineConfig.g(this.aK.extraInfo);
}
nEMediaEngineConfig.l(this.aO);
nEMediaEngineConfig.o(this.aL);
nEMediaEngineConfig.n(this.U);
nEMediaEngineConfig.n(false);
nEMediaEngineConfig.e(sb2.toString());
nEMediaEngineConfig.d(str);
if (this.aa == 1) {
z2 = true;
}
nEMediaEngineConfig.p(z2);
nEMediaEngineConfig.r(C0373a.f10499h);
nEMediaEngineConfig.q(C0373a.f10499h);
nEMediaEngineConfig.o(((Integer) com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.ae, (Object) 80)).intValue());
nEMediaEngineConfig.p(((Integer) com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.af, (Object) 120)).intValue());
nEMediaEngineConfig.q(((Integer) com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.ag, (Object) 400)).intValue());
nEMediaEngineConfig.r(((Integer) com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.ah, (Object) 1)).intValue());
nEMediaEngineConfig.s(this.aW);
nEMediaEngineConfig.t(this.aX);
nEMediaEngineConfig.s(this.ar);
nEMediaEngineConfig.a(this.f10508d.reproxy);
return nEMediaEngineConfig;
}
}
i2 = 0;
NEMediaEngineConfig nEMediaEngineConfig2 = new NEMediaEngineConfig();
nEMediaEngineConfig2.b((int) this.f10508d.userType);
nEMediaEngineConfig2.m(this.f10508d.appKeyChannel);
nEMediaEngineConfig2.d(!StringUtils.isEmpty(str) ? null : str);
nEMediaEngineConfig2.e(sb2.toString());
nEMediaEngineConfig2.a(!StringUtils.isEmpty(str));
nEMediaEngineConfig2.a(this.f10508d.userId);
nEMediaEngineConfig2.b(this.f10508d.channel);
nEMediaEngineConfig2.b(this.f10508d.p2p);
nEMediaEngineConfig2.i(this.f10508d.dTunnel);
if (this.f10508d.networkProxy != null) {
}
nEMediaEngineConfig2.b(!StringUtils.isEmpty(this.f10507c) ? "" : this.f10507c);
nEMediaEngineConfig2.a("nrtc_engine");
nEMediaEngineConfig2.c(e());
nEMediaEngineConfig2.f(this.q);
nEMediaEngineConfig2.e(r());
nEMediaEngineConfig2.d(this.p);
nEMediaEngineConfig2.c(this.H);
nEMediaEngineConfig2.d(k());
nEMediaEngineConfig2.c(new String(this.f10508d.encryptToken));
nEMediaEngineConfig2.a(this.f10508d.encrypt_type);
nEMediaEngineConfig2.g(com.netease.nrtc.utility.c.c.a(C0373a.f10493b));
nEMediaEngineConfig2.h(i2);
nEMediaEngineConfig2.i(C0373a.k);
if (IRtcEngine.versionCode() >= 1011) {
}
nEMediaEngineConfig2.e(this.at);
nEMediaEngineConfig2.f(this.au);
nEMediaEngineConfig2.k(this.aw);
nEMediaEngineConfig2.g(this.av);
nEMediaEngineConfig2.h(this.aC);
nEMediaEngineConfig2.m(!StringUtils.isEmpty(this.aI));
nEMediaEngineConfig2.k(!this.aC && this.aH);
nEMediaEngineConfig2.f(this.aI);
rtcLiveCompositingLayout = this.aK;
if (rtcLiveCompositingLayout != null) {
}
nEMediaEngineConfig2.l(this.aO);
nEMediaEngineConfig2.o(this.aL);
nEMediaEngineConfig2.n(this.U);
nEMediaEngineConfig2.n(false);
nEMediaEngineConfig2.e(sb2.toString());
nEMediaEngineConfig2.d(str);
if (this.aa == 1) {
}
nEMediaEngineConfig2.p(z2);
nEMediaEngineConfig2.r(C0373a.f10499h);
nEMediaEngineConfig2.q(C0373a.f10499h);
nEMediaEngineConfig2.o(((Integer) com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.ae, (Object) 80)).intValue());
nEMediaEngineConfig2.p(((Integer) com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.af, (Object) 120)).intValue());
nEMediaEngineConfig2.q(((Integer) com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.ag, (Object) 400)).intValue());
nEMediaEngineConfig2.r(((Integer) com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.ah, (Object) 1)).intValue());
nEMediaEngineConfig2.s(this.aW);
nEMediaEngineConfig2.t(this.aX);
nEMediaEngineConfig2.s(this.ar);
nEMediaEngineConfig2.a(this.f10508d.reproxy);
return nEMediaEngineConfig2;
}
private LoginExtraConfig x() {
LoginExtraConfig loginExtraConfig = new LoginExtraConfig();
loginExtraConfig.a(this.aU);
loginExtraConfig.a(this.aV);
Trace.d("RtcEngineImpl", "encrypt , type : " + loginExtraConfig.getEncryptType() + " , key : " + loginExtraConfig.getEncryptKey());
return loginExtraConfig;
}
private boolean y() {
return z() && this.aH;
}
private boolean z() {
return this.aC;
}
@Override // com.netease.nrtc.engine.impl.k
public int a(long j2, WrappedNativeAudioFrame wrappedNativeAudioFrame) {
NEMediaEngine nEMediaEngine = this.f10511g;
return (nEMediaEngine == null || nEMediaEngine.a(wrappedNativeAudioFrame)) ? 0 : -1;
}
@Override // com.netease.nrtc.engine.impl.k
public WrappedNativeAudioFrame a(long j2, int i2) {
RtcConfig rtcConfig;
NEMediaEngine nEMediaEngine = this.f10511g;
if (nEMediaEngine != null) {
WrappedNativeAudioFrame a2 = nEMediaEngine.a(j2, i2);
if (a2 != null && a2.a() && com.netease.nrtc.c.a.a().a(j2, 0) && (rtcConfig = this.f10508d) != null) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.l.a(rtcConfig.channel, j2, 0));
}
return a2;
}
Trace.e("RtcEngineImpl", "get audio err , mNEMediaEngine is null");
return null;
}
@Override // com.netease.nrtc.video.a.c
public void a() {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass20 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onVideoCapturerStopped();
}
});
}
@Override // com.netease.nrtc.video.a.c
public void a(int i2) {
Trace.i("RtcEngineImpl", "onVideoSenderCodecChanged->" + i2);
ThreadUtils.runOnUiThread(new z(this, i2));
}
@Override // com.netease.nrtc.voice.a
public void a(final int i2, final int i3) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass27 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onAudioEffectPreload(i2, i3);
}
});
}
@Override // com.netease.nrtc.voice.device.b.e.a
public void a(int i2, int i3, Set<Integer> set, boolean z2) {
b(i2, i3, set, z2);
}
@Override // com.netease.nrtc.voice.a
public void a(final int i2, final String str) {
Trace.i("RtcEngineImpl", "onAudioDeviceEvent->" + i2 + "#" + str);
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass22 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onDeviceEvent(e.k(i2), str);
}
});
}
@Override // com.netease.nrtc.voice.a
public void a(final int i2, long[] jArr, int[] iArr, final int i3) {
if (jArr.length >= i2 && iArr.length >= i2) {
long[] jArr2 = this.k;
if (jArr2 == null || this.l == null || jArr2.length < i2) {
this.k = new long[i2];
this.l = new int[i2];
}
for (int i4 = 0; i4 < i2; i4++) {
long j2 = jArr[i4];
int i5 = iArr[i4];
if (j2 == 0) {
j2 = this.f10508d.userId;
}
this.k[i4] = j2;
this.l[i4] = i5;
}
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass24 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onReportSpeaker(i2, e.this.k, e.this.l, i3);
}
});
}
}
@Override // com.netease.nrtc.rec.a.AbstractC0109a
public void a(final long j2) {
Trace.e("RtcEngineImpl", "onLowStorageSpaceWarning ->" + j2);
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass34 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onLowStorageSpaceWarning(j2);
}
});
if (j2 < 10485760) {
this.f10512h.a();
}
}
@Override // com.netease.nrtc.video.a.c
public void a(final long j2, final int i2, final int i3, final int i4) {
Trace.i("RtcEngineImpl", "onFrameResolutionChanged->" + j2 + "#" + i2 + GroupChatInvitation.ELEMENT_NAME + i3 + ":" + i4);
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass17 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onVideoFrameResolutionChanged(j2, i2, i3, i4);
}
});
}
@Override // com.netease.nrtc.video.a.c
public void a(long j2, final int i2, final String str) {
com.netease.nrtc.c.g.a aVar;
Trace.i("RtcEngineImpl", "onVideoDeviceEvent->" + j2 + "#" + i2 + "#" + str);
if (i2 == 5) {
aVar = new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.f10412h, true);
} else if (i2 == 4) {
aVar = new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.f10412h, false);
} else {
if (i2 == 10 || i2 == 11) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.ai);
}
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass14 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onDeviceEvent(e.m(i2), str);
}
});
}
com.netease.nrtc.c.a(aVar);
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass14 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onDeviceEvent(e.m(i2), str);
}
});
}
@Override // com.netease.nrtc.rec.a.AbstractC0109a
public void a(long j2, final String str) {
final long j3 = j2 == 0 ? this.f10508d.userId : j2;
Trace.i("RtcEngineImpl", "onAVRecordingStart ->" + j2);
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass39 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onAVRecordingStart(j3, str);
}
});
}
@Override // com.netease.nrtc.video.a.c
public void a(final long j2, final boolean z2, final String str) {
Trace.i("RtcEngineImpl", "onSnapshot->" + j2 + "#" + z2);
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass18 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onTakeSnapshotResult(j2, z2, str);
}
});
}
@Override // com.netease.nrtc.voice.a
public void a(AudioMixing audioMixing) {
final long j2 = -1;
final long currentMs = audioMixing == null ? -1 : audioMixing.getCurrentMs();
if (audioMixing != null) {
j2 = audioMixing.getDurationMs();
}
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass26 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onAudioMixingProgressUpdated(currentMs, j2);
}
});
}
@Override // com.netease.nrtc.rec.a.AbstractC0109a
public void a(final String str) {
Trace.i("RtcEngineImpl", "onAudioRecordingStart");
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass40 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onAudioRecordingStart(str);
}
});
}
@Override // com.netease.nrtc.video.a.c
public void a(final boolean z2) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass19 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onVideoCapturerStarted(z2);
}
});
}
@Override // com.netease.nrtc.utility.a.c.a
public void a(boolean z2, boolean z3, boolean z4, int i2) {
if (this.y.get() == 3 && z4 && !com.netease.nrtc.utility.a.a(i2)) {
Size c2 = com.netease.nrtc.utility.a.c.a().c(i2);
int a2 = this.f10511g.a(new PublishVideoProfile(i2, c2.getWidth(), c2.getHeight(), this.aJ), com.netease.nrtc.utility.c.c.a(C0373a.f10493b));
com.netease.nrtc.utility.a.c.a().b(a2 * 1000, i2);
Trace.i("RtcEngineImpl", "onChange : video bitrate : " + a2 + " , type:" + i2 + " , w : " + c2.getWidth() + " , h : " + c2.getHeight() + " , r : " + this.aJ);
}
}
@Override // com.netease.nrtc.engine.impl.k
public void a(byte[] bArr, int i2, int i3, int i4, int i5, int i6) {
if (this.f10511g != null) {
if (!this.an.onReceiveVideo(bArr, i2, i3, i4)) {
this.f10511g.a(bArr, i2, i3, i4, i5, i6);
}
j jVar = this.M;
if (jVar != null) {
jVar.h().a(i3, (long) i2);
}
com.netease.nrtc.video.a aVar = this.aq;
if (aVar != null) {
aVar.a(i3, i2);
}
}
}
@Override // com.netease.nrtc.rec.a.b
public boolean a(long j2, long j3) {
if (!this.j.a(j2, j3)) {
return false;
}
if (this.r != 5 || this.n.a(j2, j3)) {
return true;
}
this.j.a(j2, 0);
return false;
}
@Override // com.netease.nrtc.voice.a
public boolean a(AudioFrame audioFrame) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.l);
IRtcEventHandler iRtcEventHandler = this.f10506b;
return iRtcEventHandler == null || iRtcEventHandler.onAudioFrameFilter(audioFrame);
}
@Override // com.netease.nrtc.video.a.c
public boolean a(VideoFrame videoFrame, boolean z2) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.m);
IRtcEventHandler iRtcEventHandler = this.f10506b;
if (iRtcEventHandler != null) {
return iRtcEventHandler.onVideoFrameFilter(videoFrame, z2);
}
return false;
}
@Override // com.netease.nrtc.video.a.c
public boolean a(com.netease.nrtc.sdk.video.VideoFrame videoFrame, com.netease.nrtc.sdk.video.VideoFrame[] videoFrameArr, VideoFilterParameter videoFilterParameter) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.m);
IRtcEventHandler iRtcEventHandler = this.f10506b;
if (iRtcEventHandler != null) {
return iRtcEventHandler.onVideoFrameFilter(videoFrame, videoFrameArr, videoFilterParameter);
}
return false;
}
@Override // com.netease.nrtc.utility.c.b.c
public void b(final int i2) {
Trace.i("RtcEngineImpl", "onConnectionTypeChanged (" + i2 + ")");
this.am = i2;
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass21 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onConnectionTypeChanged(i2);
}
});
if (this.f10508d != null && i2 != 70) {
if (this.y.get() == 3) {
this.f10511g.a(i2);
}
v();
}
}
@Override // com.netease.nrtc.voice.a
public void b(final int i2, final int i3) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass28 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onAudioEffectPlayEvent(i2, i3);
}
});
}
@Override // com.netease.nrtc.video.a.c
public void b(long j2, int i2) {
ThreadUtils.runOnThread(this.v, new A(this, i2, j2));
}
@Override // com.netease.nrtc.rec.a.AbstractC0109a
public void b(long j2, final String str) {
final long j3 = j2 == 0 ? this.f10508d.userId : j2;
Trace.i("RtcEngineImpl", "onAVRecordingCompletion ->" + j2);
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass41 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onAVRecordingCompletion(j3, str);
}
});
}
@Override // com.netease.nrtc.rec.a.AbstractC0109a
public void b(final String str) {
Trace.i("RtcEngineImpl", "onAudioRecordingCompletion");
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass42 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onAudioRecordingCompletion(str);
}
});
}
@Override // com.netease.nrtc.rec.a.b
public boolean b(long j2) {
com.netease.nrtc.voice.b bVar = this.j;
boolean z2 = true;
if (!this.aC || this.aB != 1) {
z2 = false;
}
return bVar.a(j2, z2);
}
@Override // com.netease.nrtc.voice.a
public void c(final int i2) {
Trace.i("RtcEngineImpl", "onAudioMixingEvent->" + i2);
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass25 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onAudioMixingEvent(e.l(i2));
}
});
}
@Override // com.netease.nrtc.video.a.c
public void c(final long j2) {
Trace.i("RtcEngineImpl", "onFirstVideoFrameAvailable->" + j2);
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass13 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onFirstVideoFrameAvailable(j2);
}
});
}
@Override // com.netease.nrtc.video.a.c
public void c(final long j2, final int i2) {
if (this.aD) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass15 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onVideoFpsReported(j2, i2);
}
});
}
}
@Override // com.netease.nrtc.video.a.c
public void d(long j2) {
ThreadUtils.runOnThread(this.v, new l(this, j2));
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int disableVideo() {
int i2;
Trace.i("RtcEngineImpl", "disable video");
i2 = 0;
if (this.H) {
this.H = false;
if (this.y.get() == 3) {
K();
}
I();
} else {
Trace.i("RtcEngineImpl", "video is already disabled");
}
if (!this.H) {
this.F.b();
}
if (this.H) {
i2 = -1;
}
return i2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int dispose() throws IllegalStateException {
Trace.i("RtcEngineImpl", "dispose");
if (this.y.get() == 3) {
Trace.w("RtcEngineImpl", "dispose warning: need leave channel!");
leaveChannel();
}
if (this.ah != null) {
this.ah.release();
}
this.ac.a();
com.netease.nrtc.monitor.e.a().c();
this.f10511g.c();
this.j.b();
this.n.a();
if (this.M != null) {
this.M.b();
}
if (this.aq != null) {
this.aq.b();
}
this.m.a();
com.netease.nrtc.utility.c.b.a().b(this);
com.netease.nrtc.c.a.a().d();
b(false);
com.netease.nrtc.profile.a.a().b();
this.j = null;
this.n = null;
this.m = null;
this.f10512h = null;
this.F.b();
this.F = null;
this.f10506b = null;
com.netease.nrtc.utility.j.d();
com.netease.nrtc.b.a.b();
this.O.a();
com.netease.nrtc.monitor.d.a();
String c2 = c(this.f10507c);
if (FileUtils.isNotEmpty(c2)) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.e.a(this.f10508d != null ? this.f10508d.channel : 0, c2));
}
this.z.set(0);
Trace.d("Connect-Status-Test-Log", "status : " + this.z.get());
com.netease.nrtc.c.a();
Trace.i("RtcEngineImpl", "dispose done");
Trace.ReturnTrace();
return 0;
}
@Override // com.netease.nrtc.video.a.c
public void e(long j2) {
Trace.i("RtcEngineImpl", "onFirstFramePkgReceived->" + j2);
RtcConfig rtcConfig = this.f10508d;
if (rtcConfig != null) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.l.c(String.valueOf(rtcConfig.channel), String.valueOf(j2), 1));
}
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int enableVideo() {
if (!this.H) {
this.H = true;
if (this.y.get() == 3) {
J();
}
I();
} else {
Trace.i("RtcEngineImpl", "video is already enabled");
}
if (this.H && !this.aF) {
this.F.a();
}
Trace.i("RtcEngineImpl", "enable video : " + this.H);
return this.H ? 0 : -2;
}
@Override // com.netease.nrtc.video.a.c
public void f(final long j2) {
Trace.i("RtcEngineImpl", "onFirstFrameRendered->" + j2);
RtcConfig rtcConfig = this.f10508d;
if (!(rtcConfig == null || rtcConfig.userId == j2 || !com.netease.nrtc.c.a.a().a(j2, 1))) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.l.a(this.f10508d.channel, j2, 1));
}
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass16 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onFirstVideoFrameRendered(j2);
}
});
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public int getConnectStatus() {
return this.z.get();
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized RtcParameters getParameters(RtcParameters rtcParameters) {
RtcParameters rtcParameters2;
rtcParameters2 = new RtcParameters();
ArrayList<String> arrayList = new ArrayList();
Privilege privilege = l.c(C0373a.f10493b) ? Privilege.PROTECTED : Privilege.PUBLIC;
arrayList.addAll(rtcParameters == null ? RtcParameters.getReadableKeys(privilege) : RtcParameters.getReadableKeys(rtcParameters.keys(), privilege));
for (String str : arrayList) {
Object d2 = d(str);
if (d2 != null) {
try {
rtcParameters2.setObject(str, d2);
} catch (Exception e2) {
e2.printStackTrace();
}
} else {
rtcParameters2.removeParameters(str);
}
}
return rtcParameters2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int getRole() {
return this.aB;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized boolean isAutoPublishVideo() {
return this.aj;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized boolean isAutoSubscribeAudio() {
return this.ak;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized boolean isAutoSubscribeVideo() {
return this.ak;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized boolean isMicrophoneMute() {
return this.j.v();
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized boolean isSpeakerphoneOn() {
return this.m.b() == 0;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int joinChannel(RtcConfig rtcConfig, long j2) throws RuntimeException {
int i2;
Trace.i("RtcEngineImpl", "joinChannel");
Checker.checkNotNull(rtcConfig, "join channel error [config is null]");
if (!this.y.compareAndSet(1, 2)) {
Trace.e("RtcEngineImpl", "joinChannel error (status not stop)");
i2 = -1;
} else {
this.z.set(1);
Trace.d("Connect-Status-Test-Log", "status : " + this.z.get());
com.netease.nrtc.c.a(MD5.md5(rtcConfig.channel + ":" + rtcConfig.userId + System.currentTimeMillis()));
com.netease.nrtc.b.a.a(rtcConfig.grayReleased, C0373a.j);
f fVar = rtcConfig.logTrace;
if (fVar != null && fVar.a()) {
this.O.a(fVar);
}
int i3 = 0;
this.j.i(com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.an, 0));
this.j.j(com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.ap, 0));
if (!this.j.a(this.aL)) {
Trace.e("RtcEngineImpl", "joinChannel error (voe init error)");
this.z.set(0);
Trace.d("Connect-Status-Test-Log", "status : " + this.z.get());
i2 = -2;
} else {
i();
a(rtcConfig);
if (this.M != null) {
this.M.c();
}
this.N.a();
boolean t2 = t();
if (t2) {
this.y.set(3);
if (this.M != null) {
this.M.a();
}
com.netease.nrtc.utility.a.c.a().a(C0373a.f10493b);
com.netease.nrtc.utility.a.c.a().a((c.a) this, true);
com.netease.nrtc.utility.c.b.a().a(C0373a.f10493b);
if (!com.netease.nrtc.profile.a.a().c()) {
com.netease.nrtc.profile.a.a().a(this.aY);
com.netease.nrtc.profile.a.b().a(String.valueOf(rtcConfig.channel));
com.netease.nrtc.profile.a.b().a(this.aW);
com.netease.nrtc.profile.a.b().b(C0373a.s);
com.netease.nrtc.b.b a2 = com.netease.nrtc.b.a.a();
com.netease.nrtc.profile.a.b().e(a2 != null ? a2.h() : "");
com.netease.nrtc.profile.a.a().a();
}
if (y()) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.f10781c, this.aK == null ? 0 : this.aK.mode + 1);
} else {
com.netease.nrtc.monitor.d.a(z() ? com.netease.nrtc.monitor.d.f10780b : com.netease.nrtc.monitor.d.f10779a);
}
} else {
this.y.set(1);
this.z.set(0);
Trace.d("Connect-Status-Test-Log", "status : " + this.z.get());
}
this.N.a(j2);
boolean a3 = com.netease.nrtc.b.a.a(com.netease.nrtc.b.c.ai, false);
i.a(C0373a.f10493b, a3);
Trace.i("RtcEngineImpl", "enableCrashCatch from config: " + a3);
StringBuilder sb = new StringBuilder();
sb.append("joinChannel (");
sb.append(t2 ? "ok" : "failed");
sb.append(")");
Trace.i("RtcEngineImpl", sb.toString());
if (!t2) {
i3 = -5;
}
return i3;
}
}
return i2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int leaveChannel() {
Trace.i("RtcEngineImpl", "leaveChannel");
this.B.set(false);
this.C.set(false);
this.E.set(false);
this.D.set(0);
if (!this.y.compareAndSet(3, 4)) {
Trace.e("RtcEngineImpl", "leaveChannel error (status not running)");
return -1;
}
if (this.A.getAndSet(false)) {
this.j.d();
this.f10511g.a(this.f10508d.channel, this.f10508d.userId);
T();
}
ThreadUtils.removeRunnableOnThreadWithToken(this.v, e.a.class);
if (this.M != null) {
this.M.b();
}
com.netease.nrtc.utility.a.c.a().a((c.a) this, false);
com.netease.nrtc.utility.a.c.a().b();
com.netease.nrtc.utility.c.b.a().b();
H();
s();
n(-1L);
l(-1L);
E();
B();
h(-1L);
i(-1L);
this.f10512h.a();
this.m.a();
if (this.M != null) {
VoiceRxStatistics f2 = this.M.f();
a(f2.freezeSessionRate, f2.gapPacketCount, f2.outOfDatePacketCount);
} else {
a(0, 0, 0);
}
this.y.set(1);
e(true);
this.an.release();
Trace.i("RtcEngineImpl", "leaveChannel done");
return 0;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized boolean localAudioStreamMuted() {
return this.j.i();
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized boolean localVideoStreamMuted() {
return this.aM;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int muteLocalAudioStream(boolean z2) {
int i2;
if (k()) {
Trace.i("RtcEngineImpl", "audience unsupported muteLocalAudioStream");
i2 = -1;
} else {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.f10783e);
com.netease.nrtc.c.a(new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.f10406b, z2));
this.j.c(z2);
this.aN = z2;
i2 = 0;
}
return i2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int muteLocalVideoStream(boolean z2) {
int i2;
Trace.i("RtcEngineImpl", "muteLocalVideoStream: " + z2);
if (k()) {
Trace.i("RtcEngineImpl", "audience, unsupported muteLocalVideoStream");
i2 = -1;
} else {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.aj);
this.aM = z2;
if (this.A.get()) {
if (z2) {
this.n.d();
} else {
this.n.c();
}
}
i2 = 0;
}
return i2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int muteRemoteAudioStream(long j2, boolean z2) {
if (!this.A.get()) {
Trace.i("RtcEngineImpl", "muteRemoteAudioStream before call established. channel:" + j2 + ", mute:" + z2);
return -700;
}
int i2 = (j2 > -1 ? 1 : (j2 == -1 ? 0 : -1));
if (i2 == 0) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.X);
com.netease.nrtc.c.a(new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.f10411g, z2));
} else {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.ak);
}
if (!this.A.get()) {
Trace.i("RtcEngineImpl", "muteRemoteAudioStream before call established. channel:" + j2 + ", mute:" + z2);
return -700;
}
if (z2) {
if (!remoteAudioStreamMuted(j2)) {
j(j2);
}
} else if (i2 == 0 || remoteAudioStreamMuted(j2)) {
g(j2);
}
return 0;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int muteRemoteVideoStream(long j2, boolean z2) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.al);
Trace.i("RtcEngineImpl", "muteRemoteVideoStream: " + j2 + "#" + z2);
if (z2) {
if (!remoteVideoStreamMuted(j2)) {
n(j2);
}
} else if (remoteVideoStreamMuted(j2)) {
k(j2);
}
return 0;
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onConnected(ConnectInfo connectInfo) {
ThreadUtils.runOnUiThread(new q(this, connectInfo));
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onForceIdrFrame(long j2, int i2) {
if (this.A.get()) {
this.n.b(i2);
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onLiveEvent(int i2) {
ThreadUtils.runOnUiThread(new r(this, i2));
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onLogin(LoginResInfo loginResInfo) {
ThreadUtils.runOnUiThread(new u(this, loginResInfo));
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onLogoutFinished() {
ThreadUtils.runOnUiThread(new t(this));
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onNetQualityChange(long j2, int i2, NetStatInfo netStatInfo) {
ThreadUtils.runOnUiThread(new D(this, j2, i2, netStatInfo));
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onP2PState(int i2) {
Trace.i("RtcEngineImpl", "onP2PState->" + i2);
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onPeerDisconnected() {
Trace.i("RtcEngineImpl", "onPeerDisconnected");
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onPeerNetTypeChange(int i2) {
Trace.i("RtcEngineImpl", "onPeerNetTypeChange->" + com.netease.nrtc.internal.a.b(i2));
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onPeopleJoined(long j2, PeopleJoinInfo peopleJoinInfo) {
ThreadUtils.runOnUiThread(new n(this, j2, peopleJoinInfo));
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onPeopleLeft(long j2, int i2) {
ThreadUtils.runOnUiThread(new y(this, j2, i2));
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onProtocolIncompatible(int i2) {
ThreadUtils.runOnUiThread(new C(this, i2));
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onPublicIpChange(String str, boolean z2) {
ThreadUtils.runOnUiThread(new o(this, str, z2));
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onPublishVideoResult(Map<Integer, PublishVideoProfile> map, final int i2) {
synchronized (this.ae) {
for (RemoteSubscribeLocalInfo remoteSubscribeLocalInfo : this.ae) {
if (map.get(Integer.valueOf(remoteSubscribeLocalInfo.a())) != null) {
this.n.a(true, remoteSubscribeLocalInfo.a());
}
}
}
if (this.aC) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass30 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onPublishVideoResult(i2);
}
});
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onReLogin(LoginResInfo loginResInfo) {
ThreadUtils.runOnUiThread(new p(this, loginResInfo));
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onReceiveVideo(byte[] bArr, long j2, int i2, int i3, int i4, boolean z2) {
if (this.A.get()) {
this.n.a(j2, i2, bArr, i3, z2);
j jVar = this.M;
if (jVar != null) {
jVar.h().b(j2, (long) i3);
}
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onReceivedAudioSignal(long j2, long j3, long j4, long j5, long j6, long j7, long j8) {
RtcConfig rtcConfig;
if (this.A.get()) {
j jVar = this.M;
if (jVar != null) {
jVar.h().a(j2, j4);
}
if (com.netease.nrtc.c.a.a().b(j2, 0) && (rtcConfig = this.f10508d) != null) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.l.c(String.valueOf(rtcConfig.channel), String.valueOf(j2), 0));
}
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onReloginCallback(int i2) {
ThreadUtils.runOnUiThread(new w(this, i2));
}
/* JADX WARNING: Removed duplicated region for block: B:18:0x006b */
/* JADX WARNING: Removed duplicated region for block: B:21:0x00a1 A[RETURN] */
/* JADX WARNING: Removed duplicated region for block: B:22:0x00a2 */
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onRemotePublishVideo(final long j2, ArrayList<Integer> arrayList) {
int i2;
if (com.netease.nrtc.utility.a.a(arrayList)) {
Trace.i("RtcEngineImpl", -300000, "remote publish video ， but type list is empty ");
return;
}
final int[] iArr = new int[arrayList.size()];
int[] iArr2 = new int[arrayList.size()];
for (int i3 = 0; i3 < arrayList.size(); i3++) {
int intValue = arrayList.get(i3).intValue();
iArr[i3] = intValue;
iArr2[i3] = intValue;
}
a(true, j2, true, iArr2, false, -1);
if (this.H) {
if (this.ak) {
i2 = a(iArr2);
} else {
C0374b bVar = this.ad.get(Long.valueOf(j2));
if (bVar != null) {
i2 = bVar.b();
}
}
if (i2 != -1) {
int e2 = e(j2, i2);
Trace.i("RtcEngineImpl", -300000, "remote publish video ， so subscribe , result : " + e2 + " , uid : " + j2 + " ,auto :" + this.ak + " ,type : " + i2);
}
if (!this.aC) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass36 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onRemotePublishVideo(j2, iArr);
}
});
return;
}
return;
}
i2 = -1;
if (i2 != -1) {
}
if (!this.aC) {
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onRemoteSubscribeCallback(ArrayList<RemoteSubscribeLocalInfo> arrayList) {
ArrayList arrayList2 = new ArrayList(arrayList);
ArrayList arrayList3 = new ArrayList();
synchronized (this.ae) {
for (RemoteSubscribeLocalInfo remoteSubscribeLocalInfo : this.ae) {
if (arrayList.contains(remoteSubscribeLocalInfo)) {
arrayList2.remove(remoteSubscribeLocalInfo);
} else {
arrayList3.add(remoteSubscribeLocalInfo);
}
}
this.ae.clear();
this.ae.addAll(arrayList);
}
Iterator it2 = arrayList2.iterator();
while (it2.hasNext()) {
RemoteSubscribeLocalInfo remoteSubscribeLocalInfo2 = (RemoteSubscribeLocalInfo) it2.next();
if (com.netease.nrtc.utility.a.a(remoteSubscribeLocalInfo2.a())) {
Trace.e("RtcEngineImpl", -300000, "onRemoteSubscribeCallback ，newSubTypeList ,type is invalid , " + remoteSubscribeLocalInfo2);
} else {
this.n.a(true, remoteSubscribeLocalInfo2.a());
}
}
Iterator it3 = arrayList3.iterator();
while (it3.hasNext()) {
RemoteSubscribeLocalInfo remoteSubscribeLocalInfo3 = (RemoteSubscribeLocalInfo) it3.next();
if (com.netease.nrtc.utility.a.a(remoteSubscribeLocalInfo3.a())) {
Trace.e("RtcEngineImpl", -300000, "onRemoteSubscribeCallback ，unSubTypeList ,type is invalid , " + remoteSubscribeLocalInfo3);
} else {
this.n.a(false, remoteSubscribeLocalInfo3.a());
j jVar = this.M;
if (jVar != null) {
jVar.a(remoteSubscribeLocalInfo3.a());
}
}
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onRemoteUnpublishVideo(final long j2) {
a(false, j2, true, (int[]) null, false, -1);
int o2 = o(j2);
Trace.i("RtcEngineImpl", -300000, "remote un publish video ， so un subscribe , result = " + o2 + " , uid = " + j2);
if (this.aC) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass35 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onRemoteUnpublishVideo(j2);
}
});
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onRemoteUnsubscribeCallback() {
synchronized (this.ae) {
for (RemoteSubscribeLocalInfo remoteSubscribeLocalInfo : this.ae) {
this.n.a(false, remoteSubscribeLocalInfo.a());
}
this.ae.clear();
}
j jVar = this.M;
if (jVar != null) {
jVar.a(-1);
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onRequestChangeVideoBitrate(int i2, int i3, float f2, int i4) {
ThreadUtils.runOnUiThread(new s(this, i2, i3, f2, i4));
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onSendAudioSignal(int i2, int i3) {
j jVar;
if (this.A.get() && (jVar = this.M) != null) {
jVar.h().a((long) i3);
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onServerDisconnected(int i2) {
ThreadUtils.runOnUiThread(new v(this, i2));
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onSubscribeAudioResult(final int i2) {
if (i2 == 0) {
this.ag = true;
}
if (this.aC) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass38 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onSubscribeAudioResult(i2);
}
});
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onSubscribeVideoResult(final long j2, final int i2, final int i3) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.j, "1", i2 + "", j2 + ""));
if (i3 == 0 && !com.netease.nrtc.utility.a.a(i2)) {
com.netease.nrtc.c.a.a().a(j2, System.currentTimeMillis());
a(true, j2, false, (int[]) null, true, i2);
this.n.c(j2, i2);
}
if (this.aC) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass32 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onSubscribeVideoResult(j2, i2, i3);
}
});
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onUnpublishVideoResult(final int i2) {
if (this.aC) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass31 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onUnpublishVideoResult(i2);
}
});
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onUnsubscribeAudioResult(final int i2) {
if (i2 == 0) {
this.ag = false;
}
if (this.aC) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass37 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onUnsubscribeAudioResult(i2);
}
});
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onUnsubscribeVideoResult(final long j2, final int i2, final int i3) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.j, "0", i2 + "", j2 + ""));
if (i3 == 0 && !com.netease.nrtc.utility.a.a(i2)) {
com.netease.nrtc.c.a.a().a(j2);
a(false, j2, false, (int[]) null, true, -1);
}
if (this.aC) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass33 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onUnsubscribeVideoResult(j2, i2, i3);
}
});
}
}
@Override // com.netease.nrtc.internal.NEMediaEngineSink
public void onVideoDropFrame(int i2, int i3, int i4) {
ThreadUtils.runOnUiThread(new m(this, i2, i3, i4));
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int pauseAudioMixing() {
int i2;
if (this.j == null) {
Trace.e("RtcEngineImpl", "pause audio mixing error, voe is null!");
i2 = -1;
} else {
Trace.i("RtcEngineImpl", "pause audio mixing");
this.j.l();
i2 = 0;
}
return i2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int playAudioEffect(int i2, int i3, boolean z2, float f2) {
if (k()) {
Trace.i("RtcEngineImpl", "audience unsupported playAudioEffect");
return RtcCode.ERR_UNINITIALIZED;
}
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.an);
if (f2 < 0.0f) {
f2 = 0.0f;
}
if (f2 > 1.0f) {
f2 = 1.0f;
}
Trace.i("RtcEngineImpl", "play audio effect , id = " + i2 + " , loopback = " + i3 + " , send = " + z2 + " , volume = " + f2);
return this.j.a(i2, i3, z2, f2);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public void preloadAudioEffect(int i2, String str) {
if (k()) {
Trace.i("RtcEngineImpl", "audience unsupported preloadAudioEffect");
} else {
this.ac.a(i2, str);
}
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int publishVideo() {
if (this.y.get() != 3) {
Trace.e("RtcEngineImpl", -300000, "publish video but not running ， status = " + this.y.get());
return -1;
}
int ag2 = ag();
if (ag2 == 0) {
ag2 = Y();
}
Trace.i("RtcEngineImpl", -300000, "publish video ， result = " + ag2);
return ag2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public int pushExternalAudioData(byte[] bArr, int i2, int i3, int i4, int i5, boolean z2) throws NullPointerException, IllegalArgumentException {
Checker.checkNotNull(bArr, "audio data is null");
Checker.checkArgument(i2 * 2 <= bArr.length, "audio data samples illegality");
if (!this.A.get()) {
return -1;
}
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.p);
com.netease.nrtc.voice.b bVar = this.j;
if (bVar == null) {
return -2;
}
return bVar.a(bArr, i2, i3, i4, i5, z2);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int pushExternalAudioMixingStream(byte[] bArr, int i2, int i3, int i4) {
if (this.j == null) {
Trace.e("RtcEngineImpl", "push external audio mixing stream error, voe is null!");
return -1;
}
return this.j.a(bArr, i2, i3, i4);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized void rate(int i2, String str) {
if (this.f10508d != null) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.f.a(this.f10507c, this.f10508d.channel, i2, str));
}
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized boolean registerPlayAudioCallBack(IPlayAudioCallBack iPlayAudioCallBack) {
if (this.j == null) {
Trace.w("RtcEngineImpl", "register play audio call back , but voe is null , callback :" + iPlayAudioCallBack);
return iPlayAudioCallBack == null;
}
Trace.i("RtcEngineImpl", "register play audio call back , callback : " + iPlayAudioCallBack);
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.af);
return this.j.a(iPlayAudioCallBack);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized boolean registerRemoteAudioCallBack(long j2, IRemoteAudioCallBack iRemoteAudioCallBack) {
boolean z2 = true;
if (this.j == null) {
Trace.w("RtcEngineImpl", "register remote audio call back , but voe is null , uid : " + j2 + ", callback :" + iRemoteAudioCallBack);
if (iRemoteAudioCallBack != null) {
z2 = false;
}
return z2;
} else if (!this.f10509e.containsKey(Long.valueOf(j2))) {
Trace.w("RtcEngineImpl", "register remote audio call back , but not find user , uid : " + j2 + ", callback :" + iRemoteAudioCallBack);
if (iRemoteAudioCallBack != null) {
z2 = false;
}
return z2;
} else {
Trace.i("RtcEngineImpl", "register remote audio call back , uid : " + j2 + ", callback :" + iRemoteAudioCallBack);
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.ae);
return this.j.a(j2, iRemoteAudioCallBack);
}
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized boolean remoteAudioStreamMuted(long j2) {
boolean z2;
if (j2 == -1) {
for (Long l2 : this.f10509e.keySet()) {
long longValue = l2.longValue();
if (longValue != this.f10508d.userId && this.j.c(longValue)) {
z2 = false;
}
}
return true;
}
z2 = !this.j.c(j2);
return z2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized boolean remoteVideoStreamMuted(long j2) {
return !this.n.f(j2);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int resumeAudioMixing() {
int i2;
if (this.j == null) {
Trace.e("RtcEngineImpl", "resume audio mixing error, voe is null!");
i2 = RtcCode.ERR_UNINITIALIZED;
} else {
Trace.i("RtcEngineImpl", "resume audio mixing");
this.j.k();
i2 = 0;
}
return i2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public int seekAudioMixing(long j2) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.W);
return this.j.h(j2);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized void selectAudioDevice(int i2) {
if (this.m != null) {
this.m.b(i2);
}
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public void setAsMainArea(long j2, IRtcRoomServerHandler iRtcRoomServerHandler) {
String str;
if (!this.aH) {
if (iRtcRoomServerHandler != null) {
iRtcRoomServerHandler.onResult(300, "not in live mode");
}
str = "setAsMainArea not live mode ";
} else if (TextUtils.isEmpty(this.aI)) {
if (iRtcRoomServerHandler != null) {
iRtcRoomServerHandler.onResult(301, "not anchor");
}
str = "setAsMainArea not anchor";
} else {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.am);
try {
h.a(j2, this.f10508d.channel, this.f10508d.roomServerToken, this.f10508d.userId, iRtcRoomServerHandler);
return;
} catch (Exception e2) {
if (iRtcRoomServerHandler != null) {
iRtcRoomServerHandler.onResult(400, e2.getMessage());
}
Trace.e("RtcEngineImpl", e2.getMessage());
return;
}
}
Trace.e("RtcEngineImpl", str);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public int setAudioMixingPlaybackVolume(float f2) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.V);
if (f2 < 0.0f) {
f2 = 0.0f;
}
if (f2 > 1.0f) {
f2 = 1.0f;
}
return this.j.a(((float) Math.round(f2 * 10.0f)) / 10.0f);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public int setAudioMixingSendVolume(float f2) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.U);
if (f2 < 0.0f) {
f2 = 0.0f;
}
if (f2 > 1.0f) {
f2 = 1.0f;
}
return this.j.b(((float) Math.round(f2 * 10.0f)) / 10.0f);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int setAutoPublish(boolean z2, boolean z3) {
int i2;
int i3 = 1;
if (this.y.get() != 1) {
Trace.e("RtcEngineImpl", -300000, "setAutoPublish err , must before joinChannel");
i2 = -1;
} else {
if (!z2 && z3) {
i3 = 2;
} else if (z2 && !z3) {
i3 = 3;
} else if (!z2) {
i3 = 4;
}
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.ap, i3);
this.ai.a(z2);
this.ai.b(z3);
Trace.i("RtcEngineImpl", -300000, "setAutoPublish , autoPub = " + z2 + ", autoSub = " + z3);
i2 = 0;
}
return i2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public int setChannelProfile(int i2) {
Trace.i("RtcEngineImpl", "setChannelProfile " + i2);
if (i2 == 0 || i2 == 1) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.D, i2 + 1);
if (this.y.get() == 3) {
Trace.i("RtcEngineImpl", "set channel profile error, rtc is running.");
return -500;
}
this.P = i2;
C0373a.j = this.P;
return 0;
}
Trace.e("RtcEngineImpl", "setVideoQualityStrategy error: profile is illegality");
return -400;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int setExternalAudioMixingStream(boolean z2, boolean z3, boolean z4) {
if (this.j == null) {
Trace.e("RtcEngineImpl", "set external audio mixing steam error, voe is null!");
return -1;
}
Trace.i("RtcEngineImpl", "set external audio mixing stream, enable:" + z2 + ", as source:" + z3 + ", as sink:" + z4);
com.netease.nrtc.voice.b bVar = this.j;
boolean z5 = true;
boolean z6 = z2 && z3;
if (!z2 || !z4) {
z5 = false;
}
return bVar.a(z6, z5);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public int setExternalAudioSource(boolean z2) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.f10405a, z2));
if (this.A.get()) {
return -1;
}
com.netease.nrtc.voice.b bVar = this.j;
if (bVar == null) {
return -2;
}
return bVar.b(z2) ? 0 : -3;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int setLocalVideoSimulcastModel(int i2) {
int i3 = 1;
if (this.y.get() != 1) {
Trace.e("RtcEngineImpl", -300000, "setLocalVideoSimulcastModel err , must before joinChannel");
return -1;
} else if (q(i2)) {
Trace.e("RtcEngineImpl", -300000, "setLocalVideoSimulcastModel param illegal , see NRtcConstants.Subscribe , mode = " + i2);
return -1;
} else {
int i4 = com.netease.nrtc.monitor.d.ao;
if (i2 != 0) {
i3 = 2;
}
com.netease.nrtc.monitor.d.a(i4, i3);
this.ai.a(i2);
Trace.i("RtcEngineImpl", -300000, "setLocalVideoSimulcastModel , mode = " + i2);
return 0;
}
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int setMicrophoneMute(boolean z2) {
com.netease.nrtc.c.a(new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.f10407c, z2));
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.f10784f);
return this.j.h(z2);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized void setNewLoginConfig(RtcConfig rtcConfig) {
if (!(this.f10508d == null || rtcConfig == null)) {
if (this.f10508d.channel == rtcConfig.channel) {
this.f10508d = rtcConfig;
this.z.set(3);
Trace.d("Connect-Status-Test-Log", "status : " + this.z.get());
this.f10511g.a(w());
return;
}
}
Trace.e("RtcEngineImpl", "relogin but info err , pre : " + this.f10508d + ", new : " + rtcConfig);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized void setParameters(RtcParameters rtcParameters) throws IllegalArgumentException {
Checker.checkArgument(rtcParameters != null, "parameters is null");
Set<String> keys = rtcParameters.keys();
if (keys.size() != 0) {
String[] strArr = new String[keys.size()];
Object[] objArr = new Object[keys.size()];
Privilege privilege = l.c(C0373a.f10493b) ? Privilege.PROTECTED : Privilege.PUBLIC;
int i2 = 0;
for (String str : keys) {
if (!RtcParameters.checkPrivilege(str, privilege)) {
throw new IllegalArgumentException("check parameter [" + str.toUpperCase() + "] privilege failed!");
} else if (!RtcParameters.writeSupported(str)) {
throw new IllegalArgumentException("check parameter [" + str.toUpperCase() + "] access mode failed!");
} else if (this.y.get() != 3 || RtcParameters.runtimeSupported(str)) {
strArr[i2] = str;
objArr[i2] = rtcParameters.getObject(str);
i2++;
} else {
throw new IllegalArgumentException("parameter [" + str.toUpperCase() + "] unsupported runtime!");
}
}
for (int i3 = 0; i3 < strArr.length; i3++) {
a(strArr[i3], objArr[i3]);
}
}
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int setPlayCapturedAudioVolume(float f2) {
Trace.i("RtcEngineImpl", "set play capture audio volume:" + f2);
if (this.j == null) {
Trace.e("RtcEngineImpl", "set play capture audio volume error, voe is null!");
return RtcCode.ERR_UNINITIALIZED;
}
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.T);
return this.j.c(Math.max(Math.min(f2, 1.0f), 0.0f));
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int setPublishFallbackOption(int i2) {
int i3;
if (this.y.get() == 3) {
Trace.e("RtcEngineImpl", -300000, "set publish fallback option but is running ， status = " + this.y.get());
i3 = -1;
} else {
Trace.i("RtcEngineImpl", -300000, "set publish fallback option ， option = " + i2);
this.ar = i2;
i3 = 0;
}
return i3;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int setRole(int i2) {
Trace.i("RtcEngineImpl", "setRole: " + i2);
if (!this.aC) {
Trace.i("RtcEngineImpl", "role only supported multi mode");
return -2;
}
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.Y);
if (i2 == this.aB) {
return 0;
}
this.aB = i2;
if (this.A.get()) {
if (this.f10511g != null) {
this.f10511g.c(i2 == 1);
}
if (this.aB == 1) {
stopAVRecording(0);
stopAudioRecording();
stopAudioMixing();
H();
stopVideoPreview();
E();
} else {
if (!C()) {
a(this.v, new a(this.f10506b) {
/* class com.netease.nrtc.engine.impl.e.AnonymousClass23 */
/* access modifiers changed from: package-private */
@Override // com.netease.nrtc.engine.impl.e.a
public void a(IRtcEventHandler iRtcEventHandler) {
iRtcEventHandler.onDeviceEvent(3002, "start voice send error");
}
});
}
startVideoPreview();
F();
}
}
I();
return 0;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int setSpeakerphoneOn(boolean z2) {
this.m.a(z2 ? 0 : 2);
selectAudioDevice(z2 ? 0 : -1);
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.f10786h);
com.netease.nrtc.c.a(new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.f10408d, z2));
return 0;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public int setVideoQualityStrategy(int i2) {
if (this.y.get() != 3 || this.al == 0) {
Trace.i("RtcEngineImpl", "setVideoQualityStrategy :" + i2);
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.E, i2);
if (this.R == i2) {
return 0;
}
this.R = i2;
Q();
return 0;
}
Trace.w("RtcEngineImpl", "can not change strategy , rtc is running and not single stream");
return -500;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int setupLocalVideoRenderer(IVideoRender iVideoRender, int i2, boolean z2) {
StringBuilder sb = new StringBuilder();
sb.append("setupLocalVideoRenderer:");
sb.append(iVideoRender == null ? "null" : Integer.toHexString(iVideoRender.hashCode()));
sb.append(",render mode:");
sb.append(i2);
sb.append(", mirror:");
sb.append(z2);
Trace.i("RtcEngineImpl", sb.toString());
int i3 = -1;
if (!this.H) {
Trace.i("RtcEngineImpl", "setup local video renderer error: video is not enabled!");
return -1;
} else if (iVideoRender == null || !iVideoRender.isAttachedToSession() || this.f10508d == null || iVideoRender.getAttachedSession() == this.f10508d.userId) {
if (this.n.a(iVideoRender, i2, z2)) {
i3 = 0;
}
return i3;
} else {
throw new RuntimeException("the canvas already attached a user, reused need detach.");
}
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int setupRemoteVideoRenderer(IVideoRender iVideoRender, long j2, int i2, boolean z2) {
Checker.checkArgument(j2 != 0, "uid can not be 0.");
StringBuilder sb = new StringBuilder();
sb.append("setupRemoteVideoRenderer:");
sb.append(iVideoRender == null ? "null" : Integer.toHexString(iVideoRender.hashCode()));
sb.append(", uid:");
sb.append(j2);
sb.append(",render mode:");
sb.append(i2);
sb.append(", mirror:");
sb.append(z2);
Trace.i("RtcEngineImpl", sb.toString());
int i3 = -1;
if (!this.H) {
Trace.i("RtcEngineImpl", "setup remote video renderer error: video is not enabled!");
return -1;
} else if (iVideoRender == null || !iVideoRender.isAttachedToSession() || iVideoRender.getAttachedSession() == j2) {
if (this.n.a(iVideoRender, j2, i2, z2)) {
i3 = 0;
}
return i3;
} else {
throw new RuntimeException("the canvas already attached a user, reused need detach.");
}
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int setupVideoCapturer(IVideoCapturer iVideoCapturer) {
Trace.i("RtcEngineImpl", "setupVideoCapturer");
return this.n.a(iVideoCapturer);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int startAVRecording(long j2) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.t);
int i2 = -1;
long j3 = j2 == this.f10508d.userId ? 0 : j2;
C0374b bVar = null;
int i3 = (j3 > 0 ? 1 : (j3 == 0 ? 0 : -1));
if (i3 == 0 || (((bVar = this.ad.get(Long.valueOf(j3))) != null && bVar.c()) || this.ag)) {
if (this.f10512h != null && M() && this.f10512h.a(j3)) {
if (i3 == 0) {
this.n.a(true);
} else if (bVar != null) {
b(j3, bVar.b());
}
if (C0373a.l && (j2 == 0 || j2 == this.f10508d.userId)) {
C0373a.m = true;
}
if (!(!C0373a.o || j2 == 0 || j2 == this.f10508d.userId)) {
C0373a.p = true;
}
i2 = 0;
}
return i2;
}
Trace.e("RtcEngineImpl", "try record remote video, but not subscribe video and audio , uid : " + j3);
return -1;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int startAudioMixing(String str, boolean z2, boolean z3, int i2, float f2) {
int i3;
if (k()) {
Trace.i("RtcEngineImpl", "audience unsupported startAudioMixing");
i3 = -700;
} else if (this.j == null) {
Trace.e("RtcEngineImpl", "start audio mixing error, voe is null!");
i3 = RtcCode.ERR_UNINITIALIZED;
} else if (StringUtils.isEmpty(str)) {
Trace.e("RtcEngineImpl", "start audio mixing error, file path is empty!");
i3 = -400;
} else {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.r);
if (f2 < 0.0f) {
f2 = 0.0f;
}
if (f2 > 1.0f) {
f2 = 1.0f;
}
float round = ((float) Math.round(f2 * 10.0f)) / 10.0f;
Trace.i("RtcEngineImpl", "start audio mixing (path:" + str + ",loop:" + z2 + ",replace:" + z3 + ",cycle:" + i2 + ",volume:" + round + ")");
return this.j.a(str, z2, z3, i2, round);
}
return i3;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int startAudioRecording() {
int i2;
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.u);
i2 = 0;
if (!(this.f10512h != null && M() && this.f10512h.b())) {
i2 = -1;
}
return i2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public int startAudioRecording(int i2) {
this.aT = i2;
com.netease.nrtc.rec.a aVar = this.f10512h;
if (aVar != null) {
aVar.a(this.aT);
}
return startAudioRecording();
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int startPlayCapturedAudio() {
Trace.i("RtcEngineImpl", "start play capture audio");
if (this.j == null) {
Trace.e("RtcEngineImpl", "start play capture audio error, voe is null!");
return RtcCode.ERR_UNINITIALIZED;
}
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.S);
com.netease.nrtc.c.a(new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.f10410f, true));
return this.j.o();
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int startVideoPreview() {
int i2;
Trace.i("RtcEngineImpl", "start video preview");
if (!this.H) {
Trace.e("RtcEngineImpl", "start video preview error: video is not enable!!");
i2 = -500;
} else {
if (!this.n.g()) {
if (!SystemPermissionUtils.checkCameraPermission(C0373a.f10493b)) {
Trace.e("RtcEngineImpl", "no camera permission!");
return -700;
} else if (this.n.i() <= 0) {
Trace.e("RtcEngineImpl", "no video capture device");
return -700;
}
}
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.v);
com.netease.nrtc.video.a.a ab2 = ab();
com.netease.nrtc.video.a.a ac2 = ac();
this.n.a(ab2.f11135a, ab2.f11136b, ac2.f11135a, ac2.f11136b, this.aJ);
this.n.c(0L);
i2 = 0;
}
return i2;
}
/* JADX WARNING: Removed duplicated region for block: B:32:0x0056 */
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int stopAVRecording(long j2) {
int i2;
boolean z2;
i2 = 0;
if (this.f10512h != null) {
if (this.f10512h.b(j2 == this.f10508d.userId ? 0 : j2)) {
z2 = true;
if (C0373a.l && (j2 == 0 || j2 == this.f10508d.userId)) {
C0373a.m = false;
}
if (!(!C0373a.o || j2 == 0 || j2 == this.f10508d.userId)) {
C0373a.p = false;
}
if (j2 == 0 || j2 == this.f10508d.userId) {
this.n.a(false);
}
if (!z2) {
i2 = -1;
}
}
}
z2 = false;
C0373a.m = false;
C0373a.p = false;
this.n.a(false);
if (!z2) {
}
return i2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int stopAudioMixing() {
int i2;
if (k()) {
Trace.i("RtcEngineImpl", "audience unsupported stopAudioMixing");
i2 = -700;
} else if (this.j == null) {
Trace.e("RtcEngineImpl", "stop audio mixing error, voe is null!");
i2 = RtcCode.ERR_UNINITIALIZED;
} else {
Trace.i("RtcEngineImpl", "stop audio mixing");
return this.j.q();
}
return i2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int stopAudioRecording() {
int i2;
i2 = 0;
if (!(this.f10512h != null && this.f10512h.c())) {
i2 = -1;
}
return i2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int stopPlayAudioEffect(int i2) {
if (k()) {
Trace.i("RtcEngineImpl", "audience unsupported stopPlayAudioEffect");
return -700;
}
Trace.i("RtcEngineImpl", "stop audio effect , id = " + i2);
return this.j.a(i2);
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int stopPlayCapturedAudio() {
Trace.i("RtcEngineImpl", "stop play capture audio");
if (this.j == null) {
Trace.e("RtcEngineImpl", "stop play capture audio error, voe is null!");
return RtcCode.ERR_UNINITIALIZED;
}
com.netease.nrtc.c.a(new com.netease.nrtc.c.g.a(com.netease.nrtc.c.g.b.f10410f, false));
return this.j.p();
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int stopVideoPreview() {
Trace.i("RtcEngineImpl", "stop video preview");
this.n.d(0L);
this.n.h();
return 0;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int subscribeActiveAudio() {
if (this.y.get() != 3) {
Trace.e("RtcEngineImpl", -300000, "subscribe active audio but not running ， status = " + this.y.get());
return -1;
}
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.aq);
int ah2 = ah();
if (ah2 == 0) {
ah2 = ae();
}
Trace.i("RtcEngineImpl", -300000, "subscribe active audio ， result = " + ah2);
return ah2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int subscribeVideo(long j2, int i2) {
if (this.y.get() != 3) {
Trace.e("RtcEngineImpl", -300000, "subscribe video but not running ， status = " + this.y.get() + " , uid = " + j2);
return -1;
} else if (com.netease.nrtc.utility.a.a(i2)) {
Trace.e("RtcEngineImpl", -300000, "subscribe video type err , uid = " + j2 + ", type = " + i2);
return -1;
} else {
int ah2 = ah();
if (ah2 == 0) {
C0374b bVar = this.ad.get(Long.valueOf(j2));
int b2 = bVar != null ? bVar.b() : -1;
if (b2 == -1 || b2 == i2) {
ah2 = e(j2, i2);
} else {
Trace.e("RtcEngineImpl", -300000, "subscribe video type err , must un subscribe first, uid = " + j2 + ", type = " + i2 + " , pre = " + b2);
return -700;
}
}
Trace.i("RtcEngineImpl", -300000, "subscribe video , uid = " + j2 + ", type = " + i2 + ", result = " + ah2);
return ah2;
}
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int takeSnapshot(long j2) {
com.netease.nrtc.monitor.d.a(com.netease.nrtc.monitor.d.s);
Trace.i("RtcEngineImpl", "takeSnapshot: " + j2);
return this.n.h(j2) ? 0 : -1;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int unpublishVideo() {
if (this.y.get() != 3) {
Trace.e("RtcEngineImpl", -300000, "un publish video but not running ， status = " + this.y.get());
return -1;
}
int ag2 = ag();
if (ag2 == 0) {
ag2 = ad();
}
Trace.i("RtcEngineImpl", -300000, "un publish video ， result = " + ag2);
return ag2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int unsubscribeActiveAudio() {
if (this.y.get() != 3) {
Trace.e("RtcEngineImpl", -300000, "un subscribe active audio but not running ， status = " + this.y.get());
return -1;
}
int ah2 = ah();
if (ah2 == 0) {
ah2 = af();
}
Trace.i("RtcEngineImpl", -300000, "un subscribe active audio ， result = " + ah2);
return ah2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int unsubscribeVideo(long j2) {
if (this.y.get() != 3) {
Trace.e("RtcEngineImpl", -300000, "un subscribe video but not running ， status = " + this.y.get() + " , uid = " + j2);
return -1;
}
int ah2 = ah();
if (ah2 == 0) {
ah2 = o(j2);
}
Trace.i("RtcEngineImpl", -300000, "un subscribe video , uid = " + j2 + " result = " + ah2);
return ah2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int updateSharedEGLContext(android.opengl.EGLContext eGLContext) {
if (this.n == null) {
Trace.e("RtcEngineImpl", "updateSharedEGL14Context error, vie is null");
return -1;
}
if (!(this.ah == null || eGLContext == this.ah.getEglContext())) {
Trace.i("RtcEngineImpl", "updateSharedEGL14Context:" + eGLContext + " default EglContext: " + this.ah.getEglContext());
this.ah.release();
this.ah = null;
}
return this.n.a(eGLContext) ? 0 : -2;
}
@Override // com.netease.nrtc.engine.rawapi.IRtcEngine
public synchronized int updateSharedEGLContext(EGLContext eGLContext) {
if (this.n == null) {
Trace.e("RtcEngineImpl", "updateSharedEGL10Context error, vie is null");
return -1;
}
if (!(this.ah == null || eGLContext == this.ah.getEglContext())) {
Trace.i("RtcEngineImpl", "updateSharedEGL10Context:" + eGLContext + " default EglContext: " + this.ah.getEglContext());
this.ah.release();
this.ah = null;
}
return this.n.a(eGLContext) ? 0 : -2;
}
}