summaryrefslogtreecommitdiff
path: root/same-android/src/main/java
diff options
context:
space:
mode:
authorKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-02-26 11:18:26 +0100
committerKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-02-26 11:38:33 +0100
commit402efe234b8e2fefa6ea5f135d27c5575ade34d9 (patch)
treeb1a4a6352b1519f969f357cd691eabeedd1d50a0 /same-android/src/main/java
parent5aaf308a0c0d67836d3225fb7f4ed0ab0d842209 (diff)
Add StateViewerActivity.
StateViewerActivity displays the current state from a ClientInterfaceBridge
Diffstat (limited to 'same-android/src/main/java')
-rw-r--r--same-android/src/main/java/com/orbekk/same/MainActivity.java3
-rw-r--r--same-android/src/main/java/com/orbekk/same/SameService.java35
-rw-r--r--same-android/src/main/java/com/orbekk/same/StateViewerActivity.java55
-rw-r--r--same-android/src/main/java/com/orbekk/same/android/ClientInterfaceBridge.java42
4 files changed, 117 insertions, 18 deletions
diff --git a/same-android/src/main/java/com/orbekk/same/MainActivity.java b/same-android/src/main/java/com/orbekk/same/MainActivity.java
index ea6e315..a8624ce 100644
--- a/same-android/src/main/java/com/orbekk/same/MainActivity.java
+++ b/same-android/src/main/java/com/orbekk/same/MainActivity.java
@@ -33,6 +33,9 @@ public class MainActivity extends Activity {
case R.id.variable_test:
startActivity(new Intent(this, VariableTestActivity.class));
break;
+ case R.id.state_viewer:
+ startActivity(new Intent(this, StateViewerActivity.class));
+ break;
default:
logger.error("Unknown menu entry: {}", item);
}
diff --git a/same-android/src/main/java/com/orbekk/same/SameService.java b/same-android/src/main/java/com/orbekk/same/SameService.java
index dad4b50..386b9b8 100644
--- a/same-android/src/main/java/com/orbekk/same/SameService.java
+++ b/same-android/src/main/java/com/orbekk/same/SameService.java
@@ -2,6 +2,7 @@ package com.orbekk.same;
import java.util.ArrayList;
import java.util.Properties;
+import java.util.Vector;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -27,6 +28,7 @@ public class SameService extends Service {
public final static int JOIN_NETWORK = 4;
public final static int UPDATED_STATE_MESSAGE = 5;
public final static int ADD_STATE_RECEIVER = 6;
+ public final static int REMOVE_STATE_RECEIVER = 7;
public final static String AVAILABLE_NETWORKS_UPDATE =
"com.orbekk.same.SameService.action.AVAILABLE_NETWORKS_UPDATE";
@@ -41,7 +43,7 @@ public class SameService extends Service {
private Logger logger = LoggerFactory.getLogger(getClass());
private SameController sameController = null;
private Configuration configuration = null;
- private ArrayList<Messenger> stateReceivers = new ArrayList<Messenger>();
+ private Vector<Messenger> stateReceivers = new Vector<Messenger>();
private ArrayList<String> networkNames = new ArrayList<String>();
private ArrayList<String> networkUrls = new ArrayList<String>();
@@ -92,6 +94,7 @@ public class SameService extends Service {
logger.info("JOIN_NETWORK");
String masterUrl = (String)message.obj;
sameController.getClient().joinNetwork(masterUrl);
+ break;
case ADD_STATE_RECEIVER:
logger.info("ADD_STATE_RECEIVER: {}", message);
Messenger messenger = message.replyTo;
@@ -101,6 +104,12 @@ public class SameService extends Service {
} else {
logger.error("ADD_STATE_RECEIVER: Missing Messenger.");
}
+ break;
+ case REMOVE_STATE_RECEIVER:
+ logger.info("REMOVE_STATE_RECEIVER: {}", message);
+ Messenger droppedMessenger = (Messenger)message.obj;
+ stateReceivers.remove(droppedMessenger);
+ break;
default:
super.handleMessage(message);
}
@@ -112,19 +121,21 @@ public class SameService extends Service {
private StateChangedListener stateListener = new StateChangedListener() {
@Override
public void stateChanged(Component component) {
- ArrayList<Messenger> dropped = new ArrayList<Messenger>();
- for (Messenger messenger : stateReceivers) {
- Message message = Message.obtain(null, UPDATED_STATE_MESSAGE);
- message.obj = component;
- try {
- messenger.send(message);
- } catch (RemoteException e) {
- logger.warn("Failed to send update. Dropping state receiver.");
- e.printStackTrace();
- dropped.add(messenger);
+ synchronized (stateReceivers) {
+ ArrayList<Messenger> dropped = new ArrayList<Messenger>();
+ for (Messenger messenger : stateReceivers) {
+ Message message = Message.obtain(null, UPDATED_STATE_MESSAGE);
+ message.obj = component;
+ try {
+ messenger.send(message);
+ } catch (RemoteException e) {
+ logger.warn("Failed to send update. Dropping state receiver.");
+ e.printStackTrace();
+ dropped.add(messenger);
+ }
}
+ stateReceivers.removeAll(dropped);
}
- stateReceivers.removeAll(dropped);
}
};
diff --git a/same-android/src/main/java/com/orbekk/same/StateViewerActivity.java b/same-android/src/main/java/com/orbekk/same/StateViewerActivity.java
new file mode 100644
index 0000000..9dfb61e
--- /dev/null
+++ b/same-android/src/main/java/com/orbekk/same/StateViewerActivity.java
@@ -0,0 +1,55 @@
+package com.orbekk.same;
+
+import java.util.ArrayList;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import android.app.Activity;
+import android.os.Bundle;
+import android.widget.ArrayAdapter;
+import android.widget.ListView;
+import android.widget.Toast;
+
+import com.orbekk.same.State.Component;
+import com.orbekk.same.android.ClientInterfaceBridge;
+
+public class StateViewerActivity extends Activity {
+ private Logger logger = LoggerFactory.getLogger(getClass());
+ private ClientInterfaceBridge client;
+
+ private StateChangedListener stateListener = new StateChangedListener() {
+ @Override
+ public void stateChanged(Component component) {
+ displayState();
+ }
+ };
+
+ private void displayState() {
+ ArrayList<String> contentList = new ArrayList<String>();
+ for (State.Component component : client.getState().getComponents()) {
+ contentList.add(component.toString());
+ }
+ ListView list = (ListView)findViewById(R.id.state_view_list);
+ list.setAdapter(new ArrayAdapter<String>(
+ this, R.layout.list_text_item, contentList));
+ }
+
+ @Override public void onCreate(Bundle bundle) {
+ super.onCreate(bundle);
+ setContentView(R.layout.state_viewer);
+ }
+
+ @Override public void onResume() {
+ super.onResume();
+ client = new ClientInterfaceBridge(this);
+ client.addStateListener(stateListener);
+ client.connect();
+ }
+
+ @Override public void onStop() {
+ super.onStop();
+ client.removeStateListener(stateListener);
+ client.disconnect();
+ }
+}
diff --git a/same-android/src/main/java/com/orbekk/same/android/ClientInterfaceBridge.java b/same-android/src/main/java/com/orbekk/same/android/ClientInterfaceBridge.java
index 22396f3..f885b5a 100644
--- a/same-android/src/main/java/com/orbekk/same/android/ClientInterfaceBridge.java
+++ b/same-android/src/main/java/com/orbekk/same/android/ClientInterfaceBridge.java
@@ -1,5 +1,7 @@
package com.orbekk.same.android;
+import java.util.ArrayList;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -12,7 +14,6 @@ import android.os.IBinder;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
-import android.widget.Toast;
import com.orbekk.same.ClientInterface;
import com.orbekk.same.SameService;
@@ -21,13 +22,20 @@ import com.orbekk.same.StateChangedListener;
import com.orbekk.same.UpdateConflict;
public class ClientInterfaceBridge implements ClientInterface {
+ private State state;
+ private ArrayList<StateChangedListener> listeners =
+ new ArrayList<StateChangedListener>();
+
class ResponseHandler extends Handler {
@Override public void handleMessage(Message message) {
+ if (serviceMessenger == null) {
+ logger.warn("Ignoring message to disabled ResponseHandler.");
+ return;
+ }
switch (message.what) {
case SameService.UPDATED_STATE_MESSAGE:
State.Component component = (State.Component)message.obj;
- Toast.makeText(context, "Updated: " + component,
- Toast.LENGTH_SHORT).show();
+ updateState(component);
default:
logger.warn("Received unknown message from service: {}",
message);
@@ -60,40 +68,62 @@ public class ClientInterfaceBridge implements ClientInterface {
}
};
+ private void updateState(State.Component component) {
+ state.update(component.getName(), component.getData(),
+ component.getRevision());
+ for (StateChangedListener listener : listeners) {
+ listener.stateChanged(component);
+ }
+ }
+
public ClientInterfaceBridge(Context context) {
this.context = context;
}
public void connect() {
+ state = new State(".Temporary");
Intent intent = new Intent(context, SameService.class);
context.bindService(intent, serviceConnection, Context.BIND_AUTO_CREATE);
}
+ private void disconnectFromService() {
+ Message message = Message.obtain(null, SameService.REMOVE_STATE_RECEIVER);
+ message.obj = responseMessenger;
+ try {
+ serviceMessenger.send(message);
+ } catch (RemoteException e) {
+ e.printStackTrace();
+ }
+ }
+
public void disconnect() {
if (serviceMessenger != null) {
+ disconnectFromService();
context.unbindService(serviceConnection);
+ state = null;
}
}
@Override
public State getState() {
- return null;
+ return new State(state);
}
@Override
public void set(String name, String data, long revision) throws UpdateConflict {
logger.info("set({}, {}, {}",
new Object[]{name, data, revision});
+ throw new RuntimeException("Not implemented.");
}
@Override
public void addStateListener(StateChangedListener listener) {
- logger.info("addStateListener()");
+ listeners.add(listener);
}
@Override
public void removeStateListener(StateChangedListener listener) {
- logger.info("removeStateListener()");
+ listeners.remove(listener);
}
}