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 1514: lv_ret_code := DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_task_que, PIPE_TIME_OUT);

1510: END IF;
1511:
1512: -- Get the Task Number ----------------------
1513:
1514: lv_ret_code := DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_task_que, PIPE_TIME_OUT);
1515:
1516: --agmcont
1517: if (lv_toset_prec_flag) then
1518: lv_toset_prec_flag := FALSE;

Line 1597: DBMS_PIPE.UNPACK_MESSAGE( lv_task_num);

1593:
1594:
1595: ELSE
1596: lv_is_waiting := true;
1597: DBMS_PIPE.UNPACK_MESSAGE( lv_task_num);
1598:
1599: FND_MESSAGE.SET_NAME('MSC','MSC_CL_WORKER_TSK_UNPACK');
1600: FND_MESSAGE.SET_TOKEN('LV_TASK_NUM',lv_task_num);
1601: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, FND_MESSAGE.GET);

Line 1698: DBMS_PIPE.PACK_MESSAGE( -lv_task_num);

1694: FND_MESSAGE.SET_NAME('MSC','MSC_CL_EXECUTE_TSK_PROB');
1695: FND_MESSAGE.SET_TOKEN('LV_TASK_NUMBER',lv_task_num);
1696: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
1697:
1698: DBMS_PIPE.PACK_MESSAGE( -lv_task_num);
1699:
1700: ELSE
1701:
1702: DBMS_PIPE.PACK_MESSAGE( lv_task_num);

Line 1702: DBMS_PIPE.PACK_MESSAGE( lv_task_num);

1698: DBMS_PIPE.PACK_MESSAGE( -lv_task_num);
1699:
1700: ELSE
1701:
1702: DBMS_PIPE.PACK_MESSAGE( lv_task_num);
1703: COMMIT;
1704:
1705: END IF;
1706:

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

1703: COMMIT;
1704:
1705: END IF;
1706:
1707: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN RAISE EX_PIPE_SND;
1708: END IF;
1709:
1710: IF lv_task_status <> OK THEN DBMS_LOCK.SLEEP(5);
1711: END IF;

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

1716:
1717: IF lv_task_num = 0 THEN -- NO TASK IS LEFT
1718: COMMIT;
1719:
1720: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
1721:
1722: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
1723: RAISE EX_PIPE_SND;
1724: END IF;

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

1718: COMMIT;
1719:
1720: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
1721:
1722: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
1723: RAISE EX_PIPE_SND;
1724: END IF;
1725:
1726: FND_MESSAGE.SET_NAME('MSC', 'MSC_DP_SUCCEED');

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

1774: ROLLBACK;
1775:
1776: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'There is an Unknown error in the Worker.');
1777:
1778: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
1779:
1780: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
1781: RAISE EX_PIPE_SND;
1782: END IF;

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

1776: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'There is an Unknown error in the Worker.');
1777:
1778: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
1779:
1780: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
1781: RAISE EX_PIPE_SND;
1782: END IF;
1783:
1784: FND_MESSAGE.SET_NAME('MSC', 'MSC_DP_FAIL');

Line 1806: DBMS_PIPE.PACK_MESSAGE( UNRESOLVABLE_ERROR);

1802: RETCODE := MSC_UTIL.G_ERROR;
1803:
1804: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, SQLERRM);
1805:
1806: DBMS_PIPE.PACK_MESSAGE( UNRESOLVABLE_ERROR);
1807:
1808: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
1809:
1810: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');

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

1804: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, SQLERRM);
1805:
1806: DBMS_PIPE.PACK_MESSAGE( UNRESOLVABLE_ERROR);
1807:
1808: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
1809:
1810: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
1811: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
1812: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);

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

1812: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
1813:
1814: END IF;
1815:
1816: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
1817:
1818: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
1819: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
1820: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_status);

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

1814: END IF;
1815:
1816: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
1817:
1818: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
1819: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
1820: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_status);
1821: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
1822: END IF;

Line 2557: DBMS_PIPE.PURGE( v_pipe_task_que);

2553:
2554: INITIALIZE_PULL_GLOBALS( pINSTANCE_ID); -- Initializes Level 2 Global Variables used in Data Pull
2555:
2556:
2557: DBMS_PIPE.PURGE( v_pipe_task_que);
2558: DBMS_PIPE.PURGE( v_pipe_wm);
2559: DBMS_PIPE.PURGE( v_pipe_mw);
2560: DBMS_PIPE.PURGE( v_pipe_status);
2561:

