Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(607)

Side by Side Diff: webrtc/api/android/jni/peerconnection_jni.cc

Issue 2547483003: Move /webrtc/api/android files to /webrtc/sdk/android (Closed)
Patch Set: Move to api folder under Android instead of src Created 4 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
(Empty)
1 /*
2 * Copyright 2013 The WebRTC project authors. All Rights Reserved.
3 *
4 * Use of this source code is governed by a BSD-style license
5 * that can be found in the LICENSE file in the root of the source
6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree.
9 */
10
11 // Hints for future visitors:
12 // This entire file is an implementation detail of the org.webrtc Java package,
13 // the most interesting bits of which are org.webrtc.PeerConnection{,Factory}.
14 // The layout of this file is roughly:
15 // - various helper C++ functions & classes that wrap Java counterparts and
16 // expose a C++ interface that can be passed to the C++ PeerConnection APIs
17 // - implementations of methods declared "static" in the Java package (named
18 // things like Java_org_webrtc_OMG_Can_This_Name_Be_Any_Longer, prescribed by
19 // the JNI spec).
20 //
21 // Lifecycle notes: objects are owned where they will be called; in other words
22 // FooObservers are owned by C++-land, and user-callable objects (e.g.
23 // PeerConnection and VideoTrack) are owned by Java-land.
24 // When this file allocates C++ RefCountInterfaces it AddRef()s an artificial
25 // ref simulating the jlong held in Java-land, and then Release()s the ref in
26 // the respective free call. Sometimes this AddRef is implicit in the
27 // construction of a scoped_refptr<> which is then .release()d.
28 // Any persistent (non-local) references from C++ to Java must be global or weak
29 // (in which case they must be checked before use)!
30 //
31 // Exception notes: pretty much all JNI calls can throw Java exceptions, so each
32 // call through a JNIEnv* pointer needs to be followed by an ExceptionCheck()
33 // call. In this file this is done in CHECK_EXCEPTION, making for much easier
34 // debugging in case of failure (the alternative is to wait for control to
35 // return to the Java frame that called code in this file, at which point it's
36 // impossible to tell which JNI call broke).
37
38 #include <jni.h>
39 #undef JNIEXPORT
40 #define JNIEXPORT __attribute__((visibility("default")))
41
42 #include <limits>
43 #include <memory>
44 #include <utility>
45
46 #include "third_party/libyuv/include/libyuv/convert_from.h"
47 #include "third_party/libyuv/include/libyuv/scale.h"
48 #include "webrtc/api/android/jni/androidmediadecoder_jni.h"
49 #include "webrtc/api/android/jni/androidmediaencoder_jni.h"
50 #include "webrtc/api/android/jni/androidnetworkmonitor_jni.h"
51 #include "webrtc/api/android/jni/androidvideotracksource.h"
52 #include "webrtc/api/android/jni/classreferenceholder.h"
53 #include "webrtc/api/android/jni/jni_helpers.h"
54 #include "webrtc/api/android/jni/native_handle_impl.h"
55 #include "webrtc/api/mediaconstraintsinterface.h"
56 #include "webrtc/api/peerconnectioninterface.h"
57 #include "webrtc/api/rtpreceiverinterface.h"
58 #include "webrtc/api/rtpsenderinterface.h"
59 #include "webrtc/api/videosourceproxy.h"
60 #include "webrtc/api/webrtcsdp.h"
61 #include "webrtc/base/bind.h"
62 #include "webrtc/base/checks.h"
63 #include "webrtc/base/event_tracer.h"
64 #include "webrtc/base/logging.h"
65 #include "webrtc/base/logsinks.h"
66 #include "webrtc/base/messagequeue.h"
67 #include "webrtc/base/networkmonitor.h"
68 #include "webrtc/base/rtccertificategenerator.h"
69 #include "webrtc/base/ssladapter.h"
70 #include "webrtc/base/stringutils.h"
71 #include "webrtc/media/base/videocapturer.h"
72 #include "webrtc/media/engine/webrtcvideodecoderfactory.h"
73 #include "webrtc/media/engine/webrtcvideoencoderfactory.h"
74 #include "webrtc/system_wrappers/include/field_trial_default.h"
75 #include "webrtc/system_wrappers/include/logcat_trace_context.h"
76 #include "webrtc/system_wrappers/include/trace.h"
77 #include "webrtc/voice_engine/include/voe_base.h"
78
79 using cricket::WebRtcVideoDecoderFactory;
80 using cricket::WebRtcVideoEncoderFactory;
81 using rtc::Bind;
82 using rtc::Thread;
83 using rtc::ThreadManager;
84 using webrtc::AudioSourceInterface;
85 using webrtc::AudioTrackInterface;
86 using webrtc::AudioTrackVector;
87 using webrtc::CreateSessionDescriptionObserver;
88 using webrtc::DataBuffer;
89 using webrtc::DataChannelInit;
90 using webrtc::DataChannelInterface;
91 using webrtc::DataChannelObserver;
92 using webrtc::IceCandidateInterface;
93 using webrtc::LogcatTraceContext;
94 using webrtc::MediaConstraintsInterface;
95 using webrtc::MediaSourceInterface;
96 using webrtc::MediaStreamInterface;
97 using webrtc::MediaStreamTrackInterface;
98 using webrtc::PeerConnectionFactoryInterface;
99 using webrtc::PeerConnectionInterface;
100 using webrtc::PeerConnectionObserver;
101 using webrtc::RtpReceiverInterface;
102 using webrtc::RtpSenderInterface;
103 using webrtc::SessionDescriptionInterface;
104 using webrtc::SetSessionDescriptionObserver;
105 using webrtc::StatsObserver;
106 using webrtc::StatsReport;
107 using webrtc::StatsReports;
108 using webrtc::VideoTrackSourceInterface;
109 using webrtc::VideoTrackInterface;
110 using webrtc::VideoTrackVector;
111 using webrtc::kVideoCodecVP8;
112
113 namespace webrtc_jni {
114
115 // Field trials initialization string
116 static char *field_trials_init_string = NULL;
117
118 // Set in PeerConnectionFactory_initializeAndroidGlobals().
119 static bool factory_static_initialized = false;
120 static bool video_hw_acceleration_enabled = true;
121 static jobject j_application_context = nullptr;
122
123 // Return the (singleton) Java Enum object corresponding to |index|;
124 // |state_class_fragment| is something like "MediaSource$State".
125 static jobject JavaEnumFromIndex(
126 JNIEnv* jni, const std::string& state_class_fragment, int index) {
127 const std::string state_class = "org/webrtc/" + state_class_fragment;
128 return JavaEnumFromIndex(jni, FindClass(jni, state_class.c_str()),
129 state_class, index);
130 }
131
132 static DataChannelInit JavaDataChannelInitToNative(
133 JNIEnv* jni, jobject j_init) {
134 DataChannelInit init;
135
136 jclass j_init_class = FindClass(jni, "org/webrtc/DataChannel$Init");
137 jfieldID ordered_id = GetFieldID(jni, j_init_class, "ordered", "Z");
138 jfieldID max_retransmit_time_id =
139 GetFieldID(jni, j_init_class, "maxRetransmitTimeMs", "I");
140 jfieldID max_retransmits_id =
141 GetFieldID(jni, j_init_class, "maxRetransmits", "I");
142 jfieldID protocol_id =
143 GetFieldID(jni, j_init_class, "protocol", "Ljava/lang/String;");
144 jfieldID negotiated_id = GetFieldID(jni, j_init_class, "negotiated", "Z");
145 jfieldID id_id = GetFieldID(jni, j_init_class, "id", "I");
146
147 init.ordered = GetBooleanField(jni, j_init, ordered_id);
148 init.maxRetransmitTime = GetIntField(jni, j_init, max_retransmit_time_id);
149 init.maxRetransmits = GetIntField(jni, j_init, max_retransmits_id);
150 init.protocol = JavaToStdString(
151 jni, GetStringField(jni, j_init, protocol_id));
152 init.negotiated = GetBooleanField(jni, j_init, negotiated_id);
153 init.id = GetIntField(jni, j_init, id_id);
154
155 return init;
156 }
157
158 class ConstraintsWrapper;
159
160 // Adapter between the C++ PeerConnectionObserver interface and the Java
161 // PeerConnection.Observer interface. Wraps an instance of the Java interface
162 // and dispatches C++ callbacks to Java.
163 class PCOJava : public PeerConnectionObserver {
164 public:
165 // We need these using declarations because there are two versions of each of
166 // the below methods and we only override one of them.
167 // TODO(deadbeef): Remove once there's only one version of the methods.
168 using PeerConnectionObserver::OnAddStream;
169 using PeerConnectionObserver::OnRemoveStream;
170 using PeerConnectionObserver::OnDataChannel;
171
172 PCOJava(JNIEnv* jni, jobject j_observer)
173 : j_observer_global_(jni, j_observer),
174 j_observer_class_(jni, GetObjectClass(jni, *j_observer_global_)),
175 j_media_stream_class_(jni, FindClass(jni, "org/webrtc/MediaStream")),
176 j_media_stream_ctor_(GetMethodID(
177 jni, *j_media_stream_class_, "<init>", "(J)V")),
178 j_audio_track_class_(jni, FindClass(jni, "org/webrtc/AudioTrack")),
179 j_audio_track_ctor_(GetMethodID(
180 jni, *j_audio_track_class_, "<init>", "(J)V")),
181 j_video_track_class_(jni, FindClass(jni, "org/webrtc/VideoTrack")),
182 j_video_track_ctor_(GetMethodID(
183 jni, *j_video_track_class_, "<init>", "(J)V")),
184 j_data_channel_class_(jni, FindClass(jni, "org/webrtc/DataChannel")),
185 j_data_channel_ctor_(GetMethodID(
186 jni, *j_data_channel_class_, "<init>", "(J)V")) {
187 }
188
189 virtual ~PCOJava() {
190 ScopedLocalRefFrame local_ref_frame(jni());
191 while (!remote_streams_.empty())
192 DisposeRemoteStream(remote_streams_.begin());
193 }
194
195 void OnIceCandidate(const IceCandidateInterface* candidate) override {
196 ScopedLocalRefFrame local_ref_frame(jni());
197 std::string sdp;
198 RTC_CHECK(candidate->ToString(&sdp)) << "got so far: " << sdp;
199 jclass candidate_class = FindClass(jni(), "org/webrtc/IceCandidate");
200 jmethodID ctor = GetMethodID(jni(), candidate_class,
201 "<init>", "(Ljava/lang/String;ILjava/lang/String;)V");
202 jstring j_mid = JavaStringFromStdString(jni(), candidate->sdp_mid());
203 jstring j_sdp = JavaStringFromStdString(jni(), sdp);
204 jobject j_candidate = jni()->NewObject(candidate_class, ctor, j_mid,
205 candidate->sdp_mline_index(), j_sdp);
206 CHECK_EXCEPTION(jni()) << "error during NewObject";
207 jmethodID m = GetMethodID(jni(), *j_observer_class_,
208 "onIceCandidate", "(Lorg/webrtc/IceCandidate;)V");
209 jni()->CallVoidMethod(*j_observer_global_, m, j_candidate);
210 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
211 }
212
213 void OnIceCandidatesRemoved(
214 const std::vector<cricket::Candidate>& candidates) override {
215 ScopedLocalRefFrame local_ref_frame(jni());
216 jobjectArray candidates_array = ToJavaCandidateArray(jni(), candidates);
217 jmethodID m =
218 GetMethodID(jni(), *j_observer_class_, "onIceCandidatesRemoved",
219 "([Lorg/webrtc/IceCandidate;)V");
220 jni()->CallVoidMethod(*j_observer_global_, m, candidates_array);
221 CHECK_EXCEPTION(jni()) << "Error during CallVoidMethod";
222 }
223
224 void OnSignalingChange(
225 PeerConnectionInterface::SignalingState new_state) override {
226 ScopedLocalRefFrame local_ref_frame(jni());
227 jmethodID m = GetMethodID(
228 jni(), *j_observer_class_, "onSignalingChange",
229 "(Lorg/webrtc/PeerConnection$SignalingState;)V");
230 jobject new_state_enum =
231 JavaEnumFromIndex(jni(), "PeerConnection$SignalingState", new_state);
232 jni()->CallVoidMethod(*j_observer_global_, m, new_state_enum);
233 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
234 }
235
236 void OnIceConnectionChange(
237 PeerConnectionInterface::IceConnectionState new_state) override {
238 ScopedLocalRefFrame local_ref_frame(jni());
239 jmethodID m = GetMethodID(
240 jni(), *j_observer_class_, "onIceConnectionChange",
241 "(Lorg/webrtc/PeerConnection$IceConnectionState;)V");
242 jobject new_state_enum = JavaEnumFromIndex(
243 jni(), "PeerConnection$IceConnectionState", new_state);
244 jni()->CallVoidMethod(*j_observer_global_, m, new_state_enum);
245 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
246 }
247
248 void OnIceConnectionReceivingChange(bool receiving) override {
249 ScopedLocalRefFrame local_ref_frame(jni());
250 jmethodID m = GetMethodID(
251 jni(), *j_observer_class_, "onIceConnectionReceivingChange", "(Z)V");
252 jni()->CallVoidMethod(*j_observer_global_, m, receiving);
253 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
254 }
255
256 void OnIceGatheringChange(
257 PeerConnectionInterface::IceGatheringState new_state) override {
258 ScopedLocalRefFrame local_ref_frame(jni());
259 jmethodID m = GetMethodID(
260 jni(), *j_observer_class_, "onIceGatheringChange",
261 "(Lorg/webrtc/PeerConnection$IceGatheringState;)V");
262 jobject new_state_enum = JavaEnumFromIndex(
263 jni(), "PeerConnection$IceGatheringState", new_state);
264 jni()->CallVoidMethod(*j_observer_global_, m, new_state_enum);
265 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
266 }
267
268 void OnAddStream(rtc::scoped_refptr<MediaStreamInterface> stream) override {
269 ScopedLocalRefFrame local_ref_frame(jni());
270 // Java MediaStream holds one reference. Corresponding Release() is in
271 // MediaStream_free, triggered by MediaStream.dispose().
272 stream->AddRef();
273 jobject j_stream =
274 jni()->NewObject(*j_media_stream_class_, j_media_stream_ctor_,
275 reinterpret_cast<jlong>(stream.get()));
276 CHECK_EXCEPTION(jni()) << "error during NewObject";
277
278 for (const auto& track : stream->GetAudioTracks()) {
279 jstring id = JavaStringFromStdString(jni(), track->id());
280 // Java AudioTrack holds one reference. Corresponding Release() is in
281 // MediaStreamTrack_free, triggered by AudioTrack.dispose().
282 track->AddRef();
283 jobject j_track =
284 jni()->NewObject(*j_audio_track_class_, j_audio_track_ctor_,
285 reinterpret_cast<jlong>(track.get()), id);
286 CHECK_EXCEPTION(jni()) << "error during NewObject";
287 jfieldID audio_tracks_id = GetFieldID(jni(),
288 *j_media_stream_class_,
289 "audioTracks",
290 "Ljava/util/LinkedList;");
291 jobject audio_tracks = GetObjectField(jni(), j_stream, audio_tracks_id);
292 jmethodID add = GetMethodID(jni(),
293 GetObjectClass(jni(), audio_tracks),
294 "add",
295 "(Ljava/lang/Object;)Z");
296 jboolean added = jni()->CallBooleanMethod(audio_tracks, add, j_track);
297 CHECK_EXCEPTION(jni()) << "error during CallBooleanMethod";
298 RTC_CHECK(added);
299 }
300
301 for (const auto& track : stream->GetVideoTracks()) {
302 jstring id = JavaStringFromStdString(jni(), track->id());
303 // Java VideoTrack holds one reference. Corresponding Release() is in
304 // MediaStreamTrack_free, triggered by VideoTrack.dispose().
305 track->AddRef();
306 jobject j_track =
307 jni()->NewObject(*j_video_track_class_, j_video_track_ctor_,
308 reinterpret_cast<jlong>(track.get()), id);
309 CHECK_EXCEPTION(jni()) << "error during NewObject";
310 jfieldID video_tracks_id = GetFieldID(jni(),
311 *j_media_stream_class_,
312 "videoTracks",
313 "Ljava/util/LinkedList;");
314 jobject video_tracks = GetObjectField(jni(), j_stream, video_tracks_id);
315 jmethodID add = GetMethodID(jni(),
316 GetObjectClass(jni(), video_tracks),
317 "add",
318 "(Ljava/lang/Object;)Z");
319 jboolean added = jni()->CallBooleanMethod(video_tracks, add, j_track);
320 CHECK_EXCEPTION(jni()) << "error during CallBooleanMethod";
321 RTC_CHECK(added);
322 }
323 remote_streams_[stream] = NewGlobalRef(jni(), j_stream);
324
325 jmethodID m = GetMethodID(jni(), *j_observer_class_, "onAddStream",
326 "(Lorg/webrtc/MediaStream;)V");
327 jni()->CallVoidMethod(*j_observer_global_, m, j_stream);
328 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
329 }
330
331 void OnRemoveStream(
332 rtc::scoped_refptr<MediaStreamInterface> stream) override {
333 ScopedLocalRefFrame local_ref_frame(jni());
334 NativeToJavaStreamsMap::iterator it = remote_streams_.find(stream);
335 RTC_CHECK(it != remote_streams_.end()) << "unexpected stream: " << std::hex
336 << stream;
337 jobject j_stream = it->second;
338 jmethodID m = GetMethodID(jni(), *j_observer_class_, "onRemoveStream",
339 "(Lorg/webrtc/MediaStream;)V");
340 jni()->CallVoidMethod(*j_observer_global_, m, j_stream);
341 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
342 // Release the refptr reference so that DisposeRemoteStream can assert
343 // it removes the final reference.
344 stream = nullptr;
345 DisposeRemoteStream(it);
346 }
347
348 void OnDataChannel(
349 rtc::scoped_refptr<DataChannelInterface> channel) override {
350 ScopedLocalRefFrame local_ref_frame(jni());
351 jobject j_channel = jni()->NewObject(
352 *j_data_channel_class_, j_data_channel_ctor_, (jlong)channel.get());
353 CHECK_EXCEPTION(jni()) << "error during NewObject";
354
355 jmethodID m = GetMethodID(jni(), *j_observer_class_, "onDataChannel",
356 "(Lorg/webrtc/DataChannel;)V");
357 jni()->CallVoidMethod(*j_observer_global_, m, j_channel);
358
359 // Channel is now owned by Java object, and will be freed from
360 // DataChannel.dispose(). Important that this be done _after_ the
361 // CallVoidMethod above as Java code might call back into native code and be
362 // surprised to see a refcount of 2.
363 int bumped_count = channel->AddRef();
364 RTC_CHECK(bumped_count == 2) << "Unexpected refcount OnDataChannel";
365
366 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
367 }
368
369 void OnRenegotiationNeeded() override {
370 ScopedLocalRefFrame local_ref_frame(jni());
371 jmethodID m =
372 GetMethodID(jni(), *j_observer_class_, "onRenegotiationNeeded", "()V");
373 jni()->CallVoidMethod(*j_observer_global_, m);
374 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
375 }
376
377 void SetConstraints(ConstraintsWrapper* constraints) {
378 RTC_CHECK(!constraints_.get()) << "constraints already set!";
379 constraints_.reset(constraints);
380 }
381
382 const ConstraintsWrapper* constraints() { return constraints_.get(); }
383
384 private:
385 typedef std::map<MediaStreamInterface*, jobject> NativeToJavaStreamsMap;
386
387 void DisposeRemoteStream(const NativeToJavaStreamsMap::iterator& it) {
388 jobject j_stream = it->second;
389 remote_streams_.erase(it);
390 jni()->CallVoidMethod(
391 j_stream, GetMethodID(jni(), *j_media_stream_class_, "dispose", "()V"));
392 CHECK_EXCEPTION(jni()) << "error during MediaStream.dispose()";
393 DeleteGlobalRef(jni(), j_stream);
394 }
395
396 jobject ToJavaCandidate(JNIEnv* jni,
397 jclass* candidate_class,
398 const cricket::Candidate& candidate) {
399 std::string sdp = webrtc::SdpSerializeCandidate(candidate);
400 RTC_CHECK(!sdp.empty()) << "got an empty ICE candidate";
401 jmethodID ctor = GetMethodID(jni, *candidate_class, "<init>",
402 "(Ljava/lang/String;ILjava/lang/String;)V");
403 jstring j_mid = JavaStringFromStdString(jni, candidate.transport_name());
404 jstring j_sdp = JavaStringFromStdString(jni, sdp);
405 // sdp_mline_index is not used, pass an invalid value -1.
406 jobject j_candidate =
407 jni->NewObject(*candidate_class, ctor, j_mid, -1, j_sdp);
408 CHECK_EXCEPTION(jni) << "error during Java Candidate NewObject";
409 return j_candidate;
410 }
411
412 jobjectArray ToJavaCandidateArray(
413 JNIEnv* jni,
414 const std::vector<cricket::Candidate>& candidates) {
415 jclass candidate_class = FindClass(jni, "org/webrtc/IceCandidate");
416 jobjectArray java_candidates =
417 jni->NewObjectArray(candidates.size(), candidate_class, NULL);
418 int i = 0;
419 for (const cricket::Candidate& candidate : candidates) {
420 jobject j_candidate = ToJavaCandidate(jni, &candidate_class, candidate);
421 jni->SetObjectArrayElement(java_candidates, i++, j_candidate);
422 }
423 return java_candidates;
424 }
425
426 JNIEnv* jni() {
427 return AttachCurrentThreadIfNeeded();
428 }
429
430 const ScopedGlobalRef<jobject> j_observer_global_;
431 const ScopedGlobalRef<jclass> j_observer_class_;
432 const ScopedGlobalRef<jclass> j_media_stream_class_;
433 const jmethodID j_media_stream_ctor_;
434 const ScopedGlobalRef<jclass> j_audio_track_class_;
435 const jmethodID j_audio_track_ctor_;
436 const ScopedGlobalRef<jclass> j_video_track_class_;
437 const jmethodID j_video_track_ctor_;
438 const ScopedGlobalRef<jclass> j_data_channel_class_;
439 const jmethodID j_data_channel_ctor_;
440 // C++ -> Java remote streams. The stored jobects are global refs and must be
441 // manually deleted upon removal. Use DisposeRemoteStream().
442 NativeToJavaStreamsMap remote_streams_;
443 std::unique_ptr<ConstraintsWrapper> constraints_;
444 };
445
446 // Wrapper for a Java MediaConstraints object. Copies all needed data so when
447 // the constructor returns the Java object is no longer needed.
448 class ConstraintsWrapper : public MediaConstraintsInterface {
449 public:
450 ConstraintsWrapper(JNIEnv* jni, jobject j_constraints) {
451 PopulateConstraintsFromJavaPairList(
452 jni, j_constraints, "mandatory", &mandatory_);
453 PopulateConstraintsFromJavaPairList(
454 jni, j_constraints, "optional", &optional_);
455 }
456
457 virtual ~ConstraintsWrapper() {}
458
459 // MediaConstraintsInterface.
460 const Constraints& GetMandatory() const override { return mandatory_; }
461
462 const Constraints& GetOptional() const override { return optional_; }
463
464 private:
465 // Helper for translating a List<Pair<String, String>> to a Constraints.
466 static void PopulateConstraintsFromJavaPairList(
467 JNIEnv* jni, jobject j_constraints,
468 const char* field_name, Constraints* field) {
469 jfieldID j_id = GetFieldID(jni,
470 GetObjectClass(jni, j_constraints), field_name, "Ljava/util/List;");
471 jobject j_list = GetObjectField(jni, j_constraints, j_id);
472 for (jobject entry : Iterable(jni, j_list)) {
473 jmethodID get_key = GetMethodID(jni,
474 GetObjectClass(jni, entry), "getKey", "()Ljava/lang/String;");
475 jstring j_key = reinterpret_cast<jstring>(
476 jni->CallObjectMethod(entry, get_key));
477 CHECK_EXCEPTION(jni) << "error during CallObjectMethod";
478 jmethodID get_value = GetMethodID(jni,
479 GetObjectClass(jni, entry), "getValue", "()Ljava/lang/String;");
480 jstring j_value = reinterpret_cast<jstring>(
481 jni->CallObjectMethod(entry, get_value));
482 CHECK_EXCEPTION(jni) << "error during CallObjectMethod";
483 field->push_back(Constraint(JavaToStdString(jni, j_key),
484 JavaToStdString(jni, j_value)));
485 }
486 }
487
488 Constraints mandatory_;
489 Constraints optional_;
490 };
491
492 static jobject JavaSdpFromNativeSdp(
493 JNIEnv* jni, const SessionDescriptionInterface* desc) {
494 std::string sdp;
495 RTC_CHECK(desc->ToString(&sdp)) << "got so far: " << sdp;
496 jstring j_description = JavaStringFromStdString(jni, sdp);
497
498 jclass j_type_class = FindClass(
499 jni, "org/webrtc/SessionDescription$Type");
500 jmethodID j_type_from_canonical = GetStaticMethodID(
501 jni, j_type_class, "fromCanonicalForm",
502 "(Ljava/lang/String;)Lorg/webrtc/SessionDescription$Type;");
503 jstring j_type_string = JavaStringFromStdString(jni, desc->type());
504 jobject j_type = jni->CallStaticObjectMethod(
505 j_type_class, j_type_from_canonical, j_type_string);
506 CHECK_EXCEPTION(jni) << "error during CallObjectMethod";
507
508 jclass j_sdp_class = FindClass(jni, "org/webrtc/SessionDescription");
509 jmethodID j_sdp_ctor = GetMethodID(
510 jni, j_sdp_class, "<init>",
511 "(Lorg/webrtc/SessionDescription$Type;Ljava/lang/String;)V");
512 jobject j_sdp = jni->NewObject(
513 j_sdp_class, j_sdp_ctor, j_type, j_description);
514 CHECK_EXCEPTION(jni) << "error during NewObject";
515 return j_sdp;
516 }
517
518 template <class T> // T is one of {Create,Set}SessionDescriptionObserver.
519 class SdpObserverWrapper : public T {
520 public:
521 SdpObserverWrapper(JNIEnv* jni, jobject j_observer,
522 ConstraintsWrapper* constraints)
523 : constraints_(constraints),
524 j_observer_global_(jni, j_observer),
525 j_observer_class_(jni, GetObjectClass(jni, j_observer)) {
526 }
527
528 virtual ~SdpObserverWrapper() {}
529
530 // Can't mark override because of templating.
531 virtual void OnSuccess() {
532 ScopedLocalRefFrame local_ref_frame(jni());
533 jmethodID m = GetMethodID(jni(), *j_observer_class_, "onSetSuccess", "()V");
534 jni()->CallVoidMethod(*j_observer_global_, m);
535 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
536 }
537
538 // Can't mark override because of templating.
539 virtual void OnSuccess(SessionDescriptionInterface* desc) {
540 ScopedLocalRefFrame local_ref_frame(jni());
541 jmethodID m = GetMethodID(
542 jni(), *j_observer_class_, "onCreateSuccess",
543 "(Lorg/webrtc/SessionDescription;)V");
544 jobject j_sdp = JavaSdpFromNativeSdp(jni(), desc);
545 jni()->CallVoidMethod(*j_observer_global_, m, j_sdp);
546 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
547 }
548
549 protected:
550 // Common implementation for failure of Set & Create types, distinguished by
551 // |op| being "Set" or "Create".
552 void DoOnFailure(const std::string& op, const std::string& error) {
553 jmethodID m = GetMethodID(jni(), *j_observer_class_, "on" + op + "Failure",
554 "(Ljava/lang/String;)V");
555 jstring j_error_string = JavaStringFromStdString(jni(), error);
556 jni()->CallVoidMethod(*j_observer_global_, m, j_error_string);
557 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
558 }
559
560 JNIEnv* jni() {
561 return AttachCurrentThreadIfNeeded();
562 }
563
564 private:
565 std::unique_ptr<ConstraintsWrapper> constraints_;
566 const ScopedGlobalRef<jobject> j_observer_global_;
567 const ScopedGlobalRef<jclass> j_observer_class_;
568 };
569
570 class CreateSdpObserverWrapper
571 : public SdpObserverWrapper<CreateSessionDescriptionObserver> {
572 public:
573 CreateSdpObserverWrapper(JNIEnv* jni, jobject j_observer,
574 ConstraintsWrapper* constraints)
575 : SdpObserverWrapper(jni, j_observer, constraints) {}
576
577 void OnFailure(const std::string& error) override {
578 ScopedLocalRefFrame local_ref_frame(jni());
579 SdpObserverWrapper::DoOnFailure(std::string("Create"), error);
580 }
581 };
582
583 class SetSdpObserverWrapper
584 : public SdpObserverWrapper<SetSessionDescriptionObserver> {
585 public:
586 SetSdpObserverWrapper(JNIEnv* jni, jobject j_observer,
587 ConstraintsWrapper* constraints)
588 : SdpObserverWrapper(jni, j_observer, constraints) {}
589
590 void OnFailure(const std::string& error) override {
591 ScopedLocalRefFrame local_ref_frame(jni());
592 SdpObserverWrapper::DoOnFailure(std::string("Set"), error);
593 }
594 };
595
596 // Adapter for a Java DataChannel$Observer presenting a C++ DataChannelObserver
597 // and dispatching the callback from C++ back to Java.
598 class DataChannelObserverWrapper : public DataChannelObserver {
599 public:
600 DataChannelObserverWrapper(JNIEnv* jni, jobject j_observer)
601 : j_observer_global_(jni, j_observer),
602 j_observer_class_(jni, GetObjectClass(jni, j_observer)),
603 j_buffer_class_(jni, FindClass(jni, "org/webrtc/DataChannel$Buffer")),
604 j_on_buffered_amount_change_mid_(GetMethodID(
605 jni, *j_observer_class_, "onBufferedAmountChange", "(J)V")),
606 j_on_state_change_mid_(
607 GetMethodID(jni, *j_observer_class_, "onStateChange", "()V")),
608 j_on_message_mid_(GetMethodID(jni, *j_observer_class_, "onMessage",
609 "(Lorg/webrtc/DataChannel$Buffer;)V")),
610 j_buffer_ctor_(GetMethodID(jni, *j_buffer_class_, "<init>",
611 "(Ljava/nio/ByteBuffer;Z)V")) {}
612
613 virtual ~DataChannelObserverWrapper() {}
614
615 void OnBufferedAmountChange(uint64_t previous_amount) override {
616 ScopedLocalRefFrame local_ref_frame(jni());
617 jni()->CallVoidMethod(*j_observer_global_, j_on_buffered_amount_change_mid_,
618 previous_amount);
619 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
620 }
621
622 void OnStateChange() override {
623 ScopedLocalRefFrame local_ref_frame(jni());
624 jni()->CallVoidMethod(*j_observer_global_, j_on_state_change_mid_);
625 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
626 }
627
628 void OnMessage(const DataBuffer& buffer) override {
629 ScopedLocalRefFrame local_ref_frame(jni());
630 jobject byte_buffer = jni()->NewDirectByteBuffer(
631 const_cast<char*>(buffer.data.data<char>()), buffer.data.size());
632 jobject j_buffer = jni()->NewObject(*j_buffer_class_, j_buffer_ctor_,
633 byte_buffer, buffer.binary);
634 jni()->CallVoidMethod(*j_observer_global_, j_on_message_mid_, j_buffer);
635 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
636 }
637
638 private:
639 JNIEnv* jni() {
640 return AttachCurrentThreadIfNeeded();
641 }
642
643 const ScopedGlobalRef<jobject> j_observer_global_;
644 const ScopedGlobalRef<jclass> j_observer_class_;
645 const ScopedGlobalRef<jclass> j_buffer_class_;
646 const jmethodID j_on_buffered_amount_change_mid_;
647 const jmethodID j_on_state_change_mid_;
648 const jmethodID j_on_message_mid_;
649 const jmethodID j_buffer_ctor_;
650 };
651
652 // Adapter for a Java StatsObserver presenting a C++ StatsObserver and
653 // dispatching the callback from C++ back to Java.
654 class StatsObserverWrapper : public StatsObserver {
655 public:
656 StatsObserverWrapper(JNIEnv* jni, jobject j_observer)
657 : j_observer_global_(jni, j_observer),
658 j_observer_class_(jni, GetObjectClass(jni, j_observer)),
659 j_stats_report_class_(jni, FindClass(jni, "org/webrtc/StatsReport")),
660 j_stats_report_ctor_(GetMethodID(
661 jni, *j_stats_report_class_, "<init>",
662 "(Ljava/lang/String;Ljava/lang/String;D"
663 "[Lorg/webrtc/StatsReport$Value;)V")),
664 j_value_class_(jni, FindClass(
665 jni, "org/webrtc/StatsReport$Value")),
666 j_value_ctor_(GetMethodID(
667 jni, *j_value_class_, "<init>",
668 "(Ljava/lang/String;Ljava/lang/String;)V")) {
669 }
670
671 virtual ~StatsObserverWrapper() {}
672
673 void OnComplete(const StatsReports& reports) override {
674 ScopedLocalRefFrame local_ref_frame(jni());
675 jobjectArray j_reports = ReportsToJava(jni(), reports);
676 jmethodID m = GetMethodID(jni(), *j_observer_class_, "onComplete",
677 "([Lorg/webrtc/StatsReport;)V");
678 jni()->CallVoidMethod(*j_observer_global_, m, j_reports);
679 CHECK_EXCEPTION(jni()) << "error during CallVoidMethod";
680 }
681
682 private:
683 jobjectArray ReportsToJava(
684 JNIEnv* jni, const StatsReports& reports) {
685 jobjectArray reports_array = jni->NewObjectArray(
686 reports.size(), *j_stats_report_class_, NULL);
687 int i = 0;
688 for (const auto* report : reports) {
689 ScopedLocalRefFrame local_ref_frame(jni);
690 jstring j_id = JavaStringFromStdString(jni, report->id()->ToString());
691 jstring j_type = JavaStringFromStdString(jni, report->TypeToString());
692 jobjectArray j_values = ValuesToJava(jni, report->values());
693 jobject j_report = jni->NewObject(*j_stats_report_class_,
694 j_stats_report_ctor_,
695 j_id,
696 j_type,
697 report->timestamp(),
698 j_values);
699 jni->SetObjectArrayElement(reports_array, i++, j_report);
700 }
701 return reports_array;
702 }
703
704 jobjectArray ValuesToJava(JNIEnv* jni, const StatsReport::Values& values) {
705 jobjectArray j_values = jni->NewObjectArray(
706 values.size(), *j_value_class_, NULL);
707 int i = 0;
708 for (const auto& it : values) {
709 ScopedLocalRefFrame local_ref_frame(jni);
710 // Should we use the '.name' enum value here instead of converting the
711 // name to a string?
712 jstring j_name = JavaStringFromStdString(jni, it.second->display_name());
713 jstring j_value = JavaStringFromStdString(jni, it.second->ToString());
714 jobject j_element_value =
715 jni->NewObject(*j_value_class_, j_value_ctor_, j_name, j_value);
716 jni->SetObjectArrayElement(j_values, i++, j_element_value);
717 }
718 return j_values;
719 }
720
721 JNIEnv* jni() {
722 return AttachCurrentThreadIfNeeded();
723 }
724
725 const ScopedGlobalRef<jobject> j_observer_global_;
726 const ScopedGlobalRef<jclass> j_observer_class_;
727 const ScopedGlobalRef<jclass> j_stats_report_class_;
728 const jmethodID j_stats_report_ctor_;
729 const ScopedGlobalRef<jclass> j_value_class_;
730 const jmethodID j_value_ctor_;
731 };
732
733 // Wrapper dispatching rtc::VideoSinkInterface to a Java VideoRenderer
734 // instance.
735 class JavaVideoRendererWrapper
736 : public rtc::VideoSinkInterface<webrtc::VideoFrame> {
737 public:
738 JavaVideoRendererWrapper(JNIEnv* jni, jobject j_callbacks)
739 : j_callbacks_(jni, j_callbacks),
740 j_render_frame_id_(GetMethodID(
741 jni, GetObjectClass(jni, j_callbacks), "renderFrame",
742 "(Lorg/webrtc/VideoRenderer$I420Frame;)V")),
743 j_frame_class_(jni,
744 FindClass(jni, "org/webrtc/VideoRenderer$I420Frame")),
745 j_i420_frame_ctor_id_(GetMethodID(
746 jni, *j_frame_class_, "<init>", "(III[I[Ljava/nio/ByteBuffer;J)V")),
747 j_texture_frame_ctor_id_(GetMethodID(
748 jni, *j_frame_class_, "<init>",
749 "(IIII[FJ)V")),
750 j_byte_buffer_class_(jni, FindClass(jni, "java/nio/ByteBuffer")) {
751 CHECK_EXCEPTION(jni);
752 }
753
754 virtual ~JavaVideoRendererWrapper() {}
755
756 void OnFrame(const webrtc::VideoFrame& video_frame) override {
757 ScopedLocalRefFrame local_ref_frame(jni());
758 jobject j_frame =
759 (video_frame.video_frame_buffer()->native_handle() != nullptr)
760 ? CricketToJavaTextureFrame(&video_frame)
761 : CricketToJavaI420Frame(&video_frame);
762 // |j_callbacks_| is responsible for releasing |j_frame| with
763 // VideoRenderer.renderFrameDone().
764 jni()->CallVoidMethod(*j_callbacks_, j_render_frame_id_, j_frame);
765 CHECK_EXCEPTION(jni());
766 }
767
768 private:
769 // Make a shallow copy of |frame| to be used with Java. The callee has
770 // ownership of the frame, and the frame should be released with
771 // VideoRenderer.releaseNativeFrame().
772 static jlong javaShallowCopy(const webrtc::VideoFrame* frame) {
773 return jlongFromPointer(new webrtc::VideoFrame(*frame));
774 }
775
776 // Return a VideoRenderer.I420Frame referring to the data in |frame|.
777 jobject CricketToJavaI420Frame(const webrtc::VideoFrame* frame) {
778 jintArray strides = jni()->NewIntArray(3);
779 jint* strides_array = jni()->GetIntArrayElements(strides, NULL);
780 strides_array[0] = frame->video_frame_buffer()->StrideY();
781 strides_array[1] = frame->video_frame_buffer()->StrideU();
782 strides_array[2] = frame->video_frame_buffer()->StrideV();
783 jni()->ReleaseIntArrayElements(strides, strides_array, 0);
784 jobjectArray planes = jni()->NewObjectArray(3, *j_byte_buffer_class_, NULL);
785 jobject y_buffer = jni()->NewDirectByteBuffer(
786 const_cast<uint8_t*>(frame->video_frame_buffer()->DataY()),
787 frame->video_frame_buffer()->StrideY() *
788 frame->video_frame_buffer()->height());
789 size_t chroma_height = (frame->height() + 1) / 2;
790 jobject u_buffer = jni()->NewDirectByteBuffer(
791 const_cast<uint8_t*>(frame->video_frame_buffer()->DataU()),
792 frame->video_frame_buffer()->StrideU() * chroma_height);
793 jobject v_buffer = jni()->NewDirectByteBuffer(
794 const_cast<uint8_t*>(frame->video_frame_buffer()->DataV()),
795 frame->video_frame_buffer()->StrideV() * chroma_height);
796
797 jni()->SetObjectArrayElement(planes, 0, y_buffer);
798 jni()->SetObjectArrayElement(planes, 1, u_buffer);
799 jni()->SetObjectArrayElement(planes, 2, v_buffer);
800 return jni()->NewObject(
801 *j_frame_class_, j_i420_frame_ctor_id_,
802 frame->width(), frame->height(),
803 static_cast<int>(frame->rotation()),
804 strides, planes, javaShallowCopy(frame));
805 }
806
807 // Return a VideoRenderer.I420Frame referring texture object in |frame|.
808 jobject CricketToJavaTextureFrame(const webrtc::VideoFrame* frame) {
809 NativeHandleImpl* handle = reinterpret_cast<NativeHandleImpl*>(
810 frame->video_frame_buffer()->native_handle());
811 jfloatArray sampling_matrix = handle->sampling_matrix.ToJava(jni());
812
813 return jni()->NewObject(
814 *j_frame_class_, j_texture_frame_ctor_id_,
815 frame->width(), frame->height(),
816 static_cast<int>(frame->rotation()),
817 handle->oes_texture_id, sampling_matrix, javaShallowCopy(frame));
818 }
819
820 JNIEnv* jni() {
821 return AttachCurrentThreadIfNeeded();
822 }
823
824 ScopedGlobalRef<jobject> j_callbacks_;
825 jmethodID j_render_frame_id_;
826 ScopedGlobalRef<jclass> j_frame_class_;
827 jmethodID j_i420_frame_ctor_id_;
828 jmethodID j_texture_frame_ctor_id_;
829 ScopedGlobalRef<jclass> j_byte_buffer_class_;
830 };
831
832
833 static DataChannelInterface* ExtractNativeDC(JNIEnv* jni, jobject j_dc) {
834 jfieldID native_dc_id = GetFieldID(jni,
835 GetObjectClass(jni, j_dc), "nativeDataChannel", "J");
836 jlong j_d = GetLongField(jni, j_dc, native_dc_id);
837 return reinterpret_cast<DataChannelInterface*>(j_d);
838 }
839
840 JOW(jlong, DataChannel_registerObserverNative)(
841 JNIEnv* jni, jobject j_dc, jobject j_observer) {
842 std::unique_ptr<DataChannelObserverWrapper> observer(
843 new DataChannelObserverWrapper(jni, j_observer));
844 ExtractNativeDC(jni, j_dc)->RegisterObserver(observer.get());
845 return jlongFromPointer(observer.release());
846 }
847
848 JOW(void, DataChannel_unregisterObserverNative)(
849 JNIEnv* jni, jobject j_dc, jlong native_observer) {
850 ExtractNativeDC(jni, j_dc)->UnregisterObserver();
851 delete reinterpret_cast<DataChannelObserverWrapper*>(native_observer);
852 }
853
854 JOW(jstring, DataChannel_label)(JNIEnv* jni, jobject j_dc) {
855 return JavaStringFromStdString(jni, ExtractNativeDC(jni, j_dc)->label());
856 }
857
858 JOW(jint, DataChannel_id)(JNIEnv* jni, jobject j_dc) {
859 int id = ExtractNativeDC(jni, j_dc)->id();
860 RTC_CHECK_LE(id, std::numeric_limits<int32_t>::max())
861 << "id overflowed jint!";
862 return static_cast<jint>(id);
863 }
864
865 JOW(jobject, DataChannel_state)(JNIEnv* jni, jobject j_dc) {
866 return JavaEnumFromIndex(
867 jni, "DataChannel$State", ExtractNativeDC(jni, j_dc)->state());
868 }
869
870 JOW(jlong, DataChannel_bufferedAmount)(JNIEnv* jni, jobject j_dc) {
871 uint64_t buffered_amount = ExtractNativeDC(jni, j_dc)->buffered_amount();
872 RTC_CHECK_LE(buffered_amount, std::numeric_limits<int64_t>::max())
873 << "buffered_amount overflowed jlong!";
874 return static_cast<jlong>(buffered_amount);
875 }
876
877 JOW(void, DataChannel_close)(JNIEnv* jni, jobject j_dc) {
878 ExtractNativeDC(jni, j_dc)->Close();
879 }
880
881 JOW(jboolean, DataChannel_sendNative)(JNIEnv* jni, jobject j_dc,
882 jbyteArray data, jboolean binary) {
883 jbyte* bytes = jni->GetByteArrayElements(data, NULL);
884 bool ret = ExtractNativeDC(jni, j_dc)->Send(DataBuffer(
885 rtc::CopyOnWriteBuffer(bytes, jni->GetArrayLength(data)),
886 binary));
887 jni->ReleaseByteArrayElements(data, bytes, JNI_ABORT);
888 return ret;
889 }
890
891 JOW(void, DataChannel_dispose)(JNIEnv* jni, jobject j_dc) {
892 CHECK_RELEASE(ExtractNativeDC(jni, j_dc));
893 }
894
895 JOW(void, Logging_nativeEnableTracing)(
896 JNIEnv* jni, jclass, jstring j_path, jint nativeLevels) {
897 std::string path = JavaToStdString(jni, j_path);
898 if (nativeLevels != webrtc::kTraceNone) {
899 webrtc::Trace::set_level_filter(nativeLevels);
900 if (path != "logcat:") {
901 RTC_CHECK_EQ(0, webrtc::Trace::SetTraceFile(path.c_str(), false))
902 << "SetTraceFile failed";
903 } else {
904 // Intentionally leak this to avoid needing to reason about its lifecycle.
905 // It keeps no state and functions only as a dispatch point.
906 static LogcatTraceContext* g_trace_callback = new LogcatTraceContext();
907 }
908 }
909 }
910
911 JOW(void, Logging_nativeEnableLogToDebugOutput)
912 (JNIEnv *jni, jclass, jint nativeSeverity) {
913 if (nativeSeverity >= rtc::LS_SENSITIVE && nativeSeverity <= rtc::LS_NONE) {
914 rtc::LogMessage::LogToDebug(
915 static_cast<rtc::LoggingSeverity>(nativeSeverity));
916 }
917 }
918
919 JOW(void, Logging_nativeEnableLogThreads)(JNIEnv* jni, jclass) {
920 rtc::LogMessage::LogThreads(true);
921 }
922
923 JOW(void, Logging_nativeEnableLogTimeStamps)(JNIEnv* jni, jclass) {
924 rtc::LogMessage::LogTimestamps(true);
925 }
926
927 JOW(void, Logging_nativeLog)(
928 JNIEnv* jni, jclass, jint j_severity, jstring j_tag, jstring j_message) {
929 std::string message = JavaToStdString(jni, j_message);
930 std::string tag = JavaToStdString(jni, j_tag);
931 LOG_TAG(static_cast<rtc::LoggingSeverity>(j_severity), tag) << message;
932 }
933
934 JOW(void, PeerConnection_freePeerConnection)(JNIEnv*, jclass, jlong j_p) {
935 CHECK_RELEASE(reinterpret_cast<PeerConnectionInterface*>(j_p));
936 }
937
938 JOW(void, PeerConnection_freeObserver)(JNIEnv*, jclass, jlong j_p) {
939 PCOJava* p = reinterpret_cast<PCOJava*>(j_p);
940 delete p;
941 }
942
943 JOW(void, MediaSource_free)(JNIEnv*, jclass, jlong j_p) {
944 reinterpret_cast<rtc::RefCountInterface*>(j_p)->Release();
945 }
946
947 JOW(void, VideoRenderer_freeWrappedVideoRenderer)(JNIEnv*, jclass, jlong j_p) {
948 delete reinterpret_cast<JavaVideoRendererWrapper*>(j_p);
949 }
950
951 JOW(void, VideoRenderer_releaseNativeFrame)(
952 JNIEnv* jni, jclass, jlong j_frame_ptr) {
953 delete reinterpret_cast<const webrtc::VideoFrame*>(j_frame_ptr);
954 }
955
956 JOW(void, MediaStreamTrack_free)(JNIEnv*, jclass, jlong j_p) {
957 reinterpret_cast<MediaStreamTrackInterface*>(j_p)->Release();
958 }
959
960 JOW(jboolean, MediaStream_nativeAddAudioTrack)(
961 JNIEnv* jni, jclass, jlong pointer, jlong j_audio_track_pointer) {
962 return reinterpret_cast<MediaStreamInterface*>(pointer)->AddTrack(
963 reinterpret_cast<AudioTrackInterface*>(j_audio_track_pointer));
964 }
965
966 JOW(jboolean, MediaStream_nativeAddVideoTrack)(
967 JNIEnv* jni, jclass, jlong pointer, jlong j_video_track_pointer) {
968 return reinterpret_cast<MediaStreamInterface*>(pointer)
969 ->AddTrack(reinterpret_cast<VideoTrackInterface*>(j_video_track_pointer));
970 }
971
972 JOW(jboolean, MediaStream_nativeRemoveAudioTrack)(
973 JNIEnv* jni, jclass, jlong pointer, jlong j_audio_track_pointer) {
974 return reinterpret_cast<MediaStreamInterface*>(pointer)->RemoveTrack(
975 reinterpret_cast<AudioTrackInterface*>(j_audio_track_pointer));
976 }
977
978 JOW(jboolean, MediaStream_nativeRemoveVideoTrack)(
979 JNIEnv* jni, jclass, jlong pointer, jlong j_video_track_pointer) {
980 return reinterpret_cast<MediaStreamInterface*>(pointer)->RemoveTrack(
981 reinterpret_cast<VideoTrackInterface*>(j_video_track_pointer));
982 }
983
984 JOW(jstring, MediaStream_nativeLabel)(JNIEnv* jni, jclass, jlong j_p) {
985 return JavaStringFromStdString(
986 jni, reinterpret_cast<MediaStreamInterface*>(j_p)->label());
987 }
988
989 JOW(void, MediaStream_free)(JNIEnv*, jclass, jlong j_p) {
990 CHECK_RELEASE(reinterpret_cast<MediaStreamInterface*>(j_p));
991 }
992
993 JOW(jlong, PeerConnectionFactory_nativeCreateObserver)(
994 JNIEnv * jni, jclass, jobject j_observer) {
995 return (jlong)new PCOJava(jni, j_observer);
996 }
997
998 JOW(jboolean, PeerConnectionFactory_initializeAndroidGlobals)
999 (JNIEnv* jni,
1000 jclass,
1001 jobject context,
1002 jboolean initialize_audio,
1003 jboolean initialize_video,
1004 jboolean video_hw_acceleration) {
1005 bool failure = false;
1006 video_hw_acceleration_enabled = video_hw_acceleration;
1007 AndroidNetworkMonitor::SetAndroidContext(jni, context);
1008 if (!factory_static_initialized) {
1009 RTC_DCHECK(j_application_context == nullptr);
1010 j_application_context = NewGlobalRef(jni, context);
1011
1012 if (initialize_audio)
1013 failure |= webrtc::VoiceEngine::SetAndroidObjects(GetJVM(), context);
1014 factory_static_initialized = true;
1015 }
1016 return !failure;
1017 }
1018
1019 JOW(void, PeerConnectionFactory_initializeFieldTrials)(
1020 JNIEnv* jni, jclass, jstring j_trials_init_string) {
1021 field_trials_init_string = NULL;
1022 if (j_trials_init_string != NULL) {
1023 const char* init_string =
1024 jni->GetStringUTFChars(j_trials_init_string, NULL);
1025 int init_string_length = jni->GetStringUTFLength(j_trials_init_string);
1026 field_trials_init_string = new char[init_string_length + 1];
1027 rtc::strcpyn(field_trials_init_string, init_string_length + 1, init_string);
1028 jni->ReleaseStringUTFChars(j_trials_init_string, init_string);
1029 LOG(LS_INFO) << "initializeFieldTrials: " << field_trials_init_string;
1030 }
1031 webrtc::field_trial::InitFieldTrialsFromString(field_trials_init_string);
1032 }
1033
1034 JOW(void, PeerConnectionFactory_initializeInternalTracer)(JNIEnv* jni, jclass) {
1035 rtc::tracing::SetupInternalTracer();
1036 }
1037
1038 JOW(jboolean, PeerConnectionFactory_startInternalTracingCapture)(
1039 JNIEnv* jni, jclass, jstring j_event_tracing_filename) {
1040 if (!j_event_tracing_filename)
1041 return false;
1042
1043 const char* init_string =
1044 jni->GetStringUTFChars(j_event_tracing_filename, NULL);
1045 LOG(LS_INFO) << "Starting internal tracing to: " << init_string;
1046 bool ret = rtc::tracing::StartInternalCapture(init_string);
1047 jni->ReleaseStringUTFChars(j_event_tracing_filename, init_string);
1048 return ret;
1049 }
1050
1051 JOW(void, PeerConnectionFactory_stopInternalTracingCapture)(
1052 JNIEnv* jni, jclass) {
1053 rtc::tracing::StopInternalCapture();
1054 }
1055
1056 JOW(void, PeerConnectionFactory_shutdownInternalTracer)(JNIEnv* jni, jclass) {
1057 rtc::tracing::ShutdownInternalTracer();
1058 }
1059
1060 // Helper struct for working around the fact that CreatePeerConnectionFactory()
1061 // comes in two flavors: either entirely automagical (constructing its own
1062 // threads and deleting them on teardown, but no external codec factory support)
1063 // or entirely manual (requires caller to delete threads after factory
1064 // teardown). This struct takes ownership of its ctor's arguments to present a
1065 // single thing for Java to hold and eventually free.
1066 class OwnedFactoryAndThreads {
1067 public:
1068 OwnedFactoryAndThreads(std::unique_ptr<Thread> network_thread,
1069 std::unique_ptr<Thread> worker_thread,
1070 std::unique_ptr<Thread> signaling_thread,
1071 WebRtcVideoEncoderFactory* encoder_factory,
1072 WebRtcVideoDecoderFactory* decoder_factory,
1073 rtc::NetworkMonitorFactory* network_monitor_factory,
1074 PeerConnectionFactoryInterface* factory)
1075 : network_thread_(std::move(network_thread)),
1076 worker_thread_(std::move(worker_thread)),
1077 signaling_thread_(std::move(signaling_thread)),
1078 encoder_factory_(encoder_factory),
1079 decoder_factory_(decoder_factory),
1080 network_monitor_factory_(network_monitor_factory),
1081 factory_(factory) {}
1082
1083 ~OwnedFactoryAndThreads() {
1084 CHECK_RELEASE(factory_);
1085 if (network_monitor_factory_ != nullptr) {
1086 rtc::NetworkMonitorFactory::ReleaseFactory(network_monitor_factory_);
1087 }
1088 }
1089
1090 PeerConnectionFactoryInterface* factory() { return factory_; }
1091 Thread* signaling_thread() { return signaling_thread_.get(); }
1092 Thread* worker_thread() { return worker_thread_.get(); }
1093 WebRtcVideoEncoderFactory* encoder_factory() { return encoder_factory_; }
1094 WebRtcVideoDecoderFactory* decoder_factory() { return decoder_factory_; }
1095 rtc::NetworkMonitorFactory* network_monitor_factory() {
1096 return network_monitor_factory_;
1097 }
1098 void clear_network_monitor_factory() { network_monitor_factory_ = nullptr; }
1099 void InvokeJavaCallbacksOnFactoryThreads();
1100
1101 private:
1102 void JavaCallbackOnFactoryThreads();
1103
1104 const std::unique_ptr<Thread> network_thread_;
1105 const std::unique_ptr<Thread> worker_thread_;
1106 const std::unique_ptr<Thread> signaling_thread_;
1107 WebRtcVideoEncoderFactory* encoder_factory_;
1108 WebRtcVideoDecoderFactory* decoder_factory_;
1109 rtc::NetworkMonitorFactory* network_monitor_factory_;
1110 PeerConnectionFactoryInterface* factory_; // Const after ctor except dtor.
1111 };
1112
1113 void OwnedFactoryAndThreads::JavaCallbackOnFactoryThreads() {
1114 JNIEnv* jni = AttachCurrentThreadIfNeeded();
1115 ScopedLocalRefFrame local_ref_frame(jni);
1116 jclass j_factory_class = FindClass(jni, "org/webrtc/PeerConnectionFactory");
1117 jmethodID m = nullptr;
1118 if (network_thread_->IsCurrent()) {
1119 LOG(LS_INFO) << "Network thread JavaCallback";
1120 m = GetStaticMethodID(jni, j_factory_class, "onNetworkThreadReady", "()V");
1121 }
1122 if (worker_thread_->IsCurrent()) {
1123 LOG(LS_INFO) << "Worker thread JavaCallback";
1124 m = GetStaticMethodID(jni, j_factory_class, "onWorkerThreadReady", "()V");
1125 }
1126 if (signaling_thread_->IsCurrent()) {
1127 LOG(LS_INFO) << "Signaling thread JavaCallback";
1128 m = GetStaticMethodID(
1129 jni, j_factory_class, "onSignalingThreadReady", "()V");
1130 }
1131 if (m != nullptr) {
1132 jni->CallStaticVoidMethod(j_factory_class, m);
1133 CHECK_EXCEPTION(jni) << "error during JavaCallback::CallStaticVoidMethod";
1134 }
1135 }
1136
1137 void OwnedFactoryAndThreads::InvokeJavaCallbacksOnFactoryThreads() {
1138 LOG(LS_INFO) << "InvokeJavaCallbacksOnFactoryThreads.";
1139 network_thread_->Invoke<void>(RTC_FROM_HERE,
1140 [this] { JavaCallbackOnFactoryThreads(); });
1141 worker_thread_->Invoke<void>(RTC_FROM_HERE,
1142 [this] { JavaCallbackOnFactoryThreads(); });
1143 signaling_thread_->Invoke<void>(RTC_FROM_HERE,
1144 [this] { JavaCallbackOnFactoryThreads(); });
1145 }
1146
1147 PeerConnectionFactoryInterface::Options ParseOptionsFromJava(JNIEnv* jni,
1148 jobject options) {
1149 jclass options_class = jni->GetObjectClass(options);
1150 jfieldID network_ignore_mask_field =
1151 jni->GetFieldID(options_class, "networkIgnoreMask", "I");
1152 int network_ignore_mask =
1153 jni->GetIntField(options, network_ignore_mask_field);
1154
1155 jfieldID disable_encryption_field =
1156 jni->GetFieldID(options_class, "disableEncryption", "Z");
1157 bool disable_encryption =
1158 jni->GetBooleanField(options, disable_encryption_field);
1159
1160 jfieldID disable_network_monitor_field =
1161 jni->GetFieldID(options_class, "disableNetworkMonitor", "Z");
1162 bool disable_network_monitor =
1163 jni->GetBooleanField(options, disable_network_monitor_field);
1164
1165 PeerConnectionFactoryInterface::Options native_options;
1166
1167 // This doesn't necessarily match the c++ version of this struct; feel free
1168 // to add more parameters as necessary.
1169 native_options.network_ignore_mask = network_ignore_mask;
1170 native_options.disable_encryption = disable_encryption;
1171 native_options.disable_network_monitor = disable_network_monitor;
1172 return native_options;
1173 }
1174
1175 JOW(jlong, PeerConnectionFactory_nativeCreatePeerConnectionFactory)(
1176 JNIEnv* jni, jclass, jobject joptions) {
1177 // talk/ assumes pretty widely that the current Thread is ThreadManager'd, but
1178 // ThreadManager only WrapCurrentThread()s the thread where it is first
1179 // created. Since the semantics around when auto-wrapping happens in
1180 // webrtc/base/ are convoluted, we simply wrap here to avoid having to think
1181 // about ramifications of auto-wrapping there.
1182 rtc::ThreadManager::Instance()->WrapCurrentThread();
1183 webrtc::Trace::CreateTrace();
1184
1185 std::unique_ptr<Thread> network_thread =
1186 rtc::Thread::CreateWithSocketServer();
1187 network_thread->SetName("network_thread", nullptr);
1188 RTC_CHECK(network_thread->Start()) << "Failed to start thread";
1189
1190 std::unique_ptr<Thread> worker_thread = rtc::Thread::Create();
1191 worker_thread->SetName("worker_thread", nullptr);
1192 RTC_CHECK(worker_thread->Start()) << "Failed to start thread";
1193
1194 std::unique_ptr<Thread> signaling_thread = rtc::Thread::Create();
1195 signaling_thread->SetName("signaling_thread", NULL);
1196 RTC_CHECK(signaling_thread->Start()) << "Failed to start thread";
1197
1198 WebRtcVideoEncoderFactory* encoder_factory = nullptr;
1199 WebRtcVideoDecoderFactory* decoder_factory = nullptr;
1200 rtc::NetworkMonitorFactory* network_monitor_factory = nullptr;
1201
1202 PeerConnectionFactoryInterface::Options options;
1203 bool has_options = joptions != NULL;
1204 if (has_options) {
1205 options = ParseOptionsFromJava(jni, joptions);
1206 }
1207
1208 if (video_hw_acceleration_enabled) {
1209 encoder_factory = new MediaCodecVideoEncoderFactory();
1210 decoder_factory = new MediaCodecVideoDecoderFactory();
1211 }
1212 // Do not create network_monitor_factory only if the options are
1213 // provided and disable_network_monitor therein is set to true.
1214 if (!(has_options && options.disable_network_monitor)) {
1215 network_monitor_factory = new AndroidNetworkMonitorFactory();
1216 rtc::NetworkMonitorFactory::SetFactory(network_monitor_factory);
1217 }
1218
1219 rtc::scoped_refptr<PeerConnectionFactoryInterface> factory(
1220 webrtc::CreatePeerConnectionFactory(
1221 network_thread.get(), worker_thread.get(), signaling_thread.get(),
1222 nullptr, encoder_factory, decoder_factory));
1223 RTC_CHECK(factory) << "Failed to create the peer connection factory; "
1224 << "WebRTC/libjingle init likely failed on this device";
1225 // TODO(honghaiz): Maybe put the options as the argument of
1226 // CreatePeerConnectionFactory.
1227 if (has_options) {
1228 factory->SetOptions(options);
1229 }
1230 OwnedFactoryAndThreads* owned_factory = new OwnedFactoryAndThreads(
1231 std::move(network_thread), std::move(worker_thread),
1232 std::move(signaling_thread), encoder_factory, decoder_factory,
1233 network_monitor_factory, factory.release());
1234 owned_factory->InvokeJavaCallbacksOnFactoryThreads();
1235 return jlongFromPointer(owned_factory);
1236 }
1237
1238 JOW(void, PeerConnectionFactory_nativeFreeFactory)(JNIEnv*, jclass, jlong j_p) {
1239 delete reinterpret_cast<OwnedFactoryAndThreads*>(j_p);
1240 if (field_trials_init_string) {
1241 webrtc::field_trial::InitFieldTrialsFromString(NULL);
1242 delete field_trials_init_string;
1243 field_trials_init_string = NULL;
1244 }
1245 webrtc::Trace::ReturnTrace();
1246 }
1247
1248 static PeerConnectionFactoryInterface* factoryFromJava(jlong j_p) {
1249 return reinterpret_cast<OwnedFactoryAndThreads*>(j_p)->factory();
1250 }
1251
1252 JOW(void, PeerConnectionFactory_nativeThreadsCallbacks)(
1253 JNIEnv*, jclass, jlong j_p) {
1254 OwnedFactoryAndThreads *factory =
1255 reinterpret_cast<OwnedFactoryAndThreads*>(j_p);
1256 factory->InvokeJavaCallbacksOnFactoryThreads();
1257 }
1258
1259 JOW(jlong, PeerConnectionFactory_nativeCreateLocalMediaStream)(
1260 JNIEnv* jni, jclass, jlong native_factory, jstring label) {
1261 rtc::scoped_refptr<PeerConnectionFactoryInterface> factory(
1262 factoryFromJava(native_factory));
1263 rtc::scoped_refptr<MediaStreamInterface> stream(
1264 factory->CreateLocalMediaStream(JavaToStdString(jni, label)));
1265 return (jlong)stream.release();
1266 }
1267
1268 JOW(jlong, PeerConnectionFactory_nativeCreateVideoSource)
1269 (JNIEnv* jni, jclass, jlong native_factory, jobject j_egl_context,
1270 jboolean is_screencast) {
1271 OwnedFactoryAndThreads* factory =
1272 reinterpret_cast<OwnedFactoryAndThreads*>(native_factory);
1273
1274 rtc::scoped_refptr<webrtc::AndroidVideoTrackSource> source(
1275 new rtc::RefCountedObject<webrtc::AndroidVideoTrackSource>(
1276 factory->signaling_thread(), jni, j_egl_context, is_screencast));
1277 rtc::scoped_refptr<webrtc::VideoTrackSourceProxy> proxy_source =
1278 webrtc::VideoTrackSourceProxy::Create(factory->signaling_thread(),
1279 factory->worker_thread(), source);
1280
1281 return (jlong)proxy_source.release();
1282 }
1283
1284 JOW(void, PeerConnectionFactory_nativeInitializeVideoCapturer)
1285 (JNIEnv* jni,
1286 jclass,
1287 jlong native_factory,
1288 jobject j_video_capturer,
1289 jlong native_source,
1290 jobject j_frame_observer) {
1291 LOG(LS_INFO) << "PeerConnectionFactory_nativeInitializeVideoCapturer";
1292 rtc::scoped_refptr<PeerConnectionFactoryInterface> factory(
1293 factoryFromJava(native_factory));
1294 auto proxy_source =
1295 reinterpret_cast<webrtc::VideoTrackSourceProxy*>(native_source);
1296 auto source = reinterpret_cast<webrtc::AndroidVideoTrackSource*>(
1297 proxy_source->internal());
1298 rtc::scoped_refptr<SurfaceTextureHelper> surface_texture_helper =
1299 source->surface_texture_helper();
1300 jni->CallVoidMethod(
1301 j_video_capturer,
1302 GetMethodID(jni, FindClass(jni, "org/webrtc/VideoCapturer"), "initialize",
1303 "(Lorg/webrtc/SurfaceTextureHelper;Landroid/content/"
1304 "Context;Lorg/webrtc/VideoCapturer$CapturerObserver;)V"),
1305 surface_texture_helper
1306 ? surface_texture_helper->GetJavaSurfaceTextureHelper()
1307 : nullptr,
1308 j_application_context, j_frame_observer);
1309 CHECK_EXCEPTION(jni) << "error during VideoCapturer.initialize()";
1310 }
1311
1312 JOW(jlong, PeerConnectionFactory_nativeCreateVideoTrack)(
1313 JNIEnv* jni, jclass, jlong native_factory, jstring id,
1314 jlong native_source) {
1315 rtc::scoped_refptr<PeerConnectionFactoryInterface> factory(
1316 factoryFromJava(native_factory));
1317 rtc::scoped_refptr<VideoTrackInterface> track(factory->CreateVideoTrack(
1318 JavaToStdString(jni, id),
1319 reinterpret_cast<VideoTrackSourceInterface*>(native_source)));
1320 return (jlong)track.release();
1321 }
1322
1323 JOW(jlong, PeerConnectionFactory_nativeCreateAudioSource)(
1324 JNIEnv* jni, jclass, jlong native_factory, jobject j_constraints) {
1325 std::unique_ptr<ConstraintsWrapper> constraints(
1326 new ConstraintsWrapper(jni, j_constraints));
1327 rtc::scoped_refptr<PeerConnectionFactoryInterface> factory(
1328 factoryFromJava(native_factory));
1329 rtc::scoped_refptr<AudioSourceInterface> source(
1330 factory->CreateAudioSource(constraints.get()));
1331 return (jlong)source.release();
1332 }
1333
1334 JOW(jlong, PeerConnectionFactory_nativeCreateAudioTrack)(
1335 JNIEnv* jni, jclass, jlong native_factory, jstring id,
1336 jlong native_source) {
1337 rtc::scoped_refptr<PeerConnectionFactoryInterface> factory(
1338 factoryFromJava(native_factory));
1339 rtc::scoped_refptr<AudioTrackInterface> track(factory->CreateAudioTrack(
1340 JavaToStdString(jni, id),
1341 reinterpret_cast<AudioSourceInterface*>(native_source)));
1342 return (jlong)track.release();
1343 }
1344
1345 JOW(jboolean, PeerConnectionFactory_nativeStartAecDump)(
1346 JNIEnv* jni, jclass, jlong native_factory, jint file,
1347 jint filesize_limit_bytes) {
1348 rtc::scoped_refptr<PeerConnectionFactoryInterface> factory(
1349 factoryFromJava(native_factory));
1350 return factory->StartAecDump(file, filesize_limit_bytes);
1351 }
1352
1353 JOW(void, PeerConnectionFactory_nativeStopAecDump)(
1354 JNIEnv* jni, jclass, jlong native_factory) {
1355 rtc::scoped_refptr<PeerConnectionFactoryInterface> factory(
1356 factoryFromJava(native_factory));
1357 factory->StopAecDump();
1358 }
1359
1360 JOW(void, PeerConnectionFactory_nativeSetOptions)(
1361 JNIEnv* jni, jclass, jlong native_factory, jobject options) {
1362 rtc::scoped_refptr<PeerConnectionFactoryInterface> factory(
1363 factoryFromJava(native_factory));
1364 PeerConnectionFactoryInterface::Options options_to_set =
1365 ParseOptionsFromJava(jni, options);
1366 factory->SetOptions(options_to_set);
1367
1368 if (options_to_set.disable_network_monitor) {
1369 OwnedFactoryAndThreads* owner =
1370 reinterpret_cast<OwnedFactoryAndThreads*>(native_factory);
1371 if (owner->network_monitor_factory()) {
1372 rtc::NetworkMonitorFactory::ReleaseFactory(
1373 owner->network_monitor_factory());
1374 owner->clear_network_monitor_factory();
1375 }
1376 }
1377 }
1378
1379 JOW(void, PeerConnectionFactory_nativeSetVideoHwAccelerationOptions)(
1380 JNIEnv* jni, jclass, jlong native_factory, jobject local_egl_context,
1381 jobject remote_egl_context) {
1382 OwnedFactoryAndThreads* owned_factory =
1383 reinterpret_cast<OwnedFactoryAndThreads*>(native_factory);
1384
1385 jclass j_eglbase14_context_class =
1386 FindClass(jni, "org/webrtc/EglBase14$Context");
1387
1388 MediaCodecVideoEncoderFactory* encoder_factory =
1389 static_cast<MediaCodecVideoEncoderFactory*>
1390 (owned_factory->encoder_factory());
1391 if (encoder_factory &&
1392 jni->IsInstanceOf(local_egl_context, j_eglbase14_context_class)) {
1393 LOG(LS_INFO) << "Set EGL context for HW encoding.";
1394 encoder_factory->SetEGLContext(jni, local_egl_context);
1395 }
1396
1397 MediaCodecVideoDecoderFactory* decoder_factory =
1398 static_cast<MediaCodecVideoDecoderFactory*>
1399 (owned_factory->decoder_factory());
1400 if (decoder_factory) {
1401 LOG(LS_INFO) << "Set EGL context for HW decoding.";
1402 decoder_factory->SetEGLContext(jni, remote_egl_context);
1403 }
1404 }
1405
1406 static PeerConnectionInterface::IceTransportsType
1407 JavaIceTransportsTypeToNativeType(JNIEnv* jni, jobject j_ice_transports_type) {
1408 std::string enum_name = GetJavaEnumName(
1409 jni, "org/webrtc/PeerConnection$IceTransportsType",
1410 j_ice_transports_type);
1411
1412 if (enum_name == "ALL")
1413 return PeerConnectionInterface::kAll;
1414
1415 if (enum_name == "RELAY")
1416 return PeerConnectionInterface::kRelay;
1417
1418 if (enum_name == "NOHOST")
1419 return PeerConnectionInterface::kNoHost;
1420
1421 if (enum_name == "NONE")
1422 return PeerConnectionInterface::kNone;
1423
1424 RTC_CHECK(false) << "Unexpected IceTransportsType enum_name " << enum_name;
1425 return PeerConnectionInterface::kAll;
1426 }
1427
1428 static PeerConnectionInterface::BundlePolicy
1429 JavaBundlePolicyToNativeType(JNIEnv* jni, jobject j_bundle_policy) {
1430 std::string enum_name = GetJavaEnumName(
1431 jni, "org/webrtc/PeerConnection$BundlePolicy",
1432 j_bundle_policy);
1433
1434 if (enum_name == "BALANCED")
1435 return PeerConnectionInterface::kBundlePolicyBalanced;
1436
1437 if (enum_name == "MAXBUNDLE")
1438 return PeerConnectionInterface::kBundlePolicyMaxBundle;
1439
1440 if (enum_name == "MAXCOMPAT")
1441 return PeerConnectionInterface::kBundlePolicyMaxCompat;
1442
1443 RTC_CHECK(false) << "Unexpected BundlePolicy enum_name " << enum_name;
1444 return PeerConnectionInterface::kBundlePolicyBalanced;
1445 }
1446
1447 static PeerConnectionInterface::RtcpMuxPolicy
1448 JavaRtcpMuxPolicyToNativeType(JNIEnv* jni, jobject j_rtcp_mux_policy) {
1449 std::string enum_name = GetJavaEnumName(
1450 jni, "org/webrtc/PeerConnection$RtcpMuxPolicy",
1451 j_rtcp_mux_policy);
1452
1453 if (enum_name == "NEGOTIATE")
1454 return PeerConnectionInterface::kRtcpMuxPolicyNegotiate;
1455
1456 if (enum_name == "REQUIRE")
1457 return PeerConnectionInterface::kRtcpMuxPolicyRequire;
1458
1459 RTC_CHECK(false) << "Unexpected RtcpMuxPolicy enum_name " << enum_name;
1460 return PeerConnectionInterface::kRtcpMuxPolicyNegotiate;
1461 }
1462
1463 static PeerConnectionInterface::TcpCandidatePolicy
1464 JavaTcpCandidatePolicyToNativeType(
1465 JNIEnv* jni, jobject j_tcp_candidate_policy) {
1466 std::string enum_name = GetJavaEnumName(
1467 jni, "org/webrtc/PeerConnection$TcpCandidatePolicy",
1468 j_tcp_candidate_policy);
1469
1470 if (enum_name == "ENABLED")
1471 return PeerConnectionInterface::kTcpCandidatePolicyEnabled;
1472
1473 if (enum_name == "DISABLED")
1474 return PeerConnectionInterface::kTcpCandidatePolicyDisabled;
1475
1476 RTC_CHECK(false) << "Unexpected TcpCandidatePolicy enum_name " << enum_name;
1477 return PeerConnectionInterface::kTcpCandidatePolicyEnabled;
1478 }
1479
1480 static PeerConnectionInterface::CandidateNetworkPolicy
1481 JavaCandidateNetworkPolicyToNativeType(JNIEnv* jni,
1482 jobject j_candidate_network_policy) {
1483 std::string enum_name =
1484 GetJavaEnumName(jni, "org/webrtc/PeerConnection$CandidateNetworkPolicy",
1485 j_candidate_network_policy);
1486
1487 if (enum_name == "ALL")
1488 return PeerConnectionInterface::kCandidateNetworkPolicyAll;
1489
1490 if (enum_name == "LOW_COST")
1491 return PeerConnectionInterface::kCandidateNetworkPolicyLowCost;
1492
1493 RTC_CHECK(false) << "Unexpected CandidateNetworkPolicy enum_name "
1494 << enum_name;
1495 return PeerConnectionInterface::kCandidateNetworkPolicyAll;
1496 }
1497
1498 static rtc::KeyType JavaKeyTypeToNativeType(JNIEnv* jni, jobject j_key_type) {
1499 std::string enum_name = GetJavaEnumName(
1500 jni, "org/webrtc/PeerConnection$KeyType", j_key_type);
1501
1502 if (enum_name == "RSA")
1503 return rtc::KT_RSA;
1504 if (enum_name == "ECDSA")
1505 return rtc::KT_ECDSA;
1506
1507 RTC_CHECK(false) << "Unexpected KeyType enum_name " << enum_name;
1508 return rtc::KT_ECDSA;
1509 }
1510
1511 static PeerConnectionInterface::ContinualGatheringPolicy
1512 JavaContinualGatheringPolicyToNativeType(
1513 JNIEnv* jni, jobject j_gathering_policy) {
1514 std::string enum_name = GetJavaEnumName(
1515 jni, "org/webrtc/PeerConnection$ContinualGatheringPolicy",
1516 j_gathering_policy);
1517 if (enum_name == "GATHER_ONCE")
1518 return PeerConnectionInterface::GATHER_ONCE;
1519
1520 if (enum_name == "GATHER_CONTINUALLY")
1521 return PeerConnectionInterface::GATHER_CONTINUALLY;
1522
1523 RTC_CHECK(false) << "Unexpected ContinualGatheringPolicy enum name "
1524 << enum_name;
1525 return PeerConnectionInterface::GATHER_ONCE;
1526 }
1527
1528 static void JavaIceServersToJsepIceServers(
1529 JNIEnv* jni, jobject j_ice_servers,
1530 PeerConnectionInterface::IceServers* ice_servers) {
1531 for (jobject j_ice_server : Iterable(jni, j_ice_servers)) {
1532 jclass j_ice_server_class = GetObjectClass(jni, j_ice_server);
1533 jfieldID j_ice_server_uri_id =
1534 GetFieldID(jni, j_ice_server_class, "uri", "Ljava/lang/String;");
1535 jfieldID j_ice_server_username_id =
1536 GetFieldID(jni, j_ice_server_class, "username", "Ljava/lang/String;");
1537 jfieldID j_ice_server_password_id =
1538 GetFieldID(jni, j_ice_server_class, "password", "Ljava/lang/String;");
1539 jstring uri = reinterpret_cast<jstring>(
1540 GetObjectField(jni, j_ice_server, j_ice_server_uri_id));
1541 jstring username = reinterpret_cast<jstring>(
1542 GetObjectField(jni, j_ice_server, j_ice_server_username_id));
1543 jstring password = reinterpret_cast<jstring>(
1544 GetObjectField(jni, j_ice_server, j_ice_server_password_id));
1545 PeerConnectionInterface::IceServer server;
1546 server.uri = JavaToStdString(jni, uri);
1547 server.username = JavaToStdString(jni, username);
1548 server.password = JavaToStdString(jni, password);
1549 ice_servers->push_back(server);
1550 }
1551 }
1552
1553 static void JavaRTCConfigurationToJsepRTCConfiguration(
1554 JNIEnv* jni,
1555 jobject j_rtc_config,
1556 PeerConnectionInterface::RTCConfiguration* rtc_config) {
1557 jclass j_rtc_config_class = GetObjectClass(jni, j_rtc_config);
1558
1559 jfieldID j_ice_transports_type_id = GetFieldID(
1560 jni, j_rtc_config_class, "iceTransportsType",
1561 "Lorg/webrtc/PeerConnection$IceTransportsType;");
1562 jobject j_ice_transports_type = GetObjectField(
1563 jni, j_rtc_config, j_ice_transports_type_id);
1564
1565 jfieldID j_bundle_policy_id = GetFieldID(
1566 jni, j_rtc_config_class, "bundlePolicy",
1567 "Lorg/webrtc/PeerConnection$BundlePolicy;");
1568 jobject j_bundle_policy = GetObjectField(
1569 jni, j_rtc_config, j_bundle_policy_id);
1570
1571 jfieldID j_rtcp_mux_policy_id = GetFieldID(
1572 jni, j_rtc_config_class, "rtcpMuxPolicy",
1573 "Lorg/webrtc/PeerConnection$RtcpMuxPolicy;");
1574 jobject j_rtcp_mux_policy = GetObjectField(
1575 jni, j_rtc_config, j_rtcp_mux_policy_id);
1576
1577 jfieldID j_tcp_candidate_policy_id = GetFieldID(
1578 jni, j_rtc_config_class, "tcpCandidatePolicy",
1579 "Lorg/webrtc/PeerConnection$TcpCandidatePolicy;");
1580 jobject j_tcp_candidate_policy = GetObjectField(
1581 jni, j_rtc_config, j_tcp_candidate_policy_id);
1582
1583 jfieldID j_candidate_network_policy_id = GetFieldID(
1584 jni, j_rtc_config_class, "candidateNetworkPolicy",
1585 "Lorg/webrtc/PeerConnection$CandidateNetworkPolicy;");
1586 jobject j_candidate_network_policy = GetObjectField(
1587 jni, j_rtc_config, j_candidate_network_policy_id);
1588
1589 jfieldID j_ice_servers_id = GetFieldID(
1590 jni, j_rtc_config_class, "iceServers", "Ljava/util/List;");
1591 jobject j_ice_servers = GetObjectField(jni, j_rtc_config, j_ice_servers_id);
1592
1593 jfieldID j_audio_jitter_buffer_max_packets_id =
1594 GetFieldID(jni, j_rtc_config_class, "audioJitterBufferMaxPackets", "I");
1595 jfieldID j_audio_jitter_buffer_fast_accelerate_id = GetFieldID(
1596 jni, j_rtc_config_class, "audioJitterBufferFastAccelerate", "Z");
1597
1598 jfieldID j_ice_connection_receiving_timeout_id =
1599 GetFieldID(jni, j_rtc_config_class, "iceConnectionReceivingTimeout", "I");
1600
1601 jfieldID j_ice_backup_candidate_pair_ping_interval_id = GetFieldID(
1602 jni, j_rtc_config_class, "iceBackupCandidatePairPingInterval", "I");
1603
1604 jfieldID j_continual_gathering_policy_id =
1605 GetFieldID(jni, j_rtc_config_class, "continualGatheringPolicy",
1606 "Lorg/webrtc/PeerConnection$ContinualGatheringPolicy;");
1607 jobject j_continual_gathering_policy =
1608 GetObjectField(jni, j_rtc_config, j_continual_gathering_policy_id);
1609
1610 jfieldID j_ice_candidate_pool_size_id =
1611 GetFieldID(jni, j_rtc_config_class, "iceCandidatePoolSize", "I");
1612 jfieldID j_presume_writable_when_fully_relayed_id = GetFieldID(
1613 jni, j_rtc_config_class, "presumeWritableWhenFullyRelayed", "Z");
1614
1615 jfieldID j_prune_turn_ports_id =
1616 GetFieldID(jni, j_rtc_config_class, "pruneTurnPorts", "Z");
1617
1618 rtc_config->type =
1619 JavaIceTransportsTypeToNativeType(jni, j_ice_transports_type);
1620 rtc_config->bundle_policy =
1621 JavaBundlePolicyToNativeType(jni, j_bundle_policy);
1622 rtc_config->rtcp_mux_policy =
1623 JavaRtcpMuxPolicyToNativeType(jni, j_rtcp_mux_policy);
1624 rtc_config->tcp_candidate_policy =
1625 JavaTcpCandidatePolicyToNativeType(jni, j_tcp_candidate_policy);
1626 rtc_config->candidate_network_policy =
1627 JavaCandidateNetworkPolicyToNativeType(jni, j_candidate_network_policy);
1628 JavaIceServersToJsepIceServers(jni, j_ice_servers, &rtc_config->servers);
1629 rtc_config->audio_jitter_buffer_max_packets =
1630 GetIntField(jni, j_rtc_config, j_audio_jitter_buffer_max_packets_id);
1631 rtc_config->audio_jitter_buffer_fast_accelerate = GetBooleanField(
1632 jni, j_rtc_config, j_audio_jitter_buffer_fast_accelerate_id);
1633 rtc_config->ice_connection_receiving_timeout =
1634 GetIntField(jni, j_rtc_config, j_ice_connection_receiving_timeout_id);
1635 rtc_config->ice_backup_candidate_pair_ping_interval = GetIntField(
1636 jni, j_rtc_config, j_ice_backup_candidate_pair_ping_interval_id);
1637 rtc_config->continual_gathering_policy =
1638 JavaContinualGatheringPolicyToNativeType(
1639 jni, j_continual_gathering_policy);
1640 rtc_config->ice_candidate_pool_size =
1641 GetIntField(jni, j_rtc_config, j_ice_candidate_pool_size_id);
1642 rtc_config->prune_turn_ports =
1643 GetBooleanField(jni, j_rtc_config, j_prune_turn_ports_id);
1644 rtc_config->presume_writable_when_fully_relayed = GetBooleanField(
1645 jni, j_rtc_config, j_presume_writable_when_fully_relayed_id);
1646 }
1647
1648 JOW(jlong, PeerConnectionFactory_nativeCreatePeerConnection)(
1649 JNIEnv *jni, jclass, jlong factory, jobject j_rtc_config,
1650 jobject j_constraints, jlong observer_p) {
1651 rtc::scoped_refptr<PeerConnectionFactoryInterface> f(
1652 reinterpret_cast<PeerConnectionFactoryInterface*>(
1653 factoryFromJava(factory)));
1654
1655 PeerConnectionInterface::RTCConfiguration rtc_config(
1656 PeerConnectionInterface::RTCConfigurationType::kAggressive);
1657 JavaRTCConfigurationToJsepRTCConfiguration(jni, j_rtc_config, &rtc_config);
1658
1659 jclass j_rtc_config_class = GetObjectClass(jni, j_rtc_config);
1660 jfieldID j_key_type_id = GetFieldID(jni, j_rtc_config_class, "keyType",
1661 "Lorg/webrtc/PeerConnection$KeyType;");
1662 jobject j_key_type = GetObjectField(jni, j_rtc_config, j_key_type_id);
1663
1664 // Generate non-default certificate.
1665 rtc::KeyType key_type = JavaKeyTypeToNativeType(jni, j_key_type);
1666 if (key_type != rtc::KT_DEFAULT) {
1667 rtc::scoped_refptr<rtc::RTCCertificate> certificate =
1668 rtc::RTCCertificateGenerator::GenerateCertificate(
1669 rtc::KeyParams(key_type), rtc::Optional<uint64_t>());
1670 if (!certificate) {
1671 LOG(LS_ERROR) << "Failed to generate certificate. KeyType: " << key_type;
1672 return 0;
1673 }
1674 rtc_config.certificates.push_back(certificate);
1675 }
1676
1677 PCOJava* observer = reinterpret_cast<PCOJava*>(observer_p);
1678 observer->SetConstraints(new ConstraintsWrapper(jni, j_constraints));
1679 rtc::scoped_refptr<PeerConnectionInterface> pc(f->CreatePeerConnection(
1680 rtc_config, observer->constraints(), NULL, NULL, observer));
1681 return (jlong)pc.release();
1682 }
1683
1684 static rtc::scoped_refptr<PeerConnectionInterface> ExtractNativePC(
1685 JNIEnv* jni, jobject j_pc) {
1686 jfieldID native_pc_id = GetFieldID(jni,
1687 GetObjectClass(jni, j_pc), "nativePeerConnection", "J");
1688 jlong j_p = GetLongField(jni, j_pc, native_pc_id);
1689 return rtc::scoped_refptr<PeerConnectionInterface>(
1690 reinterpret_cast<PeerConnectionInterface*>(j_p));
1691 }
1692
1693 JOW(jobject, PeerConnection_getLocalDescription)(JNIEnv* jni, jobject j_pc) {
1694 const SessionDescriptionInterface* sdp =
1695 ExtractNativePC(jni, j_pc)->local_description();
1696 return sdp ? JavaSdpFromNativeSdp(jni, sdp) : NULL;
1697 }
1698
1699 JOW(jobject, PeerConnection_getRemoteDescription)(JNIEnv* jni, jobject j_pc) {
1700 const SessionDescriptionInterface* sdp =
1701 ExtractNativePC(jni, j_pc)->remote_description();
1702 return sdp ? JavaSdpFromNativeSdp(jni, sdp) : NULL;
1703 }
1704
1705 JOW(jobject, PeerConnection_createDataChannel)(
1706 JNIEnv* jni, jobject j_pc, jstring j_label, jobject j_init) {
1707 DataChannelInit init = JavaDataChannelInitToNative(jni, j_init);
1708 rtc::scoped_refptr<DataChannelInterface> channel(
1709 ExtractNativePC(jni, j_pc)->CreateDataChannel(
1710 JavaToStdString(jni, j_label), &init));
1711 // Mustn't pass channel.get() directly through NewObject to avoid reading its
1712 // vararg parameter as 64-bit and reading memory that doesn't belong to the
1713 // 32-bit parameter.
1714 jlong nativeChannelPtr = jlongFromPointer(channel.get());
1715 if (!nativeChannelPtr) {
1716 LOG(LS_ERROR) << "Failed to create DataChannel";
1717 return nullptr;
1718 }
1719 jclass j_data_channel_class = FindClass(jni, "org/webrtc/DataChannel");
1720 jmethodID j_data_channel_ctor = GetMethodID(
1721 jni, j_data_channel_class, "<init>", "(J)V");
1722 jobject j_channel = jni->NewObject(
1723 j_data_channel_class, j_data_channel_ctor, nativeChannelPtr);
1724 CHECK_EXCEPTION(jni) << "error during NewObject";
1725 // Channel is now owned by Java object, and will be freed from there.
1726 int bumped_count = channel->AddRef();
1727 RTC_CHECK(bumped_count == 2) << "Unexpected refcount";
1728 return j_channel;
1729 }
1730
1731 JOW(void, PeerConnection_createOffer)(
1732 JNIEnv* jni, jobject j_pc, jobject j_observer, jobject j_constraints) {
1733 ConstraintsWrapper* constraints =
1734 new ConstraintsWrapper(jni, j_constraints);
1735 rtc::scoped_refptr<CreateSdpObserverWrapper> observer(
1736 new rtc::RefCountedObject<CreateSdpObserverWrapper>(
1737 jni, j_observer, constraints));
1738 ExtractNativePC(jni, j_pc)->CreateOffer(observer, constraints);
1739 }
1740
1741 JOW(void, PeerConnection_createAnswer)(
1742 JNIEnv* jni, jobject j_pc, jobject j_observer, jobject j_constraints) {
1743 ConstraintsWrapper* constraints =
1744 new ConstraintsWrapper(jni, j_constraints);
1745 rtc::scoped_refptr<CreateSdpObserverWrapper> observer(
1746 new rtc::RefCountedObject<CreateSdpObserverWrapper>(
1747 jni, j_observer, constraints));
1748 ExtractNativePC(jni, j_pc)->CreateAnswer(observer, constraints);
1749 }
1750
1751 // Helper to create a SessionDescriptionInterface from a SessionDescription.
1752 static SessionDescriptionInterface* JavaSdpToNativeSdp(
1753 JNIEnv* jni, jobject j_sdp) {
1754 jfieldID j_type_id = GetFieldID(
1755 jni, GetObjectClass(jni, j_sdp), "type",
1756 "Lorg/webrtc/SessionDescription$Type;");
1757 jobject j_type = GetObjectField(jni, j_sdp, j_type_id);
1758 jmethodID j_canonical_form_id = GetMethodID(
1759 jni, GetObjectClass(jni, j_type), "canonicalForm",
1760 "()Ljava/lang/String;");
1761 jstring j_type_string = (jstring)jni->CallObjectMethod(
1762 j_type, j_canonical_form_id);
1763 CHECK_EXCEPTION(jni) << "error during CallObjectMethod";
1764 std::string std_type = JavaToStdString(jni, j_type_string);
1765
1766 jfieldID j_description_id = GetFieldID(
1767 jni, GetObjectClass(jni, j_sdp), "description", "Ljava/lang/String;");
1768 jstring j_description = (jstring)GetObjectField(jni, j_sdp, j_description_id);
1769 std::string std_description = JavaToStdString(jni, j_description);
1770
1771 return webrtc::CreateSessionDescription(
1772 std_type, std_description, NULL);
1773 }
1774
1775 JOW(void, PeerConnection_setLocalDescription)(
1776 JNIEnv* jni, jobject j_pc,
1777 jobject j_observer, jobject j_sdp) {
1778 rtc::scoped_refptr<SetSdpObserverWrapper> observer(
1779 new rtc::RefCountedObject<SetSdpObserverWrapper>(
1780 jni, j_observer, reinterpret_cast<ConstraintsWrapper*>(NULL)));
1781 ExtractNativePC(jni, j_pc)->SetLocalDescription(
1782 observer, JavaSdpToNativeSdp(jni, j_sdp));
1783 }
1784
1785 JOW(void, PeerConnection_setRemoteDescription)(
1786 JNIEnv* jni, jobject j_pc,
1787 jobject j_observer, jobject j_sdp) {
1788 rtc::scoped_refptr<SetSdpObserverWrapper> observer(
1789 new rtc::RefCountedObject<SetSdpObserverWrapper>(
1790 jni, j_observer, reinterpret_cast<ConstraintsWrapper*>(NULL)));
1791 ExtractNativePC(jni, j_pc)->SetRemoteDescription(
1792 observer, JavaSdpToNativeSdp(jni, j_sdp));
1793 }
1794
1795 JOW(jboolean, PeerConnection_setConfiguration)(
1796 JNIEnv* jni, jobject j_pc, jobject j_rtc_config) {
1797 PeerConnectionInterface::RTCConfiguration rtc_config(
1798 PeerConnectionInterface::RTCConfigurationType::kAggressive);
1799 JavaRTCConfigurationToJsepRTCConfiguration(jni, j_rtc_config, &rtc_config);
1800 return ExtractNativePC(jni, j_pc)->SetConfiguration(rtc_config);
1801 }
1802
1803 JOW(jboolean, PeerConnection_nativeAddIceCandidate)(
1804 JNIEnv* jni, jobject j_pc, jstring j_sdp_mid,
1805 jint j_sdp_mline_index, jstring j_candidate_sdp) {
1806 std::string sdp_mid = JavaToStdString(jni, j_sdp_mid);
1807 std::string sdp = JavaToStdString(jni, j_candidate_sdp);
1808 std::unique_ptr<IceCandidateInterface> candidate(
1809 webrtc::CreateIceCandidate(sdp_mid, j_sdp_mline_index, sdp, NULL));
1810 return ExtractNativePC(jni, j_pc)->AddIceCandidate(candidate.get());
1811 }
1812
1813 static cricket::Candidate GetCandidateFromJava(JNIEnv* jni,
1814 jobject j_candidate) {
1815 jclass j_candidate_class = GetObjectClass(jni, j_candidate);
1816 jfieldID j_sdp_mid_id =
1817 GetFieldID(jni, j_candidate_class, "sdpMid", "Ljava/lang/String;");
1818 std::string sdp_mid =
1819 JavaToStdString(jni, GetStringField(jni, j_candidate, j_sdp_mid_id));
1820 jfieldID j_sdp_id =
1821 GetFieldID(jni, j_candidate_class, "sdp", "Ljava/lang/String;");
1822 std::string sdp =
1823 JavaToStdString(jni, GetStringField(jni, j_candidate, j_sdp_id));
1824 cricket::Candidate candidate;
1825 if (!webrtc::SdpDeserializeCandidate(sdp_mid, sdp, &candidate, NULL)) {
1826 LOG(LS_ERROR) << "SdpDescrializeCandidate failed with sdp " << sdp;
1827 }
1828 return candidate;
1829 }
1830
1831 JOW(jboolean, PeerConnection_nativeRemoveIceCandidates)
1832 (JNIEnv* jni, jobject j_pc, jobjectArray j_candidates) {
1833 std::vector<cricket::Candidate> candidates;
1834 size_t num_candidates = jni->GetArrayLength(j_candidates);
1835 for (size_t i = 0; i < num_candidates; ++i) {
1836 jobject j_candidate = jni->GetObjectArrayElement(j_candidates, i);
1837 candidates.push_back(GetCandidateFromJava(jni, j_candidate));
1838 }
1839 return ExtractNativePC(jni, j_pc)->RemoveIceCandidates(candidates);
1840 }
1841
1842 JOW(jboolean, PeerConnection_nativeAddLocalStream)(
1843 JNIEnv* jni, jobject j_pc, jlong native_stream) {
1844 return ExtractNativePC(jni, j_pc)->AddStream(
1845 reinterpret_cast<MediaStreamInterface*>(native_stream));
1846 }
1847
1848 JOW(void, PeerConnection_nativeRemoveLocalStream)(
1849 JNIEnv* jni, jobject j_pc, jlong native_stream) {
1850 ExtractNativePC(jni, j_pc)->RemoveStream(
1851 reinterpret_cast<MediaStreamInterface*>(native_stream));
1852 }
1853
1854 JOW(jobject, PeerConnection_nativeCreateSender)(
1855 JNIEnv* jni, jobject j_pc, jstring j_kind, jstring j_stream_id) {
1856 jclass j_rtp_sender_class = FindClass(jni, "org/webrtc/RtpSender");
1857 jmethodID j_rtp_sender_ctor =
1858 GetMethodID(jni, j_rtp_sender_class, "<init>", "(J)V");
1859
1860 std::string kind = JavaToStdString(jni, j_kind);
1861 std::string stream_id = JavaToStdString(jni, j_stream_id);
1862 rtc::scoped_refptr<RtpSenderInterface> sender =
1863 ExtractNativePC(jni, j_pc)->CreateSender(kind, stream_id);
1864 if (!sender.get()) {
1865 return nullptr;
1866 }
1867 jlong nativeSenderPtr = jlongFromPointer(sender.get());
1868 jobject j_sender =
1869 jni->NewObject(j_rtp_sender_class, j_rtp_sender_ctor, nativeSenderPtr);
1870 CHECK_EXCEPTION(jni) << "error during NewObject";
1871 // Sender is now owned by the Java object, and will be freed from
1872 // RtpSender.dispose(), called by PeerConnection.dispose() or getSenders().
1873 sender->AddRef();
1874 return j_sender;
1875 }
1876
1877 JOW(jobject, PeerConnection_nativeGetSenders)(JNIEnv* jni, jobject j_pc) {
1878 jclass j_array_list_class = FindClass(jni, "java/util/ArrayList");
1879 jmethodID j_array_list_ctor =
1880 GetMethodID(jni, j_array_list_class, "<init>", "()V");
1881 jmethodID j_array_list_add =
1882 GetMethodID(jni, j_array_list_class, "add", "(Ljava/lang/Object;)Z");
1883 jobject j_senders = jni->NewObject(j_array_list_class, j_array_list_ctor);
1884 CHECK_EXCEPTION(jni) << "error during NewObject";
1885
1886 jclass j_rtp_sender_class = FindClass(jni, "org/webrtc/RtpSender");
1887 jmethodID j_rtp_sender_ctor =
1888 GetMethodID(jni, j_rtp_sender_class, "<init>", "(J)V");
1889
1890 auto senders = ExtractNativePC(jni, j_pc)->GetSenders();
1891 for (const auto& sender : senders) {
1892 jlong nativeSenderPtr = jlongFromPointer(sender.get());
1893 jobject j_sender =
1894 jni->NewObject(j_rtp_sender_class, j_rtp_sender_ctor, nativeSenderPtr);
1895 CHECK_EXCEPTION(jni) << "error during NewObject";
1896 // Sender is now owned by the Java object, and will be freed from
1897 // RtpSender.dispose(), called by PeerConnection.dispose() or getSenders().
1898 sender->AddRef();
1899 jni->CallBooleanMethod(j_senders, j_array_list_add, j_sender);
1900 CHECK_EXCEPTION(jni) << "error during CallBooleanMethod";
1901 }
1902 return j_senders;
1903 }
1904
1905 JOW(jobject, PeerConnection_nativeGetReceivers)(JNIEnv* jni, jobject j_pc) {
1906 jclass j_array_list_class = FindClass(jni, "java/util/ArrayList");
1907 jmethodID j_array_list_ctor =
1908 GetMethodID(jni, j_array_list_class, "<init>", "()V");
1909 jmethodID j_array_list_add =
1910 GetMethodID(jni, j_array_list_class, "add", "(Ljava/lang/Object;)Z");
1911 jobject j_receivers = jni->NewObject(j_array_list_class, j_array_list_ctor);
1912 CHECK_EXCEPTION(jni) << "error during NewObject";
1913
1914 jclass j_rtp_receiver_class = FindClass(jni, "org/webrtc/RtpReceiver");
1915 jmethodID j_rtp_receiver_ctor =
1916 GetMethodID(jni, j_rtp_receiver_class, "<init>", "(J)V");
1917
1918 auto receivers = ExtractNativePC(jni, j_pc)->GetReceivers();
1919 for (const auto& receiver : receivers) {
1920 jlong nativeReceiverPtr = jlongFromPointer(receiver.get());
1921 jobject j_receiver = jni->NewObject(j_rtp_receiver_class,
1922 j_rtp_receiver_ctor, nativeReceiverPtr);
1923 CHECK_EXCEPTION(jni) << "error during NewObject";
1924 // Receiver is now owned by Java object, and will be freed from there.
1925 receiver->AddRef();
1926 jni->CallBooleanMethod(j_receivers, j_array_list_add, j_receiver);
1927 CHECK_EXCEPTION(jni) << "error during CallBooleanMethod";
1928 }
1929 return j_receivers;
1930 }
1931
1932 JOW(bool, PeerConnection_nativeGetStats)(
1933 JNIEnv* jni, jobject j_pc, jobject j_observer, jlong native_track) {
1934 rtc::scoped_refptr<StatsObserverWrapper> observer(
1935 new rtc::RefCountedObject<StatsObserverWrapper>(jni, j_observer));
1936 return ExtractNativePC(jni, j_pc)->GetStats(
1937 observer,
1938 reinterpret_cast<MediaStreamTrackInterface*>(native_track),
1939 PeerConnectionInterface::kStatsOutputLevelStandard);
1940 }
1941
1942 JOW(bool, PeerConnection_nativeStartRtcEventLog)(
1943 JNIEnv* jni, jobject j_pc, int file_descriptor, int max_size_bytes) {
1944 return ExtractNativePC(jni, j_pc)->StartRtcEventLog(file_descriptor,
1945 max_size_bytes);
1946 }
1947
1948 JOW(void, PeerConnection_nativeStopRtcEventLog)(JNIEnv* jni, jobject j_pc) {
1949 ExtractNativePC(jni, j_pc)->StopRtcEventLog();
1950 }
1951
1952 JOW(jobject, PeerConnection_signalingState)(JNIEnv* jni, jobject j_pc) {
1953 PeerConnectionInterface::SignalingState state =
1954 ExtractNativePC(jni, j_pc)->signaling_state();
1955 return JavaEnumFromIndex(jni, "PeerConnection$SignalingState", state);
1956 }
1957
1958 JOW(jobject, PeerConnection_iceConnectionState)(JNIEnv* jni, jobject j_pc) {
1959 PeerConnectionInterface::IceConnectionState state =
1960 ExtractNativePC(jni, j_pc)->ice_connection_state();
1961 return JavaEnumFromIndex(jni, "PeerConnection$IceConnectionState", state);
1962 }
1963
1964 JOW(jobject, PeerConnection_iceGatheringState)(JNIEnv* jni, jobject j_pc) {
1965 PeerConnectionInterface::IceGatheringState state =
1966 ExtractNativePC(jni, j_pc)->ice_gathering_state();
1967 return JavaEnumFromIndex(jni, "PeerConnection$IceGatheringState", state);
1968 }
1969
1970 JOW(void, PeerConnection_close)(JNIEnv* jni, jobject j_pc) {
1971 ExtractNativePC(jni, j_pc)->Close();
1972 return;
1973 }
1974
1975 JOW(jobject, MediaSource_nativeState)(JNIEnv* jni, jclass, jlong j_p) {
1976 rtc::scoped_refptr<MediaSourceInterface> p(
1977 reinterpret_cast<MediaSourceInterface*>(j_p));
1978 return JavaEnumFromIndex(jni, "MediaSource$State", p->state());
1979 }
1980
1981 JOW(jlong, VideoRenderer_nativeWrapVideoRenderer)(
1982 JNIEnv* jni, jclass, jobject j_callbacks) {
1983 std::unique_ptr<JavaVideoRendererWrapper> renderer(
1984 new JavaVideoRendererWrapper(jni, j_callbacks));
1985 return (jlong)renderer.release();
1986 }
1987
1988 JOW(void, VideoRenderer_nativeCopyPlane)(
1989 JNIEnv *jni, jclass, jobject j_src_buffer, jint width, jint height,
1990 jint src_stride, jobject j_dst_buffer, jint dst_stride) {
1991 size_t src_size = jni->GetDirectBufferCapacity(j_src_buffer);
1992 size_t dst_size = jni->GetDirectBufferCapacity(j_dst_buffer);
1993 RTC_CHECK(src_stride >= width) << "Wrong source stride " << src_stride;
1994 RTC_CHECK(dst_stride >= width) << "Wrong destination stride " << dst_stride;
1995 RTC_CHECK(src_size >= src_stride * height)
1996 << "Insufficient source buffer capacity " << src_size;
1997 RTC_CHECK(dst_size >= dst_stride * height)
1998 << "Insufficient destination buffer capacity " << dst_size;
1999 uint8_t *src =
2000 reinterpret_cast<uint8_t*>(jni->GetDirectBufferAddress(j_src_buffer));
2001 uint8_t *dst =
2002 reinterpret_cast<uint8_t*>(jni->GetDirectBufferAddress(j_dst_buffer));
2003 if (src_stride == dst_stride) {
2004 memcpy(dst, src, src_stride * height);
2005 } else {
2006 for (int i = 0; i < height; i++) {
2007 memcpy(dst, src, width);
2008 src += src_stride;
2009 dst += dst_stride;
2010 }
2011 }
2012 }
2013
2014 JOW(void, FileVideoCapturer_nativeI420ToNV21)(
2015 JNIEnv *jni, jclass, jbyteArray j_src_buffer, jint width, jint height,
2016 jbyteArray j_dst_buffer) {
2017 size_t src_size = jni->GetArrayLength(j_src_buffer);
2018 size_t dst_size = jni->GetArrayLength(j_dst_buffer);
2019 int src_stride = width;
2020 int dst_stride = width;
2021 RTC_CHECK_GE(src_size, src_stride * height * 3 / 2);
2022 RTC_CHECK_GE(dst_size, dst_stride * height * 3 / 2);
2023
2024 jbyte* src_bytes = jni->GetByteArrayElements(j_src_buffer, 0);
2025 uint8_t* src = reinterpret_cast<uint8_t*>(src_bytes);
2026 jbyte* dst_bytes = jni->GetByteArrayElements(j_dst_buffer, 0);
2027 uint8_t* dst = reinterpret_cast<uint8_t*>(dst_bytes);
2028
2029 uint8_t* src_y = src;
2030 size_t src_stride_y = src_stride;
2031 uint8_t* src_u = src + src_stride * height;
2032 size_t src_stride_u = src_stride / 2;
2033 uint8_t* src_v = src + src_stride * height * 5 / 4;
2034 size_t src_stride_v = src_stride / 2;
2035
2036 uint8_t* dst_y = dst;
2037 size_t dst_stride_y = dst_stride;
2038 size_t dst_stride_uv = dst_stride;
2039 uint8_t* dst_uv = dst + dst_stride * height;
2040
2041 int ret = libyuv::I420ToNV21(src_y, src_stride_y, src_u, src_stride_u, src_v,
2042 src_stride_v, dst_y, dst_stride_y, dst_uv,
2043 dst_stride_uv, width, height);
2044 jni->ReleaseByteArrayElements(j_src_buffer, src_bytes, 0);
2045 jni->ReleaseByteArrayElements(j_dst_buffer, dst_bytes, 0);
2046 if (ret) {
2047 LOG(LS_ERROR) << "Error converting I420 frame to NV21: " << ret;
2048 }
2049 }
2050
2051 JOW(void, VideoFileRenderer_nativeI420Scale)(
2052 JNIEnv *jni, jclass,
2053 jobject j_src_buffer_y, jint j_src_stride_y,
2054 jobject j_src_buffer_u, jint j_src_stride_u,
2055 jobject j_src_buffer_v, jint j_src_stride_v,
2056 jint width, jint height,
2057 jbyteArray j_dst_buffer, jint dstWidth, jint dstHeight) {
2058 size_t src_size_y = jni->GetDirectBufferCapacity(j_src_buffer_y);
2059 size_t src_size_u = jni->GetDirectBufferCapacity(j_src_buffer_u);
2060 size_t src_size_v = jni->GetDirectBufferCapacity(j_src_buffer_v);
2061 size_t dst_size = jni->GetDirectBufferCapacity(j_dst_buffer);
2062 int dst_stride = dstWidth;
2063 RTC_CHECK_GE(src_size_y, j_src_stride_y * height);
2064 RTC_CHECK_GE(src_size_u, j_src_stride_u * height / 4);
2065 RTC_CHECK_GE(src_size_v, j_src_stride_v * height / 4);
2066 RTC_CHECK_GE(dst_size, dst_stride * height * 3 / 2);
2067 uint8_t* src_y =
2068 reinterpret_cast<uint8_t*>(jni->GetDirectBufferAddress(j_src_buffer_y));
2069 uint8_t* src_u =
2070 reinterpret_cast<uint8_t*>(jni->GetDirectBufferAddress(j_src_buffer_u));
2071 uint8_t* src_v =
2072 reinterpret_cast<uint8_t*>(jni->GetDirectBufferAddress(j_src_buffer_v));
2073 uint8_t* dst =
2074 reinterpret_cast<uint8_t*>(jni->GetDirectBufferAddress(j_dst_buffer));
2075
2076 uint8_t* dst_y = dst;
2077 size_t dst_stride_y = dst_stride;
2078 uint8_t* dst_u = dst + dst_stride * dstHeight;
2079 size_t dst_stride_u = dst_stride / 2;
2080 uint8_t* dst_v = dst + dst_stride * dstHeight * 5 / 4;
2081 size_t dst_stride_v = dst_stride / 2;
2082
2083 int ret = libyuv::I420Scale(
2084 src_y, j_src_stride_y, src_u, j_src_stride_u, src_v, j_src_stride_v,
2085 width, height, dst_y, dst_stride_y, dst_u, dst_stride_u, dst_v,
2086 dst_stride_v, dstWidth, dstHeight, libyuv::kFilterBilinear);
2087 if (ret) {
2088 LOG(LS_ERROR) << "Error scaling I420 frame: " << ret;
2089 }
2090 }
2091
2092 JOW(jstring, MediaStreamTrack_nativeId)(JNIEnv* jni, jclass, jlong j_p) {
2093 return JavaStringFromStdString(
2094 jni, reinterpret_cast<MediaStreamTrackInterface*>(j_p)->id());
2095 }
2096
2097 JOW(jstring, MediaStreamTrack_nativeKind)(JNIEnv* jni, jclass, jlong j_p) {
2098 return JavaStringFromStdString(
2099 jni, reinterpret_cast<MediaStreamTrackInterface*>(j_p)->kind());
2100 }
2101
2102 JOW(jboolean, MediaStreamTrack_nativeEnabled)(JNIEnv* jni, jclass, jlong j_p) {
2103 return reinterpret_cast<MediaStreamTrackInterface*>(j_p)->enabled();
2104 }
2105
2106 JOW(jobject, MediaStreamTrack_nativeState)(JNIEnv* jni, jclass, jlong j_p) {
2107 return JavaEnumFromIndex(
2108 jni,
2109 "MediaStreamTrack$State",
2110 reinterpret_cast<MediaStreamTrackInterface*>(j_p)->state());
2111 }
2112
2113 JOW(jboolean, MediaStreamTrack_nativeSetEnabled)(
2114 JNIEnv* jni, jclass, jlong j_p, jboolean enabled) {
2115 return reinterpret_cast<MediaStreamTrackInterface*>(j_p)
2116 ->set_enabled(enabled);
2117 }
2118
2119 JOW(void, VideoTrack_nativeAddRenderer)(
2120 JNIEnv* jni, jclass,
2121 jlong j_video_track_pointer, jlong j_renderer_pointer) {
2122 LOG(LS_INFO) << "VideoTrack::nativeAddRenderer";
2123 reinterpret_cast<VideoTrackInterface*>(j_video_track_pointer)
2124 ->AddOrUpdateSink(
2125 reinterpret_cast<rtc::VideoSinkInterface<webrtc::VideoFrame>*>(
2126 j_renderer_pointer),
2127 rtc::VideoSinkWants());
2128 }
2129
2130 JOW(void, VideoTrack_nativeRemoveRenderer)(
2131 JNIEnv* jni, jclass,
2132 jlong j_video_track_pointer, jlong j_renderer_pointer) {
2133 reinterpret_cast<VideoTrackInterface*>(j_video_track_pointer)
2134 ->RemoveSink(
2135 reinterpret_cast<rtc::VideoSinkInterface<webrtc::VideoFrame>*>(
2136 j_renderer_pointer));
2137 }
2138
2139 JOW(jlong, CallSessionFileRotatingLogSink_nativeAddSink)(
2140 JNIEnv* jni, jclass,
2141 jstring j_dirPath, jint j_maxFileSize, jint j_severity) {
2142 std::string dir_path = JavaToStdString(jni, j_dirPath);
2143 rtc::CallSessionFileRotatingLogSink* sink =
2144 new rtc::CallSessionFileRotatingLogSink(dir_path, j_maxFileSize);
2145 if (!sink->Init()) {
2146 LOG_V(rtc::LoggingSeverity::LS_WARNING) <<
2147 "Failed to init CallSessionFileRotatingLogSink for path " << dir_path;
2148 delete sink;
2149 return 0;
2150 }
2151 rtc::LogMessage::AddLogToStream(
2152 sink, static_cast<rtc::LoggingSeverity>(j_severity));
2153 return (jlong) sink;
2154 }
2155
2156 JOW(void, CallSessionFileRotatingLogSink_nativeDeleteSink)(
2157 JNIEnv* jni, jclass, jlong j_sink) {
2158 rtc::CallSessionFileRotatingLogSink* sink =
2159 reinterpret_cast<rtc::CallSessionFileRotatingLogSink*>(j_sink);
2160 rtc::LogMessage::RemoveLogToStream(sink);
2161 delete sink;
2162 }
2163
2164 JOW(jbyteArray, CallSessionFileRotatingLogSink_nativeGetLogData)(
2165 JNIEnv* jni, jclass, jstring j_dirPath) {
2166 std::string dir_path = JavaToStdString(jni, j_dirPath);
2167 std::unique_ptr<rtc::CallSessionFileRotatingStream> stream(
2168 new rtc::CallSessionFileRotatingStream(dir_path));
2169 if (!stream->Open()) {
2170 LOG_V(rtc::LoggingSeverity::LS_WARNING) <<
2171 "Failed to open CallSessionFileRotatingStream for path " << dir_path;
2172 return jni->NewByteArray(0);
2173 }
2174 size_t log_size = 0;
2175 if (!stream->GetSize(&log_size) || log_size == 0) {
2176 LOG_V(rtc::LoggingSeverity::LS_WARNING) <<
2177 "CallSessionFileRotatingStream returns 0 size for path " << dir_path;
2178 return jni->NewByteArray(0);
2179 }
2180
2181 size_t read = 0;
2182 std::unique_ptr<jbyte> buffer(static_cast<jbyte*>(malloc(log_size)));
2183 stream->ReadAll(buffer.get(), log_size, &read, nullptr);
2184
2185 jbyteArray result = jni->NewByteArray(read);
2186 jni->SetByteArrayRegion(result, 0, read, buffer.get());
2187
2188 return result;
2189 }
2190
2191 JOW(jboolean, RtpSender_nativeSetTrack)(JNIEnv* jni,
2192 jclass,
2193 jlong j_rtp_sender_pointer,
2194 jlong j_track_pointer) {
2195 return reinterpret_cast<RtpSenderInterface*>(j_rtp_sender_pointer)
2196 ->SetTrack(reinterpret_cast<MediaStreamTrackInterface*>(j_track_pointer));
2197 }
2198
2199 JOW(jlong, RtpSender_nativeGetTrack)(JNIEnv* jni,
2200 jclass,
2201 jlong j_rtp_sender_pointer,
2202 jlong j_track_pointer) {
2203 return jlongFromPointer(
2204 reinterpret_cast<RtpSenderInterface*>(j_rtp_sender_pointer)
2205 ->track()
2206 .release());
2207 }
2208
2209 static void JavaRtpParametersToJsepRtpParameters(
2210 JNIEnv* jni,
2211 jobject j_parameters,
2212 webrtc::RtpParameters* parameters) {
2213 RTC_CHECK(parameters != nullptr);
2214 jclass parameters_class = jni->FindClass("org/webrtc/RtpParameters");
2215 jfieldID encodings_id =
2216 GetFieldID(jni, parameters_class, "encodings", "Ljava/util/LinkedList;");
2217 jfieldID codecs_id =
2218 GetFieldID(jni, parameters_class, "codecs", "Ljava/util/LinkedList;");
2219
2220 // Convert encodings.
2221 jobject j_encodings = GetObjectField(jni, j_parameters, encodings_id);
2222 const int kBitrateUnlimited = -1;
2223 jclass j_encoding_parameters_class =
2224 jni->FindClass("org/webrtc/RtpParameters$Encoding");
2225 jfieldID active_id =
2226 GetFieldID(jni, j_encoding_parameters_class, "active", "Z");
2227 jfieldID bitrate_id = GetFieldID(jni, j_encoding_parameters_class,
2228 "maxBitrateBps", "Ljava/lang/Integer;");
2229 jclass j_integer_class = jni->FindClass("java/lang/Integer");
2230 jmethodID int_value_id = GetMethodID(jni, j_integer_class, "intValue", "()I");
2231
2232 for (jobject j_encoding_parameters : Iterable(jni, j_encodings)) {
2233 webrtc::RtpEncodingParameters encoding;
2234 encoding.active = GetBooleanField(jni, j_encoding_parameters, active_id);
2235 jobject j_bitrate =
2236 GetNullableObjectField(jni, j_encoding_parameters, bitrate_id);
2237 if (!IsNull(jni, j_bitrate)) {
2238 int bitrate_value = jni->CallIntMethod(j_bitrate, int_value_id);
2239 CHECK_EXCEPTION(jni) << "error during CallIntMethod";
2240 encoding.max_bitrate_bps = bitrate_value;
2241 } else {
2242 encoding.max_bitrate_bps = kBitrateUnlimited;
2243 }
2244 parameters->encodings.push_back(encoding);
2245 }
2246
2247 // Convert codecs.
2248 jobject j_codecs = GetObjectField(jni, j_parameters, codecs_id);
2249 jclass codec_class = jni->FindClass("org/webrtc/RtpParameters$Codec");
2250 jfieldID payload_type_id = GetFieldID(jni, codec_class, "payloadType", "I");
2251 jfieldID mime_type_id =
2252 GetFieldID(jni, codec_class, "mimeType", "Ljava/lang/String;");
2253 jfieldID clock_rate_id = GetFieldID(jni, codec_class, "clockRate", "I");
2254 jfieldID channels_id = GetFieldID(jni, codec_class, "channels", "I");
2255
2256 for (jobject j_codec : Iterable(jni, j_codecs)) {
2257 webrtc::RtpCodecParameters codec;
2258 codec.payload_type = GetIntField(jni, j_codec, payload_type_id);
2259 codec.mime_type =
2260 JavaToStdString(jni, GetStringField(jni, j_codec, mime_type_id));
2261 codec.clock_rate = GetIntField(jni, j_codec, clock_rate_id);
2262 codec.channels = GetIntField(jni, j_codec, channels_id);
2263 parameters->codecs.push_back(codec);
2264 }
2265 }
2266
2267 static jobject JsepRtpParametersToJavaRtpParameters(
2268 JNIEnv* jni,
2269 const webrtc::RtpParameters& parameters) {
2270 jclass parameters_class = jni->FindClass("org/webrtc/RtpParameters");
2271 jmethodID parameters_ctor =
2272 GetMethodID(jni, parameters_class, "<init>", "()V");
2273 jobject j_parameters = jni->NewObject(parameters_class, parameters_ctor);
2274 CHECK_EXCEPTION(jni) << "error during NewObject";
2275
2276 // Add encodings.
2277 jclass encoding_class = jni->FindClass("org/webrtc/RtpParameters$Encoding");
2278 jmethodID encoding_ctor = GetMethodID(jni, encoding_class, "<init>", "()V");
2279 jfieldID encodings_id =
2280 GetFieldID(jni, parameters_class, "encodings", "Ljava/util/LinkedList;");
2281 jobject j_encodings = GetObjectField(jni, j_parameters, encodings_id);
2282 jmethodID encodings_add = GetMethodID(jni, GetObjectClass(jni, j_encodings),
2283 "add", "(Ljava/lang/Object;)Z");
2284 jfieldID active_id =
2285 GetFieldID(jni, encoding_class, "active", "Z");
2286 jfieldID bitrate_id =
2287 GetFieldID(jni, encoding_class, "maxBitrateBps", "Ljava/lang/Integer;");
2288
2289 jclass integer_class = jni->FindClass("java/lang/Integer");
2290 jmethodID integer_ctor = GetMethodID(jni, integer_class, "<init>", "(I)V");
2291
2292 for (const webrtc::RtpEncodingParameters& encoding : parameters.encodings) {
2293 jobject j_encoding_parameters =
2294 jni->NewObject(encoding_class, encoding_ctor);
2295 CHECK_EXCEPTION(jni) << "error during NewObject";
2296 jni->SetBooleanField(j_encoding_parameters, active_id, encoding.active);
2297 CHECK_EXCEPTION(jni) << "error during SetBooleanField";
2298 if (encoding.max_bitrate_bps > 0) {
2299 jobject j_bitrate_value =
2300 jni->NewObject(integer_class, integer_ctor, encoding.max_bitrate_bps);
2301 CHECK_EXCEPTION(jni) << "error during NewObject";
2302 jni->SetObjectField(j_encoding_parameters, bitrate_id, j_bitrate_value);
2303 CHECK_EXCEPTION(jni) << "error during SetObjectField";
2304 }
2305 jboolean added = jni->CallBooleanMethod(j_encodings, encodings_add,
2306 j_encoding_parameters);
2307 CHECK_EXCEPTION(jni) << "error during CallBooleanMethod";
2308 RTC_CHECK(added);
2309 }
2310
2311 // Add codecs.
2312 jclass codec_class = jni->FindClass("org/webrtc/RtpParameters$Codec");
2313 jmethodID codec_ctor = GetMethodID(jni, codec_class, "<init>", "()V");
2314 jfieldID codecs_id =
2315 GetFieldID(jni, parameters_class, "codecs", "Ljava/util/LinkedList;");
2316 jobject j_codecs = GetObjectField(jni, j_parameters, codecs_id);
2317 jmethodID codecs_add = GetMethodID(jni, GetObjectClass(jni, j_codecs),
2318 "add", "(Ljava/lang/Object;)Z");
2319 jfieldID payload_type_id = GetFieldID(jni, codec_class, "payloadType", "I");
2320 jfieldID mime_type_id =
2321 GetFieldID(jni, codec_class, "mimeType", "Ljava/lang/String;");
2322 jfieldID clock_rate_id = GetFieldID(jni, codec_class, "clockRate", "I");
2323 jfieldID channels_id = GetFieldID(jni, codec_class, "channels", "I");
2324
2325 for (const webrtc::RtpCodecParameters& codec : parameters.codecs) {
2326 jobject j_codec = jni->NewObject(codec_class, codec_ctor);
2327 CHECK_EXCEPTION(jni) << "error during NewObject";
2328 jni->SetIntField(j_codec, payload_type_id, codec.payload_type);
2329 CHECK_EXCEPTION(jni) << "error during SetIntField";
2330 jni->SetObjectField(j_codec, mime_type_id,
2331 JavaStringFromStdString(jni, codec.mime_type));
2332 CHECK_EXCEPTION(jni) << "error during SetObjectField";
2333 jni->SetIntField(j_codec, clock_rate_id, codec.clock_rate);
2334 CHECK_EXCEPTION(jni) << "error during SetIntField";
2335 jni->SetIntField(j_codec, channels_id, codec.channels);
2336 CHECK_EXCEPTION(jni) << "error during SetIntField";
2337 jboolean added = jni->CallBooleanMethod(j_codecs, codecs_add, j_codec);
2338 CHECK_EXCEPTION(jni) << "error during CallBooleanMethod";
2339 RTC_CHECK(added);
2340 }
2341
2342 return j_parameters;
2343 }
2344
2345 JOW(jboolean, RtpSender_nativeSetParameters)
2346 (JNIEnv* jni, jclass, jlong j_rtp_sender_pointer, jobject j_parameters) {
2347 if (IsNull(jni, j_parameters)) {
2348 return false;
2349 }
2350 webrtc::RtpParameters parameters;
2351 JavaRtpParametersToJsepRtpParameters(jni, j_parameters, &parameters);
2352 return reinterpret_cast<RtpSenderInterface*>(j_rtp_sender_pointer)
2353 ->SetParameters(parameters);
2354 }
2355
2356 JOW(jobject, RtpSender_nativeGetParameters)
2357 (JNIEnv* jni, jclass, jlong j_rtp_sender_pointer) {
2358 webrtc::RtpParameters parameters =
2359 reinterpret_cast<RtpSenderInterface*>(j_rtp_sender_pointer)
2360 ->GetParameters();
2361 return JsepRtpParametersToJavaRtpParameters(jni, parameters);
2362 }
2363
2364 JOW(jstring, RtpSender_nativeId)(
2365 JNIEnv* jni, jclass, jlong j_rtp_sender_pointer) {
2366 return JavaStringFromStdString(
2367 jni, reinterpret_cast<RtpSenderInterface*>(j_rtp_sender_pointer)->id());
2368 }
2369
2370 JOW(void, RtpSender_free)(JNIEnv* jni, jclass, jlong j_rtp_sender_pointer) {
2371 reinterpret_cast<RtpSenderInterface*>(j_rtp_sender_pointer)->Release();
2372 }
2373
2374 JOW(jlong, RtpReceiver_nativeGetTrack)(JNIEnv* jni,
2375 jclass,
2376 jlong j_rtp_receiver_pointer,
2377 jlong j_track_pointer) {
2378 return jlongFromPointer(
2379 reinterpret_cast<RtpReceiverInterface*>(j_rtp_receiver_pointer)
2380 ->track()
2381 .release());
2382 }
2383
2384 JOW(jboolean, RtpReceiver_nativeSetParameters)
2385 (JNIEnv* jni, jclass, jlong j_rtp_sender_pointer, jobject j_parameters) {
2386 if (IsNull(jni, j_parameters)) {
2387 return false;
2388 }
2389 webrtc::RtpParameters parameters;
2390 JavaRtpParametersToJsepRtpParameters(jni, j_parameters, &parameters);
2391 return reinterpret_cast<RtpReceiverInterface*>(j_rtp_sender_pointer)
2392 ->SetParameters(parameters);
2393 }
2394
2395 JOW(jobject, RtpReceiver_nativeGetParameters)
2396 (JNIEnv* jni, jclass, jlong j_rtp_sender_pointer) {
2397 webrtc::RtpParameters parameters =
2398 reinterpret_cast<RtpReceiverInterface*>(j_rtp_sender_pointer)
2399 ->GetParameters();
2400 return JsepRtpParametersToJavaRtpParameters(jni, parameters);
2401 }
2402
2403 JOW(jstring, RtpReceiver_nativeId)(
2404 JNIEnv* jni, jclass, jlong j_rtp_receiver_pointer) {
2405 return JavaStringFromStdString(
2406 jni,
2407 reinterpret_cast<RtpReceiverInterface*>(j_rtp_receiver_pointer)->id());
2408 }
2409
2410 JOW(void, RtpReceiver_free)(JNIEnv* jni, jclass, jlong j_rtp_receiver_pointer) {
2411 reinterpret_cast<RtpReceiverInterface*>(j_rtp_receiver_pointer)->Release();
2412 }
2413
2414 } // namespace webrtc_jni
OLDNEW
« no previous file with comments | « webrtc/api/android/jni/native_handle_impl.cc ('k') | webrtc/api/android/jni/surfacetexturehelper_jni.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698