// $Header: /cvs/gled-1.2/GledCore/Glasses/SaturnInfo.cxx,v 1.6 2005/05/30 11:41:03 matevz Exp $

// Copyright (C) 1999-2005, Matevz Tadel. All rights reserved.
// This file is part of GLED, released under GNU General Public License version 2.
// For the licensing terms see $GLEDSYS/LICENSE or http://www.gnu.org/.

//______________________________________________________________________
// SaturnInfo
//
// Saturnnfo glass represents a Saturn within a Gled cluster.

#include <Gled/GledNS.h>
#include "SaturnInfo.h"
#include <Ephra/Saturn.h>
#include <Glasses/ZQueen.h>
#include <Glasses/EyeInfo.h>
#include <Stones/ZMIR.h>

#include <TSocket.h>
#include <TSystem.h>

#include "SaturnInfo.c7"

ClassImp(SaturnInfo)

 SaturnInfo::SaturnInfo(const Text_t* n, const Text_t* t) : 
  ZMirEmittingEntity(n,t)
{
  hSocket = 0; hRoute = 0;

  mHostName   = ""; mServerPort = GLED_DEF_PORT; mServPortScan = 0;
  mMasterName = ""; mMasterPort = GLED_DEF_PORT;

  mSunSpaceSize = mKingID = mFireKingID = 0;
  bUseAuth = false;

  mCPU_Model = "<unknown>"; mCPU_Freq = mCPU_Num = 0;
  mMemory = mSwap = mMFree = mSFree = 0;
  mLAvg1 = mLAvg5 = mLAvg15 = 0;
  mCU_Total = mCU_User = mCU_Nice = mCU_Sys = 0;

  mMaster = 0; mMoons = 0; mEyes = 0;
}

 SaturnInfo::~SaturnInfo()
{}

/**************************************************************************/

 void SaturnInfo::Message(const Text_t* s)
{
  ISmess(string("Received message: ") + s);
}

 void SaturnInfo::Error(const Text_t* s)
{
  ISerr(string("Received error: ") + s);
}

/**************************************************************************/

 void SaturnInfo::create_lists()
{
  ZHashList* l;
  l = new ZHashList(GForm("Moons of %s", mName.Data()));
  mQueen->CheckIn(l); SetMoons(l);
  l = new ZHashList(GForm("Eyes of %s", mName.Data()));
  mQueen->CheckIn(l); SetEyes(l);
}

/**************************************************************************/
/**************************************************************************/



/**************************************************************************/
/**************************************************************************/
/**************************************************************************/
/**************************************************************************/
/*
void SaturnInfo::handle_new_connection()
{
  // Called from local Saturn to manage login procedure for a new connection.
  // Beams SunAbsolute ... then waits for its responses.

  // create connection object

  // create beam ... send to SA

  // wait for response

  // if ok ... pass connection key, host, port to the new connectee

  // wait for response

  // if ok ... pass data to the new connectee
}

void SaturnInfo::new_connection_request(SaturnInfo* host)
{
  // Called by an SaturnInfo in an attempt to initiate new connection.
  // Must be sent to SunAbsolute via a beamed MIR.

}

void SaturnInfo::new_connection_result()
{
  // Called by SunAbsolute upon receiving new_connection_request().
  // Beamed back to host that sent the original request.

  // unstream and set data
  // signal condition
}

void SaturnInfo::handle_login(TMessage* msg)
{
  // Called by SunAbsoulte upon receiving login request.

  
}

void SaturnInfo::login_result()
{
  // Called by SunAbsolute upon finalizing login procedure of a new MEE.
  // Beamed back to host that sent the original request.

  // unstream data
  // signal condition
}

*/

/**************************************************************************/
/**************************************************************************/

 void SaturnInfo::AddMoon(SaturnInfo* moon)
{
  // blabla ...
  // moon->create_lists
}

 void SaturnInfo::AddEye(EyeInfo* eye)
{

}

/**************************************************************************/

 void SaturnInfo::ReceiveBeamResult(UInt_t req_handle)
{
  // Should be called via S_ and passed as beam to beam result
  // requestor (a SaturnInfo).

  static const string _eh("SaturnInfo::ReceiveBeamResult ");

  ZMIR* mir = assert_MIR_presence(_eh);

  mSaturn->handle_mir_result(req_handle, mir);
}

/**************************************************************************/

 void SaturnInfo::TellAverages()
{
  // Sort-of-a demo for Beam Result facility.

  static const string _eh("SaturnInfo::TellAverages ");

  assert_MIR_presence(_eh, ZGlass::MC_IsBeam | ZGlass::MC_HasResultReq);

  UInt_t  j[4];
  Float_t l[3] = {0,0,0};
  FILE* p = gSystem->OpenPipe("GledNodeReport.pl cpureport", "r");
  if(p != 0) {
    fscanf(p, "%u %u %u %u", &j[0], &j[1], &j[2], &j[3]);
    fscanf(p, "%f %f %f", &l[0], &l[1], &l[2]);
  }
  gSystem->ClosePipe(p);


  TBuffer ret(TBuffer::kWrite);
  ret << l[0] << l[1] << l[2];
  mSaturn->ShootMIRResult(ret);
}

/**************************************************************************/