Line 2558: DBMS_PIPE.PURGE( v_pipe_wm);

2554: INITIALIZE_PULL_GLOBALS( pINSTANCE_ID); -- Initializes Level 2 Global Variables used in Data Pull
2555:
2556:
2557: DBMS_PIPE.PURGE( v_pipe_task_que);
2558: DBMS_PIPE.PURGE( v_pipe_wm);
2559: DBMS_PIPE.PURGE( v_pipe_mw);
2560: DBMS_PIPE.PURGE( v_pipe_status);
2561:
2562:

Line 2559: DBMS_PIPE.PURGE( v_pipe_mw);

2555:
2556:
2557: DBMS_PIPE.PURGE( v_pipe_task_que);
2558: DBMS_PIPE.PURGE( v_pipe_wm);
2559: DBMS_PIPE.PURGE( v_pipe_mw);
2560: DBMS_PIPE.PURGE( v_pipe_status);
2561:
2562:
2563: -- To be called only at the first run.

Line 2560: DBMS_PIPE.PURGE( v_pipe_status);

2556:
2557: DBMS_PIPE.PURGE( v_pipe_task_que);
2558: DBMS_PIPE.PURGE( v_pipe_wm);
2559: DBMS_PIPE.PURGE( v_pipe_mw);
2560: DBMS_PIPE.PURGE( v_pipe_status);
2561:
2562:
2563: -- To be called only at the first run.
2564: IF (v_req_data is null) THEN -- for the fix 2351297

Line 2992: DBMS_PIPE.PACK_MESSAGE( -1);

2988: END IF;
2989:
2990: FOR lc_j IN 1..pTotalWorkerNum LOOP
2991:
2992: DBMS_PIPE.PACK_MESSAGE( -1);
2993:
2994: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
2995: RAISE EX_PIPE_SND;
2996: END IF;

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

2990: FOR lc_j IN 1..pTotalWorkerNum LOOP
2991:
2992: DBMS_PIPE.PACK_MESSAGE( -1);
2993:
2994: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
2995: RAISE EX_PIPE_SND;
2996: END IF;
2997:
2998: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');

Line 3056: DBMS_PIPE.PACK_MESSAGE( lc_i);

3052: IF (pRTYPE = MSC_UTIL.G_COMPLETE) AND
3053: (prec.ds_mode <> MSC_UTIL.SYS_YES ) THEN /*ds_plan: change */
3054: -- maintain old behaviour for complete collection
3055:
3056: DBMS_PIPE.PACK_MESSAGE( lc_i);
3057: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'ALL:Sending task number: '||lc_i||' to the queue');
3058:
3059: -- Only send the message if it has been packed.
3060: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

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

3056: DBMS_PIPE.PACK_MESSAGE( lc_i);
3057: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'ALL:Sending task number: '||lc_i||' to the queue');
3058:
3059: -- Only send the message if it has been packed.
3060: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
3061: FND_MESSAGE.SET_NAME('MSC','MSC_CL_ERROR_SEND_TSK');
3062: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
3063: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
3064:

Line 3081: DBMS_PIPE.PACK_MESSAGE( lc_i);

3077: -- NCPerf: Do for incremental and targeted
3078: -- Only carry out Data Pull for specific objects
3079:
3080: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Partial: PIPE to the DATA PULL - Task Number ' || TO_CHAR(lc_i));
3081: DBMS_PIPE.PACK_MESSAGE( lc_i);
3082:
3083: -- Only send the message if it has been packed.
3084: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
3085: RAISE EX_PIPE_SND;

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

3080: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Partial: PIPE to the DATA PULL - Task Number ' || TO_CHAR(lc_i));
3081: DBMS_PIPE.PACK_MESSAGE( lc_i);
3082:
3083: -- Only send the message if it has been packed.
3084: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
3085: RAISE EX_PIPE_SND;
3086: END IF;
3087: lv_task_not_completed := lv_task_not_completed + 1;
3088:

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

3112:
3113: var_debug := 2;
3114: EXIT WHEN is_worker_status_valid(lvs_request_id) <> MSC_UTIL.SYS_YES;
3115:
3116: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_wm, PIPE_TIME_OUT);
3117:
3118: IF lv_pipe_ret_code=0 THEN
3119:
3120: DBMS_PIPE.UNPACK_MESSAGE( lv_task_num);

