mirror of
https://github.com/neovim/neovim.git
synced 2026-01-07 03:48:02 +10:00
file: Move src/nvim/file.* to src/nvim/os/fileio.*
This commit is contained in:
ZyX
361
test/unit/os/fileio_spec.lua
Normal file
361
test/unit/os/fileio_spec.lua
Normal file
@@ -0,0 +1,361 @@
|
||||
local lfs = require('lfs')
|
||||
|
||||
local helpers = require('test.unit.helpers')
|
||||
|
||||
local eq = helpers.eq
|
||||
local ok = helpers.ok
|
||||
local ffi = helpers.ffi
|
||||
local cimport = helpers.cimport
|
||||
|
||||
local m = cimport('./src/nvim/os/fileio.h')
|
||||
|
||||
local s = ''
|
||||
for i = 0, 255 do
|
||||
s = s .. (i == 0 and '\0' or ('%c'):format(i))
|
||||
end
|
||||
local fcontents = s:rep(16)
|
||||
|
||||
local dir = 'Xtest-unit-file_spec.d'
|
||||
local file1 = dir .. '/file1.dat'
|
||||
local file2 = dir .. '/file2.dat'
|
||||
local linkf = dir .. '/file.lnk'
|
||||
local linkb = dir .. '/broken.lnk'
|
||||
local filec = dir .. '/created-file.dat'
|
||||
|
||||
before_each(function()
|
||||
lfs.mkdir(dir);
|
||||
|
||||
local f1 = io.open(file1, 'w')
|
||||
f1:write(fcontents)
|
||||
f1:close()
|
||||
|
||||
local f2 = io.open(file2, 'w')
|
||||
f2:write(fcontents)
|
||||
f2:close()
|
||||
|
||||
lfs.link('file1.dat', linkf, true)
|
||||
lfs.link('broken.dat', linkb, true)
|
||||
end)
|
||||
|
||||
after_each(function()
|
||||
os.remove(file1)
|
||||
os.remove(file2)
|
||||
os.remove(linkf)
|
||||
os.remove(linkb)
|
||||
os.remove(filec)
|
||||
lfs.rmdir(dir)
|
||||
end)
|
||||
|
||||
local function file_open(fname, flags, mode)
|
||||
local ret2 = ffi.new('FileDescriptor')
|
||||
local ret1 = m.file_open(ret2, fname, flags, mode)
|
||||
return ret1, ret2
|
||||
end
|
||||
|
||||
local function file_open_new(fname, flags, mode)
|
||||
local ret1 = ffi.new('int[?]', 1, {0})
|
||||
local ret2 = ffi.gc(m.file_open_new(ret1, fname, flags, mode), nil)
|
||||
return ret1[0], ret2
|
||||
end
|
||||
|
||||
local function file_write(fp, buf)
|
||||
return m.file_write(fp, buf, #buf)
|
||||
end
|
||||
|
||||
local function file_read(fp, size)
|
||||
local buf = nil
|
||||
if size == nil then
|
||||
size = 0
|
||||
else
|
||||
buf = ffi.new('char[?]', size, ('\0'):rep(size))
|
||||
end
|
||||
local ret1 = m.file_read(fp, buf, size)
|
||||
local ret2 = ''
|
||||
if buf ~= nil then
|
||||
ret2 = ffi.string(buf, size)
|
||||
end
|
||||
return ret1, ret2
|
||||
end
|
||||
|
||||
local function file_fsync(fp)
|
||||
return m.file_fsync(fp)
|
||||
end
|
||||
|
||||
local function file_skip(fp, size)
|
||||
return m.file_skip(fp, size)
|
||||
end
|
||||
|
||||
describe('file_open', function()
|
||||
it('can create a rwx------ file with kFileCreate', function()
|
||||
local err, fp = file_open(filec, m.kFileCreate, 448)
|
||||
eq(0, err)
|
||||
local attrs = lfs.attributes(filec)
|
||||
eq('rwx------', attrs.permissions)
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
|
||||
it('can create a rw------- file with kFileCreate', function()
|
||||
local err, fp = file_open(filec, m.kFileCreate, 384)
|
||||
eq(0, err)
|
||||
local attrs = lfs.attributes(filec)
|
||||
eq('rw-------', attrs.permissions)
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
|
||||
it('can create a rwx------ file with kFileCreateOnly', function()
|
||||
local err, fp = file_open(filec, m.kFileCreateOnly, 448)
|
||||
eq(0, err)
|
||||
local attrs = lfs.attributes(filec)
|
||||
eq('rwx------', attrs.permissions)
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
|
||||
it('can create a rw------- file with kFileCreateOnly', function()
|
||||
local err, fp = file_open(filec, m.kFileCreateOnly, 384)
|
||||
eq(0, err)
|
||||
local attrs = lfs.attributes(filec)
|
||||
eq('rw-------', attrs.permissions)
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
|
||||
it('fails to open an existing file with kFileCreateOnly', function()
|
||||
local err, fp = file_open(file1, m.kFileCreateOnly, 384)
|
||||
eq(m.UV_EEXIST, err)
|
||||
end)
|
||||
|
||||
it('fails to open an symlink with kFileNoSymlink', function()
|
||||
local err, fp = file_open(linkf, m.kFileNoSymlink, 384)
|
||||
eq(m.UV_ELOOP, err)
|
||||
end)
|
||||
|
||||
it('can open an existing file write-only with kFileCreate', function()
|
||||
local err, fp = file_open(file1, m.kFileCreate, 384)
|
||||
eq(0, err)
|
||||
eq(true, fp.wr)
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
|
||||
it('can open an existing file read-only with zero', function()
|
||||
local err, fp = file_open(file1, 0, 384)
|
||||
eq(0, err)
|
||||
eq(false, fp.wr)
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
|
||||
it('can open an existing file read-only with kFileReadOnly', function()
|
||||
local err, fp = file_open(file1, m.kFileReadOnly, 384)
|
||||
eq(0, err)
|
||||
eq(false, fp.wr)
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
|
||||
it('can open an existing file read-only with kFileNoSymlink', function()
|
||||
local err, fp = file_open(file1, m.kFileNoSymlink, 384)
|
||||
eq(0, err)
|
||||
eq(false, fp.wr)
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
|
||||
it('can truncate an existing file with kFileTruncate', function()
|
||||
local err, fp = file_open(file1, m.kFileTruncate, 384)
|
||||
eq(0, err)
|
||||
eq(true, fp.wr)
|
||||
eq(0, m.file_close(fp))
|
||||
local attrs = lfs.attributes(file1)
|
||||
eq(0, attrs.size)
|
||||
end)
|
||||
|
||||
it('can open an existing file write-only with kFileWriteOnly', function()
|
||||
local err, fp = file_open(file1, m.kFileWriteOnly, 384)
|
||||
eq(0, err)
|
||||
eq(true, fp.wr)
|
||||
eq(0, m.file_close(fp))
|
||||
local attrs = lfs.attributes(file1)
|
||||
eq(4096, attrs.size)
|
||||
end)
|
||||
|
||||
it('fails to create a file with just kFileWriteOnly', function()
|
||||
local err, fp = file_open(filec, m.kFileWriteOnly, 384)
|
||||
eq(m.UV_ENOENT, err)
|
||||
local attrs = lfs.attributes(filec)
|
||||
eq(nil, attrs)
|
||||
end)
|
||||
|
||||
it('can truncate an existing file with kFileTruncate when opening a symlink',
|
||||
function()
|
||||
local err, fp = file_open(linkf, m.kFileTruncate, 384)
|
||||
eq(0, err)
|
||||
eq(true, fp.wr)
|
||||
eq(0, m.file_close(fp))
|
||||
local attrs = lfs.attributes(file1)
|
||||
eq(0, attrs.size)
|
||||
end)
|
||||
|
||||
it('fails to open a directory write-only', function()
|
||||
local err, fp = file_open(dir, m.kFileWriteOnly, 384)
|
||||
eq(m.UV_EISDIR, err)
|
||||
end)
|
||||
|
||||
it('fails to open a broken symbolic link write-only', function()
|
||||
local err, fp = file_open(linkb, m.kFileWriteOnly, 384)
|
||||
eq(m.UV_ENOENT, err)
|
||||
end)
|
||||
|
||||
it('fails to open a broken symbolic link read-only', function()
|
||||
local err, fp = file_open(linkb, m.kFileReadOnly, 384)
|
||||
eq(m.UV_ENOENT, err)
|
||||
end)
|
||||
end)
|
||||
|
||||
describe('file_open_new', function()
|
||||
it('can open a file read-only', function()
|
||||
local err, fp = file_open_new(file1, 0, 384)
|
||||
eq(0, err)
|
||||
eq(false, fp.wr)
|
||||
eq(0, m.file_free(fp))
|
||||
end)
|
||||
|
||||
it('fails to open an existing file with kFileCreateOnly', function()
|
||||
local err, fp = file_open_new(file1, m.kFileCreateOnly, 384)
|
||||
eq(m.UV_EEXIST, err)
|
||||
eq(nil, fp)
|
||||
end)
|
||||
end)
|
||||
|
||||
-- file_close is called above, so it is not tested directly
|
||||
|
||||
describe('file_fsync', function()
|
||||
it('can flush writes to disk', function()
|
||||
local err, fp = file_open(filec, m.kFileCreateOnly, 384)
|
||||
eq(0, file_fsync(fp))
|
||||
eq(0, err)
|
||||
eq(0, lfs.attributes(filec).size)
|
||||
local wsize = file_write(fp, 'test')
|
||||
eq(4, wsize)
|
||||
eq(0, lfs.attributes(filec).size)
|
||||
eq(0, file_fsync(fp))
|
||||
eq(wsize, lfs.attributes(filec).size)
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
end)
|
||||
|
||||
describe('file_read', function()
|
||||
it('can read small chunks of input until eof', function()
|
||||
local err, fp = file_open(file1, 0, 384)
|
||||
eq(0, err)
|
||||
eq(false, fp.wr)
|
||||
local shift = 0
|
||||
while shift < #fcontents do
|
||||
local size = 3
|
||||
local exp_err = size
|
||||
local exp_s = fcontents:sub(shift + 1, shift + size)
|
||||
if shift + size >= #fcontents then
|
||||
exp_err = #fcontents - shift
|
||||
exp_s = (fcontents:sub(shift + 1, shift + size)
|
||||
.. (('\0'):rep(size - exp_err)))
|
||||
end
|
||||
eq({exp_err, exp_s}, {file_read(fp, size)})
|
||||
shift = shift + size
|
||||
end
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
|
||||
it('can read the whole file at once', function()
|
||||
local err, fp = file_open(file1, 0, 384)
|
||||
eq(0, err)
|
||||
eq(false, fp.wr)
|
||||
eq({#fcontents, fcontents}, {file_read(fp, #fcontents)})
|
||||
eq({0, ('\0'):rep(#fcontents)}, {file_read(fp, #fcontents)})
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
|
||||
it('can read more then 1024 bytes after reading a small chunk', function()
|
||||
local err, fp = file_open(file1, 0, 384)
|
||||
eq(0, err)
|
||||
eq(false, fp.wr)
|
||||
eq({5, fcontents:sub(1, 5)}, {file_read(fp, 5)})
|
||||
eq({#fcontents - 5, fcontents:sub(6) .. (('\0'):rep(5))},
|
||||
{file_read(fp, #fcontents)})
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
|
||||
it('can read file by 768-byte-chunks', function()
|
||||
local err, fp = file_open(file1, 0, 384)
|
||||
eq(0, err)
|
||||
eq(false, fp.wr)
|
||||
local shift = 0
|
||||
while shift < #fcontents do
|
||||
local size = 768
|
||||
local exp_err = size
|
||||
local exp_s = fcontents:sub(shift + 1, shift + size)
|
||||
if shift + size >= #fcontents then
|
||||
exp_err = #fcontents - shift
|
||||
exp_s = (fcontents:sub(shift + 1, shift + size)
|
||||
.. (('\0'):rep(size - exp_err)))
|
||||
end
|
||||
eq({exp_err, exp_s}, {file_read(fp, size)})
|
||||
shift = shift + size
|
||||
end
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
end)
|
||||
|
||||
describe('file_write', function()
|
||||
it('can write the whole file at once', function()
|
||||
local err, fp = file_open(filec, m.kFileCreateOnly, 384)
|
||||
eq(0, err)
|
||||
eq(true, fp.wr)
|
||||
local err = file_write(fp, fcontents)
|
||||
eq(#fcontents, err)
|
||||
eq(0, m.file_close(fp))
|
||||
eq(err, lfs.attributes(filec).size)
|
||||
eq(fcontents, io.open(filec):read('*a'))
|
||||
end)
|
||||
|
||||
it('can write the whole file by small chunks', function()
|
||||
local err, fp = file_open(filec, m.kFileCreateOnly, 384)
|
||||
eq(0, err)
|
||||
eq(true, fp.wr)
|
||||
local shift = 0
|
||||
while shift < #fcontents do
|
||||
local size = 3
|
||||
local s = fcontents:sub(shift + 1, shift + size)
|
||||
local err = file_write(fp, s)
|
||||
eq(err, #s)
|
||||
shift = shift + size
|
||||
end
|
||||
eq(0, m.file_close(fp))
|
||||
eq(#fcontents, lfs.attributes(filec).size)
|
||||
eq(fcontents, io.open(filec):read('*a'))
|
||||
end)
|
||||
|
||||
it('can write the whole file by 768-byte-chunks', function()
|
||||
local err, fp = file_open(filec, m.kFileCreateOnly, 384)
|
||||
eq(0, err)
|
||||
eq(true, fp.wr)
|
||||
local shift = 0
|
||||
while shift < #fcontents do
|
||||
local size = 768
|
||||
local s = fcontents:sub(shift + 1, shift + size)
|
||||
local err = file_write(fp, s)
|
||||
eq(err, #s)
|
||||
shift = shift + size
|
||||
end
|
||||
eq(0, m.file_close(fp))
|
||||
eq(#fcontents, lfs.attributes(filec).size)
|
||||
eq(fcontents, io.open(filec):read('*a'))
|
||||
end)
|
||||
end)
|
||||
|
||||
describe('file_skip', function()
|
||||
it('can skip 3 bytes', function()
|
||||
local err, fp = file_open(file1, 0, 384)
|
||||
eq(0, err)
|
||||
eq(false, fp.wr)
|
||||
eq(3, file_skip(fp, 3))
|
||||
local err, s = file_read(fp, 3)
|
||||
eq(3, err)
|
||||
eq(fcontents:sub(4, 6), s)
|
||||
eq(0, m.file_close(fp))
|
||||
end)
|
||||
end)
|
||||
Reference in New Issue
Block a user