[Home] [Help]
504: FROM FII_FA_NEW_EXP_HDR_IDS;
505:
506: WHILE (l_start_number <= l_max_number) LOOP
507: l_end_number:= l_start_number + g_child_process_size;
508: g_phase := 'Loop to insert into FII_FA_WORKER_JOBS: '
509: || l_start_number || ', ' || l_end_number;
510: INSERT INTO FII_FA_WORKER_JOBS (start_range, end_range, worker_number, status)
511: VALUES (l_start_number, least(l_end_number, l_max_number), 0, 'UNASSIGNED');
512: l_count := l_count + 1;
506: WHILE (l_start_number <= l_max_number) LOOP
507: l_end_number:= l_start_number + g_child_process_size;
508: g_phase := 'Loop to insert into FII_FA_WORKER_JOBS: '
509: || l_start_number || ', ' || l_end_number;
510: INSERT INTO FII_FA_WORKER_JOBS (start_range, end_range, worker_number, status)
511: VALUES (l_start_number, least(l_end_number, l_max_number), 0, 'UNASSIGNED');
512: l_count := l_count + 1;
513: l_start_number := least(l_end_number, l_max_number) + 1;
514: END LOOP;
513: l_start_number := least(l_end_number, l_max_number) + 1;
514: END LOOP;
515:
516: if g_debug_flag = 'Y' then
517: FII_UTIL.put_line('Inserted ' || l_count || ' jobs into FII_FA_WORKER_JOBS table');
518: end if;
519:
520: COMMIT;
521:
776:
777: ------------------------------------------------------
778: -- Current plan is to not use a worker table
779: ------------------------------------------------------
780: FII_UTIL.TRUNCATE_TABLE(p_table_name => 'FII_FA_WORKER_JOBS',
781: P_RETCODE => l_ret_code);
782:
783: IF (g_truncate_id) THEN
784: FII_UTIL.TRUNCATE_TABLE(p_table_name => 'FII_FA_NEW_EXP_HDR_IDS',
2356:
2357: CHECK_XLA_CONVERSION_STATUS;
2358:
2359: ----------------------------------------------------------------
2360: -- Register jobs in the table FII_FA_WORKER_JOBS for launching
2361: -- child processes - needed for both parallel and sole for incremental
2362: ----------------------------------------------------------------
2363:
2364: if (p_program_type = 'I') then
2419: l_completed_cnt,
2420: l_wip_cnt,
2421: l_failed_cnt,
2422: l_tot_cnt
2423: FROM FII_FA_WORKER_JOBS;
2424:
2425: if g_debug_flag = 'Y' then
2426: FII_UTIL.put_line('Job status - Unassigned:'||l_unassigned_cnt||
2427: ' In Process:'||l_wip_cnt||
2529: l_failed_cnt,
2530: l_wip_cnt,
2531: l_completed_cnt,
2532: l_total_cnt
2533: FROM FII_FA_WORKER_JOBS;
2534:
2535: if g_debug_flag = 'Y' then
2536: FII_UTIL.put_line('Job status - Unassigned: '||l_unassigned_cnt||
2537: ' In Process: '||l_wip_cnt||
2558: FII_UTIL.put_line('All jobs completed, no more job. Terminating');
2559: end if;
2560: EXIT;
2561: ELSIF (l_unassigned_cnt > 0) THEN
2562: UPDATE FII_FA_WORKER_JOBS
2563: SET status = 'IN PROCESS',
2564: worker_number = g_worker_num
2565: WHERE status = 'UNASSIGNED'
2566: AND rownum < 2;
2581: -- -----------------------------------
2582: IF (l_count > 0) THEN
2583: DECLARE
2584: BEGIN
2585: g_phase := 'Getting ID range from FII_FA_WORKER_JOBS table';
2586:
2587: if g_debug_flag = 'Y' then
2588: FII_UTIL.put_line(g_phase);
2589: end if;
2591: SELECT start_range,
2592: end_range
2593: INTO l_start_range,
2594: l_end_range
2595: FROM FII_FA_WORKER_JOBS
2596: WHERE worker_number = g_worker_num
2597: AND status = 'IN PROCESS';
2598:
2599: --------------------------------------------------
2621: -- process
2622: -- After completing the work, set the job status
2623: -- to complete
2624: -----------------------------------------------------
2625: g_phase:='Updating job status in FII_FA_WORKER_JOBS table';
2626: if g_debug_flag = 'Y' then
2627: FII_UTIL.put_line(g_phase);
2628: end if;
2629:
2626: if g_debug_flag = 'Y' then
2627: FII_UTIL.put_line(g_phase);
2628: end if;
2629:
2630: UPDATE FII_FA_WORKER_JOBS
2631: SET status = 'COMPLETED'
2632: WHERE status = 'IN PROCESS'
2633: AND worker_number = g_worker_num;
2634:
2640: EXCEPTION
2641: WHEN OTHERS THEN
2642: g_retcode := -1;
2643:
2644: UPDATE FII_FA_WORKER_JOBS
2645: SET status = 'FAILED'
2646: WHERE worker_number = g_worker_num
2647: AND status = 'IN PROCESS';
2648: