APPS.BSC_AW_UTILITY dependencies on DBMS_PIPE

Line 1242: using dbms_pipe

1238: /*
1239: handle dbms jobs for parallel loading and aggregations in 10g+
1240: we will have a global table with info on all current jobs. procedure
1241: wait on jobs will wait on jobs. jobs will communicate with the main process
1242: using dbms_pipe
1243: create job will add entries to the global table. clean job procedure will clean
1244: up the table
1245: p_process: will contain the string with the full procedure call and parameters.
1246:

Line 1399: l_status:=dbms_pipe.create_pipe(pipename=>p_pipe_name,private=>false);

1395: procedure create_pipe(p_pipe_name varchar2) is
1396: l_status number;
1397: Begin
1398: remove_pipe(p_pipe_name);
1399: l_status:=dbms_pipe.create_pipe(pipename=>p_pipe_name,private=>false);
1400: Exception when others then
1401: if sqlcode=-23322 then --naming conflict
1402: if g_debug then
1403: log_n('Pipe with same name '||p_pipe_name||' exists');

Line 1416: l_status:=dbms_pipe.receive_message(pipename=>p_pipe_name);

1412: --
1413: l_status number;
1414: l_message varchar2(2000);
1415: Begin
1416: l_status:=dbms_pipe.receive_message(pipename=>p_pipe_name);
1417: if l_status=0 then
1418: dbms_pipe.unpack_message(l_message);
1419: end if;
1420: return l_message;

Line 1418: dbms_pipe.unpack_message(l_message);

1414: l_message varchar2(2000);
1415: Begin
1416: l_status:=dbms_pipe.receive_message(pipename=>p_pipe_name);
1417: if l_status=0 then
1418: dbms_pipe.unpack_message(l_message);
1419: end if;
1420: return l_message;
1421: Exception when others then
1422: log_n('Exception in get_pipe_message '||sqlerrm);

Line 1431: dbms_pipe.reset_buffer;

1427: PRAGMA AUTONOMOUS_TRANSACTION;
1428: --
1429: l_status number;
1430: Begin
1431: dbms_pipe.reset_buffer;
1432: dbms_pipe.pack_message(p_message);
1433: l_status:=dbms_pipe.send_message(pipename=>p_pipe_name);
1434: commit;
1435: Exception when others then

Line 1432: dbms_pipe.pack_message(p_message);

1428: --
1429: l_status number;
1430: Begin
1431: dbms_pipe.reset_buffer;
1432: dbms_pipe.pack_message(p_message);
1433: l_status:=dbms_pipe.send_message(pipename=>p_pipe_name);
1434: commit;
1435: Exception when others then
1436: log_n('Exception in send_pipe_message '||sqlerrm);

Line 1433: l_status:=dbms_pipe.send_message(pipename=>p_pipe_name);

1429: l_status number;
1430: Begin
1431: dbms_pipe.reset_buffer;
1432: dbms_pipe.pack_message(p_message);
1433: l_status:=dbms_pipe.send_message(pipename=>p_pipe_name);
1434: commit;
1435: Exception when others then
1436: log_n('Exception in send_pipe_message '||sqlerrm);
1437: raise;

Line 1444: l_status:=dbms_pipe.remove_pipe(pipename=>p_pipe_name);

1440: procedure remove_pipe(p_pipe_name varchar2) is
1441: --
1442: l_status number;
1443: Begin
1444: l_status:=dbms_pipe.remove_pipe(pipename=>p_pipe_name);
1445: Exception when others then
1446: log_n('Exception in remove_pipe '||sqlerrm);
1447: End;
1448: