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;

/* JADX INFO: renamed from: ᵲʒˇˉ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C4479 extends AbstractFutureC1396 {

    /* JADX INFO: renamed from: ˌᴵ, reason: contains not printable characters */
    public final C0486 f17089;

    /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */
    public final C1983 f17091;

    /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
    public final AtomicBoolean f17090 = new AtomicBoolean(false);

    /* JADX INFO: renamed from: ᵨᵼⁱ, reason: contains not printable characters */
    public final ReentrantReadWriteLock f17092 = new ReentrantReadWriteLock();

    public C4479(C0486 c0486, C1983 c1983) {
        this.f17089 = c0486;
        this.f17091 = c1983;
    }

    @Override // java.util.concurrent.Future
    public final boolean cancel(boolean z) {
        AtomicBoolean atomicBoolean = this.f17090;
        ReentrantReadWriteLock reentrantReadWriteLock = this.f17092;
        reentrantReadWriteLock.writeLock().lock();
        try {
            if (!isDone() && !atomicBoolean.getAndSet(true)) {
                this.f17091.m5362();
                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.f17089.get();
    }

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

    @Override // java.util.concurrent.Future
    public final boolean isCancelled() {
        ReentrantReadWriteLock reentrantReadWriteLock = this.f17092;
        reentrantReadWriteLock.readLock().lock();
        try {
            return this.f17090.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.
    */
    public final boolean isDone() {
        boolean z;
        ReentrantReadWriteLock reentrantReadWriteLock = this.f17092;
        reentrantReadWriteLock.readLock().lock();
        try {
            if (!this.f17090.get()) {
                z = this.f17089.isDone();
            }
            return z;
        } finally {
            reentrantReadWriteLock.readLock().unlock();
        }
    }
}