Mercurial Hosting > luan
view src/luan/lib/rpc/RpcServer.java @ 1120:e8fc6712b468
luan Rpc uses luan.lib.rpc
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Mon, 07 Aug 2017 23:50:52 -0600 |
parents | 87c674f3f6b7 |
children |
line wrap: on
line source
package luan.lib.rpc; import java.io.EOFException; import java.net.Socket; import java.util.List; import java.util.ArrayList; public class RpcServer extends RpcCon { public RpcServer(Socket socket) throws RpcError { super(socket); } public RpcCall read() throws RpcError { try { List list = readJson(); String cmd = (String)list.remove(0); Object[] args = list.toArray(); return new RpcCall(inBinary,lenBinary,cmd,args); } catch(RpcError e) { if( !readSome && e.getCause() instanceof EOFException ) return null; throw e; } } public void write(RpcResult result) throws RpcError { List list = new ArrayList(); list.add(true); for( Object val : result.returnValues ) { list.add(val); } write(result.in,result.lenIn,list); } public void write(RpcException ex) throws RpcError { List list = new ArrayList(); list.add(false); list.add(ex.getMessage()); for( Object val : ex.values ) { list.add(val); } write(ex.in,ex.lenIn,list); } }