Repackage to org.cristalise

1 files changed, 208 insertions, 0 deletions

diff --git a/src/main/java/org/cristalise/kernel/entity/proxy/ProxyClientConnection.java b/src/main/java/org/cristalise/kernel/entity/proxy/ProxyClientConnection.java
new file mode 100644
index 0000000..9f65afa
--- /dev/null
+++ b/src/main/java/org/cristalise/kernel/entity/proxy/ProxyClientConnection.java
@@ -0,0 +1,208 @@
+/**

+ * This file is part of the CRISTAL-iSE kernel.

+ * Copyright (c) 2001-2014 The CRISTAL Consortium. All rights reserved.

+ *

+ * This library is free software; you can redistribute it and/or modify it

+ * under the terms of the GNU Lesser General Public License as published

+ * by the Free Software Foundation; either version 3 of the License, or (at

+ * your option) any later version.

+ *

+ * This library is distributed in the hope that it will be useful, but WITHOUT

+ * ANY WARRANTY; with out even the implied warranty of MERCHANTABILITY or

+ * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public

+ * License for more details.

+ *

+ * You should have received a copy of the GNU Lesser General Public License

+ * along with this library; if not, write to the Free Software Foundation,

+ * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.

+ *

+ * http://www.fsf.org/licensing/licenses/lgpl.html

+ */

+package org.cristalise.kernel.entity.proxy;

+

+import java.io.BufferedReader;

+import java.io.IOException;

+import java.io.InputStreamReader;

+import java.io.InterruptedIOException;

+import java.io.PrintWriter;

+import java.net.Socket;

+import java.net.SocketException;

+import java.util.ArrayList;

+import java.util.Iterator;

+

+import org.cristalise.kernel.common.InvalidDataException;

+import org.cristalise.kernel.lookup.ItemPath;

+import org.cristalise.kernel.process.Gateway;

+import org.cristalise.kernel.utils.Logger;

+import org.cristalise.kernel.utils.server.SocketHandler;

+

+

+/**************************************************************************

+ *

+ * $Revision: 1.18 $

+ * $Date: 2005/05/10 11:40:09 $

+ *

+ * Copyright (C) 2003 CERN - European Organization for Nuclear Research

+ * All rights reserved.

+ **************************************************************************/

+

+public class ProxyClientConnection implements SocketHandler {

+

+	Socket clientSocket = null;

+    static int clientId = -1;

+    int thisClientId;

+    ArrayList<ItemPath> subscribedItems;

+    PrintWriter response;

+    BufferedReader request;

+    boolean closing = false;

+

+    public ProxyClientConnection() {

+        super();

+        thisClientId = ++clientId;

+        Gateway.getProxyServer().registerProxyClient(this);

+        Logger.msg(1, "Proxy Client Connection Handler "+thisClientId+" ready.");

+    }

+

+

+    @Override

+	public String getName() {

+        return "Proxy Client Connection";

+    }

+

+    @Override

+	public boolean isBusy() {

+        return clientSocket != null;

+    }

+

+    @Override

+	public synchronized void setSocket(Socket newSocket) {

+        try {

+            Logger.msg(1, "Proxy Client Connection "+thisClientId+" connect from "+newSocket.getInetAddress()+":"+newSocket.getPort());

+            newSocket.setSoTimeout(500);

+            clientSocket = newSocket;

+            response = new PrintWriter(clientSocket.getOutputStream(), true);

+            subscribedItems = new ArrayList<ItemPath>();

+        } catch (SocketException ex) {

+            Logger.msg("Could not set socket timeout:");

+            Logger.error(ex);

+            closeSocket();

+        } catch (IOException ex) {

+            Logger.msg("Could not setup output stream:");

+            Logger.error(ex);

+            closeSocket();

+        }

+    }

+

+    /**

+     * Main loop. Reads proxy commands from the client and acts on them.

+     */

+    @Override

+	public void run() {

+        Thread.currentThread().setName("Proxy Client Connection: "+clientSocket.getInetAddress());

+        Logger.msg(7, "ProxyClientConnection "+thisClientId+" - Setting up proxy client connection with "+clientSocket.getInetAddress());

+        try {

+            request = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));

+            String input = null;

+            ProxyMessage thisMessage;

+            while (clientSocket != null) {

+                try {

+                    input = request.readLine();

+                    Logger.msg(9, "ProxyClientConnection "+thisClientId+" - received "+input);

+                    thisMessage = new ProxyMessage(input);

+                    processMessage(thisMessage);

+                } catch (InterruptedIOException ex) { //timeout

+                } catch (InvalidDataException ex) { // invalid proxy message

+                    Logger.error("ProxyClientConnection "+thisClientId+" - Invalid proxy message: "+input);

+                }

+

+            }

+        } catch (IOException ex) {

+            if (!closing)

+                Logger.error("ProxyClientConnection "+thisClientId+" - Error reading from socket.");

+        }

