410 lines
14 KiB
Java
410 lines
14 KiB
Java
|
/*
|
||
|
|
* Copyright (c) 2015, Motorola Mobility LLC
|
||
|
|
* All rights reserved.
|
||
|
|
*
|
||
|
|
* Redistribution and use in source and binary forms, with or without
|
||
|
|
* modification, are permitted provided that the following conditions are met:
|
||
|
|
* - Redistributions of source code must retain the above copyright
|
||
|
|
* notice, this list of conditions and the following disclaimer.
|
||
|
|
* - Redistributions in binary form must reproduce the above copyright
|
||
|
|
* notice, this list of conditions and the following disclaimer in the
|
||
|
|
* documentation and/or other materials provided with the distribution.
|
||
|
|
* - Neither the name of Motorola Mobility nor the
|
||
|
|
* names of its contributors may be used to endorse or promote products
|
||
|
|
* derived from this software without specific prior written permission.
|
||
|
|
*
|
||
|
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
|
||
|
|
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
|
||
|
|
* THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
|
||
|
|
* PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL MOTOROLA MOBILITY LLC BE LIABLE
|
||
|
|
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
||
|
|
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
|
||
|
|
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
|
||
|
|
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
|
||
|
|
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
|
||
|
|
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH
|
||
|
|
* DAMAGE.
|
||
|
|
*/
|
||
|
|
|
||
|
|
package com.android.service.ims;
|
||
|
|
|
||
|
|
import android.content.Context;
|
||
|
|
import android.os.Handler;
|
||
|
|
import android.os.HandlerThread;
|
||
|
|
import android.os.Looper;
|
||
|
|
import android.os.Message;
|
||
|
|
import android.telephony.PhoneNumberUtils;
|
||
|
|
|
||
|
|
import com.android.ims.internal.Logger;
|
||
|
|
import com.android.service.ims.presence.ContactCapabilityResponse;
|
||
|
|
import com.android.service.ims.presence.PresenceAvailabilityTask;
|
||
|
|
import com.android.service.ims.presence.PresenceCapabilityTask;
|
||
|
|
import com.android.service.ims.presence.PresenceTask;
|
||
|
|
|
||
|
|
import java.util.HashMap;
|
||
|
|
import java.util.Iterator;
|
||
|
|
import java.util.Map;
|
||
|
|
import java.util.Set;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* TaskManager
|
||
|
|
*/
|
||
|
|
public class TaskManager{
|
||
|
|
/*
|
||
|
|
* The logger
|
||
|
|
*/
|
||
|
|
private Logger logger = Logger.getLogger(this.getClass().getName());
|
||
|
|
|
||
|
|
private static TaskManager sTaskManager = null;
|
||
|
|
|
||
|
|
private int mTaskId = 0;
|
||
|
|
|
||
|
|
public final static int TASK_TYPE_GET_CAPABILITY = 1;
|
||
|
|
public final static int TASK_TYPE_GET_AVAILABILITY = 2;
|
||
|
|
public final static int TASK_TYPE_PUBLISH = 3;
|
||
|
|
|
||
|
|
private Map<String, Task> mTaskMap;
|
||
|
|
|
||
|
|
private final Object mSyncObj = new Object();
|
||
|
|
|
||
|
|
private static final int TASK_MANAGER_ON_TERMINATED = 1;
|
||
|
|
private static final int TASK_MANAGER_ON_TIMEOUT = 2;
|
||
|
|
|
||
|
|
private static MessageHandler sMsgHandler;
|
||
|
|
|
||
|
|
public TaskManager(){
|
||
|
|
logger.debug("TaskManager created.");
|
||
|
|
mTaskMap = new HashMap<String, Task>();
|
||
|
|
|
||
|
|
HandlerThread messageHandlerThread = new HandlerThread("MessageHandler",
|
||
|
|
android.os.Process.THREAD_PRIORITY_BACKGROUND);
|
||
|
|
|
||
|
|
messageHandlerThread.start();
|
||
|
|
Looper messageHandlerLooper = messageHandlerThread.getLooper();
|
||
|
|
sMsgHandler = new MessageHandler(messageHandlerLooper);
|
||
|
|
}
|
||
|
|
|
||
|
|
public static synchronized TaskManager getDefault(){
|
||
|
|
if(sTaskManager == null){
|
||
|
|
sTaskManager = new TaskManager();
|
||
|
|
}
|
||
|
|
|
||
|
|
return sTaskManager;
|
||
|
|
}
|
||
|
|
|
||
|
|
public synchronized int generateTaskId(){
|
||
|
|
return mTaskId++;
|
||
|
|
}
|
||
|
|
|
||
|
|
public void putTask(int taskId, Task task){
|
||
|
|
synchronized (mSyncObj){
|
||
|
|
putTaskInternal(taskId, task);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
private synchronized void putTaskInternal(int taskId, Task task){
|
||
|
|
Task sameKeyTask = mTaskMap.put(String.valueOf(taskId), task);
|
||
|
|
|
||
|
|
logger.debug("Added Task: " + task + "Original same key task:" + sameKeyTask);
|
||
|
|
}
|
||
|
|
|
||
|
|
public int addCapabilityTask(Context context, String[] contacts,
|
||
|
|
ContactCapabilityResponse listener, long timeout){
|
||
|
|
int taskId = TaskManager.getDefault().generateTaskId();
|
||
|
|
synchronized (mSyncObj){
|
||
|
|
Task task = new PresenceCapabilityTask(context, taskId, TASK_TYPE_GET_CAPABILITY,
|
||
|
|
listener, contacts, timeout);
|
||
|
|
putTaskInternal(taskId, task);
|
||
|
|
}
|
||
|
|
|
||
|
|
return taskId;
|
||
|
|
}
|
||
|
|
|
||
|
|
public int addAvailabilityTask(String contact, ContactCapabilityResponse listener){
|
||
|
|
int taskId = TaskManager.getDefault().generateTaskId();
|
||
|
|
synchronized (mSyncObj){
|
||
|
|
String[] contacts = new String[1];
|
||
|
|
contacts[0] = contact;
|
||
|
|
Task task = new PresenceAvailabilityTask(taskId, TASK_TYPE_GET_AVAILABILITY,
|
||
|
|
listener, contacts);
|
||
|
|
putTaskInternal(taskId, task);
|
||
|
|
}
|
||
|
|
|
||
|
|
return taskId;
|
||
|
|
}
|
||
|
|
|
||
|
|
public int addPublishTask(String contact){
|
||
|
|
int taskId = TaskManager.getDefault().generateTaskId();
|
||
|
|
synchronized (mSyncObj){
|
||
|
|
String[] contacts = new String[1];
|
||
|
|
contacts[0] = contact;
|
||
|
|
Task task = new PresenceTask(taskId, TASK_TYPE_PUBLISH, null /*listener*/, contacts);
|
||
|
|
putTaskInternal(taskId, task);
|
||
|
|
}
|
||
|
|
|
||
|
|
return taskId;
|
||
|
|
}
|
||
|
|
|
||
|
|
// If need to call getTask in this class please add another one getTaskInternal
|
||
|
|
public Task getTask(int taskId){
|
||
|
|
synchronized (mSyncObj){
|
||
|
|
return mTaskMap.get(String.valueOf(taskId));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public void removeTask(int taskId){
|
||
|
|
synchronized (mSyncObj){
|
||
|
|
Task task = mTaskMap.remove(String.valueOf(taskId));
|
||
|
|
if(task instanceof PresenceCapabilityTask){
|
||
|
|
((PresenceCapabilityTask)task).cancelTimer();
|
||
|
|
}
|
||
|
|
logger.debug("Removed Task: " + task);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public Task getTaskForSingleContactQuery(String contact) {
|
||
|
|
synchronized (mSyncObj){
|
||
|
|
Set<String> keys= mTaskMap.keySet();
|
||
|
|
if(keys == null){
|
||
|
|
logger.debug("getTaskByContact keys=null");
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
for(String key:keys){
|
||
|
|
Task task = mTaskMap.get(key);
|
||
|
|
if(task == null){
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (task instanceof PresenceTask) {
|
||
|
|
PresenceTask presenceTask = (PresenceTask) task;
|
||
|
|
if(presenceTask.mContacts.length == 1 &&
|
||
|
|
PhoneNumberUtils.compare(contact, presenceTask.mContacts[0])){
|
||
|
|
return task;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
public Task getTaskByRequestId(int sipRequestId){
|
||
|
|
synchronized (mSyncObj){
|
||
|
|
Set<String> keys= mTaskMap.keySet();
|
||
|
|
if(keys == null){
|
||
|
|
logger.debug("getTaskByRequestId keys=null");
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
for(String key:keys){
|
||
|
|
if(mTaskMap.get(key).mSipRequestId == sipRequestId){
|
||
|
|
logger.debug("getTaskByRequestId, sipRequestId=" + sipRequestId +
|
||
|
|
" task=" + mTaskMap.get(key));
|
||
|
|
return mTaskMap.get(key);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
logger.debug("getTaskByRequestId, sipRequestId=" + sipRequestId + " task=null");
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
public void onTerminated(String contact){ // for single number capability polling
|
||
|
|
if(contact == null){
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
synchronized (mSyncObj){
|
||
|
|
Set<String> keys= mTaskMap.keySet();
|
||
|
|
if(keys == null){
|
||
|
|
logger.debug("onTerminated keys is null");
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
for(String key:keys){
|
||
|
|
Task task = mTaskMap.get(key);
|
||
|
|
if(task == null){
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
|
||
|
|
if(task instanceof PresenceCapabilityTask){
|
||
|
|
PresenceCapabilityTask capabilityTask = (PresenceCapabilityTask)task;
|
||
|
|
if(capabilityTask.mContacts != null && capabilityTask.mContacts[0] != null &&
|
||
|
|
PhoneNumberUtils.compare(contact, capabilityTask.mContacts[0])){
|
||
|
|
if(!capabilityTask.isWaitingForNotify()){
|
||
|
|
logger.debug("onTerminated the tesk is not waiting for NOTIFY yet");
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
|
||
|
|
MessageData messageData = new MessageData();
|
||
|
|
messageData.mTask = capabilityTask;
|
||
|
|
messageData.mReason = null;
|
||
|
|
|
||
|
|
Message notifyMessage = sMsgHandler.obtainMessage(
|
||
|
|
TASK_MANAGER_ON_TERMINATED,
|
||
|
|
messageData);
|
||
|
|
sMsgHandler.sendMessage(notifyMessage);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public void onTerminated(int requestId, String reason){
|
||
|
|
logger.debug("onTerminated requestId=" + requestId + " reason=" + reason);
|
||
|
|
|
||
|
|
Task task = getTaskByRequestId(requestId);
|
||
|
|
if(task == null){
|
||
|
|
logger.debug("onTerminated Can't find request " + requestId);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
synchronized (mSyncObj){
|
||
|
|
if(task instanceof PresenceCapabilityTask){
|
||
|
|
MessageData messageData = new MessageData();
|
||
|
|
messageData.mTask = (PresenceCapabilityTask)task;
|
||
|
|
messageData.mReason = reason;
|
||
|
|
|
||
|
|
Message notifyMessage = sMsgHandler.obtainMessage(TASK_MANAGER_ON_TERMINATED,
|
||
|
|
messageData);
|
||
|
|
sMsgHandler.sendMessage(notifyMessage);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public void onTimeout(int taskId){
|
||
|
|
logger.debug("onTimeout taskId=" + taskId);
|
||
|
|
|
||
|
|
Task task = getTask(taskId);
|
||
|
|
if(task == null){
|
||
|
|
logger.debug("onTimeout task = null");
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
synchronized (mSyncObj){
|
||
|
|
if(task instanceof PresenceCapabilityTask){
|
||
|
|
MessageData messageData = new MessageData();
|
||
|
|
messageData.mTask = (PresenceCapabilityTask)task;
|
||
|
|
messageData.mReason = null;
|
||
|
|
|
||
|
|
Message timeoutMessage = sMsgHandler.obtainMessage(TASK_MANAGER_ON_TIMEOUT,
|
||
|
|
messageData);
|
||
|
|
sMsgHandler.sendMessage(timeoutMessage);
|
||
|
|
}else{
|
||
|
|
logger.debug("not PresenceCapabilityTask, taskId=" + taskId);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public class MessageData{
|
||
|
|
public PresenceCapabilityTask mTask;
|
||
|
|
public String mReason;
|
||
|
|
}
|
||
|
|
|
||
|
|
public class MessageHandler extends Handler{
|
||
|
|
MessageHandler(Looper looper){
|
||
|
|
super(looper);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override
|
||
|
|
public void handleMessage(Message msg) {
|
||
|
|
super.handleMessage(msg);
|
||
|
|
|
||
|
|
logger.debug( "Thread=" + Thread.currentThread().getName() + " received "
|
||
|
|
+ msg);
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
if(msg == null){
|
||
|
|
logger.error("msg=null");
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
switch (msg.what) {
|
||
|
|
case TASK_MANAGER_ON_TERMINATED:
|
||
|
|
{
|
||
|
|
MessageData messageData = (MessageData) msg.obj;
|
||
|
|
if(messageData != null && messageData.mTask != null){
|
||
|
|
messageData.mTask.onTerminated(messageData.mReason);
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
case TASK_MANAGER_ON_TIMEOUT:
|
||
|
|
{
|
||
|
|
MessageData messageData = (MessageData) msg.obj;
|
||
|
|
if(messageData != null && messageData.mTask != null){
|
||
|
|
messageData.mTask.onTimeout();
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
default:
|
||
|
|
logger.debug("handleMessage unknown msg=" + msg.what);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public void clearTimeoutAvailabilityTask(long availabilityExpire) {
|
||
|
|
logger.debug("clearTimeoutAvailabilityTask");
|
||
|
|
|
||
|
|
synchronized (mSyncObj) {
|
||
|
|
long currentTime = System.currentTimeMillis();
|
||
|
|
|
||
|
|
Iterator<Map.Entry<String, Task>> iterator = mTaskMap.entrySet().iterator();
|
||
|
|
while (iterator.hasNext()) {
|
||
|
|
Map.Entry<String, Task> entry = iterator.next();
|
||
|
|
|
||
|
|
Task task = (Task) entry.getValue();
|
||
|
|
logger.debug("Currently existing Availability task, key: " + entry.getKey()
|
||
|
|
+ ", Task: " + task);
|
||
|
|
|
||
|
|
if ((task != null) && (task instanceof PresenceAvailabilityTask)) {
|
||
|
|
PresenceAvailabilityTask presenceTask = (PresenceAvailabilityTask)task;
|
||
|
|
|
||
|
|
long notifyTimestamp = presenceTask.getNotifyTimestamp();
|
||
|
|
long createTimestamp = presenceTask.getCreateTimestamp();
|
||
|
|
logger.debug("createTimestamp=" + createTimestamp + " notifyTimestamp=" +
|
||
|
|
notifyTimestamp + " currentTime=" + currentTime);
|
||
|
|
|
||
|
|
// remove it if it didn't get notify in 60s.
|
||
|
|
// or get notify for 60s
|
||
|
|
if(((notifyTimestamp != 0) &&
|
||
|
|
(notifyTimestamp + availabilityExpire < currentTime)) ||
|
||
|
|
(notifyTimestamp == 0) &&
|
||
|
|
(createTimestamp + availabilityExpire < currentTime)) {
|
||
|
|
logger.debug("remove expired availability task:" + presenceTask);
|
||
|
|
iterator.remove();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public PresenceAvailabilityTask getAvailabilityTaskByContact(String contact){
|
||
|
|
synchronized (mSyncObj){
|
||
|
|
Set<String> keys= mTaskMap.keySet();
|
||
|
|
if(keys == null){
|
||
|
|
logger.debug("getTaskByContact keys=null");
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
for(String key:keys){
|
||
|
|
Task task = mTaskMap.get(key);
|
||
|
|
if(task == null){
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
|
||
|
|
if(task instanceof PresenceAvailabilityTask){
|
||
|
|
PresenceAvailabilityTask availabilityTask = (PresenceAvailabilityTask)task;
|
||
|
|
if(PhoneNumberUtils.compare(contact, availabilityTask.mContacts[0])){
|
||
|
|
return availabilityTask;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|