Centre Blaise Pascal » gZFS

package gZFS;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.PipedInputStream;

import java.io.PipedOutputStream;

import java.io.PrintStream;

import java.util.ArrayList;

import java.util.Properties;

import com.jcraft.jsch.Channel;

import com.jcraft.jsch.ChannelExec;

import com.jcraft.jsch.JSch;

import com.jcraft.jsch.JSchException;

import com.jcraft.jsch.Session;

public class libConnect {

        private String userLogin;

        private String userPassword;

        private String sshHost;

        private int sshPort;

        private Session session;

        private JSch jsch = new JSch();

        public String connect(String cmd) {

                String outCmd = null ;

                try {

                        setSession(jsch.getSession(getUserLogin(), getSshHost(), getSshPort()));

                        session.setPassword(this.getUserPassword());

                        Properties config = new Properties();

                        config.put("StrictHostKeyChecking", "no");

                        session.setConfig(config);

                        session.connect();

                        if ( session.isConnected()){

                                System.out.println("Connected");

                        }else{

                                System.out.println("not Connected");

                        }

                        ChannelExec channel = (ChannelExec) session.openChannel("exec");

                        //((ChannelExec) channel).setCommand("ls");

                        ((ChannelExec) channel).setCommand(cmd);

                        InputStream in = channel.getInputStream();

                        OutputStream out = channel.getOutputStream();

                        ((ChannelExec) channel).setErrStream(System.err);

                        channel.connect();

                        byte[] tmp = new byte[1024];

                        while (true) {

                                int ind = 0;

                                while (in.available() > 0) {

                                        int i = in.read(tmp, 0, 1024);

                                        if (i < 0)

                                                break;

                                        outCmd= new String(tmp, 0, i);

                                        //System.out.println(toto);

                                        System.out.println(outCmd);

                                        //System.out.print(new String(tmp, 0, i));

                                }

                                if (channel.isClosed()) {

                                        break;

                                }

                                try {

                                        Thread.sleep(1000);

                                } catch (Exception ee) {

                                        System.out.println(ee);

                                }

                        }

                        channel.disconnect();

                } catch (JSchException e) {

                        // TODO Auto-generated catch block

                        e.printStackTrace();

                        return null;

                } catch (IOException e) {

                        // TODO Auto-generated catch block

                        e.printStackTrace();

                        return null;

                }

                /*for (int cpt=0;cpt < outCmd.length;cpt++ ) {

                        System.out.println(outCmd[cpt]);

                }*/

                System.out.println(outCmd);

                return outCmd;

        }

  public String zfsGetAllVolume(String volume){

         return connect("zfs list");

//          return this.executeCmd("/sbin/zfs get all "+volume);

  }

        public String getSshHost() {

                return sshHost;

        }

        public void setSshHost(String sshHost) {

                this.sshHost = sshHost;

        }

        public String getUserLogin() {

                return userLogin;

        }

        public void setUserLogin(String userLogin) {

                this.userLogin = userLogin;

        }

        public int getSshPort() {

                return sshPort;

        }

        public void setSshPort(int sshPort) {

                this.sshPort = sshPort;

        }

        public Session getSession() {

                return session;

        }

        public void setSession(Session session) {

                this.session = session;

        }

        public String getUserPassword() {

                return userPassword;

        }

        public void setUserPassword(String userPassword) {

                this.userPassword = userPassword;

        }

}