1 PACKAGE BODY XDP_FQUEUE_TOOLS AS
2 /* $Header: XDPFQTLB.pls 115.4 2002/05/14 13:23:03 pkm ship $ */
3
4 FUNCTION No_Entries (queued_id VARCHAR2) RETURN NUMBER IS
5 entries_number NUMBER := 0;
6 BEGIN
7 IF queued_id = 'XDP_PENDING_ORDER_QUEUE' THEN
8 SELECT count(1)
9 INTO entries_number
10 FROM xdp_pending_order_qtab;
11 ELSIF queued_id = 'XDP_ORDER_PROC_QUEUE' THEN
12 SELECT count(1)
13 INTO entries_number
14 FROM XDP_ORDER_PROCESSOR_qtab;
15 ELSIF queued_id = 'XDP_WORKITEM_QUEUE' THEN
16 SELECT count(1)
17 INTO entries_number
18 FROM xdp_workitem_qtab;
19 ELSIF queued_id = 'XDP_FA_QUEUE' THEN
20 SELECT count(1)
21 INTO entries_number
22 FROM xdp_fa_qtab;
23 ELSIF queued_id = 'XDP_ADAPTER_JOB_QUEUE' THEN
24 SELECT count(1)
25 INTO entries_number
26 FROM xdp_adapter_job_queue;
27 ELSIF queued_id = 'XDP_WF_CHANNEL_Q' THEN
28 SELECT count(1)
29 INTO entries_number
30 FROM xdp_wf_channel_qtab;
31 /* ELSIF queued_id = 'XDP_ADAPTER_ADMIN_REQUEST' THEN
32 SELECT count(1)
33 INTO entries_number
34 FROM XDP_ADAPTER_ADMIN_REQS; */
35 ELSIF queued_id = 'XNP_IN_MSG_Q' THEN
36 SELECT count(1)
37 INTO entries_number
38 FROM xnp_in_msg_qtab;
39 ELSIF queued_id = 'XNP_OUT_MSG_Q' THEN
40 SELECT count(1)
41 INTO entries_number
42 FROM xnp_out_msg_qtab;
43 ELSIF queued_id = 'XNP_IN_EVT_Q' THEN
44 SELECT count(1)
45 INTO entries_number
46 FROM xnp_in_evt_qtab;
47 ELSIF queued_id = 'XNP_IN_TMR_Q' THEN
48 SELECT count(1)
49 INTO entries_number
50 FROM xnp_in_tmr_qtab;
51 END IF;
52 RETURN entries_number;
53 END No_Entries;
54 FUNCTION Max_Entry_Date (queued_id VARCHAR2) RETURN DATE IS
55 entry_date DATE;
56 BEGIN
57 IF queued_id = 'XDP_PENDING_ORDER_QUEUE' THEN
58 SELECT max(ENQ_TIME)
59 INTO entry_date
60 FROM xdp_pending_order_qtab;
61 ELSIF queued_id = 'XDP_ORDER_PROC_QUEUE' THEN
62 SELECT max(ENQ_TIME)
63 INTO entry_date
64 FROM XDP_ORDER_PROCESSOR_qtab;
65 ELSIF queued_id = 'XDP_WORKITEM_QUEUE' THEN
66 SELECT max(ENQ_TIME)
67 INTO entry_date
68 FROM xdp_workitem_qtab;
69 ELSIF queued_id = 'XDP_FA_QUEUE' THEN
70 SELECT max(ENQ_TIME)
71 INTO entry_date
72 FROM xdp_fa_qtab;
73 ELSIF queued_id = 'XDP_ADAPTER_JOB_QUEUE' THEN
74 SELECT max(QUEUED_ON)
75 INTO entry_date
76 FROM xdp_adapter_job_queue;
77 ELSIF queued_id = 'XDP_WF_CHANNEL_Q' THEN
78 SELECT max(enq_time)
79 INTO entry_date
80 FROM xdp_wf_channel_qtab;
81 /* ELSIF queued_id = 'XDP_ADAPTER_ADMIN_REQS' THEN
82 SELECT max(REQUEST_DATE)
83 INTO entry_date
84 FROM XDP_ADAPTER_ADMIN_REQS; */
85 ELSIF queued_id = 'XNP_IN_MSG_Q' THEN
86 SELECT max(ENQ_TIME)
87 INTO entry_date
88 FROM xnp_in_msg_qtab;
89 ELSIF queued_id = 'XNP_OUT_MSG_Q' THEN
90 SELECT max(ENQ_TIME)
91 INTO entry_date
92 FROM xnp_out_msg_qtab;
93 ELSIF queued_id = 'XNP_IN_EVT_Q' THEN
94 SELECT max(ENQ_TIME)
95 INTO entry_date
96 FROM xnp_in_evt_qtab;
97 END IF;
98 RETURN entry_date;
99 END Max_Entry_Date;
100
101 FUNCTION Processors_Running (queued_id VARCHAR2) RETURN NUMBER IS
102 procs_number NUMBER := 0;
103 BEGIN
104 SELECT count(1)
105 INTO procs_number
106 FROM xdp_dqer_registration
107 WHERE internal_q_name = queued_id;
108 RETURN procs_number;
109 END Processors_Running;
110
111 PROCEDURE Do_Commit IS
112 BEGIN
113 COMMIT;
114 END Do_Commit;
115 END XDP_FQUEUE_TOOLS;
[Home] [Help]