DBA Data[Home] [Help]

APPS.MSC_SCH_WB dependencies on DBMS_PIPE

Line 1563: ret := DBMS_PIPE.CREATE_PIPE

1559: x_msg_data := NULL;
1560: x_msg_count := NULL;
1561:
1562: IF p_command = 'CREATE' THEN
1563: ret := DBMS_PIPE.CREATE_PIPE
1564: (pipename => 'session-'||p_session_id,
1565: maxpipesize => 8000, --7419485
1566: private => FALSE);
1567: IF ret <> 0 THEN

Line 1574: dbms_pipe.reset_buffer; -- good to reset it to clear things

1570: END IF;
1571: x_return_status := 'E';
1572: RETURN;
1573: END IF;
1574: dbms_pipe.reset_buffer; -- good to reset it to clear things
1575: ELSIF p_command = 'REMOVE' THEN
1576: ret := dbms_pipe.remove_pipe('session-'||p_session_id);
1577: IF ret <> 0 THEN
1578: IF PG_DEBUG in ('Y', 'C') THEN

Line 1576: ret := dbms_pipe.remove_pipe('session-'||p_session_id);

1572: RETURN;
1573: END IF;
1574: dbms_pipe.reset_buffer; -- good to reset it to clear things
1575: ELSIF p_command = 'REMOVE' THEN
1576: ret := dbms_pipe.remove_pipe('session-'||p_session_id);
1577: IF ret <> 0 THEN
1578: IF PG_DEBUG in ('Y', 'C') THEN
1579: atp_debug('pipe_utility: ' || ' Unable to remove pipe ');
1580: END IF;

Line 1585: dbms_pipe.purge('session-'||p_session_id);

1581: x_return_status := 'E';
1582: RETURN;
1583: END IF;
1584: ELSIF p_command = 'PURGE' THEN
1585: dbms_pipe.purge('session-'||p_session_id);
1586:
1587: ELSIF p_command = 'OMERROR' THEN
1588: -- we need to create a new independent pipe for this
1589:

Line 1590: ret := DBMS_PIPE.CREATE_PIPE

1586:
1587: ELSIF p_command = 'OMERROR' THEN
1588: -- we need to create a new independent pipe for this
1589:
1590: ret := DBMS_PIPE.CREATE_PIPE
1591: (pipename => 'OMERROR-'||p_session_id,
1592: maxpipesize => 5000,
1593: private => FALSE);
1594: IF ret <> 0 THEN

Line 1601: dbms_pipe.reset_buffer;

1597: END IF;
1598: x_return_status := 'E';
1599: RETURN;
1600: END IF;
1601: dbms_pipe.reset_buffer;
1602: dbms_pipe.pack_message(p_message);
1603: ret := dbms_pipe.send_message('OMERROR-'||p_session_id, 0);
1604:
1605: ELSIF p_command = 'CHECK_OM' THEN

Line 1602: dbms_pipe.pack_message(p_message);

1598: x_return_status := 'E';
1599: RETURN;
1600: END IF;
1601: dbms_pipe.reset_buffer;
1602: dbms_pipe.pack_message(p_message);
1603: ret := dbms_pipe.send_message('OMERROR-'||p_session_id, 0);
1604:
1605: ELSIF p_command = 'CHECK_OM' THEN
1606: p_message := NULL;

Line 1603: ret := dbms_pipe.send_message('OMERROR-'||p_session_id, 0);

1599: RETURN;
1600: END IF;
1601: dbms_pipe.reset_buffer;
1602: dbms_pipe.pack_message(p_message);
1603: ret := dbms_pipe.send_message('OMERROR-'||p_session_id, 0);
1604:
1605: ELSIF p_command = 'CHECK_OM' THEN
1606: p_message := NULL;
1607: ret := dbms_pipe.receive_message('OMERROR-'||p_session_id, 0);

Line 1607: ret := dbms_pipe.receive_message('OMERROR-'||p_session_id, 0);

1603: ret := dbms_pipe.send_message('OMERROR-'||p_session_id, 0);
1604:
1605: ELSIF p_command = 'CHECK_OM' THEN
1606: p_message := NULL;
1607: ret := dbms_pipe.receive_message('OMERROR-'||p_session_id, 0);
1608: ret := dbms_pipe.next_item_type;
1609: dbms_pipe.unpack_message(p_message);
1610: dbms_pipe.purge('OMERROR-'||p_session_id);
1611:

