[Home] [Help]
232: (
233: g_process || to_char(x),
234: g_process || to_char(x)
235: ) < FND_GLOBAL.CONC_REQUEST_ID and
236: PJI_FM_SUM_EXTR.WORKER_STATUS(x, 'RUNNING')) then
237: l_count := l_count + 1;
238: end if;
239: end loop;
240:
798:
799: l_batch_count := 0;
800:
801: for x in l_from_process .. l_parallel_processes loop
802: if (not PJI_FM_SUM_EXTR.WORKER_STATUS(x, 'OKAY')) then
803: l_batch_count := l_batch_count + 1;
804: end if;
805: end loop;
806:
823:
824: -- check that all workers have stopped
825:
826: for x in l_from_process .. l_parallel_processes loop
827: PJI_FM_SUM_EXTR.WAIT_FOR_WORKER(x);
828: end loop;
829:
830: return false;
831:
858:
859: -- start extraction helpers
860:
861: for x in 2 .. l_parallel_processes loop
862: PJI_FM_SUM_EXTR.START_HELPER(x);
863: end loop;
864:
865: -- run extraction worker
866:
863: end loop;
864:
865: -- run extraction worker
866:
867: PJI_FM_SUM_EXTR.WORKER(1);
868:
869: -- sleep until process is complete
870:
871: while PROCESS_RUNNING('WAIT') loop
1466: l_parallel_processes :=
1467: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PARALLEL_PROCESSES');
1468:
1469: for x in 2 .. l_parallel_processes loop
1470: PJI_FM_SUM_EXTR.WAIT_FOR_WORKER(x);
1471: end loop;
1472:
1473: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') = 'A') then
1474: fnd_message.set_name('PJI', 'PJI_SUM_ABORT');