DBA Data[Home] [Help]

APPS.IEM_MDTSTARTPROCESS_PUB dependencies on FND_CONCURRENT

Line 134: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);

130: ROLLBACK TO LaunchProcess_PUB;
131: FND_MESSAGE.SET_NAME('IEM','IEM_LAUNCHPROCESS_EXEC_ERROR');
132: l_Error_Message := FND_MESSAGE.GET;
133: fnd_file.put_line(fnd_file.log, l_Error_Message);
134: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);
135: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
136: ROLLBACK TO LaunchProcess_PUB;
137: FND_MESSAGE.SET_NAME('IEM','IEM_LAUNCHPROCESS_UNXPTD_ERR');
138: l_Error_Message := FND_MESSAGE.GET;

Line 140: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);

136: ROLLBACK TO LaunchProcess_PUB;
137: FND_MESSAGE.SET_NAME('IEM','IEM_LAUNCHPROCESS_UNXPTD_ERR');
138: l_Error_Message := FND_MESSAGE.GET;
139: fnd_file.put_line(fnd_file.log, l_Error_Message);
140: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);
141: WHEN STOP_ALL_WORKERS THEN
142: -- Get a current IEM Concurrent worker id.
143: l_call_status :=FND_CONCURRENT.GET_REQUEST_STATUS(l_request_id, 'IEM', 'IEMMDTWW', l_rphase,l_rstatus,l_dphase,l_dstatus,l_message);
144: IF l_call_status = false THEN

Line 143: l_call_status :=FND_CONCURRENT.GET_REQUEST_STATUS(l_request_id, 'IEM', 'IEMMDTWW', l_rphase,l_rstatus,l_dphase,l_dstatus,l_message);

139: fnd_file.put_line(fnd_file.log, l_Error_Message);
140: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);
141: WHEN STOP_ALL_WORKERS THEN
142: -- Get a current IEM Concurrent worker id.
143: l_call_status :=FND_CONCURRENT.GET_REQUEST_STATUS(l_request_id, 'IEM', 'IEMMDTWW', l_rphase,l_rstatus,l_dphase,l_dstatus,l_message);
144: IF l_call_status = false THEN
145: fnd_file.put_line(fnd_file.log, l_message);
146: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',l_message);
147:

Line 146: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',l_message);

142: -- Get a current IEM Concurrent worker id.
143: l_call_status :=FND_CONCURRENT.GET_REQUEST_STATUS(l_request_id, 'IEM', 'IEMMDTWW', l_rphase,l_rstatus,l_dphase,l_dstatus,l_message);
144: IF l_call_status = false THEN
145: fnd_file.put_line(fnd_file.log, l_message);
146: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',l_message);
147:
148: ELSE -- call staus is true
149: -- Cancel request id
150: l_call_status :=FND_CONCURRENT.CANCEL_REQUEST(l_request_id,l_Error_Message);

Line 150: l_call_status :=FND_CONCURRENT.CANCEL_REQUEST(l_request_id,l_Error_Message);

146: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',l_message);
147:
148: ELSE -- call staus is true
149: -- Cancel request id
150: l_call_status :=FND_CONCURRENT.CANCEL_REQUEST(l_request_id,l_Error_Message);
151:
152: IF l_call_status = false THEN
153: -- Try again
154: l_counter2 :=0;

Line 159: l_call_status :=FND_CONCURRENT.GET_REQUEST_STATUS(l_request_id, 'IEM', 'IEMMDTWW', l_rphase,l_rstatus,l_dphase,l_dstatus,l_message);

155: LOOP -- Sleep while other worker is terminating
156: l_counter2 := l_counter2 +1;
157: EXIT when l_counter2 = 100000000;
158: END LOOP;
159: l_call_status :=FND_CONCURRENT.GET_REQUEST_STATUS(l_request_id, 'IEM', 'IEMMDTWW', l_rphase,l_rstatus,l_dphase,l_dstatus,l_message);
160: l_call_status :=FND_CONCURRENT.CANCEL_REQUEST(l_request_id,l_Error_Message);
161: IF l_call_status = false THEN
162: fnd_file.put_line(fnd_file.log, l_Error_Message);
163: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',l_Error_Message);

