Subversion Repositories DevTools

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 java.io.BufferedReader;

import java.io.DataInputStream;

import java.io.File;

import java.io.FileInputStream;

import java.io.InputStreamReader;

import java.sql.SQLException;

import java.lang.System;

import org.apache.log4j.Logger;

/**Master Thread sub component

 */

public class MasterThread

  extends BuildThread

{

  /**Logger

   * @attribute

   */

  private static final Logger mLogger = Logger.getLogger(MasterThread.class);

  /**Nagios Monitoring

   * @attribute

   */

  protected long mPhaseStartTime = 0;

   /**constructor

   */

  public MasterThread(int rtag_id, int rcon_id, String unitTest)

  {

    mLogger.warn("MasterThread rtag_id " + rtag_id + " rcon_id " + rcon_id);

    mRtagId = rtag_id;

    mRconId = rcon_id;

    if ( unitTest == null )

    {

      unitTest = new String();

    }

    mUnitTest = unitTest;

  }

  /**implements the sequence diagrams coordinate slave threads, generate build files, allowed to proceed, check environment

   */

  public void run()

  {

    Integer id = new Integer(mRtagId);

    setName(id.toString());

    mLogger.debug("run");

    boolean exit = false;

    RippleEngine rippleEngine = new RippleEngine(mReleaseManager, mRtagId, true);

    MutableInt rconId = new MutableInt();

    MutableInt current_run_level = new MutableInt();

    MutableString addendum = new MutableString();

    while(!exit)

    {

      try

      {

        mPhaseStartTime = 0;

        mLogger.fatal("run calling sleepCheck");

        sleepCheck();

        mLogger.fatal("run calling rippleEngine.collectMetaData");

        mPhaseStartTime = System.currentTimeMillis();

        rippleEngine.collectMetaData();

        mPhaseStartTime = 0;

        if ( Thread.currentThread().isInterrupted() )

        {

          mLogger.warn("run is interrupted");

          // unit test technique

          throw new ExitException();

        }

        if ( mUnitTest.compareTo("unit test spawn thread") == 0)

        {

          throw new Exception();

        }

        MutableString buildFileContent = new MutableString();

        if ( mUnitTest.compareTo("unit test check environment") != 0)

        {

          if ( mUnitTest.compareTo("unit test generate build files") != 0)

          {

            if ((mUnitTest.compareTo("unit test allowed to proceed") != 0) &&

                (mUnitTest.compareTo("unit test not allowed to proceed") != 0) &&

                (mUnitTest.compareTo("unit test exit") != 0))

            {

              // coordinate slave threads

              mLogger.warn("run coordinate slave threads");

              mRunLevel = RunLevel.WAITING;

              mLogger.warn("run changing run level to WAITING for rcon_id " + mRconId);

              mLogger.fatal("run calling mRunLevel.persistNew to set WAITING");

              mRunLevel.persistNew(mReleaseManager, mRconId);

              boolean allSlaveThreadsWaiting = false;

              boolean logWarning = true;

              boolean logWarning2 = true;

              while ( !allSlaveThreadsWaiting )

              {

                mLogger.fatal("run calling mReleaseManager.queryRunLevel");

                mReleaseManager.queryRunLevel(mRtagId);

                // anything but WAITING or PAUSED

                current_run_level.value = ReleaseManager.DB_IDLE;

                mLogger.fatal("run calling mReleaseManager.getFirstRunLevel");

                boolean moreRunLevelsConfigured = mReleaseManager.getFirstRunLevel(rconId, current_run_level);

                // attempt to exit loop

                allSlaveThreadsWaiting = true;

                do

                {

                  if (moreRunLevelsConfigured)

                  {

                    // DEVI 53065 Slave indication that they are done with a package includes

                    // having a paused run level

                    if ((current_run_level.value != ReleaseManager.DB_WAITING) &&

                        (current_run_level.value != ReleaseManager.DB_PAUSED))

                    {

                      if ( logWarning )

                      {

                        mLogger.warn("run waiting for rcon id " + rconId.value);

                        logWarning = false;

                      }

                      else

                      {

                        mLogger.info("run waiting for rcon id " + rconId.value);                      

                      }

                      allSlaveThreadsWaiting = false;

                    }

                    else

                    {

                      mLogger.fatal("run calling mReleaseManager.getNextRunLevel");

                      moreRunLevelsConfigured = mReleaseManager.getNextRunLevel(rconId, current_run_level);

                    }

                  }

                }

                while (moreRunLevelsConfigured && allSlaveThreadsWaiting);

                if ( !allSlaveThreadsWaiting )

                {

                  // to do, sleep for periodicMs

                  if ( mUnitTest.compareTo("unit test coordinate slave threads") == 0 )

                  {

                    Thread.currentThread().interrupt();

                  }

                  else

                  {

                    if ( logWarning2 )

                    {

                      mLogger.warn("run sleeping 3 secs waiting for slave threads");

                      logWarning2 = false;

                    }

                    else

                    {

                      mLogger.info("run sleeping 3 secs waiting for slave threads");

                    }

                    mLogger.fatal("run calling Thread.sleep for 3 secs");

                    Thread.sleep(3000);

                    mLogger.info("run sleep returned");

                  }

                }

              }

              if ( mUnitTest.compareTo("unit test coordinate slave threads") == 0 )

              {

                throw new ExitException();

              }

              // DEVI 50527

              mRunLevel = RunLevel.PUBLISHING;

              mLogger.warn("run changing run level to PUBLISHING for rcon_id " + mRconId);

              mLogger.fatal("run calling mRunLevel.persist to set PUBLISHING");

              mRunLevel.persist(mReleaseManager, mRconId);

              mLogger.fatal("run calling deliverChange on AbtPublish");

              deliverChange(null, "AbtPublish", false);

              // preserve 

              String reportingFullyPublished = mReportingFullyPublished;

              String reportingNewVcsTag = mReportingNewVcsTag;

              mLogger.fatal("run calling deliverChange on AbtTearDown");

              deliverChange(null, "AbtTearDown", false);

              // DEVI 47395 delete the build file now

              // this will prevent any chance of multiply publishing a package version

              File buildFile = new File(mRtagId + "build.xml");

              if ( buildFile.exists() )

              {

                buildFile.delete();

              }

              if ( mReportingPackageName != null )

              {

                // a dummy build file did not apply

                // Publishing is done outside ant by design

                // The preference is to do all release manager work outside ant

                boolean buildErrorOccurred = true;

                boolean publishError = false;

                // max 50 characters

                String rootCause = "Error publishing to Release Manager";

                try

                {

                  if ( mReportingTestBuild.compareTo("0") != 0 )

                  {

                    mLogger.info("run completing test build on " + mReportingPackageName + mReportingPackageExtension);

                    // build failure emails will have been sent

                    // just left to notify the user of the test build completion

                    Package p = rippleEngine.findPackage(mReportingPackageName + mReportingPackageExtension);

                    if (p != ReleaseManager.NULL_PACKAGE)

                    {

                      boolean success = false;

                      if ( reportingFullyPublished != null && reportingFullyPublished.compareTo("yes") == 0 )

                      {

                        success = true;

                      }

                      mLogger.fatal("run calling p.completeTestBuild");                      

                      p.completeTestBuild(rippleEngine.mMailServer, rippleEngine.mMailSender, mReleaseManager, rippleEngine.mBaselineName, success);

                    }

                    // ... and clean up the mess in the archive

                    throw new Exception();                    

                  }

                  if ( reportingFullyPublished != null && reportingFullyPublished.compareTo("yes") == 0 )

                  {

                    buildErrorOccurred = false;

                    if ( reportingNewVcsTag.length() > 0 )

                    {

                      Integer rtagId = new Integer(mRtagId);

                      if ( mGbeGatherMetricsOnly == null )

                      {

                        // publish to release manager

                        // On error mAutoMakeReleaseCause will contain error string

                        mLogger.fatal("run calling mReleaseManager.autoMakeRelease");

                        publishError =  mReleaseManager.autoMakeRelease(

                                                    rtagId.toString(),

                                                    mReportingPackageName,

                                                    mReportingPackageExtension,

                                                    mReportingPackageVersion,

                                                    reportingNewVcsTag,

                                                    mReportingPackageDepends,

                                                    mReportingIsRipple);

                        // publishErrors only affect one package

                        if ( publishError )

                        {

                            rootCause = mReleaseManager.mAutoMakeReleaseCause;

                            mLogger.fatal("autoMakeRelease publishError: " + rootCause);

                            throw new Exception();

                        }

                      }

                      FileInputStream abtmetrics = new FileInputStream( rtagId.toString() + "abtmetrics.txt" );

                      DataInputStream din = new DataInputStream( abtmetrics );

                      InputStreamReader isr = new InputStreamReader( din );

                      BufferedReader br = new BufferedReader( isr );

                      String metrics = br.readLine();

                      mLogger.warn( "execute read metrics string " + metrics );

                      br.close();

                      isr.close();

                      din.close();

                      mLogger.fatal("run calling mReleaseManager.insertPackageMetrics");                      

                      mReleaseManager.insertPackageMetrics(rtagId.toString(), mReportingPackageName, mReportingPackageExtension, metrics );

                    }

                    else

                    {

                      mLogger.info("run package not labelled in Version Control on " + mReportingPackageName + mReportingPackageVersion);

                      // max 50 characters

                      rootCause = "Error publishing to Version Control System";

                      throw new Exception();

                    }

                  }

                  else

                  {

                    mLogger.info("run build error occurred on " + mReportingPackageName + mReportingPackageVersion);

                    throw new Exception();

                  }

                }

                catch( Exception e)

                {

                  // a build error occurred or

                  // an error occurred publishing to Version Control or Release Manager

                  // take out the archive entry first

                  String fs = System.getProperty( "file.separator" );

                  String dpkgArchiveEntry = new String(Package.mGbeDpkg + fs + mReportingPackageName + fs + mReportingPackageVersion);

                  File dpkgArchiveEntryFile = new File(dpkgArchiveEntry);

                  mLogger.info("run checking existence of " + dpkgArchiveEntry);

                  if ( dpkgArchiveEntryFile.exists() )

                  {

                    if ( dpkgArchiveEntryFile.isDirectory() )

                    {

                      mLogger.warn("run deleting " + dpkgArchiveEntryFile.getName());

                      mLogger.fatal("run calling deleteDirectory on " + dpkgArchiveEntryFile);                      

                      deleteDirectory(dpkgArchiveEntryFile);

                    }

                  }

                  Integer rtagId = new Integer(mRtagId);

                  if ( !buildErrorOccurred )

                  {

                    mLogger.fatal("an error occurred publishing to Version Control or Release Manager");

                    // force exclusion by default

                    int testBuildInstruction = 0;

                    try

                    {

                      testBuildInstruction = Integer.parseInt( mReportingTestBuild );

                    }

                    catch( NumberFormatException nfe )

                    {

                    }

                    mLogger.fatal("run calling excludeFromBuild");                      

                    mReleaseManager.excludeFromBuild(mReportingPackageVersionId, null, rtagId.toString(), null, rootCause, null, false, testBuildInstruction);

                    if ( ! publishError )

                    {

                        throw new Exception("an error occurred publishing to Version Control or Release Manager");

                    }

                  }

                  // DEVI 55364

                  // Package has not been built on all configured platforms

                  // Under normal circumstances, this root cause will be masked by a previously reported error

                  // Under abnormal circumstances amidst build activity such as:

                  // - slave build machine reboots

                  // - slave build machines with a read only file system

                  // this root cause is required to keep the end user informed

                  // max 50 chars

                  String cause = "Buildtool env error occurred. Attempt build again";

                  // force exclusion by default

                  int testBuildInstruction = 0;

                  try

                  {

                    testBuildInstruction = Integer.parseInt( mReportingTestBuild );

                  }

                  catch( NumberFormatException nfe )

                  {

                  }

                  mLogger.fatal("run calling excludeFromBuild");                      

                  mReleaseManager.excludeFromBuild(mReportingPackageVersionId, mReportingPackageVersion, rtagId.toString(), null, mReportingBuildFailureLogFile == null ? cause : null, mReportingBuildFailureLogFile, false, testBuildInstruction);

                }

              }

              if ( mUnitTest.compareTo("unit test coordinate slave threads") == 0 )            

              {

                throw new ExitException();

              }

              mLogger.info("run coordinate slave threads returned");

            }

            // DEVI 51366 allowed to proceed after coordinate slave threads

            mLogger.warn("run checking allowedToProceed");

            mLogger.fatal("run calling allowedToProceed");                      

            allowedToProceed(true);

            mLogger.info("run allowedToProceed returned");

            if ( mUnitTest.compareTo("unit test allowed to proceed") == 0 )            

            {

              throw new ExitException();

            }

            // generate build files

            mLogger.warn("run generating build files");

            mLogger.fatal("run calling planRelease");

            rippleEngine.planRelease();

            mPhaseStartTime = System.currentTimeMillis();

            mLogger.fatal("run calling reportChange");                      

            rippleEngine.reportChange();

            mPhaseStartTime = 0;

            // get the build file from the ripple engine

            rippleEngine.getFirstBuildFileContent(buildFileContent, addendum);

            if ( addendum.value.compareTo("non generic") == 0 )

            {

              // publish the build file

              mLogger.warn("run publishing build file");

              mLogger.fatal("run calling publishBuildFile");                      

              mReleaseManager.publishBuildFile(mRtagId, buildFileContent.value);

            }

            else

            {

              // publish a dummy build file for either generic or dummy cases

              // this results in the slave not running ant

              mLogger.warn("run publishing dummy build file");

              mLogger.fatal("run calling publishBuildFile on dummy");                      

              mReleaseManager.publishBuildFile(mRtagId, mDummyBuildFileContent);

            }

          }

          mLogger.info("run generated build files");

          // Start of a build cycle. Set new log file to capture entire build log

          flagStartBuildCycle();

          if ( mGbeGatherMetricsOnly != null )

          {

            // set view up early for metrics gathering to ensure build file is fully written before letting the slave loose

            mLogger.fatal("run calling setViewUp");                      

            setViewUp(buildFileContent.value, true);            

          }

          // change the run level for all threads in associated with the baseline

          mLogger.warn("run change the run level for all threads in associated with the baseline");

          mLogger.fatal("run calling queryReleaseConfig");                      

          mReleaseManager.queryReleaseConfig(mRtagId);

          rconId.value = -1;

          boolean moreBuildThreadsConfigured = mReleaseManager.getFirstReleaseConfig(rconId);

          mRunLevel = RunLevel.ACTIVE;

          do

          {

            if (moreBuildThreadsConfigured)

            {

                mLogger.warn("run changing run level to ACTIVE for rcon_id " + rconId.value);

                mLogger.fatal("run calling mRunLevel.persist to set ACTIVE");                      

                mRunLevel.persist(mReleaseManager, rconId.value);

                moreBuildThreadsConfigured = mReleaseManager.getNextReleaseConfig(rconId);

            }

          }

          while (moreBuildThreadsConfigured);

          if ( mUnitTest.compareTo("unit test generate build files") == 0 )

          {

            throw new ExitException();

          }

        }

        mLogger.info("run changed run levels");

        // check environment

        mLogger.warn("run checkEnvironment");

        mLogger.fatal("run calling checkEnvironment");                      

        checkEnvironment();

        mLogger.info("run checkEnvironment returned");

        if ( mUnitTest.compareTo("unit test check environment") == 0 )

        {

          throw new ExitException();

        }

        // deliver change to product baseline

        mLogger.warn("run deliverChange");

        if ( mGbeGatherMetricsOnly == null )

        {

          mLogger.fatal("run calling setViewUp metrics only");                      

          setViewUp(buildFileContent.value, true);

        }

        mLogger.fatal("run calling deliverChange - the actual build " + mReportingPackageName + "_" + mReportingPackageVersion);

        deliverChange(null, null, false);

        mLogger.info("run deliverChange returned");

        mSleep = false;

        if ( addendum.value.compareTo("dummy") == 0 )

        {

          // no build requirement, so let things settle

          mLogger.warn("run no build requirement, so let things settle");

          mSleep = true;

        }        

      }

      catch( SQLException e )

      {

        // oracle connection issues        

        mLogger.warn("run oracle connection issues");

        mException = true;

      }

      catch( ExitException e )

      {

        mLogger.warn("run ExitException");

        exit = true;

      }

      catch( InterruptedException e )

      {

        mLogger.warn("run InterruptedException");

      }

      catch( Exception e )

      {

        mLogger.error("run indefinitePause " + e.toString());

        String cause = e.getMessage();

        if ( cause == null )

        {

          cause = e.toString();

        }

        try

        {

          // notify first

          // many reasons for indefinite pause, including database related, so do database last

          mRecoverable = false;

          if ( cause.compareTo(Package.mRecoverable) == 0 )

          {

            mRecoverable = true;

          }

          indefinitePause(rippleEngine, cause);

          mReleaseManager.indefinitePause();

          // DEVI 51366 force sleep at beginning of while loop

          mException = true;

        }

        catch( Exception f )

        {

          mLogger.error("run indefinitePause failed");

        }

      }

    }

  }

  /**returns 'M'

   */

  protected char getMode()

  {

    mLogger.debug("getMode");

    return 'M';

  }

  /**

   * Nagios interface extension

   * This method should be overriden by classes that extend this class

   * If not overriden then the test indicates OK

   *

   *      Returns true if the thread looks OK

  */

  boolean checkThreadExtended()

  {

    boolean retVal = true;

mLogger.info("Master checkThreadExtended");

    if ( mPhaseStartTime > 0 )

    {

      /*

      **    Report if we appear to be stuck in the current phase

      **    At the moment the phases that we monitor should complete

      **    within 5 minutes and 10 minutes is real error.

      **    We do need to allow time for interlocking with other tasks.

      */

      if ( (System.currentTimeMillis() - mPhaseStartTime) / 1000 > 10 * 60  )

      {

        retVal = false;

      }

    }

    return retVal;

  }

}