//Connections_p.java //----------------------- //part of YaCy //(C) by Michael Peter Christen; mc@yacy.net //first published on http://www.anomic.de //Frankfurt, Germany, 2004, 2005 // //$LastChangedDate$ //$LastChangedRevision$ //$LastChangedBy$ // //This program is free software; you can redistribute it and/or modify //it under the terms of the GNU General Public License as published by //the Free Software Foundation; either version 2 of the License, or //(at your option) any later version. // //This program is distributed in the hope that it will be useful, //but WITHOUT ANY WARRANTY; without even the implied warranty of //MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the //GNU General Public License for more details. // //You should have received a copy of the GNU General Public License //along with this program; if not, write to the Free Software //Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA //You must compile this file with //javac -classpath .:../classes Network.java //if the shell's current path is HTROOT import java.io.UnsupportedEncodingException; import java.net.InetAddress; import java.net.URLEncoder; import java.util.Properties; import java.util.Set; import de.anomic.http.client.ConnectionInfo; import de.anomic.http.client.Client; import de.anomic.http.metadata.HeaderFramework; import de.anomic.http.metadata.RequestHeader; import de.anomic.http.server.HTTPDemon; import de.anomic.kelondro.util.DateFormatter; import de.anomic.search.Switchboard; import de.anomic.server.serverCore; import de.anomic.server.serverHandler; import de.anomic.server.serverObjects; import de.anomic.server.serverSwitch; import de.anomic.server.serverThread; import de.anomic.server.serverCore.Session; import de.anomic.yacy.yacySeed; public final class Connections_p { public static serverObjects respond(final RequestHeader header, final serverObjects post, final serverSwitch env) { // return variable that accumulates replacements final Switchboard sb = (Switchboard) env; final serverObjects prop = new serverObjects(); // get the virtualHost string final String virtualHost = sb.getConfig("fileHost", "localhost"); // server sessions // get the serverCore thread final serverThread httpd = sb.getThread("10_httpd"); /* waiting for all threads to finish */ int count = serverCore.sessionThreadGroup.activeCount(); final Thread[] threadList = new Thread[((serverCore) httpd).getJobCount()]; count = serverCore.sessionThreadGroup.enumerate(threadList); // determines if name lookup should be done or not boolean doNameLookup = false; if (post != null) { if (post.containsKey("nameLookup") && post.get("nameLookup","true").equals("true")) { doNameLookup = true; } if (post.containsKey("closeServerSession")) { final String sessionName = post.get("closeServerSession", null); sb.closeSessions("10_httpd", sessionName); prop.put("LOCATION",""); return prop; } } int idx = 0, numActiveRunning = 0, numActivePending = 0; boolean dark = true; for ( int currentThreadIdx = 0; currentThreadIdx < count; currentThreadIdx++ ) { final Thread t = threadList[currentThreadIdx]; if ((t != null) && (t instanceof serverCore.Session) && (t.isAlive())) { // getting the session object final Session s = ((Session) t); // getting the session runtime final long sessionTime = s.getTime(); // getting the request command line boolean blockingRequest = false; String commandLine = s.getCommandLine(); if (commandLine == null) blockingRequest = true; final int commandCount = s.getCommandCount(); // getting the source ip address and port final InetAddress userAddress = s.getUserAddress(); final int userPort = s.getUserPort(); if (userAddress == null) continue; final boolean isSSL = s.isSSL(); String dest = null; String prot = null; final serverHandler cmdObj = s.getCommandObj(); if (cmdObj instanceof HTTPDemon) { prot = isSSL ? "https":"http"; // getting the http command object final HTTPDemon currentHttpd = (HTTPDemon)cmdObj; // getting the connection properties of this session final Properties conProp = (Properties) currentHttpd.getConProp().clone(); // getting the destination host dest = conProp.getProperty(HeaderFramework.CONNECTION_PROP_HOST); if (dest==null)continue; } if ((dest != null) && (dest.equals(virtualHost))) dest = sb.peers.mySeed().getName() + ".yacy"; // determining if the source is a yacy host yacySeed seed = null; if (doNameLookup) { seed = sb.peers.lookupByIP(userAddress,true,false,false); if (seed != null) { if ((seed.hash.equals(sb.peers.mySeed().hash)) && (!seed.get(yacySeed.PORT,"").equals(Integer.toString(userPort)))) { seed = null; } } } prop.put("list_" + idx + "_dark", dark ? "1" : "0"); dark=!dark; try { prop.put("list_" + idx + "_serverSessionID",URLEncoder.encode(s.getName(),"UTF8")); } catch (final UnsupportedEncodingException e) { // TODO Auto-generated catch block e.printStackTrace(); } prop.putHTML("list_" + idx + "_sessionName", s.getName()); prop.put("list_" + idx + "_proto", prot); if (sessionTime > 1000*60) { prop.put("list_" + idx + "_ms", "0"); prop.put("list_" + idx + "_ms_duration",DateFormatter.formatInterval(sessionTime)); } else { prop.put("list_" + idx + "_ms", "1"); prop.putNum("list_" + idx + "_ms_duration", sessionTime); } prop.putHTML("list_" + idx + "_source",(seed!=null)?seed.getName()+".yacy":userAddress.getHostAddress()+":"+userPort); prop.putHTML("list_" + idx + "_dest",(dest==null)?"-":dest); if (blockingRequest) { prop.put("list_" + idx + "_running", "0"); prop.putNum("list_" + idx + "_running_reqNr", commandCount+1); numActivePending++; } else { prop.put("list_" + idx + "_running", "1"); prop.put("list_" + idx + "_running_command", commandLine==null ? "" :commandLine); numActiveRunning++; } prop.putNum("list_" + idx + "_used", commandCount); idx++; } } prop.put("list", idx); prop.putNum("numMax", ((serverCore)httpd).getMaxSessionCount()); prop.putNum("numActiveRunning", numActiveRunning); prop.putNum("numActivePending", numActivePending); // client sessions final Set allConnections = ConnectionInfo.getAllConnections(); // TODO sorting // Arrays.sort(a, httpc.connectionTimeComparatorInstance); int c = 0; synchronized (allConnections) { for (final ConnectionInfo conInfo: allConnections) { prop.put("clientList_" + c + "_clientProtocol", conInfo.getProtocol()); prop.putNum("clientList_" + c + "_clientLifetime", conInfo.getLifetime()); prop.putNum("clientList_" + c + "_clientIdletime", conInfo.getIdletime()); prop.put("clientList_" + c + "_clientTargetHost", conInfo.getTargetHost()); prop.putHTML("clientList_" + c + "_clientCommand", conInfo.getCommand()); prop.put("clientList_" + c + "_clientID", conInfo.getID()); c++; } } prop.put("clientList", c); prop.put("clientActive", Client.connectionCount()); // return rewrite values for templates return prop; } }