File Transfer Functions

0th

Percentile

File Transfer Functions

High level functions calling zmq_send() and zmq_recv() to transfer a file in 200 KiB chunks.

Keywords
programming
Usage
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)

Arguments
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 zmq_sendfile and zmq_recvfile

endpoint

A ZMQ socket endpoint.

Details

zmq.sendfile() binds a ZMQ_PUSH socket, and zmq.recvfile() connects to this with a ZMQ_PULL socket.

Value

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.

References

ZeroMQ/4.1.0 API Reference: http://api.zeromq.org/4-1:_start

Programming with Big Data in R Website: http://r-pbd.org/

See Also

zmq.msg.send(), zmq.msg.recv().

Aliases
  • File Transfer Functions
  • zmq.sendfile
  • zmq.recvfile
Examples
# 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)
# }
# NOT RUN {
# }
Documentation reproduced from package pbdZMQ, version 0.3-3, License: GPL-3

Community examples

Looks like there are no examples yet.