files.cc

certi-SHM-3.0.tar 不错的开源的分布式方针软件 大家多多支持 他是linux

// -*- mode:C++ ; tab-width:4 ; c-basic-offset:4 ; indent-tabs-mode:nil -*-
// ----------------------------------------------------------------------------
// CERTI - HLA RunTime Infrastructure
// Copyright (C) 2002, 2003  ONERA
//
// This file is part of CERTI
//
// CERTI is free software ; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation ; either version 2 of the License, or
// (at your option) any later version.
//
// CERTI is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY ; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program ; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
//
// $Id: Files.cc,v 3.6 2003/02/19 15:45:22 breholee Exp $
// ----------------------------------------------------------------------------

#include "Files.hh"

namespace certi {
namespace rtia {

// ----------------------------------------------------------------------------
Queues::Queues(void)
{
}

// ----------------------------------------------------------------------------
Queues::~Queues(void)
{
}

// ----------------------------------------------------------------------------
//! Returns logical time from first message in TSO list.
void
Queues::nextTsoDate(Boolean &found, FederationTime &time)
{
    NetworkMessage *msg_buffer ;

    if (tsos.empty()) {
        found = RTI_FALSE ;
        time = -1.0 ;
    }
    else {
        msg_buffer = tsos.front();
        found = RTI_TRUE ;
        time = msg_buffer->date ;
    }
}

// ----------------------------------------------------------------------------
/*! Give all the commands to the federate (en invoquant les services
  "RTI Initiated" du federe).
*/
NetworkMessage*
Queues::giveCommandMessage(Boolean &msg_donne, Boolean &msg_restant)
{
    NetworkMessage *msg ;

    msg_donne = RTI_FALSE ;
    msg_restant = RTI_FALSE ;

    if (!commands.empty()) {
        // remove from list but keep pointer to execute ExecuterServiceFedere.
        msg = commands.front();
        commands.pop_front();
        msg_donne = RTI_TRUE ;

        if (!commands.empty())
            msg_restant = RTI_TRUE ;

        return msg ;
    }
    else return 0 ;
}

// ----------------------------------------------------------------------------
//! Give a FIFO message to federate.
NetworkMessage*
Queues::giveFifoMessage(Boolean &msg_donne, Boolean &msg_restant)
{
    NetworkMessage *msg_tampon ;

    msg_donne = RTI_FALSE ;
    msg_restant = RTI_FALSE ;

    if (!fifos.empty()) {
        // remove from list but keep pointer to execute ExecuterServiceFedere.
        msg_tampon = fifos.front();
        fifos.pop_front();
        msg_donne = RTI_TRUE ;

        if (!fifos.empty())
            msg_restant = RTI_TRUE ;

        return msg_tampon ;
    }
    else return 0 ;
}

// ----------------------------------------------------------------------------
/*! 'heure_logique' is the minimum value between current LBTS and current
  time
*/
NetworkMessage *
Queues::giveTsoMessage(FederationTime heure_logique,
                       Boolean &msg_donne,
                       Boolean &msg_restant)
{
    NetworkMessage *buffer_msg = NULL ;

    msg_donne = RTI_FALSE ;
    msg_restant = RTI_FALSE ;

    if (!tsos.empty()) {
        buffer_msg = tsos.front();
        if (buffer_msg->date <= heure_logique) {
            // remove from list but keep pointer to execute
            // ExecuterServiceFedere.
            tsos.pop_front();
            msg_donne = RTI_TRUE ;

            // Test if next TSO message can be sent.
            if (!tsos.empty()) {
                NetworkMessage *buffer_msg2 ;
                buffer_msg2 = tsos.front();

                if (buffer_msg2->date <= heure_logique)
                    msg_restant = RTI_TRUE ;
            }
            return buffer_msg ;
        }
        else return 0 ;
    }
    else return 0 ;
}

// ----------------------------------------------------------------------------
/*! Insert a message with a command (ex: requestPause) to the beginning of
  command list.
*/
void
Queues::insertBeginCommand(NetworkMessage *msg)
{
    commands.push_front(msg);
}

// ----------------------------------------------------------------------------
//! Insert a message with a command at the end of command list.
void
Queues::insertLastCommand(NetworkMessage *msg)
{
    commands.push_back(msg);
}

// ----------------------------------------------------------------------------
//! Insert a message to end FIFO list.
void
Queues::insertFifoMessage(NetworkMessage *msg)
{
    fifos.push_back(msg);
}

// ----------------------------------------------------------------------------
//! TSO list is sorted by message logical time.
void
Queues::insertTsoMessage(NetworkMessage *msg)
{
    if (tsos.empty()) {
        tsos.push_front(msg);
        return ;
    }
    else {
        list<NetworkMessage *>::iterator i ;
        for (i = tsos.begin(); i != tsos.end(); i++) {
            // stricly greater because we want to place new message behind
            // older ones with same logical time and thus keep receive order
            // in list.
            if ((*i)->date > msg->date) {
                tsos.insert(i, msg);
                return ;
            }
        }
    }
    tsos.push_back(msg);
}

}} // namespaces

// $Id: Files.cc,v 3.6 2003/02/19 15:45:22 breholee Exp $