commit:     e6777b92a3c4aa1d23ccb868146a71336b29cf8a
Author:     Michał Górny <mgorny <AT> gentoo <DOT> org>
AuthorDate: Sat Jan 17 13:29:30 2015 +0000
Commit:     Michał Górny <mgorny <AT> gentoo <DOT> org>
CommitDate: Sun Jan 18 18:04:25 2015 +0000
URL:        
http://sources.gentoo.org/gitweb/?p=proj/portage.git;a=commit;h=e6777b92

sync: unify syncing messages and reduce noise

Print single ">>> Syncing repository '%s' into '%s'..." before syncing,
and single "=== Sync completed for %s" after successful sync.

Remove duplicate in-module clone/pull messages. Instead, verbosely print
git commands executed.

Remove useless verbosity in pre-sync mkdir.

---
 pym/portage/sync/controller.py              |  8 +++++---
 pym/portage/sync/modules/cvs/cvs.py         |  6 ------
 pym/portage/sync/modules/git/git.py         | 31 +++++++++++------------------
 pym/portage/sync/modules/rsync/rsync.py     |  2 +-
 pym/portage/sync/modules/svn/svn.py         |  6 ------
 pym/portage/sync/modules/websync/websync.py |  6 ------
 6 files changed, 18 insertions(+), 41 deletions(-)

diff --git a/pym/portage/sync/controller.py b/pym/portage/sync/controller.py
index 3d217db..128a38e 100644
--- a/pym/portage/sync/controller.py
+++ b/pym/portage/sync/controller.py
@@ -156,6 +156,10 @@ class SyncManager(object):
                #print("result:", result, "callback()", self.callback)
                exitcode, updatecache_flg = result
                self.exitcode = exitcode
+               if exitcode == 0:
+                       msg = "=== Sync completed for %s" % self.repo.name
+                       self.logger(self.xterm_titles, msg)
+                       writemsg_level(msg + "\n")
                if self.callback:
                        self.callback(exitcode, updatecache_flg)
                return
@@ -184,7 +188,7 @@ class SyncManager(object):
        def pre_sync(self, repo):
                self.settings, self.trees, self.mtimedb = self.emerge_config
                self.xterm_titles = "notitles" not in self.settings.features
-               msg = ">>> Synchronization of repository '%s' located in 
'%s'..." \
+               msg = ">>> Syncing repository '%s' into '%s'..." \
                        % (repo.name, repo.location)
                self.logger(self.xterm_titles, msg)
                writemsg_level(msg + "\n")
@@ -255,8 +259,6 @@ class SyncManager(object):
                        if 'gid' in spawn_kwargs:
                                perms['gid'] = spawn_kwargs['gid']
 
-                       writemsg_level(">>> '%s' not found, creating it."
-                               % _unicode_decode(repo.location))
                        portage.util.ensure_dirs(repo.location, **perms)
                        st = os.stat(repo.location)
 

diff --git a/pym/portage/sync/modules/cvs/cvs.py 
b/pym/portage/sync/modules/cvs/cvs.py
index 52d5d9a..2c3c6a3 100644
--- a/pym/portage/sync/modules/cvs/cvs.py
+++ b/pym/portage/sync/modules/cvs/cvs.py
@@ -28,9 +28,6 @@ class CVSSync(SyncBase):
                if kwargs:
                        self._kwargs(kwargs)
                #initial checkout
-               msg = ">>> Starting initial cvs checkout with %s..." % 
self.repo.sync_uri
-               self.logger(self.xterm_titles, msg)
-               writemsg_level(msg + "\n")
                try:
                        os.rmdir(self.repo.location)
                except OSError as e:
@@ -68,9 +65,6 @@ class CVSSync(SyncBase):
                if cvs_root.startswith("cvs://"):
                        cvs_root = cvs_root[6:]
                        #cvs update
-                       msg = ">>> Starting cvs update with %s..." % 
self.repo.sync_uri
-                       self.logger(self.xterm_titles, msg)
-                       writemsg_level(msg + "\n")
                        exitcode = portage.process.spawn_bash(
                                "cd %s; exec cvs -z0 -q update -dP" % \
                                (portage._shell_quote(self.repo.location),),

diff --git a/pym/portage/sync/modules/git/git.py 
b/pym/portage/sync/modules/git/git.py
index c5c569e..3acfc2a 100644
--- a/pym/portage/sync/modules/git/git.py
+++ b/pym/portage/sync/modules/git/git.py
@@ -45,29 +45,25 @@ class GitSync(SyncBase):
                                        'Created new directory %s' % 
self.repo.location)
                except IOError:
                        return (1, False)
-               msg = ">>> Cloning git repository from upstream into %s..." % 
self.repo.location
-               self.logger(self.xterm_titles, msg)
-               writemsg_level(msg + "\n")
                sync_uri = self.repo.sync_uri
                if sync_uri.startswith("file://"):
                        sync_uri = sync_uri[6:]
                depth_arg = ''
                if self.repo.sync_depth is not None:
                        depth_arg = '--depth %d ' % self.repo.sync_depth
