package p138.p329.p362.p365;

import com.hierynomus.smbj.common.SMBRuntimeException;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;
import p138.p139.p143.p144.C2803;

/* JADX INFO: renamed from: ދ.ށ.މ.ބ.ބ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public class C6362 {

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public AtomicLong f17777 = new AtomicLong(0);

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public Semaphore f17778 = new Semaphore(1);

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public long[] m9583(int i) {
        try {
            if (!this.f17778.tryAcquire(i, 5000L, TimeUnit.MILLISECONDS)) {
                StringBuilder sbM4889 = C2803.m4889("Not enough credits (");
                sbM4889.append(this.f17778.availablePermits());
                sbM4889.append(" available) to hand out ");
                sbM4889.append(i);
                sbM4889.append(" sequence numbers");
                throw new SMBRuntimeException(sbM4889.toString());
            }
            long j = i;
            long andAdd = this.f17777.getAndAdd(j);
            int i2 = (int) ((j + andAdd) - andAdd);
            long[] jArr = new long[i2];
            for (int i3 = 0; i3 < i2; i3++) {
                jArr[i3] = ((long) i3) + andAdd;
            }
            return jArr;
        } catch (InterruptedException unused) {
            Thread.currentThread().interrupt();
            StringBuilder sbM4896 = C2803.m4896("Got interrupted waiting for ", i, " to be available. Credits available at this moment: ");
            sbM4896.append(this.f17778.availablePermits());
            throw new SMBRuntimeException(sbM4896.toString());
        }
    }
}
