DBA Data[Home] [Help]

APPS.WSH_CONC_UTIL_PKG dependencies on AD_PARALLEL_UPDATES_PKG

Line 101: WSH_DEBUG_SV.logmsg(l_module_name,'Calling program unit ad_parallel_updates_pkg.initialize_rowid_range',WSH_DEBUG_SV.C_PROC_LEVEL);

97:
98: l_table_owner := l_Prod_Schema;
99:
100: IF l_debug_on THEN
101: WSH_DEBUG_SV.logmsg(l_module_name,'Calling program unit ad_parallel_updates_pkg.initialize_rowid_range',WSH_DEBUG_SV.C_PROC_LEVEL);
102: END IF;
103: ad_parallel_updates_pkg.initialize_rowid_range(
104: ad_parallel_updates_pkg.ROWID_RANGE,
105: l_table_owner,

Line 103: ad_parallel_updates_pkg.initialize_rowid_range(

99:
100: IF l_debug_on THEN
101: WSH_DEBUG_SV.logmsg(l_module_name,'Calling program unit ad_parallel_updates_pkg.initialize_rowid_range',WSH_DEBUG_SV.C_PROC_LEVEL);
102: END IF;
103: ad_parallel_updates_pkg.initialize_rowid_range(
104: ad_parallel_updates_pkg.ROWID_RANGE,
105: l_table_owner,
106: l_table_name,
107: l_script_name,

Line 104: ad_parallel_updates_pkg.ROWID_RANGE,

100: IF l_debug_on THEN
101: WSH_DEBUG_SV.logmsg(l_module_name,'Calling program unit ad_parallel_updates_pkg.initialize_rowid_range',WSH_DEBUG_SV.C_PROC_LEVEL);
102: END IF;
103: ad_parallel_updates_pkg.initialize_rowid_range(
104: ad_parallel_updates_pkg.ROWID_RANGE,
105: l_table_owner,
106: l_table_name,
107: l_script_name,
108: l_worker_id,

Line 113: WSH_DEBUG_SV.logmsg(l_module_name,'Calling program unit ad_parallel_updates_pkg.get_rowid_range',WSH_DEBUG_SV.C_PROC_LEVEL);

109: l_num_workers,
110: l_batch_size, 0);
111:
112: IF l_debug_on THEN
113: WSH_DEBUG_SV.logmsg(l_module_name,'Calling program unit ad_parallel_updates_pkg.get_rowid_range',WSH_DEBUG_SV.C_PROC_LEVEL);
114: END IF;
115: ad_parallel_updates_pkg.get_rowid_range(
116: l_start_rowid,
117: l_end_rowid,

Line 115: ad_parallel_updates_pkg.get_rowid_range(

111:
112: IF l_debug_on THEN
113: WSH_DEBUG_SV.logmsg(l_module_name,'Calling program unit ad_parallel_updates_pkg.get_rowid_range',WSH_DEBUG_SV.C_PROC_LEVEL);
114: END IF;
115: ad_parallel_updates_pkg.get_rowid_range(
116: l_start_rowid,
117: l_end_rowid,
118: l_any_rows_to_process,
119: l_batch_size,

Line 189: ad_parallel_updates_pkg.processed_rowid_range(

185: END IF;
186:
187: END LOOP; -- FOR v_notupg in c_fgt_not_upg
188:
189: ad_parallel_updates_pkg.processed_rowid_range(
190: l_rows_processed,
191: l_end_rowid);
192:
193: --

Line 202: ad_parallel_updates_pkg.get_rowid_range(

198:
199: --
200: -- get new range of rowids
201: --
202: ad_parallel_updates_pkg.get_rowid_range(
203: l_start_rowid,
204: l_end_rowid,
205: l_any_rows_to_process,
206: l_batch_size,