summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorYuriy <YChernyshov@luxoft.com>2014-06-24 13:41:45 +0300
committerYuriy <YChernyshov@luxoft.com>2014-06-24 13:41:45 +0300
commitea3a2c806dfe0b0181b1b22891689c938b8ab250 (patch)
tree89a87b90ceca2369a6b570434e1449806df12323
parent97dfcb8152a7e6f271d49f1891840597e52b026b (diff)
downloadsdl_core-ea3a2c806dfe0b0181b1b22891689c938b8ab250.tar.gz
Not a subject for review
Reason: Trivial changes
-rw-r--r--mobile/android/SyncProxyAndroid/src/main/java/com/ford/syncV4/proxy/SyncProxyBase.java3
-rw-r--r--mobile/android/SyncProxyAndroid/src/main/java/com/ford/syncV4/proxy/rpc/RegisterAppInterface.java5
-rw-r--r--mobile/android/SyncProxyTester/src/main/java/com/ford/syncV4/android/activity/SyncProxyTester.java63
-rw-r--r--mobile/android/SyncProxyTester/src/main/java/com/ford/syncV4/android/service/ProxyService.java10
4 files changed, 29 insertions, 52 deletions
diff --git a/mobile/android/SyncProxyAndroid/src/main/java/com/ford/syncV4/proxy/SyncProxyBase.java b/mobile/android/SyncProxyAndroid/src/main/java/com/ford/syncV4/proxy/SyncProxyBase.java
index bf8baeca25..1a16fb9876 100644
--- a/mobile/android/SyncProxyAndroid/src/main/java/com/ford/syncV4/proxy/SyncProxyBase.java
+++ b/mobile/android/SyncProxyAndroid/src/main/java/com/ford/syncV4/proxy/SyncProxyBase.java
@@ -1085,6 +1085,7 @@ public abstract class SyncProxyBase<ProxyListenerType extends IProxyListenerBase
private void cleanProxy() throws SyncException {
try {
// ALM Specific Cleanup
+ Logger.d("Start clean SYNC Proxy, isALM:" + mAdvancedLifecycleManagementEnabled);
if (mAdvancedLifecycleManagementEnabled) {
mSyncConnectionState = SyncConnectionState.SYNC_DISCONNECTED;
@@ -1120,7 +1121,7 @@ public abstract class SyncProxyBase<ProxyListenerType extends IProxyListenerBase
mIsProxyDisposed = true;
- Logger.i("SyncProxy start Dispose");
+ Logger.i("SYNC Proxy start Dispose");
try {
// Clean the proxy
diff --git a/mobile/android/SyncProxyAndroid/src/main/java/com/ford/syncV4/proxy/rpc/RegisterAppInterface.java b/mobile/android/SyncProxyAndroid/src/main/java/com/ford/syncV4/proxy/rpc/RegisterAppInterface.java
index 544d911edb..2d97c41abd 100644
--- a/mobile/android/SyncProxyAndroid/src/main/java/com/ford/syncV4/proxy/rpc/RegisterAppInterface.java
+++ b/mobile/android/SyncProxyAndroid/src/main/java/com/ford/syncV4/proxy/rpc/RegisterAppInterface.java
@@ -24,15 +24,10 @@ public class RegisterAppInterface extends RPCRequest {
public SyncMsgVersion getSyncMsgVersion() {
Object obj = parameters.get(Names.syncMsgVersion);
- Logger.d("TRACE RAI:" + obj);
if (obj instanceof SyncMsgVersion) {
- Logger.d("TRACE RAI SyncMsgVersion:" + obj);
return (SyncMsgVersion) obj;
} else if (obj instanceof Hashtable) {
- Logger.d("TRACE RAI Hashtable:" + obj);
return new SyncMsgVersion((Hashtable) obj);
- } else if (obj instanceof Vector<?>) {
- Logger.d("TRACE RAI Vector:" + obj);
}
return null;
}
diff --git a/mobile/android/SyncProxyTester/src/main/java/com/ford/syncV4/android/activity/SyncProxyTester.java b/mobile/android/SyncProxyTester/src/main/java/com/ford/syncV4/android/activity/SyncProxyTester.java
index 8634ddf38b..d6447616cb 100644
--- a/mobile/android/SyncProxyTester/src/main/java/com/ford/syncV4/android/activity/SyncProxyTester.java
+++ b/mobile/android/SyncProxyTester/src/main/java/com/ford/syncV4/android/activity/SyncProxyTester.java
@@ -165,9 +165,6 @@ public class SyncProxyTester extends ActionBarActivity implements ActionBar.TabL
// make it public to access from Fragments
public ProxyService mBoundProxyService;
- // Probably this is obsolete approch as there is Services Pool inside SDK
- private ExecutorService mStreamCommandsExecutorService;
-
public static SyncProxyTester getInstance() {
return sActivityInstance;
}
@@ -273,7 +270,6 @@ public class SyncProxyTester extends ActionBarActivity implements ActionBar.TabL
});
addListeners();
- mStreamCommandsExecutorService = Executors.newFixedThreadPool(3);
}
/**
@@ -1401,14 +1397,11 @@ public class SyncProxyTester extends ActionBarActivity implements ActionBar.TabL
}
public void startMobileNaviService(final String appId) {
-
- mStreamCommandsExecutorService.submit(new Runnable() {
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(new Runnable() {
@Override
public void run() {
- if (!isProxyReadyForWork(appId)) {
- return;
- }
- PlaceholderFragment fragment = getFragmentByAppId(appId);
+ final PlaceholderFragment fragment = getFragmentByAppId(appId);
if (fragment == null) {
Logger.w("Start Mobile Navi service, Fragment NULL");
return;
@@ -1450,13 +1443,10 @@ public class SyncProxyTester extends ActionBarActivity implements ActionBar.TabL
}
public void stopMobileNavService(final String appId) {
-
- mStreamCommandsExecutorService.submit(new Runnable() {
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(new Runnable() {
@Override
public void run() {
- if (!isProxyReadyForWork(appId)) {
- return;
- }
final PlaceholderFragment fragment = getFragmentByAppId(appId);
if (fragment == null) {
Logger.w("Stop Audio Service, Fragment NULL");
@@ -1467,39 +1457,17 @@ public class SyncProxyTester extends ActionBarActivity implements ActionBar.TabL
if (mBoundProxyService == null) {
return;
}
- mBoundProxyService.syncProxyStopMobileNaviService(appId);
closeMobileNaviOutputStream();
+ mBoundProxyService.syncProxyStopMobileNaviService(appId);
}
});
}
- public boolean isProxyReadyForWork(String appId) {
- if (mBoundProxyService == null) {
- return false;
- }
- if (!mBoundProxyService.isSyncProxyNotNull()) {
- onSyncServiceError(appId, "Error. Proxy is null");
- return false;
- }
- if (!mBoundProxyService.isSyncProxyConnected()) {
- onSyncServiceError(appId, "Error. Proxy is not connected");
- return false;
- }
- if (!mBoundProxyService.isSyncProxyConnectionNotNull()) {
- onSyncServiceError(appId, "Error. Sync Connection is null");
- return false;
- }
- return true;
- }
-
public void startAudioService(final String appId) {
-
- mStreamCommandsExecutorService.submit(new Runnable() {
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(new Runnable() {
@Override
public void run() {
- if (!isProxyReadyForWork(appId)) {
- return;
- }
PlaceholderFragment fragment = getFragmentByAppId(appId);
if (fragment == null) {
Logger.w("Start Audio Service, Fragment NULL");
@@ -1516,13 +1484,10 @@ public class SyncProxyTester extends ActionBarActivity implements ActionBar.TabL
}
public void stopAudioService(final String appId) {
-
- mStreamCommandsExecutorService.submit(new Runnable() {
+ ExecutorService executorService = Executors.newSingleThreadExecutor();
+ executorService.submit(new Runnable() {
@Override
public void run() {
- if (!isProxyReadyForWork(appId)) {
- return;
- }
final PlaceholderFragment fragment = getFragmentByAppId(appId);
if (fragment == null) {
Logger.w("Stop Audio Service, Fragment NULL");
@@ -1533,8 +1498,8 @@ public class SyncProxyTester extends ActionBarActivity implements ActionBar.TabL
if (mBoundProxyService == null) {
return;
}
- mBoundProxyService.syncProxyStopAudioService(appId);
closeAudioOutputStream();
+ mBoundProxyService.syncProxyStopAudioService(appId);
}
});
}
@@ -1673,6 +1638,12 @@ public class SyncProxyTester extends ActionBarActivity implements ActionBar.TabL
mStopProxyServiceTimeOutHandler.postDelayed(mExitPostDelayedCallback, EXIT_TIMEOUT);
+ String[] appIds = mBoundProxyService.getAllAppIds();
+ for (String appId: appIds) {
+ stopMobileNavService(appId);
+ stopAudioService(appId);
+ }
+
mBoundProxyService.destroyService();
}
});
diff --git a/mobile/android/SyncProxyTester/src/main/java/com/ford/syncV4/android/service/ProxyService.java b/mobile/android/SyncProxyTester/src/main/java/com/ford/syncV4/android/service/ProxyService.java
index c46c99b106..bdd1da4fa7 100644
--- a/mobile/android/SyncProxyTester/src/main/java/com/ford/syncV4/android/service/ProxyService.java
+++ b/mobile/android/SyncProxyTester/src/main/java/com/ford/syncV4/android/service/ProxyService.java
@@ -362,6 +362,16 @@ public class ProxyService extends Service implements IProxyListenerALMTesting, I
return mSessionsCounter.contains(appId);
}
+ public String[] getAllAppIds() {
+ String[] result = new String[mSessionsCounter.size()];
+ int counter = 0;
+ for (String appId: mSessionsCounter) {
+ // return a copy of the AppId
+ result[counter] = new String(appId);
+ }
+ return result;
+ }
+
/**
* Prepare all necessary parameters to be passed to Sync proxy
*/