322 lines
9.5 KiB
Java
322 lines
9.5 KiB
Java
package o;
|
|
|
|
import com.google.protobuf.InvalidProtocolBufferException;
|
|
import java.io.IOException;
|
|
import java.util.Iterator;
|
|
import java.util.Map;
|
|
import o.C1174XdZ;
|
|
import o.Nvr;
|
|
import o.Rkw;
|
|
import o.rqb;
|
|
|
|
/* loaded from: classes2.dex */
|
|
final class Ywj<T> implements Wnq<T> {
|
|
private final Hjq<?, ?> a;
|
|
private final boolean b;
|
|
private final InterfaceC16581pUl c;
|
|
private final SSy<?> e;
|
|
|
|
private Ywj(Hjq<?, ?> hjq, SSy<?> sSy, InterfaceC16581pUl interfaceC16581pUl) {
|
|
this.a = hjq;
|
|
this.b = sSy.c(interfaceC16581pUl);
|
|
this.e = sSy;
|
|
this.c = interfaceC16581pUl;
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
|
public static <T> Ywj<T> a(Hjq<?, ?> hjq, SSy<?> sSy, InterfaceC16581pUl interfaceC16581pUl) {
|
|
return new Ywj<>(hjq, sSy, interfaceC16581pUl);
|
|
}
|
|
|
|
@Override // o.Wnq
|
|
public final T e() {
|
|
return (T) this.c.newBuilderForType().buildPartial();
|
|
}
|
|
|
|
@Override // o.Wnq
|
|
public final boolean c(T t, T t2) {
|
|
if (!this.a.d(t).equals(this.a.d(t2))) {
|
|
return false;
|
|
}
|
|
if (this.b) {
|
|
return this.e.a(t).equals(this.e.a(t2));
|
|
}
|
|
return true;
|
|
}
|
|
|
|
@Override // o.Wnq
|
|
public final int b(T t) {
|
|
int hashCode = this.a.d(t).hashCode();
|
|
return this.b ? (hashCode * 53) + this.e.a(t).hashCode() : hashCode;
|
|
}
|
|
|
|
@Override // o.Wnq
|
|
public final void a(T t, T t2) {
|
|
jDR.a(this.a, t, t2);
|
|
if (this.b) {
|
|
jDR.c(this.e, t, t2);
|
|
}
|
|
}
|
|
|
|
@Override // o.Wnq
|
|
public final void a(T t, InterfaceC16095lEl interfaceC16095lEl) throws IOException {
|
|
Iterator<Map.Entry<?, Object>> b = this.e.a(t).b();
|
|
while (b.hasNext()) {
|
|
Map.Entry<?, Object> next = b.next();
|
|
Rkw.Sts sts = (Rkw.Sts) next.getKey();
|
|
if (sts.c() != Nvr.Sts.MESSAGE || sts.d() || sts.e()) {
|
|
throw new IllegalStateException("Found invalid MessageSet item.");
|
|
}
|
|
if (next instanceof C1174XdZ.IeS) {
|
|
interfaceC16095lEl.d(sts.b(), ((C1174XdZ.IeS) next).d.getValue().b());
|
|
} else {
|
|
interfaceC16095lEl.d(sts.b(), next.getValue());
|
|
}
|
|
}
|
|
Hjq<?, ?> hjq = this.a;
|
|
hjq.a((Hjq<?, ?>) hjq.d(t), interfaceC16095lEl);
|
|
}
|
|
|
|
/* JADX WARN: Code restructure failed: missing block: B:36:0x00b9, code lost:
|
|
|
|
if (r2 == null) goto L48;
|
|
*/
|
|
/* JADX WARN: Code restructure failed: missing block: B:37:0x00bb, code lost:
|
|
|
|
r1.a(o.Nvr.c(r12, 2), r2);
|
|
*/
|
|
/* JADX WARN: Code restructure failed: missing block: B:38:0x00c2, code lost:
|
|
|
|
r12 = r4;
|
|
*/
|
|
/* JADX WARN: Multi-variable type inference failed */
|
|
/* JADX WARN: Removed duplicated region for block: B:32:0x00b3 */
|
|
/* JADX WARN: Removed duplicated region for block: B:34:0x00b8 A[SYNTHETIC] */
|
|
@Override // o.Wnq
|
|
/*
|
|
Code decompiled incorrectly, please refer to instructions dump.
|
|
To view partially-correct add '--show-bad-code' argument
|
|
*/
|
|
public final void d(T r10, byte[] r11, int r12, int r13, o.sjx.LWm r14) throws java.io.IOException {
|
|
/*
|
|
r9 = this;
|
|
r0 = r10
|
|
o.KUw r0 = (o.KUw) r0
|
|
o.IsC r1 = r0.unknownFields
|
|
o.IsC r2 = o.C0526IsC.d()
|
|
if (r1 != r2) goto L11
|
|
o.IsC r1 = o.C0526IsC.e()
|
|
r0.unknownFields = r1
|
|
L11:
|
|
o.KUw$Sts r10 = (o.KUw.Sts) r10
|
|
r10.c()
|
|
r10 = 0
|
|
r0 = r10
|
|
L18:
|
|
if (r12 >= r13) goto Lc5
|
|
int r2 = r12 + 1
|
|
r12 = r11[r12]
|
|
if (r12 < 0) goto L24
|
|
r14.d = r12
|
|
r4 = r2
|
|
goto L29
|
|
L24:
|
|
int r12 = o.sjx.b(r12, r11, r2, r14)
|
|
r4 = r12
|
|
L29:
|
|
int r2 = r14.d
|
|
int r12 = o.Nvr.d
|
|
r3 = 2
|
|
if (r2 == r12) goto L5d
|
|
int r12 = o.Nvr.c(r2)
|
|
if (r12 != r3) goto L58
|
|
o.SSy<?> r12 = r9.e
|
|
o.ZjA r0 = r14.e
|
|
o.pUl r3 = r9.c
|
|
int r5 = o.Nvr.b(r2)
|
|
java.lang.Object r12 = r12.c(r0, r3, r5)
|
|
r0 = r12
|
|
o.KUw$IeS r0 = (o.KUw.IeS) r0
|
|
if (r0 != 0) goto L52
|
|
r3 = r11
|
|
r5 = r13
|
|
r6 = r1
|
|
r7 = r14
|
|
int r12 = o.sjx.d(r2, r3, r4, r5, r6, r7)
|
|
goto L18
|
|
L52:
|
|
o.MvG.a()
|
|
o.pUl r11 = r0.c
|
|
throw r10
|
|
L58:
|
|
int r12 = o.sjx.c(r2, r11, r4, r13, r14)
|
|
goto L18
|
|
L5d:
|
|
r12 = 0
|
|
r2 = r10
|
|
L5f:
|
|
if (r4 >= r13) goto Lb9
|
|
int r5 = r4 + 1
|
|
r4 = r11[r4]
|
|
if (r4 < 0) goto L6a
|
|
r14.d = r4
|
|
goto L6e
|
|
L6a:
|
|
int r5 = o.sjx.b(r4, r11, r5, r14)
|
|
L6e:
|
|
int r4 = r14.d
|
|
int r6 = o.Nvr.b(r4)
|
|
int r7 = o.Nvr.c(r4)
|
|
if (r6 == r3) goto L90
|
|
r8 = 3
|
|
if (r6 != r8) goto Laf
|
|
if (r0 != 0) goto L8a
|
|
if (r7 != r3) goto Laf
|
|
int r4 = o.sjx.b(r11, r5, r14)
|
|
java.lang.Object r2 = r14.b
|
|
o.QwV r2 = (o.QwV) r2
|
|
goto L5f
|
|
L8a:
|
|
o.MvG.a()
|
|
o.pUl r11 = r0.c
|
|
throw r10
|
|
L90:
|
|
if (r7 != 0) goto Laf
|
|
int r12 = r5 + 1
|
|
r0 = r11[r5]
|
|
if (r0 < 0) goto L9b
|
|
r14.d = r0
|
|
goto L9f
|
|
L9b:
|
|
int r12 = o.sjx.b(r0, r11, r12, r14)
|
|
L9f:
|
|
r4 = r12
|
|
int r12 = r14.d
|
|
o.SSy<?> r0 = r9.e
|
|
o.ZjA r5 = r14.e
|
|
o.pUl r6 = r9.c
|
|
java.lang.Object r0 = r0.c(r5, r6, r12)
|
|
o.KUw$IeS r0 = (o.KUw.IeS) r0
|
|
goto L5f
|
|
Laf:
|
|
int r6 = o.Nvr.a
|
|
if (r4 == r6) goto Lb8
|
|
int r4 = o.sjx.c(r4, r11, r5, r13, r14)
|
|
goto L5f
|
|
Lb8:
|
|
r4 = r5
|
|
Lb9:
|
|
if (r2 == 0) goto Lc2
|
|
int r12 = o.Nvr.c(r12, r3)
|
|
r1.a(r12, r2)
|
|
Lc2:
|
|
r12 = r4
|
|
goto L18
|
|
Lc5:
|
|
if (r12 != r13) goto Lc8
|
|
return
|
|
Lc8:
|
|
com.google.protobuf.InvalidProtocolBufferException r10 = com.google.protobuf.InvalidProtocolBufferException.f()
|
|
throw r10
|
|
*/
|
|
throw new UnsupportedOperationException("Method not decompiled: o.Ywj.d(java.lang.Object, byte[], int, int, o.sjx$LWm):void");
|
|
}
|
|
|
|
@Override // o.Wnq
|
|
public final void e(T t) {
|
|
this.a.a(t);
|
|
this.e.e(t);
|
|
}
|
|
|
|
@Override // o.Wnq
|
|
public final boolean c(T t) {
|
|
return this.e.a(t).a();
|
|
}
|
|
|
|
@Override // o.Wnq
|
|
public final int a(T t) {
|
|
Iterable entrySet;
|
|
Hjq<?, ?> hjq = this.a;
|
|
int c = hjq.c(hjq.d(t));
|
|
if (!this.b) {
|
|
return c;
|
|
}
|
|
Rkw<?> a = this.e.a(t);
|
|
int i = 0;
|
|
for (int i2 = 0; i2 < a.c.e.size(); i2++) {
|
|
i += Rkw.b(a.c.e.get(i2));
|
|
}
|
|
rqb<?, Object> rqbVar = a.c;
|
|
if (rqbVar.b.isEmpty()) {
|
|
entrySet = rqb.HBt.c();
|
|
} else {
|
|
entrySet = rqbVar.b.entrySet();
|
|
}
|
|
Iterator<T> it = entrySet.iterator();
|
|
while (it.hasNext()) {
|
|
i += Rkw.b((Map.Entry) it.next());
|
|
}
|
|
return c + i;
|
|
}
|
|
|
|
@Override // o.Wnq
|
|
public final void c(T t, lfg lfgVar, ZjA zjA) throws IOException {
|
|
boolean s;
|
|
Hjq<?, ?> hjq = this.a;
|
|
SSy<?> sSy = this.e;
|
|
Object e = hjq.e(t);
|
|
sSy.d(t);
|
|
while (lfgVar.e() != Integer.MAX_VALUE) {
|
|
try {
|
|
int d = lfgVar.d();
|
|
if (d != Nvr.d) {
|
|
if (Nvr.c(d) == 2) {
|
|
Object c = sSy.c(zjA, this.c, Nvr.b(d));
|
|
if (c != null) {
|
|
sSy.c(c);
|
|
} else {
|
|
s = hjq.a((Hjq<?, ?>) e, lfgVar);
|
|
}
|
|
} else {
|
|
s = lfgVar.s();
|
|
}
|
|
if (!s) {
|
|
return;
|
|
}
|
|
} else {
|
|
Object obj = null;
|
|
int i = 0;
|
|
QwV qwV = null;
|
|
while (lfgVar.e() != Integer.MAX_VALUE) {
|
|
int d2 = lfgVar.d();
|
|
if (d2 == Nvr.b) {
|
|
i = lfgVar.t();
|
|
obj = sSy.c(zjA, this.c, i);
|
|
} else if (d2 == Nvr.c) {
|
|
if (obj != null) {
|
|
sSy.c(obj);
|
|
} else {
|
|
qwV = lfgVar.b();
|
|
}
|
|
} else if (!lfgVar.s()) {
|
|
break;
|
|
}
|
|
}
|
|
if (lfgVar.d() != Nvr.a) {
|
|
throw InvalidProtocolBufferException.c();
|
|
}
|
|
if (qwV != null) {
|
|
if (obj != null) {
|
|
sSy.i(obj);
|
|
} else {
|
|
hjq.d((Hjq<?, ?>) e, i, qwV);
|
|
}
|
|
}
|
|
}
|
|
} finally {
|
|
hjq.a((Object) t, (T) e);
|
|
}
|
|
}
|
|
}
|
|
}
|