doc/lab0/socket__example__3_8cc_source.html

 // create a pair of stream sockets

 std::array<int, 2> fds{};

 SystemCall("socketpair", ::socketpair(AF_UNIX, SOCK_STREAM, 0, fds.data()));

 LocalStreamSocket pipe1{FileDescriptor(fds[0])}, pipe2{FileDescriptor(fds[1])};


 pipe1.write("hi there");

 auto recvd = pipe2.read();


 pipe2.write("hi yourself");

 auto recvd2 = pipe1.read();


 if (recvd != "hi there" || recvd2 != "hi yourself") {

     throw std::runtime_error("wrong data received");

 }

std::array

FileDescriptor
A reference-counted handle to a file descriptor.
Definition: file_descriptor.hh:12

FileDescriptor::write
size_t write(const char *str, const bool write_all=true)
Write a string, possibly blocking until all is written.
Definition: file_descriptor.hh:65

FileDescriptor::read
std::string read(const size_t limit=std::numeric_limits< size_t >::max())
Read up to limit bytes.

LocalStreamSocket
A wrapper around Unix-domain stream sockets.
Definition: socket.hh:113

std::runtime_error

pipe2
LocalStreamSocket pipe2
Definition: socket_example_3.cc:4

fds
std::array< int, 2 > fds
Definition: socket_example_3.cc:2

recvd2
auto recvd2
Definition: socket_example_3.cc:10

pipe1
LocalStreamSocket pipe1
Definition: socket_example_3.cc:4

SystemCall
SystemCall("socketpair", ::socketpair(AF_UNIX, SOCK_STREAM, 0, fds.data()))

recvd
auto recvd
Definition: socket_example_3.cc:7