File Transfer Functions {pbdZMQ} | R Documentation |
High level functions calling zmq_send()
and zmq_recv()
to transfer a file in 200 KiB chunks.
zmq.sendfile(port, filename, verbose = FALSE, flags = .pbd_env$ZMQ.SR$BLOCK) zmq.recvfile(port, endpoint, filename, verbose = FALSE, flags = .pbd_env$ZMQ.SR$BLOCK)
port |
A valid tcp port. |
filename |
The name (as a string) of the in/out files. |
verbose |
logical; determines if a progress bar should be shown. |
flags |
a flag for the method used by |
endpoint |
A ZMQ socket endpoint. |
zmq.sendfile()
binds a ZMQ_PUSH
socket, and
zmq.recvfile()
connects to this with a ZMQ_PULL
socket.
zmq.sendfile()
and zmq.recvfile()
return
number of bytes (invisible) in the sent message if successful,
otherwise returns -1 (invisible) and sets errno
to the error
value, see ZeroMQ manual for details.
Drew Schmidt and Christian Heckendorf
ZeroMQ/4.1.0 API Reference: http://api.zeromq.org/4-1:_start
Programming with Big Data in R Website: http://r-pbd.org/
zmq.msg.send()
, zmq.msg.recv()
.
## Not run: ### Run the sender and receiver code in separate R sessions. # Receiver library(pbdZMQ, quietly = TRUE) zmq.recvfile(55555, "localhost", "/tmp/outfile", verbose=TRUE) # Sender library(pbdZMQ, quietly = TRUE) zmq.sendfile(55555, "/tmp/infile", verbose=TRUE) ## End(Not run)