source: XIOS/dev/XIOS_DEV_CMIP6/src/event_server.cpp @ 1474

Last change on this file since 1474 was 716, checked in by rlacroix, 8 years ago

Cosmetic: Fix a typo in an error message.

  • Property copyright set to
    Software name : XIOS (Xml I/O Server)
    http://forge.ipsl.jussieu.fr/ioserver
    Creation date : January 2009
    Licence : CeCCIL version2
    see license file in root directory : Licence_CeCILL_V2-en.txt
    or http://www.cecill.info/licences/Licence_CeCILL_V2-en.html
    Holder : CEA/LSCE (Laboratoire des Sciences du CLimat et de l'Environnement)
    CNRS/IPSL (Institut Pierre Simon Laplace)
    Project Manager : Yann Meurdesoif
    yann.meurdesoif@cea.fr
  • Property svn:eol-style set to native
File size: 1.9 KB
Line 
1#include "xios_spl.hpp"
2#include "buffer_in.hpp"
3#include "type.hpp"
4#include "event_server.hpp"
5#include "buffer_server.hpp"
6
7namespace xios
8{
9  void CEventServer::push(int rank, CServerBuffer* serverBuffer, char* startBuffer, int size)
10  {
11    CBufferIn buffer(startBuffer, size);
12    size_t timeLine;
13    int myClassId, myType, myNbSender;
14 
15    buffer >> size >> timeLine >> myNbSender >> myClassId >> myType;
16 
17    if (subEvents.empty())
18    { 
19      nbSender = myNbSender;
20      classId = myClassId;
21      type = myType;
22    }
23    else
24    {
25      if (classId != myClassId || type != myType || nbSender != myNbSender)
26        ERROR("void CEventServer::push(int rank, CServerBuffer* serverBuffer, char* startBuffer, int size)",
27              << "The callers of event " << timeLine << " are not coherent." << std::endl
28              << "Received subevent: classId = " << myClassId << ", type = " << myType << ", nbSender = " << myNbSender << std::endl
29              << "Expected subevent: classId = " << classId << ", type = " << type << ", nbSender = " << nbSender);
30    }
31
32    SSubEvent ev;
33    ev.rank = rank;
34    ev.serverBuffer = serverBuffer;
35    ev.buffer = new CBufferIn(buffer.ptr(), buffer.remain());
36    ev.size = size; 
37    subEvents.push_back(ev);
38 
39    if (subEvents.size() > nbSender)
40    {
41        ERROR("void CEventServer::push(int rank, CServerBuffer* serverBuffer, char* startBuffer, int size)",
42              << "The callers of event " << timeLine << " are not coherent." << std::endl
43              << "Too many subevents have been received (" << subEvents.size() << " instead of " << nbSender << ").");
44    }
45  }
46
47  bool CEventServer::isFull(void) 
48  {
49    return (nbSender == subEvents.size());
50  }
51
52  CEventServer::~CEventServer()
53  {
54    list<SSubEvent>::iterator it;
55    for (it = subEvents.begin(); it != subEvents.end(); it++)
56    {
57      it->serverBuffer->freeBuffer(it->size);
58      delete it->buffer;
59    }
60  }
61}
Note: See TracBrowser for help on using the repository browser.