+        closeSocket();

+        Logger.msg(1, "ProxyClientConnection "+thisClientId+" closed.");

+    }

+

+    private void processMessage(ProxyMessage message) throws InvalidDataException {

+

+        // proxy disconnection

+        if (message.getPath().equals(ProxyMessage.BYEPATH)) {

+            Logger.msg(7, "ProxyClientConnection "+thisClientId+" disconnecting");

+            closeSocket();

+        }

+

+        // proxy checking connection

+        else if (message.getPath().equals(ProxyMessage.PINGPATH))

+        response.println(ProxyMessage.pingMessage);

+

+        // new subscription to entity changes

+        else if (message.getPath().equals(ProxyMessage.ADDPATH)) {

+            Logger.msg(7, "ProxyClientConnection "+thisClientId+" subscribed to "+message.getItemPath());

+            synchronized (subscribedItems) {

+            	subscribedItems.add(message.getItemPath());

+            }

+        }

+

+        // remove of subscription to entity changes

+        else if (message.getPath().equals(ProxyMessage.DELPATH)) {

+            synchronized (subscribedItems) {

+            	subscribedItems.remove(message.getItemPath());

+            }

+            Logger.msg(7, "ProxyClientConnection "+thisClientId+" unsubscribed from "+message.getItemPath());

+        }

+

+        else // unknown message

+            Logger.error("ProxyClientConnection "+thisClientId+" - Unknown message type: "+message);

+

+    }

+

+    public synchronized void sendMessage(ProxyMessage message) {

+        if (clientSocket==null) return; // idle

+        boolean relevant = message.getItemPath() == null;

+        synchronized (subscribedItems) {

+            for (Iterator<ItemPath> iter = subscribedItems.iterator(); iter.hasNext() && !relevant;) {

+                ItemPath thisKey = iter.next();

+                if (thisKey.equals(message.getItemPath()))

+                    relevant = true;

+            }

+        }

+        if (!relevant) return; // not for our client

+

+        response.println(message);

+    }

+

+    @Override

+	public void shutdown() {

+        if (isBusy()) {

+            closing = true;

+            Logger.msg("ProxyClientConnection "+thisClientId+" closing.");

+            closeSocket();

+        }

+    }

+

+    @Override

+	public String toString() {

+        if (clientSocket == null) return thisClientId+": idle";

+        else return thisClientId+": "+clientSocket.getInetAddress();

+    }

+

+    private synchronized void closeSocket() {

+        if (clientSocket==null) return;

+        try {

+            request.close();

+            response.close();

+            clientSocket.close();

+        } catch (IOException e) {

+            Logger.error("ProxyClientConnection "+thisClientId+" - Could not close socket.");

+            Logger.error(e);

+        }

+        synchronized (subscribedItems) {

+        	subscribedItems = null;

+        }

+

+        clientSocket = null;

+

+    }

+

+}