feat: add SyncClock for audio and video synchronization support

Author: devopvoid

webrtc-jni/src/main/cpp/include/JNI_CustomAudioSource.h

@@ -30,6 +30,18 @@ JNIEXPORT void JNICALL Java_dev_onvoid_webrtc_media_audio_CustomAudioSource_init
     SetHandle(env, caller, source.release());
 }
 
+JNIEXPORT void JNICALL Java_dev_onvoid_webrtc_media_audio_CustomAudioSource_initializeWithClock
+(JNIEnv * env, jobject caller, jobject javaClock)
+{
+    jni::SyncClock * clock = GetHandle<jni::SyncClock>(env, javaClock);
+    CHECK_HANDLE(clock);
+
+    std::shared_ptr<jni::SyncClock> sync_clock(clock, [](jni::SyncClock*) {});  // Shared ownership without deleting
+    webrtc::scoped_refptr<jni::CustomAudioSource> source = webrtc::make_ref_counted<jni::CustomAudioSource>(sync_clock);
+
+    SetHandle(env, caller, source.release());
+}
+
 JNIEXPORT void JNICALL Java_dev_onvoid_webrtc_media_audio_CustomAudioSource_dispose
 (JNIEnv * env, jobject caller)
 {

webrtc-jni/src/main/cpp/include/JNI_CustomVideoSource.h

@@ -31,6 +31,18 @@ JNIEXPORT void JNICALL Java_dev_onvoid_webrtc_media_video_CustomVideoSource_init
     SetHandle(env, caller, source.release());
 }
 
