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_COLLECTION dependencies on DBMS_PIPE

Line 3730: lv_pipe_ret_code := DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_task_que, PIPE_TIME_OUT);

3726: END IF;
3727:
3728: -- ============= Get the Task from Task Que ==============
3729:
3730: lv_pipe_ret_code := DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_task_que, PIPE_TIME_OUT);
3731:
3732: FND_MESSAGE.SET_NAME('MSC','MSC_CL_WORKER_RCV_RET_CODE');
3733: FND_MESSAGE.SET_TOKEN('LV_TASK_NUMBER',lv_pipe_ret_code);
3734: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, FND_MESSAGE.GET);

Line 3750: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number);

3746: END IF;
3747:
3748: ELSE
3749: lv_is_waiting := true;
3750: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number);
3751:
3752: FND_MESSAGE.SET_NAME('MSC','MSC_CL_WORKER_TSK_UNPACK');
3753: FND_MESSAGE.SET_TOKEN('LV_TASK_NUM',lv_task_number);
3754: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, FND_MESSAGE.GET);

Line 3792: DBMS_PIPE.PACK_MESSAGE( -lv_task_number);

3788: FND_MESSAGE.SET_NAME('MSC','MSC_CL_EXECUTE_TSK_PROB');
3789: FND_MESSAGE.SET_TOKEN('LV_TASK_NUMBER',lv_task_number);
3790: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
3791:
3792: DBMS_PIPE.PACK_MESSAGE( -lv_task_number);
3793: IF (MSC_UTIL.G_MSC_DEBUG <> 'N' ) THEN
3794: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Sent status '||lv_task_number||' to the monitor.');
3795: END IF;
3796: ELSE

Line 3798: DBMS_PIPE.PACK_MESSAGE( lv_task_number);

3794: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Sent status '||lv_task_number||' to the monitor.');
3795: END IF;
3796: ELSE
3797:
3798: DBMS_PIPE.PACK_MESSAGE( lv_task_number);
3799:
3800: IF (MSC_UTIL.G_MSC_DEBUG <> 'N' ) THEN
3801: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Sent status '||lv_task_number||' to the monitor.');
3802: END IF;

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

3802: END IF;
3803:
3804: END IF;
3805:
3806: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
3807: RAISE EX_PIPE_SND;
3808: END IF;
3809:
3810: IF lv_task_status <> OK THEN

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

3817:
3818: IF lv_task_number = 0 THEN
3819: COMMIT;
3820:
3821: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
3822:
3823: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
3824: RAISE EX_PIPE_SND;
3825: END IF;

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

3819: COMMIT;
3820:
3821: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
3822:
3823: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
3824: RAISE EX_PIPE_SND;
3825: END IF;
3826:
3827: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_SUCCEED');

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

3839:
3840: FND_MESSAGE.SET_NAME('MSC','MSC_CL_UNKNOWN_WORKER_ERR');
3841: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
3842:
3843: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
3844:
3845: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
3846: RAISE EX_PIPE_SND;
3847: END IF;

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

3841: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
3842:
3843: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
3844:
3845: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
3846: RAISE EX_PIPE_SND;
3847: END IF;
3848:
3849: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_FAIL');

Line 3870: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);

3866: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, SQLERRM);
3867:
3868:
3869: -- send a message of 'unresolavable error' to monitor
3870: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
3871: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'Sending message :'||UNRESOVLABLE_ERROR||' to monitor.');
3872:
3873: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
3874: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');

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

3869: -- send a message of 'unresolavable error' to monitor
3870: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
3871: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'Sending message :'||UNRESOVLABLE_ERROR||' to monitor.');
3872:
3873: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
3874: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
3875: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
3876: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
3877: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'FAIL TO SEND MESSAGE!');

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

3877: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'FAIL TO SEND MESSAGE!');
3878: END IF;
3879:
3880: -- send a message of 'the worker ends its process' to monitor
3881: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
3882:
3883: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
3884: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'FAIL TO SEND MESSAGE!');
3885: END IF;

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

3879:
3880: -- send a message of 'the worker ends its process' to monitor
3881: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
3882:
3883: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
3884: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'FAIL TO SEND MESSAGE!');
3885: END IF;
3886:
3887: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'Error_Stack...' );

Line 4132: DBMS_PIPE.PURGE( v_pipe_task_que);

4128: ROLLBACK;
4129: RETURN;
4130: END IF;
4131:
4132: DBMS_PIPE.PURGE( v_pipe_task_que);
4133: DBMS_PIPE.PURGE( v_pipe_wm);
4134: DBMS_PIPE.PURGE( v_pipe_mw);
4135: DBMS_PIPE.PURGE( v_pipe_status);
4136:

Line 4133: DBMS_PIPE.PURGE( v_pipe_wm);

4129: RETURN;
4130: END IF;
4131:
4132: DBMS_PIPE.PURGE( v_pipe_task_que);
4133: DBMS_PIPE.PURGE( v_pipe_wm);
4134: DBMS_PIPE.PURGE( v_pipe_mw);
4135: DBMS_PIPE.PURGE( v_pipe_status);
4136:
4137: --- PREPLACE CHANGE START ---

Line 4134: DBMS_PIPE.PURGE( v_pipe_mw);

4130: END IF;
4131:
4132: DBMS_PIPE.PURGE( v_pipe_task_que);
4133: DBMS_PIPE.PURGE( v_pipe_wm);
4134: DBMS_PIPE.PURGE( v_pipe_mw);
4135: DBMS_PIPE.PURGE( v_pipe_status);
4136:
4137: --- PREPLACE CHANGE START ---
4138: IF (v_is_partial_refresh OR v_is_cont_refresh) THEN

Line 4135: DBMS_PIPE.PURGE( v_pipe_status);

4131:
4132: DBMS_PIPE.PURGE( v_pipe_task_que);
4133: DBMS_PIPE.PURGE( v_pipe_wm);
4134: DBMS_PIPE.PURGE( v_pipe_mw);
4135: DBMS_PIPE.PURGE( v_pipe_status);
4136:
4137: --- PREPLACE CHANGE START ---
4138: IF (v_is_partial_refresh OR v_is_cont_refresh) THEN
4139:

Line 4555: DBMS_PIPE.PACK_MESSAGE( -1);

4551: END IF;
4552:
4553: FOR lc_i IN 1..pTotalWorkerNum LOOP
4554:
4555: DBMS_PIPE.PACK_MESSAGE( -1);
4556:
4557: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
4558: RAISE EX_PIPE_SND;
4559: END IF;

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

4553: FOR lc_i IN 1..pTotalWorkerNum LOOP
4554:
4555: DBMS_PIPE.PACK_MESSAGE( -1);
4556:
4557: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
4558: RAISE EX_PIPE_SND;
4559: END IF;
4560:
4561: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');

Line 4612: DBMS_PIPE.PACK_MESSAGE( lc_i);

4608: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'ds mode= '||to_char(v_coll_prec.ds_mode));
4609:
4610: IF v_coll_prec.ds_mode = MSC_UTIL.SYS_YES THEN
4611: IF Q_PARTIAL_TASK (pINSTANCE_ID, lc_i) THEN
4612: DBMS_PIPE.PACK_MESSAGE( lc_i);
4613: lv_task_not_completed := lv_task_not_completed + 1;
4614:
4615: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending DS task number: '||lc_i||' to the queue');
4616:

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

4613: lv_task_not_completed := lv_task_not_completed + 1;
4614:
4615: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending DS task number: '||lc_i||' to the queue');
4616:
4617: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que) <> 0 THEN
4618:
4619: FND_MESSAGE.SET_NAME('MSC','MSC_CL_ERROR_SEND_TSK');
4620: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
4621: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);

Line 4634: DBMS_PIPE.PACK_MESSAGE( lc_i);

