mir/kdeconnect-android
2
0
Fork 0
mirror of https://github.com/KDE/kdeconnect-android synced 2025-08-30 13:47:41 +00:00
Code Issues Releases Wiki Activity

BroadcastTcpLinkProvider now only uses NioSessionComputerLinks

Browse Source
This commit is contained in:
Albert Vaca 2013-08-07 12:23:52 +02:00
parent 158d57153a
commit a3c9893afd
1 changed files with 73 additions and 88 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

161
KdeConnect/src/main/java/org/kde/connect/LinkProviders/BroadcastTcpLinkProvider.java
View File

@ -7,7 +7,11 @@ import android.os.Looper;
import android.os.Message; import android.os.Message;
import android.util.Log; import android.util.Log;
import org.apache.mina.core.future.ConnectFuture;
import org.apache.mina.core.future.IoFuture;
import org.apache.mina.core.future.IoFutureListener;
import org.apache.mina.core.future.ReadFuture; import org.apache.mina.core.future.ReadFuture;
import org.apache.mina.core.service.IoHandler;
import org.apache.mina.core.service.IoHandlerAdapter; import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession; import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolCodecFilter; import org.apache.mina.filter.codec.ProtocolCodecFilter;
@ -15,6 +19,7 @@ import org.apache.mina.filter.codec.textline.LineDelimiter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory; import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioDatagramAcceptor; import org.apache.mina.transport.socket.nio.NioDatagramAcceptor;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor; import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
import org.apache.mina.transport.socket.nio.NioSocketConnector;
import org.kde.connect.ComputerLinks.BaseComputerLink; import org.kde.connect.ComputerLinks.BaseComputerLink;
import org.kde.connect.ComputerLinks.NioSessionComputerLink; import org.kde.connect.ComputerLinks.NioSessionComputerLink;
import org.kde.connect.ComputerLinks.TcpComputerLink; import org.kde.connect.ComputerLinks.TcpComputerLink;
@ -30,6 +35,46 @@ import java.util.HashMap;
public class BroadcastTcpLinkProvider extends BaseLinkProvider { public class BroadcastTcpLinkProvider extends BaseLinkProvider {
private final static int port = 1714; private final static int port = 1714;
private final IoHandler tcpHandler = new IoHandlerAdapter() {
@Override
public void sessionClosed(IoSession session) throws Exception {
String address = ((InetSocketAddress) session.getRemoteAddress()).toString();
NioSessionComputerLink brokenLink = nioSessions.remove(address);
if (brokenLink != null) {
connectionLost(brokenLink);
String id = brokenLink.getDeviceId();
visibleComputers.remove(id);
}
}
@Override
public void messageReceived(IoSession session, Object message) throws Exception {
super.messageReceived(session, message);
String address = ((InetSocketAddress) session.getRemoteAddress()).toString();
Log.e("BroadcastTcpLinkProvider","Incoming package, address: "+address);
String theMessage = (String) message;
NetworkPackage np = NetworkPackage.unserialize(theMessage);
NioSessionComputerLink prevLink = nioSessions.get(address);
if (np.getType().equals(NetworkPackage.PACKAGE_TYPE_IDENTITY)) {
NioSessionComputerLink link = new NioSessionComputerLink(session, np.getString("deviceId"), BroadcastTcpLinkProvider.this);
nioSessions.put(address,link);
addLink(np, link);
} else {
if (prevLink == null) {
Log.e("BroadcastTcpLinkProvider","2 Expecting an identity package");
} else {
prevLink.injectNetworkPackage(np);
}
}
}
};
Context context; Context context;
HashMap<String, BaseComputerLink> visibleComputers = new HashMap<String, BaseComputerLink>(); HashMap<String, BaseComputerLink> visibleComputers = new HashMap<String, BaseComputerLink>();
@ -57,45 +102,7 @@ public class BroadcastTcpLinkProvider extends BaseLinkProvider {
//This handles the case when I'm the new device in the network and somebody answers my introduction package //This handles the case when I'm the new device in the network and somebody answers my introduction package
tcpAcceptor = new NioSocketAcceptor(); tcpAcceptor = new NioSocketAcceptor();
tcpAcceptor.setHandler(new IoHandlerAdapter() { tcpAcceptor.setHandler(tcpHandler);
@Override
public void sessionClosed(IoSession session) throws Exception {
String address = ((InetSocketAddress) session.getRemoteAddress()).toString();
NioSessionComputerLink brokenLink = nioSessions.remove(address);
if (brokenLink != null) {
connectionLost(brokenLink);
String id = brokenLink.getDeviceId();
visibleComputers.remove(id);
}
}
@Override
public void messageReceived(IoSession session, Object message) throws Exception {
super.messageReceived(session, message);
String address = ((InetSocketAddress) session.getRemoteAddress()).toString();
Log.e("BroadcastTcpLinkProvider","Incoming package, address: "+address);
String theMessage = (String) message;
NetworkPackage np = NetworkPackage.unserialize(theMessage);
NioSessionComputerLink prevLink = nioSessions.get(address);
if (np.getType().equals(NetworkPackage.PACKAGE_TYPE_IDENTITY)) {
NioSessionComputerLink link = new NioSessionComputerLink(session, np.getString("deviceId"), BroadcastTcpLinkProvider.this);
nioSessions.put(address,link);
addLink(np, link);
} else {
if (prevLink == null) {
Log.e("BroadcastTcpLinkProvider","2 Expecting an identity package");
} else {
prevLink.injectNetworkPackage(np);
}
}
}
});
tcpAcceptor.getSessionConfig().setKeepAlive(true); tcpAcceptor.getSessionConfig().setKeepAlive(true);
//TextLineCodecFactory will split incoming data delimited by the given string //TextLineCodecFactory will split incoming data delimited by the given string
tcpAcceptor.getFilterChain().addLast("codec", tcpAcceptor.getFilterChain().addLast("codec",
@ -120,12 +127,12 @@ public class BroadcastTcpLinkProvider extends BaseLinkProvider {
//This handles the case when I'm the existing device in the network and receive a "hello" UDP package //This handles the case when I'm the existing device in the network and receive a "hello" UDP package
updAcceptor = new NioDatagramAcceptor(); updAcceptor = new NioDatagramAcceptor();
updAcceptor.getSessionConfig().setReuseAddress(true); //Share port if existing updAcceptor.getSessionConfig().setReuseAddress(true); //Share port if existing
updAcceptor.setHandler(new IoHandlerAdapter(){ updAcceptor.setHandler(new IoHandlerAdapter() {
@Override @Override
public void messageReceived(IoSession session, Object message) throws Exception { public void messageReceived(IoSession session, Object message) throws Exception {
super.messageReceived(session, message); super.messageReceived(session, message);
Log.e("BroadcastTcpLinkProvider","Udp message received (" + message.getClass() + ") " + message.toString()); Log.e("BroadcastTcpLinkProvider", "Udp message received (" + message.getClass() + ") " + message.toString());
NetworkPackage np = null; NetworkPackage np = null;
@ -135,74 +142,52 @@ public class BroadcastTcpLinkProvider extends BaseLinkProvider {
np = NetworkPackage.unserialize(theMessage); np = NetworkPackage.unserialize(theMessage);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
Log.e("BroadcastTcpLinkProvider","Could not unserialize package"); Log.e("BroadcastTcpLinkProvider", "Could not unserialize package");
} }
if (np != null) { if (np != null) {
final NetworkPackage identityPackage = np; final NetworkPackage identityPackage = np;
if (!np.getType().equals(NetworkPackage.PACKAGE_TYPE_IDENTITY)) { if (!np.getType().equals(NetworkPackage.PACKAGE_TYPE_IDENTITY)) {
Log.e("BroadcastTcpLinkProvider","1 Expecting an identity package"); Log.e("BroadcastTcpLinkProvider", "1 Expecting an identity package");
return; return;
} }
Log.e("BroadcastTcpLinkProvider","It is an identity package, creating link"); Log.e("BroadcastTcpLinkProvider", "It is an identity package, creating link");
final TcpComputerLink link = new TcpComputerLink(np.getString("deviceId"), BroadcastTcpLinkProvider.this);
final InetSocketAddress address = (InetSocketAddress) session.getRemoteAddress(); final InetSocketAddress address = (InetSocketAddress) session.getRemoteAddress();
//This handler inside a thread with a looper inside a handler is ultra hackish final NioSocketConnector connector = new NioSocketConnector();
new Thread(new Runnable() { connector.setHandler(tcpHandler);
//TextLineCodecFactory will split incoming data delimited by the given string
connector.getFilterChain().addLast("codec",
new ProtocolCodecFilter(
new TextLineCodecFactory(Charset.defaultCharset(), LineDelimiter.UNIX, LineDelimiter.UNIX)
)
);
connector.getSessionConfig().setKeepAlive(true);
ConnectFuture future = connector.connect(new InetSocketAddress(address.getAddress(), port));
future.addListener(new IoFutureListener<IoFuture>() {
@Override @Override
public void run() { public void operationComplete(IoFuture ioFuture) {
try { IoSession session = ioFuture.getSession();
Looper l = Looper.myLooper();
if (l != null) l.quit();
try {
Looper.prepare();
} catch(Exception e) {
e.printStackTrace();
Log.e("BroadcastTcpLinkProvider","Looper prepare exception");
}
final Looper l2 = Looper.myLooper();
link.connect(address.getAddress(), port, new Handler() {
@Override
public void handleMessage(Message msg) {
Log.e("BroadcastTcpLinkProvider","Link established, sending own identity"); Log.e("BroadcastTcpLinkProvider","Connection successful: "+session.isConnected());
NetworkPackage np2 = NetworkPackage.createIdentityPackage(context); NioSessionComputerLink link = new NioSessionComputerLink(session,identityPackage.getString("deviceId"),BroadcastTcpLinkProvider.this);
link.sendPackage(np2);
addLink(identityPackage, link); NetworkPackage np2 = NetworkPackage.createIdentityPackage(context);
link.sendPackage(np2);
l2.quit();
}
}, new Handler() {
@Override
public void handleMessage(Message msg) {
connectionLost(link);
visibleComputers.remove(identityPackage.getString("deviceId"));
}
});
Looper.loop();
} catch (Exception e) {
e.printStackTrace();
Log.e("BroadcastTcpLinkProvider","Exception");
Looper l = Looper.myLooper();
if (l != null) l.quit();
}
nioSessions.put(address.toString(),link);
addLink(identityPackage, link);
} }
}).run(); });
Log.e("DONE","DONE0");
} }
Log.e("DONE","DONE2");
} }
}); });
//TextLineCodecFactory will split incoming data delimited by the given string //TextLineCodecFactory will split incoming data delimited by the given string
updAcceptor.getFilterChain().addLast("codec", updAcceptor.getFilterChain().addLast("codec",