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

Side by Side Diff: webrtc/api/android/java/src/org/webrtc/DataChannel.java

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 package org.webrtc;
12
13 import java.nio.ByteBuffer;
14
15 /** Java wrapper for a C++ DataChannelInterface. */
16 public class DataChannel {
17 /** Java wrapper for WebIDL RTCDataChannel. */
18 public static class Init {
19 public boolean ordered = true;
20 // Optional unsigned short in WebIDL, -1 means unspecified.
21 public int maxRetransmitTimeMs = -1;
22 // Optional unsigned short in WebIDL, -1 means unspecified.
23 public int maxRetransmits = -1;
24 public String protocol = "";
25 public boolean negotiated = false;
26 // Optional unsigned short in WebIDL, -1 means unspecified.
27 public int id = -1;
28
29 public Init() {}
30
31 // Called only by native code.
32 private Init(boolean ordered, int maxRetransmitTimeMs, int maxRetransmits, S tring protocol,
33 boolean negotiated, int id) {
34 this.ordered = ordered;
35 this.maxRetransmitTimeMs = maxRetransmitTimeMs;
36 this.maxRetransmits = maxRetransmits;
37 this.protocol = protocol;
38 this.negotiated = negotiated;
39 this.id = id;
40 }
41 }
42
43 /** Java version of C++ DataBuffer. The atom of data in a DataChannel. */
44 public static class Buffer {
45 /** The underlying data. */
46 public final ByteBuffer data;
47
48 /**
49 * Indicates whether |data| contains UTF-8 text or "binary data"
50 * (i.e. anything else).
51 */
52 public final boolean binary;
53
54 public Buffer(ByteBuffer data, boolean binary) {
55 this.data = data;
56 this.binary = binary;
57 }
58 }
59
60 /** Java version of C++ DataChannelObserver. */
61 public interface Observer {
62 /** The data channel's bufferedAmount has changed. */
63 public void onBufferedAmountChange(long previousAmount);
64 /** The data channel state has changed. */
65 public void onStateChange();
66 /**
67 * A data buffer was successfully received. NOTE: |buffer.data| will be
68 * freed once this function returns so callers who want to use the data
69 * asynchronously must make sure to copy it first.
70 */
71 public void onMessage(Buffer buffer);
72 }
73
74 /** Keep in sync with DataChannelInterface::DataState. */
75 public enum State { CONNECTING, OPEN, CLOSING, CLOSED }
76
77 private final long nativeDataChannel;
78 private long nativeObserver;
79
80 public DataChannel(long nativeDataChannel) {
81 this.nativeDataChannel = nativeDataChannel;
82 }
83
84 /** Register |observer|, replacing any previously-registered observer. */
85 public void registerObserver(Observer observer) {
86 if (nativeObserver != 0) {
87 unregisterObserverNative(nativeObserver);
88 }
89 nativeObserver = registerObserverNative(observer);
90 }
91 private native long registerObserverNative(Observer observer);
92
93 /** Unregister the (only) observer. */
94 public void unregisterObserver() {
95 unregisterObserverNative(nativeObserver);
96 }
97 private native void unregisterObserverNative(long nativeObserver);
98
99 public native String label();
100
101 public native int id();
102
103 public native State state();
104
105 /**
106 * Return the number of bytes of application data (UTF-8 text and binary data)
107 * that have been queued using SendBuffer but have not yet been transmitted
108 * to the network.
109 */
110 public native long bufferedAmount();
111
112 /** Close the channel. */
113 public native void close();
114
115 /** Send |data| to the remote peer; return success. */
116 public boolean send(Buffer buffer) {
117 // TODO(fischman): this could be cleverer about avoiding copies if the
118 // ByteBuffer is direct and/or is backed by an array.
119 byte[] data = new byte[buffer.data.remaining()];
120 buffer.data.get(data);
121 return sendNative(data, buffer.binary);
122 }
123 private native boolean sendNative(byte[] data, boolean binary);
124
125 /** Dispose of native resources attached to this channel. */
126 public native void dispose();
127 };
OLDNEW
« no previous file with comments | « webrtc/api/android/java/src/org/webrtc/CameraVideoCapturer.java ('k') | webrtc/api/android/java/src/org/webrtc/EglBase.java » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698