package p138.p329.p362.p371; import com.hierynomus.mssmb.SMB1NotSupportedException; import com.hierynomus.protocol.commons.buffer.Buffer; import com.hierynomus.protocol.transport.TransportException; import com.hierynomus.security.SecurityException; import com.hierynomus.smbj.common.SMBRuntimeException; import java.io.IOException; import java.io.InputStream; import java.util.HashSet; import java.util.Iterator; import java.util.concurrent.atomic.AtomicBoolean; import p138.p139.p143.p144.C2803; import p138.p176.p177.p242.p246.p251.C4303; import p138.p329.p341.EnumC6158; import p138.p329.p346.C6231; import p138.p329.p346.C6237; import p138.p329.p346.C6238; import p138.p329.p346.EnumC6233; import p138.p329.p346.EnumC6235; import p138.p329.p351.InterfaceC6286; import p138.p329.p351.p352.p354.C6302; import p138.p329.p351.p356.InterfaceC6307; import p138.p329.p357.InterfaceC6310; import p138.p329.p361.AbstractC6335; import p138.p329.p361.C6332; import p138.p329.p362.p365.C6354; import p138.p329.p362.p365.C6359; import p138.p329.p362.p365.C6360; import p138.p329.p362.p369.C6383; import p138.p329.p362.p369.C6386; import p138.p329.p362.p371.p372.p373.C6415; import p463.p481.C7162; import p463.p481.InterfaceC7161; /* JADX INFO: renamed from: ދ.ށ.މ.ފ.֏, reason: contains not printable characters */ /* JADX INFO: loaded from: classes.dex */ public abstract class AbstractRunnableC6414> implements Runnable { /* JADX INFO: renamed from: އ, reason: contains not printable characters */ public static final InterfaceC7161 f17904 = C7162.m10575((Class) AbstractRunnableC6414.class); /* JADX INFO: renamed from: ރ, reason: contains not printable characters */ public InputStream f17905; /* JADX INFO: renamed from: ބ, reason: contains not printable characters */ public InterfaceC6307 f17906; /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */ public AtomicBoolean f17907 = new AtomicBoolean(false); /* JADX INFO: renamed from: ކ, reason: contains not printable characters */ public Thread f17908; public AbstractRunnableC6414(String str, InputStream inputStream, InterfaceC6307 interfaceC6307) { this.f17905 = inputStream; this.f17906 = interfaceC6307; Thread thread = new Thread(this, C2803.m4879("Packet Reader for ", str)); this.f17908 = thread; thread.setDaemon(true); } /* JADX WARN: Type inference failed for: r5v4, types: [T extends java.lang.Throwable, java.lang.Throwable] */ @Override // java.lang.Runnable public void run() { while (!Thread.currentThread().isInterrupted() && !this.f17907.get()) { try { m9635(); } catch (TransportException e) { if (!this.f17907.get()) { f17904.mo10557("PacketReader error, got exception.", (Throwable) e); C6354 c6354 = (C6354) this.f17906; C6359 c6359 = c6354.f17742; c6359.f17768.writeLock().lock(); try { Iterator it = new HashSet(c6359.f17769.keySet()).iterator(); while (it.hasNext()) { C6360 c6360Remove = c6359.f17769.remove((Long) it.next()); c6359.f17770.remove(c6360Remove.f17774); C6302 c6302 = c6360Remove.f17771; c6302.f17642.lock(); try { c6302.f17645 = c6302.f17641.mo1479(e); c6302.f17643.signalAll(); c6302.f17642.unlock(); } catch (Throwable th) { c6302.f17642.unlock(); throw th; } } try { c6354.close(); return; } catch (Exception e2) { C6354.f17737.mo10556("{} while closing connection on error, ignoring: {}", e2.getClass().getSimpleName(), e2.getMessage()); return; } } finally { c6359.f17768.writeLock().unlock(); } } } } if (this.f17907.get()) { f17904.mo10561("{} stopped.", this.f17908); } } /* JADX WARN: Code restructure failed: missing block: B:41:0x018a, code lost: p138.p329.p362.p369.C6383.f17815.mo10572("Signatures for packet {} do not match (received: {}, calculated: {})", r4, java.util.Arrays.toString(r9), java.util.Arrays.toString(r6)); p138.p329.p362.p369.C6383.f17815.mo10574("Packet {} has header: {}", r4, r4.mo9556()); */ /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Type inference failed for: r4v18, types: [V, java.lang.Object, ދ.ށ.ބ.ތ, ދ.ށ.ވ.ހ] */ /* JADX WARN: Type inference fix 'apply assigned field type' failed java.lang.UnsupportedOperationException: ArgType.getObject(), call class: class jadx.core.dex.instructions.args.ArgType$UnknownArg at jadx.core.dex.instructions.args.ArgType.getObject(ArgType.java:593) at jadx.core.dex.attributes.nodes.ClassTypeVarsAttr.getTypeVarsMapFor(ClassTypeVarsAttr.java:35) at jadx.core.dex.nodes.utils.TypeUtils.replaceClassGenerics(TypeUtils.java:177) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.insertExplicitUseCast(FixTypesVisitor.java:397) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.tryFieldTypeWithNewCasts(FixTypesVisitor.java:359) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.applyFieldType(FixTypesVisitor.java:309) at jadx.core.dex.visitors.typeinference.FixTypesVisitor.visit(FixTypesVisitor.java:94) */ /* JADX INFO: renamed from: ֏, reason: contains not printable characters */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final void m9635() throws TransportException { C6415 c6415 = (C6415) this; try { byte[] bArr = new byte[c6415.m9637()]; c6415.m9636(bArr); InterfaceC6286 interfaceC6286Mo9495 = c6415.f17909.mo9495(bArr); f17904.mo10573("Received packet {}", interfaceC6286Mo9495); C6354 c6354 = (C6354) this.f17906; if (c6354 == null) { throw null; } AbstractC6335 abstractC6335 = (AbstractC6335) interfaceC6286Mo9495; if (!(abstractC6335 instanceof C6238)) { throw new SMB1NotSupportedException(); } C6238 c6238 = (C6238) abstractC6335; long j = ((C6231) c6238.f17678).f17390; C6359 c6359 = c6354.f17742; Long lValueOf = Long.valueOf(j); c6359.f17768.readLock().lock(); try { if (!c6359.f17769.containsKey(lValueOf)) { throw new TransportException(C2803.m4875("Received response with unknown sequence number <<", j, ">>")); } c6354.f17743.f17778.release(((C6231) c6238.f17678).f17388); boolean z = false; C6354.f17737.mo10558("Server granted us {} credits for {}, now available: {} credits", Integer.valueOf(((C6231) c6238.f17678).f17388), c6238, Integer.valueOf(c6354.f17743.f17778.availablePermits())); c6359 = c6354.f17742; Long lValueOf2 = Long.valueOf(j); c6359.f17768.readLock().lock(); try { C6360 c6360 = c6359.f17769.get(lValueOf2); c6359.f17768.readLock().unlock(); C6354.f17737.mo10562("Send/Recv of packet {} took << {} ms >>", c6238, Long.valueOf(System.currentTimeMillis() - c6360.f17775.getTime())); if (C4303.m7122(((C6231) c6238.f17678).f17395, EnumC6235.SMB2_FLAGS_ASYNC_COMMAND) && ((C6231) c6238.f17678).f17394 == EnumC6158.STATUS_PENDING.f17193) { C6354.f17737.mo10556("Received ASYNC packet {} with AsyncId << {} >>", c6238, Long.valueOf(((C6231) c6238.f17678).f17391)); c6360.f17776 = ((C6231) c6238.f17678).f17391; return; } try { ?? M9503 = c6354.f17744.m9503(c6360.f17772, c6238); C6231 c6231 = (C6231) c6238.f17678; long j2 = c6231.f17392; if (j2 != 0 && c6231.f17389 != EnumC6233.SMB2_SESSION_SETUP) { C6386 c6386M9584 = c6354.f17740.m9584(Long.valueOf(j2)); if (c6386M9584 == null && (c6386M9584 = c6354.f17741.m9584(Long.valueOf(j2))) == null) { C6354.f17737.mo10566("Illegal request, no session matching the sessionId: {}", Long.valueOf(j2)); return; } if (C4303.m7122(((C6231) M9503.mo9556()).f17395, EnumC6235.SMB2_FLAGS_SIGNED)) { C6383 c6383 = c6386M9584.f17826; if (c6383 == null) { throw null; } try { C6332 c6332 = M9503.f17438; byte[] bArr2 = c6383.f17819; InterfaceC6310 interfaceC6310Mo9551 = c6383.f17817.mo9551(c6383.f17818); interfaceC6310Mo9551.mo9548(bArr2); interfaceC6310Mo9551.mo9546(c6332.f2168, ((C6231) M9503.f17677).f17398, 48); interfaceC6310Mo9551.mo9545(C6231.f17384); interfaceC6310Mo9551.mo9546(c6332.f2168, 64, M9503.f17440 - 64); byte[] bArrMo9547 = interfaceC6310Mo9551.mo9547(); byte[] bArr3 = ((C6231) M9503.mo9556()).f17397; int i = 0; while (true) { if (i >= 16) { z = true; break; } else if (bArrMo9547[i] != bArr3[i]) { break; } else { i++; } } if (!z) { C6354.f17737.mo10566("Invalid packet signature for packet {}", (Object) M9503); if (c6386M9584.f17827) { throw new TransportException("Packet signature for packet " + ((Object) M9503) + " was not correct"); } } } catch (SecurityException e) { throw new IllegalStateException(e); } } else if (c6386M9584.f17827) { C6354.f17737.mo10566("Illegal request, session requires message signing, but packet {} is not signed.", (Object) M9503); throw new TransportException("Session requires signing, but packet " + ((Object) M9503) + " was not signed"); } } C6359 c63592 = c6354.f17742; Long lValueOf3 = Long.valueOf(j); c63592.f17768.writeLock().lock(); try { C6360 c6360Remove = c63592.f17769.remove(lValueOf3); if (c6360Remove == null) { throw new SMBRuntimeException("Unable to find outstanding request for messageId " + lValueOf3); } c63592.f17770.remove(c6360Remove.f17774); c63592.f17768.writeLock().unlock(); C6302 c6302 = c6360Remove.f17771; c6302.f17642.lock(); try { c6302.f17639.mo10556("Setting << {} >> to `{}`", c6302.f17640, M9503); c6302.f17644 = M9503; c6302.f17643.signalAll(); } finally { c6302.f17642.unlock(); } } catch (Throwable th) { c63592.f17768.writeLock().unlock(); throw th; } } catch (Buffer.BufferException e2) { throw new TransportException("Unable to deserialize SMB2 Packet Data.", e2); } } finally { } } finally { } } catch (Buffer.BufferException e3) { e = e3; throw new TransportException(e); } catch (TransportException e4) { throw e4; } catch (IOException e5) { e = e5; throw new TransportException(e); } } }