
import os
import sys

from tornado.httpserver import HTTPServer
from tornado.ioloop import IOLoop, PeriodicCallback


from gunicorn.workers.base import Worker
from gunicorn import __version__ as gversion


def patch_request_handler():
    web = sys.modules.pop("tornado.web")

    old_clear = web.RequestHandler.clear

    def clear(self):
        old_clear(self)
        self._headers["Server"] += " (Gunicorn/%s)" % gversion
         
    web.RequestHandler.clear = clear
    sys.modules["tornado.web"] = web
    

class TornadoWorker(Worker):
    
    @classmethod
    def setup(cls):
        patch_request_handler()
        
    def watchdog(self):
        self.notify()
            
        if self.ppid != os.getppid():
            self.log.info("Parent changed, shutting down: %s" % self)
            self.ioloop.stop()
    
    def run(self):
        self.socket.setblocking(0)
        self.ioloop = IOLoop.instance()
        PeriodicCallback(self.watchdog, 1000, io_loop=self.ioloop).start()

        server = HTTPServer(self.app, io_loop=self.ioloop)
        server._socket = self.socket
        server.start(num_processes=1)

        self.ioloop.start()


import os
import sys

import tornado.web
from tornado.httpserver import HTTPServer
from tornado.ioloop import IOLoop, PeriodicCallback


from gunicorn.workers.base import Worker
from gunicorn import __version__ as gversion


def patch_request_handler():
    web = sys.modules.pop("tornado.web")

    old_clear = web.RequestHandler.clear

    def clear(self):
        old_clear(self)
        self._headers["Server"] += " (Gunicorn/%s)" % gversion
         
    web.RequestHandler.clear = clear
    sys.modules["tornado.web"] = web
    

class TornadoWorker(Worker):
    
    @classmethod
    def setup(cls):
        patch_request_handler()
        
    def watchdog(self):
        self.notify()
            
        if self.ppid != os.getppid():
            self.log.info("Parent changed, shutting down: %s" % self)
            self.ioloop.stop()
    
    def run(self):
        self.socket.setblocking(0)
        self.ioloop = IOLoop.instance()
        PeriodicCallback(self.watchdog, 1000, io_loop=self.ioloop).start()

        server = HTTPServer(self.app, io_loop=self.ioloop)
        server._socket = self.socket
        server.start(num_processes=1)

        self.ioloop.start()

Fix assumption that tornado.web was imported.
Fix assumption that tornado.web was imported.

  
  import os
  import sys
  
+ import tornado.web
  from tornado.httpserver import HTTPServer
  from tornado.ioloop import IOLoop, PeriodicCallback
  
  
  from gunicorn.workers.base import Worker
  from gunicorn import __version__ as gversion
  
  
  def patch_request_handler():
      web = sys.modules.pop("tornado.web")
  
      old_clear = web.RequestHandler.clear
  
      def clear(self):
          old_clear(self)
          self._headers["Server"] += " (Gunicorn/%s)" % gversion
           
      web.RequestHandler.clear = clear
      sys.modules["tornado.web"] = web
      
  
  class TornadoWorker(Worker):
      
      @classmethod
      def setup(cls):
          patch_request_handler()
          
      def watchdog(self):
          self.notify()
              
          if self.ppid != os.getppid():
              self.log.info("Parent changed, shutting down: %s" % self)
              self.ioloop.stop()
      
      def run(self):
          self.socket.setblocking(0)
          self.ioloop = IOLoop.instance()
          PeriodicCallback(self.watchdog, 1000, io_loop=self.ioloop).start()
  
          server = HTTPServer(self.app, io_loop=self.ioloop)
          server._socket = self.socket
          server.start(num_processes=1)
  
          self.ioloop.start()
  
Fix assumption that tornado.web was imported.
## Code Before:

import os
import sys

from tornado.httpserver import HTTPServer
from tornado.ioloop import IOLoop, PeriodicCallback


from gunicorn.workers.base import Worker
from gunicorn import __version__ as gversion


def patch_request_handler():
    web = sys.modules.pop("tornado.web")

    old_clear = web.RequestHandler.clear

    def clear(self):
        old_clear(self)
        self._headers["Server"] += " (Gunicorn/%s)" % gversion
         
    web.RequestHandler.clear = clear
    sys.modules["tornado.web"] = web
    

class TornadoWorker(Worker):
    
    @classmethod
    def setup(cls):
        patch_request_handler()
        
    def watchdog(self):
        self.notify()
            
        if self.ppid != os.getppid():
            self.log.info("Parent changed, shutting down: %s" % self)
            self.ioloop.stop()
    
    def run(self):
        self.socket.setblocking(0)
        self.ioloop = IOLoop.instance()
        PeriodicCallback(self.watchdog, 1000, io_loop=self.ioloop).start()

        server = HTTPServer(self.app, io_loop=self.ioloop)
        server._socket = self.socket
        server.start(num_processes=1)

        self.ioloop.start()

## Instruction:
Fix assumption that tornado.web was imported.
## Code After:

import os
import sys

import tornado.web
from tornado.httpserver import HTTPServer
from tornado.ioloop import IOLoop, PeriodicCallback


from gunicorn.workers.base import Worker
from gunicorn import __version__ as gversion


def patch_request_handler():
    web = sys.modules.pop("tornado.web")

    old_clear = web.RequestHandler.clear

    def clear(self):
        old_clear(self)
        self._headers["Server"] += " (Gunicorn/%s)" % gversion
         
    web.RequestHandler.clear = clear
    sys.modules["tornado.web"] = web
    

class TornadoWorker(Worker):
    
    @classmethod
    def setup(cls):
        patch_request_handler()
        
    def watchdog(self):
        self.notify()
            
        if self.ppid != os.getppid():
            self.log.info("Parent changed, shutting down: %s" % self)
            self.ioloop.stop()
    
    def run(self):
        self.socket.setblocking(0)
        self.ioloop = IOLoop.instance()
        PeriodicCallback(self.watchdog, 1000, io_loop=self.ioloop).start()

        server = HTTPServer(self.app, io_loop=self.ioloop)
        server._socket = self.socket
        server.start(num_processes=1)

        self.ioloop.start()
