diff options
Diffstat (limited to '')
-rw-r--r-- | src/lanes.lua | 12 |
1 files changed, 2 insertions, 10 deletions
diff --git a/src/lanes.lua b/src/lanes.lua index 42e946b..b6fbc08 100644 --- a/src/lanes.lua +++ b/src/lanes.lua | |||
@@ -45,8 +45,6 @@ local mm = require "lua51-lanes" | |||
45 | assert( type(mm)=="table" ) | 45 | assert( type(mm)=="table" ) |
46 | 46 | ||
47 | 47 | ||
48 | local linda_id= assert( mm.linda_id ) | ||
49 | |||
50 | local thread_new= assert(mm.thread_new) | 48 | local thread_new= assert(mm.thread_new) |
51 | local thread_status= assert(mm.thread_status) | 49 | local thread_status= assert(mm.thread_status) |
52 | local thread_join= assert(mm.thread_join) | 50 | local thread_join= assert(mm.thread_join) |
@@ -55,8 +53,6 @@ local thread_cancel= assert(mm.thread_cancel) | |||
55 | local _single= assert(mm._single) | 53 | local _single= assert(mm._single) |
56 | local _version= assert(mm._version) | 54 | local _version= assert(mm._version) |
57 | 55 | ||
58 | local _deep_userdata= assert(mm._deep_userdata) | ||
59 | |||
60 | local now_secs= assert( mm.now_secs ) | 56 | local now_secs= assert( mm.now_secs ) |
61 | local wakeup_conv= assert( mm.wakeup_conv ) | 57 | local wakeup_conv= assert( mm.wakeup_conv ) |
62 | local timer_gateway= assert( mm.timer_gateway ) | 58 | local timer_gateway= assert( mm.timer_gateway ) |
@@ -336,11 +332,7 @@ end | |||
336 | ----- | 332 | ----- |
337 | -- linda_ud= lanes.linda() | 333 | -- linda_ud= lanes.linda() |
338 | -- | 334 | -- |
339 | function linda() | 335 | linda = mm.linda |
340 | local proxy= _deep_userdata( linda_id ) | ||
341 | assert( (type(proxy) == "userdata") and getmetatable(proxy) ) | ||
342 | return proxy | ||
343 | end | ||
344 | 336 | ||
345 | 337 | ||
346 | ---=== Timers ===--- | 338 | ---=== Timers ===--- |
@@ -505,7 +497,7 @@ if first_time then | |||
505 | -- We let the timer lane be a "free running" thread; no handle to it | 497 | -- We let the timer lane be a "free running" thread; no handle to it |
506 | -- remains. | 498 | -- remains. |
507 | -- | 499 | -- |
508 | gen( "io", { priority=max_prio, globals={threadName="LanesTimer"} }, function() | 500 | gen( "io,package", { priority=max_prio, globals={threadName="LanesTimer"} }, function() |
509 | 501 | ||
510 | while true do | 502 | while true do |
511 | local next_wakeup= check_timers() | 503 | local next_wakeup= check_timers() |