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



 
    while(!exit)
    {
      try
      {
        mLogger.fatal("run calling sleepCheck");
        sleepCheck();
        mLogger.fatal("run calling rippleEngine.collectMetaData");
        rippleEngine.collectMetaData();
        
        if ( Thread.currentThread().isInterrupted() )
        {
          mLogger.warn("run is interrupted");

        // allowed to proceed
        if ( mUnitTest.compareTo("unit test consume build files") != 0)
        {
          mRunLevel = RunLevel.IDLE;
          mLogger.warn("run changing run level to IDLE for rcon_id " + mRconId);
          mLogger.fatal("run calling rmRunLevel.persistNew to set IDLE");
          mRunLevel.persistNew(mReleaseManager, mRconId);
 
          mLogger.warn("run checking allowedToProceed");
          mLogger.fatal("run calling allowedToProceed");
          allowedToProceed(false);
          mLogger.info("run allowedToProceed returned");
        }
        
        mRunLevel = RunLevel.WAITING;
        mLogger.warn("run changing run level to WAITING for rcon_id " + mRconId);
        mLogger.fatal("run calling rmRunLevel.persist to set WAITING");
        mRunLevel.persist(mReleaseManager, mRconId);
 
        // consume build files
        mLogger.warn("run consume build files");
        buildFileContent.value = "";

        MutableInt rconId = new MutableInt();
        MutableInt current_run_level = new MutableInt();
        
        do
        {
          mLogger.fatal("run calling mReleaseManager.querySingleRunLevel");
          mReleaseManager.querySingleRunLevel(mRconId);
          mLogger.fatal("run calling mReleaseManager.getFirstRunLevel");
          if ( !mReleaseManager.getFirstRunLevel(rconId, current_run_level) )
          {
            mLogger.warn("run no longer configured 1");
            throw new ExitException();
          }

              else
              {
                mLogger.info("run sleep 3 secs waiting for Master to set Slave run level ACTIVE");
              }
              // to do, sleep for periodicMs
              mLogger.fatal("run calling Thread.sleep for 3 secs");
              Thread.sleep(3000);
              mLogger.info("run sleep returned");
            }
            catch (InterruptedException e)
            {
              mLogger.warn("run caught InterruptedException");
            }
          }
        } while (current_run_level.value != ReleaseManager.DB_ACTIVE);
 
        mLogger.fatal("run calling mReleaseManager.queryRunLevel");
        mReleaseManager.queryRunLevel(mRconId, buildFileContent);
        
        if ( buildFileContent.value.compareTo("") == 0)
        {
          mLogger.warn("run no longer configured 2");

        {
          throw new ExitException();
        }
 
        // set CURRENT_BUILD_FILES to null
        mLogger.fatal("run calling mReleaseManager.clearBuildFile");
        mReleaseManager.clearBuildFile(mRconId);
 
        // check environment
        mLogger.warn("run checkEnvironment");
        mLogger.fatal("run calling checkEnvironment");
        checkEnvironment();
        mLogger.info("run checkEnvironment returned");
        
        mSleep = true;
        if ( buildFileContent.value.compareTo(mDummyBuildFileContent) != 0 )
        {
          // deliver change to product baseline
          mLogger.warn("run deliverChange");
          mLogger.fatal("run calling setViewUp");
          setViewUp(buildFileContent.value, false);
          
          if ( mGbeGatherMetricsOnly != null )
          {
            // special for metrics
            // deliverChange on a benign target to get mReportingPackageName and mReportingPackageVersion set up
            // nb in the metrics gathering world the <rtagid>build.xml is provided by the master thread
            mLogger.fatal("run calling deliverChange on fullstart");
            deliverChange(null, "fullstart", false);
            
            String archive = Package.mGbeDpkg;
            
            if (archive != null)

            }
            
          }
          else
          {
            mLogger.fatal("run calling deliverChange - the actual build");
            deliverChange(null, null, false);
            mLogger.fatal("run calling deliverChange on AbtTearDown");
            deliverChange(null, "AbtTearDown", false);
          }
          
          if ( mReportingBuildFailureLogFile != null )
          {

              testBuildInstruction = Integer.parseInt( mReportingTestBuild );
            }
            catch( NumberFormatException nfe )
            {
            }
            mLogger.fatal("run calling excludeFromBuild");
            mReleaseManager.excludeFromBuild(mReportingPackageVersionId, mReportingPackageVersion, rtagId.toString(), null, null, mReportingBuildFailureLogFile, false, testBuildInstruction);
          }
          
          mLogger.info("run deliverChange returned");
          mSleep = false;

Rev 908	Rev 916
Line 49...	Line 49...
49		49
50	`while(!exit)`	50	`while(!exit)`
51	`{`	51	`{`
52	`try`	52	`try`
53	`{`	53	`{`
-		54	`mLogger.fatal("run calling sleepCheck");`
54	`sleepCheck();`	55	`sleepCheck();`
-		56	`mLogger.fatal("run calling rippleEngine.collectMetaData");`
55	`rippleEngine.collectMetaData();`	57	`rippleEngine.collectMetaData();`
56		58
57	`if ( Thread.currentThread().isInterrupted() )`	59	`if ( Thread.currentThread().isInterrupted() )`
58	`{`	60	`{`
59	`mLogger.warn("run is interrupted");`	61	`mLogger.warn("run is interrupted");`
Line 69...	Line 71...
69	`// allowed to proceed`	71	`// allowed to proceed`
70	`if ( mUnitTest.compareTo("unit test consume build files") != 0)`	72	`if ( mUnitTest.compareTo("unit test consume build files") != 0)`
71	`{`	73	`{`
72	`mRunLevel = RunLevel.IDLE;`	74	`mRunLevel = RunLevel.IDLE;`
73	`mLogger.warn("run changing run level to IDLE for rcon_id " + mRconId);`	75	`mLogger.warn("run changing run level to IDLE for rcon_id " + mRconId);`
-		76	`mLogger.fatal("run calling rmRunLevel.persistNew to set IDLE");`
74	`mRunLevel.persistNew(mReleaseManager, mRconId);`	77	`mRunLevel.persistNew(mReleaseManager, mRconId);`
75		78
76	`mLogger.warn("run checking allowedToProceed");`	79	`mLogger.warn("run checking allowedToProceed");`
-		80	`mLogger.fatal("run calling allowedToProceed");`
77	`allowedToProceed(false);`	81	`allowedToProceed(false);`
78	`mLogger.info("run allowedToProceed returned");`	82	`mLogger.info("run allowedToProceed returned");`
79	`}`	83	`}`
80		84
81	`mRunLevel = RunLevel.WAITING;`	85	`mRunLevel = RunLevel.WAITING;`
82	`mLogger.warn("run changing run level to WAITING for rcon_id " + mRconId);`	86	`mLogger.warn("run changing run level to WAITING for rcon_id " + mRconId);`
-		87	`mLogger.fatal("run calling rmRunLevel.persist to set WAITING");`
83	`mRunLevel.persist(mReleaseManager, mRconId);`	88	`mRunLevel.persist(mReleaseManager, mRconId);`
84		89
85	`// consume build files`	90	`// consume build files`
86	`mLogger.warn("run consume build files");`	91	`mLogger.warn("run consume build files");`
87	`buildFileContent.value = "";`	92	`buildFileContent.value = "";`
Line 93...	Line 98...
93	`MutableInt rconId = new MutableInt();`	98	`MutableInt rconId = new MutableInt();`
94	`MutableInt current_run_level = new MutableInt();`	99	`MutableInt current_run_level = new MutableInt();`
95		100
96	`do`	101	`do`
97	`{`	102	`{`
-		103	`mLogger.fatal("run calling mReleaseManager.querySingleRunLevel");`
98	`mReleaseManager.querySingleRunLevel(mRconId);`	104	`mReleaseManager.querySingleRunLevel(mRconId);`
-		105	`mLogger.fatal("run calling mReleaseManager.getFirstRunLevel");`
99	`if ( !mReleaseManager.getFirstRunLevel(rconId, current_run_level) )`	106	`if ( !mReleaseManager.getFirstRunLevel(rconId, current_run_level) )`
100	`{`	107	`{`
101	`mLogger.warn("run no longer configured 1");`	108	`mLogger.warn("run no longer configured 1");`
102	`throw new ExitException();`	109	`throw new ExitException();`
103	`}`	110	`}`
Line 114...	Line 121...
114	`else`	121	`else`
115	`{`	122	`{`
116	`mLogger.info("run sleep 3 secs waiting for Master to set Slave run level ACTIVE");`	123	`mLogger.info("run sleep 3 secs waiting for Master to set Slave run level ACTIVE");`
117	`}`	124	`}`
118	`// to do, sleep for periodicMs`	125	`// to do, sleep for periodicMs`
-		126	`mLogger.fatal("run calling Thread.sleep for 3 secs");`
119	`Thread.sleep(3000);`	127	`Thread.sleep(3000);`
120	`mLogger.info("run sleep returned");`	128	`mLogger.info("run sleep returned");`
121	`}`	129	`}`
122	`catch (InterruptedException e)`	130	`catch (InterruptedException e)`
123	`{`	131	`{`
124	`mLogger.warn("run caught InterruptedException");`	132	`mLogger.warn("run caught InterruptedException");`
125	`}`	133	`}`
126	`}`	134	`}`
127	`} while (current_run_level.value != ReleaseManager.DB_ACTIVE);`	135	`} while (current_run_level.value != ReleaseManager.DB_ACTIVE);`
128		136
-		137	`mLogger.fatal("run calling mReleaseManager.queryRunLevel");`
129	`mReleaseManager.queryRunLevel(mRconId, buildFileContent);`	138	`mReleaseManager.queryRunLevel(mRconId, buildFileContent);`
130		139
131	`if ( buildFileContent.value.compareTo("") == 0)`	140	`if ( buildFileContent.value.compareTo("") == 0)`
132	`{`	141	`{`
133	`mLogger.warn("run no longer configured 2");`	142	`mLogger.warn("run no longer configured 2");`
Line 140...	Line 149...
140	`{`	149	`{`
141	`throw new ExitException();`	150	`throw new ExitException();`
142	`}`	151	`}`
143		152
144	`// set CURRENT_BUILD_FILES to null`	153	`// set CURRENT_BUILD_FILES to null`
-		154	`mLogger.fatal("run calling mReleaseManager.clearBuildFile");`
145	`mReleaseManager.clearBuildFile(mRconId);`	155	`mReleaseManager.clearBuildFile(mRconId);`
146		156
147	`// check environment`	157	`// check environment`
148	`mLogger.warn("run checkEnvironment");`	158	`mLogger.warn("run checkEnvironment");`
-		159	`mLogger.fatal("run calling checkEnvironment");`
149	`checkEnvironment();`	160	`checkEnvironment();`
150	`mLogger.info("run checkEnvironment returned");`	161	`mLogger.info("run checkEnvironment returned");`
151		162
152	`mSleep = true;`	163	`mSleep = true;`
153	`if ( buildFileContent.value.compareTo(mDummyBuildFileContent) != 0 )`	164	`if ( buildFileContent.value.compareTo(mDummyBuildFileContent) != 0 )`
154	`{`	165	`{`
155	`// deliver change to product baseline`	166	`// deliver change to product baseline`
156	`mLogger.warn("run deliverChange");`	167	`mLogger.warn("run deliverChange");`
-		168	`mLogger.fatal("run calling setViewUp");`
157	`setViewUp(buildFileContent.value, false);`	169	`setViewUp(buildFileContent.value, false);`
158		170
159	`if ( mGbeGatherMetricsOnly != null )`	171	`if ( mGbeGatherMetricsOnly != null )`
160	`{`	172	`{`
161	`// special for metrics`	173	`// special for metrics`
162	`// deliverChange on a benign target to get mReportingPackageName and mReportingPackageVersion set up`	174	`// deliverChange on a benign target to get mReportingPackageName and mReportingPackageVersion set up`
163	`// nb in the metrics gathering world the <rtagid>build.xml is provided by the master thread`	175	`// nb in the metrics gathering world the <rtagid>build.xml is provided by the master thread`
-		176	`mLogger.fatal("run calling deliverChange on fullstart");`
164	`deliverChange(null, "fullstart", false);`	177	`deliverChange(null, "fullstart", false);`
165		178
166	`String archive = Package.mGbeDpkg;`	179	`String archive = Package.mGbeDpkg;`
167		180
168	`if (archive != null)`	181	`if (archive != null)`
Line 179...	Line 192...
179	`}`	192	`}`
180		193
181	`}`	194	`}`
182	`else`	195	`else`
183	`{`	196	`{`
-		197	`mLogger.fatal("run calling deliverChange - the actual build");`
184	`deliverChange(null, null, false);`	198	`deliverChange(null, null, false);`
-		199	`mLogger.fatal("run calling deliverChange on AbtTearDown");`
185	`deliverChange(null, "AbtTearDown", false);`	200	`deliverChange(null, "AbtTearDown", false);`
186	`}`	201	`}`
187		202
188	`if ( mReportingBuildFailureLogFile != null )`	203	`if ( mReportingBuildFailureLogFile != null )`
189	`{`	204	`{`
Line 197...	Line 212...
197	`testBuildInstruction = Integer.parseInt( mReportingTestBuild );`	212	`testBuildInstruction = Integer.parseInt( mReportingTestBuild );`
198	`}`	213	`}`
199	`catch( NumberFormatException nfe )`	214	`catch( NumberFormatException nfe )`
200	`{`	215	`{`
201	`}`	216	`}`
-		217	`mLogger.fatal("run calling excludeFromBuild");`
202	`mReleaseManager.excludeFromBuild(mReportingPackageVersionId, mReportingPackageVersion, rtagId.toString(), null, null, mReportingBuildFailureLogFile, false, testBuildInstruction);`	218	`mReleaseManager.excludeFromBuild(mReportingPackageVersionId, mReportingPackageVersion, rtagId.toString(), null, null, mReportingBuildFailureLogFile, false, testBuildInstruction);`
203	`}`	219	`}`
204		220
205	`mLogger.info("run deliverChange returned");`	221	`mLogger.info("run deliverChange returned");`
206	`mSleep = false;`	222	`mSleep = false;`

Subversion Repositories DevTools

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