com.box.androidsdk.preview.player

Class DefaultHttpDataSource

java.lang.Object

com.box.androidsdk.preview.player.DefaultHttpDataSource

All Implemented Interfaces:

com.google.android.exoplayer.upstream.DataSource, com.google.android.exoplayer.upstream.HttpDataSource, com.google.android.exoplayer.upstream.UriDataSource

Direct Known Subclasses:

BoxHttpDataSource

public class DefaultHttpDataSource
extends java.lang.Object
implements com.google.android.exoplayer.upstream.HttpDataSource

Slightly modified for better usage with Box sessions. A HttpDataSource that uses Android's HttpURLConnection.

By default this implementation will not follow cross-protocol redirects (i.e. redirects from HTTP to HTTPS or vice versa). Cross-protocol redirects can be enabled by using the DefaultHttpDataSource(String, Predicate, TransferListener, int, int, boolean) constructor and passing true as the final argument.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.android.exoplayer.upstream.HttpDataSource

com.google.android.exoplayer.upstream.HttpDataSource.HttpDataSourceException, com.google.android.exoplayer.upstream.HttpDataSource.InvalidContentTypeException, com.google.android.exoplayer.upstream.HttpDataSource.InvalidResponseCodeException

Field Summary

Fields

Modifier and Type	Field and Description
protected java.net.HttpURLConnection	connection
protected com.google.android.exoplayer.upstream.DataSpec	dataSpec
static int	DEFAULT_CONNECT_TIMEOUT_MILLIS The default connection timeout, in milliseconds.
static int	DEFAULT_READ_TIMEOUT_MILLIS The default read timeout, in milliseconds.

Fields inherited from interface com.google.android.exoplayer.upstream.HttpDataSource

REJECT_PAYWALL_TYPES

Constructor Summary

Constructors

Constructor and Description
DefaultHttpDataSource(java.lang.String userAgent, com.google.android.exoplayer.util.Predicate<java.lang.String> contentTypePredicate)
DefaultHttpDataSource(java.lang.String userAgent, com.google.android.exoplayer.util.Predicate<java.lang.String> contentTypePredicate, com.google.android.exoplayer.upstream.TransferListener listener)
DefaultHttpDataSource(java.lang.String userAgent, com.google.android.exoplayer.util.Predicate<java.lang.String> contentTypePredicate, com.google.android.exoplayer.upstream.TransferListener listener, int connectTimeoutMillis, int readTimeoutMillis)
DefaultHttpDataSource(java.lang.String userAgent, com.google.android.exoplayer.util.Predicate<java.lang.String> contentTypePredicate, com.google.android.exoplayer.upstream.TransferListener listener, int connectTimeoutMillis, int readTimeoutMillis, boolean allowCrossProtocolRedirects)

Method Summary

Modifier and Type	Method and Description
protected long	bytesRead() Returns the number of bytes that have been read since the most recent call to open(DataSpec).
protected long	bytesRemaining() Returns the number of bytes that are still to be read for the current DataSpec.
protected long	bytesSkipped() Returns the number of bytes that have been skipped since the most recent call to open(DataSpec).
void	clearAllRequestProperties()
void	clearRequestProperty(java.lang.String name)
void	close()
protected void	closeConnectionQuietly() Closes the current connection quietly, if there is one.
protected java.net.HttpURLConnection	getConnection() Returns the current connection, or null if the source is not currently opened.
protected static long	getContentLength(java.net.HttpURLConnection connection) Attempts to extract the length of the content from the response headers of an open connection.
java.util.Map<java.lang.String,java.util.List<java.lang.String>>	getResponseHeaders()
java.lang.String	getUri()
protected static java.net.URL	handleRedirect(java.net.URL originalUrl, java.lang.String location) Handles a redirect.
protected int	interceptResponseCode(int responseCode)
protected java.net.HttpURLConnection	makeConnection(com.google.android.exoplayer.upstream.DataSpec dataSpec) Establishes a connection, following redirects to do so where permitted.
protected java.net.HttpURLConnection	makeConnection(java.net.URL url, byte[] postBody, long position, long length, boolean allowGzip, boolean followRedirects) Configures a connection and opens it.
long	open(com.google.android.exoplayer.upstream.DataSpec dataSpec)
int	read(byte[] buffer, int offset, int readLength)
protected int	readInternal(byte[] buffer, int offset, int readLength) Reads up to length bytes of data and stores them into buffer, starting at index offset.
void	setRequestProperty(java.lang.String name, java.lang.String value)
protected void	skipInternal() Skips any bytes that need skipping.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_CONNECT_TIMEOUT_MILLIS

public static final int DEFAULT_CONNECT_TIMEOUT_MILLIS

The default connection timeout, in milliseconds.

