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

Parse new data that is writtne while parsing is in progress in the parse loop

Browse Source 
Avoids unnecessary memmove()
This commit is contained in:
Kovid Goyal
2023-11-10 15:40:22 +05:30
parent f0afdc51af
commit 1f8feea454
1 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
kitty/vt-parser.c
View File

@@ -1525,10 +1525,9 @@ do_parse_vt(PS *self) {
#define LOG(prefix) \
log_error(#prefix " state: %s pos: %zu consumed: %zu sz: %zu %.*s", vte_state_name(self->vte_state), self->read.pos, self->read.consumed, self->read.sz, (int)MIN(64u, (self->read.sz-self->read.pos)), self->buf + self->read.pos);
self->read.consumed = 0;
self->pending_mode.draining = false;
/* LOG(START); */
while (self->read.pos < self->read.sz) {
do {
if (self->pending_mode.activated_at) {
if (
self->pending_mode.activated_at + self->pending_mode.wait_time < self->now ||
@@ -1542,7 +1541,7 @@ do_parse_vt(PS *self) {
} else continue;
}
consume_input(self);
}
} while (self->read.pos < self->read.sz);
/* LOG(END); */
#undef LOG
}
@@ -1568,15 +1567,17 @@ run_worker(void *p, ParseData *pd, bool flush) {
}
#endif
self->screen = p;
if (self->read.consumed < self->read.sz) {
if (self->read.pos < self->read.sz) {
self->dump_callback = pd->dump_callback; self->now = pd->now;
pd->time_since_new_input = pd->now - self->new_input_at;
if (flush || pd->time_since_new_input >= OPT(input_delay) || (BUF_SZ - self->read.sz) <= 16 * 1024) {
pd->input_read = true;
end_with_lock; {
do_parse_vt(self);
} with_lock;
self->read.sz += self->write.pending; self->write.pending = 0;
do {
end_with_lock; {
do_parse_vt(self);
} with_lock;
self->read.sz += self->write.pending; self->write.pending = 0;
} while (self->read.pos < self->read.sz);
self->new_input_at = pd->now;
pd->pending_activated_at = self->pending_mode.activated_at;
pd->pending_wait_time = self->pending_mode.wait_time;