gump-general mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aj...@apache.org
Subject svn commit: rev 37388 - gump/trunk/python/gump/update
Date Thu, 02 Sep 2004 15:27:09 GMT
Author: ajack
Date: Thu Sep  2 08:27:08 2004
New Revision: 37388

Added:
   gump/trunk/python/gump/update/p4.py
Log:
Complete Peter's patch.

Added: gump/trunk/python/gump/update/p4.py
==============================================================================
--- (empty file)
+++ gump/trunk/python/gump/update/p4.py	Thu Sep  2 08:27:08 2004
@@ -0,0 +1,208 @@
+#!/usr/bin/python
+
+# Copyright 2003-2004 The Apache Software Foundation
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+# 
+#     http://www.apache.org/licenses/LICENSE-2.0
+# 
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+"""
+
+"""
+
+import os.path
+import sys
+from fnmatch import fnmatch
+
+from gump import log
+from gump.run.gumprun import *
+from gump.core.config import dir, default, basicConfig
+
+from gump.utils import dump, display, getIndent, logResourceUtilization, \
+                            invokeGarbageCollection
+from gump.utils.note import Annotatable
+from gump.utils.work import *
+
+from gump.utils.tools import *
+
+from gump.model.workspace import *
+from gump.model.module import Module
+from gump.model.project import Project
+from gump.model.depend import  ProjectDependency
+from gump.model.stats import *
+from gump.model.state import *
+
+
+###############################################################################
+# Classes
+###############################################################################
+
+class P4Updater(RunSpecific):
+    
+    def __init__(self,run):
+        RunSpecific.__init__(self,run)
+
+        #
+        # A stash of known logins.
+        #
+        #self.logins=readLogins()
+
+    def updateModule(self,module):
+        """
+        
+            Perform a P4 sync on a module
+            
+        """
+            
+        #log.info('Perform P4 Sync on #[' + `module.getPosition()` + \
+        #                '] : ' + module.getName())
+    
+        ## Did we 'P4 checkout' already?
+        exists	=	os.path.exists(module.getSourceControlStagingDirectory())
+       
+        # Doesn't tell us much...
+        if exists:
+            self.performStatus(module)
+                
+        self.performUpdate(module,exists)        
+        
+        return module.okToPerformWork()      
+        
+    def performStatus(self,module):
+        #  Get the Update Command
+        (repository, root, cmd ) = self.getUpdateCommand(module, True, True)
+                
+        ## Provide P4 logins, if not already there
+        #loginToRepositoryOnDemand(repository,root,self.logins)
+               
+        # Execute the command and capture results        
+        cmdResult=execute(cmd, module.getWorkspace().tmpdir)
+      
+        #
+        # Store this as work, on both the module and (cloned) on the repo
+        #
+        work=CommandWorkItem(WORK_TYPE_UPDATE,cmd,cmdResult)
+        module.performedWork(work)  
+     
+        if not cmdResult.isOk():              
+            log.error('Failed to checkout/update module: ' + module.name)   
+                                  
+    def performUpdate(self,module,exists):
+        """
+            Update this module (checking out if needed)
+        """
+        #  Get the Update Command
+        (repository, root, cmd ) = self.getUpdateCommand(module, exists)
+                
+        #log.debug("P4 Sync Module " + module.getName() + \
+        #               ", Repository Name: " + str(module.repository.getName()))
+                                        
+        ## Provide P4 logins, if not already there
+        #loginToRepositoryOnDemand(repository,root,self.logins)
+               
+        # Execute the command and capture results        
+        cmdResult=execute(cmd, module.getWorkspace().tmpdir)
+      
+        #
+        # Store this as work, on both the module and (cloned) on the repo
+        #
+        work=CommandWorkItem(WORK_TYPE_UPDATE,cmd,cmdResult)
+        module.performedWork(work)  
+        repository.performedWork(work.clone())
+      
+        # Update Context w/ Results  
+        if not cmdResult.isOk():              
+            log.error('Failed w/ P4 Root ' + root + ' for %s on Repository %s.' \
+                % (module.name, module.repository.getName())) 
+            if not exists:     
+                module.changeState(STATE_FAILED,REASON_UPDATE_FAILED)
+            else:
+                module.addError('*** Failed to update from source control. Stale contents
***')
+                        
+                # Black mark for this repository
+                repository=module.getRepository()
+                repository.addError('*** Failed to update %s from source control. Stale contents
***'	\
+                                    % module.getName())
+                                        
+                # Kinda bogus, but better than nowt (for now)
+                module.changeState(STATE_SUCCESS,REASON_UPDATE_FAILED)
+        else:
+            module.changeState(STATE_SUCCESS)      
+            
+            # We run P4 so any output means updates occured...
+            if cmdResult.hasOutput():                       
+                log.info('Update(s) received via P4 on #[' \
+                                + `module.getPosition()` + \
+                                '] : ' + module.getName())
+                                 
+    def preview(self,module):
+                
+        (repository, root, command ) = self.getUpdateCommand(module,False)
+        command.dump()
+        
+        # Doesn't tell us much...
+        #(repository, root, command ) = self.getUpdateCommand(module,True,True)
+        #command.dump()
+            
+        (repository, root, command ) = self.getUpdateCommand(module,True)
+        command.dump()                       
+        
+    
+    def getUpdateCommand(self,module,exists=False,nowork=False):
+        """        
+            Format a commandline for doing the P4 update            
+        """
+        if nowork and not exists:
+            raise RuntimeException('Not coded for this combo.')            
+        
+        root=module.p4.getClientspec()
+        # Prepare P4 sync command...
+        prefix='update'
+        directory=module.getWorkspace().getSourceControlStagingDirectory()
+        #if exists:     
+        #    directory=module.getSourceControlStagingDirectory()            
+        if nowork:
+            prefix='status'
+                
+        cmd=Cmd(	'p4',
+                    prefix+'_'+module.getName(),
+                    directory)
+          
+        ## Allow trace for debug
+        #if module.isDebug():
+        #    cmd.addParameter('-t')
+          
+        ## Request compression
+        #cmd.addParameter('-z3')
+          
+        # Determine if a tag is set, on <p4 or on <module
+        tag=None
+        if module.p4.hasTag():
+            tag=module.p4.getTag()
+        elif module.hasTag():
+            tag=module.getTag()
+        
+        # Do a p4 sync
+        cmd.addParameter('-p',module.p4.getPort())
+        cmd.addParameter('-u',module.p4.getUser())
+        cmd.addParameter('-P',module.p4.getPassword())
+        cmd.addParameter('-c',root)
+        cmd.addParameter('sync')
+        if nowork:
+            cmd.addParameter('-n')
+        if tag:
+            cmd.addParameter(module.getName()+'/...@',tag,' ')
+        else:
+            cmd.addParameter(module.getName()+'/...')
+        #cmd.addParameter(module.getName())
+
+        return (module.repository, root, cmd)
+    

---------------------------------------------------------------------
To unsubscribe, e-mail: general-unsubscribe@gump.apache.org
For additional commands, e-mail: general-help@gump.apache.org


Mime
View raw message