serverscanning/capnproto-java-rpc
16
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

EzRpcServer expects internet sockets

Browse source
This commit is contained in:
Vaci Koblizek 2020-12-07 19:07:56 +00:00
parent c9dcefb153
commit 59c6913d0d
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
runtime-rpc/src/main/java/org/capnproto/EzRpcServer.java
View file

@ -2,7 +2,6 @@ package org.capnproto;
import java.io.IOException; import java.io.IOException;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.nio.channels.AsynchronousChannelGroup; import java.nio.channels.AsynchronousChannelGroup;
import java.nio.channels.AsynchronousServerSocketChannel; import java.nio.channels.AsynchronousServerSocketChannel;
import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletableFuture;
@ -15,11 +14,11 @@ public class EzRpcServer {
private final TwoPartyServer twoPartyRpc; private final TwoPartyServer twoPartyRpc;
private final int port; private final int port;
public EzRpcServer(Capability.Server bootstrapInterface, SocketAddress address) throws IOException { public EzRpcServer(Capability.Server bootstrapInterface, InetSocketAddress address) throws IOException {
this(new Capability.Client(bootstrapInterface), address); this(new Capability.Client(bootstrapInterface), address);
} }
public EzRpcServer(Capability.Client bootstrapInterface, SocketAddress address) throws IOException { public EzRpcServer(Capability.Client bootstrapInterface, InetSocketAddress address) throws IOException {
this.channelgroup = AsynchronousChannelGroup.withThreadPool(Executors.newFixedThreadPool(1)); this.channelgroup = AsynchronousChannelGroup.withThreadPool(Executors.newFixedThreadPool(1));
this.serverAcceptSocket = AsynchronousServerSocketChannel.open(this.channelgroup); this.serverAcceptSocket = AsynchronousServerSocketChannel.open(this.channelgroup);
this.serverAcceptSocket.bind(address); this.serverAcceptSocket.bind(address);