-               exitcode = portage.process.spawn_bash("cd %s ; %s clone %s%s ." 
% \
-                       (portage._shell_quote(self.repo.location),
-                       self.bin_command,
-                       depth_arg,
-                       portage._shell_quote(sync_uri)),
+
+               git_cmd = "%s clone %s%s ." % (self.bin_command, depth_arg,
+                               portage._shell_quote(sync_uri))
+               writemsg_level(git_cmd + "\n")
+
+               exitcode = portage.process.spawn_bash("cd %s ; exec %s" % (
+                               portage._shell_quote(self.repo.location), 
git_cmd),
                        **portage._native_kwargs(self.spawn_kwargs))
                if exitcode != os.EX_OK:
                        msg = "!!! git clone error in %s" % self.repo.location
                        self.logger(self.xterm_titles, msg)
                        writemsg_level(msg + "\n", level=logging.ERROR, 
noiselevel=-1)
                        return (exitcode, False)
-               msg = ">>> Git clone successful"
-               self.logger(self.xterm_titles, msg)
-               writemsg_level(msg + "\n")
                return (os.EX_OK, True)
 
 
@@ -82,18 +78,15 @@ class GitSync(SyncBase):
                emerge_config = self.options.get('emerge_config', None)
                portdb = self.options.get('portdb', None)
 
-               msg = ">>> Starting git pull in %s..." % self.repo.location
-               self.logger(self.xterm_titles, msg)
-               writemsg_level(msg + "\n")
-               exitcode = portage.process.spawn_bash("cd %s ; git pull" % \
-                       (portage._shell_quote(self.repo.location),),
+               git_cmd = "%s pull" % self.bin_command
+               writemsg_level(git_cmd + "\n")
+
+               exitcode = portage.process.spawn_bash("cd %s ; exec %s" % (
+                               portage._shell_quote(self.repo.location), 
git_cmd),
                        **portage._native_kwargs(self.spawn_kwargs))
                if exitcode != os.EX_OK:
                        msg = "!!! git pull error in %s" % self.repo.location
                        self.logger(self.xterm_titles, msg)
                        writemsg_level(msg + "\n", level=logging.ERROR, 
noiselevel=-1)
                        return (exitcode, False)
-               msg = ">>> Git pull successful: %s" % self.repo.location
-               self.logger(self.xterm_titles, msg)
-               writemsg_level(msg + "\n")
                return (os.EX_OK, True)

diff --git a/pym/portage/sync/modules/rsync/rsync.py 
b/pym/portage/sync/modules/rsync/rsync.py
index b2fb2f8..52d8b0f 100644
--- a/pym/portage/sync/modules/rsync/rsync.py
+++ b/pym/portage/sync/modules/rsync/rsync.py
@@ -246,7 +246,7 @@ class RsyncSync(SyncBase):
 
        def _process_exitcode(self, exitcode, syncuri, out, maxretries):
                if (exitcode==0):
-                       self.logger(self.xterm_titles, "=== Sync completed with 
%s" % syncuri)
+                       pass
                elif exitcode == SERVER_OUT_OF_DATE:
                        exitcode = 1
                elif exitcode == EXCEEDED_MAX_RETRIES:

diff --git a/pym/portage/sync/modules/svn/svn.py 
b/pym/portage/sync/modules/svn/svn.py
index 0365e90..73c4b83 100644
--- a/pym/portage/sync/modules/svn/svn.py
+++ b/pym/portage/sync/modules/svn/svn.py
@@ -28,9 +28,6 @@ class SVNSync(SyncBase):
                if kwargs:
                        self._kwargs(kwargs)
                #initial checkout
-               msg = ">>> Starting initial svn checkout with %s..." % 
self.repo.sync_uri
-               self.logger(self.xterm_titles, msg)
-               writemsg_level(msg + "\n")
                try:
                        os.rmdir(self.repo.location)
                except OSError as e:
@@ -71,9 +68,6 @@ class SVNSync(SyncBase):
                if svn_root.startswith("svn://"):
                        svn_root = svn_root[6:]
                        #svn update
-                       msg = ">>> Starting svn update with %s..." % 
self.repo.sync_uri
-                       self.logger(self.xterm_titles, msg)
-                       writemsg_level(msg + "\n")
                        exitcode = portage.process.spawn_bash(
                                "cd %s; exec svn update" % \
                                (portage._shell_quote(self.repo.location),),

diff --git a/pym/portage/sync/modules/websync/websync.py 
b/pym/portage/sync/modules/websync/websync.py
index f08ae77..0ad4efb 100644
--- a/pym/portage/sync/modules/websync/websync.py
+++ b/pym/portage/sync/modules/websync/websync.py
@@ -38,9 +38,6 @@ class WebRsync(SyncBase):
                emerge_config = self.options.get('emerge_config', None)
                portdb = self.options.get('portdb', None)
 
-               msg = ">>> Starting emerge-webrsync for %s..." % 
self.repo.location
-               self.logger(self.xterm_titles, msg)
-               writemsg_level(msg + "\n")
                exitcode = portage.process.spawn_bash("%s" % \
                        (self.bin_command),
                        **portage._native_kwargs(self.spawn_kwargs))
@@ -49,9 +46,6 @@ class WebRsync(SyncBase):
                        self.logger(self.xterm_titles, msg)
                        writemsg_level(msg + "\n", level=logging.ERROR, 
noiselevel=-1)
                        return (exitcode, False)
-               msg = ">>> Emerge-webrsync successful: %s" % self.repo.location
-               self.logger(self.xterm_titles, msg)
-               writemsg_level(msg + "\n")
                #return self.post_sync(portdb, self.repo.location, 
emerge_config)
                return (exitcode, True)
 

Reply via email to