DDSClientId.cxx

Go to the documentation of this file.

//                                                                           //
// DDSClientId                                                               //
//                                                                           //
// Package: DDS (Data Dispatcher System).                                    //
//                                                                           //
// S. Kasahara 10/2006                                                       //
//                                                                           //
// Purpose: Identification of DDS client.                                    //
//                                                                           //
#include <iostream>
using namespace std;

#include <TUnixSystem.h>

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

ClassImp(DDSClientId)

CVSID("$Id: DDSClientId.cxx,v 1.4 2007/08/24 05:23:48 schubert Exp $");

ostream& operator << (ostream& os, const DDSClientId& cid) { 
                                                      return cid.Print(os); } 

//_____________________________________________________________________________
DDSClientId::DDSClientId(DDS::EClientType clienttype, string clientname) :
                 fClientType(clienttype), fClientName(clientname), 
                 fUserName(""), fRealName(""), fHostName(""),fStartTime(0), 
                 fChildPid(0) {
  // Default constructor 

  if ( fClientName.size() > 30 ) {
    fClientName.resize(30);
    MSG("DDS",Msg::kWarning) << "Client name exceeds 30 character limit."
                             << "\nTruncated to " 
                             << fClientName.c_str() << endl;
  }
  
  // Fill identifying user information using system functions
  UserGroup_t* usergrp = gSystem->GetUserInfo(gSystem->GetUid());
  if ( usergrp ) {
    fUserName = usergrp -> fUser; // username
    fRealName = usergrp -> fRealName; // user's full name
  }
  else {
    MSG("DDS",Msg::kWarning) 
       << "Failed to identify user info for client w/uid "
       << gSystem->GetUid() << "." << endl;
  }
  if ( usergrp ) delete usergrp; usergrp = 0; // has ownership

  // This system's host name and ip address
  fHostName = gSystem->HostName();
  
}

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

}

//_____________________________________________________________________________
void DDSClientId::Connected(int childpid) {
  // Purpose:  Invoked by DDSParentServer when client connection with
  //           child established.  Also sets start time of connection
  //           to Now.
  //           Protected method accessible only by DDSParentServer friend.

  fChildPid = childpid;
  fStartTime = VldTimeStamp(); // set to current time

}

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

  VldTimeStamp currentTime;
  if ( fStartTime.GetSec() == 0 ) currentTime = VldTimeStamp(0);

  os << fUserName.c_str() 
     << " \"" << fRealName.c_str() << "\" "  
     << fHostName.c_str() << " Type: "
     << DDS::AsString(fClientType);

  if ( !fClientName.empty() ) os <<  "/" << fClientName.c_str();

  if ( fChildPid ) {
    os << "\n   CS pid " << fChildPid << " Start: " 
       << fStartTime.AsString("s") << " UpTime(sec): "
       << (currentTime-fStartTime).GetSec() << "." << endl;
  }
  else 
    os << endl;


  return os;

}

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

  Print(std::cout); 

}

---