eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.MSC_CL_PULL dependencies on DBMS_PIPE

Line 1480: lv_ret_code := DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_task_que, PIPE_TIME_OUT);

1476: END IF;
1477:
1478: -- Get the Task Number ----------------------
1479:
1480: lv_ret_code := DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_task_que, PIPE_TIME_OUT);
1481:
1482: --agmcont
1483: if (lv_toset_prec_flag) then
1484: lv_toset_prec_flag := FALSE;

Line 1559: DBMS_PIPE.UNPACK_MESSAGE( lv_task_num);

1555:
1556:
1557: ELSE
1558: lv_is_waiting := true;
1559: DBMS_PIPE.UNPACK_MESSAGE( lv_task_num);
1560:
1561: FND_MESSAGE.SET_NAME('MSC','MSC_CL_WORKER_TSK_UNPACK');
1562: FND_MESSAGE.SET_TOKEN('LV_TASK_NUM',lv_task_num);
1563: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, FND_MESSAGE.GET);

Line 1660: DBMS_PIPE.PACK_MESSAGE( -lv_task_num);

1656: FND_MESSAGE.SET_NAME('MSC','MSC_CL_EXECUTE_TSK_PROB');
1657: FND_MESSAGE.SET_TOKEN('LV_TASK_NUMBER',lv_task_num);
1658: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
1659:
1660: DBMS_PIPE.PACK_MESSAGE( -lv_task_num);
1661:
1662: ELSE
1663:
1664: DBMS_PIPE.PACK_MESSAGE( lv_task_num);

Line 1664: DBMS_PIPE.PACK_MESSAGE( lv_task_num);

1660: DBMS_PIPE.PACK_MESSAGE( -lv_task_num);
1661:
1662: ELSE
1663:
1664: DBMS_PIPE.PACK_MESSAGE( lv_task_num);
1665: COMMIT;
1666:
1667: END IF;
1668:

Line 1669: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN RAISE EX_PIPE_SND;

1665: COMMIT;
1666:
1667: END IF;
1668:
1669: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN RAISE EX_PIPE_SND;
1670: END IF;
1671:
1672: IF lv_task_status <> OK THEN DBMS_LOCK.SLEEP(5);
1673: END IF;

Line 1682: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);

1678:
1679: IF lv_task_num = 0 THEN -- NO TASK IS LEFT
1680: COMMIT;
1681:
1682: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
1683:
1684: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
1685: RAISE EX_PIPE_SND;
1686: END IF;

Line 1684: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN

1680: COMMIT;
1681:
1682: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
1683:
1684: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
1685: RAISE EX_PIPE_SND;
1686: END IF;
1687:
1688: FND_MESSAGE.SET_NAME('MSC', 'MSC_DP_SUCCEED');

Line 1740: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);

1736: ROLLBACK;
1737:
1738: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'There is an Unknown error in the Worker.');
1739:
1740: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
1741:
1742: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
1743: RAISE EX_PIPE_SND;
1744: END IF;

Line 1742: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN

1738: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'There is an Unknown error in the Worker.');
1739:
1740: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
1741:
1742: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
1743: RAISE EX_PIPE_SND;
1744: END IF;
1745:
1746: FND_MESSAGE.SET_NAME('MSC', 'MSC_DP_FAIL');

Line 1768: DBMS_PIPE.PACK_MESSAGE( UNRESOLVABLE_ERROR);

1764: RETCODE := MSC_UTIL.G_ERROR;
1765:
1766: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, SQLERRM);
1767:
1768: DBMS_PIPE.PACK_MESSAGE( UNRESOLVABLE_ERROR);
1769:
1770: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
1771:
1772: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');

Line 1770: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN

1766: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, SQLERRM);
1767:
1768: DBMS_PIPE.PACK_MESSAGE( UNRESOLVABLE_ERROR);
1769:
1770: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
1771:
1772: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
1773: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
1774: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);

Line 1778: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);

1774: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
1775:
1776: END IF;
1777:
1778: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
1779:
1780: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
1781: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
1782: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_status);

Line 1780: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN

1776: END IF;
1777:
1778: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
1779:
1780: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
1781: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
1782: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_status);
1783: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
1784: END IF;

Line 2401: DBMS_PIPE.PURGE( v_pipe_task_que);

2397:
2398: INITIALIZE_PULL_GLOBALS( pINSTANCE_ID); -- Initializes Level 2 Global Variables used in Data Pull
2399:
2400:
2401: DBMS_PIPE.PURGE( v_pipe_task_que);
2402: DBMS_PIPE.PURGE( v_pipe_wm);
2403: DBMS_PIPE.PURGE( v_pipe_mw);
2404: DBMS_PIPE.PURGE( v_pipe_status);
2405:

