CurrValClient.py

Go to the documentation of this file.

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

__facility__ = "Online"
__abstract__ = "Current Value Table Client"
__author__  = "Jim Panetta <panetta@slac.stanford.edu> SLAC - GLAST LAT I&T/Online"
__date__     = ("$Date: 2006/01/28 05:35:25 $").split(' ')[1]
__version__ = "$Revision: 1.9 $"
__release__  = "$Name: HEAD $"
__credits__ = "SLAC"

import LICOS.copyright_SLAC

import LICOS.util.gOptions as gOptions

import threading, asyncore, socket
import time
import cPickle as pickle

from LICOS.lib.currValTable.StringTcpProtocol import Int16StringProtocol
from LICOS.lib.currValTable.CurrValTable      import *

class CurrValClient(Int16StringProtocol):
  def __init__(self,  host, port, mnemList):

    super(CurrValClient, self).__init__()
    self.__mnemList = mnemList

    # build the main connection socket
    self.create_socket(socket.AF_INET,socket.SOCK_STREAM)

    self.__host = host
    self.__port = port
    self.__connect()

  def __connect(self):
    self.connect( (self.__host, self.__port) )


  def handle_connect(self):
    pass

  def handle_close(self):
    # Try an exponential reconnect?  ****REVISIT****
    self.close()

  def stringReceived(self, line):
    # print "got stringRec", len(line)
    response = line[0:3]
    fields   = line.split()
    if response ==   'ok ':
      self.sendString("observer")
      pass
    elif response == 'ob ':
      # print fields
      self.registerAll()
      pass
    elif response == "up ":
      # print "dispatch update"
      
      self.update(decodeCurrentValue(line[3:]))
    else:
      print "bad response:", line

  def register(self, mnem):
    query = "register " + mnem
    self.sendString(query)

  def unregister(self, mnem):
    query = "unregister " + mnem
    self.sendString(query)

  def registerAll(self):
    for mnem in self.__mnemList:
      self.register(mnem)

  def update(self, cv):
    """!\brief update method

    to be overridden by the sub class

    \param mnem
    \param value
    """
    print "recieved update of ", cv.name, " =", cv.rawValue()

if __name__ == '__main__':

  options = gOptions.Options(['cvtHost', 'cvtPort'])
  try:
    options.parse()
  except Exception, msg:
    options.usage(str(msg))
    exit

  cvtHost = options.cvtHost
  cvtPort = int(options.cvtPort)


  mnemList = []
  mnemList.append("LHKT5TKRC5T0")


  cvc = CurrValClient( cvtHost, cvtPort, mnemList )

  asyncore.loop(1)










#eof

---