1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
package com.orbekk;
import java.util.ArrayList;
import java.util.Properties;
import android.app.Service;
import android.content.Intent;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.os.Messenger;
import android.widget.Toast;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.orbekk.same.NetworkNotificationListener;
import com.orbekk.same.SameController;
import com.orbekk.same.android.net.AndroidBroadcasterFactory;
import com.orbekk.same.android.net.Broadcaster;
import com.orbekk.same.config.Configuration;
public class SameService extends Service {
public final static int DISPLAY_MESSAGE = 1;
public final static int SEARCH_NETWORKS = 2;
public final static String AVAILABLE_NETWORKS_UPDATE =
"com.orbekk.same.SameService.action.AVAILABLE_NETWORKS_UPDATE";
public final static String AVAILABLE_NETWORKS =
"com.orbekk.same.SameService.action.AVAILABLE_NETWORKS";
final static int SERVICE_PORT = 15068;
final static int DISCOVERY_PORT = 15066;
private Logger logger = LoggerFactory.getLogger(getClass());
private SameController sameController = null;
private Configuration configuration = null;
private ArrayList<String> networkNames = new ArrayList<String>();
private ArrayList<String> networkUrls = new ArrayList<String>();
private NetworkNotificationListener networkListener =
new NetworkNotificationListener() {
@Override
public void notifyNetwork(String networkName, String masterUrl) {
logger.info("notifyNetwork({})", networkName);
networkNames.add(networkName);
networkUrls.add(masterUrl);
Intent intent = new Intent(AVAILABLE_NETWORKS_UPDATE);
intent.putStringArrayListExtra(AVAILABLE_NETWORKS,
networkNames);
sendBroadcast(intent);
}
};
class InterfaceHandler extends Handler {
@Override public void handleMessage(Message message) {
switch (message.what) {
case DISPLAY_MESSAGE:
Toast.makeText(SameService.this,
(String)message.obj, Toast.LENGTH_SHORT)
.show();
break;
case SEARCH_NETWORKS:
logger.info("SEARCH_NETWORKS");
sameController.searchNetworks();
break;
default:
super.handleMessage(message);
}
}
}
private final Messenger messenger = new Messenger(new InterfaceHandler());
private void initializeConfiguration() {
Properties properties = new Properties();
properties.setProperty("port", ""+SERVICE_PORT);
properties.setProperty("localIp",
new Broadcaster(this).getWlanAddress().getHostAddress());
properties.setProperty("masterUrl", "http://10.0.0.6:10010/MasterService.json");
properties.setProperty("discoveryPort", ""+DISCOVERY_PORT);
configuration = new Configuration(properties);
}
@Override
public IBinder onBind(Intent intent) {
logger.info("onBind()");
// Make sure service continues to run after it is unbound.
Intent service = new Intent(this, getClass());
startService(service);
return messenger.getBinder();
}
@Override
public int onStartCommand(Intent intent, int flags, int startId) {
logger.info("onStartCommand()");
return START_STICKY;
}
@Override
public void onCreate() {
logger.info("onCreate()");
if (sameController == null) {
initializeConfiguration();
sameController = SameController.create(
new AndroidBroadcasterFactory(this),
configuration);
try {
sameController.start();
sameController.getClient().setNetworkListener(networkListener);
} catch (Exception e) {
logger.error("Failed to start server", e);
}
}
}
@Override
public void onDestroy() {
logger.info("onDestroy()");
if (sameController != null) {
sameController.stop();
}
}
}
|
