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

3129: END IF;
3130:
3131: -- ============= Get the Task from Task Que ==============
3132:
3133: lv_pipe_ret_code := DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_task_que, PIPE_TIME_OUT);
3134:
3135: FND_MESSAGE.SET_NAME('MSC','MSC_CL_WORKER_RCV_RET_CODE');
3136: FND_MESSAGE.SET_TOKEN('LV_TASK_NUMBER',lv_pipe_ret_code);
3137: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, FND_MESSAGE.GET);

Line 3153: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number);

3149: END IF;
3150:
3151: ELSE
3152: lv_is_waiting := true;
3153: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number);
3154:
3155: FND_MESSAGE.SET_NAME('MSC','MSC_CL_WORKER_TSK_UNPACK');
3156: FND_MESSAGE.SET_TOKEN('LV_TASK_NUM',lv_task_number);
3157: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, FND_MESSAGE.GET);

Line 3195: DBMS_PIPE.PACK_MESSAGE( -lv_task_number);

3191: FND_MESSAGE.SET_NAME('MSC','MSC_CL_EXECUTE_TSK_PROB');
3192: FND_MESSAGE.SET_TOKEN('LV_TASK_NUMBER',lv_task_number);
3193: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
3194:
3195: DBMS_PIPE.PACK_MESSAGE( -lv_task_number);
3196: IF (MSC_UTIL.G_MSC_DEBUG <> 'N' ) THEN
3197: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Sent status '||lv_task_number||' to the monitor.');
3198: END IF;
3199: ELSE

Line 3201: DBMS_PIPE.PACK_MESSAGE( lv_task_number);

3197: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Sent status '||lv_task_number||' to the monitor.');
3198: END IF;
3199: ELSE
3200:
3201: DBMS_PIPE.PACK_MESSAGE( lv_task_number);
3202:
3203: IF (MSC_UTIL.G_MSC_DEBUG <> 'N' ) THEN
3204: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Sent status '||lv_task_number||' to the monitor.');
3205: END IF;

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

3205: END IF;
3206:
3207: END IF;
3208:
3209: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
3210: RAISE EX_PIPE_SND;
3211: END IF;
3212:
3213: IF lv_task_status <> OK THEN

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

3220:
3221: IF lv_task_number = 0 THEN
3222: COMMIT;
3223:
3224: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
3225:
3226: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
3227: RAISE EX_PIPE_SND;
3228: END IF;

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

3222: COMMIT;
3223:
3224: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
3225:
3226: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
3227: RAISE EX_PIPE_SND;
3228: END IF;
3229:
3230: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_SUCCEED');

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

3242:
3243: FND_MESSAGE.SET_NAME('MSC','MSC_CL_UNKNOWN_WORKER_ERR');
3244: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
3245:
3246: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
3247:
3248: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
3249: RAISE EX_PIPE_SND;
3250: END IF;

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

3244: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
3245:
3246: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
3247:
3248: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
3249: RAISE EX_PIPE_SND;
3250: END IF;
3251:
3252: FND_MESSAGE.SET_NAME('MSC', 'MSC_OL_FAIL');

Line 3273: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);

3269: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, SQLERRM);
3270:
3271:
3272: -- send a message of 'unresolavable error' to monitor
3273: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
3274: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'Sending message :'||UNRESOVLABLE_ERROR||' to monitor.');
3275:
3276: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
3277: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');

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

3272: -- send a message of 'unresolavable error' to monitor
3273: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
3274: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'Sending message :'||UNRESOVLABLE_ERROR||' to monitor.');
3275:
3276: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
3277: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
3278: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
3279: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
3280: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'FAIL TO SEND MESSAGE!');

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

3280: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'FAIL TO SEND MESSAGE!');
3281: END IF;
3282:
3283: -- send a message of 'the worker ends its process' to monitor
3284: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
3285:
3286: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
3287: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'FAIL TO SEND MESSAGE!');
3288: END IF;

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

