OLD | NEW |
1 /* | 1 /* |
2 * Copyright 2016 The WebRTC Project Authors. All rights reserved. | 2 * Copyright 2016 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 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
109 private void reportError(final String message) { | 109 private void reportError(final String message) { |
110 Log.e(TAG, "TCP Error: " + message); | 110 Log.e(TAG, "TCP Error: " + message); |
111 executor.execute(new Runnable() { | 111 executor.execute(new Runnable() { |
112 @Override | 112 @Override |
113 public void run() { | 113 public void run() { |
114 eventListener.onTCPError(message); | 114 eventListener.onTCPError(message); |
115 } | 115 } |
116 }); | 116 }); |
117 } | 117 } |
118 | 118 |
119 | |
120 /** | 119 /** |
121 * Base class for server and client sockets. Contains a listening thread that
will call | 120 * Base class for server and client sockets. Contains a listening thread that
will call |
122 * eventListener.onTCPMessage on new messages. | 121 * eventListener.onTCPMessage on new messages. |
123 */ | 122 */ |
124 private abstract class TCPSocket extends Thread { | 123 private abstract class TCPSocket extends Thread { |
125 // Lock for editing out and rawSocket | 124 // Lock for editing out and rawSocket |
126 protected final Object rawSocketLock; | 125 protected final Object rawSocketLock; |
127 private PrintWriter out; | 126 private PrintWriter out; |
128 private Socket rawSocket; | 127 private Socket rawSocket; |
129 | 128 |
(...skipping 216 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
346 return null; | 345 return null; |
347 } | 346 } |
348 } | 347 } |
349 | 348 |
350 @Override | 349 @Override |
351 public boolean isServer() { | 350 public boolean isServer() { |
352 return false; | 351 return false; |
353 } | 352 } |
354 } | 353 } |
355 } | 354 } |
OLD | NEW |