Chromium Code Reviews

Side by Side Diff: talk/app/webrtc/java/testcommon/src/org/webrtc/PeerConnectionTest.java

Issue 1207613006: Support for onbufferedamountlow (Closed) Base URL: https://chromium.googlesource.com/external/webrtc/trunk/talk.git@master
Patch Set: Objective C style cleanup Created 5 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments.
Jump to:
View unified diff |
OLDNEW
1 /* 1 /*
2 * libjingle 2 * libjingle
3 * Copyright 2013 Google Inc. 3 * Copyright 2013 Google Inc.
4 * 4 *
5 * Redistribution and use in source and binary forms, with or without 5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met: 6 * modification, are permitted provided that the following conditions are met:
7 * 7 *
8 * 1. Redistributions of source code must retain the above copyright notice, 8 * 1. Redistributions of source code must retain the above copyright notice,
9 * this list of conditions and the following disclaimer. 9 * this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright notice, 10 * 2. Redistributions in binary form must reproduce the above copyright notice,
(...skipping 241 matching lines...)
252 } 252 }
253 253
254 @Override 254 @Override
255 public synchronized void onMessage(DataChannel.Buffer buffer) { 255 public synchronized void onMessage(DataChannel.Buffer buffer) {
256 DataChannel.Buffer expected = expectedBuffers.removeFirst(); 256 DataChannel.Buffer expected = expectedBuffers.removeFirst();
257 assertEquals(expected.binary, buffer.binary); 257 assertEquals(expected.binary, buffer.binary);
258 assertTrue(expected.data.equals(buffer.data)); 258 assertTrue(expected.data.equals(buffer.data));
259 } 259 }
260 260
261 @Override 261 @Override
262 public synchronized void onBufferedAmountChange(long previousAmount) {
263 assertFalse(previousAmount == dataChannel.bufferedAmount());
264 }
265
266 @Override
262 public synchronized void onStateChange() { 267 public synchronized void onStateChange() {
263 assertEquals(expectedStateChanges.removeFirst(), dataChannel.state()); 268 assertEquals(expectedStateChanges.removeFirst(), dataChannel.state());
264 } 269 }
265 270
266 public synchronized void expectStateChange(DataChannel.State state) { 271 public synchronized void expectStateChange(DataChannel.State state) {
267 expectedStateChanges.add(state); 272 expectedStateChanges.add(state);
268 } 273 }
269 274
270 @Override 275 @Override
271 public synchronized void onComplete(StatsReport[] reports) { 276 public synchronized void onComplete(StatsReport[] reports) {
(...skipping 491 matching lines...)
763 TreeSet<String> threads = new TreeSet<String>(); 768 TreeSet<String> threads = new TreeSet<String>();
764 // This pokes at /proc instead of using the Java APIs because we're also 769 // This pokes at /proc instead of using the Java APIs because we're also
765 // looking for libjingle/webrtc native threads, most of which won't have 770 // looking for libjingle/webrtc native threads, most of which won't have
766 // attached to the JVM. 771 // attached to the JVM.
767 for (String threadId : (new File("/proc/self/task")).list()) { 772 for (String threadId : (new File("/proc/self/task")).list()) {
768 threads.add(threadId); 773 threads.add(threadId);
769 } 774 }
770 return threads; 775 return threads;
771 } 776 }
772 } 777 }
OLDNEW

Powered by Google App Engine