Synnefo » snf-ganeti » ganeti-local

from ganeti import errors

from ganeti import serializer

from ganeti import objects

from ganeti import impexpd

from ganeti import netutils

      poller.register(fd, select.POLLIN)

    if options.connect_timeout and mode == constants.IEM_IMPORT:

    else:

      listen_timeout = None

          logging.info("Child process didn't establish connection in time")

          child.Kill(signal.SIGTERM)

          exit_timeout = \

          # Next block will calculate timeout

        else:

          # Not yet connected, check again in a second

        notify_status = child_io_proc.NotifyDd()

        if notify_status:

          # Schedule next notification

        else:

          # Try again soon (dd isn't ready yet)

      if dd_stats_timeout:

        dd_timeout = max(0, dd_stats_timeout.Remaining() * 1000)

                  logging.info("Giving child process %0.2f seconds to exit",

                               CHILD_LINGER_TIMEOUT)

                  exit_timeout = \

          else:

            poller.unregister(fd)

            del fdmap[fd]