Merge "revert "HLS seeking: call readAt() on new thread""

import java.net.UnknownServiceException;

import java.util.HashMap;

import java.util.Map;

import java.util.concurrent.atomic.AtomicBoolean;

/** @hide */

public class MediaHTTPConnection extends IMediaHTTPConnection.Stub {

    // from com.squareup.okhttp.internal.http

    private final static int HTTP_TEMP_REDIRECT = 307;

    private final static int MAX_REDIRECTS = 20;

    private AtomicBoolean mIsConnected = new AtomicBoolean(false);

    @UnsupportedAppUsage

    public MediaHTTPConnection() {

            mAllowCrossDomainRedirect = true;

            mURL = new URL(uri);

            mHeaders = convertHeaderStringToMap(headers);

            mIsConnected.set(true);

        } catch (MalformedURLException e) {

            return null;

        }

    @Override

    @UnsupportedAppUsage

    public void disconnect() {

        if (mIsConnected.getAndSet(false)) {

            (new Thread() {

                @Override

                public void run() {

        teardownConnection();

                }

            }).start();

        }

        mHeaders = null;

        mURL = null;

    }

    @Override

    @UnsupportedAppUsage

    public int readAt(long offset, int size) {

        if (!mIsConnected.get()) {

            return -1;

        }

        int result = native_readAt(offset, size);

        if (!mIsConnected.get()) {

            return -1;

        }

        return result;

        return native_readAt(offset, size);

    }

    private int readAt(long offset, byte[] data, int size) {