KittyPatch/kitty
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Debounce WINSZ events

Browse Source
This commit is contained in:
Kovid Goyal 2022-07-13 14:51:00 +05:30
parent 78542ede14
commit be458303c5
No known key found for this signature in database
GPG Key ID: 06BC317B515ACE7C
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
kitty/prewarm.py
View File

@ -11,6 +11,7 @@ import socket
import struct import struct
import sys import sys
import time import time
import traceback
import warnings import warnings
from contextlib import suppress from contextlib import suppress
from dataclasses import dataclass from dataclasses import dataclass
@ -18,7 +19,7 @@ from importlib import import_module
from itertools import count from itertools import count
from typing import ( from typing import (
IO, TYPE_CHECKING, Any, Callable, Dict, Iterator, List, NoReturn, Optional, IO, TYPE_CHECKING, Any, Callable, Dict, Iterator, List, NoReturn, Optional,
Tuple, Union, cast, TypeVar Tuple, TypeVar, Union, cast
) )
from kitty.constants import kitty_exe, running_in_kitty from kitty.constants import kitty_exe, running_in_kitty
@ -486,10 +487,15 @@ def fork_socket_child_supervisor(conn: socket.socket, free_non_child_resources:
return return
from_socket_buf += msg from_socket_buf += msg
data = memoryview(from_socket_buf) data = memoryview(from_socket_buf)
record = memoryview(b'')
while len(data) >= winsize: while len(data) >= winsize:
record, data = data[:winsize], data[winsize:] record, data = data[:winsize], data[winsize:]
with suppress(OSError), open(os.open(os.ctermid(), os.O_RDWR | os.O_CLOEXEC | os.O_NOCTTY, 0), 'rb') as f: if record:
eintr_retry(fcntl.ioctl, f.fileno(), termios.TIOCSWINSZ, record) try:
with open(os.open(os.ctermid(), os.O_RDWR | os.O_CLOEXEC), 'w') as f:
eintr_retry(fcntl.ioctl, f.fileno(), termios.TIOCSWINSZ, record)
except OSError:
traceback.print_exc()
from_socket_buf = bytes(data) from_socket_buf = bytes(data)
def read_launch_msg() -> bool: def read_launch_msg() -> bool:
@ -769,7 +775,6 @@ def main(stdin_fd: int, stdout_fd: int, notify_child_death_fd: int, unix_socket:
raise raise
except Exception: except Exception:
if is_zygote: if is_zygote:
import traceback
traceback.print_exc() traceback.print_exc()
raise raise
finally: finally: