[gentoo-commits] proj/portage:plugin-sync commit in: pym/portage/sync/modules/rsync/

[Brian Dolbec]

commit:     cddccc60e653cad0760553b44bedd8c7cd544fe7
Author:     Brian Dolbec <dolsen <AT> gentoo <DOT> org>
AuthorDate: Sat Feb  8 01:50:23 2014 +0000
Commit:     Brian Dolbec <brian.dolbec <AT> gmail <DOT> com>
CommitDate: Sat Feb  8 02:13:48 2014 +0000
URL:        http://git.overlays.gentoo.org/gitweb/?p=proj/portage.git;a=commit;h=cddccc60

Rsync module, add exists() and new()

---
 pym/portage/sync/modules/rsync/rsync.py | 27 +++++++++++++++++++++++++++
 1 file changed, 27 insertions(+)

diff --git a/pym/portage/sync/modules/rsync/rsync.py b/pym/portage/sync/modules/rsync/rsync.py
index de561ad..12b4c9c 100644
--- a/pym/portage/sync/modules/rsync/rsync.py
+++ b/pym/portage/sync/modules/rsync/rsync.py
@@ -60,6 +60,10 @@ class RsyncSync(object):
 			spawn_kwargs = self.options.get('spawn_kwargs', None)
 			usersync_uid = self.options.get('usersync_uid', None)
 
+		if not self.exists():
+			if not self.new():
+				return (1, False)
+
 		enter_invalid = '--ask-enter-invalid' in myopts
 		out = portage.output.EOutput()
 		syncuri = self.repo.sync_uri
@@ -499,3 +503,26 @@ class RsyncSync(object):
 			for line in msg:
 				out.eerror(line)
 		return (exitcode, updatecache_flg)
+
+
+	def exists(self, **kwargs):
+		if kwargs:
+			self._kwargs(kwargs)
+		elif not self.repo:
+			return False
+		return os.path.exists(self.repo.location)
+
+
+
+	def new(self, **kwargs):
+		if kwargs:
+			self._kwargs(kwargs)
+		try:
+			if not os.path.exists(self.repo.location):
+				os.makedirs(self.repo.location)
+				self.logger(self.self.xterm_titles,
+					'Created New Directory %s ' % self.repo.location )
+		except IOError:
+			return False
+		return True
+