This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/src/lua/init.c b/src/lua/init.c | |
index c9dc6a49ac93..97d5dfdd2fd4 100644 | |
--- a/src/lua/init.c | |
+++ b/src/lua/init.c | |
@@ -828,6 +828,32 @@ luaT_set_module_from_source(struct lua_State *L, const char *modname, | |
lua_pop(L, 1); /* modfile */ | |
} | |
+struct varbinary { | |
+ size_t len; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/************************ BUILD & RUN ************************ | |
gcc tnt-lost-msg.c -o tnt-lost-msg \ | |
-I$TARANTOOL_C_INCLUDE -L$TARANTOOL_C_LIB -ltarantool && \ | |
LD_LIBRARY_PATH=$TARANTOOL_C_LIB ./tnt-lost-msg | |
*************************************************************/ | |
#include <err.h> | |
#include <stddef.h> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
clock = require('clock') | |
fiber = require('fiber') | |
net_box = require('net.box') | |
jit_p = require('jit.p') | |
cpuprof = require('gperftools.cpu') | |
URI = '127.0.0.1:3301' | |
ITERATIONS = 1000 | |
CONCURRENCY = 2000 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
clock = require('clock') | |
fiber = require('fiber') | |
net_box = require('net.box') | |
URI = '127.0.0.1:3301' | |
SPACE = 'T' | |
TIMEOUT = 5 | |
ITERATIONS = 3000 | |
CONCURRENCY = 2000 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/src/CMakeLists.txt b/src/CMakeLists.txt | |
index 324574fec748..1f55c37b0766 100644 | |
--- a/src/CMakeLists.txt | |
+++ b/src/CMakeLists.txt | |
@@ -117,7 +117,6 @@ set (server_sources | |
lua/digest.c | |
lua/init.c | |
lua/fiber.c | |
- lua/fiber_cond.c | |
lua/fiber_channel.c |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/src/box/lua/net_box.lua b/src/box/lua/net_box.lua | |
index 3878abf21914..04e3f6c6b5a2 100644 | |
--- a/src/box/lua/net_box.lua | |
+++ b/src/box/lua/net_box.lua | |
@@ -367,7 +367,7 @@ local function create_transport(host, port, user, password, callback, | |
local timeout = iterator.timeout | |
repeat | |
local ts = fiber_clock() | |
- request.cond:wait(timeout) | |
+ fiber.sleep(timeout) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
clock = require('clock') | |
fiber = require('fiber') | |
net_box = require('net.box') | |
function test(n_args) | |
print('==== TEST(' .. n_args .. ' ARGS) ====') | |
local call_args = {} | |
for i = 1, n_args do | |
table.insert(call_args, {i, 123, {i, "abc", "def"}}) | |
end |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
clock = require('clock') | |
fiber = require('fiber') | |
net_box = require('net.box') | |
function test(method) | |
print('==== TEST(' .. method .. ') ====') | |
local conn = net_box.connect('127.0.0.1:3301') | |
local n_iters = 500 | |
local n_reqs_per_iter = 2000 | |
local n_reqs = n_iters * n_reqs_per_iter |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/src/box/lua/net_box.c b/src/box/lua/net_box.c | |
index 3f43872ca2e4..edd7ea90b4c7 100644 | |
--- a/src/box/lua/net_box.c | |
+++ b/src/box/lua/net_box.c | |
@@ -38,13 +38,16 @@ | |
#include "box/iproto_constants.h" | |
#include "box/lua/tuple.h" /* luamp_convert_tuple() / luamp_convert_key() */ | |
#include "box/xrow.h" | |
+#include "box/xrow_io.h" | |
#include "box/tuple.h" |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
clock = require('clock') | |
fiber = require('fiber') | |
net_box = require('net.box') | |
function test(method) | |
print('==== TEST(' .. method .. ') ====') | |
local conn = net_box.connect('127.0.0.1:3301') | |
local n_iters = 500 | |
local n_reqs_per_iter = 2000 | |
local n_reqs = n_iters * n_reqs_per_iter |
NewerOlder