Flashdown,
Через IPC ?Да не вопрос. 
Код самих процессов -то есть ? R и P ? Это тупая работа, так что увольте
Еще пулы будешь сам делать, как один буфер сварганить покажу, дальше по аналогии... Будут проблемы - обращайся.
Есть такая фиговина, называется семафоры (mutex). Код (из новой dlib-ы, которую я на днях выложу... наверно. http://sf.net/projects/silenbob)
| Код |
/*
* (c) Oleg Puchinin 2006
* graycardinalster@gmail.com
*
*/
/* 2006-05-26 */
R
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <errno.h>
#include "dlib.h"
inline int __semset (struct sembuf * action, int num, int op)
{
action->sem_flg = SEM_UNDO;
action->sem_num = num;
action->sem_op = op;
}
enum {
hold_read = 0,
hold_write = 1,
};
inline void __sem_zero (int sem, int num = 0)
{
semctl (sem, num, SETVAL, 0);
}
int __sem_try_key (int *KEY, int count = 1)
{
int key = 9900;
int id;
while (key < 10000) {
id = semget (key, count, (0600|IPC_CREAT|IPC_EXCL));
if (id < 0) {
key++;
continue;
}
if (KEY)
*KEY = key;
return id;
}
return -1;
}
int __sem_init_one (int key, int count = 1)
{
int id;
id = semget (key, 1, (0600|IPC_CREAT|IPC_EXCL));
if (id > 0)
__sem_zero (id);
return id;
}
int sem_init (int * KEY)
{
int key = 9900;
int id;
/*
* Try *KEY or any random key if *KEY is 0
*/
if (KEY && *KEY)
id = __sem_init_one (*KEY);
else
id = __sem_try_key (&key);
if (id < 0)
return id;
__sem_zero (id);
if (KEY)
*KEY = key;
return id;
}
int down (int sem)
{
struct sembuf actions[2];
__semset (&actions[0], 0, 0);
__semset (&actions[1], 0, +1);
semop (sem, actions, 2);
return errno;
}
int up (int sem)
{
struct sembuf actions[1];
__semset (&actions[0], 0, -1);
return semop (sem, actions, 1);
}
int sem_init_rw (int * KEY)
{
int id;
int key;
if (KEY && *KEY)
id = __sem_init_one (*KEY, 2);
else
id = __sem_try_key (KEY, 2);
if (id < 0)
return id;
__sem_zero (id, hold_read);
__sem_zero (id, hold_write);
}
int down_read (int sem)
{
struct sembuf actions[2];
__semset (&actions[0], hold_write, 0);
__semset (&actions[1], hold_read, +1);
return semop (sem, actions, 2);
}
int up_read (int sem)
{
struct sembuf actions[1];
__semset (&actions[0], hold_read, -1);
return semop (sem, actions, 1);
}
int down_write (int sem)
{
struct sembuf actions[3];
__semset (&actions[0], hold_read, 0);
__semset (&actions[1], hold_write, 0);
__semset (&actions[2], hold_write, +1);
semop (sem, actions, 3);
return errno;
}
int up_write (int sem)
{
struct sembuf actions[2];
__semset (&actions[0], hold_write, -1);
return semop (sem, actions, 1);
}
|
Вот этим можно решать траблы с блокировкой. Сервак делает sem_init c "ключом" KEY (вообще туда адрес передается на int переменную в которой будет ключ). Клиентура - semget (KEY...)
$ man 2 semget
Если надо пользовать ID, который дал semget(2) (не sem_init), просто результат в переменную загоняешь (int) и можно все преведенные функции пользовать. Т.е.
1. Клиент делает down_write, пишет данные, делает up_write когда закончит.
2. Сервер делает down_read, читает данные, делает up_read когда закончит.
Можно заменить на "простые" down/up, суть не меняется.
И все работает без косяков. (в "догонялки" никто не играет). Скорее всего понадобится один для каждого буфера, но это не проблема - там их
9999 свободных если не ошибаюсь, и никто не пользует... В общем код глянь и RTFM. Там основная идея - что все операции (sigactions) - атомарные. Вообще по IPC неплохо справочник иметь под ручками...
Вторая проблема - сам буфер(ы) (для процесса M)
Тут вообще просто
#include <ipc.h>
int size = 4096;
char * ptr;
ptr = (char *) shmget (KEY, size, IPC_CREAT);
На серваке (M), без IPC_CREAT на клиентуре ®. Еще на сервере можно настроечки выставить $ man 2 shmctl
Ключи выбирай "от фанаря", главное чтоб во всех процессах совпадали.
На счет того, чтоб сообщить процессу M что данные типа есть, лично я бы для данного случая тупо включил таймер
$ man 2 alarm
$ man 2 signal
И не парился. Но можно попробовать через
$ man 2 msgget
Чтоб мессаги кидать. Сам не пользовался, рассказать не могу... Но вроде ничего сложного.
|
