Subversion Repositories Kolibri OS

/*

 * This is an example program for sending a message through a "pipe".

 * Created by turbocat (Maxim Logaev) 2022.

 */

#include 

#include 

#include 

#include 

#include 

#define TH_STACK_SIZE 1024

#define MESSAGE_SIZE 12

ksys_colors_table_t sys_colors;

int pipefd[2];

char* send_message = "HELLO PIPE!";

void tmain()

{

    char recv_message[MESSAGE_SIZE];

    _ksys_posix_read(pipefd[0], recv_message, MESSAGE_SIZE);

    printf("RECV: %s\n", recv_message);

    assert(!strcmp(recv_message, send_message));

    puts("Successful pipe test");

    exit(0);

}

void create_thread(void)

{

    unsigned tid;                           // New thread ID

    void* th_stack = malloc(TH_STACK_SIZE); // Allocate memory for thread stack

    if (!th_stack) {

        puts("Memory allocation error for thread!");

        return;

    }

    tid = _ksys_create_thread(tmain, th_stack + TH_STACK_SIZE); // Create new thread with entry "main"

    if (tid == -1) {

        puts("Unable to create a new thread!");

        return;

    }

    printf("New thread created (TID=%u)\n", tid);

}

void main()

{

    if (_ksys_posix_pipe2(pipefd, 0)) {

        puts("Pipe creation error!");

        return;

    }

    printf("SEND: %s\n", send_message);

    _ksys_posix_write(pipefd[1], send_message, MESSAGE_SIZE);

    create_thread();

}