1058: -- assume that all concurrent dup workers completed normally, unless found otherwise
1059: l_workers_completed := TRUE;
1060:
1061: Select request_id BULK COLLECT into l_sub_requests
1062: from Fnd_Concurrent_Requests R
1063: Where Parent_Request_Id = FND_GLOBAL.conc_request_id
1064: and (phase_code<>'C' or status_code<>'C');
1065:
1066: IF l_sub_requests.count>0 THEN
1344: -- assume that all concurrent dup workers completed normally, unless found otherwise
1345: l_workers_completed := TRUE;
1346:
1347: Select request_id BULK COLLECT into l_sub_requests
1348: from Fnd_Concurrent_Requests R
1349: Where Parent_Request_Id = FND_GLOBAL.conc_request_id
1350: and (phase_code<>'C' or status_code<>'C');
1351:
1352: IF l_sub_requests.count>0 THEN
2805: l('');
2806: l(' BEGIN');
2807: l(' req_id := FND_GLOBAL.CONC_REQUEST_ID;');
2808: l(' LOOP');
2809: l(' call_status := FND_CONCURRENT.GET_REQUEST_STATUS(');
2810: l(' req_id, null,null,rphase,rstatus,dphase,dstatus,message);');
2811: l(' IF dstatus = ''TERMINATING'' THEN');
2812: l(' FND_FILE.put_line(FND_FILE.log,''Aborted by User'');');
2813: l(' RAISE USER_TERMINATE;');
2920: l(' ROLLBACK to party_batch;');
2921: l(' RAISE;');
2922: l(' END;');
2923: l(' IF l_last_fetch THEN');
2924: l(' FND_CONCURRENT.AF_Commit;');
2925: l(' EXIT;');
2926: l(' END IF;');
2927: l(' FND_CONCURRENT.AF_Commit;');
2928: l(' END LOOP;');
2923: l(' IF l_last_fetch THEN');
2924: l(' FND_CONCURRENT.AF_Commit;');
2925: l(' EXIT;');
2926: l(' END IF;');
2927: l(' FND_CONCURRENT.AF_Commit;');
2928: l(' END LOOP;');
2929: l(' END;');
2930:
2931: l(' PROCEDURE sync_single_party (');
4631:
4632: l_bool BOOLEAN;
4633:
4634: BEGIN
4635: l_bool := FND_CONCURRENT.wait_for_request(p_request_id,
4636: 60, 144000, uphase, ustatus, dphase, dstatus, message);
4637:
4638: IF dphase <> 'COMPLETE' and dstatus <> 'NORMAL' THEN
4639: return 'ERROR';