DDSPSStatus.cxx

Go to the documentation of this file.

//                                                                           //
// DDSPSStatus                                                               //
//                                                                           //
// Package: DDS (Data Dispatcher System).                                    //
//                                                                           //
// S. Kasahara 10/2006                                                       //
//                                                                           //
// Purpose: DDS Parent Server status.                                        //
//                                                                           //
// Parent Server Status.  This class maintains a map of child process id's   //
//                        and their associated DDSClientId's.                //
//                        DDSParentServer has a DDSPSStatus data member.     //
//                        One use is that a "ddscomm -r" request for DDS     //
//                        parent server status report will have the parent   //
//                        server ship its DDSPSStatus object to the ddscomm  //
//                        client.                                            //
#include <iostream>
using namespace std;

#include "Dispatcher/DDSPSStatus.h"
#include "Dispatcher/DDSClientId.h"
#include "MessageService/MsgService.h"

ClassImp(DDSPSStatus)

CVSID("$Id: DDSPSStatus.cxx,v 1.2 2006/11/01 02:44:56 schubert Exp $");

ostream& operator << (ostream& os, const DDSPSStatus& pss) { 
                                             return pss.Print(os); } 

//_____________________________________________________________________________
DDSPSStatus::DDSPSStatus() : fClientMap() {
  // Default constructor 
  
}

//_____________________________________________________________________________
DDSPSStatus::~DDSPSStatus() {
  // Destructor.

  // Owns all DDSClientId's in map
  for ( ClientMapItr itr=fClientMap.begin(); itr != fClientMap.end(); itr++ ) {
    DDSClientId* clientid = itr->second;
    if ( clientid ) delete clientid; clientid = 0;
  }
  fClientMap.clear();

}

//_____________________________________________________________________________
const DDSClientId* DDSPSStatus::GetClientId(int childpid) const {
  // Purpose: Retrieve ClientId corresponding child process id childpid from 
  // map. If not in map, return null.

  ClientMapConstItr citr = fClientMap.find(childpid);
  if ( citr == fClientMap.end() ) return 0;
  
  return citr -> second;

}

//_____________________________________________________________________________
void DDSPSStatus::SetClientId(int childpid, DDSClientId* cid) {
  // Purpose:  Set client id in fClientMap associated with child process id
  //           childpid.  ClientId is owned by this.

  fClientMap.insert(make_pair(childpid,cid));

}

//_____________________________________________________________________________
void DDSPSStatus::RemoveClientId(int childpid) {
  // Purpose:  Remove map entry corresponding to child process id childpid.

  ClientMapItr itr = fClientMap.find(childpid);
  if ( itr == fClientMap.end() ) {
    MSG("DDS",Msg::kWarning) << "DDSPSStatus::RemoveClientId w/Child pid " 
    << childpid << "\nbut no matching pid in map." << endl;
    return;  
  }

  if ( itr -> second ) delete (itr->second);
  fClientMap.erase(itr);

  return;

}

//_____________________________________________________________________________
std::ostream& DDSPSStatus::Print(std::ostream& os) const {
  // Purpose: Print DDSPSStatus status on std::ostream.

  os << "DDSParentServer Status: ";

  if ( fClientMap.size() == 0 ) { 
    os << "No active clients." << endl;
    return os;
  }
  
  // Loop over map containing active clients
  if ( fClientMap.size() == 1 ) 
    os << fClientMap.size() << " active client." << endl;
  else
    os << fClientMap.size() << " active clients." << endl;

  int ic = 0;
  for ( ClientMapConstItr citr = fClientMap.begin(); citr != fClientMap.end(); 
                                                     citr++ ) {
    DDSClientId* clientid = citr -> second;
    os << ic++ << ") " << *clientid;
  }
  os << endl;
  
  return os;

}

//_____________________________________________________________________________
void DDSPSStatus::Print(Option_t* /* option */) const { 
  // Purpose: Print method in TObject::Print format

  Print(std::cout); 

}

---