Mycorrhiza/test/mycodaemon.c

/*
 *  mycodaemon.c
 */

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>


int myco_send (const char *message, const char *myco_daemon_address, uint16_t myco_daemon_port) {
    int create_socket;
    struct sockaddr_in address;

    if ((create_socket = socket (AF_INET, SOCK_STREAM, 0)) < 1)
        return -1;
    address.sin_family = AF_INET;
    address.sin_port = htons (myco_daemon_port);
    inet_aton (myco_daemon_address, &address.sin_addr);
    if (connect ( create_socket, (struct sockaddr *) &address, sizeof (address)) != 0)
        return -1;

    send(create_socket, message, strlen (message), 0);

    close (create_socket);

    return 0;
}

int myco_recv (char *message, const char *myco_daemon_address, uint16_t myco_daemon_port) {
    int buf = 1024;
    int create_socket, new_socket;
    socklen_t addrlen;
    char *buffer = malloc (buf);
    ssize_t size;
    struct sockaddr_in address;
    const int y = 1;
    printf ("\e[2J");
    if ((create_socket=socket (AF_INET, SOCK_STREAM, 0)) > 0)
        printf ("Socket wurde angelegt\n");
    setsockopt( create_socket, SOL_SOCKET,
            SO_REUSEADDR, &y, sizeof(int));
    address.sin_family = AF_INET;
    address.sin_addr.s_addr = INADDR_ANY;
    address.sin_port = htons (myco_daemon_port);
    if (bind ( create_socket,
                (struct sockaddr *) &address,
                sizeof (address)) != 0) {
        printf( "Der Port ist nicht frei – belegt!\n");
    }
    listen (create_socket, 5);
    addrlen = sizeof (struct sockaddr_in);
    new_socket = accept ( create_socket,
            (struct sockaddr *) &address,
            &addrlen );
    if (new_socket > 0)
        printf ("Ein Client (%s) ist verbunden ...\n",
                inet_ntoa (address.sin_addr));
    size = recv (new_socket, buffer, buf-1, 0);
    if( size > 0)
        buffer[size] = '\0';
    printf ("Nachricht empfangen: %s\n", buffer);

    close (new_socket);

    return EXIT_SUCCESS;

}


// make into daemon later
int main() {
    char *message = malloc(1024);

    if (myco_recv (message, "127.0.0.1", 15000))
            printf ("Receive.\n");

    if (myco_send ("foobar", "127.0.0.1", 15000))
            printf ("Send.\n");

    return EXIT_SUCCESS;

}