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 2060: FND_CONCURRENT.AF_Commit;

2056: --End Bug:5407223---
2057:
2058: --start bug 5460390: Add commit
2059: COMMIT;
2060: FND_CONCURRENT.AF_Commit;
2061: log('Committed Records');
2062: --end bug 5460390
2063: -- Get number of workers
2064: l_num_of_workers := to_number(nvl(p_num_of_workers, '1'));

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

2154: log ('checking completion status of child programs spawned by tis program' );
2155: l_workers_completed := TRUE;
2156:
2157: -- program id is hard coded since any conc program submitted by this program is construed
2158: -- as its child in FND_CONCURRENT_REQUESTS, regardless of the TRUE/FALSE flag
2159: -- used in FND_CONCURRENT.SUBMIT_REQUEST
2160:
2161: select request_id BULK COLLECT into l_sub_requests
2162: from fnd_concurrent_requests R

Line 2159: -- used in FND_CONCURRENT.SUBMIT_REQUEST

2155: l_workers_completed := TRUE;
2156:
2157: -- program id is hard coded since any conc program submitted by this program is construed
2158: -- as its child in FND_CONCURRENT_REQUESTS, regardless of the TRUE/FALSE flag
2159: -- used in FND_CONCURRENT.SUBMIT_REQUEST
2160:
2161: select request_id BULK COLLECT into l_sub_requests
2162: from fnd_concurrent_requests R
2163: where parent_request_id = l_request_id

Line 2162: from fnd_concurrent_requests R

2158: -- as its child in FND_CONCURRENT_REQUESTS, regardless of the TRUE/FALSE flag
2159: -- used in FND_CONCURRENT.SUBMIT_REQUEST
2160:
2161: select request_id BULK COLLECT into l_sub_requests
2162: from fnd_concurrent_requests R
2163: where parent_request_id = l_request_id
2164: and concurrent_program_id = 46839
2165: and (phase_code<>'C' or status_code<>'C');
2166:

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

2487: -- set request id we want to query
2488: req_id := p_request_id ;
2489:
2490: -- call FND procedure to find status of concurrent program
2491: status := FND_CONCURRENT.GET_REQUEST_STATUS(req_id, NULL, NULL, rphase,rstatus,dphase,dstatus,message);
2492:
2493: -- Return true any time request is complete
2494: -- IF dphase = 'RUNNING' OR dphase = 'PENDING'
2495: IF dphase = 'COMPLETE'

Line 2782: from Fnd_Concurrent_Requests R

2778: l_workers_completed := TRUE;
2779:
2780: -- get request ids that did not complete
2781: Select request_id BULK COLLECT into l_sub_requests
2782: from Fnd_Concurrent_Requests R
2783: Where Parent_Request_Id = FND_GLOBAL.conc_request_id
2784: and (phase_code<>'C' or status_code<>'C');
2785:
2786: -- log these request_ids and set the return code of the parent concurrent program