Небольшая проблема с обработкой сообщений, сброс флага "Сообщение пусто" Опции

[sonycman]

Доброго времени суток!

Организую взаимодействие между двумя процессами с помощью сообщений.
Один процесс отправляет сообщение, другой - принимает.

Почему то казалось, что после считывания сообщения оператором = его статус автоматически устанавливается на "пусто".
Поэтому делал так:

CODE

//thread 1
command_message.send();
response_message.wait();
...

//thread 2
if (command_message.is_non_empty())
{
message_placeholder = command_message;
...
response_message.send();
...
}

Оказалось, что это не так, и необходимо после считывания принудительно сбрасывать сообщение функцией reset().

Но, может быть, удобнее было бы сделать автоматический сброс флага NonEmpty после отрабатывания оператора присваивания?

[sonycman]

Мне просто было интересно, почему авторы не предусмотрели сброс флага.
Теперь это понятно.
Спасибо за оперативную помощь.

Что касается модификации - к сожалению, я не смог с наскоку добавить сброс NonEmpty прямо в тело функции-оператора "=" так, чтобы не вызвать ошибки компилятора.
А дальше пока не стал копать, в принципе, вполне устраивает и так

[dxp]

Что касается модификации - к сожалению, я не смог с наскоку добавить сброс NonEmpty прямо в тело функции-оператора "=" так, чтобы не вызвать ошибки компилятора.
А дальше пока не стал копать, в принципе, вполне устраивает и так

Можно попробовать как-то так:

Код

template <typename T>
class my_message : public OS::message<T>
{
public:
    INLINE const T& operator=(const T& msg) { return OS::message<T>::operator=(msg); }
    INLINE operator T()
    {
        reset();
        return OS::message<T>::operator T();
    }  
};
...
my_message<int> Slonick;

...
    // process 1
    Slonick = 10;
    Slonick.send();

...
    // process 2
    if(Slonick.is_non_empty())
    {
        A = Slonick; // чтение тела сообщения со сбросом внутреннего флага
    }

[sonycman]

Можно попробовать как-то так:

Спасибо!

А я пробовал просто вставить функцию внутрь класса message вот так:

Код

INLINE operator     T() const       { TCritSect cs; reset(); return Msg; }

на что получаю такую ошибку:

Error[Pe1086]: the object has cv-qualifiers that are not compatible with the member function "OS::message<T>::reset"

Вроде бы наследующий класс должен получать доступ ко всем public членам наследуемого?

ЗЫ: в Вашем примере будет дважды формироваться критическая секция? Сначала внутри reset(), а затем самим оператором Т ?