a.java 源代码

package s;

import android.os.SystemClock;
import java.io.IOException;
import java.io.InputStream;
import java.net.MalformedURLException;
import java.net.SocketTimeoutException;
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.TreeMap;
import r.b;
import r.k;
import r.o;
import r.p;
import r.q;
import r.r;
import r.s;

public class a implements r.f {

    protected static final boolean f26080c = s.f25882b;

    private static int f26081d = 3000;

    private static int f26082e = 4096;

    protected final e f26083a;

    protected final b f26084b;

    public a(e eVar) {
        this(eVar, new b(f26082e));
    }

    private void b(Map<String, String> map, b.a aVar) {
        if (aVar == null) {
            return;
        }
        String str = aVar.f25811b;
        if (str != null) {
            map.put("If-None-Match", str);
        }
        if (aVar.f25813d > 0) {
            map.put("If-Modified-Since", c4.b.a(new Date(aVar.f25813d)));
        }
    }

    private static void c(String str, k<?> kVar, r rVar) throws r {
        o y6 = kVar.y();
        int z6 = kVar.z();
        try {
            y6.c(rVar);
            kVar.b(String.format("%s-retry [timeout=%s]", str, Integer.valueOf(z6)));
        } catch (r e6) {
            kVar.b(String.format("%s-timeout-giveup [timeout=%s]", str, Integer.valueOf(z6)));
            throw e6;
        }
    }

    protected static Map<String, String> d(w3.b[] bVarArr) {
        TreeMap treeMap = new TreeMap(String.CASE_INSENSITIVE_ORDER);
        for (int i6 = 0; i6 < bVarArr.length; i6++) {
            treeMap.put(bVarArr[i6].getName(), bVarArr[i6].getValue());
        }
        return treeMap;
    }

    private byte[] e(w3.d dVar) throws IOException, p {
        g gVar = new g(this.f26084b, (int) dVar.c());
        try {
            InputStream a7 = dVar.a();
            if (a7 != null) {
                byte[] a8 = this.f26084b.a(1024);
                while (true) {
                    int read = a7.read(a8);
                    if (read == -1) {
                        break;
                    }
                    gVar.write(a8, 0, read);
                }
                byte[] byteArray = gVar.toByteArray();
                try {
                    dVar.b();
                } catch (IOException unused) {
                    s.e("Error occured when calling consumingContent", new Object[0]);
                }
                this.f26084b.b(a8);
                gVar.close();
                return byteArray;
            }
            throw new p();
        } catch (Throwable th) {
            try {
                dVar.b();
            } catch (IOException unused2) {
                s.e("Error occured when calling consumingContent", new Object[0]);
            }
            this.f26084b.b(null);
            gVar.close();
            throw th;
        }
    }

    private void f(long j6, k<?> kVar, byte[] bArr, w3.j jVar) {
        Object obj;
        if (f26080c || j6 > f26081d) {
            Object[] objArr = new Object[5];
            objArr[0] = kVar;
            objArr[1] = Long.valueOf(j6);
            if (bArr != null) {
                obj = Integer.valueOf(bArr.length);
            } else {
                obj = "null";
            }
            objArr[2] = obj;
            objArr[3] = Integer.valueOf(jVar.getStatusCode());
            objArr[4] = Integer.valueOf(kVar.y().b());
            s.b("HTTP response for request=<%s> [lifetime=%d], [size=%s], [rc=%d], [retryCount=%s]", objArr);
        }
    }

    @Override
    public r.i a(k<?> kVar) throws r {
        ?? r17;
        w3.f fVar;
        byte[] bArr;
        byte[] e6;
        a aVar;
        long elapsedRealtime = SystemClock.elapsedRealtime();
        while (true) {
            Map emptyMap = Collections.emptyMap();
            try {
                try {
                    HashMap hashMap = new HashMap();
                    b(hashMap, kVar.n());
                    fVar = this.f26083a.a(kVar, hashMap);
                    try {
                        w3.j b6 = fVar.b();
                        int statusCode = b6.getStatusCode();
                        ?? d6 = d(fVar.c());
                        if (statusCode == 304) {
                            b.a n6 = kVar.n();
                            if (n6 == null) {
                                return new r.i(304, null, d6, true, SystemClock.elapsedRealtime() - elapsedRealtime);
                            }
                            n6.f25816g.putAll(d6);
                            return new r.i(304, n6.f25810a, n6.f25816g, true, SystemClock.elapsedRealtime() - elapsedRealtime);
                        }
                        try {
                            if (fVar.a() != null) {
                                try {
                                    e6 = e(fVar.a());
                                } catch (IOException e7) {
                                    e = e7;
                                    bArr = null;
                                    r17 = d6;
                                    if (fVar != null) {
                                    }
                                }
                            } else {
                                e6 = new byte[0];
                            }
                            byte[] bArr2 = e6;
                            try {
                                aVar = this;
                                aVar.f(SystemClock.elapsedRealtime() - elapsedRealtime, kVar, bArr2, b6);
                                try {
                                    if (statusCode < 200 || statusCode > 299) {
                                        break;
                                    }
                                    return new r.i(statusCode, bArr2, d6, false, SystemClock.elapsedRealtime() - elapsedRealtime);
                                } catch (IOException e8) {
                                    e = e8;
                                    r17 = aVar;
                                    bArr = bArr2;
                                    if (fVar != null) {
                                        int statusCode2 = fVar.b().getStatusCode();
                                        s.c("Unexpected response code %d for %s", Integer.valueOf(statusCode2), kVar.B());
                                        if (bArr != null) {
                                            r.i iVar = new r.i(statusCode2, bArr, r17, false, SystemClock.elapsedRealtime() - elapsedRealtime);
                                            if (statusCode2 != 401 && statusCode2 != 403) {
                                                throw new p(iVar);
                                            }
                                            c("auth", kVar, new r.a(iVar));
                                        } else {
                                            throw new r.h((r.i) null);
                                        }
                                    } else {
                                        throw new r.j(e);
                                    }
                                }
                            } catch (IOException e9) {
                                e = e9;
                                aVar = d6;
                            }
                        } catch (IOException e10) {
                            e = e10;
                            emptyMap = d6;
                            r17 = emptyMap;
                            bArr = null;
                            if (fVar != null) {
                            }
                        }
                    } catch (IOException e11) {
                        e = e11;
                    }
                } catch (IOException e12) {
                    e = e12;
                    r17 = emptyMap;
                    fVar = null;
                    bArr = null;
                }
            } catch (MalformedURLException e13) {
                throw new RuntimeException("Bad URL " + kVar.B(), e13);
            } catch (SocketTimeoutException unused) {
                c("socket", kVar, new q());
            }
        }
    }

    public a(e eVar, b bVar) {
        this.f26083a = eVar;
        this.f26084b = bVar;
    }
}