Line 160: l_call_status :=FND_CONCURRENT.CANCEL_REQUEST(l_request_id,l_Error_Message);

156: l_counter2 := l_counter2 +1;
157: EXIT when l_counter2 = 100000000;
158: END LOOP;
159: l_call_status :=FND_CONCURRENT.GET_REQUEST_STATUS(l_request_id, 'IEM', 'IEMMDTWW', l_rphase,l_rstatus,l_dphase,l_dstatus,l_message);
160: l_call_status :=FND_CONCURRENT.CANCEL_REQUEST(l_request_id,l_Error_Message);
161: IF l_call_status = false THEN
162: fnd_file.put_line(fnd_file.log, l_Error_Message);
163: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',l_Error_Message);
164: ELSE -- call ststus is true

Line 163: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',l_Error_Message);

159: l_call_status :=FND_CONCURRENT.GET_REQUEST_STATUS(l_request_id, 'IEM', 'IEMMDTWW', l_rphase,l_rstatus,l_dphase,l_dstatus,l_message);
160: l_call_status :=FND_CONCURRENT.CANCEL_REQUEST(l_request_id,l_Error_Message);
161: IF l_call_status = false THEN
162: fnd_file.put_line(fnd_file.log, l_Error_Message);
163: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',l_Error_Message);
164: ELSE -- call ststus is true
165: l_call_status :=FND_CONCURRENT.WAIT_FOR_REQUEST(l_request_id, 60, 600, l_rphase, l_rstatus, l_dphase, l_dstatus, l_message);
166: IF l_call_status = false THEN
167: fnd_file.put_line(fnd_file.log, l_Error_Message);

Line 165: l_call_status :=FND_CONCURRENT.WAIT_FOR_REQUEST(l_request_id, 60, 600, l_rphase, l_rstatus, l_dphase, l_dstatus, l_message);

161: IF l_call_status = false THEN
162: fnd_file.put_line(fnd_file.log, l_Error_Message);
163: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',l_Error_Message);
164: ELSE -- call ststus is true
165: l_call_status :=FND_CONCURRENT.WAIT_FOR_REQUEST(l_request_id, 60, 600, l_rphase, l_rstatus, l_dphase, l_dstatus, l_message);
166: IF l_call_status = false THEN
167: fnd_file.put_line(fnd_file.log, l_Error_Message);
168: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',l_message);
169: END IF;

Line 168: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',l_message);

164: ELSE -- call ststus is true
165: l_call_status :=FND_CONCURRENT.WAIT_FOR_REQUEST(l_request_id, 60, 600, l_rphase, l_rstatus, l_dphase, l_dstatus, l_message);
166: IF l_call_status = false THEN
167: fnd_file.put_line(fnd_file.log, l_Error_Message);
168: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',l_message);
169: END IF;
170: END IF;
171:
172: ELSE -- Call status is True

Line 173: l_call_status :=FND_CONCURRENT.WAIT_FOR_REQUEST(l_request_id, 60, 600, l_rphase, l_rstatus, l_dphase, l_dstatus, l_message);

169: END IF;
170: END IF;
171:
172: ELSE -- Call status is True
173: l_call_status :=FND_CONCURRENT.WAIT_FOR_REQUEST(l_request_id, 60, 600, l_rphase, l_rstatus, l_dphase, l_dstatus, l_message);
174: IF l_call_status = false OR l_dstatus='TERMINATING' THEN
175: l_call_status :=FND_CONCURRENT.CHECK_LOCK_CONTENTION('', l_request_id, l_UProcess_ID, l_UTerminal, l_UNode, l_UName, l_UProgram);
176: fnd_file.put_line(fnd_file.log, l_message);
177: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING', ' '||l_UProcess_ID||' '||l_UName||' '||l_UProgram);

Line 175: l_call_status :=FND_CONCURRENT.CHECK_LOCK_CONTENTION('', l_request_id, l_UProcess_ID, l_UTerminal, l_UNode, l_UName, l_UProgram);