Line 3120: DBMS_PIPE.UNPACK_MESSAGE( lv_task_num);

3116: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_wm, PIPE_TIME_OUT);
3117:
3118: IF lv_pipe_ret_code=0 THEN
3119:
3120: DBMS_PIPE.UNPACK_MESSAGE( lv_task_num);
3121: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Unpacked Task Number: '||lv_task_num);
3122:
3123: IF lv_task_num>0 THEN -- it's ok, the vlaue is the task number
3124:

Line 3143: DBMS_PIPE.PACK_MESSAGE( -lv_task_num);

3139:
3140: var_debug := 4;
3141: EXIT WHEN lv_task_num= UNRESOLVABLE_ERROR;
3142:
3143: DBMS_PIPE.PACK_MESSAGE( -lv_task_num);
3144: -- resend the task to the task que
3145: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Re-sending the task number: '||lv_task_num ||' to the queue');
3146:
3147: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

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

3143: DBMS_PIPE.PACK_MESSAGE( -lv_task_num);
3144: -- resend the task to the task que
3145: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Re-sending the task number: '||lv_task_num ||' to the queue');
3146:
3147: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
3148: RAISE EX_PIPE_SND;
3149: END IF;
3150:
3151: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Task number: '||lv_task_num||' re-sent to the pipe queue');

Line 3197: DBMS_PIPE.PURGE( v_pipe_task_que);

3193: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '----------------------------------------------------');
3194:
3195: IF lv_task_not_completed > 0 THEN
3196:
3197: DBMS_PIPE.PURGE( v_pipe_task_que);
3198:
3199: FND_MESSAGE.SET_NAME('MSC', 'MSC_DP_FAIL');
3200: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
3201: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, SQLERRM);

Line 3254: DBMS_PIPE.PACK_MESSAGE( lv_task_num);

3250: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');
3251: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
3252: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
3253:
3254: DBMS_PIPE.PACK_MESSAGE( lv_task_num);
3255:
3256: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_num|| ' to the worker '||lc_i);
3257:
3258: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

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

3254: DBMS_PIPE.PACK_MESSAGE( lv_task_num);
3255:
3256: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_num|| ' to the worker '||lc_i);
3257:
3258: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
3259: RAISE EX_PIPE_SND;
3260: END IF;
3261:
3262: END LOOP; -- lc_i

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

3282: lv_start_time:= SYSDATE;
3283:
3284: LOOP
3285:
3286: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_status,
3287: PIPE_TIME_OUT);
3288:
3289: IF lv_pipe_ret_code=0 THEN
3290:

Line 3359: DBMS_PIPE.PACK_MESSAGE( lv_task_num);

3355: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');
3356: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
3357: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
3358:
3359: DBMS_PIPE.PACK_MESSAGE( lv_task_num);
3360:
3361: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_num|| ' to the worker '||lc_i);
3362:
3363: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

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

3359: DBMS_PIPE.PACK_MESSAGE( lv_task_num);
3360:
3361: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_num|| ' to the worker '||lc_i);
3362:
3363: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
3364: RAISE EX_PIPE_SND;
3365: END IF;
3366:
3367: END LOOP; -- lc_i

Line 3412: DBMS_PIPE.PURGE( v_pipe_task_que);

3408: WHEN EX_PROCESS_TIME_OUT THEN
3409:
3410: ROLLBACK;
3411:
3412: DBMS_PIPE.PURGE( v_pipe_task_que);
3413:
3414: IF lv_check_point= 2 THEN
3415: IF SET_ST_STATUS( lv_errbuf, lv_retcode,
3416: pINSTANCE_ID, MSC_UTIL.G_ST_EMPTY) THEN

Line 3799: DBMS_PIPE.PACK_MESSAGE( UNRESOLVABLE_ERROR);

3795: INITIALIZE_PULL_GLOBALS( pINSTANCE_ID); -- Initializes Level 2 Global Variables used in Data Pull
3796:
3797: RETCODE := MSC_UTIL.G_SUCCESS;
3798:
3799: DBMS_PIPE.PACK_MESSAGE( UNRESOLVABLE_ERROR);
3800:
3801: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
3802:
3803: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');

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

3797: RETCODE := MSC_UTIL.G_SUCCESS;
3798:
3799: DBMS_PIPE.PACK_MESSAGE( UNRESOLVABLE_ERROR);
3800:
3801: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
3802:
3803: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
3804: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
3805: ERRBUF:= FND_MESSAGE.GET;