API: nvim__stats()

Use it to verify fsync() behavior.
This commit is contained in:
Justin M. Keyes
2018-04-24 00:27:09 +02:00
parent 32f3937477
commit 77cb14cc6d
4 changed files with 31 additions and 7 deletions

View File

@@ -1473,6 +1473,17 @@ Float nvim__id_float(Float flt)
return flt; return flt;
} }
/// Gets internal stats.
///
/// @return Map of various internal stats.
Dictionary nvim__stats(void)
{
Dictionary rv = ARRAY_DICT_INIT;
PUT(rv, "fsync", INTEGER_OBJ(g_stats.fsync));
PUT(rv, "redraw", INTEGER_OBJ(g_stats.redraw));
return rv;
}
/// Gets a list of dictionaries representing attached UIs. /// Gets a list of dictionaries representing attached UIs.
/// ///
/// @return Array of UI dictionaries /// @return Array of UI dictionaries

View File

@@ -80,6 +80,11 @@ typedef enum {
kTrue = 1, kTrue = 1,
} TriState; } TriState;
EXTERN struct nvim_stats_s {
int64_t fsync;
int64_t redraw;
} g_stats INIT(= { 0, 0 });
/* Values for "starting" */ /* Values for "starting" */
#define NO_SCREEN 2 /* no screen updating yet */ #define NO_SCREEN 2 /* no screen updating yet */
#define NO_BUFFERS 1 /* not all buffers loaded yet */ #define NO_BUFFERS 1 /* not all buffers loaded yet */

View File

@@ -629,6 +629,7 @@ int os_fsync(int fd)
{ {
int r; int r;
RUN_UV_FS_FUNC(r, uv_fs_fsync, fd, NULL); RUN_UV_FS_FUNC(r, uv_fs_fsync, fd, NULL);
g_stats.fsync++;
return r; return r;
} }

View File

@@ -3,10 +3,11 @@ local helpers = require('test.functional.helpers')(after_each)
local clear = helpers.clear local clear = helpers.clear
local command = helpers.command local command = helpers.command
local eq = helpers.eq local eq = helpers.eq
local eval = helpers.eval
local feed = helpers.feed local feed = helpers.feed
local funcs = helpers.funcs local funcs = helpers.funcs
local nvim_prog = helpers.nvim_prog local nvim_prog = helpers.nvim_prog
local request = helpers.request
local retry = helpers.retry
local rmdir = helpers.rmdir local rmdir = helpers.rmdir
local sleep = helpers.sleep local sleep = helpers.sleep
@@ -22,20 +23,24 @@ describe('fileio', function()
end) end)
it('fsync() codepaths #8304', function() it('fsync() codepaths #8304', function()
-- This is an "acceptance test" or "smoke test".
clear({ args={ '-i', 'Xtest_startup_shada', clear({ args={ '-i', 'Xtest_startup_shada',
'--cmd', 'set directory=Xtest_startup_swapdir' } }) '--cmd', 'set directory=Xtest_startup_swapdir' } })
-- These cases ALWAYS force fsync (regardless of 'fsync' option): -- These cases ALWAYS force fsync (regardless of 'fsync' option):
-- 1. Idle (CursorHold) with modified buffers (+ 'swapfile'). -- 1. Idle (CursorHold) with modified buffers (+ 'swapfile').
command('set swapfile')
command('set updatetime=1')
command('write Xtest_startup_file1') command('write Xtest_startup_file1')
feed('ifoo<esc>h') feed('ifoo<esc>h')
sleep(2) command('write')
eq(1, eval('&modified')) eq(0, request('nvim__stats').fsync) -- 'nofsync' is the default.
command('set swapfile')
command('set updatetime=1')
feed('izub<esc>h') -- File is 'modified'.
sleep(3) -- Allow 'updatetime' to expire.
retry(3, nil, function()
eq(1, request('nvim__stats').fsync)
end)
command('set updatetime=9999')
-- 2. Exit caused by deadly signal (+ 'swapfile'). -- 2. Exit caused by deadly signal (+ 'swapfile').
local j = funcs.jobstart({ nvim_prog, '-u', 'NONE', '-i', local j = funcs.jobstart({ nvim_prog, '-u', 'NONE', '-i',
@@ -51,11 +56,13 @@ describe('fileio', function()
-- 4. Explicit :preserve command. -- 4. Explicit :preserve command.
command('preserve') command('preserve')
eq(2, request('nvim__stats').fsync)
-- 5. Enable 'fsync' option, write file. -- 5. Enable 'fsync' option, write file.
command('set fsync') command('set fsync')
feed('ibaz<esc>h') feed('ibaz<esc>h')
command('write') command('write')
eq(4, request('nvim__stats').fsync)
end) end)
end) end)