import spread, time, struct

mbox = spread.connect('4803@localhost', membership=0)
group = 'test'
mbox.join(group)
x = 0
cnt = 0
for i in range(1000):
  ebfFile = open('muon-5_1.ebf', 'rb')
  while 1:
    data = ebfFile.read(8)
    if len(data) < 8:
      ebfFile.close()
      break
    print cnt
    cnt += 1
    (identity, length) = struct.unpack('!LL', data)
    data += ebfFile.read(length - 8)
    time.sleep(.001)
    x += mbox.multicast(spread.RELIABLE_MESS | spread.SELF_DISCARD, group, data[8:], cnt)
mbox.leave('test')
mbox.disconnect()
print x