1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
-- test-run result file version 2
fiber = require 'fiber'
| ---
| ...
net = require('net.box')
| ---
| ...
--
-- gh-3107: fiber-async netbox.
--
cond = nil
| ---
| ...
box.schema.func.create('long_function')
| ---
| ...
box.schema.user.grant('guest', 'execute', 'function', 'long_function')
| ---
| ...
function long_function(...) cond = fiber.cond() cond:wait() return ... end
| ---
| ...
function finalize_long() while not cond do fiber.sleep(0.01) end cond:signal() cond = nil end
| ---
| ...
s = box.schema.create_space('test')
| ---
| ...
pk = s:create_index('pk')
| ---
| ...
s:replace{1}
| ---
| - [1]
| ...
s:replace{2}
| ---
| - [2]
| ...
s:replace{3}
| ---
| - [3]
| ...
s:replace{4}
| ---
| - [4]
| ...
c = net:connect(box.cfg.listen)
| ---
| ...
--
-- Check infinity timeout.
--
ret = nil
| ---
| ...
_ = fiber.create(function() ret = c:call('long_function', {1, 2, 3}, {is_async = true}):wait_result() end)
| ---
| ...
finalize_long()
| ---
| ...
while not ret do fiber.sleep(0.01) end
| ---
| ...
ret
| ---
| - [1, 2, 3]
| ...
c:close()
| ---
| ...
box.schema.user.grant('guest', 'execute', 'universe')
| ---
| ...
c = net:connect(box.cfg.listen)
| ---
| ...
future = c:eval('return long_function(...)', {1, 2, 3}, {is_async = true})
| ---
| ...
future:result()
| ---
| - null
| - Response is not ready
| ...
future:wait_result(0.01) -- Must fail on timeout.
| ---
| - null
| - Timeout exceeded
| ...
finalize_long()
| ---
| ...
future:wait_result(100)
| ---
| - [1, 2, 3]
| ...
c:close()
| ---
| ...
--
-- Check that is_async does not work on a closed connection.
--
c:call('any_func', {}, {is_async = true})
| ---
| - error: Connection closed
| ...
box.schema.user.revoke('guest', 'execute', 'universe')
| ---
| ...
c = net:connect(box.cfg.listen)
| ---
| ...
c:close()
| ---
| ...
s:drop()
| ---
| ...
|
