HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.  2.0.0-chaika
Hierarchical Cluster Engine Python language binding
app.Utils.LoggerFileName Class Reference
Inheritance diagram for app.Utils.LoggerFileName:
Collaboration diagram for app.Utils.LoggerFileName:

Public Member Functions

def __init__ (self, loggerInst=None)
 
def getFreeProcInstanceNumber (self, sock_prefix="module", min_number=0, max_number=32)
 
def findReplace (self, newFile=None, rollover=True)
 

Public Attributes

 loggerInst
 

Detailed Description

Definition at line 822 of file Utils.py.

Constructor & Destructor Documentation

◆ __init__()

def app.Utils.LoggerFileName.__init__ (   self,
  loggerInst = None 
)

Definition at line 825 of file Utils.py.

825  def __init__(self, loggerInst=None):
826  self.loggerInst = loggerInst
827 
828 
def __init__(self)
constructor
Definition: UIDGenerator.py:19

Member Function Documentation

◆ findReplace()

def app.Utils.LoggerFileName.findReplace (   self,
  newFile = None,
  rollover = True 
)

Definition at line 850 of file Utils.py.

850  def findReplace(self, newFile=None, rollover=True):
851  log_file = None
852 
853  if self.loggerInst is None:
854  lg = logging.getLogger('')
855  else:
856  lg = self.loggerInst
857  for h in lg.__dict__['handlers']:
858  if h.__class__.__name__ == 'FileHandler':
859  log_file = h.baseFilename
860  if newFile is not None:
861  h.baseFilename = newFile
862  if h.stream:
863  h.stream.close()
864  h.stream = None
865  h.stream = h._open() # pylint: disable=W0212
866  if os.path.exists(newFile):
867  t = os.stat(newFile)[ST_MTIME]
868  else:
869  t = int(time.time())
870  h.rolloverAt = h.computeRollover(t)
871  if rollover and h.shouldRollover(''):
872  h.doRollover()
873  break
874  elif h.__class__.__name__ == 'TimedRotatingFileHandler':
875  log_file = h.baseFilename
876  if newFile is not None:
877  h.baseFilename = newFile
878  if h.stream:
879  h.stream.close()
880  h.stream = None
881  h.stream = h._open() # pylint: disable=W0212
882  if rollover and h.shouldRollover(''):
883  h.doRollover()
884  break
885 
886  return log_file
887 
888 
889 
890 # #Flush logger's file type handlers
891 #
892 # @param loggerObj

◆ getFreeProcInstanceNumber()

def app.Utils.LoggerFileName.getFreeProcInstanceNumber (   self,
  sock_prefix = "module",
  min_number = 0,
  max_number = 32 
)

Definition at line 829 of file Utils.py.

829  def getFreeProcInstanceNumber(self, sock_prefix="module", min_number=0, max_number=32):
830  ret = ""
831 
832  for i in range(min_number, max_number):
833  try:
834  import socket
835 
836  global lock_socket # pylint: disable=W0601
837  lock_socket = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM)
838 
839  # Create an abstract socket
840  lock_socket.bind('\0' + "dc_process_lock_" + sock_prefix + str(i))
841  ret = str(i)
842  break
843  except socket.error:
844  # Socket already exists
845  continue
846 
847  return ret
848 
849 

Member Data Documentation

◆ loggerInst

app.Utils.LoggerFileName.loggerInst

Definition at line 826 of file Utils.py.


The documentation for this class was generated from the following file: