migration single processor to dual processor problem

[Michel Meex]

Hello,

I have an application, that has been running on a single processor server
for more then a year without any problems. Now I'm migrating to a dual
processor server, and I'm experiencing problems with threading.

The application is actually a kind of job schedular. For all jobs, I can set
a recurring interval (daily,weekly, monthly etc) at which the specific job
should be started. We program each job, according to an interface. Examples
of jobs are: server monitoring, reporting, messaging etc.

The job itself maintains a status. When it's complete, it's status is set to
ready.

The job-schedular looks at certain times for two things: Should I start a
new job and Is there a job with status Ready which should be stopped.

the code for stopping a job is only a:
ji.InstanceThre ad.Abort();
ji.InstanceThre ad.Join(1000);
MJSJobList._job List.Remove(ji) ;
What I now see, is that on the single processor server, this works, and the
job is removed from the list.
On the dual-processor server, however the job remains in the list with
status "Ready"..

Am I missing somethinge here ? The code worked perfectly on the other server
for a very long time.

Thanks in advance,
Michel Meex

[Michel Meex]

Ok, here's some more code.

In the windows service, a timer executes the following method:
internal void MonitorJobs()
{
ArrayList al = this.RetrieveJo bsState();
foreach(MJSJobS tate js in al)
{
//If job is ready
if (js.JobState == MJSJobStatic.Jo bState.Ready)
{
TempLogging(js. JobName,"Job found, status ready, should stop");
bool _found = false;
//stop and clear job
foreach (MJSJobInstance ji in MJSJobList._job List)
{
if (ji.JobData.Job Name == js.JobName)
{
_found = true;
this.JobStop(ji .JobData);
break; }
}
TempLogging(js. JobName,"Job found: " + _found.ToString ());
}
}
}

the method JobStop contains the following:
public void JobStop(MJSJobD ata jobData)
{
if (jobData != null)
{
//if job is running
if (this.JobIsRunn ing(jobData) ==
MJSJobStatic.Th reeValueBool.Tr ue)
{
bool jobStopped = false;
//Find job instance in joblist
foreach (MJSJobInstance ji in MJSJobList._job List)
{
if (jobData != null)
{
if (jobData.JobNam e == ji.JobData.JobN ame)
{
//Call job stop method (IJob interface),
((IJob) ji.InstanceObje ct).Stop();
//Clear object reference
ji.InstanceObje ct = null;
//Stop process / end thread
ji.InstanceThre ad.Abort();
ji.InstanceThre ad.Join(1000);

//debugging info
HistoryData _tempHistoryNew = new HistoryData();
_tempHistoryNew .JobName = ji.JobData.JobN ame;
_tempHistoryNew .Type = MJSJobStatic.Hi storyType.Infor mation;
_tempHistoryNew .Time = System.DateTime .Now;
_tempHistoryNew .Extra = "trying to stop.....debug info";
JobHistory.Add( _tempHistoryNew );
//end debugging info

//Remove job from JobList
MJSJobList._job List.Remove(ji) ;
jobStopped = true;
break;
}
}
}

if (jobStopped)
{
//Log event
HistoryData _tempHistoryNew = new HistoryData();
_tempHistoryNew .JobName = jobData.JobName ;
_tempHistoryNew .Type = MJSJobStatic.Hi storyType.Infor mation;
_tempHistoryNew .Time = System.DateTime .Now;
_tempHistoryNew .Extra = JOB_STOPPED;
JobHistory.Add( _tempHistoryNew );
}
else
{
//Log event
HistoryData _tempHistoryNew = new HistoryData();
_tempHistoryNew .JobName = jobData.JobName ;
_tempHistoryNew .Type = MJSJobStatic.Hi storyType.Error ;
_tempHistoryNew .Time = System.DateTime .Now;
_tempHistoryNew .Extra = "Job could not be stopped.";
JobHistory.Add( _tempHistoryNew );
}
}
else
{
//Write something to the log
//Log event
HistoryData _tempHistoryNew = new HistoryData();
_tempHistoryNew .JobName = jobData.JobName ;
_tempHistoryNew .Type = MJSJobStatic.Hi storyType.Error ;
_tempHistoryNew .Time = System.DateTime .Now;
_tempHistoryNew .Extra = "Job could not be stopped. The job is not
running.";
JobHistory.Add( _tempHistoryNew );
}
}
else
{
//Write something to the log if running state of job could not be
determined
//Log event
HistoryData _tempHistoryNew = new HistoryData();
_tempHistoryNew .JobName = string.Empty;
_tempHistoryNew .Type = MJSJobStatic.Hi storyType.Error ;
_tempHistoryNew .Time = System.DateTime .Now;
_tempHistoryNew .Extra = "Job could not be stopped. No job provided.";
JobHistory.Add( _tempHistoryNew );
}
}

I hope you can do something with this..
Regards,
Michel