package p138.p329.p362.p371.p372.p373;

import com.hierynomus.protocol.transport.TransportException;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.concurrent.locks.ReentrantLock;
import javax.net.SocketFactory;
import p138.p329.p351.InterfaceC6285;
import p138.p329.p351.InterfaceC6286;
import p138.p329.p351.p352.p355.C6304;
import p138.p329.p351.p356.C6306;
import p138.p329.p361.AbstractC6334;
import p138.p329.p361.C6332;
import p138.p329.p362.p371.AbstractRunnableC6414;
import p463.p481.C7162;
import p463.p481.InterfaceC7161;

/* JADX WARN: Unexpected interfaces in signature: [ދ.ށ.މ.ފ.ؠ.֏.ؠ<P>] */
/* JADX INFO: renamed from: ދ.ށ.މ.ފ.ؠ.֏.ؠ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public class C6416<D extends InterfaceC6286<?>, P extends InterfaceC6285<?>> {

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public final C6306<D, P> f17911;

    /* JADX INFO: renamed from: ށ, reason: contains not printable characters */
    public SocketFactory f17913;

    /* JADX INFO: renamed from: ނ, reason: contains not printable characters */
    public int f17914;

    /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
    public Socket f17915;

    /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
    public BufferedOutputStream f17916;

    /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */
    public AbstractRunnableC6414<D> f17917;

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final InterfaceC7161 f17910 = C7162.m10575((Class<?>) C6416.class);

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public final ReentrantLock f17912 = new ReentrantLock();

    public C6416(SocketFactory socketFactory, int i, C6306<D, P> c6306) {
        this.f17913 = new C6304();
        this.f17914 = i;
        this.f17913 = socketFactory;
        this.f17911 = c6306;
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m9638() {
        this.f17912.lock();
        try {
            if (m9641()) {
                AbstractRunnableC6414<D> abstractRunnableC6414 = this.f17917;
                if (abstractRunnableC6414 == null) {
                    throw null;
                }
                AbstractRunnableC6414.f17904.mo10565("Stopping PacketReader...");
                abstractRunnableC6414.f17907.set(true);
                abstractRunnableC6414.f17908.interrupt();
                if (this.f17915.getInputStream() != null) {
                    this.f17915.getInputStream().close();
                }
                if (this.f17916 != null) {
                    this.f17916.close();
                    this.f17916 = null;
                }
                if (this.f17915 != null) {
                    this.f17915.close();
                    this.f17915 = null;
                }
            }
        } finally {
            this.f17912.unlock();
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final void m9639(int i) throws IOException {
        this.f17916.write(0);
        this.f17916.write((byte) (i >> 16));
        this.f17916.write((byte) (i >> 8));
        this.f17916.write((byte) (i & 255));
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public void m9640(P p) {
        this.f17910.mo10570("Acquiring write lock to send packet << {} >>", p);
        this.f17912.lock();
        try {
            if (!m9641()) {
                throw new TransportException(String.format("Cannot write %s as transport is disconnected", p));
            }
            try {
                this.f17910.mo10573("Writing packet {}", p);
                if (this.f17911.f17650 == null) {
                    throw null;
                }
                C6332 c6332 = new C6332();
                ((AbstractC6334) p).mo9493(c6332);
                m9639(c6332.m1460());
                this.f17916.write(c6332.f2168, c6332.f2170, c6332.m1460());
                this.f17916.flush();
                this.f17910.mo10570("Packet {} sent, lock released.", p);
            } catch (IOException e) {
                throw new TransportException(e);
            }
        } finally {
            this.f17912.unlock();
        }
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public boolean m9641() {
        Socket socket = this.f17915;
        return (socket == null || !socket.isConnected() || this.f17915.isClosed()) ? false : true;
    }
}