Line 2402: DBMS_PIPE.PURGE( v_pipe_wm);

2398: INITIALIZE_PULL_GLOBALS( pINSTANCE_ID); -- Initializes Level 2 Global Variables used in Data Pull
2399:
2400:
2401: DBMS_PIPE.PURGE( v_pipe_task_que);
2402: DBMS_PIPE.PURGE( v_pipe_wm);
2403: DBMS_PIPE.PURGE( v_pipe_mw);
2404: DBMS_PIPE.PURGE( v_pipe_status);
2405:
2406:

Line 2403: DBMS_PIPE.PURGE( v_pipe_mw);

2399:
2400:
2401: DBMS_PIPE.PURGE( v_pipe_task_que);
2402: DBMS_PIPE.PURGE( v_pipe_wm);
2403: DBMS_PIPE.PURGE( v_pipe_mw);
2404: DBMS_PIPE.PURGE( v_pipe_status);
2405:
2406:
2407: -- To be called only at the first run.

Line 2404: DBMS_PIPE.PURGE( v_pipe_status);

2400:
2401: DBMS_PIPE.PURGE( v_pipe_task_que);
2402: DBMS_PIPE.PURGE( v_pipe_wm);
2403: DBMS_PIPE.PURGE( v_pipe_mw);
2404: DBMS_PIPE.PURGE( v_pipe_status);
2405:
2406:
2407: -- To be called only at the first run.
2408: IF (v_req_data is null) THEN -- for the fix 2351297

Line 2836: DBMS_PIPE.PACK_MESSAGE( -1);

2832: END IF;
2833:
2834: FOR lc_j IN 1..pTotalWorkerNum LOOP
2835:
2836: DBMS_PIPE.PACK_MESSAGE( -1);
2837:
2838: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
2839: RAISE EX_PIPE_SND;
2840: END IF;

Line 2838: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

2834: FOR lc_j IN 1..pTotalWorkerNum LOOP
2835:
2836: DBMS_PIPE.PACK_MESSAGE( -1);
2837:
2838: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
2839: RAISE EX_PIPE_SND;
2840: END IF;
2841:
2842: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');

Line 2900: DBMS_PIPE.PACK_MESSAGE( lc_i);

2896: IF (pRTYPE = MSC_UTIL.G_COMPLETE) AND
2897: (prec.ds_mode <> MSC_UTIL.SYS_YES ) THEN /*ds_plan: change */
2898: -- maintain old behaviour for complete collection
2899:
2900: DBMS_PIPE.PACK_MESSAGE( lc_i);
2901: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'ALL:Sending task number: '||lc_i||' to the queue');
2902:
2903: -- Only send the message if it has been packed.
2904: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

Line 2904: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

2900: DBMS_PIPE.PACK_MESSAGE( lc_i);
2901: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'ALL:Sending task number: '||lc_i||' to the queue');
2902:
2903: -- Only send the message if it has been packed.
2904: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
2905: FND_MESSAGE.SET_NAME('MSC','MSC_CL_ERROR_SEND_TSK');
2906: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
2907: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
2908:

Line 2925: DBMS_PIPE.PACK_MESSAGE( lc_i);

2921: -- NCPerf: Do for incremental and targeted
2922: -- Only carry out Data Pull for specific objects
2923:
2924: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Partial: PIPE to the DATA PULL - Task Number ' || TO_CHAR(lc_i));
2925: DBMS_PIPE.PACK_MESSAGE( lc_i);
2926:
2927: -- Only send the message if it has been packed.
2928: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
2929: RAISE EX_PIPE_SND;

Line 2928: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

2924: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Partial: PIPE to the DATA PULL - Task Number ' || TO_CHAR(lc_i));
2925: DBMS_PIPE.PACK_MESSAGE( lc_i);
2926:
2927: -- Only send the message if it has been packed.
2928: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
2929: RAISE EX_PIPE_SND;
2930: END IF;
2931: lv_task_not_completed := lv_task_not_completed + 1;
2932:

Line 2960: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_wm, PIPE_TIME_OUT);

2956:
2957: var_debug := 2;
2958: EXIT WHEN is_worker_status_valid(lvs_request_id) <> MSC_UTIL.SYS_YES;
2959:
2960: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_wm, PIPE_TIME_OUT);
2961:
2962: IF lv_pipe_ret_code=0 THEN
2963:
2964: DBMS_PIPE.UNPACK_MESSAGE( lv_task_num);

