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

Unified Diff: android_webview/java/src/org/chromium/android_webview/AwMessagePortService.java

Issue 1027503002: Rename MessagePort to AwMessagePort (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: rebase Created 5 years, 9 months 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 side-by-side diff with in-line comments
Download patch
Index: android_webview/java/src/org/chromium/android_webview/AwMessagePortService.java
diff --git a/android_webview/java/src/org/chromium/android_webview/AwMessagePortService.java b/android_webview/java/src/org/chromium/android_webview/AwMessagePortService.java
index e7c887b29ba17775a14901619844eb67dde4d2f8..039cd94ca8b7abb9c423729c2a39eb909c09b990 100644
--- a/android_webview/java/src/org/chromium/android_webview/AwMessagePortService.java
+++ b/android_webview/java/src/org/chromium/android_webview/AwMessagePortService.java
@@ -45,7 +45,7 @@ public class AwMessagePortService {
// A thread safe storage for Message Ports.
private static class MessagePortStorage {
- private SparseArray<MessagePort> mMessagePorts = new SparseArray<MessagePort>();
+ private SparseArray<AwMessagePort> mMessagePorts = new SparseArray<AwMessagePort>();
private Object mLock = new Object();
public void remove(int portId) {
@@ -54,12 +54,12 @@ public class AwMessagePortService {
}
}
- public void put(int portId, MessagePort m) {
+ public void put(int portId, AwMessagePort m) {
synchronized (mLock) {
mMessagePorts.put(portId, m);
}
}
- public MessagePort get(int portId) {
+ public AwMessagePort get(int portId) {
synchronized (mLock) {
return mMessagePorts.get(portId);
}
@@ -102,7 +102,7 @@ public class AwMessagePortService {
// verify that webview owns all the ports that are transferred
if (sentPorts != null) {
for (int port : sentPorts) {
- MessagePort p = mPortStorage.get(port);
+ AwMessagePort p = mPortStorage.get(port);
if (p == null) {
throw new IllegalStateException("Cannot transfer unknown port " + port);
}
@@ -111,8 +111,8 @@ public class AwMessagePortService {
}
}
- public MessagePort[] createMessageChannel() {
- return new MessagePort[]{new MessagePort(this), new MessagePort(this)};
+ public AwMessagePort[] createMessageChannel() {
+ return new AwMessagePort[]{new AwMessagePort(this), new AwMessagePort(this)};
}
// Called on UI thread.
@@ -121,7 +121,7 @@ public class AwMessagePortService {
nativeReleaseMessages(mNativeMessagePortService, portId);
}
- private MessagePort addPort(MessagePort m, int portId) {
+ private AwMessagePort addPort(AwMessagePort m, int portId) {
if (mPortStorage.get(portId) != null) {
throw new IllegalStateException("Port already exists");
}
@@ -132,7 +132,7 @@ public class AwMessagePortService {
@CalledByNative
private void onMessageChannelCreated(int portId1, int portId2,
- MessagePort[] ports) {
+ AwMessagePort[] ports) {
ThreadUtils.assertOnUiThread();
addPort(ports[0], portId1);
addPort(ports[1], portId2);
@@ -144,12 +144,12 @@ public class AwMessagePortService {
// Called on IO thread.
@CalledByNative
private void onReceivedMessage(int portId, String message, int[] ports) {
- MessagePort[] messagePorts = null;
+ AwMessagePort[] messagePorts = null;
for (int i = 0; i < ports.length; i++) {
if (messagePorts == null) {
- messagePorts = new MessagePort[ports.length];
+ messagePorts = new AwMessagePort[ports.length];
}
- messagePorts[i] = addPort(new MessagePort(this), ports[i]);
+ messagePorts[i] = addPort(new AwMessagePort(this), ports[i]);
}
mPortStorage.get(portId).onReceivedMessage(message, messagePorts);
}

Powered by Google App Engine
This is Rietveld 408576698