1 10 package org.jgap.distr.grid; 11 12 import org.homedns.dade.jcgrid.server.*; 13 import org.homedns.dade.jcgrid.*; 14 import org.homedns.dade.jcgrid.vfs.*; 15 import org.homedns.dade.jcgrid.message.*; 16 import org.homedns.dade.jcgrid.util.*; 17 import java.io.*; 18 import java.net.*; 19 20 26 public class JGAPClientHandlerThread 27 extends ClientHandlerThread { 28 29 private final static String CVS_REVISION = "$Revision: 1.1 $"; 30 31 public JGAPClientHandlerThread(GridServer server, Socket socket) 32 throws IOException { 33 super(server, socket); 34 } 35 36 protected void handleMsg(GridMessage msg) 37 throws Exception { 38 if (msg instanceof GridMessageVFSSessionFileRequest) { 39 String n = ( (GridMessageVFSSessionFileRequest) msg).getName(); 40 File f = new File(super.gridServer.getVFSSessionPool().getPath(),n); 43 long fsize = f.length(); 44 if (log.isDebugEnabled()) 45 log.debug(" File size: " + fsize); 46 47 byte[] data = new byte[ (int) fsize]; 48 FileInputStream fis = new FileInputStream(f); 49 fis.read(data); 50 fis.close(); 51 handlerChannel.send(new GridMessageVFSSessionFileResult(data)); 52 } 53 else { 54 super.handleMsg(msg); 55 } 56 } 57 } 58 | Popular Tags |