package org.openslx.dnbd3; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; import java.util.ArrayList; import java.util.List; import org.jdom2.Document; import org.jdom2.Element; import org.jdom2.JDOMException; import org.jdom2.filter.Filters; import org.jdom2.input.SAXBuilder; import org.jdom2.xpath.XPathExpression; import org.jdom2.xpath.XPathFactory; public class DNBD3Server { private static final int CMDSTOP = 0; private static final int CMDRELOAD = 1; private static final int CMDINFO = 2; private static final String HOST = "127.0.0.1"; private static final int PORT = 5004; public void doReload() throws IOException { Socket sock = new Socket(HOST, PORT); sendCommand(sock, CMDRELOAD); sock.close(); } public void doShutdown() throws IOException { Socket sock = new Socket(HOST, PORT); sendCommand(sock, CMDSTOP); sock.close(); } public List getImages() throws IOException { List images = new ArrayList(); Socket sock = new Socket(HOST, PORT); sendCommand(sock, CMDINFO); try { String atime, vid, rid, file; InputStream is = sock.getInputStream(); SAXBuilder builder = new SAXBuilder(); Document document = (Document) builder.build(is); XPathFactory xpfac = XPathFactory.instance(); XPathExpression xp; xp = xpfac.compile("//dnbd3-server/images/image", Filters.element()); for (Element e : xp.evaluate(document)) { atime = e.getAttributeValue("atime"); vid = e.getAttributeValue("vid"); rid = e.getAttributeValue("rid"); file = e.getAttributeValue("file"); images.add(new DNBD3Image(atime, vid, rid, file)); } } catch (JDOMException ex) { ex.printStackTrace(); } sock.close(); return images; } public List getClients() throws IOException { List clients = new ArrayList(); Socket sock = new Socket(HOST, PORT); sendCommand(sock, CMDINFO); try { String ip, image; InputStream is = sock.getInputStream(); SAXBuilder builder = new SAXBuilder(); Document document = (Document) builder.build(is); XPathFactory xpfac = XPathFactory.instance(); XPathExpression xp; xp = xpfac.compile("//dnbd3-server/clients/client", Filters.element()); for (Element e : xp.evaluate(document)) { ip = e.getAttributeValue("ip"); image = e.getAttributeValue("file"); clients.add(new DNBD3Client(ip, image)); } } catch (JDOMException ex) { ex.printStackTrace(); } sock.close(); return clients; } //////////////////////////////////////////////////////////////////////////////// private void sendCommand(Socket sock, int cmd) throws IOException { OutputStream os = sock.getOutputStream(); DataOutputStream dos = new DataOutputStream(os); dos.writeInt(cmd); } }