5 * Created on 1. duben 2009, 23:54
11 #include <c++/4.3.2/iostream>
13 #include <readline/readline.h>
19 cout << "Vítejte v programu POSIXovéFronty" << endl;
21 mq_vlastnosti.mq_maxmsg = POCET_ZPRAV_VE_FRONTE;
22 mq_vlastnosti.mq_msgsize = DELKA_ZPRAVY;
25 //cout << "maxmsg: " << ma.mq_maxmsg;
26 //cout << "msgsize: " << ma.mq_msgsize;
31 //cout << NAZEV_FRONTY << endl;
33 if (isOdesilaciRezim()) {
43 return (EXIT_SUCCESS);
46 bool isOdesilaciRezim() {
47 //char *odpoved = readline("Zvolte režim: (p)řijímací / (o)desílací");
49 cout << "Zvolte režim: (p)řijímací / (o)desílací" << endl;
51 char odpoved = cin.get();
56 } else if (odpoved == 'p') {
59 return isOdesilaciRezim();
64 cout << "odesíláme" << endl;
68 mqd_t fronta = mq_open(NAZEV_FRONTY, O_RDWR | O_CREAT, S_IRWXU | S_IRWXG, &mq_vlastnosti);
70 char zprava[] = "zpráva";
72 mq_send(fronta, zprava, strlen(zprava) + 1, 0);
80 cout << "přijímáme" << endl;
82 mqd_t fronta = mq_open(NAZEV_FRONTY, O_RDONLY);
83 char s[DELKA_ZPRAVY + 1];
84 s[DELKA_ZPRAVY] = '\0';
85 if (mq_receive(fronta, s, DELKA_ZPRAVY, NULL) > 0) {
86 printf("Přijatá zpráva: %s\n", s);
88 cout << "Nepodařilo se přijmout zprávu" << endl;
91 //mq_unlink(NAZEV_FRONTY);