DBA Data[Home] [Help]

APPS.MSC_PHUB_PKG dependencies on DBMS_LOCK

Line 174: dbms_lock.sleep(10);

170:
171: l_start_time := SYSDATE;
172: loop
173: << begin_loop >>
174: dbms_lock.sleep(10);
175: l_pending_timeout_flag := sign( sysdate - l_start_time - l_timeout/1440.0);
176: l_call_status:= fnd_concurrent.wait_for_request(p_request_id,
177: 10, 10, l_phase, l_status, l_dev_phase, l_dev_status, l_message);
178: --msc_phub_util.log('msc_wait_for_request '||p_request_id||' complete status '||l_dev_phase||' - '||l_dev_status);

Line 193: -- dbms_lock.sleep(10);

189: exit;
190: elsif l_dev_phase='INACTIVE' THEN
191: exit when l_pending_timeout_flag= 1;
192: end if;
193: -- dbms_lock.sleep(10);
194: end loop;
195:
196: msc_phub_util.log('msc_phub_pkg.msc_wait_for_request: failed: '||p_request_id||','||
197: l_phase||','||l_status||','||l_dev_phase||','||l_dev_status||','||l_message);

Line 327: dbms_lock.sleep(10);

323: when e_partition_not_exist then exit;
324: when e_deadlock then null;
325: when others then raise;
326: end;
327: dbms_lock.sleep(10);
328: end loop;
329: end if;
330: end loop;
331:

Line 1064: dbms_lock.allocate_unique('msc_apcc_upload_s', l_lock);

1060: msc_phub_util.log('msc_phub_pkg.create_staging_partitions('||p_plan_type||','||p_include_ods||')');
1061:
1062: if (l_staging_tables.count > 0) then
1063: -- add partitions synchronuously
1064: dbms_lock.allocate_unique('msc_apcc_upload_s', l_lock);
1065: msc_phub_util.log('msc_phub_pkg.create_staging_partitions: dbms_lock.request');
1066: l_error := dbms_lock.request(l_lock);
1067: if (l_error <> 0) then
1068: msc_phub_util.log('msc_phub_pkg.create_staging_partitions: dbms_lock.request='||l_error);

Line 1065: msc_phub_util.log('msc_phub_pkg.create_staging_partitions: dbms_lock.request');

1061:
1062: if (l_staging_tables.count > 0) then
1063: -- add partitions synchronuously
1064: dbms_lock.allocate_unique('msc_apcc_upload_s', l_lock);
1065: msc_phub_util.log('msc_phub_pkg.create_staging_partitions: dbms_lock.request');
1066: l_error := dbms_lock.request(l_lock);
1067: if (l_error <> 0) then
1068: msc_phub_util.log('msc_phub_pkg.create_staging_partitions: dbms_lock.request='||l_error);
1069: raise e_create_staging_partitions;

Line 1066: l_error := dbms_lock.request(l_lock);

1062: if (l_staging_tables.count > 0) then
1063: -- add partitions synchronuously
1064: dbms_lock.allocate_unique('msc_apcc_upload_s', l_lock);
1065: msc_phub_util.log('msc_phub_pkg.create_staging_partitions: dbms_lock.request');
1066: l_error := dbms_lock.request(l_lock);
1067: if (l_error <> 0) then
1068: msc_phub_util.log('msc_phub_pkg.create_staging_partitions: dbms_lock.request='||l_error);
1069: raise e_create_staging_partitions;
1070: end if;

Line 1068: msc_phub_util.log('msc_phub_pkg.create_staging_partitions: dbms_lock.request='||l_error);

1064: dbms_lock.allocate_unique('msc_apcc_upload_s', l_lock);
1065: msc_phub_util.log('msc_phub_pkg.create_staging_partitions: dbms_lock.request');
1066: l_error := dbms_lock.request(l_lock);
1067: if (l_error <> 0) then
1068: msc_phub_util.log('msc_phub_pkg.create_staging_partitions: dbms_lock.request='||l_error);
1069: raise e_create_staging_partitions;
1070: end if;
1071:
1072: select msc_apcc_upload_s.nextval into l_transfer_id from dual;

Line 1074: l_error := dbms_lock.release(l_lock);

1070: end if;
1071:
1072: select msc_apcc_upload_s.nextval into l_transfer_id from dual;
1073: manage_partitions(l_staging_tables, l_transfer_id, partition_add, partition_range);
1074: l_error := dbms_lock.release(l_lock);
1075: end if;
1076: return l_transfer_id;
1077:
1078: exception

Line 1081: l_error := dbms_lock.release(l_lock);

