Index: webrtc/sdk/android/src/jni/pc/rtpreceiver_jni.cc |
diff --git a/webrtc/sdk/android/src/jni/ownedfactoryandthreads.cc b/webrtc/sdk/android/src/jni/pc/rtpreceiver_jni.cc |
similarity index 18% |
copy from webrtc/sdk/android/src/jni/ownedfactoryandthreads.cc |
copy to webrtc/sdk/android/src/jni/pc/rtpreceiver_jni.cc |
index a3aa45c4bead267acec36c6862cae84a9790d792..26148a8e20746ba5bf75e53401428ec5e65f8436 100644 |
--- a/webrtc/sdk/android/src/jni/ownedfactoryandthreads.cc |
+++ b/webrtc/sdk/android/src/jni/pc/rtpreceiver_jni.cc |
@@ -8,57 +8,72 @@ |
* be found in the AUTHORS file in the root of the source tree. |
*/ |
-#include "webrtc/sdk/android/src/jni/ownedfactoryandthreads.h" |
- |
-#include "webrtc/rtc_base/logging.h" |
-#include "webrtc/sdk/android/src/jni/classreferenceholder.h" |
+#include "webrtc/api/rtpreceiverinterface.h" |
#include "webrtc/sdk/android/src/jni/jni_helpers.h" |
+#include "webrtc/sdk/android/src/jni/pc/java_native_conversion.h" |
+#include "webrtc/sdk/android/src/jni/pc/rtpreceiverobserver_jni.h" |
namespace webrtc_jni { |
-PeerConnectionFactoryInterface* factoryFromJava(jlong j_p) { |
- return reinterpret_cast<OwnedFactoryAndThreads*>(j_p)->factory(); |
+JOW(jlong, RtpReceiver_nativeGetTrack) |
+(JNIEnv* jni, jclass, jlong j_rtp_receiver_pointer, jlong j_track_pointer) { |
+ return jlongFromPointer( |
+ reinterpret_cast<webrtc::RtpReceiverInterface*>(j_rtp_receiver_pointer) |
+ ->track() |
+ .release()); |
} |
-OwnedFactoryAndThreads::~OwnedFactoryAndThreads() { |
- CHECK_RELEASE(factory_); |
- if (network_monitor_factory_ != nullptr) { |
- rtc::NetworkMonitorFactory::ReleaseFactory(network_monitor_factory_); |
+JOW(jboolean, RtpReceiver_nativeSetParameters) |
+(JNIEnv* jni, jclass, jlong j_rtp_receiver_pointer, jobject j_parameters) { |
+ if (IsNull(jni, j_parameters)) { |
+ return false; |
} |
+ webrtc::RtpParameters parameters; |
+ JavaToNativeRtpParameters(jni, j_parameters, ¶meters); |
+ return reinterpret_cast<webrtc::RtpReceiverInterface*>(j_rtp_receiver_pointer) |
+ ->SetParameters(parameters); |
} |
-void OwnedFactoryAndThreads::JavaCallbackOnFactoryThreads() { |
- JNIEnv* jni = AttachCurrentThreadIfNeeded(); |
- ScopedLocalRefFrame local_ref_frame(jni); |
- jclass j_factory_class = FindClass(jni, "org/webrtc/PeerConnectionFactory"); |
- jmethodID m = nullptr; |
- if (network_thread_->IsCurrent()) { |
- LOG(LS_INFO) << "Network thread JavaCallback"; |
- m = GetStaticMethodID(jni, j_factory_class, "onNetworkThreadReady", "()V"); |
- } |
- if (worker_thread_->IsCurrent()) { |
- LOG(LS_INFO) << "Worker thread JavaCallback"; |
- m = GetStaticMethodID(jni, j_factory_class, "onWorkerThreadReady", "()V"); |
- } |
- if (signaling_thread_->IsCurrent()) { |
- LOG(LS_INFO) << "Signaling thread JavaCallback"; |
- m = GetStaticMethodID(jni, j_factory_class, "onSignalingThreadReady", |
- "()V"); |
- } |
- if (m != nullptr) { |
- jni->CallStaticVoidMethod(j_factory_class, m); |
- CHECK_EXCEPTION(jni) << "error during JavaCallback::CallStaticVoidMethod"; |
- } |
+JOW(jobject, RtpReceiver_nativeGetParameters) |
+(JNIEnv* jni, jclass, jlong j_rtp_receiver_pointer) { |
+ webrtc::RtpParameters parameters = |
+ reinterpret_cast<webrtc::RtpReceiverInterface*>(j_rtp_receiver_pointer) |
+ ->GetParameters(); |
+ return NativeToJavaRtpParameters(jni, parameters); |
+} |
+ |
+JOW(jstring, RtpReceiver_nativeId) |
+(JNIEnv* jni, jclass, jlong j_rtp_receiver_pointer) { |
+ return JavaStringFromStdString( |
+ jni, |
+ reinterpret_cast<webrtc::RtpReceiverInterface*>(j_rtp_receiver_pointer) |
+ ->id()); |
+} |
+ |
+JOW(void, RtpReceiver_free) |
+(JNIEnv* jni, jclass, jlong j_rtp_receiver_pointer) { |
+ reinterpret_cast<webrtc::RtpReceiverInterface*>(j_rtp_receiver_pointer) |
+ ->Release(); |
} |
-void OwnedFactoryAndThreads::InvokeJavaCallbacksOnFactoryThreads() { |
- LOG(LS_INFO) << "InvokeJavaCallbacksOnFactoryThreads."; |
- network_thread_->Invoke<void>(RTC_FROM_HERE, |
- [this] { JavaCallbackOnFactoryThreads(); }); |
- worker_thread_->Invoke<void>(RTC_FROM_HERE, |
- [this] { JavaCallbackOnFactoryThreads(); }); |
- signaling_thread_->Invoke<void>(RTC_FROM_HERE, |
- [this] { JavaCallbackOnFactoryThreads(); }); |
+JOW(jlong, RtpReceiver_nativeSetObserver) |
+(JNIEnv* jni, jclass, jlong j_rtp_receiver_pointer, jobject j_observer) { |
+ RtpReceiverObserverJni* rtpReceiverObserver = |
+ new RtpReceiverObserverJni(jni, j_observer); |
+ reinterpret_cast<webrtc::RtpReceiverInterface*>(j_rtp_receiver_pointer) |
+ ->SetObserver(rtpReceiverObserver); |
+ return jlongFromPointer(rtpReceiverObserver); |
+} |
+ |
+JOW(void, RtpReceiver_nativeUnsetObserver) |
+(JNIEnv* jni, jclass, jlong j_rtp_receiver_pointer, jlong j_observer_pointer) { |
+ reinterpret_cast<webrtc::RtpReceiverInterface*>(j_rtp_receiver_pointer) |
+ ->SetObserver(nullptr); |
+ RtpReceiverObserverJni* observer = |
+ reinterpret_cast<RtpReceiverObserverJni*>(j_observer_pointer); |
+ if (observer) { |
+ delete observer; |
+ } |
} |
} // namespace webrtc_jni |