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
package main | |
import ( | |
"flag" | |
"fmt" | |
"log" | |
"strings" | |
"sync" | |
"time" | |
"github.com/tarantool/go-tarantool" |
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/misc.cc b/src/box/lua/misc.cc | |
index e356f2d4b996..d82822cef2d1 100644 | |
--- a/src/box/lua/misc.cc | |
+++ b/src/box/lua/misc.cc | |
@@ -90,8 +90,17 @@ port_msgpack_dump_lua(struct port *base, struct lua_State *L, bool is_flat) | |
const char *args = port->data; | |
uint32_t arg_count = mp_decode_array(&args); | |
- for (uint32_t i = 0; i < arg_count; i++) | |
- luamp_decode(L, luaL_msgpack_default, &args); |
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
package main | |
import ( | |
"flag" | |
"fmt" | |
"log" | |
"sync" | |
"time" | |
"github.com/tarantool/go-tarantool" | |
) |
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 == | |
# build msgpuck lib | |
git clone git@github.com:tarantool/msgpuck.git | |
cd msgpuck | |
cmake . -DCMAKE_BUILD_TYPE=RelWithDebInfo | |
cd .. |
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 == | |
# get tncxx lib | |
git clone git@github.com:tarantool/tntcxx.git | |
# build & run the test | |
g++ tnt-bench.cpp -o tnt-bench-cxx -Itntcxx/src -DNDEBUG -lrt -O2 --std=c++17 | |
./tnt-bench-cxx |
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 |
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
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) |
OlderNewer