Add Java binding for new getStats implementation.

webrtc/sdk/android/src/jni/peerconnection_jni.cc

 /*
  *  Copyright 2013 The WebRTC project authors. All Rights Reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 821 matching lines @@
   }
 
   const ScopedGlobalRef<jobject> j_observer_global_;
   const ScopedGlobalRef<jclass> j_observer_class_;
   const ScopedGlobalRef<jclass> j_stats_report_class_;
   const jmethodID j_stats_report_ctor_;
   const ScopedGlobalRef<jclass> j_value_class_;
   const jmethodID j_value_ctor_;
 };
 
+// Adapter for a Java RTCStatsCollectorCallback presenting a C++
+// RTCStatsCollectorCallback and dispatching the callback from C++ back to
+// Java.
+class RTCStatsCollectorCallbackWrapper
+    : public webrtc::RTCStatsCollectorCallback {
+ public:
+  RTCStatsCollectorCallbackWrapper(JNIEnv* jni, jobject j_callback)
+      : j_callback_global_(jni, j_callback),
+        j_callback_class_(jni, GetObjectClass(jni, j_callback)),
+        j_stats_report_class_(jni, FindClass(jni, "org/webrtc/RTCStatsReport")),
+        j_stats_report_ctor_(GetMethodID(jni,
+                                         *j_stats_report_class_,
+                                         "<init>",
+                                         "(JLjava/util/SortedMap;)V")),
+        j_stats_class_(jni, FindClass(jni, "org/webrtc/RTCStats")),
+        j_stats_ctor_(GetMethodID(
+            jni,
+            *j_stats_class_,
+            "<init>",
+            "(JLjava/lang/String;Ljava/lang/String;Ljava/util/SortedMap;)V")),
+        j_tree_map_class_(jni, FindClass(jni, "java/util/TreeMap")),
+        j_tree_map_ctor_(GetMethodID(jni, *j_tree_map_class_, "<init>", "()V")),
+        j_tree_map_put_(GetMethodID(
+            jni,
+            *j_tree_map_class_,
+            "put",
+            "(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;")),
+        j_boolean_class_(jni, FindClass(jni, "java/lang/Boolean")),
+        j_boolean_ctor_(GetMethodID(jni, *j_boolean_class_, "<init>", "(Z)V")),
+        j_integer_class_(jni, FindClass(jni, "java/lang/Integer")),
+        j_integer_ctor_(GetMethodID(jni, *j_integer_class_, "<init>", "(I)V")),
+        j_long_class_(jni, FindClass(jni, "java/lang/Long")),
+        j_long_ctor_(GetMethodID(jni, *j_long_class_, "<init>", "(J)V")),
+        j_big_integer_class_(jni, FindClass(jni, "java/math/BigInteger")),
+        j_big_integer_ctor_(GetMethodID(jni,
+                                        *j_big_integer_class_,
+                                        "<init>",
+                                        "(Ljava/lang/String;)V")),
+        j_double_class_(jni, FindClass(jni, "java/lang/Double")),
+        j_double_ctor_(GetMethodID(jni, *j_double_class_, "<init>", "(D)V")),
+        j_string_class_(jni, FindClass(jni, "java/lang/String")) {}
+
+  void OnStatsDelivered(
+      const rtc::scoped_refptr<const webrtc::RTCStatsReport>& report) override {
+    JNIEnv* jni = AttachCurrentThreadIfNeeded();
+    ScopedLocalRefFrame local_ref_frame(jni);
+    jobject j_report = ReportToJava(jni, report);
+    jmethodID m = GetMethodID(jni, *j_callback_class_, "onStatsDelivered",
+                              "(Lorg/webrtc/RTCStatsReport;)V");
+    jni->CallVoidMethod(*j_callback_global_, m, j_report);
+    CHECK_EXCEPTION(jni) << "error during CallVoidMethod";
+  }
+
+ private:
+  jobject ReportToJava(
+      JNIEnv* jni,
+      const rtc::scoped_refptr<const webrtc::RTCStatsReport>& report) {
+    jobject j_stats_map = jni->NewObject(*j_tree_map_class_, j_tree_map_ctor_);
+    CHECK_EXCEPTION(jni) << "error during NewObject";
+    for (const webrtc::RTCStats& stats : *report) {
+      ScopedLocalRefFrame local_ref_frame(jni);

[hbos, 2017/04/10 10:19:42]

If we should use ScopedLocalRefFrame for each scope we should have this in the
beginning of each function as well. However, I think because these are private
helper functions we can skip ScopedLocalRefFrame altogether relying on each
entrance point from C++ to JNI (that is, OnStatsDelivered) having done the
necessary ScopedLocalRefFrame already.

[Taylor Brandstetter, 2017/04/10 23:59:33]

Confession: I was just copying the pattern of the previous code without really
understanding why it was necessary. I agree it appears pointless; removing.

EDIT: Oh, it was necessary after all. When I removed it I got:

"JNI ERROR (app bug): local reference table overflow (max=512)"

I guess you can only have 512 local references, and there can easily be more
than 512 things in the stats.

[hbos, 2017/04/11 09:36:13]

Confession: I was just guessing how this JNI stuff works. Good that you caught
the overflow!

+      jstring j_id = JavaStringFromStdString(jni, stats.id());
+      jobject j_stats = StatsToJava(jni, stats);
+      jni->CallObjectMethod(j_stats_map, j_tree_map_put_, j_id, j_stats);
+      CHECK_EXCEPTION(jni) << "error during CallObjectMethod";
+    }
+    jobject j_report =
+        jni->NewObject(*j_stats_report_class_, j_stats_report_ctor_,
+                       report->timestamp_us(), j_stats_map);
+    CHECK_EXCEPTION(jni) << "error during NewObject";
+    return j_report;
+  }
+
+  jobject StatsToJava(JNIEnv* jni, const webrtc::RTCStats& stats) {
+    jstring j_type = JavaStringFromStdString(jni, stats.type());
+    jstring j_id = JavaStringFromStdString(jni, stats.id());
+    jobject j_members = jni->NewObject(*j_tree_map_class_, j_tree_map_ctor_);
+    for (const webrtc::RTCStatsMemberInterface* member : stats.Members()) {
+      if (!member->is_defined()) {
+        continue;
+      }
+      ScopedLocalRefFrame local_ref_frame(jni);
+      jstring j_name = JavaStringFromStdString(jni, member->name());
+      jobject j_member = MemberToJava(jni, member);
+      jni->CallObjectMethod(j_members, j_tree_map_put_, j_name, j_member);
+      CHECK_EXCEPTION(jni) << "error during CallObjectMethod";
+    }
+    jobject j_stats =
+        jni->NewObject(*j_stats_class_, j_stats_ctor_, stats.timestamp_us(),
+                       j_type, j_id, j_members);
+    CHECK_EXCEPTION(jni) << "error during NewObject";
+    return j_stats;
+  }
+
+  jobject MemberToJava(JNIEnv* jni,
+                       const webrtc::RTCStatsMemberInterface* member) {
+    switch (member->type()) {
+      case webrtc::RTCStatsMemberInterface::kBool: {
+        jobject value =
+            jni->NewObject(*j_boolean_class_, j_boolean_ctor_,
+                           *member->cast_to<webrtc::RTCStatsMember<bool>>());
+        CHECK_EXCEPTION(jni) << "error during NewObject";
+        return value;
+      }
+      case webrtc::RTCStatsMemberInterface::kInt32: {
+        jobject value =
+            jni->NewObject(*j_integer_class_, j_integer_ctor_,
+                           *member->cast_to<webrtc::RTCStatsMember<int32_t>>());
+        CHECK_EXCEPTION(jni) << "error during NewObject";
+        return value;
+      }
+      case webrtc::RTCStatsMemberInterface::kUint32: {
+        jobject value = jni->NewObject(
+            *j_long_class_, j_long_ctor_,
+            (jlong)*member->cast_to<webrtc::RTCStatsMember<uint32_t>>());
+        CHECK_EXCEPTION(jni) << "error during NewObject";
+        return value;
+      }
+      case webrtc::RTCStatsMemberInterface::kInt64: {
+        jobject value =
+            jni->NewObject(*j_long_class_, j_long_ctor_,
+                           *member->cast_to<webrtc::RTCStatsMember<int64_t>>());
+        CHECK_EXCEPTION(jni) << "error during NewObject";
+        return value;
+      }
+      case webrtc::RTCStatsMemberInterface::kUint64: {
+        jobject value = jni->NewObject(
+            *j_big_integer_class_, j_big_integer_ctor_,
+            JavaStringFromStdString(jni, member->ValueToString()));
+        CHECK_EXCEPTION(jni) << "error during NewObject";
+        return value;
+      }
+      case webrtc::RTCStatsMemberInterface::kDouble: {
+        jobject value =
+            jni->NewObject(*j_double_class_, j_double_ctor_,
+                           *member->cast_to<webrtc::RTCStatsMember<double>>());
+        CHECK_EXCEPTION(jni) << "error during NewObject";
+        return value;
+      }
+      case webrtc::RTCStatsMemberInterface::kString: {
+        return JavaStringFromStdString(
+            jni, *member->cast_to<webrtc::RTCStatsMember<std::string>>());
+      }
+      case webrtc::RTCStatsMemberInterface::kSequenceBool: {
+        const std::vector<bool>& values =
+            *member->cast_to<webrtc::RTCStatsMember<std::vector<bool>>>();
+        jobjectArray j_values =
+            jni->NewObjectArray(values.size(), *j_boolean_class_, nullptr);
+        CHECK_EXCEPTION(jni) << "error during NewObjectArray";
+        for (size_t i = 0; i < values.size(); ++i) {
+          jobject value =
+              jni->NewObject(*j_boolean_class_, j_boolean_ctor_, values[i]);
+          jni->SetObjectArrayElement(j_values, i, value);
+          CHECK_EXCEPTION(jni) << "error during SetObjectArrayElement";
+        }
+        return j_values;
+      }
+      case webrtc::RTCStatsMemberInterface::kSequenceInt32: {
+        const std::vector<int32_t>& values =
+            *member->cast_to<webrtc::RTCStatsMember<std::vector<int32_t>>>();
+        jobjectArray j_values =
+            jni->NewObjectArray(values.size(), *j_integer_class_, nullptr);
+        CHECK_EXCEPTION(jni) << "error during NewObjectArray";
+        for (size_t i = 0; i < values.size(); ++i) {
+          jobject value =
+              jni->NewObject(*j_integer_class_, j_integer_ctor_, values[i]);
+          jni->SetObjectArrayElement(j_values, i, value);
+          CHECK_EXCEPTION(jni) << "error during SetObjectArrayElement";
+        }
+        return j_values;
+      }
+      case webrtc::RTCStatsMemberInterface::kSequenceUint32: {
+        const std::vector<uint32_t>& values =
+            *member->cast_to<webrtc::RTCStatsMember<std::vector<uint32_t>>>();
+        jobjectArray j_values =
+            jni->NewObjectArray(values.size(), *j_long_class_, nullptr);
+        CHECK_EXCEPTION(jni) << "error during NewObjectArray";
+        for (size_t i = 0; i < values.size(); ++i) {
+          jobject value =
+              jni->NewObject(*j_long_class_, j_long_ctor_, values[i]);
+          jni->SetObjectArrayElement(j_values, i, value);
+          CHECK_EXCEPTION(jni) << "error during SetObjectArrayElement";
+        }
+        return j_values;
+      }
+      case webrtc::RTCStatsMemberInterface::kSequenceInt64: {
+        const std::vector<int64_t>& values =
+            *member->cast_to<webrtc::RTCStatsMember<std::vector<int64_t>>>();
+        jobjectArray j_values =
+            jni->NewObjectArray(values.size(), *j_long_class_, nullptr);
+        CHECK_EXCEPTION(jni) << "error during NewObjectArray";
+        for (size_t i = 0; i < values.size(); ++i) {
+          jobject value =
+              jni->NewObject(*j_long_class_, j_long_ctor_, values[i]);
+          jni->SetObjectArrayElement(j_values, i, value);
+          CHECK_EXCEPTION(jni) << "error during SetObjectArrayElement";
+        }
+        return j_values;
+      }
+      case webrtc::RTCStatsMemberInterface::kSequenceUint64: {
+        const std::vector<uint64_t>& values =
+            *member->cast_to<webrtc::RTCStatsMember<std::vector<uint64_t>>>();
+        jobjectArray j_values =
+            jni->NewObjectArray(values.size(), *j_big_integer_class_, nullptr);
+        CHECK_EXCEPTION(jni) << "error during NewObjectArray";
+        for (size_t i = 0; i < values.size(); ++i) {
+          jobject value = jni->NewObject(
+              *j_big_integer_class_, j_big_integer_ctor_,
+              JavaStringFromStdString(jni, rtc::ToString(values[i])));
+          jni->SetObjectArrayElement(j_values, i, value);
+          CHECK_EXCEPTION(jni) << "error during SetObjectArrayElement";
+        }
+        return j_values;
+      }
+      case webrtc::RTCStatsMemberInterface::kSequenceDouble: {
+        const std::vector<double>& values =
+            *member->cast_to<webrtc::RTCStatsMember<std::vector<double>>>();
+        jobjectArray j_values =
+            jni->NewObjectArray(values.size(), *j_double_class_, nullptr);
+        CHECK_EXCEPTION(jni) << "error during NewObjectArray";
+        for (size_t i = 0; i < values.size(); ++i) {
+          jobject value =
+              jni->NewObject(*j_double_class_, j_double_ctor_, values[i]);
+          jni->SetObjectArrayElement(j_values, i, value);
+          CHECK_EXCEPTION(jni) << "error during SetObjectArrayElement";
+        }
+        return j_values;
+      }
+      case webrtc::RTCStatsMemberInterface::kSequenceString: {
+        const std::vector<std::string>& values =
+            *member
+                 ->cast_to<webrtc::RTCStatsMember<std::vector<std::string>>>();
+        jobjectArray j_values =
+            jni->NewObjectArray(values.size(), *j_string_class_, nullptr);
+        CHECK_EXCEPTION(jni) << "error during NewObjectArray";
+        for (size_t i = 0; i < values.size(); ++i) {
+          jni->SetObjectArrayElement(j_values, i,
+                                     JavaStringFromStdString(jni, values[i]));
+          CHECK_EXCEPTION(jni) << "error during SetObjectArrayElement";
+        }
+        return j_values;
+      }
+    }
+    RTC_NOTREACHED();
+    return nullptr;
+  }
+
+  const ScopedGlobalRef<jobject> j_callback_global_;
+  const ScopedGlobalRef<jclass> j_callback_class_;
+  const ScopedGlobalRef<jclass> j_stats_report_class_;
+  const jmethodID j_stats_report_ctor_;
+  const ScopedGlobalRef<jclass> j_stats_class_;
+  const jmethodID j_stats_ctor_;
+  const ScopedGlobalRef<jclass> j_tree_map_class_;
+  const jmethodID j_tree_map_ctor_;
+  const jmethodID j_tree_map_put_;
+  const ScopedGlobalRef<jclass> j_boolean_class_;
+  const jmethodID j_boolean_ctor_;
+  const ScopedGlobalRef<jclass> j_integer_class_;
+  const jmethodID j_integer_ctor_;
+  const ScopedGlobalRef<jclass> j_long_class_;
+  const jmethodID j_long_ctor_;
+  const ScopedGlobalRef<jclass> j_big_integer_class_;
+  const jmethodID j_big_integer_ctor_;
+  const ScopedGlobalRef<jclass> j_double_class_;
+  const jmethodID j_double_ctor_;
+  const ScopedGlobalRef<jclass> j_string_class_;
+};
+
 // Wrapper dispatching rtc::VideoSinkInterface to a Java VideoRenderer
 // instance.
 class JavaVideoRendererWrapper
     : public rtc::VideoSinkInterface<webrtc::VideoFrame> {
  public:
   JavaVideoRendererWrapper(JNIEnv* jni, jobject j_callbacks)
       : j_callbacks_(jni, j_callbacks),
         j_render_frame_id_(GetMethodID(
             jni, GetObjectClass(jni, j_callbacks), "renderFrame",
             "(Lorg/webrtc/VideoRenderer$I420Frame;)V")),
@@ skipping 1262 matching lines @@
                                         j_rtp_receiver_ctor, nativeReceiverPtr);
     CHECK_EXCEPTION(jni) << "error during NewObject";
     // Receiver is now owned by Java object, and will be freed from there.
     receiver->AddRef();
     jni->CallBooleanMethod(j_receivers, j_array_list_add, j_receiver);
     CHECK_EXCEPTION(jni) << "error during CallBooleanMethod";
   }
   return j_receivers;
 }
 
-JOW(bool, PeerConnection_nativeGetStats)(
-    JNIEnv* jni, jobject j_pc, jobject j_observer, jlong native_track) {
+JOW(bool, PeerConnection_nativeOldGetStats)
+(JNIEnv* jni, jobject j_pc, jobject j_observer, jlong native_track) {
   rtc::scoped_refptr<StatsObserverWrapper> observer(
       new rtc::RefCountedObject<StatsObserverWrapper>(jni, j_observer));
   return ExtractNativePC(jni, j_pc)->GetStats(
       observer,
       reinterpret_cast<MediaStreamTrackInterface*>(native_track),
       PeerConnectionInterface::kStatsOutputLevelStandard);
 }
 
+JOW(void, PeerConnection_nativeNewGetStats)
+(JNIEnv* jni, jobject j_pc, jobject j_callback) {
+  rtc::scoped_refptr<RTCStatsCollectorCallbackWrapper> callback(
+      new rtc::RefCountedObject<RTCStatsCollectorCallbackWrapper>(jni,
+                                                                  j_callback));
+  ExtractNativePC(jni, j_pc)->GetStats(callback);
+}
+
 JOW(bool, PeerConnection_nativeStartRtcEventLog)(
     JNIEnv* jni, jobject j_pc, int file_descriptor, int max_size_bytes) {
   return ExtractNativePC(jni, j_pc)->StartRtcEventLog(file_descriptor,
                                                       max_size_bytes);
 }
 
 JOW(void, PeerConnection_nativeStopRtcEventLog)(JNIEnv* jni, jobject j_pc) {
   ExtractNativePC(jni, j_pc)->StopRtcEventLog();
 }
 
@@ skipping 583 matching lines @@
   return reinterpret_cast<DtmfSenderInterface*>(j_dtmf_sender_pointer)
       ->inter_tone_gap();
 }
 
 JOW(void, DtmfSender_free)
 (JNIEnv* jni, jclass, jlong j_dtmf_sender_pointer) {
   reinterpret_cast<DtmfSenderInterface*>(j_dtmf_sender_pointer)->Release();
 }
 
 }  // namespace webrtc_jni