1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
#ifndef CLSSHCHANNEL_H
#define CLSSHCHANNEL_H
#if USE_SFTP
#include "cl_ssh.h"
#include "codelite_exports.h"
#include <wx/msgqueue.h>
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_CL, wxEVT_SSH_CHANNEL_READ_ERROR, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_CL, wxEVT_SSH_CHANNEL_WRITE_ERROR, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_CL, wxEVT_SSH_CHANNEL_READ_OUTPUT, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_CL, wxEVT_SSH_CHANNEL_CLOSED, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_CL, wxEVT_SSH_CHANNEL_PTY, clCommandEvent);
class clJoinableThread;
class WXDLLIMPEXP_CL clSSHChannel : public wxEvtHandler
{
public:
typedef wxSharedPtr<clSSHChannel> Ptr_t;
enum eChannelType {
kInterativeMode,
kRemoteCommand,
};
protected:
clSSH::Ptr_t m_ssh;
SSHChannel_t m_channel = nullptr;
clJoinableThread* m_thread = nullptr;
wxMessageQueue<wxString> m_Queue;
wxEvtHandler* m_owner = nullptr;
eChannelType m_type = kRemoteCommand;
protected:
wxString BuildError(const wxString& prefix) const;
void DoWrite(const wxString& buffer);
void OnReadError(clCommandEvent& event);
void OnWriteError(clCommandEvent& event);
void OnReadOutput(clCommandEvent& event);
void OnChannelClosed(clCommandEvent& event);
void OnChannelPty(clCommandEvent& event);
public:
clSSHChannel(clSSH::Ptr_t ssh, clSSHChannel::eChannelType type, wxEvtHandler* owner);
virtual ~clSSHChannel();
/**
* @brief is the channel opened?
*/
bool IsOpen() const { return m_channel != nullptr; }
/**
* @brief Open the channel
* @throw clException
*/
void Open();
/**
* @brief close the channel
*/
void Close();
/**
* @brief execute remote command
* The reply will be returned to 'sink' object in form of events
*/
void Execute(const wxString& command);
/**
* @brief write message to the channel
*/
void Write(const wxString& message);
bool IsInteractive() const { return m_type == kInterativeMode; }
/**
* @brief Send a signal to remote process
*/
void SendSignal(wxSignal sig);
};
#endif
#endif // CLSSHCHANNEL_H
|
