APPS.FND_OAM_DSCRAM_TASKS_PKG dependencies on FND_OAM_DSCRAM_UTILS_PKG

Line 22: AND T.task_status in (FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_UNPROCESSED,

18: IS
19: SELECT /*+ FIRST_ROWS(1) */ T.task_id, T.task_status
20: FROM fnd_oam_dscram_tasks T
21: WHERE T.bundle_id = FND_OAM_DSCRAM_BUNDLES_PKG.GET_BUNDLE_ID
22: AND T.task_status in (FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_UNPROCESSED,
23: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING,
24: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_RESTARTABLE)
25: AND (EXISTS (SELECT unit_id
26: FROM fnd_oam_dscram_units U

Line 23: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING,

19: SELECT /*+ FIRST_ROWS(1) */ T.task_id, T.task_status
20: FROM fnd_oam_dscram_tasks T
21: WHERE T.bundle_id = FND_OAM_DSCRAM_BUNDLES_PKG.GET_BUNDLE_ID
22: AND T.task_status in (FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_UNPROCESSED,
23: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING,
24: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_RESTARTABLE)
25: AND (EXISTS (SELECT unit_id
26: FROM fnd_oam_dscram_units U
27: WHERE U.task_id = T.task_id

Line 24: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_RESTARTABLE)

20: FROM fnd_oam_dscram_tasks T
21: WHERE T.bundle_id = FND_OAM_DSCRAM_BUNDLES_PKG.GET_BUNDLE_ID
22: AND T.task_status in (FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_UNPROCESSED,
23: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING,
24: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_RESTARTABLE)
25: AND (EXISTS (SELECT unit_id
26: FROM fnd_oam_dscram_units U
27: WHERE U.task_id = T.task_id
28: AND U.unit_status IN (FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_UNPROCESSED,

Line 28: AND U.unit_status IN (FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_UNPROCESSED,

24: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_RESTARTABLE)
25: AND (EXISTS (SELECT unit_id
26: FROM fnd_oam_dscram_units U
27: WHERE U.task_id = T.task_id
28: AND U.unit_status IN (FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_UNPROCESSED,
29: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING,
30: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_RESTARTABLE)
31: AND U.concurrent_group_unit_id IS NULL
32: AND (U.actual_workers_allowed IS NULL OR U.actual_workers_allowed > U.workers_assigned)) OR

Line 29: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING,

25: AND (EXISTS (SELECT unit_id
26: FROM fnd_oam_dscram_units U
27: WHERE U.task_id = T.task_id
28: AND U.unit_status IN (FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_UNPROCESSED,
29: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING,
30: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_RESTARTABLE)
31: AND U.concurrent_group_unit_id IS NULL
32: AND (U.actual_workers_allowed IS NULL OR U.actual_workers_allowed > U.workers_assigned)) OR
33: T.workers_assigned = 0)

Line 30: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_RESTARTABLE)

26: FROM fnd_oam_dscram_units U
27: WHERE U.task_id = T.task_id
28: AND U.unit_status IN (FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_UNPROCESSED,
29: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING,
30: FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_RESTARTABLE)
31: AND U.concurrent_group_unit_id IS NULL
32: AND (U.actual_workers_allowed IS NULL OR U.actual_workers_allowed > U.workers_assigned)) OR
33: T.workers_assigned = 0)
34: ORDER BY priority ASC, weight DESC;

Line 102: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY;

98: -- no rows is an empty
99: IF B_TASKS%NOTFOUND THEN
100: fnd_oam_debug.log(1, l_ctxt, 'B_TASKS empty');
101: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
102: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY;
103: CLOSE B_TASKS;
104: RETURN;
105: END IF;
106:

Line 174: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_EXECUTABLE(l_status) THEN

170: END IF;
171: CLOSE C1;
172:
173: --make sure the task has been marked as started by the controller
174: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_EXECUTABLE(l_status) THEN
175: -- report the true status of the task to execute to pass on to execute's caller
176: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_START_STS_TO_RET(l_status);
177: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN
178: x_return_msg := 'Invalid task status('||l_status||')';

Line 176: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_START_STS_TO_RET(l_status);

172:
173: --make sure the task has been marked as started by the controller
174: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_EXECUTABLE(l_status) THEN
175: -- report the true status of the task to execute to pass on to execute's caller
176: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_START_STS_TO_RET(l_status);
177: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN
178: x_return_msg := 'Invalid task status('||l_status||')';
179: fnd_oam_debug.log(1, l_ctxt, x_return_msg);
180: END IF;

Line 177: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN

173: --make sure the task has been marked as started by the controller
174: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_EXECUTABLE(l_status) THEN
175: -- report the true status of the task to execute to pass on to execute's caller
176: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_START_STS_TO_RET(l_status);
177: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN
178: x_return_msg := 'Invalid task status('||l_status||')';
179: fnd_oam_debug.log(1, l_ctxt, x_return_msg);
180: END IF;
181: fnd_oam_debug.log(2, l_ctxt, 'EXIT');

Line 230: FND_OAM_DSCRAM_UTILS_PKG.VALIDATION_DUE(b_task_info.last_validated)) THEN

226: END IF;
227:
228: -- check if we should do work or if we can presume the cached status
229: IF (p_force_query OR
230: FND_OAM_DSCRAM_UTILS_PKG.VALIDATION_DUE(b_task_info.last_validated)) THEN
231:
232: fnd_oam_debug.log(1, l_ctxt, '>RE-QUERYING<');
233:
234: -- re-init the cached fields to allow easy exit

Line 250: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_PROCESSING(l_status) THEN

246: END IF;
247: CLOSE C1;
248:
249: --make sure the task has been marked as processing
250: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_PROCESSING(l_status) THEN
251: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_CONT_STS_TO_RET(l_status);
252: b_task_info.last_validation_ret_sts := x_return_status;
253: IF x_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED THEN
254: x_return_msg := 'Invalid task status('||l_status||')';

Line 251: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_CONT_STS_TO_RET(l_status);

247: CLOSE C1;
248:
249: --make sure the task has been marked as processing
250: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_PROCESSING(l_status) THEN
251: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_CONT_STS_TO_RET(l_status);
252: b_task_info.last_validation_ret_sts := x_return_status;
253: IF x_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED THEN
254: x_return_msg := 'Invalid task status('||l_status||')';
255: fnd_oam_debug.log(1, l_ctxt, x_return_msg);

Line 253: IF x_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED THEN

249: --make sure the task has been marked as processing
250: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_PROCESSING(l_status) THEN
251: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_CONT_STS_TO_RET(l_status);
252: b_task_info.last_validation_ret_sts := x_return_status;
253: IF x_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED THEN
254: x_return_msg := 'Invalid task status('||l_status||')';
255: fnd_oam_debug.log(1, l_ctxt, x_return_msg);
256: END IF;
257: RETURN FALSE;

Line 271: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED;

267: TRUE,
268: l_return_status,
269: l_return_msg) THEN
270: -- the run/bundle has an invalid status, tell the execute to stop the task
271: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED;
272: x_return_msg := '[Continued Validation Parent(s) Failed]:(Status('||l_return_status||'), Msg('||l_return_msg||'))';
273: fnd_oam_debug.log(1, l_ctxt, x_return_msg);
274: RETURN FALSE;
275: END IF;

Line 330: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_EXECUTABLE(l_status) THEN

326:
327: fnd_oam_debug.log(1, l_ctxt, 'Task Status(Workers): '||l_status||'('||l_workers_assigned||')');
328:
329: -- make sure the status is runnable after the lock
330: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_EXECUTABLE(l_status) THEN
331: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_START_STS_TO_RET(l_status);
332: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN
333: x_return_msg := 'Invalid task in assign, status('||l_status||')';
334: fnd_oam_debug.log(1, l_ctxt, x_return_msg);

Line 331: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_START_STS_TO_RET(l_status);

327: fnd_oam_debug.log(1, l_ctxt, 'Task Status(Workers): '||l_status||'('||l_workers_assigned||')');
328:
329: -- make sure the status is runnable after the lock
330: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_EXECUTABLE(l_status) THEN
331: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_START_STS_TO_RET(l_status);
332: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN
333: x_return_msg := 'Invalid task in assign, status('||l_status||')';
334: fnd_oam_debug.log(1, l_ctxt, x_return_msg);
335: END IF;

Line 332: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN

328:
329: -- make sure the status is runnable after the lock
330: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_EXECUTABLE(l_status) THEN
331: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_START_STS_TO_RET(l_status);
332: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN
333: x_return_msg := 'Invalid task in assign, status('||l_status||')';
334: fnd_oam_debug.log(1, l_ctxt, x_return_msg);
335: END IF;
336: fnd_oam_debug.log(2, l_ctxt, 'EXIT');

Line 342: IF l_status <> FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING THEN

338: RETURN;
339: END IF;
340:
341: -- if we're executable but not processing we should start the entry
342: IF l_status <> FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING THEN
343: IF l_workers_assigned = 0 THEN
344: --create a new stats entry for the task
345: FND_OAM_DSCRAM_STATS_PKG.CREATE_ENTRY(p_source_object_type => FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_TASK,
346: p_source_object_id => p_task_id,

Line 345: FND_OAM_DSCRAM_STATS_PKG.CREATE_ENTRY(p_source_object_type => FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_TASK,

341: -- if we're executable but not processing we should start the entry
342: IF l_status <> FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING THEN
343: IF l_workers_assigned = 0 THEN
344: --create a new stats entry for the task
345: FND_OAM_DSCRAM_STATS_PKG.CREATE_ENTRY(p_source_object_type => FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_TASK,
346: p_source_object_id => p_task_id,
347: p_start_time => SYSDATE,
348: p_prestart_status => l_status,
349: x_stat_id => l_stat_id);

Line 351: SET task_status = FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING,

347: p_start_time => SYSDATE,
348: p_prestart_status => l_status,
349: x_stat_id => l_stat_id);
350: UPDATE fnd_oam_dscram_tasks
351: SET task_status = FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING,
352: STATS_FINISHED = FND_API.G_FALSE
353: WHERE task_id = p_task_id;
354: ELSE
355: --the bundle isn't processing but the worker count's nonzero, this shouldn't happen

Line 423: FND_OAM_DSCRAM_UTILS_PKG.TRANSLATE_COMPLETED_STATUS(l_status,

419: WHERE task_id = b_task_info.task_id
420: FOR UPDATE;
421:
422: -- translate the new_status into a valid final status
423: FND_OAM_DSCRAM_UTILS_PKG.TRANSLATE_COMPLETED_STATUS(l_status,
424: l_workers_assigned,
425: p_proposed_status,
426: p_proposed_ret_sts,
427: l_final_status,

Line 433: IF l_final_ret_sts = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL AND l_workers_assigned > 1 THEN

429: fnd_oam_debug.log(1, l_ctxt, 'Translated status "'||p_proposed_status||'" into "'||l_final_status||'"');
430: fnd_oam_debug.log(1, l_ctxt, 'Translated Execute Ret Sts "'||p_proposed_ret_sts||'" into "'||l_final_ret_sts||'"');
431:
432: --if we discovered that we're full, possibly temporarily, just decrement the worker count and leave as long as we're not the last worker
433: IF l_final_ret_sts = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL AND l_workers_assigned > 1 THEN
434: UPDATE fnd_oam_dscram_tasks
435: SET workers_assigned = workers_assigned - 1,
436: last_updated_by = fnd_global.user_id,
437: last_update_login = fnd_global.user_id,

Line 452: FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_FINAL(l_final_status) THEN

448: WHERE task_id = b_task_info.task_id;
449:
450: --only complete stats if we changed state
451: IF l_final_status <> l_status AND
452: FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_FINAL(l_final_status) THEN
453:
454: FND_OAM_DSCRAM_STATS_PKG.COMPLETE_ENTRY(p_source_object_type => FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_TASK,
455: p_source_object_id => b_task_info.task_id,
456: p_end_time => SYSDATE,

Line 454: FND_OAM_DSCRAM_STATS_PKG.COMPLETE_ENTRY(p_source_object_type => FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_TASK,

450: --only complete stats if we changed state
451: IF l_final_status <> l_status AND
452: FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_FINAL(l_final_status) THEN
453:
454: FND_OAM_DSCRAM_STATS_PKG.COMPLETE_ENTRY(p_source_object_type => FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_TASK,
455: p_source_object_id => b_task_info.task_id,
456: p_end_time => SYSDATE,
457: p_postend_status => l_final_status);
458: END IF;

Line 473: x_final_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;

469:
470: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
471: EXCEPTION
472: WHEN OTHERS THEN
473: x_final_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;
474: x_final_ret_sts := FND_API.G_RET_STS_UNEXP_ERROR;
475: fnd_oam_debug.log(6, l_ctxt, 'Unhandled Exception: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
476: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
477: ROLLBACK;

Line 529: COMPLETE_TASK(FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED,

525: l_return_status,
526: l_return_msg) THEN
527: --we don't care why a parent is invalid, just knowing so forces us to
528: --stop our work
529: COMPLETE_TASK(FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED,
530: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED,
531: l_completed_status,
532: x_return_status);
533: x_return_msg := '[Post-Assignment Parent Validation Failed]:('||l_return_msg||')';

Line 530: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED,

526: l_return_msg) THEN
527: --we don't care why a parent is invalid, just knowing so forces us to
528: --stop our work
529: COMPLETE_TASK(FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED,
530: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED,
531: l_completed_status,
532: x_return_status);
533: x_return_msg := '[Post-Assignment Parent Validation Failed]:('||l_return_msg||')';
534: fnd_oam_debug.log(1, l_ctxt, x_return_msg);

Line 541: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSED;

537: END IF;
538:
539: --at this point, we're assigned so we need to issue a complete before returning.
540: --this means no quick returns, so we hit the complete after the loop.
541: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSED;
542: l_return_status := FND_API.G_RET_STS_SUCCESS;
543:
544: -- we're in, start pulling units and executing them.
545: <>

Line 552: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY THEN

548: FND_OAM_DSCRAM_UNITS_PKG.FETCH_NEXT_UNIT(TRUE,
549: l_unit_id,
550: l_return_status,
551: l_return_msg);
552: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY THEN
553: -- empty means no units left, independent of phase
554: l_return_status := FND_API.G_RET_STS_SUCCESS;
555: EXIT outer;
556: ELSIF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL THEN

Line 556: ELSIF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL THEN

552: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY THEN
553: -- empty means no units left, independent of phase
554: l_return_status := FND_API.G_RET_STS_SUCCESS;
555: EXIT outer;
556: ELSIF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL THEN
557: -- full means nothing available right now so return and find another task.
558: EXIT outer;
559: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
560: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;

Line 560: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;

556: ELSIF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL THEN
557: -- full means nothing available right now so return and find another task.
558: EXIT outer;
559: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
560: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;
561: x_return_msg := '[Fetch Next Unit Failed]:('||l_return_msg||')';
562: fnd_oam_debug.log(6, l_ctxt, x_return_msg);
563: EXIT outer;
564: END IF;

Line 570: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL THEN

566: --execute the unit
567: FND_OAM_DSCRAM_UNITS_PKG.EXECUTE_UNIT(l_unit_id,
568: l_return_status,
569: l_return_msg);
570: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL THEN
571: --If we got past the fetch but the execute found it full, continue
572: --fetching.
573: <>
574: LOOP

Line 579: IF l_return_status IN (FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY,

575: FND_OAM_DSCRAM_UNITS_PKG.FETCH_NEXT_UNIT(FALSE,
576: l_unit_id,
577: l_return_status,
578: l_return_msg);
579: IF l_return_status IN (FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY,
580: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL) THEN
581: -- seeing an empty or full here doesn't mean the task's done, just that it's busy.
582: -- return full to the bundle_pkg to pick another task.
583: l_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL;

Line 580: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL) THEN

576: l_unit_id,
577: l_return_status,
578: l_return_msg);
579: IF l_return_status IN (FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY,
580: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL) THEN
581: -- seeing an empty or full here doesn't mean the task's done, just that it's busy.
582: -- return full to the bundle_pkg to pick another task.
583: l_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL;
584: EXIT outer;

Line 583: l_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL;

579: IF l_return_status IN (FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY,
580: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL) THEN
581: -- seeing an empty or full here doesn't mean the task's done, just that it's busy.
582: -- return full to the bundle_pkg to pick another task.
583: l_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL;
584: EXIT outer;
585: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
586: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;
587: x_return_msg := '[Inner Fetch Next Unit Failed]:('||l_return_msg||')';

Line 586: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;

582: -- return full to the bundle_pkg to pick another task.
583: l_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL;
584: EXIT outer;
585: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
586: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;
587: x_return_msg := '[Inner Fetch Next Unit Failed]:('||l_return_msg||')';
588: fnd_oam_debug.log(6, l_ctxt, x_return_msg);
589: EXIT outer;
590: END IF;

Line 596: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL THEN

592: -- try to execute this unit
593: FND_OAM_DSCRAM_UNITS_PKG.EXECUTE_UNIT(l_unit_id,
594: l_return_status,
595: l_return_msg);
596: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL THEN
597: --continue to the next inner loop iteration for the next fetch
598: null;
599: ELSIF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
600: --on success break out of the loop so we can requery the units table from scratch

Line 602: ELSIF l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED AND

598: null;
599: ELSIF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
600: --on success break out of the loop so we can requery the units table from scratch
601: EXIT inner;
602: ELSIF l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED AND
603: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED THEN
604: -- unexpected execution failure, since units have phases, there may be dependencies between
605: -- units which will break if we continue with the task. To handle this, we'll stop the task and
606: -- allow the user to choose whether to ignore the failed unit or retry them when restarting the task.

Line 603: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED THEN

599: ELSIF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
600: --on success break out of the loop so we can requery the units table from scratch
601: EXIT inner;
602: ELSIF l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED AND
603: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED THEN
604: -- unexpected execution failure, since units have phases, there may be dependencies between
605: -- units which will break if we continue with the task. To handle this, we'll stop the task and
606: -- allow the user to choose whether to ignore the failed unit or retry them when restarting the task.
607: x_return_msg := '[Inner Execute Unit Failed]:(Status('||l_return_status||'), Msg('||l_return_msg||')). Stopping task.';

Line 609: l_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED;

605: -- units which will break if we continue with the task. To handle this, we'll stop the task and
606: -- allow the user to choose whether to ignore the failed unit or retry them when restarting the task.
607: x_return_msg := '[Inner Execute Unit Failed]:(Status('||l_return_status||'), Msg('||l_return_msg||')). Stopping task.';
608: fnd_oam_debug.log(6, l_ctxt, x_return_msg);
609: l_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED;
610: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED;
611: EXIT outer;
612: END IF;
613: END LOOP inner;

Line 610: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED;

606: -- allow the user to choose whether to ignore the failed unit or retry them when restarting the task.
607: x_return_msg := '[Inner Execute Unit Failed]:(Status('||l_return_status||'), Msg('||l_return_msg||')). Stopping task.';
608: fnd_oam_debug.log(6, l_ctxt, x_return_msg);
609: l_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED;
610: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED;
611: EXIT outer;
612: END IF;
613: END LOOP inner;
614: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS AND

Line 615: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED AND

611: EXIT outer;
612: END IF;
613: END LOOP inner;
614: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS AND
615: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED AND
616: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED THEN
617: -- take the same actions as when the inner execute fails
618: x_return_msg := '[Outer Execute Unit Failed]:(Status('||l_return_status||'), Msg('||l_return_msg||')). Stopping task.';
619: fnd_oam_debug.log(6, l_ctxt, x_return_msg);

Line 616: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED THEN

612: END IF;
613: END LOOP inner;
614: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS AND
615: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED AND
616: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED THEN
617: -- take the same actions as when the inner execute fails
618: x_return_msg := '[Outer Execute Unit Failed]:(Status('||l_return_status||'), Msg('||l_return_msg||')). Stopping task.';
619: fnd_oam_debug.log(6, l_ctxt, x_return_msg);
620: l_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED;

Line 620: l_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED;

616: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED THEN
617: -- take the same actions as when the inner execute fails
618: x_return_msg := '[Outer Execute Unit Failed]:(Status('||l_return_status||'), Msg('||l_return_msg||')). Stopping task.';
619: fnd_oam_debug.log(6, l_ctxt, x_return_msg);
620: l_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED;
621: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED;
622: EXIT outer;
623: END IF;
624:

Line 621: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED;

617: -- take the same actions as when the inner execute fails
618: x_return_msg := '[Outer Execute Unit Failed]:(Status('||l_return_status||'), Msg('||l_return_msg||')). Stopping task.';
619: fnd_oam_debug.log(6, l_ctxt, x_return_msg);
620: l_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED;
621: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED;
622: EXIT outer;
623: END IF;
624:
625: --after every unit evaluation, check on the task and its parents.

Line 633: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_RET_STS_TO_COMPL_STATUS(l_return_status);

629: TRUE,
630: l_return_status,
631: l_return_msg) THEN
632: --complete the task based on what validate found
633: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_RET_STS_TO_COMPL_STATUS(l_return_status);
634: IF FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_ERROR(l_return_status) THEN
635: x_return_msg := '[End-of-Loop Validate Failed]:('||l_return_msg||')';
636: fnd_oam_debug.log(6, l_ctxt, x_return_msg);
637: END IF;

Line 634: IF FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_ERROR(l_return_status) THEN

630: l_return_status,
631: l_return_msg) THEN
632: --complete the task based on what validate found
633: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_RET_STS_TO_COMPL_STATUS(l_return_status);
634: IF FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_ERROR(l_return_status) THEN
635: x_return_msg := '[End-of-Loop Validate Failed]:('||l_return_msg||')';
636: fnd_oam_debug.log(6, l_ctxt, x_return_msg);
637: END IF;
638: EXIT outer;

Line 653: COMPLETE_TASK(FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN,

649:
650: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
651: EXCEPTION
652: WHEN OTHERS THEN
653: COMPLETE_TASK(FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN,
654: FND_API.G_RET_STS_UNEXP_ERROR,
655: l_completed_status,
656: x_return_status);
657: x_return_msg := 'Unhandled Exception: [Code('||SQLCODE||'), Message("'||SQLERRM||'")]';