171:
172: ELSE -- Call status is True
173: l_call_status :=FND_CONCURRENT.WAIT_FOR_REQUEST(l_request_id, 60, 600, l_rphase, l_rstatus, l_dphase, l_dstatus, l_message);
174: IF l_call_status = false OR l_dstatus='TERMINATING' THEN
175: l_call_status :=FND_CONCURRENT.CHECK_LOCK_CONTENTION('', l_request_id, l_UProcess_ID, l_UTerminal, l_UNode, l_UName, l_UProgram);
176: fnd_file.put_line(fnd_file.log, l_message);
177: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING', ' '||l_UProcess_ID||' '||l_UName||' '||l_UProgram);
178: END IF;
179: END IF;

Line 177: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING', ' '||l_UProcess_ID||' '||l_UName||' '||l_UProgram);

173: l_call_status :=FND_CONCURRENT.WAIT_FOR_REQUEST(l_request_id, 60, 600, l_rphase, l_rstatus, l_dphase, l_dstatus, l_message);
174: IF l_call_status = false OR l_dstatus='TERMINATING' THEN
175: l_call_status :=FND_CONCURRENT.CHECK_LOCK_CONTENTION('', l_request_id, l_UProcess_ID, l_UTerminal, l_UNode, l_UName, l_UProgram);
176: fnd_file.put_line(fnd_file.log, l_message);
177: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING', ' '||l_UProcess_ID||' '||l_UName||' '||l_UProgram);
178: END IF;
179: END IF;
180: END IF;
181: --l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',' '||l_request_id||' '||l_Error_Message||' '||l_counter2);

Line 181: --l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',' '||l_request_id||' '||l_Error_Message||' '||l_counter2);

177: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING', ' '||l_UProcess_ID||' '||l_UName||' '||l_UProgram);
178: END IF;
179: END IF;
180: END IF;
181: --l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('WARNING',' '||l_request_id||' '||l_Error_Message||' '||l_counter2);
182: WHEN OTHERS THEN
183: ROLLBACK TO LaunchProcess_PUB;
184: FND_MESSAGE.SET_NAME('IEM','IEM_LAUNCHPROCESS_OTHER_ERRORS');
185: l_Error_Message := SQLERRM;

Line 187: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);

183: ROLLBACK TO LaunchProcess_PUB;
184: FND_MESSAGE.SET_NAME('IEM','IEM_LAUNCHPROCESS_OTHER_ERRORS');
185: l_Error_Message := SQLERRM;
186: fnd_file.put_line(fnd_file.log, l_Error_Message);
187: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);
188: END LaunchProcess;
189:
190: PROCEDURE ProcessRetry(ERRBUF OUT NOCOPY VARCHAR2,
191: ERRRET OUT NOCOPY VARCHAR2,

Line 228: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);

224: ROLLBACK TO LaunchProcess_PUB;
225: FND_MESSAGE.SET_NAME('IEM','IEM_RETRYPROCESS_EXEC_ERROR');
226: l_Error_Message := FND_MESSAGE.GET;
227: fnd_file.put_line(fnd_file.log, l_Error_Message);
228: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);
229: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
230: ROLLBACK TO LaunchProcess_PUB;
231: FND_MESSAGE.SET_NAME('IEM','IEM_RETRYPROCESS_UNXPTD_ERR');
232: l_Error_Message := FND_MESSAGE.GET;

Line 234: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);

230: ROLLBACK TO LaunchProcess_PUB;
231: FND_MESSAGE.SET_NAME('IEM','IEM_RETRYPROCESS_UNXPTD_ERR');
232: l_Error_Message := FND_MESSAGE.GET;
233: fnd_file.put_line(fnd_file.log, l_Error_Message);
234: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);
235: WHEN OTHERS THEN
236: ROLLBACK TO LaunchProcess_PUB;
237: FND_MESSAGE.SET_NAME('IEM','IEM_RETRYPROCESS_OTHER_ERR');
238: l_Error_Message := SQLERRM;

