WebSVN – DevTools – Diff – /buildtool/trunk/src/generated/com/erggroup/buildtool/daemon/SlaveThread.java

 package com.erggroup.buildtool.daemon;
 import com.erggroup.buildtool.daemon.BuildThread;
-import com.erggroup.buildtool.ripple.MutableInt;
 import com.erggroup.buildtool.ripple.MutableString;
 import com.erggroup.buildtool.ripple.Package;
 import com.erggroup.buildtool.ripple.ReleaseManager;
 import com.erggroup.buildtool.ripple.RippleEngine;
+import com.erggroup.buildtool.ripple.RunLevelData;
 import java.io.File;
 import java.sql.SQLException;
 import org.apache.log4j.Logger;
+/**
-/**Slave Thread sub component
+ * Slave Thread sub component
  */
-public class SlaveThread
+public class SlaveThread extends BuildThread
-  extends BuildThread
+{
-  /**Logger
+	/**
-   * @attribute
+	 * Logger
-   */
+	 *
-  private static final Logger mLogger = Logger.getLogger(SlaveThread.class);
+	 * @attribute
+	 */
-  /**constructor
+	private static final Logger mLogger = Logger.getLogger(SlaveThread.class);
-   */
-  public SlaveThread(int rtag_id, int rcon_id, String unitTest)
+	/**
-  {
+	 * constructor
-    mLogger.warn("SlaveThread rtag_id " + rtag_id + " rcon_id " + rcon_id);
+	 */
-    mRtagId = rtag_id;
+	public SlaveThread(int rtag_id, int rcon_id, String unitTest)
-    mRconId = rcon_id;
+	{
-    if ( unitTest == null )
+		mLogger.warn("SlaveThread rtag_id " + rtag_id + " rcon_id " + rcon_id);
-    {
+		mRtagId = rtag_id;
-      unitTest = new String();
+		mRconId = rcon_id;
-    }
+		if (unitTest == null)
-    mUnitTest = unitTest;
+		{
-  }
+			unitTest = new String();
+		}
-  /**implements the sequence diagrams consume build files, allowed to proceed, check environment
+		mUnitTest = unitTest;
-   */
+	}
-  public void run()
-  {
+	/**
-    Integer id = new Integer(mRtagId);
+	 * implements the sequence diagrams consume build files, allowed to proceed,
-    setName(id.toString());
+	 * check environment
-    mLogger.warn("run");
+	 */
-    boolean exit = false;
+	public void run()
-    RippleEngine rippleEngine = new RippleEngine(mReleaseManager, mRtagId, true);
+	{
-    MutableString buildFileContent = new MutableString();
+		Integer id = new Integer(mRtagId);
+		setName(id.toString());
-    while(!exit)
+		mLogger.warn("run");
-    {
+		boolean exit = false;
-      try
+		RippleEngine rippleEngine = new RippleEngine(mReleaseManager, mRtagId, true);
-      {
+		MutableString buildFileContent = new MutableString();
-        mLogger.fatal("run calling sleepCheck");
-        sleepCheck();
+		while (!exit)
-        mLogger.fatal("run calling rippleEngine.collectMetaData");
+		{
-        rippleEngine.collectMetaData();
+			try
+			{
-        if ( Thread.currentThread().isInterrupted() )
+				mLogger.fatal("run calling sleepCheck");
-        {
+				sleepCheck();
-          mLogger.warn("run is interrupted");
+				mLogger.fatal("run calling rippleEngine.collectMetaData");
-          // unit test technique
+				rippleEngine.collectMetaData();
-          throw new ExitException();
-        }
+				if (Thread.currentThread().isInterrupted())
+				{
-        if ( mUnitTest.compareTo("unit test spawn thread") == 0)
+					mLogger.warn("run is interrupted");
-        {
+					// unit test technique
-          throw new Exception();
+					throw new ExitException();
-        }
+				}
-        // allowed to proceed
+				if (mUnitTest.compareTo("unit test spawn thread") == 0)
-        if ( mUnitTest.compareTo("unit test consume build files") != 0)
+				{
-        {
+					throw new Exception();
-          mRunLevel = RunLevel.IDLE;
+				}
-          mLogger.warn("run changing run level to IDLE for rcon_id " + mRconId);
-          mLogger.fatal("run calling rmRunLevel.persistNew to set IDLE");
+				// allowed to proceed
-          mRunLevel.persistNew(mReleaseManager, mRconId);
+				if (mUnitTest.compareTo("unit test consume build files") != 0)
+				{
-          mLogger.warn("run checking allowedToProceed");
+					mRunLevel = RunLevel.IDLE;
-          mLogger.fatal("run calling allowedToProceed");
+					mLogger.warn("run changing run level to IDLE for rcon_id " + mRconId);
-          allowedToProceed(false);
+					mLogger.fatal("run calling rmRunLevel.persistNew to set IDLE");
-          mLogger.info("run allowedToProceed returned");
+					mRunLevel.persistNew(mReleaseManager, mRconId);
-        }
+					mLogger.warn("run checking allowedToProceed");
-        mRunLevel = RunLevel.WAITING;
+					mLogger.fatal("run calling allowedToProceed");
-        mLogger.warn("run changing run level to WAITING for rcon_id " + mRconId);
+					allowedToProceed(false);
-        mLogger.fatal("run calling rmRunLevel.persist to set WAITING");
+					mLogger.info("run allowedToProceed returned");
-        mRunLevel.persist(mReleaseManager, mRconId);
+				}
-        // consume build files
+				// Indicate that the Slave is WAITING - for a job
-        mLogger.warn("run consume build files");
+				mRunLevel = RunLevel.WAITING;
-        buildFileContent.value = "";
+				mLogger.warn("run changing run level to WAITING for rcon_id " + mRconId);
-        boolean logWarning = true;
+				mLogger.fatal("run calling rmRunLevel.persist to set WAITING");
+				mRunLevel.persist(mReleaseManager, mRconId);
-        // additional handshake
-        // Master waits for Slave to be in state waiting
+				// consume build files
-        // wait for the Master to signal we are active
+				mLogger.warn("run consume build files");
-        MutableInt rconId = new MutableInt();
+				buildFileContent.value = "";
-        MutableInt current_run_level = new MutableInt();
+				boolean logWarning = true;
-        do
+				// Wait for Salve to be set as Active
-        {
+				for (;;)
-          mLogger.fatal("run calling mReleaseManager.querySingleRunLevel");
+				{
-          mReleaseManager.querySingleRunLevel(mRconId);
+					mLogger.fatal("run calling mReleaseManager.querySingleRunLevel");
-          mLogger.fatal("run calling mReleaseManager.getFirstRunLevel");
+					mReleaseManager.querySingleRunLevel(mRconId);
-          if ( !mReleaseManager.getFirstRunLevel(rconId, current_run_level) )
-          {
+					// Detect this daemon has been un-configured
-            mLogger.warn("run no longer configured 1");
+					if (mReleaseManager.mRunLevelCollection.isEmpty())
-            throw new ExitException();
+					{
-          }
+						mLogger.warn("run no longer configured 1");
+						throw new ExitException();
-          if (current_run_level.value != ReleaseManager.DB_ACTIVE)
+					}
-          {
-            try
+					RunLevelData rl = mReleaseManager.mRunLevelCollection.firstElement();
-            {
+					if (rl.get_current_run_level() != ReleaseManager.DB_ACTIVE)
-              if ( logWarning )
+					{
-              {
+						try
-                mLogger.warn("run sleep 3 secs waiting for Master to set Slave run level ACTIVE");
+						{
-                logWarning = false;
+							if (logWarning)
-              }
+							{
-              else
+								mLogger.warn("run sleep 3 secs waiting for Master to set Slave run level ACTIVE");
-              {
+								logWarning = false;
-                mLogger.info("run sleep 3 secs waiting for Master to set Slave run level ACTIVE");
+							} else
-              }
+							{
-              // to do, sleep for periodicMs
+								mLogger.info("run sleep 3 secs waiting for Master to set Slave run level ACTIVE");
-              mLogger.fatal("run calling Thread.sleep for 3 secs");
+							}
-              Thread.sleep(3000);
+							// to do, sleep for periodicMs
-              mLogger.info("run sleep returned");
+							mLogger.fatal("run calling Thread.sleep for 3 secs");
-            }
+							Thread.sleep(3000);
-            catch (InterruptedException e)
+							mLogger.info("run sleep returned");
-            {
+						} catch (InterruptedException e)
-              mLogger.warn("run caught InterruptedException");
+						{
-            }
+							mLogger.warn("run caught InterruptedException");
-          }
+						}
-        } while (current_run_level.value != ReleaseManager.DB_ACTIVE);
+					} else
+					{
-        mLogger.fatal("run calling mReleaseManager.queryRunLevel");
+						// Have been set to Active
-        mReleaseManager.queryRunLevel(mRconId, buildFileContent);
+						break;
+					}
-        if ( buildFileContent.value.compareTo("") == 0)
+				}
-        {
-          mLogger.warn("run no longer configured 2");
+				mLogger.fatal("run calling mReleaseManager.queryRunLevel");
-          throw new ExitException();
+				mReleaseManager.queryBuildFile(mRconId, buildFileContent);
-        }
+				if (buildFileContent.value.compareTo("") == 0)
-        mLogger.info("run consumed build files");
+				{
+					mLogger.warn("run no longer configured 2");
-        if ( mUnitTest.compareTo("unit test consume build files") == 0 )
+					throw new ExitException();
-        {
+				}
-          throw new ExitException();
-        }
+				mLogger.info("run consumed build files");
-        // set CURRENT_BUILD_FILES to null
+				if (mUnitTest.compareTo("unit test consume build files") == 0)
-        mLogger.fatal("run calling mReleaseManager.clearBuildFile");
+				{
-        mReleaseManager.clearBuildFile(mRconId);
+					throw new ExitException();
+				}
-        // check environment
-        mLogger.warn("run checkEnvironment");
+				// set CURRENT_BUILD_FILES to null
-        mLogger.fatal("run calling checkEnvironment");
+				mLogger.fatal("run calling mReleaseManager.clearBuildFile");
-        checkEnvironment();
+				mReleaseManager.clearBuildFile(mRconId);
-        mLogger.info("run checkEnvironment returned");
+				// check environment
-        mSleep = true;
+				mLogger.warn("run checkEnvironment");
-        if ( buildFileContent.value.compareTo(mDummyBuildFileContent) != 0 )
+				mLogger.fatal("run calling checkEnvironment");
-        {
+				checkEnvironment();
-          // Start of a build cycle. Set new log file to capture entire build log
+				mLogger.info("run checkEnvironment returned");
-          flagStartBuildCycle();
+				mSleep = true;
-          // deliver change to product baseline
+				if (buildFileContent.value.compareTo(mDummyBuildFileContent) != 0)
-          mLogger.warn("run deliverChange");
+				{
-          mLogger.fatal("run calling setViewUp");
+					// Start of a build cycle. Set new log file to capture
-          setViewUp(buildFileContent.value, false);
+					// entire build log
+					flagStartBuildCycle();
-          if ( mGbeGatherMetricsOnly != null )
-          {
+					// deliver change to product baseline
-            // special for metrics
+					mLogger.warn("run deliverChange");
-            // deliverChange on a benign target to get mReportingPackageName and mReportingPackageVersion set up
+					mLogger.fatal("run calling setViewUp");
-            // nb in the metrics gathering world the <rtagid>build.xml is provided by the master thread
+					setViewUp(buildFileContent.value, false);
-            mLogger.fatal("run calling deliverChange on fullstart");
-            deliverChange(null, "fullstart", false);
+					if (mGbeGatherMetricsOnly != null)
+					{
-            String archive = Package.mGbeDpkg;
+						// special for metrics
+						// deliverChange on a benign target to get
-            if (archive != null)
+						// mReportingPackageName and mReportingPackageVersion
-            {
+						// set up
-              String fs = System.getProperty( "file.separator" );
+						// nb in the metrics gathering world the
-              String destination = archive + fs + mReportingPackageName + fs + mReportingPackageVersion;
+						// <rtagid>build.xml is provided by the master thread
+						mLogger.fatal("run calling deliverChange on fullstart");
-              // do this for all unix based platforms
+						deliverChange(null, "fullstart", false);
-              new File( destination ).mkdirs();
-              new File( destination, "built.sparc" ).createNewFile();
+						String archive = Package.mGbeDpkg;
-              new File( destination, "built.solaris10_sparc32" ).createNewFile();
-              new File( destination, "built.solaris10_x86" ).createNewFile();
+						if (archive != null)
-              new File( destination, "built.linux_i386" ).createNewFile();
+						{
-            }
+							String fs = System.getProperty("file.separator");
+							String destination = archive + fs + mReportingPackageName + fs + mReportingPackageVersion;
-          }
-          else
+							// do this for all unix based platforms
-          {
+							new File(destination).mkdirs();
-            mLogger.fatal("run calling deliverChange - the actual build");
+							new File(destination, "built.sparc").createNewFile();
-            deliverChange(null, null, false);
+							new File(destination, "built.solaris10_sparc32").createNewFile();
-            mLogger.fatal("run calling deliverChange on AbtTearDown");
+							new File(destination, "built.solaris10_x86").createNewFile();
-            deliverChange(null, "AbtTearDown", false);
+							new File(destination, "built.linux_i386").createNewFile();
-          }
+						}
-          if ( mReportingBuildFailureLogFile != null )
+					} else
-          {
+					{
-            // tweak the build failure log file in the database
+						mLogger.fatal("run calling deliverChange - the actual build");
-            Integer rtagId = mRtagId;
+						deliverChange(null, null, false);
+						mLogger.fatal("run calling deliverChange on AbtTearDown");
-            // force exclusion by default
+						deliverChange(null, "AbtTearDown", false);
-            int testBuildInstruction = 0;
+					}
-            try
-            {
+					if (mReportingBuildFailureLogFile != null)
-              testBuildInstruction = Integer.parseInt( mReportingTestBuild );
+					{
-            }
+						// tweak the build failure log file in the database
-            catch( NumberFormatException nfe )
+						Integer rtagId = mRtagId;
-            {
-            }
+						// force exclusion by default
-            mLogger.fatal("run calling excludeFromBuild");
+						int testBuildInstruction = 0;
-            mReleaseManager.excludeFromBuild(mReportingPackageVersionId, mReportingPackageVersion, rtagId.toString(), null, null, mReportingBuildFailureLogFile, false, testBuildInstruction);
+						try
-          }
+						{
+							testBuildInstruction = Integer.parseInt(mReportingTestBuild);
-          mLogger.info("run deliverChange returned");
+						} catch (NumberFormatException nfe)
-          mSleep = false;
+						{
-        }
+						}
+						mLogger.fatal("run calling excludeFromBuild");
-      }
+						mReleaseManager.excludeFromBuild(mReportingPackageVersionId, mReportingPackageVersion,
-      catch( SQLException e )
+								rtagId.toString(), null, null, mReportingBuildFailureLogFile, false,
-      {
+								testBuildInstruction);
-        // oracle connection issues
+					}
-         mLogger.warn("run oracle connection issues");
-         mException = true;
+					mLogger.info("run deliverChange returned");
-      }
+					mSleep = false;
-      catch( ExitException e )
+				}
-      {
-        mLogger.warn("run ExitException");
+			} catch (SQLException e)
-        exit = true;
+			{
-      }
+				// oracle connection issues
-      catch( InterruptedException e )
+				mLogger.warn("run oracle connection issues");
-      {
+				mException = true;
-        mLogger.warn("run InterruptedException");
+			} catch (ExitException e)
-      }
+			{
-      catch( Exception e )
+				mLogger.warn("run ExitException");
-      {
+				exit = true;
-        mLogger.error("run indefinitePause " + e.toString());
+			} catch (InterruptedException e)
-        String cause = e.getMessage();
+			{
-        if ( cause == null )
+				mLogger.warn("run InterruptedException");
-        {
+			} catch (Exception e)
-          cause = e.toString();
+			{
-        }
+				mLogger.error("run indefinitePause " + e.toString());
+				String cause = e.getMessage();
-          try
+				if (cause == null)
-          {
+				{
-            // notify first
+					cause = e.toString();
-            // many reasons for indefinite pause, including database related, so do database last
+				}
-            mRecoverable = false;
+				try
-            if ( cause.compareTo(Package.mRecoverable) == 0 )
+				{
-            {
+					// notify first
-              mRecoverable = true;
+					// many reasons for indefinite pause, including database
-            }
+					// related, so do database last
+					mRecoverable = false;
-            indefinitePause(rippleEngine, cause);
-            mReleaseManager.indefinitePause();
+					if (cause.compareTo(Package.mRecoverable) == 0)
-            // DEVI 51366 force sleep at beginning of while loop
+					{
-            mException = true;
+						mRecoverable = true;
-          }
+					}
-          catch( Exception f )
-          {
+					indefinitePause(rippleEngine, cause);
-            mLogger.error("run indefinitePause failed");
+					mReleaseManager.indefinitePause();
-          }
+					// DEVI 51366 force sleep at beginning of while loop
-        }
+					mException = true;
-      }
+				} catch (Exception f)
-    }
+				{
+					mLogger.error("run indefinitePause failed");
-  /**returns 'S'
+				}
-   */
+			}
-  protected char getMode()
+		}
-  {
+	}
-    mLogger.debug("getMode");
-    return 'S';
+	/**
-  }
+	 * returns 'S'
+	 */
+	protected char getMode()
+	{
+		mLogger.debug("getMode");
+		return 'S';
+	}
+}

Subversion Repositories DevTools

(root)/buildtool/trunk/src/generated/com/erggroup/buildtool/daemon/SlaveThread.java @ 4285 – Rev 4123 → 4285