Line 1608: ret := dbms_pipe.next_item_type;

1604:
1605: ELSIF p_command = 'CHECK_OM' THEN
1606: p_message := NULL;
1607: ret := dbms_pipe.receive_message('OMERROR-'||p_session_id, 0);
1608: ret := dbms_pipe.next_item_type;
1609: dbms_pipe.unpack_message(p_message);
1610: dbms_pipe.purge('OMERROR-'||p_session_id);
1611:
1612: ELSIF p_command = 'SEND' THEN

Line 1609: dbms_pipe.unpack_message(p_message);

1605: ELSIF p_command = 'CHECK_OM' THEN
1606: p_message := NULL;
1607: ret := dbms_pipe.receive_message('OMERROR-'||p_session_id, 0);
1608: ret := dbms_pipe.next_item_type;
1609: dbms_pipe.unpack_message(p_message);
1610: dbms_pipe.purge('OMERROR-'||p_session_id);
1611:
1612: ELSIF p_command = 'SEND' THEN
1613: --msc_sch_wb.atp_debug(' b4 sending mesg '||p_message);

Line 1610: dbms_pipe.purge('OMERROR-'||p_session_id);

1606: p_message := NULL;
1607: ret := dbms_pipe.receive_message('OMERROR-'||p_session_id, 0);
1608: ret := dbms_pipe.next_item_type;
1609: dbms_pipe.unpack_message(p_message);
1610: dbms_pipe.purge('OMERROR-'||p_session_id);
1611:
1612: ELSIF p_command = 'SEND' THEN
1613: --msc_sch_wb.atp_debug(' b4 sending mesg '||p_message);
1614: p_message := Nvl(p_message,fnd_date.date_to_canonical(Sysdate));

Line 1616: dbms_pipe.pack_message(p_message);

1612: ELSIF p_command = 'SEND' THEN
1613: --msc_sch_wb.atp_debug(' b4 sending mesg '||p_message);
1614: p_message := Nvl(p_message,fnd_date.date_to_canonical(Sysdate));
1615:
1616: dbms_pipe.pack_message(p_message);
1617: ret := dbms_pipe.send_message('session-'||p_session_id, 0); -- 0 implies no block
1618: IF ret <> 0 THEN
1619: IF PG_DEBUG in ('Y', 'C') THEN
1620: null;

Line 1617: ret := dbms_pipe.send_message('session-'||p_session_id, 0); -- 0 implies no block

1613: --msc_sch_wb.atp_debug(' b4 sending mesg '||p_message);
1614: p_message := Nvl(p_message,fnd_date.date_to_canonical(Sysdate));
1615:
1616: dbms_pipe.pack_message(p_message);
1617: ret := dbms_pipe.send_message('session-'||p_session_id, 0); -- 0 implies no block
1618: IF ret <> 0 THEN
1619: IF PG_DEBUG in ('Y', 'C') THEN
1620: null;
1621: -- msc_sch_wb.atp_debug('pipe_utility: ' || ' ERROR/Warning : ret code when sending message '||ret);

Line 1629: ret := dbms_pipe.receive_message('session-'||p_session_id, 0);

1625: msc_sch_wb.atp_debug('pipe_utility: ' || ' sent mesg '||p_message);
1626: END IF;
1627: ELSIF p_command = 'RECEIVE' THEN
1628: p_message := NULL;
1629: ret := dbms_pipe.receive_message('session-'||p_session_id, 0);
1630: IF ret <> 0 THEN
1631: IF PG_DEBUG in ('Y', 'C') THEN
1632: null;
1633: -- msc_sch_wb.atp_debug('pipe_utility: ' || ' ERROR/Warning : ret code when recv message '||ret);

Line 1639: ret := dbms_pipe.next_item_type;

1635: END IF;
1636:
1637: -- When 'END' is sent then it means that ATP is done
1638: p_message_count := 0;
1639: ret := dbms_pipe.next_item_type;
1640: IF ret <> 0 THEN
1641: dbms_pipe.unpack_message(p_message);
1642: p_message_count := p_message_count + 1;
1643: END IF;

Line 1641: dbms_pipe.unpack_message(p_message);

1637: -- When 'END' is sent then it means that ATP is done
1638: p_message_count := 0;
1639: ret := dbms_pipe.next_item_type;
1640: IF ret <> 0 THEN
1641: dbms_pipe.unpack_message(p_message);
1642: p_message_count := p_message_count + 1;
1643: END IF;
1644: END IF;
1645: