old_contents: # fssync.py
  # Filesystem syncing classes.
  #
  # Copyright (C) 2014  Red Hat, Inc.
  #
  # This copyrighted material is made available to anyone wishing to use,
  # modify, copy, or redistribute it subject to the terms and conditions of
  # the GNU General Public License v.2, or (at your option) any later version.
  # This program is distributed in the hope that it will be useful, but WITHOUT
  # ANY WARRANTY expressed or implied, including the implied warranties of
  # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General
  # Public License for more details.  You should have received a copy of the
  # GNU General Public License along with this program; if not, write to the
  # Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
  # 02110-1301, USA.  Any Red Hat trademarks that are incorporated in the
  # source code or documentation are not subject to the GNU General Public
  # License and may only be used or replicated with the express permission of
  # Red Hat, Inc.
  #
  # Red Hat Author(s): Anne Mulhern <amulhern@redhat.com>
  
  import abc
  
  from six import add_metaclass
  
  from ..errors import FSError
  from .. import util
  
  from . import availability
  from . import fstask
  from . import task
  
  
  @add_metaclass(abc.ABCMeta)
  class FSSync(task.BasicApplication, fstask.FSTask):
  
      """ An abstract class that represents syncing a filesystem. """
  
      description = "filesystem syncing"
  
      @abc.abstractmethod
      def do_task(self):
          raise NotImplementedError()
  
  
  class XFSSync(FSSync):
  
      """ Sync application for XFS. """
  
      ext = availability.XFSFREEZE_APP
  
      def _freeze_command(self):
          return [str(self.ext), "-f", self.fs.system_mountpoint]
  
      def _unfreeze_command(self):
          return [str(self.ext), "-u", self.fs.system_mountpoint]
  
      def do_task(self, root="/"):
          # pylint: disable=arguments-differ
          error_msgs = self.availability_errors
          if error_msgs:
              raise FSError("\n".join(error_msgs))
  
          error_msg = None
          try:
              rc = util.run_program(self._freeze_command(), root=root)
          except OSError as e:
              error_msg = "failed to sync filesytem: %s" % e
          error_msg = error_msg or rc
  
          try:
              rc = util.run_program(self._unfreeze_command(), root=root)
          except OSError as e:
              error_msg = error_msg or "failed to sync filesystem: %s" % e
          error_msg = error_msg or rc
  
          if error_msg:
              raise FSError(error_msg)
  
  
  class UnimplementedFSSync(fstask.UnimplementedFSTask):
      pass
  
new_contents: # fssync.py
  # Filesystem syncing classes.
  #
  # Copyright (C) 2014  Red Hat, Inc.
  #
  # This copyrighted material is made available to anyone wishing to use,
  # modify, copy, or redistribute it subject to the terms and conditions of
  # the GNU General Public License v.2, or (at your option) any later version.
  # This program is distributed in the hope that it will be useful, but WITHOUT
  # ANY WARRANTY expressed or implied, including the implied warranties of
  # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General
  # Public License for more details.  You should have received a copy of the
  # GNU General Public License along with this program; if not, write to the
  # Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
  # 02110-1301, USA.  Any Red Hat trademarks that are incorporated in the
  # source code or documentation are not subject to the GNU General Public
  # License and may only be used or replicated with the express permission of
  # Red Hat, Inc.
  #
  # Red Hat Author(s): Anne Mulhern <amulhern@redhat.com>
  
  import abc
  
  from six import add_metaclass
  
  from ..errors import FSError
  from .. import util
  
  from . import availability
  from . import fstask
  from . import task
  
  
  @add_metaclass(abc.ABCMeta)
  class FSSync(task.BasicApplication, fstask.FSTask):
  
      """ An abstract class that represents syncing a filesystem. """
  
      description = "filesystem syncing"
  
      @abc.abstractmethod
      def do_task(self):
          raise NotImplementedError()
  
  
  class XFSSync(FSSync):
  
      """ Sync application for XFS. """
  
      ext = availability.XFSFREEZE_APP
  
      def _get_mountpoint(self, root=None):
          mountpoint = self.fs.system_mountpoint
          if root is not None and root.replace('/', ''):
              if mountpoint == root:
                  mountpoint = '/'
              else:
                  mountpoint = mountpoint[len(root):]
  
          return mountpoint
  
      def _freeze_command(self, root=None):
          return [str(self.ext), "-f", self._get_mountpoint(root=root)]
  
      def _unfreeze_command(self, root=None):
          return [str(self.ext), "-u", self._get_mountpoint(root=root)]
  
      def do_task(self, root="/"):
          # pylint: disable=arguments-differ
          error_msgs = self.availability_errors
          if error_msgs:
              raise FSError("\n".join(error_msgs))
  
          error_msg = None
          try:
              rc = util.run_program(self._freeze_command(root=root), root=root)
          except OSError as e:
              error_msg = "failed to sync filesytem: %s" % e
          error_msg = error_msg or rc
  
          try:
              rc = util.run_program(self._unfreeze_command(root=root), root=root)
          except OSError as e:
              error_msg = error_msg or "failed to sync filesystem: %s" % e
          error_msg = error_msg or rc
  
          if error_msg:
              raise FSError(error_msg)
  
  
  class UnimplementedFSSync(fstask.UnimplementedFSTask):
      pass
  
subject: Fix xfs sync of chrooted mountpoint.