statistics.cc

分布式仿真 开放源码

	FED_MSG_NAME(Message::GET_OBJECT_CLASS_NAME);
	FED_MSG_NAME(Message::GET_ATTRIBUTE_HANDLE);
	FED_MSG_NAME(Message::GET_ATTRIBUTE_NAME);
	FED_MSG_NAME(Message::GET_INTERACTION_CLASS_HANDLE);
	FED_MSG_NAME(Message::GET_INTERACTION_CLASS_NAME);
	FED_MSG_NAME(Message::GET_PARAMETER_HANDLE);
	FED_MSG_NAME(Message::GET_PARAMETER_NAME);
	FED_MSG_NAME(Message::GET_OBJECT_INSTANCE_HANDLE);
	FED_MSG_NAME(Message::GET_OBJECT_INSTANCE_NAME);
	FED_MSG_NAME(Message::GET_SPACE_HANDLE);
	FED_MSG_NAME(Message::GET_SPACE_NAME);
	FED_MSG_NAME(Message::GET_DIMENSION_HANDLE);
	FED_MSG_NAME(Message::GET_DIMENSION_NAME);
	FED_MSG_NAME(Message::GET_ATTRIBUTE_SPACE_HANDLE);
	FED_MSG_NAME(Message::GET_OBJECT_CLASS);
	FED_MSG_NAME(Message::GET_INTERACTION_SPACE_HANDLE);
	FED_MSG_NAME(Message::GET_TRANSPORTATION_HANDLE);
	FED_MSG_NAME(Message::GET_TRANSPORTATION_NAME);
	FED_MSG_NAME(Message::GET_ORDERING_HANDLE);
	FED_MSG_NAME(Message::GET_ORDERING_NAME);
	FED_MSG_NAME(Message::ENABLE_CLASS_RELEVANCE_ADVISORY_SWITCH);
	FED_MSG_NAME(Message::DISABLE_CLASS_RELEVANCE_ADVISORY_SWITCH);
	FED_MSG_NAME(Message::ENABLE_ATTRIBUTE_RELEVANCE_ADVISORY_SWITCH);
	FED_MSG_NAME(Message::DISABLE_ATTRIBUTE_RELEVANCE_ADVISORY_SWITCH);
	FED_MSG_NAME(Message::ENABLE_ATTRIBUTE_SCOPE_ADVISORY_SWITCH);
	FED_MSG_NAME(Message::DISABLE_ATTRIBUTE_SCOPE_ADVISORY_SWITCH);
	FED_MSG_NAME(Message::ENABLE_INTERACTION_RELEVANCE_ADVISORY_SWITCH);
	FED_MSG_NAME(Message::DISABLE_INTERACTION_RELEVANCE_ADVISORY_SWITCH);
	FED_MSG_NAME(Message::TICK_REQUEST);

	// RTI messages
	RTI_MSG_NAME(NetworkMessage::CLOSE_CONNEXION);
	RTI_MSG_NAME(NetworkMessage::MESSAGE_NULL);
	RTI_MSG_NAME(NetworkMessage::CREATE_FEDERATION_EXECUTION);
	RTI_MSG_NAME(NetworkMessage::DESTROY_FEDERATION_EXECUTION);
	RTI_MSG_NAME(NetworkMessage::JOIN_FEDERATION_EXECUTION);
	RTI_MSG_NAME(NetworkMessage::RESIGN_FEDERATION_EXECUTION);
	RTI_MSG_NAME(NetworkMessage::SET_TIME_REGULATING);
	RTI_MSG_NAME(NetworkMessage::SET_TIME_CONSTRAINED);
	RTI_MSG_NAME(NetworkMessage::REGISTER_FEDERATION_SYNCHRONIZATION_POINT);
	RTI_MSG_NAME(NetworkMessage::SYNCHRONIZATION_POINT_REGISTRATION_SUCCEEDED);
	RTI_MSG_NAME(NetworkMessage::ANNOUNCE_SYNCHRONIZATION_POINT);
	RTI_MSG_NAME(NetworkMessage::SYNCHRONIZATION_POINT_ACHIEVED);
	RTI_MSG_NAME(NetworkMessage::FEDERATION_SYNCHRONIZED);
	RTI_MSG_NAME(NetworkMessage::REQUEST_FEDERATION_SAVE);
	RTI_MSG_NAME(NetworkMessage::FEDERATE_SAVE_BEGUN);
	RTI_MSG_NAME(NetworkMessage::FEDERATE_SAVE_COMPLETE);
	RTI_MSG_NAME(NetworkMessage::FEDERATE_SAVE_NOT_COMPLETE);
	RTI_MSG_NAME(NetworkMessage::INITIATE_FEDERATE_SAVE);
	RTI_MSG_NAME(NetworkMessage::FEDERATION_SAVED);
	RTI_MSG_NAME(NetworkMessage::FEDERATION_NOT_SAVED);
	RTI_MSG_NAME(NetworkMessage::REQUEST_FEDERATION_RESTORE);
	RTI_MSG_NAME(NetworkMessage::FEDERATE_RESTORE_COMPLETE);
	RTI_MSG_NAME(NetworkMessage::FEDERATE_RESTORE_NOT_COMPLETE);
	RTI_MSG_NAME(NetworkMessage::REQUEST_FEDERATION_RESTORE_SUCCEEDED);
	RTI_MSG_NAME(NetworkMessage::REQUEST_FEDERATION_RESTORE_FAILED);
	RTI_MSG_NAME(NetworkMessage::FEDERATION_RESTORE_BEGUN);
	RTI_MSG_NAME(NetworkMessage::INITIATE_FEDERATE_RESTORE);
	RTI_MSG_NAME(NetworkMessage::FEDERATION_RESTORED);
	RTI_MSG_NAME(NetworkMessage::FEDERATION_NOT_RESTORED);
	RTI_MSG_NAME(NetworkMessage::PUBLISH_OBJECT_CLASS);
	RTI_MSG_NAME(NetworkMessage::UNPUBLISH_OBJECT_CLASS);
	RTI_MSG_NAME(NetworkMessage::PUBLISH_INTERACTION_CLASS);
	RTI_MSG_NAME(NetworkMessage::UNPUBLISH_INTERACTION_CLASS);
	RTI_MSG_NAME(NetworkMessage::SUBSCRIBE_OBJECT_CLASS);
	RTI_MSG_NAME(NetworkMessage::UNSUBSCRIBE_OBJECT_CLASS);
	RTI_MSG_NAME(NetworkMessage::SUBSCRIBE_INTERACTION_CLASS);
	RTI_MSG_NAME(NetworkMessage::UNSUBSCRIBE_INTERACTION_CLASS);
	RTI_MSG_NAME(NetworkMessage::TURN_INTERACTIONS_ON);
	RTI_MSG_NAME(NetworkMessage::TURN_INTERACTIONS_OFF);
	RTI_MSG_NAME(NetworkMessage::REGISTER_OBJECT);
	RTI_MSG_NAME(NetworkMessage::DISCOVER_OBJECT);
	RTI_MSG_NAME(NetworkMessage::UPDATE_ATTRIBUTE_VALUES);
	RTI_MSG_NAME(NetworkMessage::REFLECT_ATTRIBUTE_VALUES);
	RTI_MSG_NAME(NetworkMessage::SEND_INTERACTION);
	RTI_MSG_NAME(NetworkMessage::RECEIVE_INTERACTION);
	RTI_MSG_NAME(NetworkMessage::DELETE_OBJECT);
	RTI_MSG_NAME(NetworkMessage::REMOVE_OBJECT);
	RTI_MSG_NAME(NetworkMessage::CHANGE_ATTRIBUTE_TRANSPORT_TYPE);
	RTI_MSG_NAME(NetworkMessage::CHANGE_ATTRIBUTE_ORDER_TYPE);
	RTI_MSG_NAME(NetworkMessage::CHANGE_INTERACTION_TRANSPORT_TYPE);
	RTI_MSG_NAME(NetworkMessage::CHANGE_INTERACTION_ORDER_TYPE);
	RTI_MSG_NAME(NetworkMessage::REQUEST_CLASS_ATTRIBUTE_VALUE_UPDATE);
	RTI_MSG_NAME(NetworkMessage::REQUEST_OBJECT_ATTRIBUTE_VALUE_UPDATE);
	RTI_MSG_NAME(NetworkMessage::IS_ATTRIBUTE_OWNED_BY_FEDERATE);
	RTI_MSG_NAME(NetworkMessage::QUERY_ATTRIBUTE_OWNERSHIP);
	RTI_MSG_NAME(NetworkMessage::ATTRIBUTE_IS_NOT_OWNED);
	RTI_MSG_NAME(NetworkMessage::INFORM_ATTRIBUTE_OWNERSHIP);
	RTI_MSG_NAME(NetworkMessage::NEGOTIATED_ATTRIBUTE_OWNERSHIP_DIVESTITURE);
	RTI_MSG_NAME(NetworkMessage::ATTRIBUTE_OWNERSHIP_ACQUISITION_NOTIFICATION);
	RTI_MSG_NAME(NetworkMessage::ATTRIBUTE_OWNERSHIP_DIVESTITURE_NOTIFICATION);
	RTI_MSG_NAME(NetworkMessage::REQUEST_ATTRIBUTE_OWNERSHIP_ASSUMPTION);
	RTI_MSG_NAME(NetworkMessage::ATTRIBUTE_OWNERSHIP_UNAVAILABLE);
	RTI_MSG_NAME(NetworkMessage::ATTRIBUTE_OWNERSHIP_ACQUISITION_IF_AVAILABLE);
	RTI_MSG_NAME(NetworkMessage::UNCONDITIONAL_ATTRIBUTE_OWNERSHIP_DIVESTITURE);
	RTI_MSG_NAME(NetworkMessage::ATTRIBUTE_OWNERSHIP_ACQUISITION);
	RTI_MSG_NAME(NetworkMessage::REQUEST_ATTRIBUTE_OWNERSHIP_RELEASE);
	RTI_MSG_NAME(NetworkMessage::CANCEL_NEGOTIATED_ATTRIBUTE_OWNERSHIP_DIVESTITURE);
	RTI_MSG_NAME(NetworkMessage::ATTRIBUTE_OWNERSHIP_RELEASE_RESPONSE);
	RTI_MSG_NAME(NetworkMessage::CANCEL_ATTRIBUTE_OWNERSHIP_ACQUISITION);
	RTI_MSG_NAME(NetworkMessage::CONFIRM_ATTRIBUTE_OWNERSHIP_ACQUISITION_CANCELLATION);
	RTI_MSG_NAME(NetworkMessage::DDM_CREATE_REGION);
	RTI_MSG_NAME(NetworkMessage::DDM_MODIFY_REGION);
	RTI_MSG_NAME(NetworkMessage::DDM_DELETE_REGION);
	RTI_MSG_NAME(NetworkMessage::DDM_ASSOCIATE_REGION);
	RTI_MSG_NAME(NetworkMessage::DDM_UNASSOCIATE_REGION);
	RTI_MSG_NAME(NetworkMessage::DDM_SUBSCRIBE_ATTRIBUTES);
	RTI_MSG_NAME(NetworkMessage::DDM_UNSUBSCRIBE_ATTRIBUTES);
	RTI_MSG_NAME(NetworkMessage::DDM_SUBSCRIBE_INTERACTION);
	RTI_MSG_NAME(NetworkMessage::DDM_UNSUBSCRIBE_INTERACTION);

        initialized = true ;
    }
}

