Release 1.12.1 (#167)

* Expose streaming flags in java with jni (#160)

* expose streaming flags in java with jni

* remove set method from clientinfo

* add enum

* rename vars; create new constructor

* change case for enum name

* Add store pressure policy  (#162)

* change stream info def version, add storePressurePolicy

* use updated dylib

* update .so file for changed JNI

* fix constructor calls and retention in streaminfo

* remove windows build from ci

* update windows dll for 1.12.0

* update cpp jni libs from release 3.3.1

* update version in pom and readme

Author: niyatim23

.github/workflows/ci.yml

@@ -18,7 +18,7 @@ jobs:
       contents: read
     strategy:
       matrix:
-        os: [ macos-10.15, ubuntu-18.04, windows-2019 ]
+        os: [ macos-10.15, ubuntu-18.04, windows-2019]
         java: [ 8, 11, 16 ]
     steps:
       - name: Checkout the repository

README.md

@@ -66,7 +66,7 @@ $ mvn clean compile assembly:single
 
 Start the demo app
 ```
-$ java -classpath target/amazon-kinesis-video-streams-producer-sdk-java-1.12.0-jar-with-dependencies.jar -Daws.accessKeyId=<ACCESS_KEY> -Daws.secretKey=<SECRET_KEY> -Dkvs-stream=<KINESIS_VIDEO_STREAM_NAME> -Djava.library.path=<NativeLibraryPath> -Dlog4j.configurationFile=log4j2.xml com.amazonaws.kinesisvideo.demoapp.DemoAppMain
+$ java -classpath target/amazon-kinesis-video-streams-producer-sdk-java-1.12.1-jar-with-dependencies.jar -Daws.accessKeyId=<ACCESS_KEY> -Daws.secretKey=<SECRET_KEY> -Dkvs-stream=<KINESIS_VIDEO_STREAM_NAME> -Djava.library.path=<NativeLibraryPath> -Dlog4j.configurationFile=log4j2.xml com.amazonaws.kinesisvideo.demoapp.DemoAppMain
 
 ```
 ##### Run API and functionality tests
@@ -134,6 +134,10 @@ The repository is using `develop` branch as the aggregation and all of the featu
 
 ## Release Notes
 
+### Release 1.12.1 (May 2022)
+* Allow updating automaticStreamingFlags (default: AUTOMATIC_STREAMING_INTERMITTENT_PRODUCER) in ClientInfo
+* Allow updating storePressurePolicy (default: CONTENT_STORE_PRESSURE_POLICY_DROP_TAIL_ITEM) in StreamInfo
+
 ### Release 1.12.0 (February 2022)
 * Update guice from 4.2.3 to 5.1.0
 * Update junit from 4.13.1 to 4.13.2

pom.xml

@@ -15,7 +15,7 @@
     <groupId>com.amazonaws</groupId>
     <artifactId>amazon-kinesis-video-streams-producer-sdk-java</artifactId>
     <name>Amazon Kinesis Video Streams Producer SDK Java</name>
-    <version>1.12.0</version>
+    <version>1.12.1</version>
     <description>The Amazon Kinesis Video Streams Producer SDK for Java enables Java developers to ingest data into
         Amazon Kinesis Video.
     </description>

src/main/java/com/amazonaws/kinesisvideo/java/mediasource/file/ImageFileMediaSource.java

@@ -18,7 +18,7 @@
 import static com.amazonaws.kinesisvideo.util.StreamInfoConstants.REQUEST_FRAGMENT_ACKS;
 import static com.amazonaws.kinesisvideo.util.StreamInfoConstants.RETENTION_ONE_HOUR;
 import static com.amazonaws.kinesisvideo.util.StreamInfoConstants.USE_FRAME_TIMECODES;
-import static com.amazonaws.kinesisvideo.util.StreamInfoConstants.VERSION_ZERO;
+import static com.amazonaws.kinesisvideo.util.StreamInfoConstants.VERSION_TWO;
 
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
@@ -83,7 +83,7 @@ public MediaSourceConfiguration getConfiguration() {
 
     @Override
     public StreamInfo getStreamInfo() throws KinesisVideoException {
-        return new StreamInfo(VERSION_ZERO,
+        return new StreamInfo(VERSION_TWO,
                 streamName,
                 StreamInfo.StreamingType.STREAMING_TYPE_REALTIME,
                 imageFileMediaSourceConfiguration.getContentType(),

src/main/java/com/amazonaws/kinesisvideo/producer/ClientInfo.java

@@ -11,16 +11,31 @@ public class ClientInfo {
     /**
      * Current version for the structure as defined in the native code
      */
-    public static final int CLIENT_INFO_CURRENT_VERSION = 0;
+    public static final int CLIENT_INFO_CURRENT_VERSION = 2;
     public static final int DEFAULT_LOG_LEVEL = 4;
 
+    public static enum AutomaticStreamingFlags {
+        AUTOMATIC_STREAMING_INTERMITTENT_PRODUCER(0), AUTOMATIC_STREAMING_ALWAYS_CONTINUOUS(256);
+        private final int streamingFlagValue;
+
+        private AutomaticStreamingFlags(int streamingFlagValue) {
+            this.streamingFlagValue = streamingFlagValue;
+        }
+
+        public int getStreamingFlagValue() {
+            return streamingFlagValue;
+        }
+
+    }
+
     private final int mVersion;
     private final long mCreateClientTimeout;
     private final long mCreateStreamTimeout;
     private final long mStopStreamTimeout;
     private final long mOfflineBufferAvailabilityTimeout;
     private final int mLogLevel;
     private final boolean mLogMetric;
+    private final AutomaticStreamingFlags mAutomaticStreamingFlags;
 
     public ClientInfo() {
         mVersion = CLIENT_INFO_CURRENT_VERSION;
@@ -30,18 +45,27 @@ public ClientInfo() {
         mOfflineBufferAvailabilityTimeout = 0L;
         mLogLevel = DEFAULT_LOG_LEVEL;
         mLogMetric = true;
+        mAutomaticStreamingFlags = AutomaticStreamingFlags.AUTOMATIC_STREAMING_INTERMITTENT_PRODUCER;
     }
 
     public ClientInfo(final long createClientTimeout, final long createStreamTimeout, final long stopStreamTimeout,
-                      final long offlineBufferAvailabilityTimeout,
-                      final int logLevel, final boolean logMetric) {
+                      final long offlineBufferAvailabilityTimeout, final int logLevel,
+                      final boolean logMetric) {
+        this(createClientTimeout, createStreamTimeout, stopStreamTimeout, offlineBufferAvailabilityTimeout,
+                logLevel, logMetric, AutomaticStreamingFlags.AUTOMATIC_STREAMING_INTERMITTENT_PRODUCER);
+    }
+
+    public ClientInfo(final long createClientTimeout, final long createStreamTimeout, final long stopStreamTimeout,
+                      final long offlineBufferAvailabilityTimeout, final int logLevel,
+                      final boolean logMetric, final AutomaticStreamingFlags flag) {
         mVersion = CLIENT_INFO_CURRENT_VERSION;
         mCreateClientTimeout = createClientTimeout;
         mCreateStreamTimeout = createStreamTimeout;
         mStopStreamTimeout = stopStreamTimeout;
         mOfflineBufferAvailabilityTimeout = offlineBufferAvailabilityTimeout;
-        mLogLevel = DEFAULT_LOG_LEVEL;
+        mLogLevel = logLevel;
         mLogMetric = logMetric;
+        mAutomaticStreamingFlags = flag;
     }
 
     public int getVersion() {
@@ -71,4 +95,8 @@ public int getLoggerLogLevel() {
     public boolean getLogMetric() {
         return mLogMetric;
     }
+
+    public int getAutomaticStreamingFlags() {
+        return mAutomaticStreamingFlags.getStreamingFlagValue();
+    }
 }

src/main/java/com/amazonaws/kinesisvideo/producer/StreamInfo.java

@@ -29,7 +29,7 @@ public class StreamInfo {
      * StreamInfo structure current version.
      * IMPORTANT: Must be kept in sync with the native counterpart.
      */
-    public static final int STREAM_INFO_CURRENT_VERSION = 1;
+    public static final int STREAM_INFO_CURRENT_VERSION = 2;
 
     /**
      * Streaming types that must correspond to the native counterparts
@@ -113,6 +113,34 @@ public int getIntValue() {
         }
     }
 
+    /**
+     * Storage pressure policy that must correspond to the native counterparts
+     */
+    public static enum StorePressurePolicy {
+        /**
+         * Return an error STATUS_STORE_OUT_OF_MEMORY when we have no available storage when putting frame.
+         * The value of 0 is the default.
+         */
+        CONTENT_STORE_PRESSURE_POLICY_OOM(0),
+
+        /**
+         * Evict the earliest frames to make space for the new frame being put.
+         * Might result in dropped frame callbacks fired.
+         */
+        CONTENT_STORE_PRESSURE_POLICY_DROP_TAIL_ITEM(1);
+
+        private int value;
+
+        private StorePressurePolicy(final int i) {
+            value = i;
+        }
+
+        public int getIntValue() {
+            return value;
+        }
+    }
+
+
     private final int mVersion;
     private final String mName;
     private final StreamingType mStreamingType;
@@ -139,6 +167,7 @@ public int getIntValue() {
     private final TrackInfo[] mTrackInfoList;
     private final UUID mSegmentUuid;
     private final FrameOrderMode mFrameOrderMode;
+    private final StorePressurePolicy mStorePressurePolicy;
 
     /**
      * Generates a track name from a content type
@@ -262,6 +291,26 @@ public StreamInfo(final int version, @Nullable final String name, @Nonnull final
                       @Nullable final UUID segmentUuid,
                       @Nonnull final TrackInfo[] trackInfoList,
                       FrameOrderMode frameOrderMode) {
+        this(version, name, streamingType, contentType, kmsKeyId, retentionPeriod, adaptive, maxLatency,
+                fragmentDuration, keyFrameFragmentation, frameTimecodes, absoluteFragmentTimes, fragmentAcks,
+                recoverOnError, avgBandwidthBps, frameRate, bufferDuration, replayDuration,
+                connectionStalenessDuration, timecodeScale, recalculateMetrics, tags,
+                nalAdaptationFlags, segmentUuid, trackInfoList, frameOrderMode,
+                StorePressurePolicy.CONTENT_STORE_PRESSURE_POLICY_DROP_TAIL_ITEM);
+    }
+
+    public StreamInfo(final int version, @Nullable final String name, @Nonnull final StreamingType streamingType,
+                      @Nonnull final String contentType, @Nullable final String kmsKeyId, final long retentionPeriod,
+                      final boolean adaptive, final long maxLatency, final long fragmentDuration,
+                      final boolean keyFrameFragmentation, final boolean frameTimecodes,
+                      final boolean absoluteFragmentTimes, final boolean fragmentAcks, final boolean recoverOnError,
+                      final int avgBandwidthBps, final int frameRate, final long bufferDuration,
+                      final long replayDuration, final long connectionStalenessDuration, final long timecodeScale,
+                      final boolean recalculateMetrics, @Nullable final Tag[] tags,
+                      @Nonnull final NalAdaptationFlags nalAdaptationFlags,
+                      @Nullable final UUID segmentUuid,
+                      @Nonnull final TrackInfo[] trackInfoList,
+                      FrameOrderMode frameOrderMode, StorePressurePolicy storePressurePolicy) {
         mVersion = version;
         mName = name;
         mStreamingType = streamingType;
@@ -288,6 +337,7 @@ public StreamInfo(final int version, @Nullable final String name, @Nonnull final
         mSegmentUuid = segmentUuid;
         mTrackInfoList = trackInfoList;
         mFrameOrderMode = frameOrderMode;
+        mStorePressurePolicy = storePressurePolicy;
     }
 
     public int getVersion() {
@@ -466,4 +516,8 @@ public int getNalAdaptationFlags() {
     public int getFrameOrderMode() {
         return mFrameOrderMode.intValue();
     }
+
+    public int getStorePressurePolicy() {
+        return mStorePressurePolicy.getIntValue();
+    }
 }

src/main/java/com/amazonaws/kinesisvideo/util/StreamInfoConstants.java

@@ -22,6 +22,8 @@ public final class StreamInfoConstants {
     public static final boolean RELATIVE_FRAGMENT_TIMECODES = false;
     public static final String NO_KMS_KEY_ID = null;
     public static final int VERSION_ZERO = 0;
+    public static final int VERSION_ONE = 1;
+    public static final int VERSION_TWO = 2;
     public static final long MAX_LATENCY_ZERO = 0L; // latency set to 0 will never trigger latency pressure callback
     public static final long MAX_LATENCY = 120L * HUNDREDS_OF_NANOS_IN_A_SECOND;
     public static final long NO_RETENTION = 0L;