Package com.jcraft.jsch

Examples of com.jcraft.jsch.ChannelExec.connect()

214
215
216
217
218
219
220
221
222
223
224
                channel.setCommand(location.getInstallPath()
                    + "/bin/hadoop version");
                BufferedReader response =
                    new BufferedReader(new InputStreamReader(channel
                        .getInputStream()));
                channel.connect();
                final String versionLine = response.readLine();

                if ((versionLine != null)
                    && versionLine.startsWith("Hadoop")) {
                  Display.getDefault().syncExec(new Runnable() {
View Full Code Here
204
205
206
207
208
209
210
211
212
213
214
            /* execute the command */
            channel = (ChannelExec) session.openChannel("exec");
            channel.setCommand(cmd);
            channel.setOutputStream(tee);
            channel.setExtOutputStream(tee);
            channel.connect();
            // wait for it to finish
            thread =
                new Thread() {
                    public void run() {
                        while (!channel.isClosed()) {
View Full Code Here
217
218
219
220
221
222
223
224
225
226
227
  public Process ssh(String cmd) throws JSchException, IOException {
    ChannelExec channel = (ChannelExec) session.openChannel("exec");
    channel.setCommand(cmd);
    channel.setPty(true);
    channel.connect();
    return new SSHProcess(channel);
  }
}

/**
 
View Full Code Here
300
301
302
303
304
305
306
307
308
309
310
            channel.setCommand( command + "\n" );

            InputStream stdout = channel.getInputStream();
            InputStream stderr = channel.getErrStream();

            channel.connect();

            stdoutReader = new BufferedReader( new InputStreamReader( stdout ) );
            stderrReader = new BufferedReader( new InputStreamReader( stderr ) );

            Streams streams = CommandExecutorStreamProcessor.processStreams( stderrReader, stdoutReader );
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
            Session session = openSession();
            session.setTimeout((int) maxwait);
            final ChannelExec channel = (ChannelExec) session.openChannel("exec");
            channel.setCommand(command);
            channel.setOutputStream(tee);
            channel.connect();

            // wait for it to finish
            thread =
                new Thread() {
                    public void run() {
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
                channel = setUpChannel(sshSession, cmd);
                fos = new FileOutputStream(scpFile.getLocalFile());
                in = channel.getInputStream();
                out = channel.getOutputStream();

                channel.connect();

                sendAck(out);

                fileSize = getFileSizeFromStream(in);
                skipFileName(in);
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
        try {
            try {
                channel = this.setUpChannel(sshSession, command);
                in = channel.getInputStream();
                channel.connect();

                streamOutput(channel, in);
            } finally {
                if (in != null)
                    in.close();
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
                channel = this.setUpChannel(sshSession, cmd);
                fis = new FileInputStream(scpFile.getLocalFile());
                in = channel.getInputStream();
                out = channel.getOutputStream();

                channel.connect();

                if (checkAck(in) != 0) {
                    throw new SshException("Acknowledgement check failed: Initializing "
                            + "session returned a status code other than 0");
                }
View Full Code Here
599
600
601
602
603
604
605
606
607
608
609
            channel.setCommand(command);

            is = channel.getInputStream();
            es = channel.getErrStream();

            channel.connect(CONNECTION_TIMEOUT); // connect and execute command

            String out = read(is, channel);
            String err = read(es, channel);

            if (log.isTraceEnabled()) {
View Full Code Here
192
193
194
195
196
197
198
199
200
201
202
   */
  private ChannelExec getSCPChannel (String command) {
    try {
      ChannelExec exec = (ChannelExec) this.session.openChannel("exec");
      exec.setCommand(command);
      exec.connect(timeout);
      return exec;
    } catch (JSchException e) {
      throw ThrowableManagerRegistry.caught(e);
    }
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.