errinj.result

errinj = box.error.injection
---
...
net_box = require('net.box')
---
...
space = box.schema.space.create('tweedledum')
---
...
index = space:create_index('primary', { type = 'hash' })
---
...
--
-- Print all error keys in sorted order to minimize diff output
-- when new ones are merged in.
ekeys = {}
---
...
evals = {}
---
...
for k, v in pairs(errinj.info()) do table.insert(ekeys, k) end
---
...
table.sort(ekeys)
---
...
for i, k in ipairs(ekeys) do         \
    evals[i] = {[k] = errinj.get(k)} \
end
---
...
evals
---
- - ERRINJ_BUILD_INDEX: -1
  - ERRINJ_BUILD_INDEX_DELAY: false
  - ERRINJ_CHECK_FORMAT_DELAY: false
  - ERRINJ_COIO_SENDFILE_CHUNK: -1
  - ERRINJ_DYN_MODULE_COUNT: 0
  - ERRINJ_FIBER_MADVISE: false
  - ERRINJ_FIBER_MPROTECT: -1
  - ERRINJ_HTTPC_EXECUTE: false
  - ERRINJ_HTTP_RESPONSE_ADD_WAIT: false
  - ERRINJ_INDEX_ALLOC: false
  - ERRINJ_IPROTO_TX_DELAY: false
  - ERRINJ_LOG_ROTATE: false
  - ERRINJ_MEMTX_DELAY_GC: false
  - ERRINJ_PORT_DUMP: false
  - ERRINJ_RELAY_BREAK_LSN: -1
  - ERRINJ_RELAY_EXIT_DELAY: 0
  - ERRINJ_RELAY_FASTER_THAN_TX: false
  - ERRINJ_RELAY_FINAL_JOIN: false
  - ERRINJ_RELAY_FINAL_SLEEP: false
  - ERRINJ_RELAY_REPORT_INTERVAL: 0
  - ERRINJ_RELAY_SEND_DELAY: false
  - ERRINJ_RELAY_TIMEOUT: 0
  - ERRINJ_SIO_READ_MAX: -1
  - ERRINJ_SNAP_COMMIT_DELAY: false
  - ERRINJ_SNAP_WRITE_DELAY: false
  - ERRINJ_SQL_NAME_NORMALIZATION: false
  - ERRINJ_SWIM_FD_ONLY: false
  - ERRINJ_TESTING: false
  - ERRINJ_TUPLE_ALLOC: false
  - ERRINJ_TUPLE_FIELD: false
  - ERRINJ_TUPLE_FORMAT_COUNT: -1
  - ERRINJ_VYRUN_DATA_READ: false
  - ERRINJ_VYRUN_INDEX_GARBAGE: false
  - ERRINJ_VY_COMPACTION_DELAY: false
  - ERRINJ_VY_DELAY_PK_LOOKUP: false
  - ERRINJ_VY_DUMP_DELAY: false
  - ERRINJ_VY_GC: false
  - ERRINJ_VY_INDEX_DUMP: -1
  - ERRINJ_VY_INDEX_FILE_RENAME: false
  - ERRINJ_VY_LOG_FILE_RENAME: false
  - ERRINJ_VY_LOG_FLUSH: false
  - ERRINJ_VY_LOG_FLUSH_DELAY: false
  - ERRINJ_VY_POINT_ITER_WAIT: false
  - ERRINJ_VY_READ_PAGE: false
  - ERRINJ_VY_READ_PAGE_DELAY: false
  - ERRINJ_VY_READ_PAGE_TIMEOUT: 0
  - ERRINJ_VY_RUN_DISCARD: false
  - ERRINJ_VY_RUN_FILE_RENAME: false
  - ERRINJ_VY_RUN_WRITE: false
  - ERRINJ_VY_RUN_WRITE_DELAY: false
  - ERRINJ_VY_RUN_WRITE_STMT_TIMEOUT: 0
  - ERRINJ_VY_SCHED_TIMEOUT: 0
  - ERRINJ_VY_SQUASH_TIMEOUT: 0
  - ERRINJ_VY_TASK_COMPLETE: false
  - ERRINJ_WAL_BREAK_LSN: -1
  - ERRINJ_WAL_DELAY: false
  - ERRINJ_WAL_FALLOCATE: 0
  - ERRINJ_WAL_IO: false
  - ERRINJ_WAL_ROTATE: false
  - ERRINJ_WAL_WRITE: false
  - ERRINJ_WAL_WRITE_DISK: false
  - ERRINJ_WAL_WRITE_EOF: false
  - ERRINJ_WAL_WRITE_PARTIAL: -1
  - ERRINJ_XLOG_GARBAGE: false
  - ERRINJ_XLOG_META: false
  - ERRINJ_XLOG_READ: -1
