导航菜单
登录 注册

页面标题

页面副标题

CallApp v2.226 - a0.java 源代码

正在查看： CallApp v2.226 应用的 a0.java JAVA 源代码文件

本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。 


package com.fyber.inneractive.sdk.network;

import com.facebook.ads.AdError;
import com.fyber.inneractive.sdk.ignite.IgniteResponseOuterClass$IgniteResponse;
import com.fyber.inneractive.sdk.util.AbstractC0230t;
import com.fyber.inneractive.sdk.util.C0217f;
import com.fyber.inneractive.sdk.util.IAlog;
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 a0 extends U {
    public final byte[] p;
    public final AtomicInteger q;

    public a0(com.fyber.inneractive.sdk.ignite.b bVar, byte[] bArr, com.fyber.inneractive.sdk.config.global.r rVar) {
        super(bVar, G.c.a(), rVar);
        this.q = new AtomicInteger();
        this.p = bArr;
    }

    @Override
    public final O a(C0111l c0111l, Map map, int i) {
        try {
            O o = new O();
            InputStream inputStream = c0111l.c;
            if (inputStream != null) {
                ByteBuffer byteBuffer = (ByteBuffer) C0217f.b.a.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();
                AbstractC0230t.b(byteArrayOutputStream);
                C0217f.b.a.offer(byteBuffer);
                String str = new String(byteArray, "UTF-8");
                IgniteResponseOuterClass$IgniteResponse parseFrom = IgniteResponseOuterClass$IgniteResponse.parseFrom(str.getBytes());
                o.b = str;
                o.a = parseFrom;
            }
            return o;
        } catch (Exception e) {
            IAlog.a("failed parse ignite network request", e, new Object[0]);
            throw new N(e);
        } catch (Throwable th) {
            IAlog.a("failed parse ignite network request", th, new Object[0]);
            throw new N("failed to parse ignite network request");
        }
    }

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

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

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

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

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

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

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