text: #!/usr/bin/env python
  # -*- coding: utf-8 -*-
  
  # Copyright (c) 2014 clowwindy
  #
  # Permission is hereby granted, free of charge, to any person obtaining a copy
  # of this software and associated documentation files (the "Software"), to deal
  # in the Software without restriction, including without limitation the rights
  # to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
  # copies of the Software, and to permit persons to whom the Software is
  # furnished to do so, subject to the following conditions:
  #
  # The above copyright notice and this permission notice shall be included in
  # all copies or substantial portions of the Software.
  #
  # THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  # IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  # FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  # AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  # LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  # SOFTWARE.
  
  from __future__ import absolute_import, division, print_function, \
      with_statement
  
  import sys
  import os
  import logging
  import signal
  
  sys.path.insert(0, os.path.join(os.path.dirname(__file__), '../'))
  from shadowsocks import utils, daemon, encrypt, eventloop, tcprelay, udprelay,\
      asyncdns
  
  
  def main():
      utils.check_python()
  
      # fix py2exe
      if hasattr(sys, "frozen") and sys.frozen in \
              ("windows_exe", "console_exe"):
          p = os.path.dirname(os.path.abspath(sys.executable))
          os.chdir(p)
  
      config = utils.get_config(True)
  
      daemon.daemon_exec(config)
  
      utils.print_shadowsocks()
  
      encrypt.try_cipher(config['password'], config['method'])
  
      try:
          logging.info("starting local at %s:%d" %
                       (config['local_address'], config['local_port']))
  
          dns_resolver = asyncdns.DNSResolver()
          tcp_server = tcprelay.TCPRelay(config, dns_resolver, True)
          udp_server = udprelay.UDPRelay(config, dns_resolver, True)
          loop = eventloop.EventLoop()
          dns_resolver.add_to_loop(loop)
          tcp_server.add_to_loop(loop)
          udp_server.add_to_loop(loop)
  
          def handler(signum, _):
              logging.warn('received SIGQUIT, doing graceful shutting down..')
              tcp_server.close(next_tick=True)
              udp_server.close(next_tick=True)
          signal.signal(getattr(signal, 'SIGQUIT', signal.SIGTERM), handler)
  
          def int_handler(signum, _):
              sys.exit(1)
          signal.signal(signal.SIGINT, int_handler)
  
          loop.run()
      except (KeyboardInterrupt, IOError, OSError) as e:
          logging.error(e)
          if config['verbose']:
              import traceback
              traceback.print_exc()
          os._exit(1)
  
  if __name__ == '__main__':
      main()
  