APPS.HRI_OPL_MULTI_THREAD dependencies on HRI_ADM_MTHD_RANGES

Line 163: select hri_adm_mthd_ranges_s.nextval

159: --
160: IF mod(p_rownum,p_chunk) = 0 OR
161: g_mthd_range_id is null THEN
162: --
163: select hri_adm_mthd_ranges_s.nextval
164: into g_mthd_range_id
165: from dual;
166: --
167: END IF;

Line 186: FROM hri_adm_mthd_ranges

182: l_error_request_id NUMBER;
183: --
184: CURSOR c_error_request IS
185: SELECT err_thread_request_id
186: FROM hri_adm_mthd_ranges
187: WHERE mthd_action_id = p_mthd_action_id
188: AND status = 'ERROR'
189: AND rownum = 1;
190: --

Line 281: FROM hri_adm_mthd_ranges

277: ,p_mthd_range_lvl_order IN NUMBER) IS
278:
279: CURSOR lower_hrchy_req_cur IS
280: SELECT count(*)
281: FROM hri_adm_mthd_ranges
282: WHERE mthd_action_id = p_mthd_action_id
283: AND status IN ('UNPROCESSED','PROCESSING')
284: AND mthd_range_lvl_order < p_mthd_range_lvl_order;
285:

Line 670: hri_adm_mthd_ranges range

666: g_mthd_action_array.hierarchical_process_type = 'TOP_DOWN') THEN
667:
668: l_dyn_range_sql :=
669: 'INSERT /*+ append parallel(range, default,default) */ INTO
670: hri_adm_mthd_ranges range
671: (mthd_range_id
672: ,mthd_range_lvl
673: ,mthd_range_lvl_order
674: ,mthd_action_id

Line 704: hri_adm_mthd_ranges range

700: g_mthd_action_array.hierarchical_process_type = 'BOTTOM_UP') THEN
701:
702: l_dyn_range_sql :=
703: 'INSERT /*+ append parallel(range, default,default) */ INTO
704: hri_adm_mthd_ranges range
705: (mthd_range_id
706: ,mthd_range_lvl
707: ,mthd_range_lvl_order
708: ,mthd_action_id

Line 736: hri_adm_mthd_ranges range

732: ELSE
733:
734: l_dyn_range_sql :=
735: 'INSERT /*+ append parallel(range, default,default) */ INTO
736: hri_adm_mthd_ranges range
737: (mthd_range_id
738: ,mthd_range_lvl
739: ,mthd_range_lvl_order
740: ,mthd_action_id

Line 833: FROM hri_adm_mthd_ranges

829: l_slave_count NUMBER;
830: --
831: CURSOR c_get_range_count IS
832: SELECT count(*)
833: FROM hri_adm_mthd_ranges
834: WHERE mthd_action_id = g_mthd_action_id;
835: --
836: BEGIN
837: dbg('Inside start_threads');

Line 1488: FROM hri_adm_mthd_ranges

1484: l_error_status NUMBER;
1485: --
1486: CURSOR c_error IS
1487: SELECT -1
1488: FROM hri_adm_mthd_ranges
1489: WHERE status = 'ERROR'
1490: AND mthd_action_id = p_mthd_action_id
1491: AND rownum = 1;
1492: --

Line 1500: UPDATE hri_adm_mthd_ranges

1496: -- by the child thread, so mark that range as PROCESSED
1497: --
1498: IF p_mthd_range_id is not null THEN
1499: --
1500: UPDATE hri_adm_mthd_ranges
1501: SET status = 'PROCESSED'
1502: WHERE status = 'PROCESSING'
1503: AND mthd_action_id = p_mthd_action_id
1504: AND mthd_range_id = p_mthd_range_id;

Line 1512: UPDATE hri_adm_mthd_ranges

1508: END IF;
1509: --
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

Line 1519: FROM hri_adm_mthd_ranges sub

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)
1519: FROM hri_adm_mthd_ranges sub
1520: WHERE sub.status = 'UNPROCESSED'
1521: AND sub.mthd_action_id = p_mthd_action_id)
1522: RETURNING
1523: mthd_range_id

Line 1586: UPDATE hri_adm_mthd_ranges

1582: dbg('Inside set_range_error');
1583: --
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: --