APPS.FND_OAM_DSCRAM_DIAG_PKG dependencies on DBMS_PIPE

Line 538: --could also use DBMS_PIPE.PURGE() if we didn't want to know how many stale messages there were

534: l_run_pipe VARCHAR2(60) := MAKE_RUN_PIPE_NAME(p_run_id);
535: l_run_ack_pipe VARCHAR2(60) := MAKE_RUN_ACK_PIPE_NAME(p_run_id);
536: l_retval INTEGER;
537: BEGIN
538: --could also use DBMS_PIPE.PURGE() if we didn't want to know how many stale messages there were
539: WHILE TRUE LOOP
540: l_retval := DBMS_PIPE.RECEIVE_MESSAGE(l_run_pipe,
541: 0);
542: IF l_retval = 0 THEN

Line 540: l_retval := DBMS_PIPE.RECEIVE_MESSAGE(l_run_pipe,

536: l_retval INTEGER;
537: BEGIN
538: --could also use DBMS_PIPE.PURGE() if we didn't want to know how many stale messages there were
539: WHILE TRUE LOOP
540: l_retval := DBMS_PIPE.RECEIVE_MESSAGE(l_run_pipe,
541: 0);
542: IF l_retval = 0 THEN
543: fnd_oam_debug.log(1, l_ctxt, 'Removed message from run pipe.');
544: ELSE

Line 549: l_retval := DBMS_PIPE.RECEIVE_MESSAGE(l_run_ack_pipe,

545: EXIT;
546: END IF;
547: END LOOP;
548: WHILE TRUE LOOP
549: l_retval := DBMS_PIPE.RECEIVE_MESSAGE(l_run_ack_pipe,
550: 0);
551: IF l_retval = 0 THEN
552: fnd_oam_debug.log(1, l_ctxt, 'Removed message from run ack pipe.');
553: ELSE

Line 1869: --which uses DBMS_PIPE based IPC to detect when the run is finished. This function is kept in case

1865: RETURN FALSE;
1866: END;
1867:
1868: --helper to the EXECUTE_TEST# functions to detect when a run is finished, replaced by the SYNC_ON_FINISH
1869: --which uses DBMS_PIPE based IPC to detect when the run is finished. This function is kept in case
1870: --we need a more manual check.
1871: FUNCTION RUN_IS_FINISHED(p_run_id IN NUMBER)
1872: RETURN BOOLEAN
1873: IS

Line 1927: l_retval := DBMS_PIPE.RECEIVE_MESSAGE(l_pipename,

1923: --we need to recieve done messages from the other n-1 messages
1924: l_msg_count := 0;
1925: l_target_msg_count := p_num_workers - 1;
1926: WHILE l_msg_count < l_target_msg_count LOOP
1927: l_retval := DBMS_PIPE.RECEIVE_MESSAGE(l_pipename,
1928: B_MAX_WAIT);
1929: IF l_retval <> 0 THEN
1930: fnd_oam_debug.log(6, l_ctxt, 'Failed to receive message: '||l_retval);
1931: RAISE SYNC_FAILED;

Line 1935: DBMS_PIPE.UNPACK_MESSAGE(l_msg);

1931: RAISE SYNC_FAILED;
1932: END IF;
1933:
1934: --get the message, update the overall status if a worker failed
1935: DBMS_PIPE.UNPACK_MESSAGE(l_msg);
1936: IF l_msg <> FND_API.G_TRUE THEN
1937: l_retbool := FALSE;
1938: END IF;
1939:

Line 1949: DBMS_PIPE.PACK_MESSAGE(FND_API.G_TRUE);

1945: l_retbool := l_retbool AND p_test_success;
1946: ELSE
1947: --if we didn't do the init, send our status on the pipe
1948: IF p_test_success THEN
1949: DBMS_PIPE.PACK_MESSAGE(FND_API.G_TRUE);
1950: ELSE
1951: DBMS_PIPE.PACK_MESSAGE(FND_API.G_FALSE);
1952: END IF;
1953: l_retval := DBMS_PIPE.SEND_MESSAGE(l_pipename,

Line 1951: DBMS_PIPE.PACK_MESSAGE(FND_API.G_FALSE);

1947: --if we didn't do the init, send our status on the pipe
1948: IF p_test_success THEN
1949: DBMS_PIPE.PACK_MESSAGE(FND_API.G_TRUE);
1950: ELSE
1951: DBMS_PIPE.PACK_MESSAGE(FND_API.G_FALSE);
1952: END IF;
1953: l_retval := DBMS_PIPE.SEND_MESSAGE(l_pipename,
1954: B_MAX_WAIT);
1955: IF l_retval <> 0 THEN

Line 1953: l_retval := DBMS_PIPE.SEND_MESSAGE(l_pipename,

1949: DBMS_PIPE.PACK_MESSAGE(FND_API.G_TRUE);
1950: ELSE
1951: DBMS_PIPE.PACK_MESSAGE(FND_API.G_FALSE);
1952: END IF;
1953: l_retval := DBMS_PIPE.SEND_MESSAGE(l_pipename,
1954: B_MAX_WAIT);
1955: IF l_retval <> 0 THEN
1956: fnd_oam_debug.log(6, l_ctxt, 'Failed to send message: '||l_retval);
1957: RAISE SYNC_FAILED;

Line 1962: l_retval := DBMS_PIPE.RECEIVE_MESSAGE(l_ack_pipename,

1958: END IF;
1959:
1960: --now block waiting for an ack with the final status of the test
1961: l_ack_pipename := MAKE_RUN_ACK_PIPE_NAME(p_run_id);
1962: l_retval := DBMS_PIPE.RECEIVE_MESSAGE(l_ack_pipename,
1963: B_MAX_WAIT);
1964: IF l_retval <> 0 THEN
1965: fnd_oam_debug.log(6, l_ctxt, 'Failed to receive ACK: '||l_retval);
1966: RAISE SYNC_FAILED;

Line 1968: DBMS_PIPE.UNPACK_MESSAGE(l_msg);

1964: IF l_retval <> 0 THEN
1965: fnd_oam_debug.log(6, l_ctxt, 'Failed to receive ACK: '||l_retval);
1966: RAISE SYNC_FAILED;
1967: END IF;
1968: DBMS_PIPE.UNPACK_MESSAGE(l_msg);
1969: l_retbool := (l_msg = FND_API.G_TRUE);
1970: END IF;
1971:
1972: fnd_oam_debug.log(2, l_ctxt, 'EXIT');

Line 2006: DBMS_PIPE.PACK_MESSAGE(l_msg);

2002: END IF;
2003:
2004: --send the messages
2005: WHILE k < l_num_msgs LOOP
2006: DBMS_PIPE.PACK_MESSAGE(l_msg);
2007: l_retval := DBMS_PIPE.SEND_MESSAGE(l_ack_pipename,
2008: B_MAX_WAIT);
2009: IF l_retval <> 0 THEN
2010: fnd_oam_debug.log(6, l_ctxt, 'Failed to send ack message: '||l_retval);

Line 2007: l_retval := DBMS_PIPE.SEND_MESSAGE(l_ack_pipename,

2003:
2004: --send the messages
2005: WHILE k < l_num_msgs LOOP
2006: DBMS_PIPE.PACK_MESSAGE(l_msg);
2007: l_retval := DBMS_PIPE.SEND_MESSAGE(l_ack_pipename,
2008: B_MAX_WAIT);
2009: IF l_retval <> 0 THEN
2010: fnd_oam_debug.log(6, l_ctxt, 'Failed to send ack message: '||l_retval);
2011: RAISE SYNC_FAILED;