Fix review comments

This commit is contained in:
Ian Baker 2024-10-24 16:27:39 +01:00
parent 7d3e6b0f27
commit 683a5b8403
12 changed files with 63 additions and 26 deletions

View File

@ -845,7 +845,7 @@ public interface AnalyticsListener {
/** /**
* @deprecated Implement {@link #onLoadStarted(EventTime, LoadEventInfo, MediaLoadData, int)} * @deprecated Implement {@link #onLoadStarted(EventTime, LoadEventInfo, MediaLoadData, int)}
* instead. * instead, and check for {@code retryCount == 0} for equivalent behavior.
*/ */
@UnstableApi @UnstableApi
@Deprecated @Deprecated

View File

@ -407,14 +407,13 @@ public class DefaultAnalyticsCollector implements AnalyticsCollector {
MediaLoadData mediaLoadData, MediaLoadData mediaLoadData,
int retryCount) { int retryCount) {
EventTime eventTime = generateMediaPeriodEventTime(windowIndex, mediaPeriodId); EventTime eventTime = generateMediaPeriodEventTime(windowIndex, mediaPeriodId);
sendEvent(
eventTime,
/* eventFlag= */ C.INDEX_UNSET,
listener -> listener.onLoadStarted(eventTime, loadEventInfo, mediaLoadData));
sendEvent( sendEvent(
eventTime, eventTime,
AnalyticsListener.EVENT_LOAD_STARTED, AnalyticsListener.EVENT_LOAD_STARTED,
listener -> listener.onLoadStarted(eventTime, loadEventInfo, mediaLoadData, retryCount)); listener -> {
listener.onLoadStarted(eventTime, loadEventInfo, mediaLoadData);
listener.onLoadStarted(eventTime, loadEventInfo, mediaLoadData, retryCount);
});
} }
@Override @Override

View File

@ -223,6 +223,15 @@ public interface MediaSourceEventListener {
} }
} }
/**
* @deprecated Use {link {@link #loadStarted(LoadEventInfo, int, int)} instead to pass {@code
* retryCount}.
*/
@Deprecated
public void loadStarted(LoadEventInfo loadEventInfo, @DataType int dataType) {
loadStarted(loadEventInfo, dataType, /* retryCount= */ 0);
}
/** Dispatches {@link #onLoadStarted(int, MediaPeriodId, LoadEventInfo, MediaLoadData, int)}. */ /** Dispatches {@link #onLoadStarted(int, MediaPeriodId, LoadEventInfo, MediaLoadData, int)}. */
public void loadStarted(LoadEventInfo loadEventInfo, @DataType int dataType, int retryCount) { public void loadStarted(LoadEventInfo loadEventInfo, @DataType int dataType, int retryCount) {
loadStarted( loadStarted(
@ -237,6 +246,32 @@ public interface MediaSourceEventListener {
retryCount); retryCount);
} }
/**
* @deprecated Use {link {@link #loadStarted(LoadEventInfo, int, int, Format, int, Object, long,
* long, int)} )} instead to pass {@code retryCount}.
*/
@Deprecated
public void loadStarted(
LoadEventInfo loadEventInfo,
@DataType int dataType,
@C.TrackType int trackType,
@Nullable Format trackFormat,
@C.SelectionReason int trackSelectionReason,
@Nullable Object trackSelectionData,
long mediaStartTimeUs,
long mediaEndTimeUs) {
loadStarted(
loadEventInfo,
new MediaLoadData(
dataType,
trackType,
trackFormat,
trackSelectionReason,
trackSelectionData,
usToMs(mediaStartTimeUs),
usToMs(mediaEndTimeUs)));
}
/** Dispatches {@link #onLoadStarted(int, MediaPeriodId, LoadEventInfo, MediaLoadData, int)}. */ /** Dispatches {@link #onLoadStarted(int, MediaPeriodId, LoadEventInfo, MediaLoadData, int)}. */
public void loadStarted( public void loadStarted(
LoadEventInfo loadEventInfo, LoadEventInfo loadEventInfo,
@ -261,6 +296,15 @@ public interface MediaSourceEventListener {
retryCount); retryCount);
} }
/**
* @deprecated Use {link {@link #loadStarted(LoadEventInfo, MediaLoadData, int)} instead to pass
* {@code retryCount}.
*/
@Deprecated
public void loadStarted(LoadEventInfo loadEventInfo, MediaLoadData mediaLoadData) {
loadStarted(loadEventInfo, mediaLoadData, /* retryCount= */ 0);
}
/** Dispatches {@link #onLoadStarted(int, MediaPeriodId, LoadEventInfo, MediaLoadData, int)}. */ /** Dispatches {@link #onLoadStarted(int, MediaPeriodId, LoadEventInfo, MediaLoadData, int)}. */
public void loadStarted( public void loadStarted(
LoadEventInfo loadEventInfo, MediaLoadData mediaLoadData, int retryCount) { LoadEventInfo loadEventInfo, MediaLoadData mediaLoadData, int retryCount) {

View File

@ -609,7 +609,7 @@ import org.checkerframework.checker.nullness.qual.MonotonicNonNull;
dataSource.getLastResponseHeaders(), dataSource.getLastResponseHeaders(),
elapsedRealtimeMs, elapsedRealtimeMs,
loadDurationMs, loadDurationMs,
/* bytesLoaded= */ 0); dataSource.getBytesRead());
mediaSourceEventDispatcher.loadStarted( mediaSourceEventDispatcher.loadStarted(
loadEventInfo, loadEventInfo,
C.DATA_TYPE_MEDIA, C.DATA_TYPE_MEDIA,

View File

@ -209,7 +209,7 @@ import org.checkerframework.checker.nullness.qual.MonotonicNonNull;
dataSource.getLastResponseHeaders(), dataSource.getLastResponseHeaders(),
elapsedRealtimeMs, elapsedRealtimeMs,
loadDurationMs, loadDurationMs,
/* bytesLoaded= */ 0); dataSource.getBytesRead());
eventDispatcher.loadStarted( eventDispatcher.loadStarted(
loadEventInfo, loadEventInfo,
C.DATA_TYPE_MEDIA, C.DATA_TYPE_MEDIA,

View File

@ -429,7 +429,7 @@ public final class ServerSideAdInsertionMediaSource extends BaseMediaSource
LoadEventInfo loadEventInfo, LoadEventInfo loadEventInfo,
MediaLoadData mediaLoadData, MediaLoadData mediaLoadData,
int retryCount) { int retryCount) {
// TODO file a bug to track updating this. // TODO: b/375408535 - Update this to support non-zero retry counts.
if (retryCount == 0) { if (retryCount == 0) {
@Nullable @Nullable
MediaPeriodImpl mediaPeriod = MediaPeriodImpl mediaPeriod =

View File

@ -440,7 +440,7 @@ public class ChunkSampleStream<T extends ChunkSource>
loadable.getResponseHeaders(), loadable.getResponseHeaders(),
elapsedRealtimeMs, elapsedRealtimeMs,
loadDurationMs, loadDurationMs,
/* bytesLoaded= */ 0), loadable.dataSource.getBytesRead()),
loadable.type, loadable.type,
primaryTrackType, primaryTrackType,
loadable.trackFormat, loadable.trackFormat,

View File

@ -146,10 +146,9 @@ import org.mockito.InOrder;
public final class DefaultAnalyticsCollectorTest { public final class DefaultAnalyticsCollectorTest {
// Deprecated event constants. // Deprecated event constants.
private static final long EVENT_PLAYER_STATE_CHANGED = 1L << 63; private static final long EVENT_PLAYER_STATE_CHANGED = Long.MIN_VALUE;
private static final long EVENT_SEEK_STARTED = 1L << 62; private static final long EVENT_SEEK_STARTED = Long.MIN_VALUE + 1;
// Start from +1 of the MIN because it will collide with 1L << 63 private static final long DEPRECATED_EVENT_LOAD_STARTED = Long.MIN_VALUE + 2;
private static final long DEPRECATED_EVENT_LOAD_STARTED = Long.MIN_VALUE + 1;
private static final UUID DRM_SCHEME_UUID = private static final UUID DRM_SCHEME_UUID =
UUID.nameUUIDFromBytes(TestUtil.createByteArray(7, 8, 9)); UUID.nameUUIDFromBytes(TestUtil.createByteArray(7, 8, 9));

View File

@ -642,7 +642,7 @@ public final class DashMediaSource extends BaseMediaSource {
loadable.getResponseHeaders(), loadable.getResponseHeaders(),
elapsedRealtimeMs, elapsedRealtimeMs,
loadDurationMs, loadDurationMs,
/* bytesLoaded= */ 0), loadable.bytesLoaded()),
loadable.type, loadable.type,
retryCount); retryCount);
} }

View File

@ -861,7 +861,7 @@ import org.checkerframework.checker.nullness.qual.RequiresNonNull;
loadable.getResponseHeaders(), loadable.getResponseHeaders(),
elapsedRealtimeMs, elapsedRealtimeMs,
loadDurationMs, loadDurationMs,
/* bytesLoaded= */ 0), loadable.bytesLoaded()),
loadable.type, loadable.type,
trackType, trackType,
loadable.trackFormat, loadable.trackFormat,

View File

@ -260,7 +260,7 @@ public final class DefaultHlsPlaylistTracker
loadable.getResponseHeaders(), loadable.getResponseHeaders(),
elapsedRealtimeMs, elapsedRealtimeMs,
loadDurationMs, loadDurationMs,
/* bytesLoaded= */ 0), loadable.bytesLoaded()),
loadable.type, loadable.type,
retryCount); retryCount);
} }

View File

@ -511,9 +511,9 @@ public final class SsMediaSource extends BaseMediaSource
loadable.getResponseHeaders(), loadable.getResponseHeaders(),
elapsedRealtimeMs, elapsedRealtimeMs,
loadDurationMs, loadDurationMs,
/* bytesLoaded= */ 0), loadable.bytesLoaded()),
loadable.type, loadable.type,
/* retryCount= */ 0); retryCount);
} }
@Override @Override
@ -678,12 +678,7 @@ public final class SsMediaSource extends BaseMediaSource
ParsingLoadable<SsManifest> loadable = ParsingLoadable<SsManifest> loadable =
new ParsingLoadable<>( new ParsingLoadable<>(
manifestDataSource, manifestUri, C.DATA_TYPE_MANIFEST, manifestParser); manifestDataSource, manifestUri, C.DATA_TYPE_MANIFEST, manifestParser);
long elapsedRealtimeMs = manifestLoader.startLoading(
manifestLoader.startLoading( loadable, this, loadErrorHandlingPolicy.getMinimumLoadableRetryCount(loadable.type));
loadable, this, loadErrorHandlingPolicy.getMinimumLoadableRetryCount(loadable.type));
manifestEventDispatcher.loadStarted(
new LoadEventInfo(loadable.loadTaskId, loadable.dataSpec, elapsedRealtimeMs),
loadable.type,
/* retryCount= */ 0);
} }
} }