1 // Copyright (C) 2014-2017 CEA/DEN, EDF R&D
3 // This library is free software; you can redistribute it and/or
4 // modify it under the terms of the GNU Lesser General Public
5 // License as published by the Free Software Foundation; either
6 // version 2.1 of the License, or (at your option) any later version.
8 // This library is distributed in the hope that it will be useful,
9 // but WITHOUT ANY WARRANTY; without even the implied warranty of
10 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
11 // Lesser General Public License for more details.
13 // You should have received a copy of the GNU Lesser General Public
14 // License along with this library; if not, write to the Free Software
15 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17 // See http://www.salome-platform.org/ or
18 // email : webmaster.salome@opencascade.com<mailto:webmaster.salome@opencascade.com>
21 #include <Events_Listener.h>
22 #include <Events_MessageGroup.h>
23 #include <Events_Loop.h>
25 void Events_Listener::groupWhileFlush(const std::shared_ptr<Events_Message>& theMessage) {
26 std::shared_ptr<Events_MessageGroup> aGroup =
27 std::dynamic_pointer_cast<Events_MessageGroup>(theMessage);
29 std::map<char*, std::shared_ptr<Events_Message> >::iterator aMyGroup = myGroups.find(
30 aGroup->eventID().eventText());
31 if (aMyGroup == myGroups.end()) { // create a new group of messages for accumulation
32 myGroups[aGroup->eventID().eventText()] = aGroup->newEmpty();
33 aMyGroup = myGroups.find(aGroup->eventID().eventText());
35 std::shared_ptr<Events_MessageGroup> aStored =
36 std::dynamic_pointer_cast<Events_MessageGroup>(aMyGroup->second);
37 aStored->Join(aGroup);
38 //std::cout<<"Add to group "<<theMessage->eventID().eventText()<<std::endl;
43 void Events_Listener::flushGrouped(const Events_ID& theID) {
44 std::map<char*, std::shared_ptr<Events_Message> >::iterator aMyGroup =
45 myGroups.find(theID.eventText());
46 if (aMyGroup != myGroups.end()) {
47 std::shared_ptr<Events_Message> aMessage = aMyGroup->second;
48 myGroups.erase(aMyGroup);
49 processEvent(aMessage);