Главная страница  Взаимодействие нетривиальных процессов 

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 [ 42 ] 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186

должать использовать дескриптор очереди сообщений, до того как область памяти будет вновь задействована вызовом mal 1 ос, мы устанавливаем значение niq magic в ноль, чтобы наши функции для работы с очередью сообщений обнаруживали ошибку.

Обратите внимание, что если процесс завершает работу без вызова mq close, эти же операции выполняются автоматически: отключается отображение в память, а память освобождается.

Функция mq unlink

Текст функции mqunl i nk приведей в листинге 5.21. Она удаляет файл, связанный с очередью сообщений, вызывая функцию unl ink.

Листинг 5.21. Функция mq unlink

niy pxmsg nirap/mq unl i nk. с

1 #inclucle unpipc.h

2 #inclucle mqueue.h

3 int

4 mymq unlink(const char *pathname)

6 if (unlink(pathname) = -1)

7 return(-l);

8 return(O);

Функция mq getattr

в листинге 5.22 приведен текст функции mqgetattr, которая возвращает текущее значение атрибутов очереди.

Листинг 5.22. Функция mq getattr

rny pxmsg mmap/mq getattr. с

1 #inclucle unpipc.h

2 #inclucle mqueue.h

3 int

4 rnymq getattr(mymqcl t mqd. struct mymq attr *mqstat)

6 int n:

7 struct rnymq hdr *mqhdr:

8 struct mymq attr *attr:

9 struct rnymqjnfo *mqinfo:

10 mqinfo = mqd;

11 if (mqinfo->mqi magic != MQI MAGIC) {

12 errno = EBADF:

13 return(-l);

14 }

15 mqhdr = mq1nfo->mqi hdr;

16 attr = &mqhdr->mqh attr;

17 if ( (n - pthread mutex lock(&mqhdr->mqh lock)) != 0) {

18 errno = n;

19 return(-l); продолжение



Листинг 5.22 (продолжение)

20 }

21 mqstat->mq flags = mqinfo->mqi flags; /* для каждого open */

22 mqstat->mq niaxnisg = attr->mq niaxnisg: /* оставшиеся три - для очереди */

23 mqstat->mq nisgsize = attr->mq nisgslze:

24 mqstat->niq cunnsgs = attr->mq curnisgs;

25 pthreacl niutex unlock(&mqhclr->rnqhJock):

26 return(O):

27 }

Блокирование взаимного исключения

17-20 Мы должны заблокировать соответствующее взаимное исключение для работы с очередью, в частности для получения атрибутов, поскольку какой-либо другой поток может в это время их изменить.

Функция mq setattr

в листинге 5.23 приведен текст функции mqsetattr, которая устанавливает значение атрибутов очереди.

Считывание текущих атрибутов

22-27 Если третий аргумент представляет собой ненулевой указатель, мы возвращаем предыдущее значение атрибутов перед внесением каких-либо изменений.

Изменение nriq f lags

28-31 Единственный атрибут, который можно менять с помощью нашей функции, - mq f 1 ags, хранящийся в структуре mq info.

Листинг 5.23. Функция mq setattr

iny pxnisg mmap/mq setattr. с

1 #inc1ucle unpipc.h

2 #inclucle mqueue.h

mymq setattr(mymqcl t mqd, const struct mymq attr *mqstat. struct mymq attr *omqstat)

int n;

8 struct myraq hdr *mqhdr;

9 struct inymq attr *attr;

10 struct itiymqjnfo *mqinfo;

11 mqinfo = mqd:

12 if (mqinfo->mqi magic != MQI IGIC) {

13 errno = EBADF:

14 return(-l);

15 }

16 mqhdr = mqinfo->mq1 hdr:

17 attr = &mqhdr->mqh attr:

18 If ( (n = pthread mutexJock(&mqhdr->mqhJock)) != 0)

19 errno = n;



20 return(-l);

21 }

22 lf (omqstat != NULL) {

23 omqstat->mq flags = niqinfo->iTiqi flags: /* исходные атрибуты */

24 omqstat->niq niaxnisg = attr->mq maxmsg;

25 omqstat->mq msgsTze = attr->mq msgsize;

26 omqstat->mq curmsgs = attr->mq curmsgs; /* текущий статус */

27 }

28 if (mqstat->mq flags & 0 NONBLOCK)

29 mqinfo->mqi flags 1= OJONBLOCK;

30 else

31 mqinfo->mqi flags &= -OJONBLOCK:

32 pthreacl mutex unl ock (&mqhclr ->mqh l ock);

33 return(O);

34 }

Функция mq notify

Функция mqjoti fy, текст которой приведен в листинге 5,24, позволяет регистрировать процесс на уведомление для текущей очереди и снимать его с регистрации. Информация о зарегистрированных процессах (их идентификаторы) хранится в поле niqh pi d структуры mqjdr. Только один процесс может быть зарегистрирован на уведомление в любой момент времени. При регистрации процесса мы сохраняем его структуру sigevent в структуре mqh event.

Листинг 5.24. Функция mq notify

myj)xmsg mmap/mq notify.c

1 #inclucle unpipc.h

2 #inclucle mqueue.h

3 int

4 mymq notify(mymqcl t mqd, const struct sigevent *notification)

6 int n;

7 pid t pid;

8 struct mymq hdr *mqhdr;

9 struct mymq info *mqinfo;

10 mqinfo = mqd:

11 if (mqinfo->mqi magic ! MQIJAGIC) {

12 errno = EBADF;

13 return(-l);

14 }

15 mqhdr = mqinfo->mqi Jdr;

16 if ( (n = pthread mutexJock(&mqhdr->mqh lock)) != 0) {

17 errno = n;

18 return(-l);

19 }

20 pid = getpidO;

21 if (notification =- NULL) {

22 if (mqhdr->mqh pid == pid) {



1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 [ 42 ] 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186

© 2000 - 2024 ULTRASONEX-AMFODENT.RU.
Копирование материалов разрешено исключительно при условии цититирования.