1077:
1078: exception
1079: when others then
1080: msc_phub_util.log('msc_phub_pkg.create_staging_partitions.exception: '||sqlerrm);
1081: l_error := dbms_lock.release(l_lock);
1082: msc_phub_util.log('msc_phub_pkg.create_staging_partitions.exception: dbms_lock.release='||l_error);
1083: rollback;
1084: raise;
1085: end create_staging_partitions;

Line 1082: msc_phub_util.log('msc_phub_pkg.create_staging_partitions.exception: dbms_lock.release='||l_error);

1078: exception
1079: when others then
1080: msc_phub_util.log('msc_phub_pkg.create_staging_partitions.exception: '||sqlerrm);
1081: l_error := dbms_lock.release(l_lock);
1082: msc_phub_util.log('msc_phub_pkg.create_staging_partitions.exception: dbms_lock.release='||l_error);
1083: rollback;
1084: raise;
1085: end create_staging_partitions;
1086:

Line 1114: dbms_lock.allocate_unique('msc_plan_runs_s', l_lock);

1110: end if;
1111:
1112: if (l_fact_tables.count > 0) then
1113: -- create fact partitions synchronuously
1114: dbms_lock.allocate_unique('msc_plan_runs_s', l_lock);
1115: msc_phub_util.log('msc_phub_pkg.create_fact_partitions: dbms_lock.request');
1116: l_error := dbms_lock.request(l_lock);
1117: if (l_error <> 0) then
1118: msc_phub_util.log('msc_phub_pkg.create_fact_partitions: dbms_lock.request='||l_error);

Line 1115: msc_phub_util.log('msc_phub_pkg.create_fact_partitions: dbms_lock.request');

1111:
1112: if (l_fact_tables.count > 0) then
1113: -- create fact partitions synchronuously
1114: dbms_lock.allocate_unique('msc_plan_runs_s', l_lock);
1115: msc_phub_util.log('msc_phub_pkg.create_fact_partitions: dbms_lock.request');
1116: l_error := dbms_lock.request(l_lock);
1117: if (l_error <> 0) then
1118: msc_phub_util.log('msc_phub_pkg.create_fact_partitions: dbms_lock.request='||l_error);
1119: raise e_create_fact_partitions;

Line 1116: l_error := dbms_lock.request(l_lock);

1112: if (l_fact_tables.count > 0) then
1113: -- create fact partitions synchronuously
1114: dbms_lock.allocate_unique('msc_plan_runs_s', l_lock);
1115: msc_phub_util.log('msc_phub_pkg.create_fact_partitions: dbms_lock.request');
1116: l_error := dbms_lock.request(l_lock);
1117: if (l_error <> 0) then
1118: msc_phub_util.log('msc_phub_pkg.create_fact_partitions: dbms_lock.request='||l_error);
1119: raise e_create_fact_partitions;
1120: end if;

Line 1118: msc_phub_util.log('msc_phub_pkg.create_fact_partitions: dbms_lock.request='||l_error);

1114: dbms_lock.allocate_unique('msc_plan_runs_s', l_lock);
1115: msc_phub_util.log('msc_phub_pkg.create_fact_partitions: dbms_lock.request');
1116: l_error := dbms_lock.request(l_lock);
1117: if (l_error <> 0) then
1118: msc_phub_util.log('msc_phub_pkg.create_fact_partitions: dbms_lock.request='||l_error);
1119: raise e_create_fact_partitions;
1120: end if;
1121:
1122: select msc_plan_runs_s.nextval into l_plan_run_id from dual;

Line 1124: l_error := dbms_lock.release(l_lock);

1120: end if;
1121:
1122: select msc_plan_runs_s.nextval into l_plan_run_id from dual;
1123: manage_partitions(l_fact_tables, l_plan_run_id, partition_add, partition_range);
1124: l_error := dbms_lock.release(l_lock);
1125: end if;
1126: return l_plan_run_id;
1127:
1128: exception

Line 1130: l_error := dbms_lock.release(l_lock);

1126: return l_plan_run_id;
1127:
1128: exception
1129: when others then
1130: l_error := dbms_lock.release(l_lock);
1131: msc_phub_util.log('msc_phub_pkg.create_fact_partitions.exception: dbms_lock.release='||l_error);
1132: raise;
1133: end create_fact_partitions;
1134:

Line 1131: msc_phub_util.log('msc_phub_pkg.create_fact_partitions.exception: dbms_lock.release='||l_error);

1127:
1128: exception
1129: when others then
1130: l_error := dbms_lock.release(l_lock);
1131: msc_phub_util.log('msc_phub_pkg.create_fact_partitions.exception: dbms_lock.release='||l_error);
1132: raise;
1133: end create_fact_partitions;
1134:
1135: function create_plan_run(