shutdown_dispatcher.py

   1 # -*- coding: utf-8 -*-
   2 #######################################################################################
   3 #   Plinn - http://plinn.org                                                          #
   4 #   Copyright (C) 2005-2009  Benoît PIN <benoit.pin@ensmp.fr>                         #
   5 #                                                                                     #
   6 #   This program is free software; you can redistribute it and/or                     #
   7 #   modify it under the terms of the GNU General Public License                       #
   8 #   as published by the Free Software Foundation; either version 2                    #
   9 #   of the License, or (at your option) any later version.                            #
  10 #                                                                                     #
  11 #   This program is distributed in the hope that it will be useful,                   #
  12 #   but WITHOUT ANY WARRANTY; without even the implied warranty of                    #
  13 #   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the                     #
  14 #   GNU General Public License for more details.                                      #
  15 #                                                                                     #
  16 #   You should have received a copy of the GNU General Public License                 #
  17 #   along with this program; if not, write to the Free Software                       #
  18 #   Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.   #
  19 #######################################################################################
  20 """ provides utilities to raise / handle zope server shutdown events
  21
  22
  23
  24 """
  25
  26 import asyncore
  27 from zope.event import notify
  28 from zope.component import getSiteManager
  29 from events import ZopeShutdownEvent
  30 from OFS.interfaces import IApplication
  31
  32 class ZopeShutdownDispatcher(asyncore.dispatcher):
  33
  34
  35         def __init__(self, app, map=None):
  36                 asyncore.dispatcher.__init__(self, None, map)
  37                 self.connected = False
  38                 self.app = self._fileno = app
  39                 self.add_channel()
  40
  41         def close(self) :
  42                 self.del_channel()
  43
  44         def readable(self):
  45                 return False
  46
  47         def handle_read(self):
  48                 return True
  49
  50         def writable(self):
  51                 return False
  52
  53         def handle_write (self):
  54                 return True
  55
  56         def clean_shutdown_control(self, phase, time):
  57                 asyncore.dispatcher.log_info(self, 'zope shutdown event raised at phase: %s' % phase, 'info')
  58                 e = ZopeShutdownEvent(self.app, phase, time)
  59                 notify(e)
  60                 return e.veto