Revision c92af313 db/db_controller.py

b/db/db_controller.py
19 19 

  		





  20
  20
  
    
setup_environ(settings)


  		





  21
  21
  
    

  		





  22
  
  
    
import sys


  		





  23
  22
  
    
import zmq


  		





  24
  23
  
    
import time


  		





  25
  24
  
    
import json


  		





  ......




  34
  33
  
    
GANETI_ZMQ_PUBLISHER = "tcp://62.217.120.67:5801" # FIXME: move to settings.py


  		





  35
  34
  
    

  		





  36
  35
  
    
class StoppableThread(Thread):


  		





  37
  
  
    
    """Thread class with a stop() moethod.


  		





  
  36
  
    
    """Thread class with a stop() method.


  		





  38
  37
  
    
    


  		





  39
  38
  
    
    The thread needs to check regularly for the stopped() condition.


  		





  40
  39
  
    
    When it does, it exits, so that another thread may .join() it.


  		












Also available in:
  Unified diff