4630: /* ds_change end*/
4631: ELSE
4632:
4633: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lc_i||' to the queue');
4634: DBMS_PIPE.PACK_MESSAGE( lc_i);
4635: lv_task_not_completed := lv_task_not_completed + 1;
4636:
4637:
4638: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

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

4634: DBMS_PIPE.PACK_MESSAGE( lc_i);
4635: lv_task_not_completed := lv_task_not_completed + 1;
4636:
4637:
4638: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
4639:
4640: FND_MESSAGE.SET_NAME('MSC','MSC_CL_ERROR_SEND_TSK');
4641: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
4642: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);

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

4662:
4663: var_debug := 2;
4664: EXIT WHEN is_worker_status_valid(lvs_request_id) <> MSC_UTIL.SYS_YES;
4665:
4666: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_wm, PIPE_TIME_OUT);
4667: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Pipe Return code: '||lv_pipe_ret_code);
4668:
4669: IF lv_pipe_ret_code=0 THEN
4670:

Line 4671: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number);

4667: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Pipe Return code: '||lv_pipe_ret_code);
4668:
4669: IF lv_pipe_ret_code=0 THEN
4670:
4671: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number);
4672: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Unpacked Task Number : '||lv_task_number);
4673:
4674: if lv_task_number = TASK_ATP_RULES THEN
4675: G_TASK_ATP_RULES :=1;

Line 4716: DBMS_PIPE.PACK_MESSAGE( -lv_task_number); -- resend the task to the task que

4712:
4713: var_debug := 4;
4714: EXIT WHEN lv_task_number= UNRESOVLABLE_ERROR;
4715:
4716: DBMS_PIPE.PACK_MESSAGE( -lv_task_number); -- resend the task to the task que
4717:
4718: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Re-sending the task number: '||lv_task_number||' to the queue');
4719:
4720: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

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

4716: DBMS_PIPE.PACK_MESSAGE( -lv_task_number); -- resend the task to the task que
4717:
4718: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Re-sending the task number: '||lv_task_number||' to the queue');
4719:
4720: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
4721: RAISE EX_PIPE_SND;
4722: END IF;
4723:
4724: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Task number: '||lv_task_number||' re-sent to the pipe queue');

Line 4766: DBMS_PIPE.PURGE( v_pipe_task_que);

4762: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '----------------------------------------------------');
4763:
4764: IF lv_task_not_completed > 0 THEN
4765:
4766: DBMS_PIPE.PURGE( v_pipe_task_que);
4767:
4768: lv_task_number:= -1;
4769:
4770: ROLLBACK;

Line 4827: DBMS_PIPE.PACK_MESSAGE( lv_task_number);

4823: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');
4824: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
4825: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
4826:
4827: DBMS_PIPE.PACK_MESSAGE( lv_task_number);
4828:
4829: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_number||' to the worker '||lc_i);
4830: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
4831: RAISE EX_PIPE_SND;

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

4826:
4827: DBMS_PIPE.PACK_MESSAGE( lv_task_number);
4828:
4829: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_number||' to the worker '||lc_i);
4830: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
4831: RAISE EX_PIPE_SND;
4832: END IF;
4833:
4834: END LOOP;

Line 4842: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_status, PIPE_TIME_OUT);

4838: lv_start_time:= SYSDATE;
4839:
4840: LOOP
4841:
4842: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_status, PIPE_TIME_OUT);
4843:
4844: IF lv_pipe_ret_code=0 THEN
4845:
4846: lv_worker_committed:= lv_worker_committed+1;

Line 5410: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);

5406: BEGIN
5407:
5408: INITIALIZE_LOAD_GLOBALS( pINSTANCE_ID);
5409:
5410: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
5411:
5412: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
5413: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
5414: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);

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

5408: INITIALIZE_LOAD_GLOBALS( pINSTANCE_ID);
5409:
5410: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
5411:
5412: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
5413: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
5414: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
5415: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
5416: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'DELETER:FAIL TO SEND MESSAGE!');

Line 6375: DBMS_PIPE.PACK_MESSAGE( -1);

6371: END IF;
6372:
6373: FOR lc_i IN 1..pTotalWorkerNum LOOP
6374:
6375: DBMS_PIPE.PACK_MESSAGE( -1);
6376:
6377: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
6378: RAISE EX_PIPE_SND;
6379: END IF;

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

6373: FOR lc_i IN 1..pTotalWorkerNum LOOP
6374:
6375: DBMS_PIPE.PACK_MESSAGE( -1);
6376:
6377: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
6378: RAISE EX_PIPE_SND;
6379: END IF;
6380:
6381: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');

Line 6449: DBMS_PIPE.PACK_MESSAGE( lc_i);

6445:
6446: IF (MSC_UTIL.G_MSC_DEBUG <> 'N' ) THEN
6447: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'PIPE to the ODS LOAD - Task Number ' || TO_CHAR(lc_i));
6448: END IF;
6449: DBMS_PIPE.PACK_MESSAGE( lc_i);
6450: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lc_i||' to the queue');
6451:
6452: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
6453:

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

6448: END IF;
6449: DBMS_PIPE.PACK_MESSAGE( lc_i);
6450: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lc_i||' to the queue');
6451:
6452: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
6453:
6454: FND_MESSAGE.SET_NAME('MSC','MSC_CL_ERROR_SEND_TSK');
6455: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
6456: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);

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

6479:
6480: var_debug := 3;
6481: EXIT WHEN is_worker_status_valid(lvs_request_id) <> MSC_UTIL.SYS_YES;
6482:
6483: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_wm, PIPE_TIME_OUT);
6484: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Pipe Return code: '||lv_pipe_ret_code);
6485:
6486: IF lv_pipe_ret_code=0 THEN
6487:

Line 6488: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number);

6484: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Pipe Return code: '||lv_pipe_ret_code);
6485:
6486: IF lv_pipe_ret_code=0 THEN
6487:
6488: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number);
6489: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Unpacked Task Number : '||lv_task_number);
6490:
6491: if lv_task_number = PTASK_ATP_RULES THEN
6492: G_TASK_ATP_RULES :=1;

Line 6560: DBMS_PIPE.PACK_MESSAGE( -lv_task_number);

6556:
6557: var_debug := 5;
6558: EXIT WHEN lv_task_number= UNRESOVLABLE_ERROR;
6559:
6560: DBMS_PIPE.PACK_MESSAGE( -lv_task_number);
6561: -- resend the task to the task queue
6562:
6563: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Re-sending the task number: '||-lv_task_number||' to the queue');
6564:

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

6561: -- resend the task to the task queue
6562:
6563: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Re-sending the task number: '||-lv_task_number||' to the queue');
6564:
6565: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
6566: RAISE EX_PIPE_SND;
6567: END IF;
6568:
6569: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Task number: '||-lv_task_number||' re-sent to the pipe queue');

Line 6617: DBMS_PIPE.PURGE( v_pipe_task_que);

6613:
6614:
6615: IF lv_task_not_completed > 0 THEN
6616:
6617: DBMS_PIPE.PURGE( v_pipe_task_que);
6618:
6619: lv_task_number:= -1;
6620:
6621: ROLLBACK;

Line 6692: DBMS_PIPE.PACK_MESSAGE( lv_task_number);

6688: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');
6689: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
6690: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
6691:
6692: DBMS_PIPE.PACK_MESSAGE( lv_task_number);
6693:
6694: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_number||' to the worker '||lc_i);
6695: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
6696: RAISE EX_PIPE_SND;

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

6691:
6692: DBMS_PIPE.PACK_MESSAGE( lv_task_number);
6693:
6694: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_number||' to the worker '||lc_i);
6695: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
6696: RAISE EX_PIPE_SND;
6697: END IF;
6698:
6699: END LOOP;

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

6704:
6705: -- Monitor the worker exits.
6706: LOOP
6707:
6708: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_status,
6709: PIPE_TIME_OUT);
6710:
6711: IF lv_pipe_ret_code=0 THEN
6712: