Synnefo » snf-ganeti

"""

import os

import sys

class ClientRequestWorker(workerpool.BaseWorker):

  def RunTask(self, server, request, client_address):

    """Process the request.

    try:

      server.finish_request(request, client_address)

      server.close_request(request)

      server.handle_error(request, client_address)

      server.close_request(request)

    self.request_workers.AddTask(self, request, client_address)

  @utils.SignalHandled([signal.SIGINT, signal.SIGTERM])

    """Handle one request at a time until told to quit."""

    assert isinstance(signal_handlers, dict) and \

           len(signal_handlers) > 0, \

  READ_SIZE = 4096

  def setup(self):

    self._buffer = ""

    self._msgs = collections.deque()

    self._ops = ClientOps(self.server)

  def __init__(self, server):

    self.server = server

    queue = self.server.context.jobqueue

    # TODO: Parameter validation

    if method == luxi.REQ_SUBMIT_JOB:

      logging.info("Received new job")

      ops = [opcodes.OpCode.LoadOpCode(state) for state in args]

  This class creates and holds common objects shared by all threads.

  """

  _instance = None

  def __init__(self):

      # Call function

      result = int(bool(fn()))

      assert result in (0, 1)

      logging.exception("Error while calling function in separate process")

      # 0 and 1 are reserved for the return value

      result = 33

  # Parent process

    confirmation = sys.stdin.readline().strip()

    if confirmation != "YES":

      sys.exit(constants.EXIT_FAILURE)

    return