// ----------------------------------------------------------------------------
//! Increment counter for RTIG message type received.
void
Statistics::rtiService(NetworkMessage::Type service)
{
    rtiServiceSet[service]++ ;
}

// ----------------------------------------------------------------------------
//! Increment counter for Federate message type received.
void
Statistics::federateService(Message::Type service)
{
    federateServiceSet[service]++ ;
}

// ----------------------------------------------------------------------------
//! Display collected data.
ostream &
operator<<(ostream &s, Statistics &stat)
{
    cout << endl << "RTIA: Statistics (processed messages)" << endl ;

    s << "List of federate initiated services " << endl
      << "--------------------------------------------------" << endl ;

    int sentFederateMessages = 0 ;

    for (int i = Message::NOT_USED ; i < Message::LAST ; ++i) {
	int nb = stat.federateServiceSet[i] ;
	if (nb > 0 || stat.displayZero()) {
	    s.width(8);
	    s << nb << ' ' << Statistics::fedMessageName[i].c_str() << " (MSG#"
	      << i << ")" << endl ;
        }
        sentFederateMessages += nb ;
    }

    s << endl << "List of RTI initiated services " << endl
      << "--------------------------------------------------" << endl ;

    int sentRtiMessages = 0 ;

    for (int i = NetworkMessage::NOT_USED ; i < NetworkMessage::LAST ; ++i) {
        int nb = stat.rtiServiceSet[i] ;
        if (nb > 0 || stat.displayZero()) {
            s.width(8);
            s << nb << ' ' << Statistics::rtiMessageName[i].c_str() << " (MSG#"
	      << i << ")" << endl ;
        }
        sentRtiMessages += nb ;
    }

    s << endl
      << " Number of Federate messages : " << sentFederateMessages << endl
      << " Number of RTIG messages : " << sentRtiMessages << endl ;

    return s ;
}

}} // namespace certi::rtia

#undef FED_MSG_NAME
#undef RTI_MSG_NAME

// $Id: Statistics.cc,v 3.11 2004/03/12 19:42:23 breholee Exp $