# File lib/raindrops/aggregate/pmq.rb, line 162 def flush_master dump = Marshal.dump @aggregate synchronize(@wr, WRLOCK) do |wr| wr.truncate 0 IO.pwrite wr.fileno, dump, 0 end end