Loading wifi/java/android/net/wifi/nan/WifiNanDiscoveryBaseSession.java +5 −4 Original line number Diff line number Diff line Loading @@ -16,6 +16,7 @@ package android.net.wifi.nan; import android.annotation.NonNull; import android.annotation.Nullable; import android.annotation.SystemApi; import android.net.wifi.RttManager; Loading Loading @@ -163,7 +164,7 @@ public class WifiNanDiscoveryBaseSession { * (note: no retransmissions are attempted in other failure cases). A value of 0 * indicates no retries. Max permitted value is {@link #getMaxSendRetryCount()}. */ public void sendMessage(Object peerHandle, int messageId, @Nullable byte[] message, public void sendMessage(@NonNull Object peerHandle, int messageId, @Nullable byte[] message, int retryCount) { if (mTerminated) { Log.w(TAG, "sendMessage: called on terminated session"); Loading Loading @@ -205,7 +206,7 @@ public class WifiNanDiscoveryBaseSession { * can be arbitrary and non-unique. * @param message The message to be transmitted. */ public void sendMessage(Object peerHandle, int messageId, @Nullable byte[] message) { public void sendMessage(@NonNull Object peerHandle, int messageId, @Nullable byte[] message) { sendMessage(peerHandle, messageId, message, 0); } Loading Loading @@ -270,8 +271,8 @@ public class WifiNanDiscoveryBaseSession { * {@link android.net.ConnectivityManager#requestNetwork(android.net.NetworkRequest,android.net.ConnectivityManager.NetworkCallback)} * [or other varieties of that API]. */ public String createNetworkSpecifier(@WifiNanManager.DataPathRole int role, Object peerHandle, @Nullable byte[] token) { public String createNetworkSpecifier(@WifiNanManager.DataPathRole int role, @Nullable Object peerHandle, @Nullable byte[] token) { if (mTerminated) { Log.w(TAG, "createNetworkSpecifier: called on terminated session"); return null; Loading wifi/java/android/net/wifi/nan/WifiNanManager.java +23 −8 Original line number Diff line number Diff line Loading @@ -459,15 +459,20 @@ public class WifiNanManager { /** @hide */ public void sendMessage(int clientId, int sessionId, Object peerHandle, byte[] message, int messageId, int retryCount) { if (peerHandle == null) { throw new IllegalArgumentException( "sendMessage: invalid peerHandle - must be non-null"); } if (VDBG) { Log.v(TAG, "sendMessage(): clientId=" + clientId + ", sessionId=" + sessionId + ", peerHandle=" + peerHandle + ", messageId=" + messageId + ", retryCount=" + retryCount); + ", peerHandle=" + ((OpaquePeerHandle) peerHandle).peerId + ", messageId=" + messageId + ", retryCount=" + retryCount); } try { mService.sendMessage(clientId, sessionId, (Integer) peerHandle, message, messageId, retryCount); mService.sendMessage(clientId, sessionId, ((OpaquePeerHandle) peerHandle).peerId, message, messageId, retryCount); } catch (RemoteException e) { throw e.rethrowFromSystemServer(); } Loading Loading @@ -499,7 +504,8 @@ public class WifiNanManager { byte[] token) { if (VDBG) { Log.v(TAG, "createNetworkSpecifier: role=" + role + ", sessionId=" + sessionId + ", peerHandle=" + peerHandle + ", token=" + token); + ", peerHandle=" + ((peerHandle == null) ? peerHandle : ((OpaquePeerHandle) peerHandle).peerId) + ", token=" + token); } int type; Loading Loading @@ -539,7 +545,7 @@ public class WifiNanManager { json.put(NETWORK_SPECIFIER_KEY_CLIENT_ID, clientId); json.put(NETWORK_SPECIFIER_KEY_SESSION_ID, sessionId); if (peerHandle != null) { json.put(NETWORK_SPECIFIER_KEY_PEER_ID, (Integer) peerHandle); json.put(NETWORK_SPECIFIER_KEY_PEER_ID, ((OpaquePeerHandle) peerHandle).peerId); } if (token != null) { json.put(NETWORK_SPECIFIER_KEY_TOKEN, Loading Loading @@ -844,7 +850,7 @@ public class WifiNanManager { break; case CALLBACK_MATCH: mOriginalCallback.onServiceDiscovered( Integer.valueOf(msg.arg1), new OpaquePeerHandle(msg.arg1), msg.getData().getByteArray(MESSAGE_BUNDLE_KEY_MESSAGE), msg.getData().getByteArray(MESSAGE_BUNDLE_KEY_MESSAGE2)); break; Loading @@ -855,7 +861,7 @@ public class WifiNanManager { mOriginalCallback.onMessageSendFailed(msg.arg1); break; case CALLBACK_MESSAGE_RECEIVED: mOriginalCallback.onMessageReceived(Integer.valueOf(msg.arg1), mOriginalCallback.onMessageReceived(new OpaquePeerHandle(msg.arg1), (byte[]) msg.obj); break; } Loading Loading @@ -986,4 +992,13 @@ public class WifiNanManager { mOriginalCallback.onSessionTerminated(reason); } } /** @hide */ public static class OpaquePeerHandle { public OpaquePeerHandle(int peerId) { this.peerId = peerId; } public int peerId; } } Loading
wifi/java/android/net/wifi/nan/WifiNanDiscoveryBaseSession.java +5 −4 Original line number Diff line number Diff line Loading @@ -16,6 +16,7 @@ package android.net.wifi.nan; import android.annotation.NonNull; import android.annotation.Nullable; import android.annotation.SystemApi; import android.net.wifi.RttManager; Loading Loading @@ -163,7 +164,7 @@ public class WifiNanDiscoveryBaseSession { * (note: no retransmissions are attempted in other failure cases). A value of 0 * indicates no retries. Max permitted value is {@link #getMaxSendRetryCount()}. */ public void sendMessage(Object peerHandle, int messageId, @Nullable byte[] message, public void sendMessage(@NonNull Object peerHandle, int messageId, @Nullable byte[] message, int retryCount) { if (mTerminated) { Log.w(TAG, "sendMessage: called on terminated session"); Loading Loading @@ -205,7 +206,7 @@ public class WifiNanDiscoveryBaseSession { * can be arbitrary and non-unique. * @param message The message to be transmitted. */ public void sendMessage(Object peerHandle, int messageId, @Nullable byte[] message) { public void sendMessage(@NonNull Object peerHandle, int messageId, @Nullable byte[] message) { sendMessage(peerHandle, messageId, message, 0); } Loading Loading @@ -270,8 +271,8 @@ public class WifiNanDiscoveryBaseSession { * {@link android.net.ConnectivityManager#requestNetwork(android.net.NetworkRequest,android.net.ConnectivityManager.NetworkCallback)} * [or other varieties of that API]. */ public String createNetworkSpecifier(@WifiNanManager.DataPathRole int role, Object peerHandle, @Nullable byte[] token) { public String createNetworkSpecifier(@WifiNanManager.DataPathRole int role, @Nullable Object peerHandle, @Nullable byte[] token) { if (mTerminated) { Log.w(TAG, "createNetworkSpecifier: called on terminated session"); return null; Loading
wifi/java/android/net/wifi/nan/WifiNanManager.java +23 −8 Original line number Diff line number Diff line Loading @@ -459,15 +459,20 @@ public class WifiNanManager { /** @hide */ public void sendMessage(int clientId, int sessionId, Object peerHandle, byte[] message, int messageId, int retryCount) { if (peerHandle == null) { throw new IllegalArgumentException( "sendMessage: invalid peerHandle - must be non-null"); } if (VDBG) { Log.v(TAG, "sendMessage(): clientId=" + clientId + ", sessionId=" + sessionId + ", peerHandle=" + peerHandle + ", messageId=" + messageId + ", retryCount=" + retryCount); + ", peerHandle=" + ((OpaquePeerHandle) peerHandle).peerId + ", messageId=" + messageId + ", retryCount=" + retryCount); } try { mService.sendMessage(clientId, sessionId, (Integer) peerHandle, message, messageId, retryCount); mService.sendMessage(clientId, sessionId, ((OpaquePeerHandle) peerHandle).peerId, message, messageId, retryCount); } catch (RemoteException e) { throw e.rethrowFromSystemServer(); } Loading Loading @@ -499,7 +504,8 @@ public class WifiNanManager { byte[] token) { if (VDBG) { Log.v(TAG, "createNetworkSpecifier: role=" + role + ", sessionId=" + sessionId + ", peerHandle=" + peerHandle + ", token=" + token); + ", peerHandle=" + ((peerHandle == null) ? peerHandle : ((OpaquePeerHandle) peerHandle).peerId) + ", token=" + token); } int type; Loading Loading @@ -539,7 +545,7 @@ public class WifiNanManager { json.put(NETWORK_SPECIFIER_KEY_CLIENT_ID, clientId); json.put(NETWORK_SPECIFIER_KEY_SESSION_ID, sessionId); if (peerHandle != null) { json.put(NETWORK_SPECIFIER_KEY_PEER_ID, (Integer) peerHandle); json.put(NETWORK_SPECIFIER_KEY_PEER_ID, ((OpaquePeerHandle) peerHandle).peerId); } if (token != null) { json.put(NETWORK_SPECIFIER_KEY_TOKEN, Loading Loading @@ -844,7 +850,7 @@ public class WifiNanManager { break; case CALLBACK_MATCH: mOriginalCallback.onServiceDiscovered( Integer.valueOf(msg.arg1), new OpaquePeerHandle(msg.arg1), msg.getData().getByteArray(MESSAGE_BUNDLE_KEY_MESSAGE), msg.getData().getByteArray(MESSAGE_BUNDLE_KEY_MESSAGE2)); break; Loading @@ -855,7 +861,7 @@ public class WifiNanManager { mOriginalCallback.onMessageSendFailed(msg.arg1); break; case CALLBACK_MESSAGE_RECEIVED: mOriginalCallback.onMessageReceived(Integer.valueOf(msg.arg1), mOriginalCallback.onMessageReceived(new OpaquePeerHandle(msg.arg1), (byte[]) msg.obj); break; } Loading Loading @@ -986,4 +992,13 @@ public class WifiNanManager { mOriginalCallback.onSessionTerminated(reason); } } /** @hide */ public static class OpaquePeerHandle { public OpaquePeerHandle(int peerId) { this.peerId = peerId; } public int peerId; } }