ScienceProxy.py

Go to the documentation of this file.

#!/usr/local/bin/python
#
#                               Copyright 2005
#                                     by
#                        The Board of Trustees of the
#                     Leland Stanford Junior University.
#                            All rights reserved.
#

__facility__ = "Online"
__abstract__ = "Science Proxy class"
__author__   = "S. Tuvi <stuvi@slac.stanford.edu> SLAC - GLAST LAT I&T/Online"
__date__     = "2006/01/16"
__updated__  = "$Date: 2006/04/25 17:22:01 $"
__version__  = "$Revision: 1.11 $"
__release__  = "$Name: HEAD $"
__credits__  = "SLAC"

import LICOS.copyright_SLAC

import VSC
import CCSDS

from LICOS.util.gOptions import Options
from LICOS.tools.proxy.VscProxyPorts import VscProxyPorts
from LICOS.tools.proxy.VscProxyTools import getip, VscProxyLogger
from LICOS.tools.proxy.VscArchivers  import VscArchiver

import os
import sys
import time
from ConfigParser import ConfigParser


class VscScienceRouter(VSC.VscRouting.ScienceRouter):
  def __init__(self, streams):
    VSC.VscRouting.ScienceRouter.__init__(self)
    self.__packet = CCSDS.Ccsds.Science(0, 0, 0)
    self.__streams = streams
    self.__apids = {}

  def allocate(self):
    return self.__packet

  def catchall(self, ccsds):
    apid = ccsds.apid()
    if apid in self.__apids.keys():
      self.__apids[apid] += 1
    else:
      self.__apids[apid] = 1
    for stream in self.__streams:
      stream.send_nothrow(ccsds)

  def apids(self):
    return self.__apids


class ScienceProxy(VSC.VscProxy.Proxy):
  def __init__(self, ip_vsc, config, noarchiver):
    ports = VscProxyPorts(config.getint('vsc', 'proxyPortBase'))
    VSC.VscProxy.Proxy.__init__(self, ip_vsc, ports.vsc())
    self.__archiver = None
    if noarchiver is False:
      archive_path = config.get('paths', 'archive_path')
      granularity  = config.getint('ccsds_archivers', 'granularity')
      self.__archiver = VscArchiver(apIdGrp = "SCI",
                                    path = archive_path,
                                    granularity = granularity)
    self.router = VscScienceRouter([self.__archiver])
    self.latScience(self.router)


if __name__ == '__main__':
  options = Options(['vscip', 'config'], [], ['logtime', 'noarchiver'])
  try:
    options.parse()
  except Exception, msg:
    options.usage(str(msg))
    sys.exit()
  
  if options.logtime is not None:
    sys.stdout = VscProxyLogger('science proxy: ')
    sys.stderr = sys.stdout

  vscip = getip(options.vscip)
  config = ConfigParser()
  config.read(options.config)
  dumpInterval = config.getint('vsc', 'dumpInterval')
  noarchiver = (options.noarchiver is not None)
  proxy = ScienceProxy(vscip, config, noarchiver)
  apids = proxy.router.apids()
  while True:
    time.sleep(dumpInterval)
    npackets = 0
    msg = ''
    for (apid, counter) in apids.items():
      npackets += counter
      msg += ', 0x%x: %d' %(apid, counter)
    print 'received %d packets%s' %(npackets, msg)
    sys.stdout.flush()

---