package defpackage;

import com.hierynomus.smbj.common.SMBRuntimeException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.locks.ReentrantReadWriteLock;

/* renamed from: ᵬʽᵫ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C4017 extends AbstractFutureC5055 {

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public final C4574 f15101;

    /* renamed from: ᵧᵾˀˈ, reason: contains not printable characters */
    public final C2006 f15102;

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public final AtomicBoolean f15104 = new AtomicBoolean(false);

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public final ReentrantReadWriteLock f15103 = new ReentrantReadWriteLock();

    public C4017(C2006 c2006, C4574 c4574) {
        this.f15102 = c2006;
        this.f15101 = c4574;
    }

    @Override // java.util.concurrent.Future
    public final boolean cancel(boolean z) {
        AtomicBoolean atomicBoolean = this.f15104;
        ReentrantReadWriteLock reentrantReadWriteLock = this.f15103;
        reentrantReadWriteLock.writeLock().lock();
        try {
            if (!isDone() && !atomicBoolean.getAndSet(true)) {
                this.f15101.m9727();
                return true;
            }
            return false;
        } catch (Throwable th) {
            try {
                atomicBoolean.set(false);
                if (th instanceof SMBRuntimeException) {
                    throw th;
                }
                throw new SMBRuntimeException(th);
            } finally {
                reentrantReadWriteLock.writeLock().unlock();
            }
        }
    }

    @Override // java.util.concurrent.Future
    public final Object get() {
        return this.f15102.get();
    }

    @Override // java.util.concurrent.Future
    public final Object get(long j, TimeUnit timeUnit) {
        return this.f15102.get(j, timeUnit);
    }

    @Override // java.util.concurrent.Future
    public final boolean isCancelled() {
        ReentrantReadWriteLock reentrantReadWriteLock = this.f15103;
        reentrantReadWriteLock.readLock().lock();
        try {
            return this.f15104.get();
        } finally {
            reentrantReadWriteLock.readLock().unlock();
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:11:0x001e  */
    @Override // java.util.concurrent.Future
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final boolean isDone() {
        /*
            r2 = this;
            java.util.concurrent.locks.ReentrantReadWriteLock r0 = r2.f15103
            java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock r1 = r0.readLock()
            r1.lock()
            java.util.concurrent.atomic.AtomicBoolean r1 = r2.f15104     // Catch: java.lang.Throwable -> L1c
            boolean r1 = r1.get()     // Catch: java.lang.Throwable -> L1c
            if (r1 != 0) goto L1e
            ːﹳʚ r2 = r2.f15102     // Catch: java.lang.Throwable -> L1c
            boolean r2 = r2.isDone()     // Catch: java.lang.Throwable -> L1c
            if (r2 == 0) goto L1a
            goto L1e
        L1a:
            r2 = 0
            goto L1f
        L1c:
            r2 = move-exception
            goto L27
        L1e:
            r2 = 1
        L1f:
            java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock r0 = r0.readLock()
            r0.unlock()
            return r2
        L27:
            java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock r0 = r0.readLock()
            r0.unlock()
            throw r2
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.C4017.isDone():boolean");
    }
}