3282:
3283: -- send a message of 'the worker ends its process' to monitor
3284: DBMS_PIPE.PACK_MESSAGE( MSC_UTIL.SYS_YES);
3285:
3286: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
3287: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'FAIL TO SEND MESSAGE!');
3288: END IF;
3289:
3290: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'Error_Stack...' );

Line 3531: DBMS_PIPE.PURGE( v_pipe_task_que);

3527: ROLLBACK;
3528: RETURN;
3529: END IF;
3530:
3531: DBMS_PIPE.PURGE( v_pipe_task_que);
3532: DBMS_PIPE.PURGE( v_pipe_wm);
3533: DBMS_PIPE.PURGE( v_pipe_mw);
3534: DBMS_PIPE.PURGE( v_pipe_status);
3535:

Line 3532: DBMS_PIPE.PURGE( v_pipe_wm);

3528: RETURN;
3529: END IF;
3530:
3531: DBMS_PIPE.PURGE( v_pipe_task_que);
3532: DBMS_PIPE.PURGE( v_pipe_wm);
3533: DBMS_PIPE.PURGE( v_pipe_mw);
3534: DBMS_PIPE.PURGE( v_pipe_status);
3535:
3536: --- PREPLACE CHANGE START ---

Line 3533: DBMS_PIPE.PURGE( v_pipe_mw);

3529: END IF;
3530:
3531: DBMS_PIPE.PURGE( v_pipe_task_que);
3532: DBMS_PIPE.PURGE( v_pipe_wm);
3533: DBMS_PIPE.PURGE( v_pipe_mw);
3534: DBMS_PIPE.PURGE( v_pipe_status);
3535:
3536: --- PREPLACE CHANGE START ---
3537: IF (v_is_partial_refresh OR v_is_cont_refresh) THEN

Line 3534: DBMS_PIPE.PURGE( v_pipe_status);

3530:
3531: DBMS_PIPE.PURGE( v_pipe_task_que);
3532: DBMS_PIPE.PURGE( v_pipe_wm);
3533: DBMS_PIPE.PURGE( v_pipe_mw);
3534: DBMS_PIPE.PURGE( v_pipe_status);
3535:
3536: --- PREPLACE CHANGE START ---
3537: IF (v_is_partial_refresh OR v_is_cont_refresh) THEN
3538:

Line 3936: DBMS_PIPE.PACK_MESSAGE( -1);

3932: END IF;
3933:
3934: FOR lc_i IN 1..pTotalWorkerNum LOOP
3935:
3936: DBMS_PIPE.PACK_MESSAGE( -1);
3937:
3938: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
3939: RAISE EX_PIPE_SND;
3940: END IF;

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

3934: FOR lc_i IN 1..pTotalWorkerNum LOOP
3935:
3936: DBMS_PIPE.PACK_MESSAGE( -1);
3937:
3938: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
3939: RAISE EX_PIPE_SND;
3940: END IF;
3941:
3942: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');

Line 3993: DBMS_PIPE.PACK_MESSAGE( lc_i);

3989: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'ds mode= '||to_char(v_coll_prec.ds_mode));
3990:
3991: IF v_coll_prec.ds_mode = MSC_UTIL.SYS_YES THEN
3992: IF Q_PARTIAL_TASK (pINSTANCE_ID, lc_i) THEN
3993: DBMS_PIPE.PACK_MESSAGE( lc_i);
3994: lv_task_not_completed := lv_task_not_completed + 1;
3995:
3996: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending DS task number: '||lc_i||' to the queue');
3997:

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

3994: lv_task_not_completed := lv_task_not_completed + 1;
3995:
3996: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending DS task number: '||lc_i||' to the queue');
3997:
3998: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que) <> 0 THEN
3999:
4000: FND_MESSAGE.SET_NAME('MSC','MSC_CL_ERROR_SEND_TSK');
4001: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
4002: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);

Line 4015: DBMS_PIPE.PACK_MESSAGE( lc_i);

4011: /* ds_change end*/
4012: ELSE
4013:
4014: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lc_i||' to the queue');
4015: DBMS_PIPE.PACK_MESSAGE( lc_i);
4016: lv_task_not_completed := lv_task_not_completed + 1;
4017:
4018:
4019: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

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

