Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (C) 2012 The Android Open Source Project |
| 3 | * |
| 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
| 5 | * you may not use this file except in compliance with the License. |
| 6 | * You may obtain a copy of the License at |
| 7 | * |
| 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
| 9 | * |
| 10 | * Unless required by applicable law or agreed to in writing, software |
| 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
| 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 13 | * See the License for the specific language governing permissions and |
| 14 | * limitations under the License. |
| 15 | */ |
| 16 | |
| 17 | package android.net.nsd; |
| 18 | |
Irfan Sheriff | 3ef889b | 2012-04-17 23:15:29 -0700 | [diff] [blame] | 19 | import android.annotation.SdkConstant; |
| 20 | import android.annotation.SdkConstant.SdkConstantType; |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 21 | import android.content.Context; |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 22 | import android.os.Handler; |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 23 | import android.os.HandlerThread; |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 24 | import android.os.Looper; |
| 25 | import android.os.Message; |
| 26 | import android.os.RemoteException; |
| 27 | import android.os.Messenger; |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 28 | import android.text.TextUtils; |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 29 | import android.util.Log; |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 30 | import android.util.SparseArray; |
| 31 | |
| 32 | import java.util.concurrent.CountDownLatch; |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 33 | |
| 34 | import com.android.internal.util.AsyncChannel; |
| 35 | import com.android.internal.util.Protocol; |
| 36 | |
| 37 | /** |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 38 | * The Network Service Discovery Manager class provides the API to discover services |
| 39 | * on a network. As an example, if device A and device B are connected over a Wi-Fi |
| 40 | * network, a game registered on device A can be discovered by a game on device |
| 41 | * B. Another example use case is an application discovering printers on the network. |
| 42 | * |
| 43 | * <p> The API currently supports DNS based service discovery and discovery is currently |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 44 | * limited to a local network over Multicast DNS. DNS service discovery is described at |
| 45 | * http://files.dns-sd.org/draft-cheshire-dnsext-dns-sd.txt |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 46 | * |
| 47 | * <p> The API is asynchronous and responses to requests from an application are on listener |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 48 | * callbacks on a seperate thread. |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 49 | * |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 50 | * <p> There are three main operations the API supports - registration, discovery and resolution. |
| 51 | * <pre> |
| 52 | * Application start |
| 53 | * | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 54 | * | |
| 55 | * | onServiceRegistered() |
| 56 | * Register any local services / |
| 57 | * to be advertised with \ |
| 58 | * registerService() onRegistrationFailed() |
| 59 | * | |
| 60 | * | |
| 61 | * discoverServices() |
| 62 | * | |
| 63 | * Maintain a list to track |
| 64 | * discovered services |
| 65 | * | |
| 66 | * |---------> |
| 67 | * | | |
| 68 | * | onServiceFound() |
| 69 | * | | |
| 70 | * | add service to list |
| 71 | * | | |
| 72 | * |<---------- |
| 73 | * | |
| 74 | * |---------> |
| 75 | * | | |
| 76 | * | onServiceLost() |
| 77 | * | | |
| 78 | * | remove service from list |
| 79 | * | | |
| 80 | * |<---------- |
| 81 | * | |
| 82 | * | |
| 83 | * | Connect to a service |
| 84 | * | from list ? |
| 85 | * | |
| 86 | * resolveService() |
| 87 | * | |
| 88 | * onServiceResolved() |
| 89 | * | |
| 90 | * Establish connection to service |
| 91 | * with the host and port information |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 92 | * |
| 93 | * </pre> |
| 94 | * An application that needs to advertise itself over a network for other applications to |
| 95 | * discover it can do so with a call to {@link #registerService}. If Example is a http based |
| 96 | * application that can provide HTML data to peer services, it can register a name "Example" |
| 97 | * with service type "_http._tcp". A successful registration is notified with a callback to |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 98 | * {@link RegistrationListener#onServiceRegistered} and a failure to register is notified |
| 99 | * over {@link RegistrationListener#onRegistrationFailed} |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 100 | * |
| 101 | * <p> A peer application looking for http services can initiate a discovery for "_http._tcp" |
| 102 | * with a call to {@link #discoverServices}. A service found is notified with a callback |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 103 | * to {@link DiscoveryListener#onServiceFound} and a service lost is notified on |
| 104 | * {@link DiscoveryListener#onServiceLost}. |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 105 | * |
| 106 | * <p> Once the peer application discovers the "Example" http srevice, and needs to receive data |
| 107 | * from the "Example" application, it can initiate a resolve with {@link #resolveService} to |
| 108 | * resolve the host and port details for the purpose of establishing a connection. A successful |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 109 | * resolve is notified on {@link ResolveListener#onServiceResolved} and a failure is notified |
| 110 | * on {@link ResolveListener#onResolveFailed}. |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 111 | * |
| 112 | * Applications can reserve for a service type at |
| 113 | * http://www.iana.org/form/ports-service. Existing services can be found at |
| 114 | * http://www.iana.org/assignments/service-names-port-numbers/service-names-port-numbers.xml |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 115 | * |
| 116 | * Get an instance of this class by calling {@link android.content.Context#getSystemService(String) |
| 117 | * Context.getSystemService(Context.NSD_SERVICE)}. |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 118 | * |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 119 | * {@see NsdServiceInfo} |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 120 | */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 121 | public final class NsdManager { |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 122 | private static final String TAG = "NsdManager"; |
| 123 | INsdManager mService; |
| 124 | |
Irfan Sheriff | 3ef889b | 2012-04-17 23:15:29 -0700 | [diff] [blame] | 125 | /** |
| 126 | * Broadcast intent action to indicate whether network service discovery is |
| 127 | * enabled or disabled. An extra {@link #EXTRA_NSD_STATE} provides the state |
| 128 | * information as int. |
| 129 | * |
| 130 | * @see #EXTRA_NSD_STATE |
Irfan Sheriff | 3ef889b | 2012-04-17 23:15:29 -0700 | [diff] [blame] | 131 | */ |
| 132 | @SdkConstant(SdkConstantType.BROADCAST_INTENT_ACTION) |
Irfan Sheriff | 6c07ba8 | 2012-04-17 23:23:42 -0700 | [diff] [blame] | 133 | public static final String ACTION_NSD_STATE_CHANGED = |
Irfan Sheriff | 3ef889b | 2012-04-17 23:15:29 -0700 | [diff] [blame] | 134 | "android.net.nsd.STATE_CHANGED"; |
| 135 | |
| 136 | /** |
| 137 | * The lookup key for an int that indicates whether network service discovery is enabled |
| 138 | * or disabled. Retrieve it with {@link android.content.Intent#getIntExtra(String,int)}. |
| 139 | * |
| 140 | * @see #NSD_STATE_DISABLED |
| 141 | * @see #NSD_STATE_ENABLED |
Irfan Sheriff | 3ef889b | 2012-04-17 23:15:29 -0700 | [diff] [blame] | 142 | */ |
| 143 | public static final String EXTRA_NSD_STATE = "nsd_state"; |
| 144 | |
| 145 | /** |
| 146 | * Network service discovery is disabled |
| 147 | * |
Irfan Sheriff | 54ac7a5 | 2012-04-19 10:26:34 -0700 | [diff] [blame] | 148 | * @see #ACTION_NSD_STATE_CHANGED |
Irfan Sheriff | 3ef889b | 2012-04-17 23:15:29 -0700 | [diff] [blame] | 149 | */ |
| 150 | public static final int NSD_STATE_DISABLED = 1; |
| 151 | |
| 152 | /** |
| 153 | * Network service discovery is enabled |
| 154 | * |
Irfan Sheriff | 54ac7a5 | 2012-04-19 10:26:34 -0700 | [diff] [blame] | 155 | * @see #ACTION_NSD_STATE_CHANGED |
Irfan Sheriff | 3ef889b | 2012-04-17 23:15:29 -0700 | [diff] [blame] | 156 | */ |
| 157 | public static final int NSD_STATE_ENABLED = 2; |
| 158 | |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 159 | private static final int BASE = Protocol.BASE_NSD_MANAGER; |
| 160 | |
| 161 | /** @hide */ |
| 162 | public static final int DISCOVER_SERVICES = BASE + 1; |
| 163 | /** @hide */ |
| 164 | public static final int DISCOVER_SERVICES_STARTED = BASE + 2; |
| 165 | /** @hide */ |
| 166 | public static final int DISCOVER_SERVICES_FAILED = BASE + 3; |
| 167 | /** @hide */ |
| 168 | public static final int SERVICE_FOUND = BASE + 4; |
| 169 | /** @hide */ |
| 170 | public static final int SERVICE_LOST = BASE + 5; |
| 171 | |
| 172 | /** @hide */ |
| 173 | public static final int STOP_DISCOVERY = BASE + 6; |
| 174 | /** @hide */ |
| 175 | public static final int STOP_DISCOVERY_FAILED = BASE + 7; |
| 176 | /** @hide */ |
| 177 | public static final int STOP_DISCOVERY_SUCCEEDED = BASE + 8; |
| 178 | |
| 179 | /** @hide */ |
| 180 | public static final int REGISTER_SERVICE = BASE + 9; |
| 181 | /** @hide */ |
| 182 | public static final int REGISTER_SERVICE_FAILED = BASE + 10; |
| 183 | /** @hide */ |
| 184 | public static final int REGISTER_SERVICE_SUCCEEDED = BASE + 11; |
| 185 | |
| 186 | /** @hide */ |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 187 | public static final int UNREGISTER_SERVICE = BASE + 12; |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 188 | /** @hide */ |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 189 | public static final int UNREGISTER_SERVICE_FAILED = BASE + 13; |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 190 | /** @hide */ |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 191 | public static final int UNREGISTER_SERVICE_SUCCEEDED = BASE + 14; |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 192 | |
| 193 | /** @hide */ |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 194 | public static final int RESOLVE_SERVICE = BASE + 18; |
Irfan Sheriff | 817388e | 2012-04-11 14:52:19 -0700 | [diff] [blame] | 195 | /** @hide */ |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 196 | public static final int RESOLVE_SERVICE_FAILED = BASE + 19; |
Irfan Sheriff | 817388e | 2012-04-11 14:52:19 -0700 | [diff] [blame] | 197 | /** @hide */ |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 198 | public static final int RESOLVE_SERVICE_SUCCEEDED = BASE + 20; |
Irfan Sheriff | 817388e | 2012-04-11 14:52:19 -0700 | [diff] [blame] | 199 | |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 200 | /** @hide */ |
Irfan Sheriff | 3ef889b | 2012-04-17 23:15:29 -0700 | [diff] [blame] | 201 | public static final int ENABLE = BASE + 24; |
| 202 | /** @hide */ |
| 203 | public static final int DISABLE = BASE + 25; |
| 204 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 205 | /** @hide */ |
| 206 | public static final int NATIVE_DAEMON_EVENT = BASE + 26; |
| 207 | |
| 208 | /** Dns based service discovery protocol */ |
| 209 | public static final int PROTOCOL_DNS_SD = 0x0001; |
| 210 | |
| 211 | private Context mContext; |
| 212 | |
| 213 | private static final int INVALID_LISTENER_KEY = 0; |
| 214 | private int mListenerKey = 1; |
| 215 | private final SparseArray mListenerMap = new SparseArray(); |
| 216 | private final SparseArray<NsdServiceInfo> mServiceMap = new SparseArray<NsdServiceInfo>(); |
| 217 | private final Object mMapLock = new Object(); |
| 218 | |
| 219 | private final AsyncChannel mAsyncChannel = new AsyncChannel(); |
| 220 | private ServiceHandler mHandler; |
| 221 | private final CountDownLatch mConnected = new CountDownLatch(1); |
Irfan Sheriff | 3ef889b | 2012-04-17 23:15:29 -0700 | [diff] [blame] | 222 | |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 223 | /** |
| 224 | * Create a new Nsd instance. Applications use |
| 225 | * {@link android.content.Context#getSystemService Context.getSystemService()} to retrieve |
| 226 | * {@link android.content.Context#NSD_SERVICE Context.NSD_SERVICE}. |
| 227 | * @param service the Binder interface |
| 228 | * @hide - hide this because it takes in a parameter of type INsdManager, which |
| 229 | * is a system private class. |
| 230 | */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 231 | public NsdManager(Context context, INsdManager service) { |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 232 | mService = service; |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 233 | mContext = context; |
| 234 | init(); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 235 | } |
| 236 | |
| 237 | /** |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 238 | * Failures are passed with {@link RegistrationListener#onRegistrationFailed}, |
| 239 | * {@link RegistrationListener#onUnregistrationFailed}, |
| 240 | * {@link DiscoveryListener#onStartDiscoveryFailed}, |
| 241 | * {@link DiscoveryListener#onStopDiscoveryFailed} or {@link ResolveListener#onResolveFailed}. |
| 242 | * |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 243 | * Indicates that the operation failed due to an internal error. |
| 244 | */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 245 | public static final int FAILURE_INTERNAL_ERROR = 0; |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 246 | |
| 247 | /** |
Irfan Sheriff | 817388e | 2012-04-11 14:52:19 -0700 | [diff] [blame] | 248 | * Indicates that the operation failed because it is already active. |
| 249 | */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 250 | public static final int FAILURE_ALREADY_ACTIVE = 3; |
Irfan Sheriff | 817388e | 2012-04-11 14:52:19 -0700 | [diff] [blame] | 251 | |
| 252 | /** |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 253 | * Indicates that the operation failed because the maximum outstanding |
| 254 | * requests from the applications have reached. |
Irfan Sheriff | 817388e | 2012-04-11 14:52:19 -0700 | [diff] [blame] | 255 | */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 256 | public static final int FAILURE_MAX_LIMIT = 4; |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 257 | |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 258 | /** Interface for callback invocation for service discovery */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 259 | public interface DiscoveryListener { |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 260 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 261 | public void onStartDiscoveryFailed(String serviceType, int errorCode); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 262 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 263 | public void onStopDiscoveryFailed(String serviceType, int errorCode); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 264 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 265 | public void onDiscoveryStarted(String serviceType); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 266 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 267 | public void onDiscoveryStopped(String serviceType); |
| 268 | |
| 269 | public void onServiceFound(NsdServiceInfo serviceInfo); |
| 270 | |
| 271 | public void onServiceLost(NsdServiceInfo serviceInfo); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 272 | |
| 273 | } |
| 274 | |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 275 | /** Interface for callback invocation for service registration */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 276 | public interface RegistrationListener { |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 277 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 278 | public void onRegistrationFailed(NsdServiceInfo serviceInfo, int errorCode); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 279 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 280 | public void onUnregistrationFailed(NsdServiceInfo serviceInfo, int errorCode); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 281 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 282 | public void onServiceRegistered(NsdServiceInfo serviceInfo); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 283 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 284 | public void onServiceUnregistered(NsdServiceInfo serviceInfo); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 285 | } |
| 286 | |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 287 | /** Interface for callback invocation for service resolution */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 288 | public interface ResolveListener { |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 289 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 290 | public void onResolveFailed(NsdServiceInfo serviceInfo, int errorCode); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 291 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 292 | public void onServiceResolved(NsdServiceInfo serviceInfo); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 293 | } |
| 294 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 295 | private class ServiceHandler extends Handler { |
| 296 | ServiceHandler(Looper looper) { |
| 297 | super(looper); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 298 | } |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 299 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 300 | @Override |
| 301 | public void handleMessage(Message message) { |
| 302 | Object listener = getListener(message.arg2); |
| 303 | boolean listenerRemove = true; |
| 304 | switch (message.what) { |
| 305 | case AsyncChannel.CMD_CHANNEL_HALF_CONNECTED: |
| 306 | mAsyncChannel.sendMessage(AsyncChannel.CMD_CHANNEL_FULL_CONNECTION); |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 307 | break; |
| 308 | case AsyncChannel.CMD_CHANNEL_FULLY_CONNECTED: |
Robert Greenwalt | af2eefb | 2013-05-02 15:45:32 -0700 | [diff] [blame] | 309 | mConnected.countDown(); |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 310 | break; |
| 311 | case AsyncChannel.CMD_CHANNEL_DISCONNECTED: |
| 312 | Log.e(TAG, "Channel lost"); |
| 313 | break; |
| 314 | case DISCOVER_SERVICES_STARTED: |
| 315 | String s = ((NsdServiceInfo) message.obj).getServiceType(); |
| 316 | ((DiscoveryListener) listener).onDiscoveryStarted(s); |
| 317 | // Keep listener until stop discovery |
| 318 | listenerRemove = false; |
| 319 | break; |
| 320 | case DISCOVER_SERVICES_FAILED: |
| 321 | ((DiscoveryListener) listener).onStartDiscoveryFailed( |
| 322 | getNsdService(message.arg2).getServiceType(), message.arg1); |
| 323 | break; |
| 324 | case SERVICE_FOUND: |
| 325 | ((DiscoveryListener) listener).onServiceFound((NsdServiceInfo) message.obj); |
| 326 | // Keep listener until stop discovery |
| 327 | listenerRemove = false; |
| 328 | break; |
| 329 | case SERVICE_LOST: |
| 330 | ((DiscoveryListener) listener).onServiceLost((NsdServiceInfo) message.obj); |
| 331 | // Keep listener until stop discovery |
| 332 | listenerRemove = false; |
| 333 | break; |
| 334 | case STOP_DISCOVERY_FAILED: |
| 335 | ((DiscoveryListener) listener).onStopDiscoveryFailed( |
| 336 | getNsdService(message.arg2).getServiceType(), message.arg1); |
| 337 | break; |
| 338 | case STOP_DISCOVERY_SUCCEEDED: |
| 339 | ((DiscoveryListener) listener).onDiscoveryStopped( |
| 340 | getNsdService(message.arg2).getServiceType()); |
| 341 | break; |
| 342 | case REGISTER_SERVICE_FAILED: |
| 343 | ((RegistrationListener) listener).onRegistrationFailed( |
| 344 | getNsdService(message.arg2), message.arg1); |
| 345 | break; |
| 346 | case REGISTER_SERVICE_SUCCEEDED: |
| 347 | ((RegistrationListener) listener).onServiceRegistered( |
| 348 | (NsdServiceInfo) message.obj); |
| 349 | // Keep listener until unregister |
| 350 | listenerRemove = false; |
| 351 | break; |
| 352 | case UNREGISTER_SERVICE_FAILED: |
| 353 | ((RegistrationListener) listener).onUnregistrationFailed( |
| 354 | getNsdService(message.arg2), message.arg1); |
| 355 | break; |
| 356 | case UNREGISTER_SERVICE_SUCCEEDED: |
| 357 | ((RegistrationListener) listener).onServiceUnregistered( |
| 358 | getNsdService(message.arg2)); |
| 359 | break; |
| 360 | case RESOLVE_SERVICE_FAILED: |
| 361 | ((ResolveListener) listener).onResolveFailed( |
| 362 | getNsdService(message.arg2), message.arg1); |
| 363 | break; |
| 364 | case RESOLVE_SERVICE_SUCCEEDED: |
| 365 | ((ResolveListener) listener).onServiceResolved((NsdServiceInfo) message.obj); |
| 366 | break; |
| 367 | default: |
| 368 | Log.d(TAG, "Ignored " + message); |
| 369 | break; |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 370 | } |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 371 | if (listenerRemove) { |
| 372 | removeListener(message.arg2); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 373 | } |
| 374 | } |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 375 | } |
| 376 | |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 377 | private int putListener(Object listener, NsdServiceInfo s) { |
| 378 | if (listener == null) return INVALID_LISTENER_KEY; |
| 379 | int key; |
| 380 | synchronized (mMapLock) { |
| 381 | do { |
| 382 | key = mListenerKey++; |
| 383 | } while (key == INVALID_LISTENER_KEY); |
| 384 | mListenerMap.put(key, listener); |
| 385 | mServiceMap.put(key, s); |
| 386 | } |
| 387 | return key; |
| 388 | } |
| 389 | |
| 390 | private Object getListener(int key) { |
| 391 | if (key == INVALID_LISTENER_KEY) return null; |
| 392 | synchronized (mMapLock) { |
| 393 | return mListenerMap.get(key); |
| 394 | } |
| 395 | } |
| 396 | |
| 397 | private NsdServiceInfo getNsdService(int key) { |
| 398 | synchronized (mMapLock) { |
| 399 | return mServiceMap.get(key); |
| 400 | } |
| 401 | } |
| 402 | |
| 403 | private void removeListener(int key) { |
| 404 | if (key == INVALID_LISTENER_KEY) return; |
| 405 | synchronized (mMapLock) { |
| 406 | mListenerMap.remove(key); |
| 407 | mServiceMap.remove(key); |
| 408 | } |
| 409 | } |
| 410 | |
| 411 | private int getListenerKey(Object listener) { |
| 412 | synchronized (mMapLock) { |
| 413 | int valueIndex = mListenerMap.indexOfValue(listener); |
| 414 | if (valueIndex != -1) { |
| 415 | return mListenerMap.keyAt(valueIndex); |
| 416 | } |
| 417 | } |
| 418 | return INVALID_LISTENER_KEY; |
| 419 | } |
| 420 | |
| 421 | |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 422 | /** |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 423 | * Initialize AsyncChannel |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 424 | */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 425 | private void init() { |
| 426 | final Messenger messenger = getMessenger(); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 427 | if (messenger == null) throw new RuntimeException("Failed to initialize"); |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 428 | HandlerThread t = new HandlerThread("NsdManager"); |
| 429 | t.start(); |
| 430 | mHandler = new ServiceHandler(t.getLooper()); |
| 431 | mAsyncChannel.connect(mContext, mHandler, messenger); |
| 432 | try { |
| 433 | mConnected.await(); |
| 434 | } catch (InterruptedException e) { |
| 435 | Log.e(TAG, "interrupted wait at init"); |
| 436 | } |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 437 | } |
| 438 | |
| 439 | /** |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 440 | * Register a service to be discovered by other services. |
| 441 | * |
| 442 | * <p> The function call immediately returns after sending a request to register service |
| 443 | * to the framework. The application is notified of a success to initiate |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 444 | * discovery through the callback {@link RegistrationListener#onServiceRegistered} or a failure |
| 445 | * through {@link RegistrationListener#onRegistrationFailed}. |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 446 | * |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 447 | * @param serviceInfo The service being registered |
| 448 | * @param protocolType The service discovery protocol |
| 449 | * @param listener The listener notifies of a successful registration and is used to |
| 450 | * unregister this service through a call on {@link #unregisterService}. Cannot be null. |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 451 | */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 452 | public void registerService(NsdServiceInfo serviceInfo, int protocolType, |
| 453 | RegistrationListener listener) { |
| 454 | if (TextUtils.isEmpty(serviceInfo.getServiceName()) || |
| 455 | TextUtils.isEmpty(serviceInfo.getServiceType())) { |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 456 | throw new IllegalArgumentException("Service name or type cannot be empty"); |
| 457 | } |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 458 | if (serviceInfo.getPort() <= 0) { |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 459 | throw new IllegalArgumentException("Invalid port number"); |
| 460 | } |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 461 | if (listener == null) { |
| 462 | throw new IllegalArgumentException("listener cannot be null"); |
| 463 | } |
| 464 | if (protocolType != PROTOCOL_DNS_SD) { |
| 465 | throw new IllegalArgumentException("Unsupported protocol"); |
| 466 | } |
| 467 | mAsyncChannel.sendMessage(REGISTER_SERVICE, 0, putListener(listener, serviceInfo), |
| 468 | serviceInfo); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 469 | } |
| 470 | |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 471 | /** |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 472 | * Unregister a service registered through {@link #registerService}. A successful |
| 473 | * unregister is notified to the application with a call to |
| 474 | * {@link RegistrationListener#onServiceUnregistered}. |
| 475 | * |
| 476 | * @param listener This should be the listener object that was passed to |
| 477 | * {@link #registerService}. It identifies the service that should be unregistered |
| 478 | * and notifies of a successful unregistration. |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 479 | */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 480 | public void unregisterService(RegistrationListener listener) { |
| 481 | int id = getListenerKey(listener); |
| 482 | if (id == INVALID_LISTENER_KEY) { |
| 483 | throw new IllegalArgumentException("listener not registered"); |
| 484 | } |
| 485 | if (listener == null) { |
| 486 | throw new IllegalArgumentException("listener cannot be null"); |
| 487 | } |
| 488 | mAsyncChannel.sendMessage(UNREGISTER_SERVICE, 0, id); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 489 | } |
| 490 | |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 491 | /** |
| 492 | * Initiate service discovery to browse for instances of a service type. Service discovery |
| 493 | * consumes network bandwidth and will continue until the application calls |
| 494 | * {@link #stopServiceDiscovery}. |
| 495 | * |
| 496 | * <p> The function call immediately returns after sending a request to start service |
| 497 | * discovery to the framework. The application is notified of a success to initiate |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 498 | * discovery through the callback {@link DiscoveryListener#onDiscoveryStarted} or a failure |
| 499 | * through {@link DiscoveryListener#onStartDiscoveryFailed}. |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 500 | * |
| 501 | * <p> Upon successful start, application is notified when a service is found with |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 502 | * {@link DiscoveryListener#onServiceFound} or when a service is lost with |
| 503 | * {@link DiscoveryListener#onServiceLost}. |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 504 | * |
| 505 | * <p> Upon failure to start, service discovery is not active and application does |
| 506 | * not need to invoke {@link #stopServiceDiscovery} |
| 507 | * |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 508 | * @param serviceType The service type being discovered. Examples include "_http._tcp" for |
| 509 | * http services or "_ipp._tcp" for printers |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 510 | * @param protocolType The service discovery protocol |
| 511 | * @param listener The listener notifies of a successful discovery and is used |
| 512 | * to stop discovery on this serviceType through a call on {@link #stopServiceDiscovery}. |
| 513 | * Cannot be null. |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 514 | */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 515 | public void discoverServices(String serviceType, int protocolType, DiscoveryListener listener) { |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 516 | if (listener == null) { |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 517 | throw new IllegalArgumentException("listener cannot be null"); |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 518 | } |
| 519 | if (TextUtils.isEmpty(serviceType)) { |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 520 | throw new IllegalArgumentException("Service type cannot be empty"); |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 521 | } |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 522 | |
| 523 | if (protocolType != PROTOCOL_DNS_SD) { |
| 524 | throw new IllegalArgumentException("Unsupported protocol"); |
| 525 | } |
| 526 | |
| 527 | NsdServiceInfo s = new NsdServiceInfo(); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 528 | s.setServiceType(serviceType); |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 529 | mAsyncChannel.sendMessage(DISCOVER_SERVICES, 0, putListener(listener, s), s); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 530 | } |
| 531 | |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 532 | /** |
| 533 | * Stop service discovery initiated with {@link #discoverServices}. An active service |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 534 | * discovery is notified to the application with {@link DiscoveryListener#onDiscoveryStarted} |
| 535 | * and it stays active until the application invokes a stop service discovery. A successful |
| 536 | * stop is notified to with a call to {@link DiscoveryListener#onDiscoveryStopped}. |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 537 | * |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 538 | * <p> Upon failure to stop service discovery, application is notified through |
| 539 | * {@link DiscoveryListener#onStopDiscoveryFailed}. |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 540 | * |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 541 | * @param listener This should be the listener object that was passed to {@link #discoverServices}. |
| 542 | * It identifies the discovery that should be stopped and notifies of a successful stop. |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 543 | */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 544 | public void stopServiceDiscovery(DiscoveryListener listener) { |
| 545 | int id = getListenerKey(listener); |
| 546 | if (id == INVALID_LISTENER_KEY) { |
| 547 | throw new IllegalArgumentException("service discovery not active on listener"); |
| 548 | } |
| 549 | if (listener == null) { |
| 550 | throw new IllegalArgumentException("listener cannot be null"); |
| 551 | } |
| 552 | mAsyncChannel.sendMessage(STOP_DISCOVERY, 0, id); |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 553 | } |
| 554 | |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 555 | /** |
| 556 | * Resolve a discovered service. An application can resolve a service right before |
| 557 | * establishing a connection to fetch the IP and port details on which to setup |
| 558 | * the connection. |
| 559 | * |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 560 | * @param serviceInfo service to be resolved |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 561 | * @param listener to receive callback upon success or failure. Cannot be null. |
| 562 | */ |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 563 | public void resolveService(NsdServiceInfo serviceInfo, ResolveListener listener) { |
| 564 | if (TextUtils.isEmpty(serviceInfo.getServiceName()) || |
| 565 | TextUtils.isEmpty(serviceInfo.getServiceType())) { |
Irfan Sheriff | 9278467 | 2012-04-13 12:15:41 -0700 | [diff] [blame] | 566 | throw new IllegalArgumentException("Service name or type cannot be empty"); |
| 567 | } |
Irfan Sheriff | 22af38c | 2012-05-03 16:44:27 -0700 | [diff] [blame] | 568 | if (listener == null) { |
| 569 | throw new IllegalArgumentException("listener cannot be null"); |
| 570 | } |
| 571 | mAsyncChannel.sendMessage(RESOLVE_SERVICE, 0, putListener(listener, serviceInfo), |
| 572 | serviceInfo); |
Irfan Sheriff | 817388e | 2012-04-11 14:52:19 -0700 | [diff] [blame] | 573 | } |
| 574 | |
Irfan Sheriff | 3ef889b | 2012-04-17 23:15:29 -0700 | [diff] [blame] | 575 | /** Internal use only @hide */ |
| 576 | public void setEnabled(boolean enabled) { |
| 577 | try { |
| 578 | mService.setEnabled(enabled); |
| 579 | } catch (RemoteException e) { } |
| 580 | } |
| 581 | |
Irfan Sheriff | 7d024d3 | 2012-03-22 17:01:39 -0700 | [diff] [blame] | 582 | /** |
| 583 | * Get a reference to NetworkService handler. This is used to establish |
| 584 | * an AsyncChannel communication with the service |
| 585 | * |
| 586 | * @return Messenger pointing to the NetworkService handler |
| 587 | */ |
| 588 | private Messenger getMessenger() { |
| 589 | try { |
| 590 | return mService.getMessenger(); |
| 591 | } catch (RemoteException e) { |
| 592 | return null; |
| 593 | } |
| 594 | } |
| 595 | } |