ExternalVendorCode/serval-dna
1
0
Fork 0
mirror of https://github.com/servalproject/serval-dna.git synced 2025-02-21 09:51:50 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Allow java nio channels to throw IOException

Browse Source
This commit is contained in:
Jeremy Lakeman 2016-06-07 11:31:04 +09:30
parent 1e3236e89c
commit 7e497d01d6
2 changed files with 35 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
java/org/servalproject/servaldna/AbstractMdpProtocol.java
View File

@ -47,14 +47,10 @@ public abstract class AbstractMdpProtocol<T> extends ChannelSelector.Handler {
protected abstract void parse(MdpPacket response);
@Override
public void read() {
try {
MdpPacket response = new MdpPacket();
socket.receive(response);
parse(response);
} catch (IOException e) {
e.printStackTrace();
}
public void read() throws IOException {
MdpPacket response = new MdpPacket();
socket.receive(response);
parse(response);
}
@Override

46
java/org/servalproject/servaldna/ChannelSelector.java
View File

@ -1,6 +1,7 @@
package org.servalproject.servaldna;
import java.io.IOException;
import java.nio.channels.CancelledKeyException;
import java.nio.channels.SelectableChannel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
@ -14,10 +15,10 @@ public class ChannelSelector {
public static abstract class Handler{
public abstract SelectableChannel getChannel() throws IOException;
public abstract int getInterest();
public void read(){};
public void write(){};
public void accept(){};
public void connect(){};
public void read() throws IOException {};
public void write() throws IOException {};
public void accept() throws IOException {};
public void finishConnect() throws IOException {};
}
private Runnable selectorThread = new Runnable(){
@ -61,17 +62,32 @@ public class ChannelSelector {
Iterator<SelectionKey> keys = selector.selectedKeys().iterator();
while(keys.hasNext()){
SelectionKey key = keys.next();
Handler h = (Handler)key.attachment();
if (key.isValid()){
if (key.isReadable())
h.read();
if (key.isWritable())
h.write();
if (key.isAcceptable())
h.accept();
if (key.isConnectable())
h.connect();
try {
SelectionKey key = keys.next();
Handler h = (Handler)key.attachment();
if (key.isValid()){
if (key.isReadable())
h.read();
if (key.isWritable())
h.write();
if (key.isAcceptable())
h.accept();
if (key.isConnectable())
h.finishConnect();
SelectableChannel channel = h.getChannel();
int i = h.getInterest() & channel.validOps();
if (i == 0) {
key.cancel();
channel.configureBlocking(true);
} else {
key.interestOps(i);
}
}
}catch (CancelledKeyException e){
// ignore
}catch(IOException e){
e.printStackTrace();
}
keys.remove();
}