mirrors/kitty
1
0
Fork 0
mirror of https://github.com/kovidgoyal/kitty synced 2026-07-16 21:45:03 +02:00
Code Issues Packages Projects Releases Wiki Activity

New API to suspend a loop

Browse Source
This commit is contained in:
Kovid Goyal
2023-02-14 22:27:41 +05:30
parent 9aaca33f15
commit 67436a48cd
3 changed files with 41 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
tools/tty/tty.go
View File

@@ -209,20 +209,30 @@ func (self *Term) RestoreAndClose() error {
return self.Close()
}
func (self *Term) SuspendAndRun(callback func() error) error {
func (self *Term) Suspend() (resume func() error, err error) {
var state unix.Termios
err := self.Tcgetattr(&state)
err = self.Tcgetattr(&state)
if err != nil {
return err
return nil, err
}
if len(self.states) > 0 {
err := self.Tcsetattr(TCSANOW, &self.states[0])
if err != nil {
return err
return nil, err
}
}
defer self.Tcsetattr(TCSANOW, &state)
return callback()
return func() error { return self.Tcsetattr(TCSANOW, &state) }, nil
}
func (self *Term) SuspendAndRun(callback func() error) error {
resume, err := self.Suspend()
if err != nil {
return err
}
err = callback()
resume()
return err
}
func clamp(v, lo, hi int64) int64 {

3
tools/tui/loop/api.go
View File

@@ -58,7 +58,8 @@ type Loop struct {
pending_writes []*write_msg
on_SIGTSTP func() error
// Send strings to this channel to queue writes in a thread safe way
// Suspend the loop restoring terminal state. Call the return resume function to restore the loop
Suspend func() (func() error, error)
// Callbacks

23
tools/tui/loop/run.go
View File

@@ -290,6 +290,29 @@ func (self *Loop) run() (err error) {
}
}
self.Suspend = func() (func() error, error) {
write_id := self.QueueWriteString(self.terminal_options.ResetStateEscapeCodes())
needs_reset_escape_codes = false
err := self.wait_for_write_to_complete(write_id, tty_write_channel, write_done_channel, 2*time.Second)
if err != nil {
return nil, err
}
resume, err := controlling_term.Suspend()
if err != nil {
return nil, err
}
return func() (err error) {
err = resume()
if err != nil {
return
}
write_id = self.QueueWriteString(self.terminal_options.SetStateEscapeCodes())
needs_reset_escape_codes = true
return self.wait_for_write_to_complete(write_id, tty_write_channel, write_done_channel, 2*time.Second)
}, nil
}
self.on_SIGTSTP = func() error {
write_id := self.QueueWriteString(self.terminal_options.ResetStateEscapeCodes())
needs_reset_escape_codes = false