DBA Data[Home] [Help]

APPS.XDP_PROC_CTL dependencies on DBMS_PIPE

Line 1576: DBMS_PIPE.PACK_MESSAGE('ACK_SDP');

1572: ErrCode := 0;
1573: ErrStr := null;
1574:
1575: begin
1576: DBMS_PIPE.PACK_MESSAGE('ACK_SDP');
1577: l_ReturnCode := DBMS_PIPE.SEND_MESSAGE(ChannelName,Timeout);
1578: END;
1579:
1580: IF l_ReturnCode <> 0 then

Line 1577: l_ReturnCode := DBMS_PIPE.SEND_MESSAGE(ChannelName,Timeout);

1573: ErrStr := null;
1574:
1575: begin
1576: DBMS_PIPE.PACK_MESSAGE('ACK_SDP');
1577: l_ReturnCode := DBMS_PIPE.SEND_MESSAGE(ChannelName,Timeout);
1578: END;
1579:
1580: IF l_ReturnCode <> 0 then
1581: RAISE e_PipeException;

Line 1626: l_ReturnCode := DBMS_PIPE.RECEIVE_MESSAGE(ChannelName,Timeout);

1622:
1623: /*
1624: * Wait till you receive a message
1625: */
1626: l_ReturnCode := DBMS_PIPE.RECEIVE_MESSAGE(ChannelName,Timeout);
1627:
1628: /*
1629: * Got timeout on RECEIVE_MESSAGE
1630: */

Line 1638: DBMS_PIPE.UNPACK_MESSAGE(Message);

1634: ELSIF l_ReturnCode <> 0 then
1635: /* Internal Error */
1636: RAISE e_InternalPipeException;
1637: ELSE
1638: DBMS_PIPE.UNPACK_MESSAGE(Message);
1639: end IF;
1640:
1641:
1642: exception

Line 2392: DBMS_PIPE.PURGE(ChannelName);

2388:
2389:
2390: /* Clean up the pipes */
2391: begin
2392: DBMS_PIPE.PURGE(ChannelName);
2393: exception
2394: when others then
2395: RAISE e_PipeOutOfSyncException;
2396: END;

Line 2400: DBMS_PIPE.PURGE(l_ReturnChannelName);

2396: END;
2397:
2398:
2399: begin
2400: DBMS_PIPE.PURGE(l_ReturnChannelName);
2401: exception
2402: when others then
2403: RAISE e_PipeOutOfSyncException;
2404: END;

Line 2408: DBMS_PIPE.PACK_MESSAGE('SYNC');

2404: END;
2405:
2406:
2407: begin
2408: DBMS_PIPE.PACK_MESSAGE('SYNC');
2409: DBMS_PIPE.PACK_MESSAGE(l_ReturnChannelName);
2410: l_ReturnCode := DBMS_PIPE.SEND_MESSAGE(ChannelName);
2411: exception
2412: when others then

Line 2409: DBMS_PIPE.PACK_MESSAGE(l_ReturnChannelName);

2405:
2406:
2407: begin
2408: DBMS_PIPE.PACK_MESSAGE('SYNC');
2409: DBMS_PIPE.PACK_MESSAGE(l_ReturnChannelName);
2410: l_ReturnCode := DBMS_PIPE.SEND_MESSAGE(ChannelName);
2411: exception
2412: when others then
2413: x_Progress := HandlePipeErrors(SQLCODE, 'PACK', 'XDP_PROC_CTL.SEND_SYNC', NULL, 'SYNC', SQLERRM);

Line 2410: l_ReturnCode := DBMS_PIPE.SEND_MESSAGE(ChannelName);

2406:
2407: begin
2408: DBMS_PIPE.PACK_MESSAGE('SYNC');
2409: DBMS_PIPE.PACK_MESSAGE(l_ReturnChannelName);
2410: l_ReturnCode := DBMS_PIPE.SEND_MESSAGE(ChannelName);
2411: exception
2412: when others then
2413: x_Progress := HandlePipeErrors(SQLCODE, 'PACK', 'XDP_PROC_CTL.SEND_SYNC', NULL, 'SYNC', SQLERRM);
2414: RAISE e_PipePackMesgException;

Line 2545: DBMS_PIPE.PURGE(ChannelName);

2541:
2542:
2543: -- Clean up the pipes
2544: begin
2545: DBMS_PIPE.PURGE(ChannelName);
2546: exception
2547: when others then
2548: RAISE e_PipeOutOfSyncException;
2549: END;

Line 2553: DBMS_PIPE.PURGE(l_ReturnChannelName);

2549: END;
2550:
2551:
2552: begin
2553: DBMS_PIPE.PURGE(l_ReturnChannelName);
2554: exception
2555: when others then
2556: RAISE e_PipeOutOfSyncException;
2557: END;

Line 2561: DBMS_PIPE.PACK_MESSAGE('SYNC');

2557: END;
2558:
2559:
2560: begin
2561: DBMS_PIPE.PACK_MESSAGE('SYNC');
2562: DBMS_PIPE.PACK_MESSAGE(l_ReturnChannelName);
2563: l_ReturnCode := DBMS_PIPE.SEND_MESSAGE(ChannelName);
2564: exception
2565: when others then

Line 2562: DBMS_PIPE.PACK_MESSAGE(l_ReturnChannelName);

2558:
2559:
2560: begin
2561: DBMS_PIPE.PACK_MESSAGE('SYNC');
2562: DBMS_PIPE.PACK_MESSAGE(l_ReturnChannelName);
2563: l_ReturnCode := DBMS_PIPE.SEND_MESSAGE(ChannelName);
2564: exception
2565: when others then
2566: x_Progress := HandlePipeErrors(SQLCODE, 'PACK', 'XDP_PROC_CTL.SEND_SYNC', NULL, 'SYNC', SQLERRM);

Line 2563: l_ReturnCode := DBMS_PIPE.SEND_MESSAGE(ChannelName);

2559:
2560: begin
2561: DBMS_PIPE.PACK_MESSAGE('SYNC');
2562: DBMS_PIPE.PACK_MESSAGE(l_ReturnChannelName);
2563: l_ReturnCode := DBMS_PIPE.SEND_MESSAGE(ChannelName);
2564: exception
2565: when others then
2566: x_Progress := HandlePipeErrors(SQLCODE, 'PACK', 'XDP_PROC_CTL.SEND_SYNC', NULL, 'SYNC', SQLERRM);
2567: RAISE e_PipePackMesgException;