DBA Data[Home] [Help]

APPS.FND_OAM_DSCRAM_BUNDLES_PKG dependencies on FND_OAM_DSCRAM_UTILS_PKG

Line 125: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED;

121: IF NOT FND_OAM_DSCRAM_RUNS_PKG.VALIDATE_START_EXECUTION(p_run_id,
122: l_return_status,
123: l_return_msg) THEN
124: -- the run has an invalid status, tell the execute to stop the bundle and return.
125: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED;
126: x_return_msg := '[Run Validation Failed]:(Status('||l_return_status||'), Msg('||l_return_msg||'))';
127: fnd_oam_debug.log(6, l_ctxt, x_return_msg);
128: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
129: RETURN FALSE;

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

140: END IF;
141: CLOSE C1;
142:
143: --make sure the bundle is in a startable state
144: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_EXECUTABLE(l_status) THEN
145: -- report the true status of the bundle to execute to pass on to execute's caller
146: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_START_STS_TO_RET(l_status);
147: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN
148: x_return_msg := 'Invalid bundle status('||l_status||')';

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

142:
143: --make sure the bundle is in a startable state
144: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_EXECUTABLE(l_status) THEN
145: -- report the true status of the bundle to execute to pass on to execute's caller
146: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_START_STS_TO_RET(l_status);
147: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN
148: x_return_msg := 'Invalid bundle status('||l_status||')';
149: fnd_oam_debug.log(1, l_ctxt, x_return_msg);
150: END IF;

Line 147: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN

143: --make sure the bundle is in a startable state
144: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_EXECUTABLE(l_status) THEN
145: -- report the true status of the bundle to execute to pass on to execute's caller
146: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_START_STS_TO_RET(l_status);
147: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN
148: x_return_msg := 'Invalid bundle status('||l_status||')';
149: fnd_oam_debug.log(1, l_ctxt, x_return_msg);
150: END IF;
151: fnd_oam_debug.log(2, l_ctxt, 'EXIT');

Line 158: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL;

154:
155: --make sure there's a worker spot, assign will allocate but this check helps short
156: --circuit the lock.
157: IF l_workers_assigned >= l_workers_allowed THEN
158: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL;
159: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
160: RETURN FALSE;
161: END IF;
162:

Line 208: FND_OAM_DSCRAM_UTILS_PKG.VALIDATION_DUE(b_bundle_info.last_validated)) THEN

204: END IF;
205:
206: -- check if we should do work or if we can presume the cached status
207: IF (p_force_query OR
208: FND_OAM_DSCRAM_UTILS_PKG.VALIDATION_DUE(b_bundle_info.last_validated)) THEN
209:
210: fnd_oam_debug.log(1, l_ctxt, '>RE-QUERYING<');
211:
212: -- re-init the cached fields to allow easy exit

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

224: END IF;
225: CLOSE C1;
226:
227: --make sure the bundle has been marked as some valid processing state
228: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_PROCESSING(l_status) THEN
229: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_CONT_STS_TO_RET(l_status);
230: b_bundle_info.last_validation_ret_sts := x_return_status;
231: IF x_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED THEN
232: x_return_msg := 'Invalid bundle status('||l_status||')';

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

225: CLOSE C1;
226:
227: --make sure the bundle has been marked as some valid processing state
228: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_PROCESSING(l_status) THEN
229: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_CONT_STS_TO_RET(l_status);
230: b_bundle_info.last_validation_ret_sts := x_return_status;
231: IF x_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED THEN
232: x_return_msg := 'Invalid bundle status('||l_status||')';
233: fnd_oam_debug.log(1, l_ctxt, x_return_msg);

Line 231: IF x_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED THEN

227: --make sure the bundle has been marked as some valid processing state
228: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_PROCESSING(l_status) THEN
229: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_CONT_STS_TO_RET(l_status);
230: b_bundle_info.last_validation_ret_sts := x_return_status;
231: IF x_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED THEN
232: x_return_msg := 'Invalid bundle status('||l_status||')';
233: fnd_oam_debug.log(1, l_ctxt, x_return_msg);
234: END IF;
235: RETURN FALSE;

Line 249: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED;

245: TRUE,
246: l_return_status,
247: l_return_msg) THEN
248: -- the run has an invalid status, tell the execute to stop the bundle
249: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED;
250: x_return_msg := '[Continued Run Validation Failed]:(Status('||l_return_status||'), Msg('||l_return_msg||'))';
251: fnd_oam_debug.log(1, l_ctxt, x_return_msg);
252: RETURN FALSE;
253: END IF;

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

327: fnd_oam_debug.log(1, l_ctxt, 'Workers Assigned: '||l_workers_assigned);
328: fnd_oam_debug.log(1, l_ctxt, 'Argument Worker ID: '||to_char(px_worker_id));
329:
330: -- make sure the status is still good
331: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_EXECUTABLE(l_status) THEN
332: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_START_STS_TO_RET(l_status);
333: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN
334: x_return_msg := 'Invalid status for assign: ('||l_status||')';
335: fnd_oam_debug.log(1, l_ctxt, x_return_msg);

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

328: fnd_oam_debug.log(1, l_ctxt, 'Argument Worker ID: '||to_char(px_worker_id));
329:
330: -- make sure the status is still good
331: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_EXECUTABLE(l_status) THEN
332: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_VALIDATE_START_STS_TO_RET(l_status);
333: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN
334: x_return_msg := 'Invalid status for assign: ('||l_status||')';
335: fnd_oam_debug.log(1, l_ctxt, x_return_msg);
336: END IF;

Line 333: IF FND_OAM_DSCRAM_UTILS_PKG.RET_STS_IS_ERROR(x_return_status) THEN

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

Line 344: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL;

340: END IF;
341:
342: -- make sure there's room for this worker
343: IF l_workers_assigned >= l_workers_allowed THEN
344: x_return_status := FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL;
345: x_return_msg := 'Workers Assigned('||l_workers_assigned||') >= workers allowed('||l_workers_allowed||')';
346: fnd_oam_debug.log(6, l_ctxt, x_return_msg);
347: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
348: ROLLBACK;

Line 353: IF l_status <> FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING THEN

