[Home] [Help]
1: package body FND_CONCURRENT as
2: /* $Header: AFCPUTLB.pls 120.18 2010/08/13 20:42:11 pferguso ship $ */
3: --
4: -- Package
5: -- FND_CONCURRENT
1: package body FND_CONCURRENT as
2: /* $Header: AFCPUTLB.pls 120.18 2010/08/13 20:42:11 pferguso ship $ */
3: --
4: -- Package
5: -- FND_CONCURRENT
6: -- Purpose
7: -- Concurrent processing related utilities
8: -- History
9: -- XX/XX/93 Ram Bhoopalam Created
18: PHASE_LOOKUP_TYPE constant varchar2(16) := 'CP_PHASE_CODE';
19: STATUS_LOOKUP_TYPE constant varchar2(16) := 'CP_STATUS_CODE';
20:
21: TYpe ConcProcessLocks Is Table of
22: Fnd_Concurrent_Processes.Lk_Handle%TYPE
23: Index By Binary_Integer;
24:
25: CmLkHandles ConcProcessLocks;
26:
41:
42: if ( apid = 0 AND cqid = 1 ) then
43: Select Max(Concurrent_Process_ID)
44: Into icm_cid
45: From Fnd_Concurrent_Processes
46: Where Process_Status_Code = 'A'
47: And (Queue_Application_ID = 0 And
48: Concurrent_Queue_ID = 1);
49:
74: when others then
75: oraerrmesg := substr(SQLERRM, 1, 80);
76: Fnd_Message.Set_Name('FND', 'CP-Generic oracle error');
77: Fnd_Message.Set_Token('ERROR', oraerrmesg, FALSE);
78: Fnd_Message.Set_Token('ROUTINE', 'FND_CONCURRENT.Get_Handle', FALSE);
79: return FALSE;
80: end get_handle;
81:
82: -- procedure is internal to this package.
232: end if;
233: begin
234: Select Concurrent_Program_ID, P.Application_ID
235: Into Program_ID, Prog_Appl_ID
236: From Fnd_Concurrent_Programs P,
237: Fnd_Application A
238: Where Concurrent_Program_Name = Program
239: And P.Application_ID = A.Application_ID
240: And A.Application_Short_Name = Appl_ShortName;
253: --
254: begin
255: Select Max(Request_ID)
256: Into Req_ID
257: From Fnd_Concurrent_Requests
258: Where Program_Application_ID = Prog_Appl_ID
259: And Concurrent_Program_ID = Program_ID;
260: --
261: -- If No rows returned, then return message saying there are no
287: Phase.Meaning, Status.Meaning
288: Into req_phase, req_status, comptext,
289: phase_code, status_code,
290: phasem, statusm
291: From Fnd_Concurrent_Requests R,
292: Fnd_Concurrent_programs P,
293: Fnd_Lookups Phase,
294: Fnd_Lookups Status
295: Where
288: Into req_phase, req_status, comptext,
289: phase_code, status_code,
290: phasem, statusm
291: From Fnd_Concurrent_Requests R,
292: Fnd_Concurrent_programs P,
293: Fnd_Lookups Phase,
294: Fnd_Lookups Status
295: Where
296: Phase.Lookup_Type = PHASE_LOOKUP_TYPE
322: when no_data_found then
323: Reqid_for_message := Req_ID;
324: Fnd_Message.Set_Name('FND', 'CONC-Request missing');
325: Fnd_Message.Set_Token('ROUTINE',
326: 'FND_CONCURRENT.GET_REQUEST_STATUS', FALSE);
327: Fnd_Message.Set_Token('REQUEST', Reqid_for_message, FALSE);
328: return FALSE;
329: when others then
330: raise; -- status_fetch_error
351: oraerrmesg := substr(SQLERRM, 1, 80);
352: Fnd_Message.Set_Name('FND', 'CP-Generic oracle error');
353: Fnd_Message.Set_Token('ERROR', oraerrmesg, FALSE);
354: Fnd_Message.Set_Token('ROUTINE',
355: 'FND_CONCURRENT.GET_REQUEST_STATUS', FALSE);
356: return FALSE;
357: end get_request_status;
358:
359:
409: Into STime From Sys.Dual;
410: end if;
411:
412: LOOP
413: call_status := FND_CONCURRENT.get_request_status(Rid, '', '',
414: phase, status, req_phase, dev_status, message);
415: if ( call_status = FALSE OR req_phase = 'COMPLETE' ) then
416: dev_phase := req_phase;
417: return (call_status);
435: oraerrmesg := substr(SQLERRM, 1, 80);
436: Fnd_Message.Set_Name('FND', 'CP-Generic oracle error');
437: Fnd_Message.Set_Token('ERROR', oraerrmesg, FALSE);
438: Fnd_Message.Set_Token('ROUTINE',
439: 'FND_CONCURRENT.WAIT_FOR_REQUEST', FALSE);
440: return FALSE;
441: end wait_for_request;
442:
443: --
441: end wait_for_request;
442:
443: --
444: -- Name
445: -- FND_CONCURRENT_GET_MANAGER_STATUS
446: -- Purpose
447: -- Returns the target ( number that should be active at this instant )
448: -- and active number of processes for a given manager.
449: -- along with the current PMON method currently in use
464: targetp OUT NOCOPY number,
465: activep OUT NOCOPY number,
466: pmon_method OUT NOCOPY varchar2,
467: callstat OUT NOCOPY number) is
468: lkh FND_CONCURRENT_PROCESSES.Lk_Handle%TYPE;
469: result number; -- result code from DBMS_LOCK.Request_Lock
470: alive number; -- is process alive? 1=TRUE 0=FALSE
471: i number := 0;
472: errflag boolean := FALSE;
476: cur_session_id number;
477:
478: Cursor C1 IS
479: Select Concurrent_Process_Id, Session_Id
480: From Fnd_Concurrent_Processes
481: Where Process_Status_Code in ( 'A', 'C', 'T' )
482: And (Queue_Application_ID = applid and
483: Concurrent_Queue_ID = managerid );
484: begin
491: /* from FCQ */
492: select manager_type,
493: Running_processes, MAX_PROCESSES, Cartridge_Handle
494: into mtype, ActiveP, TargetP, CartType
495: from Fnd_Concurrent_Queues Q, Fnd_Cp_Services S
496: Where S.Service_ID = Q.Manager_Type
497: And (Q.Application_ID = applid
498: And Q.Concurrent_Queue_ID = managerid);
499:
500: if (mtype>999) then
501: if (CartType = 'AQCART') then
502: select count(*)
503: into ActiveP
504: from gv$session GV, fnd_concurrent_processes P
505: where
506: GV.Inst_id = P.Instance_number
507: And GV.audsid = p.session_id
508: And (Process_Status_Code not in ('S','K','U'))
548: return;
549: end if;
550: end if;
551:
552: Select Max_Processes Into TargetP From Fnd_Concurrent_Queues
553: Where Concurrent_Queue_ID = ManagerID
554: And Application_ID = ApplID;
555:
556:
607: oraerrmesg := substr(SQLERRM, 1, 80);
608: Fnd_Message.Set_Name('FND', 'CP-Generic oracle error');
609: Fnd_Message.Set_Token('ERROR', oraerrmesg, FALSE);
610: Fnd_Message.Set_Token('ROUTINE',
611: 'FND_CONCURRENT.GET_MANAGER_STATUS', FALSE);
612: return;
613: end get_manager_status;
614:
615: -- Name
612: return;
613: end get_manager_status;
614:
615: -- Name
616: -- FND_CONCURRENT.SET_STATUS_AUTONUMOUS
617: -- Purpose
618: -- Updates given request status and completion text in an autonomous
619: -- transaction. This is function is called in set_completion_status
620: -- function. (Internal use only).
645: l_status := do_set_status_autonomous.status;
646:
647: if ( interim ) then
648: if(upper(status) = 'W') then
649: update fnd_concurrent_requests_remote
650: set interim_status_code = 'W',
651: req_information = substrb(message,1,240)
652: where request_id = l_request_id;
653: else
650: set interim_status_code = 'W',
651: req_information = substrb(message,1,240)
652: where request_id = l_request_id;
653: else
654: update fnd_concurrent_requests_remote
655: set interim_status_code = l_status,
656: completion_text = substrb(message, 1, 240)
657: where request_id = l_request_id;
658: end if;
657: where request_id = l_request_id;
658: end if;
659:
660: else
661: update fnd_concurrent_requests_remote
662: set phase_code = 'C',
663: status_code = l_status,
664: completion_text = substrb(message, 1, 240)
665: where request_id = l_request_id;
672: else
673:
674: if ( interim ) then
675: if(upper(status) = 'W') then
676: update fnd_concurrent_requests
677: set interim_status_code = 'W',
678: req_information = substrb(message,1,240)
679: where request_id = do_set_status_autonomous.request_id;
680: --debug('updated req_information for request_id '|| do_set_status_autonomous.request_id);
678: req_information = substrb(message,1,240)
679: where request_id = do_set_status_autonomous.request_id;
680: --debug('updated req_information for request_id '|| do_set_status_autonomous.request_id);
681: else
682: update fnd_concurrent_requests
683: set interim_status_code = do_set_status_autonomous.status,
684: completion_text = substrb(message, 1, 240)
685: where request_id = do_set_status_autonomous.request_id;
686: --debug('updated completion_text for request_id '|| do_set_status_autonomous.request_id);
686: --debug('updated completion_text for request_id '|| do_set_status_autonomous.request_id);
687: end if;
688:
689: else
690: update fnd_concurrent_requests
691: set phase_code = 'C',
692: status_code = do_set_status_autonomous.status,
693: completion_text = substrb(message, 1, 240)
694: where request_id = do_set_status_autonomous.request_id;
738:
739:
740: --
741: -- Name
742: -- FND_CONCURRENT.SET_COMPLETION_STATUS
743: -- Purpose
744: -- Called from a concurrent request to set its completion
745: -- status and message.
746: --
783: if ( nvl(lengthb(ret_str), 0 ) > 0 ) then
784: Fnd_Message.Set_Name('FND', 'CP-Generic oracle error');
785: Fnd_Message.Set_Token('ERROR', ret_str, FALSE);
786: Fnd_Message.Set_Token('ROUTINE',
787: 'FND_CONCURRENT.SET_COMPLETION_STATUS', FALSE);
788: return FALSE;
789: else
790: return TRUE;
791: end if;
809: save_output_flag OUT NOCOPY varchar2) return boolean is
810: begin
811: select number_of_copies, print_style, printer, save_output_flag
812: into number_of_copies, print_style, printer, save_output_flag
813: from fnd_concurrent_requests r
814: where r.request_id = get_request_print_options.request_id;
815:
816: return TRUE;
817:
820: oraerrmesg := substr(SQLERRM, 1, 80);
821: Fnd_Message.Set_Name('FND', 'CP-Generic oracle error');
822: Fnd_Message.Set_Token('ERROR', oraerrmesg, FALSE);
823: Fnd_Message.Set_Token('ROUTINE',
824: 'FND_CONCURRENT.GET_REQUEST_PRINT_OPTIONS', FALSE);
825: return FALSE;
826: end get_request_print_options;
827:
828: --
844: counter number := 0;
845: cursor c1 is
846: select p.number_of_copies, r.print_style,
847: p.arguments, r.save_output_flag
848: from fnd_concurrent_requests r,
849: fnd_conc_pp_actions p
850: where r.request_id = p.concurrent_request_id
851: and p.action_type = 1
852: and p.concurrent_request_id = get_request_print_options.request_id
866: oraerrmesg := substr(SQLERRM, 1, 80);
867: Fnd_Message.Set_Name('FND', 'CP-Generic oracle error');
868: Fnd_Message.Set_Token('ERROR', oraerrmesg, FALSE);
869: Fnd_Message.Set_Token('ROUTINE',
870: 'FND_CONCURRENT.GET_REQUEST_PRINT_OPTIONS', FALSE);
871: return counter;
872: end get_request_print_options;
873:
874: --
902: --
903: if (C_SessionID is NULL ) then
904: Select Session_ID
905: into C_SessionID
906: from fnd_concurrent_processes cp,
907: fnd_concurrent_queues cq
908: where process_status_code = 'A'
909: and cp.Queue_Application_ID = cq.application_ID
910: and cp.concurrent_queue_id = cq.concurrent_queue_id
903: if (C_SessionID is NULL ) then
904: Select Session_ID
905: into C_SessionID
906: from fnd_concurrent_processes cp,
907: fnd_concurrent_queues cq
908: where process_status_code = 'A'
909: and cp.Queue_Application_ID = cq.application_ID
910: and cp.concurrent_queue_id = cq.concurrent_queue_id
911: and cq.concurrent_queue_name = Queue_Name;
953: oraerrmesg := substr(SQLERRM, 1, 80);
954: Fnd_Message.Set_Name('FND', 'CP-Generic oracle error');
955: Fnd_Message.Set_Token('ERROR', oraerrmesg, FALSE);
956: Fnd_Message.Set_Token('ROUTINE',
957: 'FND_CONCURRENT.Check_Lock_Contention', FALSE);
958: return FALSE;
959:
960: end Check_Lock_Contention;
961:
976: ltype varchar2(8) := 'YES_NO';
977: begin
978: select PRINTER_NAME, user_printer_style_name, l.meaning
979: into printer, style, save_output
980: from fnd_concurrent_programs p, fnd_printer_styles_VL ps,
981: fnd_lookups L, fnd_application_vl A
982: where
983: l.lookup_code = p.SAVE_OUTPUT_FLAG
984: and l.lookup_type = ltype
999: oraerrmesg := substr(SQLERRM, 1, 80);
1000: Fnd_Message.Set_Name('FND', 'CP-Generic oracle error');
1001: Fnd_Message.Set_Token('ERROR', oraerrmesg, FALSE);
1002: Fnd_Message.Set_Token('ROUTINE',
1003: 'FND_CONCURRENT.GET_PROGRAM_ATTRIBUTES', FALSE);
1004: return FALSE;
1005: end get_program_attributes;
1006:
1007: --
1005: end get_program_attributes;
1006:
1007: --
1008: -- Name
1009: -- FND_CONCURRENT.SET_COMPLETION_STATUS
1010: -- Purpose
1011: -- Called from a concurrent request to set its completion
1012: -- status and message.
1013: --
1065: and s.sid = m.sid;
1066:
1067: l_request_id := fnd_global.conc_request_id;
1068:
1069: update fnd_concurrent_requests_remote
1070: set ORACLE_SESSION_ID = csid,
1071: ORACLE_PROCESS_ID = csspid,
1072: OS_PROCESS_ID = cspid,
1073: NLS_CodeSet = codeset
1084: From V$Session S, V$Process P
1085: Where P.Addr = S.Paddr
1086: and S.AUDSID = userenv('SESSIONID');
1087:
1088: update fnd_concurrent_requests
1089: set ORACLE_SESSION_ID = csid,
1090: ORACLE_PROCESS_ID = csspid,
1091: OS_PROCESS_ID = cspid,
1092: NLS_CodeSet = codeset
1105: execution_method_code,
1106: multi_org_category, org_id, p.application_id
1107: into optmode, program_name, ptrace, rtrace, etstat, emethod,
1108: morg_cat, orgid, temp
1109: from FND_CONCURRENT_PROGRAMS P,
1110: FND_CONCURRENT_REQUESTS R
1111: WHERE P.CONCURRENT_PROGRAM_ID = R.CONCURRENT_PROGRAM_ID
1112: And P.APPLICATION_ID = R.Program_APPLICATION_ID
1113: And R.request_id = fnd_global.conc_request_id;
1106: multi_org_category, org_id, p.application_id
1107: into optmode, program_name, ptrace, rtrace, etstat, emethod,
1108: morg_cat, orgid, temp
1109: from FND_CONCURRENT_PROGRAMS P,
1110: FND_CONCURRENT_REQUESTS R
1111: WHERE P.CONCURRENT_PROGRAM_ID = R.CONCURRENT_PROGRAM_ID
1112: And P.APPLICATION_ID = R.Program_APPLICATION_ID
1113: And R.request_id = fnd_global.conc_request_id;
1114: exception
1131: end if;
1132:
1133: Select plsql_log, plsql_out, plsql_dir
1134: Into plog, pout, pdir
1135: From Fnd_Concurrent_Processes P, Fnd_Concurrent_Requests R
1136: Where P.Concurrent_Process_ID = R.Controlling_Manager
1137: And R.Request_ID = fnd_global.conc_request_id;
1138:
1139: fnd_file.put_names(plog, pout, pdir);
1154: 'Concurrent Request');
1155: begin
1156: select Q.RESOURCE_CONSUMER_GROUP
1157: into que_rcg
1158: from fnd_concurrent_requests r,
1159: fnd_concurrent_processes p,
1160: fnd_concurrent_queues q
1161: where R.request_id = fnd_global.conc_request_id
1162: and R.controlling_manager = P.concurrent_process_id
1155: begin
1156: select Q.RESOURCE_CONSUMER_GROUP
1157: into que_rcg
1158: from fnd_concurrent_requests r,
1159: fnd_concurrent_processes p,
1160: fnd_concurrent_queues q
1161: where R.request_id = fnd_global.conc_request_id
1162: and R.controlling_manager = P.concurrent_process_id
1163: and Q.CONCURRENT_QUEUE_ID= P.CONCURRENT_QUEUE_ID
1156: select Q.RESOURCE_CONSUMER_GROUP
1157: into que_rcg
1158: from fnd_concurrent_requests r,
1159: fnd_concurrent_processes p,
1160: fnd_concurrent_queues q
1161: where R.request_id = fnd_global.conc_request_id
1162: and R.controlling_manager = P.concurrent_process_id
1163: and Q.CONCURRENT_QUEUE_ID= P.CONCURRENT_QUEUE_ID
1164: and Q.APPLICATION_ID = P.QUEUE_APPLICATION_ID;
1169:
1170: begin
1171: select p.RESOURCE_CONSUMER_GROUP
1172: into prg_rcg
1173: from fnd_concurrent_programs P,
1174: fnd_concurrent_requests R
1175: where R.request_id = fnd_global.conc_request_id
1176: and r.PROGRAM_APPLICATION_ID = P.APPLICATION_ID
1177: and R.CONCURRENT_PROGRAM_ID = P.CONCURRENT_PROGRAM_ID;
1170: begin
1171: select p.RESOURCE_CONSUMER_GROUP
1172: into prg_rcg
1173: from fnd_concurrent_programs P,
1174: fnd_concurrent_requests R
1175: where R.request_id = fnd_global.conc_request_id
1176: and r.PROGRAM_APPLICATION_ID = P.APPLICATION_ID
1177: and R.CONCURRENT_PROGRAM_ID = P.CONCURRENT_PROGRAM_ID;
1178: exception
1216: oraerrmesg := substr(SQLERRM, 1, 80);
1217: Fnd_Message.Set_Name('FND', 'CP-Generic oracle error');
1218: Fnd_Message.Set_Token('ERROR', oraerrmesg, FALSE);
1219: Fnd_Message.Set_Token('ROUTINE',
1220: 'FND_CONCURRENT.INIT_REQUEST', FALSE);
1221: fnd_adg_support.log_unhandled_exception('fnd_concurrent.init_request',SQLERRM);
1222: return;
1223:
1224: end init_request;
1217: Fnd_Message.Set_Name('FND', 'CP-Generic oracle error');
1218: Fnd_Message.Set_Token('ERROR', oraerrmesg, FALSE);
1219: Fnd_Message.Set_Token('ROUTINE',
1220: 'FND_CONCURRENT.INIT_REQUEST', FALSE);
1221: fnd_adg_support.log_unhandled_exception('fnd_concurrent.init_request',SQLERRM);
1222: return;
1223:
1224: end init_request;
1225:
1225:
1226:
1227: --
1228: -- Name
1229: -- FND_CONCURRENT.SET_PREFERRED_RBS
1230: -- Purpose
1231: -- Called from afpirq, etc to set the Rollback Segment associated with req.
1232: --
1233: -- Arguments (input)
1241:
1242: begin
1243: select P.Rollback_Segment
1244: into RBS
1245: from FND_CONCURRENT_PROGRAMS P,
1246: FND_CONCURRENT_REQUESTS R
1247: WHERE R.request_id = fnd_global.conc_request_id
1248: AND R.CONCURRENT_PROGRAM_ID = P.CONCURRENT_PROGRAM_ID
1249: And R.PROGRAM_APPLICATION_ID = P.APPLICATION_ID;
1242: begin
1243: select P.Rollback_Segment
1244: into RBS
1245: from FND_CONCURRENT_PROGRAMS P,
1246: FND_CONCURRENT_REQUESTS R
1247: WHERE R.request_id = fnd_global.conc_request_id
1248: AND R.CONCURRENT_PROGRAM_ID = P.CONCURRENT_PROGRAM_ID
1249: And R.PROGRAM_APPLICATION_ID = P.APPLICATION_ID;
1250:
1263: end SET_PREFERRED_RBS;
1264:
1265: --
1266: -- Name
1267: -- Fnd_Concurrent.Reset_Context
1268: -- Purpose
1269: -- To reset/re-establish context that may have been lost due to commits
1270: --
1271: -- Arguments (input)
1286: if (g_request_id is null) then
1287: g_request_id := Request_Id;
1288: end if;
1289:
1290: Fnd_Concurrent.Set_Preferred_RBS;
1291:
1292: return TRUE;
1293:
1294: exception
1297:
1298: end Reset_Context;
1299:
1300: -- Name
1301: -- FND_CONCURRENT.AF_COMMIT
1302: -- Purpose
1303: -- It does the commit and set the preferred rollback segment for the
1304: -- program. Call this routine only in the concurrent program context.
1305: --
1314:
1315: -- if the context is concurrent program then set the rollback segment to
1316: -- program preferred
1317: if (fnd_global.conc_request_id > 0) then
1318: fnd_concurrent.set_preferred_rbs;
1319: end if;
1320:
1321: End AF_COMMIT;
1322:
1320:
1321: End AF_COMMIT;
1322:
1323: -- Name
1324: -- FND_CONCURRENT.AF_ROLLBACK
1325: -- Purpose
1326: -- It does the rollback and set the preferred rollback segment for the
1327: -- program. Call this routine only in the concurrent program context.
1328: --
1337:
1338: -- if the context is concurrent program then set the rollback segment to
1339: -- program preferred
1340: if (fnd_global.conc_request_id > 0) then
1341: fnd_concurrent.set_preferred_rbs;
1342: end if;
1343:
1344: End AF_ROLLBACK;
1345:
1343:
1344: End AF_ROLLBACK;
1345:
1346: -- Name
1347: -- FND_CONCURRENT.SHUT_DOWN_PROCS
1348: -- Purpose
1349: -- Runs the pl/sql shutdown procedures stored in FND_EXECUTABLES
1350: -- with EXECUTION_METHOD_CODE = 'Z'.
1351: --
1373: if ( FND_LOG.LEVEL_ERROR >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) then
1374: fnd_message.set_name('FND', 'CONC-SHUTDOWN_ACTION_FAILURE');
1375: fnd_message.set_token('PROCEDURE', c_rec.execution_file_name);
1376: fnd_message.set_token('REASON', errbuf);
1377: fnd_log.message(FND_LOG.LEVEL_ERROR, 'fnd.plsql.fnd_concurrent.shut_down_procs', FALSE);
1378: end if;
1379: end;
1380: END LOOP;
1381:
1381:
1382: end shut_down_procs;
1383:
1384: -- Name
1385: -- FND_CONCURRENT.SET_INTERIM_STATUS
1386: -- Purpose
1387: -- sets the requests phase_code, interim_status_code and completion_text
1388: -- this is used in Java Concurrent Programs.
1389: --
1443: if ( nvl(lengthb(ret_str), 0 ) > 0 ) then
1444: Fnd_Message.Set_Name('FND', 'CP-Generic oracle error');
1445: Fnd_Message.Set_Token('ERROR', ret_str, FALSE);
1446: Fnd_Message.Set_Token('ROUTINE',
1447: 'FND_CONCURRENT.SET_INTERIM_STATUS', FALSE);
1448: return FALSE;
1449: else
1450: return TRUE;
1451: end if;
1452:
1453: end set_interim_status;
1454:
1455: -- Name
1456: -- FND_CONCURRENT.GET_SUB_REQUESTS
1457: -- Purpose
1458: -- gets all sub-requests for a given request id. For each sub-request it
1459: -- provides request_id, phase,status, developer phase , developer status
1460: -- completion text.
1462: -- Arguments (input)
1463: -- request_id - Request Id for which sub-requests are required.
1464: --
1465: -- Returns:
1466: -- Table FND_CONCURRENT.REQUESTS_TAB_TYPE.
1467: --
1468:
1469: function get_sub_requests( p_request_id IN number)
1470: return requests_tab_type is
1472: Select Request_Id, Completion_Text,
1473: Phase.Lookup_Code p_lookup_code,
1474: Status.Lookup_Code s_lookup_code,
1475: Phase.Meaning p_meaning, Status.Meaning s_meaning
1476: From Fnd_Concurrent_Requests R,
1477: Fnd_Concurrent_programs P,
1478: Fnd_Lookups Phase,
1479: Fnd_Lookups Status
1480: Where
1473: Phase.Lookup_Code p_lookup_code,
1474: Status.Lookup_Code s_lookup_code,
1475: Phase.Meaning p_meaning, Status.Meaning s_meaning
1476: From Fnd_Concurrent_Requests R,
1477: Fnd_Concurrent_programs P,
1478: Fnd_Lookups Phase,
1479: Fnd_Lookups Status
1480: Where
1481: Phase.Lookup_Type = PHASE_LOOKUP_TYPE
1525: return sub_reqs;
1526: end get_sub_requests;
1527:
1528: -- Name
1529: -- FND_CONCURRENT.CHILDREN_DONE
1530: -- Purpose
1531: -- Examines all child requests of a given request id. Returns TRUE if
1532: -- all have completed. Does not consider grandchildren or parent
1533: --
1551: time_left number;
1552: parent_req_id number;
1553: cursor kidslist(parent_id number) is
1554: Select request_id
1555: from fnd_concurrent_requests
1556: where parent_request_id = parent_id;
1557:
1558: begin
1559: Select sysdate + (greatest(Max_Wait, 0)/86400)
1567: if (parent_req_id = -1) then return TRUE; end if;
1568:
1569: LOOP
1570: Select count(*) into kount
1571: from fnd_concurrent_requests
1572: where parent_request_id = parent_req_id
1573: and phase_code <> 'C';
1574:
1575: if (kount = 0) AND (Recursive_Flag = 'Y') then -- check for kids
1687: end if;
1688: end register_node;
1689:
1690: -- Name
1691: -- Fnd_Concurrent.Get_Service_Instances
1692: -- Purpose
1693: -- Fetch all service instances defined for a Service type
1694: -- Returns the service instance identity along with it's current
1695: -- state (Active/Disabled/Inactive/Suspended/Transit )
1697: -- Arguments (input)
1698: -- svc_handle - Developer name for the Service type
1699: --
1700: -- Returns:
1701: -- Table Fnd_Concurrent.Service_Instance_Tab_Type. A table size of 0
1702: -- indicates absence of any service instances for the specified service
1703: -- type
1704: --
1705:
1713: RUNNING_PROCESSES c_run_procs,
1714: MAX_PROCESSES c_max_procs,
1715: CONTROL_CODE c_ctrl_code,
1716: ENABLED_FLAG c_enabled
1717: from FND_CONCURRENT_QUEUES fcq,
1718: FND_CP_SERVICES fcs,
1719: FND_APPLICATION fa
1720: where
1721: fcq.MANAGER_TYPE = to_char(fcs.SERVICE_id)
1758: return svc_inst_inf;
1759: end Get_Service_Instances;
1760:
1761: -- Name
1762: -- Fnd_Concurrent.Get_Service_Processes
1763: -- Purpose
1764: -- Fetch all service instance processes for a service instance
1765: --
1766: -- Arguments (input)
1771: --
1772: -- Application and Service Instance Name together can be used to locate
1773: -- all processes
1774: --
1775: -- Returns (Fnd_Concurrent.Service_Process_Tab_Type)
1776: -- Fnd_Concurrent.Service_Process_Tab_Type.
1777: -- CPID (Concurrent_Process_ID) - Can be used to address/act on the
1778: -- process
1779: -- Service_Parameters - To be used to target particular
1772: -- Application and Service Instance Name together can be used to locate
1773: -- all processes
1774: --
1775: -- Returns (Fnd_Concurrent.Service_Process_Tab_Type)
1776: -- Fnd_Concurrent.Service_Process_Tab_Type.
1777: -- CPID (Concurrent_Process_ID) - Can be used to address/act on the
1778: -- process
1779: -- Service_Parameters - To be used to target particular
1780: -- - service instances
1793: select CONCURRENT_PROCESS_ID c_cpid,
1794: MEANING c_state,
1795: fcp.NODE_NAME c_node,
1796: fcp.SERVICE_PARAMETERS c_parameters
1797: from FND_CONCURRENT_QUEUES fcq,
1798: FND_CONCURRENT_PROCESSES fcp,
1799: FND_APPLICATION fa,
1800: FND_LOOKUP_VALUES_VL flv
1801: where
1794: MEANING c_state,
1795: fcp.NODE_NAME c_node,
1796: fcp.SERVICE_PARAMETERS c_parameters
1797: from FND_CONCURRENT_QUEUES fcq,
1798: FND_CONCURRENT_PROCESSES fcp,
1799: FND_APPLICATION fa,
1800: FND_LOOKUP_VALUES_VL flv
1801: where
1802: fcp.QUEUE_APPLICATION_ID = fcq.APPLICATION_ID
1825: -- Validate service application and name
1826: begin
1827: select 0
1828: into i
1829: from FND_CONCURRENT_QUEUES fcq,
1830: FND_APPLICATION fa
1831: where fcq.APPLICATION_ID = fa.APPLICATION_ID
1832: and APPLICATION_SHORT_NAME = upper(appl_short_name)
1833: and upper(CONCURRENT_QUEUE_NAME) = upper(svc_instance_name);
1853: return svc_proc_inf;
1854: end Get_Service_Processes;
1855:
1856: -- Name
1857: -- FND_CONCURRENT.MSC_MATCH_BY_SERVICE_TYPE
1858: -- Purpose
1859: -- internal function used to find matches of svc cntl requests and
1860: -- Service types. returns 1 for a match, 0 for no.
1861:
1872: ugly piece of coding where we decipher if we have a hit */
1873:
1874: select argument1, argument2, argument3
1875: into rarg1, rarg2, rarg3
1876: from fnd_concurrent_requests R
1877: where requestid = R.request_id;
1878:
1879: /* CASE positive : old style requests */
1880: if (rarg1 >= 0) then
1880: if (rarg1 >= 0) then
1881:
1882: select count(concurrent_queue_id)
1883: into kount
1884: from fnd_concurrent_queues
1885: where concurrent_queue_id = rarg1
1886: and application_id = rarg2
1887: and manager_type = mtype;
1888:
1901:
1902:
1903: select count(concurrent_queue_id)
1904: into kount
1905: from fnd_concurrent_queues
1906: where application_id = rarg2
1907: and manager_type = mtype;
1908:
1909: if (kount > 0) then return 1;
1939:
1940: end MSC_MATCH_BY_SERVICE_TYPE;
1941:
1942: -- Name
1943: -- FND_CONCURRENT.MSC_MATCH
1944: -- Purpose
1945: -- internal function used to find matches of svc cntl requests and services
1946: -- or managers. returns 1 for a match, 0 for no.
1947:
1962: ugly piece of coding where we decipher if we have a hit */
1963:
1964: select argument1, argument2, argument3
1965: into rarg1, rarg2, rarg3
1966: from fnd_concurrent_requests R
1967: where requestid = R.request_id;
1968:
1969: /* CASE positive : old style requests */
1970: if ((rarg1 >= 0) and (rarg1 = que_id) and (rarg2 = app_id)) then
2007: end if;
2008:
2009: end MSC_MATCH;
2010: -- Name
2011: -- FND_CONCURRENT.find_pending_svc_ctrl_reqs
2012: -- Purpose
2013: -- gets all pending service control requests for a given service or service
2014: -- instance. Returns number of requests found and has an out parameter
2015: -- containing a comma delimited list of matching requests.
2035: my_service_id number := service_id;
2036:
2037: Cursor C1 IS
2038: Select request_id
2039: from fnd_concurrent_requests R, fnd_concurrent_programs P
2040: where r.phase_code = 'P'
2041: and p.application_id = r.PROGRAM_APPLICATION_ID
2042: and p.concurrent_program_id = r.concurrent_program_id
2043: and p.queue_control_flag = 'Y'
2053: elsif (service_id is null) then
2054: /* populate app and service id */
2055: select manager_type, application_id
2056: into my_service_id, app_id
2057: from fnd_concurrent_queues
2058: where concurrent_queue_id = service_inst_id;
2059: end if;
2060:
2061: /* find results */
2073: end find_pending_svc_ctrl_reqs;
2074:
2075:
2076: -- Name
2077: -- FND_CONCURRENT.Find_SC_Conflict
2078: -- Purpose
2079: -- Finds later conflicting service control request (if any) for another
2080: -- service control request.
2081: --
2090: kount number := 0;
2091:
2092: Cursor C1 IS
2093: Select R2.request_id
2094: from fnd_concurrent_requests R1,
2095: fnd_concurrent_requests R2,
2096: fnd_concurrent_programs P1,
2097: fnd_concurrent_programs P2,
2098: fnd_concurrent_queues Q,
2091:
2092: Cursor C1 IS
2093: Select R2.request_id
2094: from fnd_concurrent_requests R1,
2095: fnd_concurrent_requests R2,
2096: fnd_concurrent_programs P1,
2097: fnd_concurrent_programs P2,
2098: fnd_concurrent_queues Q,
2099: fnd_application A
2092: Cursor C1 IS
2093: Select R2.request_id
2094: from fnd_concurrent_requests R1,
2095: fnd_concurrent_requests R2,
2096: fnd_concurrent_programs P1,
2097: fnd_concurrent_programs P2,
2098: fnd_concurrent_queues Q,
2099: fnd_application A
2100: where r1.request_id = reqid
2093: Select R2.request_id
2094: from fnd_concurrent_requests R1,
2095: fnd_concurrent_requests R2,
2096: fnd_concurrent_programs P1,
2097: fnd_concurrent_programs P2,
2098: fnd_concurrent_queues Q,
2099: fnd_application A
2100: where r1.request_id = reqid
2101: and P1.APPLICATION_ID = R1.PROGRAM_APPLICATION_ID
2094: from fnd_concurrent_requests R1,
2095: fnd_concurrent_requests R2,
2096: fnd_concurrent_programs P1,
2097: fnd_concurrent_programs P2,
2098: fnd_concurrent_queues Q,
2099: fnd_application A
2100: where r1.request_id = reqid
2101: and P1.APPLICATION_ID = R1.PROGRAM_APPLICATION_ID
2102: and P1.concurrent_program_id = R1.concurrent_program_id
2133: /* CASE positive : old style requests */
2134: if (rarg1 >= 0) then
2135: select count(concurrent_queue_id)
2136: into kount
2137: from fnd_concurrent_queues
2138: where concurrent_queue_id = rarg1
2139: and application_id = rarg2
2140: and ((Running_processes <> MAX_PROCESSES)
2141: or ((goal_state is not null) and
2146: /* CASE -1 : By app id */
2147: elsif (rarg1 = -1) then
2148: select count(concurrent_queue_id)
2149: into kount
2150: from fnd_concurrent_queues
2151: where application_id = rarg2
2152: and (
2153: /* either CM or TM and request is for mgrs (or both) */
2154: (((manager_type = 1) or (manager_type = 3))
2163: /* CASE -2 : cp fun pak */
2164: elsif (rarg1 = -2) then
2165: select count(concurrent_queue_id)
2166: into kount
2167: from fnd_concurrent_queues
2168: where manager_type IN ('1', '3', '4', '5')
2169: and ((Running_processes <> MAX_PROCESSES)
2170: or ((goal_state is not null) and
2171: ((CONTROL_CODE <> goal_state) or (CONTROL_CODE is null)))
2175: /* CASE -3 : By service type */
2176: elsif (rarg1 = -3) then
2177: select count(concurrent_queue_id)
2178: into kount
2179: from fnd_concurrent_queues
2180: where manager_type = to_char(rarg2)
2181: and ((Running_processes <> MAX_PROCESSES)
2182: or ((goal_state is not null) and
2183: ((CONTROL_CODE <> goal_state) or (CONTROL_CODE is null)))
2186: /* CASE -4 : cp all */
2187: elsif (rarg1 = -4) then
2188: select count(concurrent_queue_id)
2189: into kount
2190: from fnd_concurrent_queues
2191: where manager_type < 1000
2192: and ((Running_processes <> MAX_PROCESSES)
2193: or ((goal_state is not null) and
2194: ((CONTROL_CODE <> goal_state) or (CONTROL_CODE is null)))
2205:
2206:
2207:
2208: -- Name
2209: -- FND_CONCURRENT.Function Wait_for_SCTL_Done
2210: -- Purpose
2211: -- Waits for Svc Ctrl request to finish, or another conflicting request,
2212: -- or timeout.
2213: --
2252: select concurrent_program_id, program_application_id, phase_code,
2253: argument1, argument2, argument3, Decode(concurrent_program_id,
2254: 0,null, 1,'E', 3, null, 4, 'X', 5, 'E', 7, 'P', 8, null, null)
2255: into prog_id, r_app_id, r_phase, rarg1, rarg2, rarg3, goal_state
2256: from fnd_concurrent_requests
2257: where request_id = reqid;
2258: exception
2259: when others then
2260: return SCTL_REQ_NOT_FOUND;
2291:
2292: /* have we run yet? */
2293: select decode(phase_code, 'C', 0, -1)
2294: into Done
2295: from fnd_concurrent_requests
2296: where request_id = reqid;
2297:
2298: if ((timesup > 0) and (Done = 0)) then
2299: return SCTL_TIMEOUT_NOT_C;
2337: end SCTL_REQ_COMPLETED;
2338:
2339:
2340: -- Name
2341: -- FND_CONCURRENT.Wait_For_All_Down
2342: -- Purpose
2343: -- Waits for all services, managers, and icm to go down, or timesout.
2344: --
2345: -- Arguments (input)
2388: oraerrmesg := substr(SQLERRM, 1, 80);
2389: Fnd_Message.Set_Name('FND', 'CP-Generic oracle error');
2390: Fnd_Message.Set_Token('ERROR', oraerrmesg, FALSE);
2391: Fnd_Message.Set_Token('ROUTINE',
2392: 'FND_CONCURRENT.WAIT_FOR_ALL_DOWN', FALSE);
2393: return FALSE;
2394: end Wait_For_All_Down;
2395:
2396:
2394: end Wait_For_All_Down;
2395:
2396:
2397: -- Name
2398: -- FND_CONCURRENT.Build_Svc_Ctrl_Desc.
2399: -- Purpose
2400: -- Provides description text for svc ctrl request based on args.
2401: --
2402: -- Arguments (input)
2419: begin
2420: begin
2421: select cp.USER_CONCURRENT_PROGRAM_NAME
2422: into action
2423: from fnd_concurrent_programs_vl cp, fnd_application a
2424: where cp.concurrent_program_name = prog
2425: AND cp.application_id = a.application_id
2426: AND a.application_short_name = 'FND';
2427: exception when others then
2432:
2433: begin
2434: select USER_CONCURRENT_QUEUE_NAME
2435: into Detail
2436: from fnd_concurrent_queues_vl
2437: where APPLICATION_ID = Arg2
2438: and concurrent_queue_id = Arg1;
2439: exception
2440: when others then
2507:
2508: end Build_Svc_Ctrl_Desc;
2509:
2510: -- Name
2511: -- FND_CONCURRENT.Cancel_Request.
2512: -- Purpose
2513: -- It Cancels given Concurrent Request.
2514: --
2515: -- Arguments (input)
2532: -- check this user got privilege to cancel request
2533: begin
2534: Select Requested_By
2535: into submitter
2536: from fnd_concurrent_requests
2537: where request_id = Cancel_Request.request_id;
2538: exception
2539: when no_data_found then
2540: raise request_missing;
2566:
2567: exception
2568: when request_missing then
2569: fnd_message.set_name('FND', 'CONC-MISSING REQUEST');
2570: fnd_message.set_token('ROUTINE', 'FND_CONCURRENT.CANCEL_REQUEST');
2571: fnd_message.set_token('REQUEST', to_char(request_id));
2572: message := fnd_message.get;
2573: return FALSE;
2574: when no_privilege then
2577: message := fnd_message.get;
2578: return FALSE;
2579: when others then
2580: fnd_message.set_name('FND', 'SQL_PLSQL_ERROR');
2581: fnd_message.set_token('ROUTINE', 'FND_CONCURRENT.CANCEL_REQUEST');
2582: fnd_message.set_token('ERRNO', SQLCODE);
2583: fnd_message.set_token('REASON', SQLERRM);
2584: message := fnd_message.get;
2585: return FALSE;
2587: end Cancel_Request;
2588:
2589: --
2590: -- Name
2591: -- FND_CONCURRENT.get_resource_lock
2592: -- Purpose
2593: -- It gets an exclusive lock for a given resource or task name.
2594: --
2595: -- Arguments (input)
2629: exception
2630: when others then
2631: fnd_message.set_name ('FND', 'CP-Generic oracle error');
2632: fnd_message.set_token ('ERROR', substr (sqlerrm, 1, 30), FALSE);
2633: fnd_message.set_token ('ROUTINE', 'fnd_concurrent.get_resource_lock',
2634: FALSE);
2635: return result;
2636:
2637: end;
2637: end;
2638:
2639: --
2640: -- Name
2641: -- FND_CONCURRENT.release_resource_lock
2642: -- Purpose
2643: -- It releases an exclusive lock for a given resource or task name.
2644: --
2645: -- Arguments (input)
2671: exception
2672: when others then
2673: fnd_message.set_name ('FND', 'CP-Generic oracle error');
2674: fnd_message.set_token ('ERROR', substr (sqlerrm, 1, 30), FALSE);
2675: fnd_message.set_token ('ROUTINE', 'fnd_concurrent.release_resource_lock',
2676: FALSE);
2677: return result;
2678:
2679: end;
2685:
2686:
2687: --
2688: -- Name
2689: -- FND_CONCURRENT.INIT_SQL_REQUEST
2690: -- Purpose
2691: -- Called for all SQL*PLUS concurrent requests to perform request initialization.
2692: --
2693:
2711: lmachine v$session.machine%type;
2712: position number;
2713: begin
2714:
2715: -- Select all the information needed for this request from fnd_concurrent_requests,
2716: -- using the fnd_cp_sql_requests table.
2717: -- A row should have been inserted earlier in usdspid, containing the current request id,
2718: -- machine name, and process id.
2719: -- By joining these tables with v$session, we can pull out all the information we need,
2743: fcr.request_id, fcr.priority_request_id
2744: into session_id, userid, respid, respappid,
2745: secgrpid, siteid, loginid, cloginid,
2746: progappid, cprogid, creqid, cprireqid
2747: from fnd_concurrent_requests fcr,
2748: fnd_cp_sql_requests sr
2749: where fcr.phase_code = 'R'
2750: and fcr.status_code = 'R'
2751: and fcr.request_id = sr.request_id
2791: if ( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) then
2792: fnd_message.set_name ('FND', 'SQL-Generic error');
2793: fnd_message.set_token ('ERRNO', sqlcode, FALSE);
2794: fnd_message.set_token ('REASON', sqlerrm, FALSE);
2795: fnd_message.set_token ('ROUTINE', 'FND_CONCURRENT.INIT_SQL_REQUEST', FALSE);
2796: fnd_log.message(FND_LOG.LEVEL_EXCEPTION,
2797: 'fnd.plsql.FND_CONCURRENT.INIT_SQL_REQUEST.others', FALSE);
2798: end if;
2799: end;
2793: fnd_message.set_token ('ERRNO', sqlcode, FALSE);
2794: fnd_message.set_token ('REASON', sqlerrm, FALSE);
2795: fnd_message.set_token ('ROUTINE', 'FND_CONCURRENT.INIT_SQL_REQUEST', FALSE);
2796: fnd_log.message(FND_LOG.LEVEL_EXCEPTION,
2797: 'fnd.plsql.FND_CONCURRENT.INIT_SQL_REQUEST.others', FALSE);
2798: end if;
2799: end;
2800:
2801: end init_sql_request;
2805: -- msg varchar2(2000);
2806: -- l_count number;
2807: -- begin
2808:
2809: -- insert into FND_CONCURRENT_DEBUG_INFO(TIME, ACTION, message, TIME_IN_NUMBER)
2810: -- VALUES(sysdate,'FND_CONCURRENT.get_m_s',message,0);
2811: --commit;
2812: --end debug;
2813:
2806: -- l_count number;
2807: -- begin
2808:
2809: -- insert into FND_CONCURRENT_DEBUG_INFO(TIME, ACTION, message, TIME_IN_NUMBER)
2810: -- VALUES(sysdate,'FND_CONCURRENT.get_m_s',message,0);
2811: --commit;
2812: --end debug;
2813:
2814:
2902:
2903: CURSOR l_prog_id_csr(p_program_name varchar2,
2904: p_application_id number) IS
2905: SELECT concurrent_program_id, srs_flag
2906: FROM fnd_concurrent_programs
2907: WHERE concurrent_program_name = p_program_name
2908: AND application_id = p_application_id;
2909:
2910: BEGIN
2946:
2947: fnd_data_security.get_security_predicate
2948: (p_api_version => 1.0,
2949: p_function => 'FND_CP_REQ_SUBMIT',
2950: p_object_name => 'FND_CONCURRENT_PROGRAMS',
2951: x_predicate => l_predicate,
2952: x_return_status => l_return_status,
2953: p_table_alias => 'p');
2954:
2951: x_predicate => l_predicate,
2952: x_return_status => l_return_status,
2953: p_table_alias => 'p');
2954:
2955: l_sql_stmt := 'select count(p.concurrent_program_id) from fnd_concurrent_programs p where p.concurrent_program_id = :1 and p.application_id = :2 and ' || l_predicate || '';
2956:
2957: execute immediate l_sql_stmt INTO l_ret_value using l_conc_program_id, l_application_id;
2958:
2959: IF (l_ret_value > 0) THEN
2970: RETURN l_ret_value;
2971: END check_program_privileges;
2972:
2973:
2974: end FND_CONCURRENT;