net_udp_client.c

Go to the documentation of this file.

 
#include <banjo/log.h>
#include <banjo/main.h>
#include <banjo/net.h>
#include <banjo/system.h>
 
#include <string.h>
 
#define SERVER_HOST "127.0.0.1"
#define SERVER_PORT 9000
 
int main(int argc, char* argv[]) {
    (void)argc;
    (void)argv;
 
    if (!bj_begin(BJ_NETWORK_SYSTEM, 0)) {
        return 1;
    }
 
    struct bj_error* error = 0;
 
    struct bj_udp* udp = bj_open_udp(0, 0, BJ_RESOLVE_IPV4, &error);
    if (!udp) {
        bj_err("client: failed to open UDP socket (%s)", bj_error_message(error));
        bj_clear_error(&error);
        bj_end();
        return 1;
    }
 
    bj_info("client: using local port %d", bj_udp_local_port(udp));
 
    const char* message = "Hello from Banjo UDP!";
    bj_info("client: sending \"%s\" to %s:%d", message, SERVER_HOST, SERVER_PORT);
 
    int sent = bj_udp_send(udp, SERVER_HOST, SERVER_PORT, message, strlen(message), &error);
    if (sent < 0) {
        bj_err("client: send failed (%s)", bj_error_message(error));
        bj_clear_error(&error);
        bj_close_udp(udp);
        bj_end();
        return 1;
    }
    bj_info("client: sent %d bytes", sent);
 
    bj_info("client: waiting for reply...");
    if (!bj_udp_wait(udp, 3000)) {
        bj_err("client: timeout waiting for reply");
        bj_close_udp(udp);
        bj_end();
        return 1;
    }
 
    struct bj_datagram* dgram = bj_udp_recv(udp, &error);
    if (!dgram) {
        bj_err("client: recv failed (%s)", bj_error_message(error));
        bj_clear_error(&error);
        bj_close_udp(udp);
        bj_end();
        return 1;
    }
 
    char reply[512];
    size_t len = bj_datagram_len(dgram);
    if (len >= sizeof(reply)) {
        len = sizeof(reply) - 1;
    }
    memcpy(reply, bj_datagram_data(dgram), len);
    reply[len] = '\0';
 
    bj_info("client: received reply: \"%s\"", reply);
 
    bj_close_datagram(dgram);
    bj_close_udp(udp);
    bj_end();
    return 0;
}