A replacement for the "ridgeway" component of the Pilatus system, using a zero-MQ stream in place of the filesystem copy operation which was previously used. This will need two components: a source running on the PPU and a sink running on a good GPFS connected host machine, with a decent ethernet (i.e. TCP/IP) connection between them.

On the HOST machine run:

python3 source.py

This will push the data as multipart messages on a stream for files found on the working directory.

On the filesystem-mounted machine run

python3 sink.py source-host-name

Which will fetch the files and write them locally with the full filename they were delivered with.

N.B. at the moment this is a copy not a move: it needs to remove the files at the source end otherwise they will keep getting sent, and the source end also needs a while loop to keep sending files.