src/neco/resources/linux/channel.py

   1 from neco.execution.attribute import Attribute, Flags
   2 from neco.execution.resource import ResourceManager, clsinit, ResourceState
   3 from neco.resources.linux.node import LinuxNode
   4
   5 import collections
   6 import logging
   7 import os
   8 import random
   9 import re
  10 import tempfile
  11 import time
  12 import threading
  13
  14 @clsinit
  15 class LinuxChannel(ResourceManager):
  16     _rtype = "LinuxChannel"
  17
  18     def __init__(self, ec, guid):
  19         super(LinuxChannel, self).__init__(ec, guid)
  20         self._logger = logging.getLogger("LinuxChannel")
  21
  22     def log_message(self, msg):
  23         return " guid %d - %s " % (self.guid, msg)
  24
  25     def valid_connection(self, guid):
  26         # TODO: Validate!
  27         return True