Priklady: c++/POSIXoveFronty/Fronta/fronta.cpp@a594ee3c93a5

     1 #include <fronta.h>

     2 #include <iostream>

     4 using namespace std;

     6 Fronta::Fronta() {

     7     prijimaci = false;

     8     odesilaci = false;

     9     otevrena = false;

    10 }

    12 Fronta::Fronta(char* nazev, bool prijimaci, bool odesilaci) {

    13     this->nazev = nazev;

    14     this->prijimaci = prijimaci;

    15     this->odesilaci = odesilaci;

    17     /** Nastavíme vlastnosti fronty */

    18     mq_vlastnosti.mq_maxmsg = POCET_ZPRAV_VE_FRONTE;

    19     mq_vlastnosti.mq_msgsize = DELKA_ZPRAVY;

    21     /** Vytvoříme odesílací (obojetnou) nebo (pouze) čtecí frontu */

    22     if (odesilaci) {

    23         fronta = mq_open(nazev, O_RDWR | O_CREAT, S_IRWXU | S_IRWXG, &mq_vlastnosti);

    24         otevrena = true;

    25     } else if (prijimaci) {

    26         fronta = mq_open(nazev, O_RDONLY);

    27         otevrena = true;

    28     } else {

    29         otevrena = false;

    30     }

    31 }

    33 int Fronta::odesliZpravu(char* zprava) {

    34     if (otevrena && odesilaci) {

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

    36     } else {

    37         return -1;

    38     }

    39 }

    41 char* Fronta::prijmiZpravu() {

    42     if (otevrena && prijimaci) {

    43         char zprava[DELKA_ZPRAVY + 1];

    44         zprava[DELKA_ZPRAVY] = '\0';

    45         if (mq_receive(fronta, zprava, DELKA_ZPRAVY, NULL) > 0) {

    46             return zprava;

    47         } else {

    48             return NULL;

    49         }

    50     } else {

    51         return NULL;

    52     }

    53 }

    55 void Fronta::zavriFrontu(bool zrusit) {

    56     if (otevrena) {

    57         if (zrusit) {

    58             mq_unlink(nazev);

    59         }

    60         mq_close(fronta);

    61         otevrena = false;

    62     }

    63 }

author	František Kučera <franta-hg@frantovo.cz>
	Mon May 07 14:05:26 2012 +0200 (2012-05-07)
changeset 17	a594ee3c93a5
permissions	-rw-r--r--