oupson
/
FooTerm
mirror of https://github.com/oupson/FooTerm.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Extract pty creation

This commit is contained in:
oupson 2023-03-03 18:33:36 +01:00
parent 11a839a989
commit 0a82c0bf60
Signed by: oupson
GPG Key ID: 3BD88615552EFCB7
1 changed files with 40 additions and 42 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

82
src/terminalpane.vala
View File

@ -60,12 +60,44 @@ namespace Footerm {
}); });
} }
~TerminalPane() { private void create_pty() throws GLib.IOError {
// TODO DESTRUCT var master_pty = Posix.posix_openpt(Posix.O_RDWR);
// session.disconnect( "Normal Shutdown, Thank you for playing"); if (master_pty == -1) {
// session = null; throw GLib.IOError.from_errno(Posix.errno);
// Posix.close(sock); }
// stdout.printf("all done!\n");)
var settings = Posix.termios();
Posix.cfmakeraw(ref settings);
if (Posix.tcsetattr(master_pty, Posix.TCSANOW, settings) == -1) {
throw GLib.IOError.from_errno(Posix.errno);
}
if (Posix.grantpt(master_pty) == -1) {
throw GLib.IOError.from_errno(Posix.errno);
}
if (Posix.unlockpt(master_pty) == -1) {
throw GLib.IOError.from_errno(Posix.errno);
}
var pts_name = Posix.ptsname(master_pty);
if (pts_name == null) {
throw GLib.IOError.from_errno(Posix.errno);
}
var slave_pty = Posix.open(pts_name, Posix.O_RDWR);
if (slave_pty < 0) {
throw GLib.IOError.from_errno(Posix.errno);
}
var vte_pty = new Vte.Pty.foreign_sync(master_pty, null);
this.terminal.set_pty(vte_pty);
this.slave_channel = new GLib.IOChannel.unix_new(slave_pty);
slave_channel.set_encoding(null);
slave_channel.set_buffered(false);
} }
private async void connect_to_server() throws GLib.IOError, GLib.Error { private async void connect_to_server() throws GLib.IOError, GLib.Error {
@ -120,49 +152,15 @@ namespace Footerm {
this.socket.close(); this.socket.close();
} }
var master_pty = Posix.posix_openpt(Posix.O_RDWR);
if (master_pty == -1) {
throw GLib.IOError.from_errno(Posix.errno);
}
var settings = Posix.termios();
Posix.cfmakeraw(ref settings);
if (Posix.tcsetattr(master_pty, Posix.TCSANOW, settings) == -1) {
throw GLib.IOError.from_errno(Posix.errno);
}
if (Posix.grantpt(master_pty) == -1) {
throw GLib.IOError.from_errno(Posix.errno);
}
if (Posix.unlockpt(master_pty) == -1) {
throw GLib.IOError.from_errno(Posix.errno);
}
var pts_name = Posix.ptsname(master_pty);
if (pts_name == null) {
throw GLib.IOError.from_errno(Posix.errno);
}
var slave_pty = Posix.open(pts_name, Posix.O_RDWR);
if (slave_pty < 0) {
throw GLib.IOError.from_errno(Posix.errno);
}
var vte_pty = new Vte.Pty.foreign_sync(master_pty, null);
this.terminal.set_pty(vte_pty);
session.blocking = false; session.blocking = false;
this.create_pty();
var inner_socket = socket.get_socket(); var inner_socket = socket.get_socket();
var source = inner_socket.create_source(GLib.IOCondition.IN, null); var source = inner_socket.create_source(GLib.IOCondition.IN, null);
source.set_callback(this.on_ssh_event); source.set_callback(this.on_ssh_event);
source.attach(null); source.attach(null);
this.slave_channel = new GLib.IOChannel.unix_new(slave_pty);
slave_channel.set_encoding(null);
slave_channel.set_buffered(false);
slave_channel.add_watch(GLib.IOCondition.IN, this.on_slave_event); slave_channel.add_watch(GLib.IOCondition.IN, this.on_slave_event);
} }
} }