| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright 2013 The WebRTC project authors. All Rights Reserved. | 2 * Copyright 2013 The WebRTC project authors. All Rights Reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 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 | 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 | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 | 10 |
| (...skipping 698 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 709 for (IceCandidate candidate : answeringExpectations.getAtLeastOneIceCandidat
e()) { | 709 for (IceCandidate candidate : answeringExpectations.getAtLeastOneIceCandidat
e()) { |
| 710 offeringPC.addIceCandidate(candidate); | 710 offeringPC.addIceCandidate(candidate); |
| 711 } | 711 } |
| 712 | 712 |
| 713 assertTrue(offeringExpectations.waitForAllExpectationsToBeSatisfied(TIMEOUT_
SECONDS)); | 713 assertTrue(offeringExpectations.waitForAllExpectationsToBeSatisfied(TIMEOUT_
SECONDS)); |
| 714 assertTrue(answeringExpectations.waitForAllExpectationsToBeSatisfied(TIMEOUT
_SECONDS)); | 714 assertTrue(answeringExpectations.waitForAllExpectationsToBeSatisfied(TIMEOUT
_SECONDS)); |
| 715 | 715 |
| 716 assertEquals(PeerConnection.SignalingState.STABLE, offeringPC.signalingState
()); | 716 assertEquals(PeerConnection.SignalingState.STABLE, offeringPC.signalingState
()); |
| 717 assertEquals(PeerConnection.SignalingState.STABLE, answeringPC.signalingStat
e()); | 717 assertEquals(PeerConnection.SignalingState.STABLE, answeringPC.signalingStat
e()); |
| 718 | 718 |
| 719 // Set a bitrate limit for the outgoing video stream for the offerer. | 719 // Test some of the RtpSender API. |
| 720 RtpSender videoSender = null; | 720 RtpSender videoSender = null; |
| 721 RtpSender audioSender = null; |
| 721 for (RtpSender sender : offeringPC.getSenders()) { | 722 for (RtpSender sender : offeringPC.getSenders()) { |
| 722 if (sender.track().kind().equals("video")) { | 723 if (sender.track().kind().equals("video")) { |
| 723 videoSender = sender; | 724 videoSender = sender; |
| 725 } else { |
| 726 audioSender = sender; |
| 724 } | 727 } |
| 725 } | 728 } |
| 726 assertNotNull(videoSender); | 729 assertNotNull(videoSender); |
| 730 assertNotNull(audioSender); |
| 731 |
| 732 // Set a bitrate limit for the outgoing video stream for the offerer. |
| 727 RtpParameters rtpParameters = videoSender.getParameters(); | 733 RtpParameters rtpParameters = videoSender.getParameters(); |
| 728 assertNotNull(rtpParameters); | 734 assertNotNull(rtpParameters); |
| 729 assertEquals(1, rtpParameters.encodings.size()); | 735 assertEquals(1, rtpParameters.encodings.size()); |
| 730 assertNull(rtpParameters.encodings.get(0).maxBitrateBps); | 736 assertNull(rtpParameters.encodings.get(0).maxBitrateBps); |
| 731 | 737 |
| 732 rtpParameters.encodings.get(0).maxBitrateBps = 300000; | 738 rtpParameters.encodings.get(0).maxBitrateBps = 300000; |
| 733 assertTrue(videoSender.setParameters(rtpParameters)); | 739 assertTrue(videoSender.setParameters(rtpParameters)); |
| 734 | 740 |
| 741 // Create a DTMF sender. |
| 742 DtmfSender dtmfSender = audioSender.dtmf(); |
| 743 assertNotNull(dtmfSender); |
| 744 assertTrue(dtmfSender.canInsertDtmf()); |
| 745 assertTrue(dtmfSender.insertDtmf("123", 300, 100)); |
| 746 |
| 735 // Verify that we can read back the updated value. | 747 // Verify that we can read back the updated value. |
| 736 rtpParameters = videoSender.getParameters(); | 748 rtpParameters = videoSender.getParameters(); |
| 737 assertEquals(300000, (int) rtpParameters.encodings.get(0).maxBitrateBps); | 749 assertEquals(300000, (int) rtpParameters.encodings.get(0).maxBitrateBps); |
| 738 | 750 |
| 739 // Test send & receive UTF-8 text. | 751 // Test send & receive UTF-8 text. |
| 740 answeringExpectations.expectMessage( | 752 answeringExpectations.expectMessage( |
| 741 ByteBuffer.wrap("hello!".getBytes(Charset.forName("UTF-8"))), false); | 753 ByteBuffer.wrap("hello!".getBytes(Charset.forName("UTF-8"))), false); |
| 742 DataChannel.Buffer buffer = | 754 DataChannel.Buffer buffer = |
| 743 new DataChannel.Buffer(ByteBuffer.wrap("hello!".getBytes(Charset.forName
("UTF-8"))), false); | 755 new DataChannel.Buffer(ByteBuffer.wrap("hello!".getBytes(Charset.forName
("UTF-8"))), false); |
| 744 assertTrue(offeringExpectations.dataChannel.send(buffer)); | 756 assertTrue(offeringExpectations.dataChannel.send(buffer)); |
| (...skipping 309 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1054 TreeSet<String> threads = new TreeSet<String>(); | 1066 TreeSet<String> threads = new TreeSet<String>(); |
| 1055 // This pokes at /proc instead of using the Java APIs because we're also | 1067 // This pokes at /proc instead of using the Java APIs because we're also |
| 1056 // looking for libjingle/webrtc native threads, most of which won't have | 1068 // looking for libjingle/webrtc native threads, most of which won't have |
| 1057 // attached to the JVM. | 1069 // attached to the JVM. |
| 1058 for (String threadId : (new File("/proc/self/task")).list()) { | 1070 for (String threadId : (new File("/proc/self/task")).list()) { |
| 1059 threads.add(threadId); | 1071 threads.add(threadId); |
| 1060 } | 1072 } |
| 1061 return threads; | 1073 return threads; |
| 1062 } | 1074 } |
| 1063 } | 1075 } |
| OLD | NEW |