Line 2964: DBMS_PIPE.UNPACK_MESSAGE( lv_task_num);

2960: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_wm, PIPE_TIME_OUT);
2961:
2962: IF lv_pipe_ret_code=0 THEN
2963:
2964: DBMS_PIPE.UNPACK_MESSAGE( lv_task_num);
2965: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Unpacked Task Number: '||lv_task_num);
2966:
2967: IF lv_task_num>0 THEN -- it's ok, the vlaue is the task number
2968:

Line 2987: DBMS_PIPE.PACK_MESSAGE( -lv_task_num);

2983:
2984: var_debug := 4;
2985: EXIT WHEN lv_task_num= UNRESOLVABLE_ERROR;
2986:
2987: DBMS_PIPE.PACK_MESSAGE( -lv_task_num);
2988: -- resend the task to the task que
2989: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Re-sending the task number: '||lv_task_num ||' to the queue');
2990:
2991: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

Line 2991: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

2987: DBMS_PIPE.PACK_MESSAGE( -lv_task_num);
2988: -- resend the task to the task que
2989: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Re-sending the task number: '||lv_task_num ||' to the queue');
2990:
2991: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
2992: RAISE EX_PIPE_SND;
2993: END IF;
2994:
2995: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Task number: '||lv_task_num||' re-sent to the pipe queue');

Line 3041: DBMS_PIPE.PURGE( v_pipe_task_que);

3037: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '----------------------------------------------------');
3038:
3039: IF lv_task_not_completed > 0 THEN
3040:
3041: DBMS_PIPE.PURGE( v_pipe_task_que);
3042:
3043: FND_MESSAGE.SET_NAME('MSC', 'MSC_DP_FAIL');
3044: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
3045: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, SQLERRM);

Line 3098: DBMS_PIPE.PACK_MESSAGE( lv_task_num);

3094: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');
3095: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
3096: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
3097:
3098: DBMS_PIPE.PACK_MESSAGE( lv_task_num);
3099:
3100: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_num|| ' to the worker '||lc_i);
3101:
3102: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

Line 3102: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

3098: DBMS_PIPE.PACK_MESSAGE( lv_task_num);
3099:
3100: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_num|| ' to the worker '||lc_i);
3101:
3102: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
3103: RAISE EX_PIPE_SND;
3104: END IF;
3105:
3106: END LOOP; -- lc_i

Line 3130: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_status,

3126: lv_start_time:= SYSDATE;
3127:
3128: LOOP
3129:
3130: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_status,
3131: PIPE_TIME_OUT);
3132:
3133: IF lv_pipe_ret_code=0 THEN
3134:

Line 3203: DBMS_PIPE.PACK_MESSAGE( lv_task_num);

3199: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');
3200: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
3201: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
3202:
3203: DBMS_PIPE.PACK_MESSAGE( lv_task_num);
3204:
3205: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_num|| ' to the worker '||lc_i);
3206:
3207: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

Line 3207: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

3203: DBMS_PIPE.PACK_MESSAGE( lv_task_num);
3204:
3205: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_num|| ' to the worker '||lc_i);
3206:
3207: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
3208: RAISE EX_PIPE_SND;
3209: END IF;
3210:
3211: END LOOP; -- lc_i

Line 3256: DBMS_PIPE.PURGE( v_pipe_task_que);

3252: WHEN EX_PROCESS_TIME_OUT THEN
3253:
3254: ROLLBACK;
3255:
3256: DBMS_PIPE.PURGE( v_pipe_task_que);
3257:
3258: IF lv_check_point= 2 THEN
3259: IF SET_ST_STATUS( lv_errbuf, lv_retcode,
3260: pINSTANCE_ID, MSC_UTIL.G_ST_EMPTY) THEN

Line 3643: DBMS_PIPE.PACK_MESSAGE( UNRESOLVABLE_ERROR);

3639: INITIALIZE_PULL_GLOBALS( pINSTANCE_ID); -- Initializes Level 2 Global Variables used in Data Pull
3640:
3641: RETCODE := MSC_UTIL.G_SUCCESS;
3642:
3643: DBMS_PIPE.PACK_MESSAGE( UNRESOLVABLE_ERROR);
3644:
3645: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
3646:
3647: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');

Line 3645: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN

3641: RETCODE := MSC_UTIL.G_SUCCESS;
3642:
3643: DBMS_PIPE.PACK_MESSAGE( UNRESOLVABLE_ERROR);
3644:
3645: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
3646:
3647: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
3648: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
3649: ERRBUF:= FND_MESSAGE.GET;