349: RETURN;
350: END IF;
351:
352: fnd_oam_debug.log(1, l_ctxt, 'Creating a New Worker...');
353: IF l_status <> FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING THEN
354: IF l_workers_assigned = 0 THEN
355: --create a stats entry
356: FND_OAM_DSCRAM_STATS_PKG.CREATE_ENTRY(p_source_object_type => FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_BUNDLE,
357: p_source_object_id => p_bundle_id,

Line 356: FND_OAM_DSCRAM_STATS_PKG.CREATE_ENTRY(p_source_object_type => FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_BUNDLE,

352: fnd_oam_debug.log(1, l_ctxt, 'Creating a New Worker...');
353: IF l_status <> FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING THEN
354: IF l_workers_assigned = 0 THEN
355: --create a stats entry
356: FND_OAM_DSCRAM_STATS_PKG.CREATE_ENTRY(p_source_object_type => FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_BUNDLE,
357: p_source_object_id => p_bundle_id,
358: p_start_time => SYSDATE,
359: p_prestart_status => l_status,
360: x_stat_id => l_stat_id);

Line 363: SET bundle_status = FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING,

359: p_prestart_status => l_status,
360: x_stat_id => l_stat_id);
361: --update the status
362: UPDATE fnd_oam_dscram_bundles
363: SET bundle_status = FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSING,
364: STATS_FINISHED = FND_API.G_FALSE
365: WHERE bundle_id = p_bundle_id;
366: ELSE
367: --the bundle isn't processing but somebody's set it to processing, this shouldn't happen

Line 462: FND_OAM_DSCRAM_UTILS_PKG.TRANSLATE_COMPLETED_STATUS(l_status,

458: WHERE bundle_id = b_bundle_info.bundle_id
459: FOR UPDATE;
460:
461: -- translate the new_status into a valid final status
462: FND_OAM_DSCRAM_UTILS_PKG.TRANSLATE_COMPLETED_STATUS(l_status,
463: l_workers_assigned,
464: p_proposed_status,
465: p_proposed_ret_sts,
466: l_final_status,

Line 482: FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_FINAL(l_final_status) THEN

478: WHERE bundle_id = b_bundle_info.bundle_id;
479:
480: --only complete stats if we changed state
481: IF l_final_status <> l_status AND
482: FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_FINAL(l_final_status) THEN
483:
484: FND_OAM_DSCRAM_STATS_PKG.COMPLETE_ENTRY(p_source_object_type => FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_BUNDLE,
485: p_source_object_id => b_bundle_info.bundle_id,
486: p_end_time => SYSDATE,

Line 484: FND_OAM_DSCRAM_STATS_PKG.COMPLETE_ENTRY(p_source_object_type => FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_BUNDLE,

480: --only complete stats if we changed state
481: IF l_final_status <> l_status AND
482: FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_FINAL(l_final_status) THEN
483:
484: FND_OAM_DSCRAM_STATS_PKG.COMPLETE_ENTRY(p_source_object_type => FND_OAM_DSCRAM_UTILS_PKG.G_TYPE_BUNDLE,
485: p_source_object_id => b_bundle_info.bundle_id,
486: p_end_time => SYSDATE,
487: p_postend_status => l_final_status);
488: END IF;

Line 493: FND_OAM_DSCRAM_UTILS_PKG.SIGNAL_PROGRESS_ALERT;

489:
490: --signal a progress alert to wake up any waiting workers for the run.
491: --this is done here as well as the unit to increase the chance that a waiting
492: --worker will see a progress alert
493: FND_OAM_DSCRAM_UTILS_PKG.SIGNAL_PROGRESS_ALERT;
494:
495: -- push the changes and release the lock
496: COMMIT;
497:

Line 507: x_final_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;

503:
504: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
505: EXCEPTION
506: WHEN OTHERS THEN
507: x_final_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;
508: x_final_ret_sts := FND_API.G_RET_STS_UNEXP_ERROR;
509: fnd_oam_debug.log(6, l_ctxt, 'Unhandled Exception: (Code('||SQLCODE||'), Message("'||SQLERRM||'"))');
510: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
511: ROLLBACK;

Line 533: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_ERROR(px_final_status) THEN

529:
530: fnd_oam_debug.log(1, l_ctxt, 'Task ID('||p_task_id||') seen as failed - current bundle final status('||px_final_status||')');
531:
532: --set the final status to stopped if it's not set to error
533: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_ERROR(px_final_status) THEN
534: px_final_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED;
535: END IF;
536: l_msg := '(Task with ID('||p_task_id||') failed with Status('||p_task_return_status||'))';
537: IF ((px_return_msg IS NULL) OR

Line 534: px_final_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED;

530: fnd_oam_debug.log(1, l_ctxt, 'Task ID('||p_task_id||') seen as failed - current bundle final status('||px_final_status||')');
531:
532: --set the final status to stopped if it's not set to error
533: IF NOT FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_ERROR(px_final_status) THEN
534: px_final_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED;
535: END IF;
536: l_msg := '(Task with ID('||p_task_id||') failed with Status('||p_task_return_status||'))';
537: IF ((px_return_msg IS NULL) OR
538: ((length(px_return_msg) + length(l_msg)) < l_msg_maxlen)) THEN

Line 575: IF l_return_status NOT IN (FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED,

571: p_bundle_id,
572: l_return_status,
573: l_return_msg) THEN
574: x_return_status := l_return_status;
575: IF l_return_status NOT IN (FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED,
576: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED) THEN
577: x_return_msg := '[Bundle Start Validation Failed]:('||l_return_msg||')';
578: END IF;
579: fnd_oam_debug.log(1, l_ctxt, x_return_msg);

Line 576: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED) THEN

572: l_return_status,
573: l_return_msg) THEN
574: x_return_status := l_return_status;
575: IF l_return_status NOT IN (FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED,
576: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED) THEN
577: x_return_msg := '[Bundle Start Validation Failed]:('||l_return_msg||')';
578: END IF;
579: fnd_oam_debug.log(1, l_ctxt, x_return_msg);
580: fnd_oam_debug.log(2, l_ctxt, 'EXIT');

Line 606: COMPLETE_BUNDLE(FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED,

602: l_return_status,
603: l_return_msg) THEN
604: --we don't care why a parent is invalid, just knowing so forces us to
605: --stop our work
606: COMPLETE_BUNDLE(FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED,
607: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED,
608: l_completed_status,
609: x_return_status);
610: x_return_msg := '[Post-Assignment Parent Validation Failed]:('||l_return_msg||')';

Line 607: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED,

603: l_return_msg) THEN
604: --we don't care why a parent is invalid, just knowing so forces us to
605: --stop our work
606: COMPLETE_BUNDLE(FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_STOPPED,
607: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_STOPPED,
608: l_completed_status,
609: x_return_status);
610: x_return_msg := '[Post-Assignment Parent Validation Failed]:('||l_return_msg||')';
611: fnd_oam_debug.log(1, l_ctxt, x_return_msg);

Line 619: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSED;

615:
616: --at this point, we're assigned so we need to issue a complete before returning.
617: --this means no quick returns, so we hit the complete after the loop.
618: l_return_status := FND_API.G_RET_STS_SUCCESS;
619: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_PROCESSED;
620:
621: -- we're in, start pulling tasks and executing them.
622: <>
623: LOOP

Line 629: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY THEN

625: FND_OAM_DSCRAM_TASKS_PKG.FETCH_NEXT_TASK(TRUE,
626: l_task_id,
627: l_return_status,
628: l_return_msg);
629: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY THEN
630: --the bundle is processed when a requery of task queue is empty
631: l_return_status := FND_API.G_RET_STS_SUCCESS;
632: EXIT outer;
633: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN

Line 634: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;

630: --the bundle is processed when a requery of task queue is empty
631: l_return_status := FND_API.G_RET_STS_SUCCESS;
632: EXIT outer;
633: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
634: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;
635: x_return_msg := '[Fetch Next Task Failed]:('||l_return_msg||')';
636: fnd_oam_debug.log(6, l_ctxt, x_return_msg);
637: EXIT outer;
638: END IF;

Line 644: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL THEN

640: --execute the task
641: FND_OAM_DSCRAM_TASKS_PKG.EXECUTE_TASK(l_task_id,
642: l_return_status,
643: l_return_msg);
644: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL THEN
645: -- the task is full when all available(in-phase) child units have the max
646: -- # of workers assigned.
647: -- to handle this, loop to fetch additional tasks and try to execute those
648: fnd_oam_debug.log(1, l_ctxt, 'Exec task found the task was full, loop fetch for more tasks');

Line 655: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY THEN

651: FND_OAM_DSCRAM_TASKS_PKG.FETCH_NEXT_TASK(FALSE,
652: l_task_id,
653: l_return_status,
654: l_return_msg);
655: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY THEN
656: -- seeing an empty here doesn't mean the bundle's finished, just that
657: --the bundle is busy and we should pause before restarting the outer loop.
658: fnd_oam_debug.log(1, l_ctxt, '[Inner Fetch Empty, Waiting for a progress alert]');
659: FND_OAM_DSCRAM_UTILS_PKG.WAIT_FOR_PROGRESS_ALERT;

Line 659: FND_OAM_DSCRAM_UTILS_PKG.WAIT_FOR_PROGRESS_ALERT;

655: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_EMPTY THEN
656: -- seeing an empty here doesn't mean the bundle's finished, just that
657: --the bundle is busy and we should pause before restarting the outer loop.
658: fnd_oam_debug.log(1, l_ctxt, '[Inner Fetch Empty, Waiting for a progress alert]');
659: FND_OAM_DSCRAM_UTILS_PKG.WAIT_FOR_PROGRESS_ALERT;
660: EXIT inner;
661: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
662: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;
663: x_return_msg := '[Inner Fetch Next Task Failed]:('||l_return_msg||')';

Line 662: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;

658: fnd_oam_debug.log(1, l_ctxt, '[Inner Fetch Empty, Waiting for a progress alert]');
659: FND_OAM_DSCRAM_UTILS_PKG.WAIT_FOR_PROGRESS_ALERT;
660: EXIT inner;
661: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
662: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN;
663: x_return_msg := '[Inner Fetch Next Task Failed]:('||l_return_msg||')';
664: fnd_oam_debug.log(6, l_ctxt, x_return_msg);
665: EXIT outer;
666: END IF;

Line 672: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL THEN

668: -- try to execute this task
669: FND_OAM_DSCRAM_TASKS_PKG.EXECUTE_TASK(l_task_id,
670: l_return_status,
671: l_return_msg);
672: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL THEN
673: --continue to the next inner loop iteration for the next fetch
674: null;
675: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS AND
676: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED AND

Line 676: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED AND

672: IF l_return_status = FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL THEN
673: --continue to the next inner loop iteration for the next fetch
674: null;
675: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS AND
676: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED AND
677: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED THEN
678: HANDLE_FAILED_TASK(l_task_id,
679: l_return_status,
680: l_completed_status,

Line 677: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED THEN

673: --continue to the next inner loop iteration for the next fetch
674: null;
675: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS AND
676: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED AND
677: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED THEN
678: HANDLE_FAILED_TASK(l_task_id,
679: l_return_status,
680: l_completed_status,
681: x_return_msg);

Line 694: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED AND

690: EXIT inner;
691: END IF;
692: END LOOP inner;
693: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS AND
694: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED AND
695: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED THEN
696: HANDLE_FAILED_TASK(l_task_id,
697: l_return_status,
698: l_completed_status,

Line 695: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED THEN

691: END IF;
692: END LOOP inner;
693: ELSIF l_return_status <> FND_API.G_RET_STS_SUCCESS AND
694: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED AND
695: l_return_status <> FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED THEN
696: HANDLE_FAILED_TASK(l_task_id,
697: l_return_status,
698: l_completed_status,
699: x_return_msg);

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

708: TRUE,
709: l_return_status,
710: l_return_msg) THEN
711: --complete the bundle based on what validate found
712: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_RET_STS_TO_COMPL_STATUS(l_return_status);
713: --change stop to stopped
714: IF FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_ERROR(l_return_status) THEN
715: x_return_msg := '[End-of-Loop Validate Failed]:('||l_return_msg||')';
716: fnd_oam_debug.log(1, l_ctxt, x_return_msg);

Line 714: IF FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_ERROR(l_return_status) THEN

710: l_return_msg) THEN
711: --complete the bundle based on what validate found
712: l_completed_status := FND_OAM_DSCRAM_UTILS_PKG.CONV_RET_STS_TO_COMPL_STATUS(l_return_status);
713: --change stop to stopped
714: IF FND_OAM_DSCRAM_UTILS_PKG.STATUS_IS_ERROR(l_return_status) THEN
715: x_return_msg := '[End-of-Loop Validate Failed]:('||l_return_msg||')';
716: fnd_oam_debug.log(1, l_ctxt, x_return_msg);
717: END IF;
718: EXIT outer;

Line 733: COMPLETE_BUNDLE(FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN,

729:
730: fnd_oam_debug.log(2, l_ctxt, 'EXIT');
731: EXCEPTION
732: WHEN OTHERS THEN
733: COMPLETE_BUNDLE(FND_OAM_DSCRAM_UTILS_PKG.G_STATUS_ERROR_UNKNOWN,
734: FND_API.G_RET_STS_UNEXP_ERROR,
735: l_completed_status,
736: x_return_status);
737: x_return_msg := 'Unhandled Exception: [Code('||SQLCODE||'), Message("'||SQLERRM||'")]';

Line 790: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED,

786: px_worker_id,
787: x_return_status,
788: x_return_msg);
789: IF x_return_status IN (FND_API.G_RET_STS_SUCCESS,
790: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED,
791: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL,
792: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED) THEN
793: --override the output status to success if it's a success-like status
794: x_return_status := FND_API.G_RET_STS_SUCCESS;

Line 791: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL,

787: x_return_status,
788: x_return_msg);
789: IF x_return_status IN (FND_API.G_RET_STS_SUCCESS,
790: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED,
791: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL,
792: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED) THEN
793: --override the output status to success if it's a success-like status
794: x_return_status := FND_API.G_RET_STS_SUCCESS;
795: ELSE

Line 792: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED) THEN

788: x_return_msg);
789: IF x_return_status IN (FND_API.G_RET_STS_SUCCESS,
790: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_PROCESSED,
791: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_FULL,
792: FND_OAM_DSCRAM_UTILS_PKG.G_RET_STS_SKIPPED) THEN
793: --override the output status to success if it's a success-like status
794: x_return_status := FND_API.G_RET_STS_SUCCESS;
795: ELSE
796: --if we didn't succeed, exit early