...
errinj.set("some-injection", true)
---
- 'error: can''t find error injection ''some-injection'''
...
errinj.set("some-injection") -- check error
---
- 'error: can''t find error injection ''some-injection'''
...
space:select{222444}
---
- []
...
errinj.set("ERRINJ_TESTING", true)
---
- ok
...
space:select{222444}
---
- error: Error injection 'ERRINJ_TESTING'
...
errinj.set("ERRINJ_TESTING", false)
---
- ok
...
-- Check how well we handle a failed log write
errinj.set("ERRINJ_WAL_IO", true)
---
- ok
...
space:insert{1}
---
- error: Failed to write to disk
...
space:get{1}
---
...
errinj.set("ERRINJ_WAL_IO", false)
---
- ok
...
space:insert{1}
---
- [1]
...
errinj.set("ERRINJ_WAL_IO", true)
---
- ok
...
space:update(1, {{'=', 2, 2}})
---
- error: Failed to write to disk
...
space:get{1}
---
- [1]
...
space:get{2}
---
...
errinj.set("ERRINJ_WAL_IO", false)
---
- ok
...
space:update(1, {{'=', 2, 2}})
---
- [1, 2]
...
space:truncate()
---
...
-- Check that WAL vclock isn't promoted on failed write.
lsn1 = box.info.vclock[box.info.id]
---
...
errinj.set("ERRINJ_WAL_WRITE_PARTIAL", 0)
---
- ok
...
space:insert{1}
---
- error: Failed to write to disk
...
errinj.set("ERRINJ_WAL_WRITE_PARTIAL", -1)
---
- ok
...
space:insert{1}
---
- [1]
...
-- Check vclock was promoted only one time
box.info.vclock[box.info.id] == lsn1 + 1
---
- true
...
errinj.set("ERRINJ_WAL_WRITE_PARTIAL", 0)
---
- ok
...
space:update(1, {{'=', 2, 2}})
---
- error: Failed to write to disk
...
space:get{1}
---
- [1]
...
errinj.set("ERRINJ_WAL_WRITE_PARTIAL", -1)
---
- ok
...
space:update(1, {{'=', 2, 2}})
---
- [1, 2]
...
-- Check vclock was promoted only two times
box.info.vclock[box.info.id] == lsn1 + 2
---
- true
...
space:truncate()
---
...
-- Check a failed log rotation
errinj.set("ERRINJ_WAL_ROTATE", true)
---
- ok
...
space:insert{1}
---
- error: Failed to write to disk
...
space:get{1}
---
...
errinj.set("ERRINJ_WAL_ROTATE", false)
---
- ok
...
space:insert{1}
---
- [1]
...
errinj.set("ERRINJ_WAL_ROTATE", true)
---
- ok
...
space:update(1, {{'=', 2, 2}})
---
- error: Failed to write to disk
...
space:get{1}
---
- [1]
...
space:get{2}
---
...
errinj.set("ERRINJ_WAL_ROTATE", false)
---
- ok
...
space:update(1, {{'=', 2, 2}})
---
- [1, 2]
...
space:get{1}
---
- [1, 2]
...
space:get{2}
---
...
space:truncate()
---
...
space:drop()
---
...
-- Check how well we handle a failed log write in DDL
s_disabled = box.schema.space.create('disabled')
---
...
s_withindex = box.schema.space.create('withindex')
---
...
index1 = s_withindex:create_index('primary', { type = 'hash' })
---
...
s_withdata = box.schema.space.create('withdata')
---
...
index2 = s_withdata:create_index('primary', { type = 'tree' })
---
...
s_withdata:insert{1, 2, 3, 4, 5}
---
- [1, 2, 3, 4, 5]
...
s_withdata:insert{4, 5, 6, 7, 8}
---
- [4, 5, 6, 7, 8]
...
index3 = s_withdata:create_index('secondary', { type = 'hash', parts = {2, 'unsigned', 3, 'unsigned' }})
---
...
errinj.set("ERRINJ_WAL_IO", true)
---
- ok
...
test = box.schema.space.create('test')
---
- error: Failed to write to disk
...
s_disabled:create_index('primary', { type = 'hash' })
---
- error: Failed to write to disk
...
s_disabled.enabled
---
- false
...
s_disabled:insert{0}
---
- error: 'No index #0 is defined in space ''disabled'''
...
s_withindex:create_index('secondary', { type = 'tree', parts = { 2, 'unsigned'} })
---
- error: Failed to write to disk
...
s_withindex.index.secondary
---
- null
...
s_withdata.index.secondary:drop()
---
- error: Failed to write to disk
...
s_withdata.index.secondary.unique
---
- true
...
s_withdata:drop()
---
- error: Failed to write to disk
...
box.space['withdata'].enabled
---
- true
...
index4 = s_withdata:create_index('another', { type = 'tree', parts = { 5, 'unsigned' }, unique = false})
---
- error: Failed to write to disk
...
s_withdata.index.another
---
- null
...
errinj.set("ERRINJ_WAL_IO", false)
---
- ok
...
test = box.schema.space.create('test')
---
...
index5 = s_disabled:create_index('primary', { type = 'hash' })
---
...
s_disabled.enabled
---
- true
...
s_disabled:insert{0}
---
- [0]
...
index6 = s_withindex:create_index('secondary', { type = 'tree', parts = { 2, 'unsigned'} })
---
...
s_withindex.index.secondary.unique
---
- true
...
s_withdata.index.secondary:drop()
---
...
s_withdata.index.secondary
---
- null
...
s_withdata:drop()
---
...
box.space['withdata']
---
- null
...
index7 = s_withdata:create_index('another', { type = 'tree', parts = { 5, 'unsigned' }, unique = false})
---
- error: Space 'withdata' does not exist
...
s_withdata.index.another
---
- null
...
test:drop()
---
...
s_disabled:drop()
---
...
s_withindex:drop()
---
...
-- Check transaction rollback when out of memory
env = require('test_run')
---
...
test_run = env.new()
---
...
s = box.schema.space.create('s')
---
...
_ = s:create_index('pk')
---
...
errinj.set("ERRINJ_TUPLE_ALLOC", true)
---
- ok
...
s:auto_increment{}
---
- error: Failed to allocate 16 bytes in slab allocator for memtx_tuple
...
s:select{}
---
- []
...
s:auto_increment{}
---
- error: Failed to allocate 16 bytes in slab allocator for memtx_tuple
...
s:select{}
---
- []
...
s:auto_increment{}
---
- error: Failed to allocate 16 bytes in slab allocator for memtx_tuple
...
s:select{}
---
- []
...
test_run:cmd("setopt delimiter ';'")
---
- true
...
box.begin()
    s:insert{1}
box.commit();
---
- error: Failed to allocate 16 bytes in slab allocator for memtx_tuple
...
box.rollback();
---
...
s:select{};
---
- []
...
box.begin()
    s:insert{1}
    s:insert{2}
box.commit();
---
- error: Failed to allocate 16 bytes in slab allocator for memtx_tuple
...
s:select{};
---
- []
...
box.rollback();
---
...
box.begin()
    pcall(s.insert, s, {1})
    s:insert{2}
box.commit();
---
- error: Failed to allocate 16 bytes in slab allocator for memtx_tuple
...
s:select{};
---
- []
...
box.rollback();
---
...
errinj.set("ERRINJ_TUPLE_ALLOC", false);
---
- ok
...
box.begin()
    s:insert{1}
    errinj.set("ERRINJ_TUPLE_ALLOC", true)
    s:insert{2}
box.commit();
---
- error: Failed to allocate 16 bytes in slab allocator for memtx_tuple
...
errinj.set("ERRINJ_TUPLE_ALLOC", false);
---
- ok
...
box.rollback();
---
...
s:select{};
---
- []
...
box.begin()
    s:insert{1}
    errinj.set("ERRINJ_TUPLE_ALLOC", true)
    pcall(s.insert, s, {2})
box.commit();
---
...
s:select{};
---
- - [1]
...
box.rollback();
---
...
test_run:cmd("setopt delimiter ''");
---
- true
...
errinj.set("ERRINJ_TUPLE_ALLOC", false)
---
- ok
...
s:drop()
---
...
s = box.schema.space.create('test')
---
...
_ = s:create_index('test', {parts = {1, 'unsigned', 3, 'unsigned', 5, 'unsigned'}})
---
...
s:insert{1, 2, 3, 4, 5, 6}
---
- [1, 2, 3, 4, 5, 6]
...
t = s:select{}[1]
---
...
errinj.set("ERRINJ_TUPLE_FIELD", true)
---
- ok
...
tostring(t[1]) .. tostring(t[2]) ..tostring(t[3]) .. tostring(t[4]) .. tostring(t[5]) .. tostring(t[6])
---
- 1nil3nil5nil
...
errinj.set("ERRINJ_TUPLE_FIELD", false)
---
- ok
...
tostring(t[1]) .. tostring(t[2]) ..tostring(t[3]) .. tostring(t[4]) .. tostring(t[5]) .. tostring(t[6])
---
- '123456'
...
s:drop()
---
...
s = box.schema.space.create('test')
---
...
_ = s:create_index('test', {parts = {2, 'unsigned', 4, 'unsigned', 6, 'unsigned'}})
---
...
s:insert{1, 2, 3, 4, 5, 6}
---
- [1, 2, 3, 4, 5, 6]
...
t = s:select{}[1]
---
...
errinj.set("ERRINJ_TUPLE_FIELD", true)
---
- ok
...
tostring(t[1]) .. tostring(t[2]) ..tostring(t[3]) .. tostring(t[4]) .. tostring(t[5]) .. tostring(t[6])
---
- 12nil4nil6
...
errinj.set("ERRINJ_TUPLE_FIELD", false)
---
- ok
...
tostring(t[1]) .. tostring(t[2]) ..tostring(t[3]) .. tostring(t[4]) .. tostring(t[5]) .. tostring(t[6])
---
- '123456'
...
-- Cleanup
s:drop()
---
...
--
-- gh-2046: don't store offsets for sequential multi-parts keys
--
s = box.schema.space.create('test')
---
...
_ = s:create_index('seq2', { parts = { 1, 'unsigned', 2, 'unsigned' }})
---
...
_ = s:create_index('seq3', { parts = { 1, 'unsigned', 2, 'unsigned', 3, 'unsigned' }})
---
...
_ = s:create_index('seq5', { parts = { 1, 'unsigned', 2, 'unsigned', 3, 'unsigned', 4, 'scalar', 5, 'number' }})
---
...
_ = s:create_index('rnd1', { parts = { 3, 'unsigned' }})
---
...
errinj.set("ERRINJ_TUPLE_FIELD", true)
---
- ok
...
tuple = s:insert({1, 2, 3, 4, 5, 6, 7, 8, 9, 10})
---
...
tuple
---
- [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
...
tuple[1] -- not-null, always accessible
---
- 1
...
tuple[2] -- null, doesn't have offset
---
- null
...
tuple[3] -- not null, has offset
---
- 3
...
tuple[4] -- null, doesn't have offset
---
- null
...
tuple[5] -- null, doesn't have offset
---
- null
...
s.index.seq2:select({1})
---
- - [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
...
s.index.seq2:select({1, 2})
---
- - [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
...
s.index.seq3:select({1})
---
- - [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
...
s.index.seq3:select({1, 2, 3})
---
- - [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
...
s.index.seq5:select({1})
---
- - [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
...
s.index.seq5:select({1, 2, 3, 4, 5})
---
- - [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
...
s.index.rnd1:select({3})
---
- - [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
...
errinj.set("ERRINJ_TUPLE_FIELD", false)
---
- ok
...
s:drop()
---
...
space = box.schema.space.create('test')
---
...
_ = space:create_index('pk')
---
...
errinj.set("ERRINJ_WAL_WRITE", true)
---
- ok
...
space:insert{1}
---
- error: Failed to write to disk
...
errinj.set("ERRINJ_WAL_WRITE", false)
---
- ok
...
errinj.set("ERRINJ_WAL_WRITE_DISK", true)
---
- ok
...
_ = space:insert{1, require'digest'.urandom(192 * 1024)}
---
- error: Failed to write to disk
...
errinj.set("ERRINJ_WAL_WRITE_DISK", false)
---
- ok
...
_ = space:insert{1}
---
...
errinj.set("ERRINJ_WAL_WRITE", true)
---
- ok
...
box.snapshot()
---
- error: Error injection 'xlog write injection'
...
errinj.set("ERRINJ_WAL_WRITE", false)
---
- ok
...
space:drop()
---
...
--test space:bsize() in case of memory error
utils = dofile('utils.lua')
---
...
s = box.schema.space.create('space_bsize')
---
...
idx = s:create_index('primary')
---
...
for i = 1, 13 do s:insert{ i, string.rep('x', i) } end
---
...
s:bsize()
---
- 130
...
utils.space_bsize(s)
---
- 130
...
errinj.set("ERRINJ_TUPLE_ALLOC", true)
---
- ok
...
s:replace{1, "test"}
---
- error: Failed to allocate 21 bytes in slab allocator for memtx_tuple
...
s:bsize()
---
- 130
...
utils.space_bsize(s)
---
- 130
...
s:update({1}, {{'=', 3, '!'}})
---
- error: Failed to allocate 20 bytes in slab allocator for memtx_tuple
...
s:bsize()
---
- 130
...
utils.space_bsize(s)
---
- 130
...
errinj.set("ERRINJ_TUPLE_ALLOC", false)
---
- ok
...
s:drop()
---
...
space = box.schema.space.create('test')
---
...
index1 = space:create_index('primary')
---
...
fiber = require'fiber'
---
...
ch = fiber.channel(1)
---
...
test_run:cmd('setopt delimiter ";"')
---
- true
...
function test()
  errinj.set('ERRINJ_WAL_WRITE_DISK', true)
  pcall(box.space.test.replace, box.space.test, {1, 1})
  errinj.set('ERRINJ_WAL_WRITE_DISK', false)
  ch:put(true)
end ;
---
...
function run()
  fiber.create(test)
  box.snapshot()
end ;
---
...
test_run:cmd('setopt delimiter ""');
---
- true
...
-- Port_dump can fail.
box.schema.user.grant('guest', 'read', 'space', '_space')
---
...
cn = net_box.connect(box.cfg.listen)
---
...
cn:ping()
---
- true
...
errinj.set('ERRINJ_PORT_DUMP', true)
---
- ok
...
ok, ret = pcall(cn.space._space.select, cn.space._space)
---
...
assert(not ok)
---
- true
...
assert(string.match(tostring(ret), 'Failed to allocate'))
---
- Failed to allocate
...
errinj.set('ERRINJ_PORT_DUMP', false)
---
- ok
...
cn:close()
---
...
box.schema.user.revoke('guest', 'read', 'space', '_space')
---
...
run()
---
- error: Can't start a checkpoint while in cascading rollback
...
ch:get()
---
- true
...
box.space.test:select()
---
- []
...
test_run:cmd('restart server default')
box.space.test:select()
---
- []
...
box.space.test:drop()
---
...
errinj = box.error.injection
---
...
net_box = require('net.box')
---
...
fiber = require'fiber'
---
...
s = box.schema.space.create('test')
---
...
_ = s:create_index('pk')
---
...
ch = fiber.channel(2)
---
...
test_run:cmd("setopt delimiter ';'")
---
- true
...
function test(tuple)
   ch:put({pcall(s.replace, s, tuple)})
end;
---
...
test_run:cmd("setopt delimiter ''");
---
- true
...
errinj.set("ERRINJ_WAL_WRITE", true)
---
- ok
...
_ = {fiber.create(test, {1, 2, 3}), fiber.create(test, {3, 4, 5})}
---
...
{ch:get(), ch:get()}
---
- - - false
    - Failed to write to disk
  - - false
    - Failed to write to disk
...
errinj.set("ERRINJ_WAL_WRITE", false)
---
- ok
...
s:drop()
---
...
-- rebuild some secondary indexes if the primary was changed
s = box.schema.space.create('test')
---
...
i1 = s:create_index('i1', {parts = {1, 'unsigned'}})
---
...
--i2 = s:create_index('i2', {parts = {5, 'unsigned'}, unique = false})
--i3 = s:create_index('i3', {parts = {6, 'unsigned'}, unique = false})
i2 = i1 i3 = i1
---
...
_ = s:insert{1, 4, 3, 4, 10, 10}
---
...
_ = s:insert{2, 3, 1, 2, 10, 10}
---
...
_ = s:insert{3, 2, 2, 1, 10, 10}
---
...
_ = s:insert{4, 1, 4, 3, 10, 10}
---
...
i1:select{}
---
- - [1, 4, 3, 4, 10, 10]
  - [2, 3, 1, 2, 10, 10]
  - [3, 2, 2, 1, 10, 10]
  - [4, 1, 4, 3, 10, 10]
...
i2:select{}
---
- - [1, 4, 3, 4, 10, 10]
  - [2, 3, 1, 2, 10, 10]
  - [3, 2, 2, 1, 10, 10]
  - [4, 1, 4, 3, 10, 10]
...
i3:select{}
---
- - [1, 4, 3, 4, 10, 10]
  - [2, 3, 1, 2, 10, 10]
  - [3, 2, 2, 1, 10, 10]
  - [4, 1, 4, 3, 10, 10]
...
i1:alter({parts={2, 'unsigned'}})
---
...
_ = collectgarbage('collect')
---
...
i1:select{}
---
- - [4, 1, 4, 3, 10, 10]
  - [3, 2, 2, 1, 10, 10]
  - [2, 3, 1, 2, 10, 10]
  - [1, 4, 3, 4, 10, 10]
...
i2:select{}
---
- - [4, 1, 4, 3, 10, 10]
  - [3, 2, 2, 1, 10, 10]
  - [2, 3, 1, 2, 10, 10]
  - [1, 4, 3, 4, 10, 10]
...
i3:select{}
---
- - [4, 1, 4, 3, 10, 10]
  - [3, 2, 2, 1, 10, 10]
  - [2, 3, 1, 2, 10, 10]
  - [1, 4, 3, 4, 10, 10]
...
box.error.injection.set('ERRINJ_BUILD_INDEX', i2.id)
---
- ok
...
i1:alter{parts = {3, "unsigned"}}
---
- error: Error injection 'build index'
...
_ = collectgarbage('collect')
---
...
i1:select{}
---
- - [4, 1, 4, 3, 10, 10]
  - [3, 2, 2, 1, 10, 10]
  - [2, 3, 1, 2, 10, 10]
  - [1, 4, 3, 4, 10, 10]
...
i2:select{}
---
- - [4, 1, 4, 3, 10, 10]
  - [3, 2, 2, 1, 10, 10]
  - [2, 3, 1, 2, 10, 10]
  - [1, 4, 3, 4, 10, 10]
...
i3:select{}
---
- - [4, 1, 4, 3, 10, 10]
  - [3, 2, 2, 1, 10, 10]
  - [2, 3, 1, 2, 10, 10]
  - [1, 4, 3, 4, 10, 10]
...
box.error.injection.set('ERRINJ_BUILD_INDEX', i3.id)
---
- ok
...
i1:alter{parts = {4, "unsigned"}}
---
- error: Error injection 'build index'
...
_ = collectgarbage('collect')
---
...
i1:select{}
---
- - [4, 1, 4, 3, 10, 10]
  - [3, 2, 2, 1, 10, 10]
  - [2, 3, 1, 2, 10, 10]
  - [1, 4, 3, 4, 10, 10]
...
i2:select{}
---
- - [4, 1, 4, 3, 10, 10]
  - [3, 2, 2, 1, 10, 10]
  - [2, 3, 1, 2, 10, 10]
  - [1, 4, 3, 4, 10, 10]
...
i3:select{}
---
- - [4, 1, 4, 3, 10, 10]
  - [3, 2, 2, 1, 10, 10]
  - [2, 3, 1, 2, 10, 10]
  - [1, 4, 3, 4, 10, 10]
...
box.error.injection.set('ERRINJ_BUILD_INDEX', -1)
---
- ok
...
s:drop()
---
...
--
-- Do not rebuild index if the only change is a key part type
-- compatible change.
--
s = box.schema.space.create('test')
---
...
pk = s:create_index('pk')
---
...
sk = s:create_index('sk', {parts = {2, 'unsigned'}})
---
...
s:replace{1, 1}
---
- [1, 1]
...
box.error.injection.set('ERRINJ_BUILD_INDEX', sk.id)
---
- ok
...
sk:alter({parts = {2, 'number'}})
---
...
box.error.injection.set('ERRINJ_BUILD_INDEX', -1)
---
- ok
...
s:drop()
---
...
--
-- gh-3255: iproto can crash and discard responses, if a network
-- is saturated, and DML yields too long on commit.
--
s = box.schema.space.create('test')
---
...
_ = s:create_index('pk')
---
...
box.schema.user.grant('guest', 'read,write,alter', 'space', 'test')
---
...
c = net_box.connect(box.cfg.listen)
---
...
ch = fiber.channel(200)
---
...
errinj.set("ERRINJ_IPROTO_TX_DELAY", true)
---
- ok
...
for i = 1, 100 do fiber.create(function() for j = 1, 10 do c.space.test:replace{1} end ch:put(true) end) end
---
...
for i = 1, 100 do fiber.create(function() for j = 1, 10 do c.space.test:select() end ch:put(true) end) end
---
...
for i = 1, 200 do ch:get() end
---
...
errinj.set("ERRINJ_IPROTO_TX_DELAY", false)
---
- ok
...
s:drop()
---
...
--
-- gh-3325: do not cancel already sent requests, when a schema
-- change is detected.
--
box.schema.user.grant('guest', 'execute', 'universe')
---
...
s = box.schema.create_space('test')
---
...
pk = s:create_index('pk')
---
...
box.schema.user.grant('guest', 'read,write,alter', 'space', 'test')
---
...
box.schema.user.grant('guest', 'create', 'space')
---
...
box.schema.user.grant('guest', 'write', 'space', '_index')
---
...
s:replace{1, 1}
---
- [1, 1]
...
cn = net_box.connect(box.cfg.listen)
---
...
errinj.set("ERRINJ_WAL_DELAY", true)
---
- ok
...
ok = nil
---
...
err = nil
---
...
test_run:cmd('setopt delimiter ";"')
---
- true
...
f = fiber.create(function()
  local str = 'box.space.test:create_index("sk", {parts = {{2, "integer"}}})'
  ok, err = pcall(cn.eval, cn, str)
end)
test_run:cmd('setopt delimiter ""');
---
...
cn.space.test:get{1}
---
- [1, 1]
...
errinj.set("ERRINJ_WAL_DELAY", false)
---
- ok
...
while ok == nil do fiber.sleep(0.01) end
---
...
ok, err
---
- true
- null
...
cn:close()
---
...
s:drop()
---
...
box.schema.user.revoke('guest', 'execute', 'universe')
---
...
box.schema.user.revoke('guest', 'create', 'space')
---
...
box.schema.user.revoke('guest', 'write', 'space', '_index')
---
...
--
-- If message memory pool is used up, stop the connection, until
-- the pool has free memory.
--
started = 0
---
...
finished = 0
---
...
continue = false
---
...
test_run:cmd('setopt delimiter ";"')
---
- true
...
function long_poll_f()
    started = started + 1
    f = fiber.self()
    while not continue do fiber.sleep(0.01) end
    finished = finished + 1
end;
---
...
box.schema.func.create('long_poll_f');
---
...
box.schema.user.grant('guest', 'execute', 'function', 'long_poll_f');
---
...
test_run:cmd('setopt delimiter ""');
---
- true
...
cn = net_box.connect(box.cfg.listen)
---
...
function long_poll() cn:call('long_poll_f') end
---
...
_ = fiber.create(long_poll)
---
...
while started ~= 1 do fiber.sleep(0.01) end
---
...
-- Simulate OOM for new requests.
errinj.set("ERRINJ_TESTING", true)
---
- ok
...
-- This request tries to allocate memory for request data and
-- fails. This stops the connection until an existing
-- request is finished.
log = require('log')
---
...
-- Fill the log with garbage to not accidentally read log messages
-- produced by a previous test.
log.info(string.rep('a', 1000))
---
...
_ = fiber.create(long_poll)
---
...
while not test_run:grep_log('default', 'can not allocate memory for a new message', 1000) do fiber.sleep(0.01) end
---
...
test_run:grep_log('default', 'stopping input on connection', 1000) ~= nil
---
- true
...
started == 1
---
- true
...
continue = true
---
...
errinj.set("ERRINJ_TESTING", false)
---
- ok
...
-- Ensure that when memory is available again, the pending
-- request is executed.
while finished ~= 2 do fiber.sleep(0.01) end
---
...
cn:close()
---
...
box.schema.user.revoke('guest', 'execute', 'function', 'long_poll_f')
---
...
box.schema.func.drop('long_poll_f')
---
...
--
-- gh-3289: drop/truncate leaves the space in inconsistent
-- state if WAL write fails.
--
s = box.schema.space.create('test')
---
...
_ = s:create_index('pk')
---
...
for i = 1, 10 do s:replace{i} end
---
...
errinj.set('ERRINJ_WAL_IO', true)
---
- ok
...
s:drop()
---
- error: Failed to write to disk
...
s:truncate()
---
- error: Failed to write to disk
...
s:drop()
---
- error: Failed to write to disk
...
s:truncate()
---
- error: Failed to write to disk
...
errinj.set('ERRINJ_WAL_IO', false)
---
- ok
...
for i = 1, 10 do s:replace{i + 10} end
---
...
s:select()
---
- - [1]
  - [2]
  - [3]
  - [4]
  - [5]
  - [6]
  - [7]
  - [8]
  - [9]
  - [10]
  - [11]
  - [12]
  - [13]
  - [14]
  - [15]
  - [16]
  - [17]
  - [18]
  - [19]
  - [20]
...
s:drop()
---
...
--
-- gh-3432: check that deletion of temporary tuples is not delayed
-- if snapshot is in progress.
--
test_run:cmd("create server test with script='box/lua/cfg_memory.lua'")
---
- true
...
test_run:cmd(string.format("start server test with args='%d'", 100 * 1024 * 1024))
---
- true
...
test_run:cmd("switch test")
---
- true
...
fiber = require('fiber')
---
...
-- Create a persistent space.
_ = box.schema.space.create('test')
---
...
_ = box.space.test:create_index('pk')
---
...
for i = 1, 100 do box.space.test:insert{i} end
---
...
-- Create a temporary space.
count = 500
---
...
pad = string.rep('x', 100 * 1024)
---
...
_ = box.schema.space.create('tmp', {temporary = true})
---
...
_ = box.space.tmp:create_index('pk')
---
...
for i = 1, count do box.space.tmp:insert{i, pad} end
---
...
-- Start background snapshot.
c = fiber.channel(1)
---
...
box.error.injection.set('ERRINJ_SNAP_WRITE_DELAY', true)
---
- ok
...
_ = fiber.create(function() box.snapshot() c:put(true) end)
---
...
-- Overwrite data stored in the temporary space while snapshot
-- is in progress to make sure that tuples stored in it are freed
-- immediately.
for i = 1, count do box.space.tmp:delete{i} end
---
...
_ = collectgarbage('collect')
---
...
for i = 1, count do box.space.tmp:insert{i, pad} end
---
...
box.error.injection.set('ERRINJ_SNAP_WRITE_DELAY', false)
---
- ok
...
c:get()
---
- true
...
box.space.tmp:drop()
---
...
box.space.test:drop()
---
...
test_run:cmd("switch default")
---
- true
...
test_run:cmd("stop server test")
---
- true
...
test_run:cmd("cleanup server test")
---
- true
...
--
-- gh-3406: check that incomplete files got cleaned up after restart.
--
fio = require('fio')
---
...
fiber = require('fiber')
---
...
-- Check that snap.inprogress files are removed.
_ = box.schema.space.create('test')
---
...
_ = box.space.test:create_index('primary')
---
...
for i = 1, 10 do box.space.test:insert{i} end
---
...
errinj.set('ERRINJ_SNAP_WRITE_DELAY', true)
---
- ok
...
_ = fiber.create(function() box.snapshot() end)
---
...
path = fio.pathjoin(box.cfg.memtx_dir, '*.snap.inprogress')
---
...
while #fio.glob(path) == 0 do fiber.sleep(0.001) end
---
...
#fio.glob(path) > 0
---
- true
...
test_run:cmd('restart server default')
fio = require('fio')
---
...
fiber = require('fiber')
---
...
errinj = box.error.injection
---
...
#fio.glob(fio.pathjoin(box.cfg.memtx_dir, "*.snap.inprogress")) == 0
---
- true
...
box.space.test:drop()
---
...
-- Check that run.inprogress, index.inprogress, and vylog.inprogress
-- files are removed.
_ = box.schema.space.create('test', {engine = 'vinyl'})
---
...
_ = box.space.test:create_index('primary')
---
...
errinj.set('ERRINJ_VY_LOG_FILE_RENAME', true)
---
- ok
...
box.snapshot()
---
- error: Error injection 'vinyl log file rename'
...
errinj.set('ERRINJ_VY_LOG_FILE_RENAME', false)
---
- ok
...
errinj.set('ERRINJ_VY_GC', true)
---
- ok
...
errinj.set('ERRINJ_VY_SCHED_TIMEOUT', 0.001)
---
- ok
...
errinj.set('ERRINJ_VY_RUN_FILE_RENAME', true)
---
- ok
...
box.space.test:insert{1}
---
- [1]
...
box.snapshot() -- error
---
- error: Error injection 'vinyl run file rename'
...
errinj.set('ERRINJ_VY_RUN_FILE_RENAME', false)
---
- ok
...
-- Wait for the scheduler to unthrottle.
repeat fiber.sleep(0.001) until pcall(box.snapshot)
---
...
errinj.set('ERRINJ_VY_INDEX_FILE_RENAME', true)
---
- ok
...
box.space.test:insert{2}
---
- [2]
...
box.snapshot() -- error
---
- error: Error injection 'vinyl index file rename'
...
errinj.set('ERRINJ_VY_INDEX_FILE_RENAME', false)
---
- ok
...
errinj.set('ERRINJ_VY_SCHED_TIMEOUT', 0)
---
- ok
...
errinj.set('ERRINJ_VY_GC', false)
---
- ok
...
test_run:cmd('restart server default')
fio = require('fio')
---
...
#fio.glob(fio.pathjoin(box.cfg.vinyl_dir, '*.vylog.inprogress')) == 0
---
- true
...
#fio.glob(fio.pathjoin(box.cfg.vinyl_dir, box.space.test.id, 0, '*.run.inprogress')) == 0
---
- true
...
#fio.glob(fio.pathjoin(box.cfg.vinyl_dir, box.space.test.id, 0, '*.index.inprogress')) == 0
---
- true
...
box.space.test:drop()
---
...
-- gh-4276 - check grant privilege rollback
_ = box.schema.user.create('testg')
---
...
_ = box.schema.space.create('testg'):create_index('pk')
---
...
box.error.injection.set('ERRINJ_WAL_IO', true)
---
- ok
...
-- the grant operation above fails and test hasn't any space test permissions
box.schema.user.grant('testg', 'read,write', 'space', 'testg')
---
- error: Failed to write to disk
...
-- switch user and check they couldn't select
box.session.su('testg')
---
...
box.space.testg:select()
---
- error: Read access to space 'testg' is denied for user 'testg'
...
box.session.su('admin')
---
...
box.error.injection.set('ERRINJ_WAL_IO', false)
---
- ok
...
box.schema.user.drop('testg')
---
...
box.space.testg:drop()
---
...
--
-- Errinj:get().
--
box.error.injection.get('bad name')
---
- 'error: can''t find error injection ''bad name'''
...
box.error.injection.set('ERRINJ_WAL_IO', true)
---
- ok
...
box.error.injection.get('ERRINJ_WAL_IO')
---
- true
...
box.error.injection.set('ERRINJ_WAL_IO', false)
---
- ok
...
box.error.injection.get('ERRINJ_WAL_IO')
---
- false
...
box.error.injection.set('ERRINJ_TUPLE_FORMAT_COUNT', 20)
---
- ok
...
box.error.injection.get('ERRINJ_TUPLE_FORMAT_COUNT')
---
- 20
...
box.error.injection.set('ERRINJ_TUPLE_FORMAT_COUNT', -1)
---
- ok
...
box.error.injection.get('ERRINJ_TUPLE_FORMAT_COUNT')
---
- -1
...
box.error.injection.set('ERRINJ_RELAY_TIMEOUT', 0.5)
---
- ok
...
box.error.injection.get('ERRINJ_RELAY_TIMEOUT')
---
- 0.5
...
box.error.injection.set('ERRINJ_RELAY_TIMEOUT', 0)
---
- ok
...
box.error.injection.get('ERRINJ_RELAY_TIMEOUT')
---
- 0
...