Line 240: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);

236: ROLLBACK TO LaunchProcess_PUB;
237: FND_MESSAGE.SET_NAME('IEM','IEM_RETRYPROCESS_OTHER_ERR');
238: l_Error_Message := SQLERRM;
239: fnd_file.put_line(fnd_file.log, l_Error_Message);
240: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);
241:
242: END ProcessRetry;
243: PROCEDURE StopProcessing(ERRBUF OUT NOCOPY VARCHAR2,
244: ERRRET OUT NOCOPY VARCHAR2,

Line 283: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);

279: ROLLBACK TO Stopworkflow_PUB;
280: FND_MESSAGE.SET_NAME('IEM','IEM_STOPWORKFLOW_EXEC_ERROR');
281: l_Error_Message := FND_MESSAGE.GET;
282: fnd_file.put_line(fnd_file.log, l_Error_Message);
283: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);
284: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
285: ROLLBACK TO Stopworkflow_PUB;
286: FND_MESSAGE.SET_NAME('IEM','IEM_STOPWORKFLOW_UNXPTD_ERR');
287: l_Error_Message := FND_MESSAGE.GET;

Line 289: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);

285: ROLLBACK TO Stopworkflow_PUB;
286: FND_MESSAGE.SET_NAME('IEM','IEM_STOPWORKFLOW_UNXPTD_ERR');
287: l_Error_Message := FND_MESSAGE.GET;
288: fnd_file.put_line(fnd_file.log, l_Error_Message);
289: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);
290: WHEN OTHERS THEN
291: ROLLBACK TO Stopworkflow_PUB;
292: FND_MESSAGE.SET_NAME('IEM','IEM_STOPWORKFLOW_OTHER_ERR');
293: l_Error_Message := SQLERRM;

Line 295: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);

291: ROLLBACK TO Stopworkflow_PUB;
292: FND_MESSAGE.SET_NAME('IEM','IEM_STOPWORKFLOW_OTHER_ERR');
293: l_Error_Message := SQLERRM;
294: fnd_file.put_line(fnd_file.log, l_Error_Message);
295: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);
296:
297: END StopProcessing;
298:
299: PROCEDURE PurgeWorkflow(ERRBUF OUT NOCOPY varchar2,

Line 353: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);

349: ROLLBACK TO Purgeworkflow_PUB;
350: FND_MESSAGE.SET_NAME('IEM','IEM_PURGEWORKFLOW_EXEC_ERROR');
351: l_Error_Message := FND_MESSAGE.GET;
352: fnd_file.put_line(fnd_file.log, l_Error_Message);
353: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);
354: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
355: ROLLBACK TO Purgeworkflow_PUB;
356: FND_MESSAGE.SET_NAME('IEM','IEM_PURGEWORKFLOW_UNXPTD_ERR');
357: l_Error_Message := FND_MESSAGE.GET;

Line 359: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);

355: ROLLBACK TO Purgeworkflow_PUB;
356: FND_MESSAGE.SET_NAME('IEM','IEM_PURGEWORKFLOW_UNXPTD_ERR');
357: l_Error_Message := FND_MESSAGE.GET;
358: fnd_file.put_line(fnd_file.log, l_Error_Message);
359: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);
360: WHEN OTHERS THEN
361: ROLLBACK TO Purgeworkflow_PUB;
362: FND_MESSAGE.SET_NAME('IEM','IEM_PURGEWORKFLOW_OTHER_ERR');
363: l_Error_Message := SQLERRM;

Line 365: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);

361: ROLLBACK TO Purgeworkflow_PUB;
362: FND_MESSAGE.SET_NAME('IEM','IEM_PURGEWORKFLOW_OTHER_ERR');
363: l_Error_Message := SQLERRM;
364: fnd_file.put_line(fnd_file.log, l_Error_Message);
365: l_call_status := FND_CONCURRENT.SET_COMPLETION_STATUS('ERROR',l_Error_Message);
366: END PurgeWorkflow;
367:
368: END IEM_MDTSTARTPROCESS_PUB ;