Package net.schmizz.sshj.connection

Examples of net.schmizz.sshj.connection.ConnectionException

111
112
113
114
115
116
117
            throws SSHException {
        if (closed)
            if (error != null)
                throw error;
            else
                throw new ConnectionException("Stream closed");
    }
View Full Code Here
169
170
171
172
173
174
175
176
177
178
179
        SSHPacket reply = req(PF_REQ, forward);
        if (forward.port == 0)
            try {
                forward.port = reply.readUInt32AsInt();
            } catch (Buffer.BufferException e) {
                throw new ConnectionException(e);
            }
        log.info("Remote end listening on {}", forward);
        listeners.put(forward, listener);
        return forward;
    }
View Full Code Here
219
220
221
222
223
224
225
226
227
228
229
        try {
            chan = new ForwardedTCPIPChannel(conn, buf.readUInt32AsInt(), buf.readUInt32AsInt(), buf.readUInt32AsInt(),
                                             new Forward(buf.readString(), buf.readUInt32AsInt()),
                                             buf.readString(), buf.readUInt32AsInt());
        } catch (Buffer.BufferException be) {
            throw new ConnectionException(be);
        }
        if (listeners.containsKey(chan.getParentForward()))
            callListener(listeners.get(chan.getParentForward()), chan);
        else
            chan.reject(OpenFailException.Reason.ADMINISTRATIVELY_PROHIBITED, "Forwarding was not requested on `"
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
    }

    public void receive(byte[] data, int offset, int len)
            throws ConnectionException, TransportException {
        if (eof)
            throw new ConnectionException("Getting data on EOF'ed stream");
        synchronized (buf) {
            buf.putRawBytes(data, offset, len);
            buf.notifyAll();
        }
        win.consume(len);
View Full Code Here
60
61
62
63
64
65
66
67
            callListener(listener, new X11Channel(conn,
                                                  buf.readUInt32AsInt(),
                                                  buf.readUInt32AsInt(), buf.readUInt32AsInt(),
                                                  buf.readString(), buf.readUInt32AsInt()));
        } catch (Buffer.BufferException be) {
            throw new ConnectionException(be);
        }
    }
View Full Code Here
55
56
57
58
59
60
61
62
            throws ConnectionException {
        synchronized (lock) {
            log.debug("Consuming by " + dec + " down to " + size);
            size -= dec;
            if (size < 0)
                throw new ConnectionException("Window consumed to below 0");
        }
    }
View Full Code Here
71
72
73
74
75
76
77
78
79
    private void gotOpenConfirmation(SSHPacket buf)
            throws ConnectionException {
        try {
            init(buf.readUInt32AsInt(), buf.readUInt32AsInt(), buf.readUInt32AsInt());
        } catch (Buffer.BufferException be) {
            throw new ConnectionException(be);
        }
        open.set();
    }
View Full Code Here
81
82
83
84
85
86
87
88
89
    private void gotOpenFailure(SSHPacket buf)
            throws ConnectionException {
        try {
            open.deliverError(new OpenFailException(getType(), buf.readUInt32AsInt(), buf.readString()));
        } catch (Buffer.BufferException be) {
            throw new ConnectionException(be);
        }
        finishOff();
    }
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
                while (size < howMuch) {
                    log.debug("Waiting, need window space for {} bytes", howMuch);
                    try {
                        lock.wait();
                    } catch (InterruptedException ie) {
                        throw new ConnectionException(ie);
                    }
                }
                consume(howMuch);
            }
        }
View Full Code Here
159
160
161
162
163
164
165
166
                exitErrMsg = buf.readString();
                sendClose();
            } else
                super.handleRequest(req, buf);
        } catch (Buffer.BufferException be) {
            throw new ConnectionException(be);
        }
    }
View Full Code Here
TOP

Related Classes of net.schmizz.sshj.connection.ConnectionException

  • net.schmizz.sshj.connection.channel.AbstractChannel
  • net.schmizz.sshj.connection.channel.ChannelInputStream
  • net.schmizz.sshj.connection.channel.ChannelOutputStream
  • net.schmizz.sshj.connection.channel.direct.AbstractDirectChannel
  • net.schmizz.sshj.connection.channel.direct.SessionChannel
  • net.schmizz.sshj.connection.channel.forwarded.RemotePortForwarder
  • net.schmizz.sshj.connection.channel.forwarded.X11Forwarder
  • net.schmizz.sshj.connection.channel.Window
  • net.schmizz.sshj.connection.channel.Window$Remote
  • org.jclouds.sshj.SshjSshClientTest
    • Copyright © 2018 www.massapicom. 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.