APPS.AD_PARALLEL_UPDATES_PKG dependencies on AD_PARALLEL_WORKERS

Line 823: update ad_parallel_workers

819: where update_id = l_update_id
820: and status = ASSIGNED_STATUS
821: and worker_id > X_num_workers;
822:
823: update ad_parallel_workers
824: set start_unit_id = 0,
825: end_unit_id = 0,
826: start_rowid = null,
827: start_id = null,

Line 968: from ad_parallel_workers

964: start_unit_id, end_unit_id
965: into X_res_start_rowid, X_res_end_rowid,
966: X_res_start_id, X_res_end_id,
967: X_start_unit_id, X_end_unit_id
968: from ad_parallel_workers
969: where worker_id = X_worker_id
970: and update_id = X_update_id;
971:
972: exception

Line 1009: from ad_parallel_workers

1005: -- lock_table(l_update_info.owner, l_update_info.table_name, 'EXCLUSIVE');
1006:
1007: select start_unit_id, end_unit_id
1008: into l_start_unit_id, l_end_unit_id
1009: from ad_parallel_workers
1010: where worker_id = l_worker_id
1011: and update_id = l_update_info.update_id;
1012:
1013: --

Line 1017: update ad_parallel_workers

1013: --
1014: -- set start_id to end_id+1 to handle cases where there is just one
1015: -- row per worker
1016: --
1017: update ad_parallel_workers
1018: set start_rowid = nvl(X_last_rowid, start_rowid),
1019: start_id = least(nvl(X_last_id, start_id)+1, end_id+1),
1020: rows_processed = nvl(rows_processed, 0) + nvl(X_rows_processed, 0)
1021: where worker_id = l_worker_id

Line 1093: update ad_parallel_workers

1089: debug_info('set_current_range()+');
1090:
1091: get_update_info(l_update_info);
1092:
1093: update ad_parallel_workers
1094: set start_unit_id = X_start_unit_id,
1095: end_unit_id = X_end_unit_id,
1096: start_rowid = X_start_rowid,
1097: end_rowid = X_end_rowid,

Line 1107: insert into ad_parallel_workers (

1103: --
1104: -- if no records updated, insert a new record
1105: --
1106: IF (SQL%ROWCOUNT = 0) THEN
1107: insert into ad_parallel_workers (
1108: worker_id, update_id,
1109: start_unit_id, end_unit_id,
1110: start_rowid, end_rowid,
1111: start_id, end_id

Line 1515: -- delete from ad_parallel_workers

1511: delete from ad_parallel_update_units
1512: where update_id = c_rec.update_id;
1513:
1514: --
1515: -- delete from ad_parallel_workers
1516: --
1517: delete from ad_parallel_workers
1518: where update_id = c_rec.update_id;
1519:

Line 1517: delete from ad_parallel_workers

1513:
1514: --
1515: -- delete from ad_parallel_workers
1516: --
1517: delete from ad_parallel_workers
1518: where update_id = c_rec.update_id;
1519:
1520: commit;
1521:

Line 1565: delete from ad_parallel_workers

1561: -- get lock for the update
1562: --
1563: lock_table(X_owner, X_table, 'EXCLUSIVE');
1564:
1565: delete from ad_parallel_workers
1566: where update_id = l_update_id;
1567:
1568: delete from ad_parallel_update_units
1569: where update_id = l_update_id;

Line 1634: delete from ad_parallel_workers

1630: --
1631: delete from ad_parallel_update_units
1632: where update_id = crec.update_id;
1633:
1634: delete from ad_parallel_workers
1635: where update_id = crec.update_id;
1636:
1637: --
1638: -- release the lock