DBA Data[Home] [Help]

APPS.HZ_DQM_SYNC dependencies on FND_CONCURRENT

Line 228: FND_CONCURRENT.AF_Commit;

224: ad_ctx_Ddl.Sync_Index ( p_index_name );
225: IF l_last_fetch THEN
226: EXIT;
227: END IF;
228: FND_CONCURRENT.AF_Commit;
229: END LOOP;
230: CLOSE l_party_cur;
231: ELSIF (INSTRB(l_index_name,'hz_stage_party_sites_t1') > 0) THEN
232: ad_ctx_Ddl.Sync_Index ( p_index_name );

Line 255: FND_CONCURRENT.AF_Commit;

251: ad_ctx_Ddl.Sync_Index ( p_index_name );
252: IF l_last_fetch THEN
253: EXIT;
254: END IF;
255: FND_CONCURRENT.AF_Commit;
256: END LOOP;
257: CLOSE l_ps_cur;
258: ELSIF (INSTRB(l_index_name,'hz_stage_contact_t1') > 0) THEN
259: ad_ctx_Ddl.Sync_Index ( p_index_name );

Line 282: FND_CONCURRENT.AF_Commit;

278: ad_ctx_Ddl.Sync_Index ( p_index_name );
279: IF l_last_fetch THEN
280: EXIT;
281: END IF;
282: FND_CONCURRENT.AF_Commit;
283: END LOOP;
284: CLOSE l_ct_cur;
285: ELSIF (INSTRB(l_index_name,'hz_stage_cpt_t1') > 0) THEN
286: ad_ctx_Ddl.Sync_Index ( p_index_name );

Line 309: FND_CONCURRENT.AF_Commit;

305: ad_ctx_Ddl.Sync_Index ( p_index_name );
306: IF l_last_fetch THEN
307: EXIT;
308: END IF;
309: FND_CONCURRENT.AF_Commit;
310: END LOOP;
311: CLOSE l_cp_cur;
312: END IF;
313: --Call to sync index

Line 377: FND_CONCURRENT.AF_Commit;

373: ad_ctx_Ddl.Sync_Index ( p_index_name );
374: IF l_last_fetch THEN
375: EXIT;
376: END IF;
377: FND_CONCURRENT.AF_Commit;
378: END LOOP;
379: CLOSE l_party_cur;
380: ELSIF (INSTRB(l_index_name,'hz_stage_party_sites_t1') > 0) THEN
381: ad_ctx_Ddl.Sync_Index ( p_index_name );

Line 404: FND_CONCURRENT.AF_Commit;

400: ad_ctx_Ddl.Sync_Index ( p_index_name );
401: IF l_last_fetch THEN
402: EXIT;
403: END IF;
404: FND_CONCURRENT.AF_Commit;
405: END LOOP;
406: CLOSE l_ps_cur;
407: ELSIF (INSTRB(l_index_name,'hz_stage_contact_t1') > 0) THEN
408: ad_ctx_Ddl.Sync_Index ( p_index_name );

Line 431: FND_CONCURRENT.AF_Commit;

427: ad_ctx_Ddl.Sync_Index ( p_index_name );
428: IF l_last_fetch THEN
429: EXIT;
430: END IF;
431: FND_CONCURRENT.AF_Commit;
432: END LOOP;
433: CLOSE l_ct_cur;
434: ELSIF (INSTRB(l_index_name,'hz_stage_cpt_t1') > 0) THEN
435: ad_ctx_Ddl.Sync_Index ( p_index_name );

Line 458: FND_CONCURRENT.AF_Commit;

454: ad_ctx_Ddl.Sync_Index ( p_index_name );
455: IF l_last_fetch THEN
456: EXIT;
457: END IF;
458: FND_CONCURRENT.AF_Commit;
459: END LOOP;
460: CLOSE l_cp_cur;
461: END IF;
462: --Call to sync index

Line 2239: FND_CONCURRENT.AF_Commit;

2235: --End Bug:5407223---
2236:
2237: --start bug 5460390: Add commit
2238: COMMIT;
2239: FND_CONCURRENT.AF_Commit;
2240: log('Committed Records');
2241: --end bug 5460390
2242: -- Get number of workers
2243: l_num_of_workers := to_number(nvl(p_num_of_workers, '1'));

Line 2337: -- as its child in FND_CONCURRENT_REQUESTS, regardless of the TRUE/FALSE flag

2333: log ('checking completion status of child programs spawned by tis program' );
2334: l_workers_completed := TRUE;
2335:
2336: -- program id is hard coded since any conc program submitted by this program is construed
2337: -- as its child in FND_CONCURRENT_REQUESTS, regardless of the TRUE/FALSE flag
2338: -- used in FND_CONCURRENT.SUBMIT_REQUEST
2339:
2340: select request_id BULK COLLECT into l_sub_requests
2341: from fnd_concurrent_requests R

Line 2338: -- used in FND_CONCURRENT.SUBMIT_REQUEST

2334: l_workers_completed := TRUE;
2335:
2336: -- program id is hard coded since any conc program submitted by this program is construed
2337: -- as its child in FND_CONCURRENT_REQUESTS, regardless of the TRUE/FALSE flag
2338: -- used in FND_CONCURRENT.SUBMIT_REQUEST
2339:
2340: select request_id BULK COLLECT into l_sub_requests
2341: from fnd_concurrent_requests R
2342: where parent_request_id = l_request_id

Line 2341: from fnd_concurrent_requests R

2337: -- as its child in FND_CONCURRENT_REQUESTS, regardless of the TRUE/FALSE flag
2338: -- used in FND_CONCURRENT.SUBMIT_REQUEST
2339:
2340: select request_id BULK COLLECT into l_sub_requests
2341: from fnd_concurrent_requests R
2342: where parent_request_id = l_request_id
2343: and concurrent_program_id = 46839
2344: and (phase_code<>'C' or status_code<>'C');
2345:

Line 2670: status := FND_CONCURRENT.GET_REQUEST_STATUS(req_id, NULL, NULL, rphase,rstatus,dphase,dstatus,message);

2666: -- set request id we want to query
2667: req_id := p_request_id ;
2668:
2669: -- call FND procedure to find status of concurrent program
2670: status := FND_CONCURRENT.GET_REQUEST_STATUS(req_id, NULL, NULL, rphase,rstatus,dphase,dstatus,message);
2671:
2672: -- Return true any time request is complete
2673: -- IF dphase = 'RUNNING' OR dphase = 'PENDING'
2674: IF dphase = 'COMPLETE'

Line 2961: from Fnd_Concurrent_Requests R

2957: l_workers_completed := TRUE;
2958:
2959: -- get request ids that did not complete
2960: Select request_id BULK COLLECT into l_sub_requests
2961: from Fnd_Concurrent_Requests R
2962: Where Parent_Request_Id = FND_GLOBAL.conc_request_id
2963: and (phase_code<>'C' or status_code<>'C');
2964:
2965: -- log these request_ids and set the return code of the parent concurrent program