diff options
author | Eric Wong <normalperson@yhbt.net> | 2013-09-01 02:06:51 +0000 |
---|---|---|
committer | Eric Wong <normalperson@yhbt.net> | 2013-09-01 02:12:13 +0000 |
commit | 0208f3bfd132d58c31d5db06db6378277fa71c7b (patch) | |
tree | 8ed0c5b21b7bc12f7f7f891a6454a88014bdc29b /lib/dtas/player | |
parent | 53b984b1e054a0804884ee83e2debe5baea8a222 (diff) | |
download | dtas-0208f3bfd132d58c31d5db06db6378277fa71c7b.tar.gz |
This helps in case dtas-player is hit with SIGKILL or the system crashes. This does not fsync(2) as that could introduce delays on slow filesystems. Users should open the file manually and fsync themselves if they need to.
Diffstat (limited to 'lib/dtas/player')
-rw-r--r-- | lib/dtas/player/client_handler.rb | 21 |
1 files changed, 21 insertions, 0 deletions
diff --git a/lib/dtas/player/client_handler.rb b/lib/dtas/player/client_handler.rb index f601d46..bbdc1c5 100644 --- a/lib/dtas/player/client_handler.rb +++ b/lib/dtas/player/client_handler.rb @@ -479,5 +479,26 @@ module DTAS::Player::ClientHandler # :nodoc: # echo(%W(cd msg[0])) # should we broadcast this? io.emit("OK") end + + def state_file_handler(io, msg) + case msg.shift + when "dump" + dest = msg.shift + if dest + sf = DTAS::StateFile.new(dest, false) + elsif @state_file + sf = @state_file + dest = sf.path + else + return io.emit("ERR no state file configured") + end + begin + sf.dump(self) + rescue => e + return io.emit("ERR dumping to #{xs(Array(dest))} #{e.message}") + end + end + io.emit("OK") + end end # :startdoc: |