4015: DBMS_PIPE.PACK_MESSAGE( lc_i);
4016: lv_task_not_completed := lv_task_not_completed + 1;
4017:
4018:
4019: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
4020:
4021: FND_MESSAGE.SET_NAME('MSC','MSC_CL_ERROR_SEND_TSK');
4022: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
4023: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);

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

4042:
4043: var_debug := 2;
4044: EXIT WHEN is_worker_status_valid(lvs_request_id) <> MSC_UTIL.SYS_YES;
4045:
4046: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_wm, PIPE_TIME_OUT);
4047: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Pipe Return code: '||lv_pipe_ret_code);
4048:
4049: IF lv_pipe_ret_code=0 THEN
4050:

Line 4051: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number);

4047: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Pipe Return code: '||lv_pipe_ret_code);
4048:
4049: IF lv_pipe_ret_code=0 THEN
4050:
4051: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number);
4052: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Unpacked Task Number : '||lv_task_number);
4053:
4054: if lv_task_number = TASK_ATP_RULES THEN
4055: G_TASK_ATP_RULES :=1;

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

4086:
4087: var_debug := 4;
4088: EXIT WHEN lv_task_number= UNRESOVLABLE_ERROR;
4089:
4090: DBMS_PIPE.PACK_MESSAGE( -lv_task_number); -- resend the task to the task que
4091:
4092: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Re-sending the task number: '||lv_task_number||' to the queue');
4093:
4094: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

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

4090: DBMS_PIPE.PACK_MESSAGE( -lv_task_number); -- resend the task to the task que
4091:
4092: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Re-sending the task number: '||lv_task_number||' to the queue');
4093:
4094: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
4095: RAISE EX_PIPE_SND;
4096: END IF;
4097:
4098: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'Task number: '||lv_task_number||' re-sent to the pipe queue');

Line 4140: DBMS_PIPE.PURGE( v_pipe_task_que);

4136: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, '----------------------------------------------------');
4137:
4138: IF lv_task_not_completed > 0 THEN
4139:
4140: DBMS_PIPE.PURGE( v_pipe_task_que);
4141:
4142: lv_task_number:= -1;
4143:
4144: ROLLBACK;

Line 4201: DBMS_PIPE.PACK_MESSAGE( lv_task_number);

4197: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');
4198: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
4199: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
4200:
4201: DBMS_PIPE.PACK_MESSAGE( lv_task_number);
4202:
4203: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_number||' to the worker '||lc_i);
4204: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
4205: RAISE EX_PIPE_SND;

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

4200:
4201: DBMS_PIPE.PACK_MESSAGE( lv_task_number);
4202:
4203: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_number||' to the worker '||lc_i);
4204: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
4205: RAISE EX_PIPE_SND;
4206: END IF;
4207:
4208: END LOOP;

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

4212: lv_start_time:= SYSDATE;
4213:
4214: LOOP
4215:
4216: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_status, PIPE_TIME_OUT);
4217:
4218: IF lv_pipe_ret_code=0 THEN
4219:
4220: lv_worker_committed:= lv_worker_committed+1;

Line 4719: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);

4715: BEGIN
4716:
4717: INITIALIZE_LOAD_GLOBALS( pINSTANCE_ID);
4718:
4719: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
4720:
4721: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
4722: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
4723: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);

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

4717: INITIALIZE_LOAD_GLOBALS( pINSTANCE_ID);
4718:
4719: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
4720:
4721: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
4722: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
4723: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
4724: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, FND_MESSAGE.GET);
4725: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_FATAL_ERR, 'DELETER:FAIL TO SEND MESSAGE!');

Line 5593: DBMS_PIPE.PACK_MESSAGE( -1);

5589: END IF;
5590:
5591: FOR lc_i IN 1..pTotalWorkerNum LOOP
5592:
5593: DBMS_PIPE.PACK_MESSAGE( -1);
5594:
5595: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
5596: RAISE EX_PIPE_SND;
5597: END IF;

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

