This repository has been archived by the owner on Mar 12, 2024. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 12
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(arbitration): improve lua prototype
* Rename `utils.log` to `utils.helper` * Fastforward blockchain when all players idle
- Loading branch information
1 parent
b560f3c
commit c86a81e
Showing
5 changed files
with
166 additions
and
78 deletions.
There are no files selected for viewing
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
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
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
93 changes: 93 additions & 0 deletions
93
onchain/permissionless-arbitration/offchain/utils/helper.lua
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,93 @@ | ||
| local color = require "utils.color" | ||
|
|
||
| local names = {'green', 'yellow', 'blue', 'pink', 'cyan', 'white'} | ||
| local idle_template = [[ls player%d_idle 2> /dev/null | grep player%d_idle | wc -l]] | ||
| local ps_template = [[ps %s | grep defunct | wc -l]] | ||
|
|
||
| local function log(player_index, msg) | ||
| local color_index = (player_index - 1) % #names + 1 | ||
| local timestamp = os.date("%m/%d/%Y %X") | ||
| print(color.reset .. color.fg[names[color_index]] .. string.format("[#%d][%s] %s", player_index, timestamp, msg) .. color.reset) | ||
| end | ||
|
|
||
| local function log_to_ts(reader, last_ts) | ||
| -- print everything hold in the buffer which has smaller timestamp | ||
| -- this is to synchronise when there're gaps in between the logs | ||
| local msg_output = 0 | ||
| while true do | ||
| local msg = reader:read() | ||
| if msg then | ||
| msg_output = msg_output + 1 | ||
| print(msg) | ||
|
|
||
| local i, j = msg:find("%d%d/%d%d/%d%d%d%d %d%d:%d%d:%d%d") | ||
| if i and j then | ||
| local timestamp = msg:sub(i, j) | ||
| if timestamp > last_ts then | ||
| last_ts = timestamp | ||
| break | ||
| end | ||
| end | ||
| else | ||
| break | ||
| end | ||
| end | ||
| return last_ts, msg_output | ||
| end | ||
|
|
||
| local function is_zombie(pid) | ||
| local reader = io.popen(string.format(ps_template, pid)) | ||
| ret = reader:read() | ||
| reader:close() | ||
| return tonumber(ret) == 1 | ||
| end | ||
|
|
||
| local function stop_players(pid_reader) | ||
| for pid, reader in pairs(pid_reader) do | ||
| print(string.format("Stopping player with pid %s...", pid)) | ||
| os.execute(string.format("kill -15 %s", pid)) | ||
| reader:close() | ||
| print "Player stopped" | ||
| end | ||
| end | ||
|
|
||
| local function touch_player_idle(player_index) | ||
| os.execute(string.format("touch player%d_idle", player_index)) | ||
| end | ||
|
|
||
| local function is_player_idle(player_index) | ||
| local reader = io.popen(string.format(idle_template, player_index, player_index)) | ||
| ret = reader:read() | ||
| reader:close() | ||
| return tonumber(ret) == 1 | ||
| end | ||
|
|
||
| local function rm_player_idle(player_index) | ||
| os.execute(string.format("rm player%d_idle", player_index)) | ||
| end | ||
|
|
||
| local function all_players_idle(pid_player) | ||
| for pid, player in pairs(pid_player) do | ||
| if not is_player_idle(player) then | ||
| return false | ||
| end | ||
| end | ||
| return true | ||
| end | ||
|
|
||
| local function rm_all_players_idle(pid_player) | ||
| for pid, player in pairs(pid_player) do | ||
| rm_player_idle(player) | ||
| end | ||
| return true | ||
| end | ||
|
|
||
| return { | ||
| log = log, | ||
| log_to_ts = log_to_ts, | ||
| is_zombie = is_zombie, | ||
| stop_players = stop_players, | ||
| touch_player_idle = touch_player_idle, | ||
| all_players_idle = all_players_idle, | ||
| rm_all_players_idle = rm_all_players_idle | ||
| } |
This file was deleted.
Oops, something went wrong.