#include <stdio.h>

#include <string.h>

#include "reowolf.h"

int main(int argc, char** argv) {

  // --- setup ---

  Arc_ProtocolDescription * pd = protocol_description_parse("", 0);

  Connector * c = connector_new(pd);

  PortId putter_a, putter_b;

  FfiSocketAddr addresses[4];

  /* (address structure initializations omitted) */

  // putter_a to UDP mediator (getter id discarded)

  // with local addresses[0] and peer addresses[1] 

  connector_add_udp_mediator_component(c, &putter_a, NULL, addresses[0], addresses[1]);

  connector_add_udp_mediator_component(c, &putter_b, NULL, addresses[2], addresses[3]);

  connector_connect(c, -1);

  // --- communication --- 

  connector_put_bytes(c, putter_a, "hello, socket!", 14);

  connector_put_bytes(c, putter_b, "hello, pseudo-socket!", 21);

  connector_sync(c, -1);

  // --- cleanup ---

  protocol_description_destroy(pd);

  connector_destroy(c);

  return 0;

}

#include <sys/socket.h> // socket addresses, constants

#include <stdio.h>

#include "pseudo_socket.h"

#define BUFSIZE 512

int main() {

  // --- setup ---

  struct sockaddr_in local, peer; 

  /* (address structure initializations omitted) */

  int fd = rw_socket(AF_INET, SOCK_DGRAM, 0); 

  rw_bind(fd, (const struct sockaddr *)&local, sizeof(local));

  rw_connect(fd, (const struct sockaddr *)&peer, sizeof(peer));

  // --- communication ---

  char buffer = malloc(BUFSIZE);

  size_t msglen, i;

  msglen = rw_recv(fd, (const void *)buffer, BUFSIZE, 0);

  for(i=0; i<msglen; i++) {

    printf("%02X", buffer[i]);

  }

  // --- cleanup ---

  rw_close(fd);

  free(buffer);

  return 0;

}

#include <sys/socket.h> // socket addresses, constants

#include <stdio.h>

#define BUFSIZE 512

int main() {

    // --- setup ---

    struct sockaddr_in local, peer; 

    /* (address structure initializations omitted) */

    int fd = socket(AF_INET, SOCK_DGRAM, 0); 

    bind(fd, (const struct sockaddr *)&local, sizeof(local));

    connect(fd, (const struct sockaddr *)&peer, sizeof(peer));

    // --- communication ---

    char buffer = malloc(BUFSIZE);

    size_t msglen, i;

    msglen = recv(fd, (const void *)buffer, BUFSIZE, 0);

    for(i=0; i<msglen; i++) {

        printf("%02X", buffer[i]);

    }

    // --- cleanup ---

    close(fd);

    free(buffer);

    return 0;

}

#include <sys/socket.h> // defines {sockaddr, socklen_t}

int rw_socket(int domain, int type, int protocol);

int rw_connect(int fd, const struct sockaddr *address, socklen_t address_len);

int rw_bind(int socket, const struct sockaddr *address, socklen_t address_len);

int rw_close(int fd);

ssize_t rw_send(int fd, const void * message, size_t length, int flags);

ssize_t rw_recv(int fd, void * buffer, size_t length, int flags);

pub unsafe extern "C" fn connector_add_udp_mediator_component(