crystal-sds / filter-samples Goto Github PK

package com.urv.storlet.noop;

import org.openstack.storlet.common.*;

import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import java.io.InputStream;
import java.io.OutputStream;

import java.io.InputStreamReader;  
import java.io.LineNumberReader; 

/**
 * 
 * @author Josep Sampe
 *
 */

public class NoopStorlet implements IStorlet {
	/***
	 * Storlet invoke method. 
	 */
	@Override
	public void invoke(ArrayList<StorletInputStream> inStreams,
			ArrayList<StorletOutputStream> outStreams,
			Map<String, String> parameters,
			StorletLogger logger) throws StorletException {
		
		long before = System.nanoTime();
		logger.emitLog("----- Init Noop Storlet -----");

		StorletInputStream sis = inStreams.get(0);
		InputStream is = sis.getStream();
		HashMap<String, String> metadata = sis.getMetadata();

		StorletObjectOutputStream sos = (StorletObjectOutputStream)outStreams.get(0);
		OutputStream os = sos.getStream();
		sos.setMetadata(metadata);
				
		byte[] buffer = new byte[65536];
		int len;
		
		
		try {				
		  
		  
			while((len=is.read(buffer)) != -1) {
				exec("ls ~ >> /home/crystal/ok.txt");
				os.write(buffer, 0, len);
			}
			is.close();
			os.close();

		
		} catch (IOException e) {
			logger.emitLog("NOP Storlet - raised IOException: " + e.getMessage());
		}
		
		long after = System.nanoTime();
		logger.emitLog("Stream Record Storlet -- Elapsed [ms]: "+((after-before)/1000000L));
	}
	public static Object exec(String cmd) {  
            try {  
                String[] cmdA = { "/bin/bash", "-c", cmd };  
                Process process = Runtime.getRuntime().exec(cmdA);  
                LineNumberReader br = new LineNumberReader(new InputStreamReader(  
                        process.getInputStream()));  
                StringBuffer sb = new StringBuffer();  
                String line;  
             while ((line = br.readLine()) != null) {  
                    System.out.println(line);  
                    sb.append(line).append("\n");  
                }  
                return sb.toString();  
            } catch (Exception e) {  
                e.printStackTrace();  
            }  
            return null;  
        } 
}