set autoreload timeout based on the latest event (#459)

currently the autoreload feature of nsxiv is a bit unreliable because we
try to load at the very first event we received. however, the writer
might not be done writing and so we might try to load a truncated image
(and fail).

in the following ascii diagram, function S represents sleep and `+` sign
represents writes by the writer. because we set the sleep (of 10ms) at
the first event, subsequent writes by the writer doesn't influence our
reload logic:

       S(10)                   load()
nsxiv        |                       |
writer       +           +           +           + (done)
time(ms):   00          05          10          15

after this patch, (assuming function T (re)sets a timeout), we will keep
(re)setting a timeout on new events giving the writer more time to
finish:

       T(10)       T(10)       T(10)       T(10)                   load()
nsxiv        |           |           |           |                       |
writer       +           +           +           + (done)
time(ms):   00          05          10          15          20          25

while this patch makes things significantly more robust, the problem
here is inherently unsolvable since there's no way to tell whether the
writer is done writing or not.

for example, if user does something like `curl 'some.png' > test.png`
then curl might stop for a second or two in the middle of writing due to
internet issues - which will make nsxiv drop the image.

this patch also increases the autoreload delay from 10ms to now 128ms
instead to decrease chances of false failures.

ref: 6ae2df6ed5
partially-fixes: https://codeberg.org/nsxiv/nsxiv/issues/456
commit-message-by: NRK
Reviewed-on: https://codeberg.org/nsxiv/nsxiv/pulls/459
Reviewed-by: eylles <eylles@noreply.codeberg.org>
This commit is contained in:
David Gowers 2023-08-28 10:28:57 +00:00 committed by NRK
parent cc132dd365
commit 10a6228538
3 changed files with 26 additions and 10 deletions

View file

@ -87,6 +87,7 @@ void img_init(img_t *img, win_t *win)
img->dirty = false; img->dirty = false;
img->anti_alias = options->anti_alias; img->anti_alias = options->anti_alias;
img->alpha_layer = options->alpha_layer; img->alpha_layer = options->alpha_layer;
img->autoreload_pending = false;
img->multi.cap = img->multi.cnt = 0; img->multi.cap = img->multi.cnt = 0;
img->multi.animate = options->animate; img->multi.animate = options->animate;
img->multi.framedelay = options->framerate > 0 ? 1000 / options->framerate : 0; img->multi.framedelay = options->framerate > 0 ? 1000 / options->framerate : 0;

33
main.c
View file

@ -22,6 +22,7 @@
#include "commands.h" #include "commands.h"
#include "config.h" #include "config.h"
#include <assert.h>
#include <errno.h> #include <errno.h>
#include <fcntl.h> #include <fcntl.h>
#include <locale.h> #include <locale.h>
@ -72,6 +73,8 @@ int prefix;
bool title_dirty; bool title_dirty;
const XButtonEvent *xbutton_ev; const XButtonEvent *xbutton_ev;
static void autoreload(void);
static bool extprefix; static bool extprefix;
static bool resized = false; static bool resized = false;
@ -91,6 +94,7 @@ static struct {
struct timeval when; struct timeval when;
bool active; bool active;
} timeouts[] = { } timeouts[] = {
{ autoreload },
{ redraw }, { redraw },
{ reset_cursor }, { reset_cursor },
{ slideshow }, { slideshow },
@ -269,6 +273,18 @@ static bool check_timeouts(int *t)
return tmin > 0; return tmin > 0;
} }
static void autoreload(void)
{
if (img.autoreload_pending) {
img_close(&img, true);
/* load_image() sets autoreload_pending to false */
load_image(fileidx);
redraw();
} else {
assert(!"unreachable");
}
}
static void kill_close(pid_t pid, int *fd) static void kill_close(pid_t pid, int *fd)
{ {
if (fd != NULL && *fd != -1) { if (fd != NULL && *fd != -1) {
@ -367,10 +383,13 @@ void load_image(int new)
if (win.xwin != None) if (win.xwin != None)
win_set_cursor(&win, CURSOR_WATCH); win_set_cursor(&win, CURSOR_WATCH);
reset_timeout(autoreload);
reset_timeout(slideshow); reset_timeout(slideshow);
if (new != current) if (new != current) {
alternate = current; alternate = current;
img.autoreload_pending = false;
}
img_close(&img, false); img_close(&img, false);
while (!img_load(&img, &files[new])) { while (!img_load(&img, &files[new])) {
@ -735,7 +754,6 @@ static void run(void)
enum { FD_X, FD_INFO, FD_TITLE, FD_ARL, FD_CNT }; enum { FD_X, FD_INFO, FD_TITLE, FD_ARL, FD_CNT };
struct pollfd pfd[FD_CNT]; struct pollfd pfd[FD_CNT];
int timeout = 0; int timeout = 0;
const struct timespec ten_ms = { 0, 10000000 };
bool discard, init_thumb, load_thumb, to_set; bool discard, init_thumb, load_thumb, to_set;
XEvent ev, nextev; XEvent ev, nextev;
@ -775,14 +793,9 @@ static void run(void)
read_info(); read_info();
if (pfd[FD_TITLE].revents & POLLIN) if (pfd[FD_TITLE].revents & POLLIN)
read_title(); read_title();
if (pfd[FD_ARL].revents & POLLIN) { if ((pfd[FD_ARL].revents & POLLIN) && arl_handle(&arl)) {
if (arl_handle(&arl)) { img.autoreload_pending = true;
/* when too fast, imlib2 can't load the image */ set_timeout(autoreload, TO_AUTORELOAD, true);
nanosleep(&ten_ms, NULL);
img_close(&img, true);
load_image(fileidx);
redraw();
}
} }
} }
continue; continue;

View file

@ -107,6 +107,7 @@ typedef struct {
/* timeouts in milliseconds: */ /* timeouts in milliseconds: */
enum { enum {
TO_AUTORELOAD = 128,
TO_REDRAW_RESIZE = 75, TO_REDRAW_RESIZE = 75,
TO_REDRAW_THUMBS = 200, TO_REDRAW_THUMBS = 200,
TO_CURSOR_HIDE = 1200, TO_CURSOR_HIDE = 1200,
@ -204,6 +205,7 @@ struct img {
bool dirty; bool dirty;
bool anti_alias; bool anti_alias;
bool alpha_layer; bool alpha_layer;
bool autoreload_pending;
struct { struct {
bool on; bool on;