[Home] [Help]
231: WHERE req1.priority_request_id =
232: -- Subquery for requests in request set
233: (SELECT req2.priority_request_id
234: FROM fnd_concurrent_requests req2
235: WHERE req2.request_id = fnd_global.conc_request_id)
236: -- Filter on previously submitted requests only
237: AND req1.request_id < fnd_global.conc_request_id);
238:
239: l_priority_count NUMBER;
233: (SELECT req2.priority_request_id
234: FROM fnd_concurrent_requests req2
235: WHERE req2.request_id = fnd_global.conc_request_id)
236: -- Filter on previously submitted requests only
237: AND req1.request_id < fnd_global.conc_request_id);
238:
239: l_priority_count NUMBER;
240: l_sleep NUMBER;
241:
477: SELECT concurrent_program_name
478: FROM fnd_concurrent_programs prg,
479: fnd_concurrent_requests req
480: WHERE prg.concurrent_program_id = req.concurrent_program_id
481: AND req.request_id = fnd_global.conc_request_id;
482: --
483: l_process_name VARCHAR2(30);
484: --
485: BEGIN
508: CLOSE c_process_name;
509: --
510: -- Initialize the record
511: --
512: g_mthd_action_array.request_id := fnd_global.conc_request_id;
513: g_mthd_action_array.debug_flag := g_debug_flag;
514: g_mthd_action_array.process_name := l_process_name;
515: --
516: INSERT into HRI_ADM_MTHD_ACTIONS
886: application => 'HRI'
887: ,program => 'HRI_MTHD_CHILD_PROCESS'
888: ,sub_request => FALSE -- Indicates that the request will not be
889: -- executed as a sub process.
890: ,argument1 => fnd_global.conc_request_id
891: ,argument2 => g_program
892: ,argument3 => g_mthd_action_id
893: ,argument4 => l_count + 1 -- worker_id
894: );
1510: -- Get the next available range for processing
1511: --
1512: UPDATE hri_adm_mthd_ranges
1513: SET status = 'PROCESSING',
1514: request_id = fnd_global.conc_request_id
1515: WHERE status = 'UNPROCESSED'
1516: AND mthd_action_id = p_mthd_action_id
1517: AND mthd_range_id =
1518: (SELECT MIN(sub.mthd_range_id)
1584: -- Mark the object range as Error
1585: --
1586: UPDATE hri_adm_mthd_ranges
1587: SET status = 'ERROR',
1588: err_thread_request_id = fnd_global.conc_request_id
1589: WHERE mthd_action_id = p_mthd_action_id
1590: --
1591: -- The records which have not been processed
1592: --
1595: -- The records which which was being processed by the thread, when the error
1596: -- was raised
1597: --
1598: (status = 'PROCESSING'
1599: AND request_id = fnd_global.conc_request_id));
1600: --
1601: dbg(sql%rowcount||' range records marked as Error');
1602: --
1603: -- Change the status action record to ERROR
1799: ,fnd_concurrent_programs prg
1800: WHERE req.concurrent_program_id = prg.concurrent_program_id
1801: AND req.program_application_id = prg.application_id
1802: AND prg.concurrent_program_name = 'HRI_MTHD_CHILD_PROCESS'
1803: AND req.request_id = fnd_global.conc_request_id;
1804:
1805: BEGIN
1806:
1807: OPEN worker_csr;