+JNIEXPORT void JNICALL Java_dev_onvoid_webrtc_media_video_CustomVideoSource_initializeWithClock
+(JNIEnv * env, jobject caller, jobject javaClock)
+{
+    jni::SyncClock * clock = GetHandle<jni::SyncClock>(env, javaClock);
+    CHECK_HANDLE(clock);
+
+    std::shared_ptr<jni::SyncClock> sync_clock(clock, [](jni::SyncClock*) {});  // Shared ownership without deleting
+    webrtc::scoped_refptr<jni::CustomVideoSource> source = webrtc::make_ref_counted<jni::CustomVideoSource>(sync_clock);
+
+    SetHandle(env, caller, source.release());
+}
+
 JNIEXPORT void JNICALL Java_dev_onvoid_webrtc_media_video_CustomVideoSource_dispose
 (JNIEnv * env, jobject caller)
 {

webrtc-jni/src/main/cpp/include/JNI_SyncClock.h

@@ -0,0 +1,66 @@
+/*
+ * Copyright 2019 Alex Andres
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include "JNI_SyncClock.h"
+#include "JavaUtils.h"
+#include "media/SyncClock.h"
+
+JNIEXPORT void JNICALL Java_dev_onvoid_webrtc_media_SyncClock_initialize
+(JNIEnv * env, jobject caller)
+{
+    jni::SyncClock * clock = new jni::SyncClock();
+    
+    SetHandle(env, caller, clock);
+}
+
+JNIEXPORT jlong JNICALL Java_dev_onvoid_webrtc_media_SyncClock_getTimestampUs
+(JNIEnv * env, jobject caller)
+{
+    jni::SyncClock * clock = GetHandle<jni::SyncClock>(env, caller);
+    CHECK_HANDLEV(clock, 0);
+    
+    return clock->GetTimestampUs();
+}
+
+JNIEXPORT jlong JNICALL Java_dev_onvoid_webrtc_media_SyncClock_getTimestampMs
+(JNIEnv * env, jobject caller)
+{
+    jni::SyncClock * clock = GetHandle<jni::SyncClock>(env, caller);
+    CHECK_HANDLEV(clock, 0);
+    
+    return clock->GetTimestampMs();
+}
+
+JNIEXPORT jlong JNICALL Java_dev_onvoid_webrtc_media_SyncClock_getNtpTime
+(JNIEnv * env, jobject caller)
+{
+    jni::SyncClock * clock = GetHandle<jni::SyncClock>(env, caller);
+    CHECK_HANDLEV(clock, 0);
+    
+    webrtc::NtpTime ntpTime = clock->GetNtpTime();
+    return ntpTime.ToMs();
+}
+
+JNIEXPORT void JNICALL Java_dev_onvoid_webrtc_media_SyncClock_dispose
+(JNIEnv * env, jobject caller)
+{
+    jni::SyncClock * clock = GetHandle<jni::SyncClock>(env, caller);
+    CHECK_HANDLE(clock);
+    
+    delete clock;
+    
+    SetHandle<std::nullptr_t>(env, caller, nullptr);
+}

webrtc-jni/src/main/cpp/src/JNI_CustomAudioSource.cpp

@@ -0,0 +1,71 @@
+/*
+ * Copyright 2019 Alex Andres
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package dev.onvoid.webrtc.media;
+
+import dev.onvoid.webrtc.internal.NativeObject;
+
+/**
+ * Synchronized Clock for A/V timing. Provides timing functionality for
+ * audio and video synchronization.
+ *
+ * @author Alex Andres
+ */
+public class SyncClock extends NativeObject {
+
+    /**
+     * Constructs a new SyncClock instance.
+     */
+    public SyncClock() {
+        super();
+
+        initialize();
+    }
+
+    /**
+     * Get the current timestamp in microseconds.
+     *
+     * @return The current timestamp in microseconds.
+     */
+    public native long getTimestampUs();
+
+    /**
+     * Get the current timestamp in milliseconds.
+     *
+     * @return The current timestamp in milliseconds.
+     */
+    public native long getTimestampMs();
+
+    /**
+     * Get NTP timestamp for RTP synchronization.
+     *
+     * @return The NTP timestamp.
+     */
+    public native long getNtpTime();
+
+    /**
+     * Disposes of any native resources held by this clock.
+     * This method should be called when the clock is no longer needed
+     * to prevent memory leaks.
+     */
+    public native void dispose();
+
+    /**
+     * Initializes the native resources required by this clock.
+     */
+    private native void initialize();
+
+}

webrtc-jni/src/main/cpp/src/JNI_CustomVideoSource.cpp

@@ -16,6 +16,8 @@
 
 package dev.onvoid.webrtc.media.audio;
 
+import dev.onvoid.webrtc.media.SyncClock;
+
 /**
  * Custom implementation of an audio source for WebRTC that allows pushing audio data
  * from external sources directly to the WebRTC audio pipeline.
@@ -33,6 +35,17 @@ public CustomAudioSource() {
 		initialize();
 	}
 
+	/**
+	 * Constructs a new CustomAudioSource instance with a specified SyncClock.
+	 *
+	 * @param clock The SyncClock to use for timing and synchronization.
+	 */
+	public CustomAudioSource(SyncClock clock) {
+		super();
+
+		initializeWithClock(clock);
+	}
+
 	/**
 	 * Pushes audio data to be processed by this audio source.
 	 *
@@ -57,4 +70,11 @@ public native void pushAudio(byte[] audioData, int bits_per_sample,
 	 */
 	private native void initialize();
 
+	/**
+	 * Initializes the native resources required by this audio source with a specified SyncClock.
+	 *
+	 * @param clock The SyncClock to use for timing and synchronization.
+	 */
+	private native void initializeWithClock(SyncClock clock);
+
 }

webrtc-jni/src/main/cpp/src/JNI_SyncClock.cpp

@@ -16,6 +16,8 @@
 
 package dev.onvoid.webrtc.media.video;
 
+import dev.onvoid.webrtc.media.SyncClock;
+
 /**
  * Custom implementation of a video source for WebRTC that allows pushing video frames
  * from external sources directly to the WebRTC video pipeline.
@@ -33,6 +35,17 @@ public CustomVideoSource() {
 		initialize();
 	}
 
+	/**
+	 * Constructs a new CustomVideoSource instance with a specified SyncClock.
+	 *
+	 * @param clock The SyncClock to use for timing and synchronization.
+	 */
+	public CustomVideoSource(SyncClock clock) {
+		super();
+
+		initializeWithClock(clock);
+	}
+
 	/**
 	 * Pushes audio data to be processed by this audio source.
 	 *
@@ -52,4 +65,11 @@ public CustomVideoSource() {
 	 */
 	private native void initialize();
 
+	/**
+	 * Initializes the native resources required by this video source with a specified SyncClock.
+	 *
+	 * @param clock The SyncClock to use for timing and synchronization.
+	 */
+	private native void initializeWithClock(SyncClock clock);
+
 }