Server_Portfolio.py

Go to the documentation of this file.

#!/usr/bin/python

## @package Server_Portfolio
# @brief Main executable for running the portfolio python service.
#
# LastChanged $Id: Server_Portfolio.py 524 2015-02-24 10:18:50Z martinml $

# Main program :
#  Run the Parser: AutoParser
#  Run the Server: SocketServer_Server ( in the main thread, may change )
#
# Rewrite the log file: ServerPortfolio.log

import sys, time
import logging, logging.config
import threading

# global definition of the server
from serverportfolio.GlobalDicts import HOST,PORT, DEBUG_MODE

# dependent to set-up the singleton
from serverportfolio.DictionaryStocks import DictionaryStocks

import serverportfolio.AutoParser as AutoParser
import serverportfolio.SocketServer_Server as SocketServer_Server

################# functions

def print_help():
    print "./Server_Portfolio dictstock.txt / help "
    print " default ./dictstock.txt"
    
################ main code

# optimisation, do not want to collect process information, but thread yes !
logging.logProcesses = 0

# setup a new logger SP
# load from a file, regroup all configurations there
logging.config.fileConfig('/home/michael/workspace_kepler/ServerPortfolio/trunk/ServerPortfolio/logging.conf')
# want module information, name the logger but CANNOT call basicConfig, need explicit setup
logger = logging.getLogger('SP')

# ok for this logger, not for derived
if DEBUG_MODE :
    print "only test "
    logger.debug("test debug")
    logger.info("test info")
    logger.error("test error")

################# Main program

## do not work as expected, sys.exit certainly send an exception
try:
    fstock=sys.argv[1]
    print "fstock ", fstock
    if ( fstock == "help" ) | ( fstock == "-h" ) | ( fstock == "-help") :
        print_help()
        sys.exit(1)
    # Load the dictionnary and add the "volatile" part  
    dict_stocks = DictionaryStocks( fstock )
    
# no argument will use the default
except : #IndexError:
    #dict_stocks=DictStocks_Parser.Init()
    print "no argument, use default dictstocks.txt" 
    #dict_stocks = DictionaryStocks( load_all_stocks=True )
    dict_stocks = DictionaryStocks()
    dict_stocks.get_stocks()
    #dict_stocks.get_stocks('SP500')
    #dict_stocks.get_stocks(['FSLR','EURUS'])
    #dict_stocks.get_stocks('FAZ') #Problem with FAZ, but RunParsers FORCE is working !!, in parse cannot extract table
    #dict_stocks.get_stocks(['SP500','CAC40'])
    #dict_stocks.get_stocks(['SP500','CAC40','FSLR','DJ'])
    
## could use a return dict ( alias, only for testing ok )

#print dict_stocks

## Load AutoParser
#  Run thread queue handler
thq=AutoParser.Thread_Handle_Queue()
thq.start()

print "threading.enumerate() ", threading.enumerate()

## Load Server

# here run server in a different thread, works but main wait until join....
#server_thread = SocketServer_Server.threading.Thread(target=SocketServer_Server.run_MyServer,
#                                                     name="t-server",
#                                                     args=(HOST,PORT,thq))

## If True, exit the server thread when the main thread terminates
# Here False (default) 
#server_thread.setDaemon(False)
#server_thread.start()
#print "enumerate",threading.enumerate()
#print "Server loop running in thread:", server_thread.name
#
# wait for TCPServer thread to stop
# server_thread.join()

# simple to run like this ! The MainThread will be the server
SocketServer_Server.run_MyServer( HOST, PORT, thq)
# exit only when server will be turned off

# kill thq
thq._running = False
# ? certainly better, should join the thread ?
del thq

print "AT THE END: enumerate thread ",threading.enumerate()