FileWipe Pro v3.0.0 - y0.java 源代码

package com.fyber.inneractive.sdk.network;

import com.fyber.inneractive.sdk.ignite.IgniteResponseOuterClass$IgniteResponse;
import com.fyber.inneractive.sdk.util.IAlog;
import com.mbridge.msdk.playercommon.exoplayer2.C;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.nio.ByteBuffer;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;

public final class y0 extends s0 {

    public final byte[] f6317p;

    public final AtomicInteger f6318q;

    public y0(com.fyber.inneractive.sdk.ignite.b bVar, byte[] bArr, com.fyber.inneractive.sdk.config.global.r rVar) {
        super(bVar, f0.f6206c.a(), rVar);
        this.f6318q = new AtomicInteger();
        this.f6317p = bArr;
    }

    @Override
    public final n0 a(l lVar, Map map, int i10) {
        try {
            n0 n0Var = new n0();
            InputStream inputStream = lVar.f6229c;
            if (inputStream != null) {
                ByteBuffer byteBuffer = (ByteBuffer) com.fyber.inneractive.sdk.util.f.f8586b.f8587a.poll();
                if (byteBuffer == null) {
                    byteBuffer = ByteBuffer.allocateDirect(16384);
                }
                ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
                byte[] array = (byteBuffer == null || !byteBuffer.hasArray()) ? new byte[8192] : byteBuffer.array();
                while (true) {
                    int read = inputStream.read(array, 0, array.length);
                    if (read == -1) {
                        break;
                    }
                    byteArrayOutputStream.write(array, 0, read);
                }
                byteArrayOutputStream.flush();
                byte[] byteArray = byteArrayOutputStream.toByteArray();
                com.fyber.inneractive.sdk.util.t.b(byteArrayOutputStream);
                com.fyber.inneractive.sdk.util.f.f8586b.f8587a.offer(byteBuffer);
                String str = new String(byteArray, C.UTF8_NAME);
                IgniteResponseOuterClass$IgniteResponse parseFrom = IgniteResponseOuterClass$IgniteResponse.parseFrom(str.getBytes());
                n0Var.f6243b = str;
                n0Var.f6242a = parseFrom;
            }
            return n0Var;
        } catch (Exception e4) {
            IAlog.a("failed parse ignite network request", e4, new Object[0]);
            throw new m0(e4);
        } catch (Throwable th) {
            IAlog.a("failed parse ignite network request", th, new Object[0]);
            throw new m0("failed to parse ignite network request");
        }
    }

    @Override
    public final byte[] d() {
        return this.f6317p;
    }

    @Override
    public final int e() {
        return ((int) Math.pow(2.0d, this.f6318q.get())) * 1000;
    }

    @Override
    public final l0 k() {
        return l0.POST;
    }

    @Override
    public final String l() {
        return "application/x-protobuf; messageType=IgniteRequest";
    }

    @Override
    public final e1 m() {
        return e1.HIGH;
    }

    @Override
    public final String p() {
        return "https://init-mp.fyber.com/init";
    }

    @Override
    public final boolean s() {
        return this.f6318q.getAndIncrement() < 4;
    }
}