DBA Data[Home] [Help]

APPS.WMS_CAROUSEL_INTEGRATION_PVT dependencies on DBMS_PIPE

Line 1250: DBMS_PIPE.reset_buffer;

1246: IS
1247: v_pipe_size INTEGER := 1048576; -- size of the pipe in bytes
1248: BEGIN
1249: -- pack the data
1250: DBMS_PIPE.reset_buffer;
1251: DBMS_PIPE.pack_message (NVL (p_addr, '1'));
1252: DBMS_PIPE.pack_message (NVL (p_directive, 'empty'));
1253:
1254: -- push it into the pipe

Line 1251: DBMS_PIPE.pack_message (NVL (p_addr, '1'));

1247: v_pipe_size INTEGER := 1048576; -- size of the pipe in bytes
1248: BEGIN
1249: -- pack the data
1250: DBMS_PIPE.reset_buffer;
1251: DBMS_PIPE.pack_message (NVL (p_addr, '1'));
1252: DBMS_PIPE.pack_message (NVL (p_directive, 'empty'));
1253:
1254: -- push it into the pipe
1255: IF (DBMS_PIPE.send_message (p_pipe_name, p_time_out, v_pipe_size) <> 0)

Line 1252: DBMS_PIPE.pack_message (NVL (p_directive, 'empty'));

1248: BEGIN
1249: -- pack the data
1250: DBMS_PIPE.reset_buffer;
1251: DBMS_PIPE.pack_message (NVL (p_addr, '1'));
1252: DBMS_PIPE.pack_message (NVL (p_directive, 'empty'));
1253:
1254: -- push it into the pipe
1255: IF (DBMS_PIPE.send_message (p_pipe_name, p_time_out, v_pipe_size) <> 0)
1256: THEN

Line 1255: IF (DBMS_PIPE.send_message (p_pipe_name, p_time_out, v_pipe_size) <> 0)

1251: DBMS_PIPE.pack_message (NVL (p_addr, '1'));
1252: DBMS_PIPE.pack_message (NVL (p_directive, 'empty'));
1253:
1254: -- push it into the pipe
1255: IF (DBMS_PIPE.send_message (p_pipe_name, p_time_out, v_pipe_size) <> 0)
1256: THEN
1257: RAISE send_pipe_exception;
1258: END IF;
1259: END;

Line 1559: l_message_received := DBMS_PIPE.receive_message (l_reading_pipe);

1555: );
1556: l_reading_pipe := 'OUT_' || l_reading_pipe;
1557:
1558: --Receive the message from the SGA into the local buffer of session 2
1559: l_message_received := DBMS_PIPE.receive_message (l_reading_pipe);
1560: DBMS_PIPE.unpack_message (v_addr);
1561: DBMS_PIPE.unpack_message (l_got_msg);
1562: ---4311016
1563: IF (l_debug > 0) THEN

Line 1560: DBMS_PIPE.unpack_message (v_addr);

1556: l_reading_pipe := 'OUT_' || l_reading_pipe;
1557:
1558: --Receive the message from the SGA into the local buffer of session 2
1559: l_message_received := DBMS_PIPE.receive_message (l_reading_pipe);
1560: DBMS_PIPE.unpack_message (v_addr);
1561: DBMS_PIPE.unpack_message (l_got_msg);
1562: ---4311016
1563: IF (l_debug > 0) THEN
1564: LOG ( p_device_id, 'In read_pipe_content. l_reading_pipe='

Line 1561: DBMS_PIPE.unpack_message (l_got_msg);

1557:
1558: --Receive the message from the SGA into the local buffer of session 2
1559: l_message_received := DBMS_PIPE.receive_message (l_reading_pipe);
1560: DBMS_PIPE.unpack_message (v_addr);
1561: DBMS_PIPE.unpack_message (l_got_msg);
1562: ---4311016
1563: IF (l_debug > 0) THEN
1564: LOG ( p_device_id, 'In read_pipe_content. l_reading_pipe='
1565: || l_reading_pipe