commit 3de17a6d16e524d8417650a238cb76c8929b08ad from: ligurio date: Sun May 14 14:12:44 2023 UTC Deploying to gh-pages from @ ligurio/molly@460ff864d3aaef9f9ccb267ee77c055b2bfcf03d 🚀 commit - 2417f237d54f9807fde5da34c86d136373b676bb commit + 3de17a6d16e524d8417650a238cb76c8929b08ad blob - bc6c754120b828f70baba3052e5680475ff9acf7 blob + 9bf28a2b020b993929c1427670a0c48e49cb39c1 --- examples/sqlite-list-append.lua.html +++ examples/sqlite-list-append.lua.html @@ -33,29 +33,29 @@

Examples

sqlite-rw-register.lua
sqlite-list-append.lua

Modules

molly.client
molly.thread_coroutine
molly.thread_fiber
molly.db
molly.gen

Topics

README

sqlite-list-append.lua

+     -- https://www.sqlite.org/isolation.html
 -- https://www.sqlite.org/threadsafe.html
 -- https://www.sqlite.org/atomiccommit.html
@@ -105,7 +104,7 @@
 sqlite_list_append.open = function(self)
     self.db = assert(sqlite3.open_memory(), 'database handle is nil')
     if self.db == nil then
-        error('database handle is nil')
+        error('database handle is nil')
     end
     -- See explanation in https://www.sqlite.org/pragma.html
     assert(sqlite3.OK == self.db:exec('PRAGMA journal_mode = WAL'))
@@ -140,7 +139,7 @@ sqlite_list_append.invoke = func
             type = 'fail'
         end
     else
-        error('Unknown operation')
+        error('Unknown operation')
     end
 
     return {
@@ -187,8 +186,7 @@ sqlite_list_append.close = funct

-generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2

Examples

sqlite-rw-register.lua
sqlite-list-append.lua

Modules

molly.client
molly.thread_coroutine
molly.thread_fiber
molly.db
molly.gen

Topics

README

sqlite-rw-register.lua

+     -- https://www.sqlite.org/isolation.html
 -- https://www.sqlite.org/threadsafe.html
 -- https://www.sqlite.org/atomiccommit.html
@@ -157,7 +156,7 @@ sqlite_rw_register.invoke = func
             type = 'fail'
         end
     else
-        error('Unknown operation')
+        error('Unknown operation')
     end
 
     return {
@@ -208,8 +207,7 @@ sqlite_rw_register.close = funct

-generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2

Modules

molly.client
molly.thread_coroutine
molly.thread_fiber
molly.db
molly.gen

Topics

README

Examples

Modules

molly.client	Module with default Molly client.	molly.tests	Module with test generators and checkers.
molly.thread_coroutine	Module with implementation of threads based on coroutines.	molly.runner	Module with main functions that runs tests.
molly.thread_fiber	Module with implementation of threads based on fibers.
molly.db	Module with default DB implementation.
molly.gen	Module with functions for generators.
molly.history	Module with functions that processes history of operations.
molly.utils	Helpers.
molly.op	Module with helpers that processes operations.
molly.gen	Module with functions for generators.
molly.client	Module with default Molly client.
molly	Framework for distributed system's verification, with fault injection.
molly.log	Module with functions for logging.	molly.db	Module with default DB implementation.
molly.thread_fiber	Module with implementation of threads based on fibers.
molly.thread_coroutine	Module with implementation of threads based on coroutines.
molly.nemesis	Module with nemeses.
molly.op	Module with helpers that processes operations.
molly.runner	Module with main functions that runs tests.
molly.tests	Module with test generators and checkers.
molly.thread	Module with thread implementation.
molly.utils	Helpers.	molly.log	Module with functions for logging.

Topics

-generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2

Modules

molly.client
molly.thread_coroutine
molly.thread_fiber
molly.db
molly.gen

Topics

README

Examples

Functions

@@ -139,10 +133,11 @@
Usage:

-
local client = require('molly').client.new() -client.invoke = function(op) - return true -end
+
+ local client = require('molly').client.new() + client.invoke = function(op) + return true + end

@@ -152,8 +147,7 @@ client.invoke = function(
-generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2
blob - f9d8c4b98a06f50e95c038e8b012917ec8457ed3 blob + 2e5f15affcd019f07070705c00e55dabf7811a42 --- modules/molly.db.html +++ modules/molly.db.html @@ -37,28 +37,28 @@
Modules
-
-
molly.client
-
molly.thread_coroutine
-
molly.thread_fiber
-
molly.db
-
molly.gen
+
+
molly.tests
+
molly.runner

molly.history
+
molly.utils
+
molly.op
+
molly.gen
+
molly.client

molly
-
molly.log
+
molly.db
+
molly.thread_fiber
+
molly.thread_coroutine

molly.nemesis
-
molly.op
-
molly.runner
-
molly.tests

molly.thread
-
molly.utils
+
molly.log

Topics
-
+

README

Examples
-
+

sqlite-rw-register.lua

sqlite-list-append.lua

@@ -84,8 +84,7 @@
-
Functions
- +
Functions

@@ -121,8 +120,7 @@
-generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2
blob - c33fb7f8a9cab839a7793957717cb2acf1cf9647 blob + 8164d94d6dceb392d73fd550440b38f8dcd194c6 --- modules/molly.gen.html +++ modules/molly.gen.html @@ -48,28 +48,28 @@
Modules
-
-
molly.client
-
molly.thread_coroutine
-
molly.thread_fiber
-
molly.db
-
molly.gen
+
+
molly.tests
+
molly.runner

molly.history
+
molly.utils
+
molly.op
+
molly.gen
+
molly.client

molly
-
molly.log
+
molly.db
+
molly.thread_fiber
+
molly.thread_coroutine

molly.nemesis
-
molly.op
-
molly.runner
-
molly.tests

molly.thread
-
molly.utils
+
molly.log

Topics
-
+

README

Examples
-
+

sqlite-rw-register.lua

sqlite-list-append.lua

@@ -99,19 +99,17 @@
Example of generator that generates two operations w and r:
+
local w = function() return { f = 'w', v = math.random(1, 10) } end +local r = function() return { f = 'r', v = nil } end +gen.rands(0, 2):map(function(x) + return (x == 0 and r()) or + (x == 1 and w())) + end):take(100) -
-local w = function() return { f = 'w', v = math.random(1, 10) } end -local r = function() return { f = 'r', v = nil } end -gen.rands(0, 2):map(function(x) - return (x == 0 and r()) or - (x == 1 and w())) - end):take(100) +local w = function(x) return { f = 'w', v = x } end +gen.map(w, gen.rands(1, 10):take(50)) +
-local w = function(x) return { f = 'w', v = x } end -gen.map(w, gen.rands(1, 10):take(50)) -
-
References:

@@ -120,11 +118,8 @@ gen.map(w, gen.rands(1, Lua iterators tutorial
Jepsen generators in a nutshell

+
-
See also:
-
- molly.op -

Basic Functions
@@ -281,7 +276,7 @@ gen.map(w, gen.rands(1, grep () - If regexp_or_predicate is string then the parameter is used as a regular + If regexporpredicate is string then the parameter is used as a regular expression to build filtering predicate. @@ -423,7 +418,7 @@ gen.map(w, gen.rands(1, -
Basic Functions
+
Basic Functions

@@ -456,26 +451,27 @@ gen.map(w, gen.rands(1, Usage:
-
> for _it, v in gen.iter({1, 2, 3}) do print(v) end -1 -2 -3 ---- -... +
+ > for _it, v in gen.iter({1, 2, 3}) do print(v) end + 1 + 2 + 3 + --- + ... -> for _it, v in gen.iter({a = 1, b = 2, c = 3}) do print(v) end -b -a -c ---- -... + > for _it, v in gen.iter({a = 1, b = 2, c = 3}) do print(v) end + b + a + c + --- + ... -> for _it, v in gen.iter("abc") do print(v) end -a -b -c ---- -...
+ > for _it, v in gen.iter("abc") do print(v) end + a + b + c + --- + ...

@@ -514,12 +510,14 @@ c
Usage:

-
> gen.each(print, { a = 1, b = 2, c = 3}) -b 2 -a 1 -c 3 ---- -...
+
+ + > gen.each(print, { a = 1, b = 2, c = 3}) + b 2 + a 1 + c 3 + --- + ...

@@ -529,7 +527,7 @@ c 3

~~An alias for each(). - See gen.each. + See gen.each . @@ -544,7 +542,7 @@ c 3~~

~~An alias for each(). - See gen.each. + See gen.each . @@ -554,7 +552,7 @@ c 3~~

-
Generators: Finite Generators
+
Generators: Finite Generators

@@ -565,8 +563,8 @@ c 3 The iterator to create arithmetic progressions. Iteration values are generated within closed interval [start, stop] (i.e. stop is included). If the start argument is omitted, it defaults to 1 (stop - > 0) or to -1 (stop < 0). If the step argument is omitted, it defaults to 1 - (start <= stop) or to -1 (start > stop). If step is positive, the last + > 0) or to -1 (stop < 0). If the step argument is omitted, it defaults to 1 + (start <= stop) or to -1 (start > stop). If step is positive, the last element is the largest start + i * step less than or equal to stop; if step is negative, the last element is the smallest start + i * step greater than or equal to stop. step must not be zero (or else an error is raised). @@ -579,7 +577,6 @@ c 3
start number – an endpoint of the interval. - (optional)

stop number @@ -588,7 +585,6 @@ c 3
step number – a step. - (optional)

@@ -602,27 +598,28 @@ c 3
Usage:

-
> for _it, v in gen.range(1, 6) do print(v) end -1 -2 -3 -4 -5 -6 ---- -... +
+ > for _it, v in gen.range(1, 6) do print(v) end + 1 + 2 + 3 + 4 + 5 + 6 + --- + ... -> for _it, v in gen.range(1, 6, 2) do print(v) end -1 -3 -5 ---- -...
+ > for _it, v in gen.range(1, 6, 2) do print(v) end + 1 + 3 + 5 + --- + ...

-
Generators: Infinity Generators
+
Generators: Infinity Generators

@@ -641,12 +638,13 @@ c 3
Usage:

-
> gen.each(print, gen.take(3, gen.duplicate('a', 'b', 'c'))) -a b c -a b c -a b c ---- -...
+
+ > gen.each(print, gen.take(3, gen.duplicate('a', 'b', 'c'))) + a b c + a b c + a b c + --- + ...

@@ -656,7 +654,7 @@ a b c

An alias for duplicate(). - See gen.duplicate. + See gen.duplicate . @@ -671,7 +669,7 @@ a b c
An alias for duplicate(). - See gen.duplicate. + See gen.duplicate . @@ -696,7 +694,7 @@ a b c

-
Generators: Random sampling
+
Generators: Random sampling

@@ -704,17 +702,18 @@ a b c rands ()

- See fun.rands. + See fun.rands. +

-
Slicing: Subsequences
+
Slicing: Subsequences

@@ -722,98 +721,105 @@ a b c take_n ()

- See fun.take_n. + See fun.take_n. +

take_while ()

- See fun.take_while. + See fun.take_while. +

take ()

- See fun.take. + See fun.take. +

drop_n ()

- See fun.drop_n. + See fun.drop_n. +

drop_while ()

- See fun.drop_while. + See fun.drop_while. +

drop ()

- See fun.drop. + See fun.drop. +

span ()

- See fun.span. + See fun.span. +

@@ -846,7 +852,7 @@ a b c
-
Indexing
+
Indexing

@@ -854,14 +860,15 @@ a b c index ()

- See fun.index. + See fun.index. +

@@ -898,14 +905,15 @@ a b c indexes ()

- See fun.indexes. + See fun.indexes. +

@@ -953,7 +961,7 @@ a b c
-
Filtering
+
Filtering

@@ -977,7 +985,7 @@ a b c

An alias for filter(). - See gen.filter. + See gen.filter . @@ -991,7 +999,7 @@ a b c grep ()
- If regexp_or_predicate is string then the parameter is used as a regular + If regexporpredicate is string then the parameter is used as a regular expression to build filtering predicate. Otherwise the function is just an alias for gen.filter(). See fun.grep. @@ -1020,7 +1028,7 @@ a b c

-
Reducing: Folds
+
Reducing: Folds

@@ -1045,7 +1053,7 @@ a b c

An alias to foldl(). - See gen.foldl. + See gen.foldl . @@ -1100,7 +1108,7 @@ a b c

-
Reducing: Predicates
+
Reducing: Predicates

@@ -1108,42 +1116,45 @@ a b c is_prefix_of ()

- See fun.isprefixof. + See fun.isprefixof. +

is_null ()

- See fun.is_null. + See fun.is_null. +

all ()

- See fun.all. + See fun.all. +

@@ -1165,14 +1176,15 @@ a b c any ()

- See fun.any. + See fun.any. +

@@ -1190,7 +1202,7 @@ a b c
-
Transformations
+
Transformations

@@ -1198,45 +1210,48 @@ a b c map ()

- See fun.map. + See fun.map. +

enumerate ()

- See fun.enumerate. + See fun.enumerate. +

intersperse ()

- See fun.intersperse. + See fun.intersperse. +

-
Compositions
+
Compositions

@@ -1342,19 +1357,20 @@ a b c
Usage:

-
> fun.each(print, fun.chain(fun.range(5, 1, -1), fun.range(1, 5))) -5 -4 -3 -2 -1 -1 -2 -3 -4 -5 ---- -...
+
+ > fun.each(print, fun.chain(fun.range(5, 1, -1), fun.range(1, 5))) + 5 + 4 + 3 + 2 + 1 + 1 + 2 + 3 + 4 + 5 + --- + ...

@@ -1455,7 +1471,7 @@ a b c
-
Special generators
+
Special generators

@@ -1531,21 +1547,22 @@ a b c
Usage:

-
> for _it, v in gen.time_limit(gen.range(1, 100), 0.0001) do print(v) end -1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 ---- -...
+
+ > for _it, v in gen.time_limit(gen.range(1, 100), 0.0001) do print(v) end + 1 + 2 + 3 + 4 + 5 + 6 + 7 + 8 + 9 + 10 + 11 + 12 + --- + ...

@@ -1555,8 +1572,7 @@ a b c
-generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2
blob - 742be2a05d0cfff43e25fbbf1e2a48292ac52423 blob + e4083832fa03ae021cbaa4508d61c7a1c3cc4f05 --- modules/molly.history.html +++ modules/molly.history.html @@ -33,28 +33,28 @@
Modules
-
-
molly.client
-
molly.thread_coroutine
-
molly.thread_fiber
-
molly.db
-
molly.gen
+
+
molly.tests
+
molly.runner

molly.history
+
molly.utils
+
molly.op
+
molly.gen
+
molly.client

molly
-
molly.log
+
molly.db
+
molly.thread_fiber
+
molly.thread_coroutine

molly.nemesis
-
molly.op
-
molly.runner
-
molly.tests

molly.thread
-
molly.utils
+
molly.log

Topics
-
+

README

Examples
-
+

sqlite-rw-register.lua

sqlite-list-append.lua

@@ -80,8 +80,7 @@
-generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2
blob - 568f1e9e455935cb07cdcd04cb622266707935e8 blob + 1c8d2ff3c526aafcaf11a335dc4a536241677309 --- modules/molly.html +++ modules/molly.html @@ -33,28 +33,28 @@
Modules
-
-
molly.client
-
molly.thread_coroutine
-
molly.thread_fiber
-
molly.db
-
molly.gen
+
+
molly.tests
+
molly.runner

molly.history
+
molly.utils
+
molly.op
+
molly.gen
+
molly.client

molly
-
molly.log
+
molly.db
+
molly.thread_fiber
+
molly.thread_coroutine

molly.nemesis
-
molly.op
-
molly.runner
-
molly.tests

molly.thread
-
molly.utils
+
molly.log

Topics
-
+

README

Examples
-
+

sqlite-rw-register.lua

sqlite-list-append.lua

@@ -86,8 +86,7 @@
-generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2
blob - 1c8c87237fa4d65188c5a78427ce5d7a563e1ad5 blob + cb9d5f00220f5f74af7d9d295c99aaa60a127076 --- modules/molly.log.html +++ modules/molly.log.html @@ -37,28 +37,28 @@
Modules
-
-
molly.client
-
molly.thread_coroutine
-
molly.thread_fiber
-
molly.db
-
molly.gen
+
+
molly.tests
+
molly.runner

molly.history
+
molly.utils
+
molly.op
+
molly.gen
+
molly.client

molly
-
molly.log
+
molly.db
+
molly.thread_fiber
+
molly.thread_coroutine

molly.nemesis
-
molly.op
-
molly.runner
-
molly.tests

molly.thread
-
molly.utils
+
molly.log

Topics
-
+

README

Examples
-
+

sqlite-rw-register.lua

sqlite-list-append.lua

@@ -106,8 +106,7 @@
-
Functions
- +
Functions

@@ -120,7 +119,7 @@
Parameters:

message - string + string Message.

@@ -146,7 +145,7 @@
Parameters:

message - string + string Message.

@@ -161,9 +160,10 @@
Usage:

-
> local log = require('molly.log') -> log.debug('Total planned requests: 1010') -[DEBUG 2021-12-1 12:26:8:689379] /home/sergeyb/sources/molly/jepsen/runner.lua:80: Total planned requests: 1010
+
+ > local log = require('molly.log') + > log.debug('Total planned requests: 1010') + [DEBUG 2021-12-1 12:26:8:689379] /home/sergeyb/sources/molly/jepsen/runner.lua:80: Total planned requests: 1010

@@ -178,7 +178,7 @@
Parameters:

message - string + string Message.

@@ -193,9 +193,10 @@
Usage:

-
> local log = require('molly.log') -> log.info('Message') -[INFO 2021-12-7 13:17:46:073544]: Message
+
+ > local log = require('molly.log') + > log.info('Message') + [INFO 2021-12-7 13:17:46:073544]: Message

@@ -210,7 +211,7 @@
Parameters:

message - string + string Message.

@@ -225,9 +226,10 @@
Usage:

-
> local log = require('jepsen.log') -> log.warn('Message') -[WARN 2021-12-7 13:17:46:073544]: Message
+
+ > local log = require('jepsen.log') + > log.warn('Message') + [WARN 2021-12-7 13:17:46:073544]: Message

@@ -242,7 +244,7 @@
Parameters:

message - string + string Message.

@@ -268,7 +270,7 @@
Parameters:

message - string + string Message.

@@ -289,8 +291,7 @@
-generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2
blob - 093afd504e9125e1c451d933a39caa90800fa685 blob + c2799bee3786bdf5f4e4e32bcc735fb854a6dd11 --- modules/molly.nemesis.html +++ modules/molly.nemesis.html @@ -37,28 +37,28 @@
Modules
-
-
molly.client
-
molly.thread_coroutine
-
molly.thread_fiber
-
molly.db
-
molly.gen
+
+
molly.tests
+
molly.runner

molly.history
+
molly.utils
+
molly.op
+
molly.gen
+
molly.client

molly
-
molly.log
+
molly.db
+
molly.thread_fiber
+
molly.thread_coroutine

molly.nemesis
-
molly.op
-
molly.runner
-
molly.tests

molly.thread
-
molly.utils
+
molly.log

Topics
-
+

README

Examples
-
+

sqlite-rw-register.lua

sqlite-list-append.lua

@@ -75,12 +75,9 @@
A nemesis is a process that will be fed operations from a generator process and then take action against the system accordingly.
- -
-{ type = "info", f = "start", process = { "nemesis", time = 5326396898, index = 169 }} -{ type = "info", f = "start", process = { "nemesis", time = 5328551016, index = 170 }} -
- +
{ type = "info", f = "start", process = { "nemesis", time = 5326396898, index = 169 }} +{ type = "info", f = "start", process = { "nemesis", time = 5328551016, index = 170 }} +

@@ -96,8 +93,7 @@
-
Functions
- +
Functions

@@ -124,8 +120,7 @@
-generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2
blob - 3e224c576ac60013c01a2dd9f8eab1d224ee0918 blob + 84b62ec3da7609e4b1e8bb9b8e0cf37da691765c --- modules/molly.op.html +++ modules/molly.op.html @@ -33,28 +33,28 @@
Modules
-
-
molly.client
-
molly.thread_coroutine
-
molly.thread_fiber
-
molly.db
-
molly.gen
+
+
molly.tests
+
molly.runner

molly.history
+
molly.utils
+
molly.op
+
molly.gen
+
molly.client

molly
-
molly.log
+
molly.db
+
molly.thread_fiber
+
molly.thread_coroutine

molly.nemesis
-
molly.op
-
molly.runner
-
molly.tests

molly.thread
-
molly.utils
+
molly.log

Topics
-
+

README

Examples
-
+

sqlite-rw-register.lua

sqlite-list-append.lua

@@ -77,15 +77,13 @@
An observed history should be a list of operations in real-time order, where each operation is a map of the form:
+
{ + type One of <code>invoke</code>, <code>ok</code>, <code>info</code>, <code>fail</code>. + process A logical identifier for a single thread of execution. + value A transaction; structure and semantics vary. + } +
-
-{ - type One of invoke, ok, info, fail. - process A logical identifier for a single thread of execution. - value A transaction; structure and semantics vary. -} -
-
Each process should perform alternating invoke and ok, info, fail operations. ok indicates the operation definitely committed. fail indicates it definitely did not occur - e.g. it was aborted, was never @@ -106,38 +104,33 @@
For example an operation with 'read' action, value is 'nil' because it is unknown before invoking of operation:
- -
-{ - f = 'read', - value = nil, +
{ + f = 'read', + value = nil, } -4 ok read {0 5, 1 10, 2 12, 8 10, 9 17} -4 invoke read nil -3 ok read {0 5, 1 9, 2 12, 3 10, 4 11} -3 invoke read nil -
+4 ok read {0 5, 1 10, 2 12, 8 10, 9 17} +4 invoke read nil +3 ok read {0 5, 1 9, 2 12, 3 10, 4 11} +3 invoke read nil +

or operation with 'transfer' action for test that transfers money between accounts:
- -
-{ - f = 'transfer', +
{ + f = 'transfer', value = { - from = math.random(1, 10), - to = math.random(1, 10), - amount = math.random(1, 100), + from = math.random(1, 10), + to = math.random(1, 10), + amount = math.random(1, 100), } } -3 ok transfer {from = 8, to = 2, amount = 3} -0 ok transfer {from = 1, to = 9, amount = 1} -0 invoke transfer {from = 3, to = 9, amount = 5} -
- +3 ok transfer {from = 8, to = 2, amount = 3} +0 ok transfer {from = 1, to = 9, amount = 1} +0 invoke transfer {from = 3, to = 9, amount = 5} +

@@ -151,8 +144,7 @@
-generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2
blob - dffbb740a7cd0639722483fc59205ab966d9cb74 blob + 76f2952022a95cf38777200d23fd1d0b2a0e8c24 --- modules/molly.runner.html +++ modules/molly.runner.html @@ -37,28 +37,28 @@
Modules
-
-
molly.client
-
molly.thread_coroutine
-
molly.thread_fiber
-
molly.db
-
molly.gen
+
+
molly.tests
+
molly.runner

molly.history
+
molly.utils
+
molly.op
+
molly.gen
+
molly.client

molly
-
molly.log
+
molly.db
+
molly.thread_fiber
+
molly.thread_coroutine

molly.nemesis
-
molly.op
-
molly.runner
-
molly.tests

molly.thread
-
molly.utils
+
molly.log

Topics
-
+

README

Examples
-
+

sqlite-rw-register.lua

sqlite-list-append.lua

@@ -78,30 +78,31 @@ remote access to log into a bunch of DB nodes, where it sets up the distributed system you're going to test or use local DB instances.
-
+-------------+ - +------- | controller | -------+ - | +-------------+ | - | | | | | - | +----+ | | | - v v | | v - +----+----+----+ | | +----+----+ - | n1 | n2 | n3 | <+ +> | n4 | n5 | - +----+----+----+ +----+----+ +`` + +-------------+ ++------- | controller | -------+ +| +-------------+ | +| | | | | +| +----+ | | | +v v | | v + +----+----+----+ | | +----+----+ + | n1 | n2 | n3 | <+ +> | n4 | n5 | + +----+----+----+ +----+----+ +` - Once the system is running, the control node spins up a set of logically - single-threaded processes (see molly.thread), each with its own client for + single-threaded processes (see molly.thread), each with its own client for the distributed system. - A generator (see molly.gen) generates new operations (see molly.op) + A generator (see molly.gen) generates new operations (see molly.op) for each process to perform. Processes then apply those operations to the - system using their clients, see molly.client. The start and end of each - operation is recorded in a history, see molly.history. While performing - operations, a special nemesis process (see molly.nemesis) introduces + system using their clients, see molly.client. The start and end of each + operation is recorded in a history, see molly.history. While performing + operations, a special nemesis process (see molly.nemesis) introduces faults into the system - also scheduled by the generator. - Finally, the DB is turn down. Molly uses a checker (see molly.checker) + Finally, the DB is turn down. Molly uses a checker (see molly.checker) to analyze the test's history for correctness, and to generate reports, graphs, etc. The test, history, analysis, and any supplementary results are written to the filesystem for later review. @@ -111,13 +112,13 @@ Performance Tips Disable debug mode: by default tests enables type checking, see - statements with dev_checks() in source code, and code coverage gathering. - This requires using Lua debug module, that can significantly slowdown of + statements with dev_checks() in source code, and code coverage gathering. + This requires using Lua debug module, that can significantly slowdown of execution (about 1.6 times). You can control it with environment variable - DEV, to run tests with disabled type checking and code coverage: `DEV=OFF - make test`. + DEV, to run tests with disabled type checking and code coverage: DEV=OFF + make test. - Disable verbose mode: see description of verbose mode. + Disable verbose mode: see description of verbose` mode. Use fibers: TODO: performance of fibers vs coroutines. @@ -135,8 +136,7 @@ - Functions - + Functions @@ -152,17 +152,16 @@ client Workload client. Learn more about creating clients in - molly.client. + molly.client . generator - table + table Generator of operations used in test workload. Generator must be a table with unwrap() method that returns an iterator - triplet. You can make generator youself or use molly.gen module. + triplet. You can make generator youself or use molly.gen module. checker Function for checking history in workload. - (optional) opts Table with test options. @@ -179,13 +178,11 @@
- (optional) threads number Number of threads in a test workload, default value is 1. - (optional) verbose boolean @@ -194,36 +191,32 @@ obvious. For example, if you want to see the progress of testing as it setup, teardown or invokes operations, you can use the 'verbose' option. In the beginning, you may find it useful to use 'verbose' at all times; when - you are more accustomed to molly, you will likely want to use it at + you are more accustomed to molly , you will likely want to use it at certain times but not at others. Disabled by default. Take into account that logging to standart output is a slow operation and - with enabled verbose mode molly logs status of every operation before + with enabled verbose mode molly logs status of every operation before and after it's invocation and this may slowdown overall testing performance significantly. It is recommended to disable verbose mode in a final testing and use it only for debugging. - (optional) thread_type - string + string Type of threads used in a test workload. - Possible values are 'fiber' (see molly.thread_fiber) and 'coroutine' (see - molly.thread_coroutine), default value is 'fiber' on Tarantool and + Possible values are 'fiber' (see molly.thread_fiber ) and 'coroutine' (see + molly.thread_coroutine ), default value is 'fiber' on Tarantool and 'coroutine' on LuaJIT. Learn more about possible thread types in - molly.thread. - (optional) + molly.thread . time_limit number Number of seconds to limit time of testing. By default testing time is endless and limited by a number of operations produced by generator. - (optional) nodes - table + table A table that contains IP addresses of nodes participated in testing. - (optional)
@@ -243,18 +236,20 @@ Usage: - local test_options = { - create_reports = true, - thread_type = 'fiber', - threads = 5, - nodes = { - '127.0.0.1' - } -} -local ok, err = runner.run_test({ - client = client.new(), - generator = gen_lib.cycle(gen_lib.iter({ r, w })):take(1000) -}, test_options) + + + local test_options = { + create_reports = true, + thread_type = 'fiber', + threads = 5, + nodes = { + '127.0.0.1' + } + } + local ok, err = runner.run_test({ + client = client.new(), + generator = gen_lib.cycle(gen_lib.iter({ r, w })):take(1000) + }, test_options) @@ -264,8 +259,7 @@ -generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2 blob - 2daef3853dcd8a5067510e527e0ff41fe4fa2828 blob + 71c653c64559b34e3a3dd6fea8918cfee53525a6 --- modules/molly.tests.html +++ modules/molly.tests.html @@ -37,28 +37,28 @@ Modules - - molly.client - molly.thread_coroutine - molly.thread_fiber - molly.db - molly.gen + + molly.tests + molly.runner molly.history + molly.utils + molly.op + molly.gen + molly.client molly - molly.log + molly.db + molly.thread_fiber + molly.thread_coroutine molly.nemesis - molly.op - molly.runner - molly.tests molly.thread - molly.utils + molly.log Topics - + README Examples - + sqlite-rw-register.lua sqlite-list-append.lua @@ -92,33 +92,27 @@ to whatever the present value of the given list is). We detect cycles in these transactions using Elle's cycle-detection system. - Generator molly.tests.list_append_gen produces an operations + Generator molly.tests.list_append_gen produces an operations compatible with Molly: + { index = 2, type = "invoke", value = {{ "append", 255, 8 } { "r", 253, null }}} + { index = 3, type = "ok", value = {{ "append", 255, 8 } { "r", 253, { 1, 3, 4 }}}} + { index = 4, type = "invoke", value = {{ "append", 256, 4 } { "r", 255, null } { "r", 256, nil } { "r", 253, null }}} + { index = 5, type = "ok", value = {{ "append", 256, 4 } { "r", 255, { 2, 3, 4, 5, 8 }} { "r", 256, { 1, 2, 4 }} {{ "r", 253, { 1, 3, 4 }}}} + { index = 6, type = "invoke", value = {{ "append", 250, 10 } { "r", 253, null }{ "r", 255, null } { "append", 256, 3 }}} + --{ index = 2, type = "invoke", value = {{ "append", 255, 8 } { "r", 253, null }}} -{ index = 3, type = "ok", value = {{ "append", 255, 8 } { "r", 253, { 1, 3, 4 }}}} -{ index = 4, type = "invoke", value = {{ "append", 256, 4 } { "r", 255, null } { "r", 256, nil } { "r", 253, null }}} -{ index = 5, type = "ok", value = {{ "append", 256, 4 } { "r", 255, { 2, 3, 4, 5, 8 }} { "r", 256, { 1, 2, 4 }} {{ "r", 253, { 1, 3, 4 }}}} -{ index = 6, type = "invoke", value = {{ "append", 250, 10 } { "r", 253, null }{ "r", 255, null } { "append", 256, 3 }}} - - A partial test, including a generator and checker. You'll need to provide a client which can understand operations of the form: + { type = "invoke", f = "txn", value = {{ "r", 3, null } { "append", 3, 2 } { "r", 3, null }}} + --{ type = "invoke", f = "txn", value = {{ "r", 3, null } { "append", 3, 2 } { "r", 3, null }}} - - and return completions like: + { type = "invoke", f = "txn", value = {{ "r", 3, { 1 }} { "append", 3, 2 } { "r", 3, { 1, 2 }}}} + --{ type = "invoke", f = "txn", value = {{ "r", 3, { 1 }} { "append", 3, 2 } { "r", 3, { 1, 2 }}}} - - where the key 3 identifies some list, whose value is initially [1], and becomes [1 2]. @@ -134,22 +128,18 @@ Operations are of two forms: + { "r", "x", 1 } denotes a read of <code>x</code> observing the value 1. + { "w", "x", 2 } denotes a write of <code>x</code>, settings its value to 2. + --{ "r", "x", 1 } denotes a read of x observing the value 1. -{ "w", "x", 2 } denotes a write of x, settings its value to 2. - - Example of history: + { type = "invoke", f = "txn", value = {{ "w", "x", 1 }}, process = 0, index = 1} + { type = "ok", f = "txn", value = {{ "w", "x", 1 }}, process = 0, index = 2} + { type = "invoke", f = "txn", value = {{ "r", "x", null }}, process = 0, index = 3} + { type = "ok", f = "txn", value = {{ "r", "x", 2 }}, process = 0, index = 4} + --{ type = "invoke", f = "txn", value = {{ "w", "x", 1 }}, process = 0, index = 1} -{ type = "ok", f = "txn", value = {{ "w", "x", 1 }}, process = 0, index = 2} -{ type = "invoke", f = "txn", value = {{ "r", "x", null }}, process = 0, index = 3} -{ type = "ok", f = "txn", value = {{ "r", "x", 2 }}, process = 0, index = 4} - - Note that in Lua associative array is an array that can be indexed not only with numbers, but also with strings or any other value of the language, except nil. Null values in Lua tables are represented as JSON null @@ -174,8 +164,7 @@ - Functions - + Functions @@ -196,21 +185,23 @@ Usage: - > log = require('log') -> tests = require('molly.tests') -> for _it, v in tests.rw_register_gen() do log.info(v()) end -{"f":"txn","value":[["r","x",null]]} -{"f":"txn","value":[["w","x",58]]} -{"f":"txn","value":[["r","x",null]]} -{"f":"txn","value":[["w","x",80]]} -{"f":"txn","value":[["r","x",null]]} -{"f":"txn","value":[["w","x",46]]} -{"f":"txn","value":[["r","x",null]]} -{"f":"txn","value":[["w","x",19]]} -{"f":"txn","value":[["r","x",null]]} -{"f":"txn","value":[["w","x",66]]} ---- -... + + + > log = require('log') + > tests = require('molly.tests') + > for _it, v in tests.rw_register_gen() do log.info(v()) end + {"f":"txn","value":[["r","x",null]]} + {"f":"txn","value":[["w","x",58]]} + {"f":"txn","value":[["r","x",null]]} + {"f":"txn","value":[["w","x",80]]} + {"f":"txn","value":[["r","x",null]]} + {"f":"txn","value":[["w","x",46]]} + {"f":"txn","value":[["r","x",null]]} + {"f":"txn","value":[["w","x",19]]} + {"f":"txn","value":[["r","x",null]]} + {"f":"txn","value":[["w","x",66]]} + --- + ... @@ -233,25 +224,21 @@ number Number of distinct keys at any point. Default is 3. - (optional) min_txn_len number Minimum number of operations per txn. Default is 1. - (optional) max_txn_len number Maximum number of operations per txn. Default is 2. - (optional) max_writes_per_key number Maximum number of operations per key. Default is 32. - (optional) @@ -266,21 +253,23 @@ Usage: - > log = require('log') -> tests = require('molly.tests') -> for _it, v in tests.list_append_gen() do log.info(v()) end -{"f":"txn","value":[["r",3,null]]} -{"f":"txn","value":[["append",3,1]]} -{"f":"txn","value":[["r",2,null]]} -{"f":"txn","value":[["append",3,2]]} -{"f":"txn","value":[["r",1,null]]} -{"f":"txn","value":[["append",2,3]]} -{"f":"txn","value":[["r",2,null]]} -{"f":"txn","value":[["append",3,4]]} -{"f":"txn","value":[["r",2,null]]} -{"f":"txn","value":[["append",2,5]]} ---- -... + + + > log = require('log') + > tests = require('molly.tests') + > for _it, v in tests.list_append_gen() do log.info(v()) end + {"f":"txn","value":[["r",3,null]]} + {"f":"txn","value":[["append",3,1]]} + {"f":"txn","value":[["r",2,null]]} + {"f":"txn","value":[["append",3,2]]} + {"f":"txn","value":[["r",1,null]]} + {"f":"txn","value":[["append",2,3]]} + {"f":"txn","value":[["r",2,null]]} + {"f":"txn","value":[["append",3,4]]} + {"f":"txn","value":[["r",2,null]]} + {"f":"txn","value":[["append",2,5]]} + --- + ... @@ -290,8 +279,7 @@ -generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2 blob - d2706e07ba8f89abc64e687b9c0909721bf4bfec blob + b34f814eaee8f6608347fa4808b56383fc25f491 --- modules/molly.thread.html +++ modules/molly.thread.html @@ -33,28 +33,28 @@ Modules - - molly.client - molly.thread_coroutine - molly.thread_fiber - molly.db - molly.gen + + molly.tests + molly.runner molly.history + molly.utils + molly.op + molly.gen + molly.client molly - molly.log + molly.db + molly.thread_fiber + molly.thread_coroutine molly.nemesis - molly.op - molly.runner - molly.tests molly.thread - molly.utils + molly.log Topics - + README Examples - + sqlite-rw-register.lua sqlite-list-append.lua @@ -85,8 +85,7 @@ -generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2 blob - 69665a9a221d325132a231059fa118ca81cc9d1e blob + ef8078673db21a2acd747eab5358e19501307d15 --- modules/molly.thread_coroutine.html +++ modules/molly.thread_coroutine.html @@ -33,28 +33,28 @@ Modules - - molly.client - molly.thread_coroutine - molly.thread_fiber - molly.db - molly.gen + + molly.tests + molly.runner molly.history + molly.utils + molly.op + molly.gen + molly.client molly - molly.log + molly.db + molly.thread_fiber + molly.thread_coroutine molly.nemesis - molly.op - molly.runner - molly.tests molly.thread - molly.utils + molly.log Topics - + README Examples - + sqlite-rw-register.lua sqlite-list-append.lua @@ -89,8 +89,7 @@ -generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2 blob - b59e9ca584d63d7e63dc28dd1d02f0026d727910 blob + a3de0d36736b179e2495c4fe356b2caeeb0dc75f --- modules/molly.thread_fiber.html +++ modules/molly.thread_fiber.html @@ -33,28 +33,28 @@ Modules - - molly.client - molly.thread_coroutine - molly.thread_fiber - molly.db - molly.gen + + molly.tests + molly.runner molly.history + molly.utils + molly.op + molly.gen + molly.client molly - molly.log + molly.db + molly.thread_fiber + molly.thread_coroutine molly.nemesis - molly.op - molly.runner - molly.tests molly.thread - molly.utils + molly.log Topics - + README Examples - + sqlite-rw-register.lua sqlite-list-append.lua @@ -106,8 +106,7 @@ -generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2 blob - 28991a412a882b12dd0a6c5ab9375868189d40e9 blob + 368232d57a32dccd24651c3a93e39aae7edbac1d --- modules/molly.utils.html +++ modules/molly.utils.html @@ -37,28 +37,28 @@ Modules - - molly.client - molly.thread_coroutine - molly.thread_fiber - molly.db - molly.gen + + molly.tests + molly.runner molly.history + molly.utils + molly.op + molly.gen + molly.client molly - molly.log + molly.db + molly.thread_fiber + molly.thread_coroutine molly.nemesis - molly.op - molly.runner - molly.tests molly.thread - molly.utils + molly.log Topics - + README Examples - + sqlite-rw-register.lua sqlite-list-append.lua @@ -107,8 +107,7 @@ - Functions - + Functions @@ -121,11 +120,11 @@ Parameters: key - string + string Variable name. value - string + string Variable value. @@ -172,7 +171,7 @@ Parameters: dir - string + string @@ -219,7 +218,7 @@ Parameters: path - string + string @@ -262,8 +261,7 @@ -generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2 blob - f15fa2ebca4bbb9027e04af5b4765fc65cd61df7 blob + 0a378792e675a1f0dd3b4096c2fca403494105a3 --- topics/README.md.html +++ topics/README.md.html @@ -37,28 +37,28 @@ Topics - + README Modules - - molly.client - molly.thread_coroutine - molly.thread_fiber - molly.db - molly.gen + + molly.tests + molly.runner molly.history + molly.utils + molly.op + molly.gen + molly.client molly - molly.log + molly.db + molly.thread_fiber + molly.thread_coroutine molly.nemesis - molly.op - molly.runner - molly.tests molly.thread - molly.utils + molly.log Examples - + sqlite-rw-register.lua sqlite-list-append.lua @@ -101,7 +101,8 @@ -$ luarocks install --local --server=https://luarocks.org/dev molly +$ luarocks install --local --server=https://luarocks.org/dev molly + @@ -123,9 +124,9 @@ $ make deps-runtime See also an examples in test/examples/ for SQLite database engine: -- sqlite-rw-register.lua contains a simple test that concurrently runs get +- sqlite-rw-register.lua contains a simple test that concurrently runs get and set operations on SQLite DB -- sqlite-list-append.lua contains a simple test that concurrently runs read +- sqlite-list-append.lua contains a simple test that concurrently runs read and append operations on SQLite DB For running examples you need installed an SQLite development package and @@ -157,7 +158,7 @@ history.json true Hacking -For developing molly you need to install: either LuaJIT or LuaJIT-based + For developing molly you need to install: either LuaJIT or LuaJIT-based and LuaRocks. @@ -180,8 +181,7 @@ $ make test -generated by LDoc 1.4.6 -Last updated 2023-05-14 13:53:06 +generated by LDoc 1.4.2

Examples

Modules

Topics

sqlite-list-append.lua

Examples

Modules

Topics

sqlite-rw-register.lua

Modules

Topics

Examples

Modules

Topics

Modules

Topics

Examples

See also:

Functions

Functions

Functions

Usage:

Modules

Topics

Examples

Functions

Functions

Modules

Topics

Examples

References:

See also:

Basic Functions

Basic Functions

Basic Functions

Usage:

Generators: Finite Generators

Generators: Finite Generators

Usage:

Generators: Infinity Generators

Generators: Infinity Generators

Usage:

Generators: Random sampling

Generators: Random sampling

Slicing: Subsequences

Slicing: Subsequences

Indexing

Indexing

Filtering

Filtering

Reducing: Folds

Reducing: Folds

Reducing: Predicates

Reducing: Predicates

Transformations

Transformations

Compositions

Compositions

Usage:

Special generators

Special generators

Usage:

Modules

Topics

Examples

Modules

Topics

Examples

Modules

Topics

Examples

Functions

Functions

Parameters:

Parameters:

Usage:

Parameters:

Usage:

Parameters:

Usage:

Parameters: