/* 

 * File:   program.cpp

 * Author: fiki

 *

 * Created on 1. duben 2009, 23:54

 */

#include <program.h>

#include <stdlib.h>

//#include <iostream>

#include <c++/4.3.2/iostream>

#include <mqueue.h>

#include <readline/readline.h>

using namespace std;

struct mq_attr ma = {

    ma.mq_maxmsg = 5,

    ma.mq_msgsize = 100

};

/*

 * 

 */

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

    cout << "Vítejte v programu POSIXovéFronty" << endl;

    ma.mq_maxmsg = 5;

    ma.mq_msgsize = 100;

    //cout << NAZEV_FRONTY << endl;

    if (isOdesilaciRezim()) {

        odesilej();

    } else {

        prijimej();

    }

    return (EXIT_SUCCESS);

}

bool isOdesilaciRezim() {

    //char *odpoved = readline("Zvolte režim: (p)řijímací / (o)desílací");

    cout << "Zvolte režim: (p)řijímací / (o)desílací" << endl;

    char odpoved = cin.get();

    cin.get();

    if (odpoved == 'o') {

        return true;

    } else if (odpoved == 'p') {

        return false;

    } else {

        return isOdesilaciRezim();

    }

}

void odesilej() {

    cout << "odesíláme" << endl;

    mqd_t fronta = mq_open(NAZEV_FRONTY, O_RDWR | O_CREAT, S_IRWXU | S_IRWXG, &ma);

    char* zprava = "zpráva";

    mq_send(fronta, zprava, strlen(zprava) + 1, 0);

    cin.get();

    mq_close(fronta);

}

void prijimej() {

    cout << "přijímáme" << endl;

    mqd_t fronta = mq_open(NAZEV_FRONTY, O_RDONLY);

    char s[101];

    s[100] = '\0';

    if (mq_receive(fronta, s, 100, NULL) > 0) {

        printf("Přijatá zpráva: %s\n", s);

    } else {

        cout << "Nepodařilo se přijmout zprávu" << endl;

    }

    //mq_unlink(NAZEV_FRONTY);

    mq_close(fronta);

}