5591: FOR lc_i IN 1..pTotalWorkerNum LOOP
5592:
5593: DBMS_PIPE.PACK_MESSAGE( -1);
5594:
5595: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
5596: RAISE EX_PIPE_SND;
5597: END IF;
5598:
5599: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');

Line 5667: DBMS_PIPE.PACK_MESSAGE( lc_i);

5663:
5664: IF (MSC_UTIL.G_MSC_DEBUG <> 'N' ) THEN
5665: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'PIPE to the ODS LOAD - Task Number ' || TO_CHAR(lc_i));
5666: END IF;
5667: DBMS_PIPE.PACK_MESSAGE( lc_i);
5668: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lc_i||' to the queue');
5669:
5670: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
5671:

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

5666: END IF;
5667: DBMS_PIPE.PACK_MESSAGE( lc_i);
5668: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lc_i||' to the queue');
5669:
5670: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
5671:
5672: FND_MESSAGE.SET_NAME('MSC','MSC_CL_ERROR_SEND_TSK');
5673: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
5674: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);

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

5696:
5697: var_debug := 3;
5698: EXIT WHEN is_worker_status_valid(lvs_request_id) <> MSC_UTIL.SYS_YES;
5699:
5700: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_wm, PIPE_TIME_OUT);
5701: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Pipe Return code: '||lv_pipe_ret_code);
5702:
5703: IF lv_pipe_ret_code=0 THEN
5704:

Line 5705: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number);

5701: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Pipe Return code: '||lv_pipe_ret_code);
5702:
5703: IF lv_pipe_ret_code=0 THEN
5704:
5705: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number);
5706: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Unpacked Task Number : '||lv_task_number);
5707:
5708: if lv_task_number = PTASK_ATP_RULES THEN
5709: G_TASK_ATP_RULES :=1;

Line 5771: DBMS_PIPE.PACK_MESSAGE( -lv_task_number);

5767:
5768: var_debug := 5;
5769: EXIT WHEN lv_task_number= UNRESOVLABLE_ERROR;
5770:
5771: DBMS_PIPE.PACK_MESSAGE( -lv_task_number);
5772: -- resend the task to the task queue
5773:
5774: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Re-sending the task number: '||-lv_task_number||' to the queue');
5775:

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

5772: -- resend the task to the task queue
5773:
5774: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Re-sending the task number: '||-lv_task_number||' to the queue');
5775:
5776: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
5777: RAISE EX_PIPE_SND;
5778: END IF;
5779:
5780: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Task number: '||-lv_task_number||' re-sent to the pipe queue');

Line 5828: DBMS_PIPE.PURGE( v_pipe_task_que);

5824:
5825:
5826: IF lv_task_not_completed > 0 THEN
5827:
5828: DBMS_PIPE.PURGE( v_pipe_task_que);
5829:
5830: lv_task_number:= -1;
5831:
5832: ROLLBACK;

Line 5896: DBMS_PIPE.PACK_MESSAGE( lv_task_number);

5892: FND_MESSAGE.SET_NAME('MSC','MSC_CL_SEND_WOR_END');
5893: FND_MESSAGE.SET_TOKEN('LCI',lc_i);
5894: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, FND_MESSAGE.GET);
5895:
5896: DBMS_PIPE.PACK_MESSAGE( lv_task_number);
5897:
5898: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_number||' to the worker '||lc_i);
5899: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
5900: RAISE EX_PIPE_SND;

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

5895:
5896: DBMS_PIPE.PACK_MESSAGE( lv_task_number);
5897:
5898: MSC_UTIL.LOG_MSG(MSC_UTIL.G_D_DEBUG_1, 'Sending task number: '||lv_task_number||' to the worker '||lc_i);
5899: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
5900: RAISE EX_PIPE_SND;
5901: END IF;
5902:
5903: END LOOP;

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

5908:
5909: -- Monitor the worker exits.
5910: LOOP
5911:
5912: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_status,
5913: PIPE_TIME_OUT);
5914:
5915: IF lv_pipe_ret_code=0 THEN
5916: