coroutine.lua 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997
  1. -- $Id: testes/coroutine.lua $
  2. -- See Copyright Notice in file all.lua
  3. print "testing coroutines"
  4. local debug = require'debug'
  5. local f
  6. local main, ismain = coroutine.running()
  7. assert(type(main) == "thread" and ismain)
  8. assert(not coroutine.resume(main))
  9. assert(not coroutine.isyieldable(main) and not coroutine.isyieldable())
  10. assert(not pcall(coroutine.yield))
  11. -- trivial errors
  12. assert(not pcall(coroutine.resume, 0))
  13. assert(not pcall(coroutine.status, 0))
  14. -- tests for multiple yield/resume arguments
  15. local function eqtab (t1, t2)
  16. assert(#t1 == #t2)
  17. for i = 1, #t1 do
  18. local v = t1[i]
  19. assert(t2[i] == v)
  20. end
  21. end
  22. _G.x = nil -- declare x
  23. function foo (a, ...)
  24. local x, y = coroutine.running()
  25. assert(x == f and y == false)
  26. -- next call should not corrupt coroutine (but must fail,
  27. -- as it attempts to resume the running coroutine)
  28. assert(coroutine.resume(f) == false)
  29. assert(coroutine.status(f) == "running")
  30. local arg = {...}
  31. assert(coroutine.isyieldable(x))
  32. for i=1,#arg do
  33. _G.x = {coroutine.yield(table.unpack(arg[i]))}
  34. end
  35. return table.unpack(a)
  36. end
  37. f = coroutine.create(foo)
  38. assert(coroutine.isyieldable(f))
  39. assert(type(f) == "thread" and coroutine.status(f) == "suspended")
  40. assert(string.find(tostring(f), "thread"))
  41. local s,a,b,c,d
  42. s,a,b,c,d = coroutine.resume(f, {1,2,3}, {}, {1}, {'a', 'b', 'c'})
  43. assert(coroutine.isyieldable(f))
  44. assert(s and a == nil and coroutine.status(f) == "suspended")
  45. s,a,b,c,d = coroutine.resume(f)
  46. eqtab(_G.x, {})
  47. assert(s and a == 1 and b == nil)
  48. assert(coroutine.isyieldable(f))
  49. s,a,b,c,d = coroutine.resume(f, 1, 2, 3)
  50. eqtab(_G.x, {1, 2, 3})
  51. assert(s and a == 'a' and b == 'b' and c == 'c' and d == nil)
  52. s,a,b,c,d = coroutine.resume(f, "xuxu")
  53. eqtab(_G.x, {"xuxu"})
  54. assert(s and a == 1 and b == 2 and c == 3 and d == nil)
  55. assert(coroutine.status(f) == "dead")
  56. s, a = coroutine.resume(f, "xuxu")
  57. assert(not s and string.find(a, "dead") and coroutine.status(f) == "dead")
  58. -- yields in tail calls
  59. local function foo (i) return coroutine.yield(i) end
  60. f = coroutine.wrap(function ()
  61. for i=1,10 do
  62. assert(foo(i) == _G.x)
  63. end
  64. return 'a'
  65. end)
  66. for i=1,10 do _G.x = i; assert(f(i) == i) end
  67. _G.x = 'xuxu'; assert(f('xuxu') == 'a')
  68. -- recursive
  69. function pf (n, i)
  70. coroutine.yield(n)
  71. pf(n*i, i+1)
  72. end
  73. f = coroutine.wrap(pf)
  74. local s=1
  75. for i=1,10 do
  76. assert(f(1, 1) == s)
  77. s = s*i
  78. end
  79. -- sieve
  80. function gen (n)
  81. return coroutine.wrap(function ()
  82. for i=2,n do coroutine.yield(i) end
  83. end)
  84. end
  85. function filter (p, g)
  86. return coroutine.wrap(function ()
  87. while 1 do
  88. local n = g()
  89. if n == nil then return end
  90. if math.fmod(n, p) ~= 0 then coroutine.yield(n) end
  91. end
  92. end)
  93. end
  94. local x = gen(80)
  95. local a = {}
  96. while 1 do
  97. local n = x()
  98. if n == nil then break end
  99. table.insert(a, n)
  100. x = filter(n, x)
  101. end
  102. assert(#a == 22 and a[#a] == 79)
  103. x, a = nil
  104. -- coroutine closing
  105. do
  106. -- ok to close a dead coroutine
  107. local co = coroutine.create(print)
  108. assert(coroutine.resume(co, "testing 'coroutine.close'"))
  109. assert(coroutine.status(co) == "dead")
  110. assert(coroutine.close(co))
  111. -- cannot close the running coroutine
  112. local st, msg = pcall(coroutine.close, coroutine.running())
  113. assert(not st and string.find(msg, "running"))
  114. local main = coroutine.running()
  115. -- cannot close a "normal" coroutine
  116. ;(coroutine.wrap(function ()
  117. local st, msg = pcall(coroutine.close, main)
  118. assert(not st and string.find(msg, "normal"))
  119. end))()
  120. -- to-be-closed variables in coroutines
  121. local X
  122. local function func2close (f)
  123. return setmetatable({}, {__close = f})
  124. end
  125. co = coroutine.create(function ()
  126. local x <close> = func2close(function (self, err)
  127. assert(err == nil); X = false
  128. end)
  129. X = true
  130. coroutine.yield()
  131. end)
  132. coroutine.resume(co)
  133. assert(X)
  134. assert(coroutine.close(co))
  135. assert(not X and coroutine.status(co) == "dead")
  136. -- error closing a coroutine
  137. local x = 0
  138. co = coroutine.create(function()
  139. local y <close> = func2close(function (self,err)
  140. if (err ~= 111) then os.exit(false) end -- should not happen
  141. x = 200
  142. error("200")
  143. end)
  144. local x <close> = func2close(function (self, err)
  145. assert(err == nil); error(111)
  146. end)
  147. coroutine.yield()
  148. end)
  149. coroutine.resume(co)
  150. assert(x == 0)
  151. -- with test library, use 'store' mode to check warnings
  152. warn(not T and "@off" or "@store")
  153. local st, msg = coroutine.close(co)
  154. if not T then
  155. warn("@on")
  156. else -- test library
  157. assert(string.find(_WARN, "200")); _WARN = nil
  158. warn("@normal")
  159. end
  160. assert(st == false and coroutine.status(co) == "dead" and msg == 111)
  161. assert(x == 200)
  162. end
  163. -- yielding across C boundaries
  164. co = coroutine.wrap(function()
  165. assert(not pcall(table.sort,{1,2,3}, coroutine.yield))
  166. assert(coroutine.isyieldable())
  167. coroutine.yield(20)
  168. return 30
  169. end)
  170. assert(co() == 20)
  171. assert(co() == 30)
  172. local f = function (s, i) return coroutine.yield(i) end
  173. local f1 = coroutine.wrap(function ()
  174. return xpcall(pcall, function (...) return ... end,
  175. function ()
  176. local s = 0
  177. for i in f, nil, 1 do pcall(function () s = s + i end) end
  178. error({s})
  179. end)
  180. end)
  181. f1()
  182. for i = 1, 10 do assert(f1(i) == i) end
  183. local r1, r2, v = f1(nil)
  184. assert(r1 and not r2 and v[1] == (10 + 1)*10/2)
  185. function f (a, b) a = coroutine.yield(a); error{a + b} end
  186. function g(x) return x[1]*2 end
  187. co = coroutine.wrap(function ()
  188. coroutine.yield(xpcall(f, g, 10, 20))
  189. end)
  190. assert(co() == 10)
  191. r, msg = co(100)
  192. assert(not r and msg == 240)
  193. -- unyieldable C call
  194. do
  195. local function f (c)
  196. assert(not coroutine.isyieldable())
  197. return c .. c
  198. end
  199. local co = coroutine.wrap(function (c)
  200. assert(coroutine.isyieldable())
  201. local s = string.gsub("a", ".", f)
  202. return s
  203. end)
  204. assert(co() == "aa")
  205. end
  206. do -- testing single trace of coroutines
  207. local X
  208. local co = coroutine.create(function ()
  209. coroutine.yield(10)
  210. return 20;
  211. end)
  212. local trace = {}
  213. local function dotrace (event)
  214. trace[#trace + 1] = event
  215. end
  216. debug.sethook(co, dotrace, "clr")
  217. repeat until not coroutine.resume(co)
  218. local correcttrace = {"call", "line", "call", "return", "line", "return"}
  219. assert(#trace == #correcttrace)
  220. for k, v in pairs(trace) do
  221. assert(v == correcttrace[k])
  222. end
  223. end
  224. -- errors in coroutines
  225. function foo ()
  226. assert(debug.getinfo(1).currentline == debug.getinfo(foo).linedefined + 1)
  227. assert(debug.getinfo(2).currentline == debug.getinfo(goo).linedefined)
  228. coroutine.yield(3)
  229. error(foo)
  230. end
  231. function goo() foo() end
  232. x = coroutine.wrap(goo)
  233. assert(x() == 3)
  234. local a,b = pcall(x)
  235. assert(not a and b == foo)
  236. x = coroutine.create(goo)
  237. a,b = coroutine.resume(x)
  238. assert(a and b == 3)
  239. a,b = coroutine.resume(x)
  240. assert(not a and b == foo and coroutine.status(x) == "dead")
  241. a,b = coroutine.resume(x)
  242. assert(not a and string.find(b, "dead") and coroutine.status(x) == "dead")
  243. -- co-routines x for loop
  244. function all (a, n, k)
  245. if k == 0 then coroutine.yield(a)
  246. else
  247. for i=1,n do
  248. a[k] = i
  249. all(a, n, k-1)
  250. end
  251. end
  252. end
  253. local a = 0
  254. for t in coroutine.wrap(function () all({}, 5, 4) end) do
  255. a = a+1
  256. end
  257. assert(a == 5^4)
  258. -- access to locals of collected corroutines
  259. local C = {}; setmetatable(C, {__mode = "kv"})
  260. local x = coroutine.wrap (function ()
  261. local a = 10
  262. local function f () a = a+10; return a end
  263. while true do
  264. a = a+1
  265. coroutine.yield(f)
  266. end
  267. end)
  268. C[1] = x;
  269. local f = x()
  270. assert(f() == 21 and x()() == 32 and x() == f)
  271. x = nil
  272. collectgarbage()
  273. assert(C[1] == undef)
  274. assert(f() == 43 and f() == 53)
  275. -- old bug: attempt to resume itself
  276. function co_func (current_co)
  277. assert(coroutine.running() == current_co)
  278. assert(coroutine.resume(current_co) == false)
  279. coroutine.yield(10, 20)
  280. assert(coroutine.resume(current_co) == false)
  281. coroutine.yield(23)
  282. return 10
  283. end
  284. local co = coroutine.create(co_func)
  285. local a,b,c = coroutine.resume(co, co)
  286. assert(a == true and b == 10 and c == 20)
  287. a,b = coroutine.resume(co, co)
  288. assert(a == true and b == 23)
  289. a,b = coroutine.resume(co, co)
  290. assert(a == true and b == 10)
  291. assert(coroutine.resume(co, co) == false)
  292. assert(coroutine.resume(co, co) == false)
  293. -- other old bug when attempting to resume itself
  294. -- (trigger C-code assertions)
  295. do
  296. local A = coroutine.running()
  297. local B = coroutine.create(function() return coroutine.resume(A) end)
  298. local st, res = coroutine.resume(B)
  299. assert(st == true and res == false)
  300. local X = false
  301. A = coroutine.wrap(function()
  302. local _ <close> = setmetatable({}, {__close = function () X = true end})
  303. return pcall(A, 1)
  304. end)
  305. st, res = A()
  306. assert(not st and string.find(res, "non%-suspended") and X == true)
  307. end
  308. -- attempt to resume 'normal' coroutine
  309. local co1, co2
  310. co1 = coroutine.create(function () return co2() end)
  311. co2 = coroutine.wrap(function ()
  312. assert(coroutine.status(co1) == 'normal')
  313. assert(not coroutine.resume(co1))
  314. coroutine.yield(3)
  315. end)
  316. a,b = coroutine.resume(co1)
  317. assert(a and b == 3)
  318. assert(coroutine.status(co1) == 'dead')
  319. -- infinite recursion of coroutines
  320. a = function(a) coroutine.wrap(a)(a) end
  321. assert(not pcall(a, a))
  322. a = nil
  323. -- access to locals of erroneous coroutines
  324. local x = coroutine.create (function ()
  325. local a = 10
  326. _G.f = function () a=a+1; return a end
  327. error('x')
  328. end)
  329. assert(not coroutine.resume(x))
  330. -- overwrite previous position of local `a'
  331. assert(not coroutine.resume(x, 1, 1, 1, 1, 1, 1, 1))
  332. assert(_G.f() == 11)
  333. assert(_G.f() == 12)
  334. if not T then
  335. (Message or print)('\n >>> testC not active: skipping yield/hook tests <<<\n')
  336. else
  337. print "testing yields inside hooks"
  338. local turn
  339. function fact (t, x)
  340. assert(turn == t)
  341. if x == 0 then return 1
  342. else return x*fact(t, x-1)
  343. end
  344. end
  345. local A, B = 0, 0
  346. local x = coroutine.create(function ()
  347. T.sethook("yield 0", "", 2)
  348. A = fact("A", 6)
  349. end)
  350. local y = coroutine.create(function ()
  351. T.sethook("yield 0", "", 3)
  352. B = fact("B", 7)
  353. end)
  354. while A==0 or B==0 do -- A ~= 0 when 'x' finishes (similar for 'B','y')
  355. if A==0 then turn = "A"; assert(T.resume(x)) end
  356. if B==0 then turn = "B"; assert(T.resume(y)) end
  357. -- check that traceback works correctly after yields inside hooks
  358. debug.traceback(x)
  359. debug.traceback(y)
  360. end
  361. assert(B // A == 7) -- fact(7) // fact(6)
  362. local line = debug.getinfo(1, "l").currentline + 2 -- get line number
  363. local function foo ()
  364. local x = 10 --<< this line is 'line'
  365. x = x + 10
  366. _G.XX = x
  367. end
  368. -- testing yields in line hook
  369. local co = coroutine.wrap(function ()
  370. T.sethook("setglobal X; yield 0", "l", 0); foo(); return 10 end)
  371. _G.XX = nil;
  372. _G.X = nil; co(); assert(_G.X == line)
  373. _G.X = nil; co(); assert(_G.X == line + 1)
  374. _G.X = nil; co(); assert(_G.X == line + 2 and _G.XX == nil)
  375. _G.X = nil; co(); assert(_G.X == line + 3 and _G.XX == 20)
  376. assert(co() == 10)
  377. -- testing yields in count hook
  378. co = coroutine.wrap(function ()
  379. T.sethook("yield 0", "", 1); foo(); return 10 end)
  380. _G.XX = nil;
  381. local c = 0
  382. repeat c = c + 1; local a = co() until a == 10
  383. assert(_G.XX == 20 and c >= 5)
  384. co = coroutine.wrap(function ()
  385. T.sethook("yield 0", "", 2); foo(); return 10 end)
  386. _G.XX = nil;
  387. local c = 0
  388. repeat c = c + 1; local a = co() until a == 10
  389. assert(_G.XX == 20 and c >= 5)
  390. _G.X = nil; _G.XX = nil
  391. do
  392. -- testing debug library on a coroutine suspended inside a hook
  393. -- (bug in 5.2/5.3)
  394. c = coroutine.create(function (a, ...)
  395. T.sethook("yield 0", "l") -- will yield on next two lines
  396. assert(a == 10)
  397. return ...
  398. end)
  399. assert(coroutine.resume(c, 1, 2, 3)) -- start coroutine
  400. local n,v = debug.getlocal(c, 0, 1) -- check its local
  401. assert(n == "a" and v == 1)
  402. assert(debug.setlocal(c, 0, 1, 10)) -- test 'setlocal'
  403. local t = debug.getinfo(c, 0) -- test 'getinfo'
  404. assert(t.currentline == t.linedefined + 1)
  405. assert(not debug.getinfo(c, 1)) -- no other level
  406. assert(coroutine.resume(c)) -- run next line
  407. v = {coroutine.resume(c)} -- finish coroutine
  408. assert(v[1] == true and v[2] == 2 and v[3] == 3 and v[4] == undef)
  409. assert(not coroutine.resume(c))
  410. end
  411. do
  412. -- testing debug library on last function in a suspended coroutine
  413. -- (bug in 5.2/5.3)
  414. local c = coroutine.create(function () T.testC("yield 1", 10, 20) end)
  415. local a, b = coroutine.resume(c)
  416. assert(a and b == 20)
  417. assert(debug.getinfo(c, 0).linedefined == -1)
  418. a, b = debug.getlocal(c, 0, 2)
  419. assert(b == 10)
  420. end
  421. print "testing coroutine API"
  422. -- reusing a thread
  423. assert(T.testC([[
  424. newthread # create thread
  425. pushvalue 2 # push body
  426. pushstring 'a a a' # push argument
  427. xmove 0 3 2 # move values to new thread
  428. resume -1, 1 # call it first time
  429. pushstatus
  430. xmove 3 0 0 # move results back to stack
  431. setglobal X # result
  432. setglobal Y # status
  433. pushvalue 2 # push body (to call it again)
  434. pushstring 'b b b'
  435. xmove 0 3 2
  436. resume -1, 1 # call it again
  437. pushstatus
  438. xmove 3 0 0
  439. return 1 # return result
  440. ]], function (...) return ... end) == 'b b b')
  441. assert(X == 'a a a' and Y == 'OK')
  442. -- resuming running coroutine
  443. C = coroutine.create(function ()
  444. return T.testC([[
  445. pushnum 10;
  446. pushnum 20;
  447. resume -3 2;
  448. pushstatus
  449. gettop;
  450. return 3]], C)
  451. end)
  452. local a, b, c, d = coroutine.resume(C)
  453. assert(a == true and string.find(b, "non%-suspended") and
  454. c == "ERRRUN" and d == 4)
  455. a, b, c, d = T.testC([[
  456. rawgeti R 1 # get main thread
  457. pushnum 10;
  458. pushnum 20;
  459. resume -3 2;
  460. pushstatus
  461. gettop;
  462. return 4]])
  463. assert(a == coroutine.running() and string.find(b, "non%-suspended") and
  464. c == "ERRRUN" and d == 4)
  465. -- using a main thread as a coroutine
  466. local state = T.newstate()
  467. T.loadlib(state)
  468. assert(T.doremote(state, [[
  469. coroutine = require'coroutine';
  470. X = function (x) coroutine.yield(x, 'BB'); return 'CC' end;
  471. return 'ok']]))
  472. t = table.pack(T.testC(state, [[
  473. rawgeti R 1 # get main thread
  474. pushstring 'XX'
  475. getglobal X # get function for body
  476. pushstring AA # arg
  477. resume 1 1 # 'resume' shadows previous stack!
  478. gettop
  479. setglobal T # top
  480. setglobal B # second yielded value
  481. setglobal A # fist yielded value
  482. rawgeti R 1 # get main thread
  483. pushnum 5 # arg (noise)
  484. resume 1 1 # after coroutine ends, previous stack is back
  485. pushstatus
  486. return *
  487. ]]))
  488. assert(t.n == 4 and t[2] == 'XX' and t[3] == 'CC' and t[4] == 'OK')
  489. assert(T.doremote(state, "return T") == '2')
  490. assert(T.doremote(state, "return A") == 'AA')
  491. assert(T.doremote(state, "return B") == 'BB')
  492. T.closestate(state)
  493. print'+'
  494. end
  495. -- leaving a pending coroutine open
  496. _X = coroutine.wrap(function ()
  497. local a = 10
  498. local x = function () a = a+1 end
  499. coroutine.yield()
  500. end)
  501. _X()
  502. if not _soft then
  503. -- bug (stack overflow)
  504. local j = 2^9
  505. local lim = 1000000 -- (C stack limit; assume 32-bit machine)
  506. local t = {lim - 10, lim - 5, lim - 1, lim, lim + 1}
  507. for i = 1, #t do
  508. local j = t[i]
  509. co = coroutine.create(function()
  510. local t = {}
  511. for i = 1, j do t[i] = i end
  512. return table.unpack(t)
  513. end)
  514. local r, msg = coroutine.resume(co)
  515. assert(not r)
  516. end
  517. co = nil
  518. end
  519. assert(coroutine.running() == main)
  520. print"+"
  521. print"testing yields inside metamethods"
  522. local function val(x)
  523. if type(x) == "table" then return x.x else return x end
  524. end
  525. local mt = {
  526. __eq = function(a,b) coroutine.yield(nil, "eq"); return val(a) == val(b) end,
  527. __lt = function(a,b) coroutine.yield(nil, "lt"); return val(a) < val(b) end,
  528. __le = function(a,b) coroutine.yield(nil, "le"); return a - b <= 0 end,
  529. __add = function(a,b) coroutine.yield(nil, "add");
  530. return val(a) + val(b) end,
  531. __sub = function(a,b) coroutine.yield(nil, "sub"); return val(a) - val(b) end,
  532. __mul = function(a,b) coroutine.yield(nil, "mul"); return val(a) * val(b) end,
  533. __div = function(a,b) coroutine.yield(nil, "div"); return val(a) / val(b) end,
  534. __idiv = function(a,b) coroutine.yield(nil, "idiv");
  535. return val(a) // val(b) end,
  536. __pow = function(a,b) coroutine.yield(nil, "pow"); return val(a) ^ val(b) end,
  537. __mod = function(a,b) coroutine.yield(nil, "mod"); return val(a) % val(b) end,
  538. __unm = function(a,b) coroutine.yield(nil, "unm"); return -val(a) end,
  539. __bnot = function(a,b) coroutine.yield(nil, "bnot"); return ~val(a) end,
  540. __shl = function(a,b) coroutine.yield(nil, "shl");
  541. return val(a) << val(b) end,
  542. __shr = function(a,b) coroutine.yield(nil, "shr");
  543. return val(a) >> val(b) end,
  544. __band = function(a,b)
  545. coroutine.yield(nil, "band")
  546. return val(a) & val(b)
  547. end,
  548. __bor = function(a,b) coroutine.yield(nil, "bor");
  549. return val(a) | val(b) end,
  550. __bxor = function(a,b) coroutine.yield(nil, "bxor");
  551. return val(a) ~ val(b) end,
  552. __concat = function(a,b)
  553. coroutine.yield(nil, "concat");
  554. return val(a) .. val(b)
  555. end,
  556. __index = function (t,k) coroutine.yield(nil, "idx"); return t.k[k] end,
  557. __newindex = function (t,k,v) coroutine.yield(nil, "nidx"); t.k[k] = v end,
  558. }
  559. local function new (x)
  560. return setmetatable({x = x, k = {}}, mt)
  561. end
  562. local a = new(10)
  563. local b = new(12)
  564. local c = new"hello"
  565. local function run (f, t)
  566. local i = 1
  567. local c = coroutine.wrap(f)
  568. while true do
  569. local res, stat = c()
  570. if res then assert(t[i] == undef); return res, t end
  571. assert(stat == t[i])
  572. i = i + 1
  573. end
  574. end
  575. assert(run(function () if (a>=b) then return '>=' else return '<' end end,
  576. {"le", "sub"}) == "<")
  577. assert(run(function () if (a<=b) then return '<=' else return '>' end end,
  578. {"le", "sub"}) == "<=")
  579. assert(run(function () if (a==b) then return '==' else return '~=' end end,
  580. {"eq"}) == "~=")
  581. assert(run(function () return a & b + a end, {"add", "band"}) == 2)
  582. assert(run(function () return 1 + a end, {"add"}) == 11)
  583. assert(run(function () return a - 25 end, {"sub"}) == -15)
  584. assert(run(function () return 2 * a end, {"mul"}) == 20)
  585. assert(run(function () return a ^ 2 end, {"pow"}) == 100)
  586. assert(run(function () return a / 2 end, {"div"}) == 5)
  587. assert(run(function () return a % 6 end, {"mod"}) == 4)
  588. assert(run(function () return a // 3 end, {"idiv"}) == 3)
  589. assert(run(function () return a + b end, {"add"}) == 22)
  590. assert(run(function () return a - b end, {"sub"}) == -2)
  591. assert(run(function () return a * b end, {"mul"}) == 120)
  592. assert(run(function () return a ^ b end, {"pow"}) == 10^12)
  593. assert(run(function () return a / b end, {"div"}) == 10/12)
  594. assert(run(function () return a % b end, {"mod"}) == 10)
  595. assert(run(function () return a // b end, {"idiv"}) == 0)
  596. assert(run(function () return a % b end, {"mod"}) == 10)
  597. assert(run(function () return ~a & b end, {"bnot", "band"}) == ~10 & 12)
  598. assert(run(function () return a | b end, {"bor"}) == 10 | 12)
  599. assert(run(function () return a ~ b end, {"bxor"}) == 10 ~ 12)
  600. assert(run(function () return a << b end, {"shl"}) == 10 << 12)
  601. assert(run(function () return a >> b end, {"shr"}) == 10 >> 12)
  602. assert(run(function () return 10 & b end, {"band"}) == 10 & 12)
  603. assert(run(function () return a | 2 end, {"bor"}) == 10 | 2)
  604. assert(run(function () return a ~ 2 end, {"bxor"}) == 10 ~ 2)
  605. assert(run(function () return a..b end, {"concat"}) == "1012")
  606. assert(run(function() return a .. b .. c .. a end,
  607. {"concat", "concat", "concat"}) == "1012hello10")
  608. assert(run(function() return "a" .. "b" .. a .. "c" .. c .. b .. "x" end,
  609. {"concat", "concat", "concat"}) == "ab10chello12x")
  610. do -- a few more tests for comparsion operators
  611. local mt1 = {
  612. __le = function (a,b)
  613. coroutine.yield(10)
  614. return (val(a) <= val(b))
  615. end,
  616. __lt = function (a,b)
  617. coroutine.yield(10)
  618. return val(a) < val(b)
  619. end,
  620. }
  621. local mt2 = { __lt = mt1.__lt, __le = mt1.__le }
  622. local function run (f)
  623. local co = coroutine.wrap(f)
  624. local res
  625. repeat
  626. res = co()
  627. until res ~= 10
  628. return res
  629. end
  630. local function test ()
  631. local a1 = setmetatable({x=1}, mt1)
  632. local a2 = setmetatable({x=2}, mt2)
  633. assert(a1 < a2)
  634. assert(a1 <= a2)
  635. assert(1 < a2)
  636. assert(1 <= a2)
  637. assert(2 > a1)
  638. assert(2 >= a2)
  639. return true
  640. end
  641. run(test)
  642. end
  643. assert(run(function ()
  644. a.BB = print
  645. return a.BB
  646. end, {"nidx", "idx"}) == print)
  647. -- getuptable & setuptable
  648. do local _ENV = _ENV
  649. f = function () AAA = BBB + 1; return AAA end
  650. end
  651. g = new(10); g.k.BBB = 10;
  652. debug.setupvalue(f, 1, g)
  653. assert(run(f, {"idx", "nidx", "idx"}) == 11)
  654. assert(g.k.AAA == 11)
  655. print"+"
  656. print"testing yields inside 'for' iterators"
  657. local f = function (s, i)
  658. if i%2 == 0 then coroutine.yield(nil, "for") end
  659. if i < s then return i + 1 end
  660. end
  661. assert(run(function ()
  662. local s = 0
  663. for i in f, 4, 0 do s = s + i end
  664. return s
  665. end, {"for", "for", "for"}) == 10)
  666. -- tests for coroutine API
  667. if T==nil then
  668. (Message or print)('\n >>> testC not active: skipping coroutine API tests <<<\n')
  669. print "OK"; return
  670. end
  671. print('testing coroutine API')
  672. local function apico (...)
  673. local x = {...}
  674. return coroutine.wrap(function ()
  675. return T.testC(table.unpack(x))
  676. end)
  677. end
  678. local a = {apico(
  679. [[
  680. pushstring errorcode
  681. pcallk 1 0 2;
  682. invalid command (should not arrive here)
  683. ]],
  684. [[return *]],
  685. "stackmark",
  686. error
  687. )()}
  688. assert(#a == 4 and
  689. a[3] == "stackmark" and
  690. a[4] == "errorcode" and
  691. _G.status == "ERRRUN" and
  692. _G.ctx == 2) -- 'ctx' to pcallk
  693. local co = apico(
  694. "pushvalue 2; pushnum 10; pcallk 1 2 3; invalid command;",
  695. coroutine.yield,
  696. "getglobal status; getglobal ctx; pushvalue 2; pushstring a; pcallk 1 0 4; invalid command",
  697. "getglobal status; getglobal ctx; return *")
  698. assert(co() == 10)
  699. assert(co(20, 30) == 'a')
  700. a = {co()}
  701. assert(#a == 10 and
  702. a[2] == coroutine.yield and
  703. a[5] == 20 and a[6] == 30 and
  704. a[7] == "YIELD" and a[8] == 3 and
  705. a[9] == "YIELD" and a[10] == 4)
  706. assert(not pcall(co)) -- coroutine is dead now
  707. f = T.makeCfunc("pushnum 3; pushnum 5; yield 1;")
  708. co = coroutine.wrap(function ()
  709. assert(f() == 23); assert(f() == 23); return 10
  710. end)
  711. assert(co(23,16) == 5)
  712. assert(co(23,16) == 5)
  713. assert(co(23,16) == 10)
  714. -- testing coroutines with C bodies
  715. f = T.makeCfunc([[
  716. pushnum 102
  717. yieldk 1 U2
  718. cannot be here!
  719. ]],
  720. [[ # continuation
  721. pushvalue U3 # accessing upvalues inside a continuation
  722. pushvalue U4
  723. return *
  724. ]], 23, "huu")
  725. x = coroutine.wrap(f)
  726. assert(x() == 102)
  727. eqtab({x()}, {23, "huu"})
  728. f = T.makeCfunc[[pushstring 'a'; pushnum 102; yield 2; ]]
  729. a, b, c, d = T.testC([[newthread; pushvalue 2; xmove 0 3 1; resume 3 0;
  730. pushstatus; xmove 3 0 0; resume 3 0; pushstatus;
  731. return 4; ]], f)
  732. assert(a == 'YIELD' and b == 'a' and c == 102 and d == 'OK')
  733. -- testing chain of suspendable C calls
  734. local count = 3 -- number of levels
  735. f = T.makeCfunc([[
  736. remove 1; # remove argument
  737. pushvalue U3; # get selection function
  738. call 0 1; # call it (result is 'f' or 'yield')
  739. pushstring hello # single argument for selected function
  740. pushupvalueindex 2; # index of continuation program
  741. callk 1 -1 .; # call selected function
  742. errorerror # should never arrive here
  743. ]],
  744. [[
  745. # continuation program
  746. pushnum 34 # return value
  747. return * # return all results
  748. ]],
  749. function () -- selection function
  750. count = count - 1
  751. if count == 0 then return coroutine.yield
  752. else return f
  753. end
  754. end
  755. )
  756. co = coroutine.wrap(function () return f(nil) end)
  757. assert(co() == "hello") -- argument to 'yield'
  758. a = {co()}
  759. -- three '34's (one from each pending C call)
  760. assert(#a == 3 and a[1] == a[2] and a[2] == a[3] and a[3] == 34)
  761. -- testing yields with continuations
  762. co = coroutine.wrap(function (...) return
  763. T.testC([[ # initial function
  764. yieldk 1 2
  765. cannot be here!
  766. ]],
  767. [[ # 1st continuation
  768. yieldk 0 3
  769. cannot be here!
  770. ]],
  771. [[ # 2nd continuation
  772. yieldk 0 4
  773. cannot be here!
  774. ]],
  775. [[ # 3th continuation
  776. pushvalue 6 # function which is last arg. to 'testC' here
  777. pushnum 10; pushnum 20;
  778. pcall 2 0 0 # call should throw an error and return to next line
  779. pop 1 # remove error message
  780. pushvalue 6
  781. getglobal status; getglobal ctx
  782. pcallk 2 2 5 # call should throw an error and jump to continuation
  783. cannot be here!
  784. ]],
  785. [[ # 4th (and last) continuation
  786. return *
  787. ]],
  788. -- function called by 3th continuation
  789. function (a,b) x=a; y=b; error("errmsg") end,
  790. ...
  791. )
  792. end)
  793. local a = {co(3,4,6)}
  794. assert(a[1] == 6 and a[2] == undef)
  795. a = {co()}; assert(a[1] == undef and _G.status == "YIELD" and _G.ctx == 2)
  796. a = {co()}; assert(a[1] == undef and _G.status == "YIELD" and _G.ctx == 3)
  797. a = {co(7,8)};
  798. -- original arguments
  799. assert(type(a[1]) == 'string' and type(a[2]) == 'string' and
  800. type(a[3]) == 'string' and type(a[4]) == 'string' and
  801. type(a[5]) == 'string' and type(a[6]) == 'function')
  802. -- arguments left from fist resume
  803. assert(a[7] == 3 and a[8] == 4)
  804. -- arguments to last resume
  805. assert(a[9] == 7 and a[10] == 8)
  806. -- error message and nothing more
  807. assert(a[11]:find("errmsg") and #a == 11)
  808. -- check arguments to pcallk
  809. assert(x == "YIELD" and y == 4)
  810. assert(not pcall(co)) -- coroutine should be dead
  811. -- bug in nCcalls
  812. local co = coroutine.wrap(function ()
  813. local a = {pcall(pcall,pcall,pcall,pcall,pcall,pcall,pcall,error,"hi")}
  814. return pcall(assert, table.unpack(a))
  815. end)
  816. local a = {co()}
  817. assert(a[10] == "hi")
  818. print'OK'