See Also:

Constant Field Values

DEFAULT_READ_TIMEOUT_MILLIS

public static final int DEFAULT_READ_TIMEOUT_MILLIS

The default read timeout, in milliseconds.

See Also:

Constant Field Values

dataSpec

protected com.google.android.exoplayer.upstream.DataSpec dataSpec

connection

protected java.net.HttpURLConnection connection

Constructor Detail

DefaultHttpDataSource

public DefaultHttpDataSource(java.lang.String userAgent,
                             com.google.android.exoplayer.util.Predicate<java.lang.String> contentTypePredicate)

Parameters:

userAgent - The User-Agent string that should be used.

contentTypePredicate - An optional Predicate. If a content type is rejected by the predicate then a HttpDataSource.InvalidContentTypeException is thrown from open(DataSpec).

DefaultHttpDataSource

public DefaultHttpDataSource(java.lang.String userAgent,
                             com.google.android.exoplayer.util.Predicate<java.lang.String> contentTypePredicate,
                             com.google.android.exoplayer.upstream.TransferListener listener)

Parameters:

userAgent - The User-Agent string that should be used.

contentTypePredicate - An optional Predicate. If a content type is rejected by the predicate then a HttpDataSource.InvalidContentTypeException is thrown from open(DataSpec).

listener - An optional listener.

DefaultHttpDataSource

public DefaultHttpDataSource(java.lang.String userAgent,
                             com.google.android.exoplayer.util.Predicate<java.lang.String> contentTypePredicate,
                             com.google.android.exoplayer.upstream.TransferListener listener,
                             int connectTimeoutMillis,
                             int readTimeoutMillis)

Parameters:

userAgent - The User-Agent string that should be used.

contentTypePredicate - An optional Predicate. If a content type is rejected by the predicate then a HttpDataSource.InvalidContentTypeException is thrown from open(DataSpec).

listener - An optional listener.

connectTimeoutMillis - The connection timeout, in milliseconds. A timeout of zero is interpreted as an infinite timeout.

readTimeoutMillis - The read timeout, in milliseconds. A timeout of zero is interpreted as an infinite timeout.

DefaultHttpDataSource

public DefaultHttpDataSource(java.lang.String userAgent,
                             com.google.android.exoplayer.util.Predicate<java.lang.String> contentTypePredicate,
                             com.google.android.exoplayer.upstream.TransferListener listener,
                             int connectTimeoutMillis,
                             int readTimeoutMillis,
                             boolean allowCrossProtocolRedirects)

Parameters:

userAgent - The User-Agent string that should be used.

contentTypePredicate - An optional Predicate. If a content type is rejected by the predicate then a HttpDataSource.InvalidContentTypeException is thrown from open(DataSpec).

listener - An optional listener.

connectTimeoutMillis - The connection timeout, in milliseconds. A timeout of zero is interpreted as an infinite timeout. Pass DEFAULT_CONNECT_TIMEOUT_MILLIS to use the default value.

readTimeoutMillis - The read timeout, in milliseconds. A timeout of zero is interpreted as an infinite timeout. Pass DEFAULT_READ_TIMEOUT_MILLIS to use the default value.

allowCrossProtocolRedirects - Whether cross-protocol redirects (i.e. redirects from HTTP to HTTPS and vice versa) are enabled.

Method Detail

getUri

public java.lang.String getUri()

Specified by:

getUri in interface com.google.android.exoplayer.upstream.UriDataSource

getResponseHeaders

public java.util.Map<java.lang.String,java.util.List<java.lang.String>> getResponseHeaders()

Specified by:

getResponseHeaders in interface com.google.android.exoplayer.upstream.HttpDataSource

setRequestProperty

public void setRequestProperty(java.lang.String name,
                               java.lang.String value)

Specified by:

setRequestProperty in interface com.google.android.exoplayer.upstream.HttpDataSource

clearRequestProperty

public void clearRequestProperty(java.lang.String name)

Specified by:

clearRequestProperty in interface com.google.android.exoplayer.upstream.HttpDataSource

clearAllRequestProperties

public void clearAllRequestProperties()

Specified by:

clearAllRequestProperties in interface com.google.android.exoplayer.upstream.HttpDataSource

interceptResponseCode

protected int interceptResponseCode(int responseCode)
                             throws com.box.androidsdk.content.BoxException,
                                    com.google.android.exoplayer.upstream.HttpDataSource.HttpDataSourceException

Throws:

com.box.androidsdk.content.BoxException

com.google.android.exoplayer.upstream.HttpDataSource.HttpDataSourceException

open

public long open(com.google.android.exoplayer.upstream.DataSpec dataSpec)
          throws com.google.android.exoplayer.upstream.HttpDataSource.HttpDataSourceException

Specified by:

open in interface com.google.android.exoplayer.upstream.DataSource

Specified by:

open in interface com.google.android.exoplayer.upstream.HttpDataSource

Throws:

com.google.android.exoplayer.upstream.HttpDataSource.HttpDataSourceException

read

public int read(byte[] buffer,
                int offset,
                int readLength)
         throws com.google.android.exoplayer.upstream.HttpDataSource.HttpDataSourceException

Specified by:

read in interface com.google.android.exoplayer.upstream.DataSource

Specified by:

read in interface com.google.android.exoplayer.upstream.HttpDataSource

Throws:

com.google.android.exoplayer.upstream.HttpDataSource.HttpDataSourceException

close

public void close()
           throws com.google.android.exoplayer.upstream.HttpDataSource.HttpDataSourceException

Specified by:

close in interface com.google.android.exoplayer.upstream.DataSource

Specified by:

close in interface com.google.android.exoplayer.upstream.HttpDataSource

Throws:

com.google.android.exoplayer.upstream.HttpDataSource.HttpDataSourceException

getConnection

protected final java.net.HttpURLConnection getConnection()

Returns the current connection, or null if the source is not currently opened.

Returns:

The current open connection, or null.

bytesSkipped

protected final long bytesSkipped()

Returns the number of bytes that have been skipped since the most recent call to open(DataSpec).

Returns:

The number of bytes skipped.

bytesRead

protected final long bytesRead()

Returns the number of bytes that have been read since the most recent call to open(DataSpec).

Returns:

The number of bytes read.

bytesRemaining

protected final long bytesRemaining()

Returns the number of bytes that are still to be read for the current DataSpec.

If the total length of the data being read is known, then this length minus bytesRead() is returned. If the total length is unknown, C.LENGTH_UNBOUNDED is returned.

Returns:

The remaining length, or C.LENGTH_UNBOUNDED.

makeConnection

protected java.net.HttpURLConnection makeConnection(com.google.android.exoplayer.upstream.DataSpec dataSpec)
                                             throws java.io.IOException

Establishes a connection, following redirects to do so where permitted.

Parameters:

dataSpec - The data spec associated with this connection.

Returns:

a HttpURLConnection connecting to provided dataspec.

Throws:

java.io.IOException - throws IOException if there is an error creating connection.

makeConnection

protected java.net.HttpURLConnection makeConnection(java.net.URL url,
                                                    byte[] postBody,
                                                    long position,
                                                    long length,
                                                    boolean allowGzip,
                                                    boolean followRedirects)
                                             throws java.io.IOException

Configures a connection and opens it.

Parameters:

url - The url to connect to.

postBody - The body data for a POST request.

position - The byte offset of the requested data.

length - The length of the requested data, or C.LENGTH_UNBOUNDED.

allowGzip - Whether to allow the use of gzip.

followRedirects - Whether to follow redirects.

Returns:

HttpURLConnection that connects to provided url.

Throws:

java.io.IOException - exception thrown if there is a problem writing to connection.

handleRedirect

protected static java.net.URL handleRedirect(java.net.URL originalUrl,
                                             java.lang.String location)
                                      throws java.io.IOException

Handles a redirect.

Parameters:

originalUrl - The original URL.

location - The Location header in the response.

Returns:

The next URL.

Throws:

java.io.IOException - If redirection isn't possible.

getContentLength

protected static long getContentLength(java.net.HttpURLConnection connection)

Attempts to extract the length of the content from the response headers of an open connection.

Parameters:

connection - The open connection.

Returns:

The extracted length, or C.LENGTH_UNBOUNDED.

skipInternal

protected void skipInternal()
                     throws java.io.IOException

Skips any bytes that need skipping. Else does nothing.

This implementation is based roughly on libcore.io.Streams.skipByReading().

Throws:

java.io.InterruptedIOException - If the thread is interrupted during the operation.

java.io.EOFException - If the end of the input stream is reached before the bytes are skipped.

java.io.IOException

readInternal

protected int readInternal(byte[] buffer,
                           int offset,
                           int readLength)
                    throws java.io.IOException

Reads up to length bytes of data and stores them into buffer, starting at index offset.

This method blocks until at least one byte of data can be read, the end of the opened range is detected, or an exception is thrown.

Parameters:

buffer - The buffer into which the read data should be stored.

offset - The start offset into buffer at which data should be written.

readLength - The maximum number of bytes to read.

Returns:

The number of bytes read, or C.RESULT_END_OF_INPUT if the end of the opened range is reached.

Throws:

java.io.IOException - If an error occurs reading from the source.

closeConnectionQuietly

protected void closeConnectionQuietly()

Closes the current connection quietly, if there is one.