50:
51: e_code number;
52:
53: begin
54: dbms_pipe.pack_message ( FNDCP_TMSRV.PK_TKN);
55: e_code := dbms_pipe.send_message (P_T_PIPE);
56: end put_token;
57:
58:
51: e_code number;
52:
53: begin
54: dbms_pipe.pack_message ( FNDCP_TMSRV.PK_TKN);
55: e_code := dbms_pipe.send_message (P_T_PIPE);
56: end put_token;
57:
58:
59: --
64:
65: e_code number;
66:
67: begin
68: e_code := dbms_pipe.receive_message (P_T_PIPE, 0);
69: if (e_code = FNDCP_TMSRV.E_SUCCESS) then
70: dbms_pipe.reset_buffer;
71: end if;
72: end take_token;
66:
67: begin
68: e_code := dbms_pipe.receive_message (P_T_PIPE, 0);
69: if (e_code = FNDCP_TMSRV.E_SUCCESS) then
70: dbms_pipe.reset_buffer;
71: end if;
72: end take_token;
73:
74:
121: -- Indicate that the TM is ready to process a TP.
122: put_token;
123:
124: -- Read wait R_pipe.
125: e_code := dbms_pipe.receive_message (P_R_PIPE, timeout);
126:
127: -- If timed out or other error, return
128: if (e_code > FNDCP_TMSRV.E_SUCCESS) then
129: take_token;
130: return;
131: end if;
132:
133: -- If packet type is not a Transaction request, return.
134: dbms_pipe.unpack_message (pktyp);
135: if (pktyp not in (FNDCP_TMSRV.PK_TRN, FNDCP_TMSRV.PK_TRN_D1, FNDCP_TMSRV.PK_TRN_D2)) then
136: take_token;
137: return;
138: end if;
139:
140: -- Set debug level
141: set_debug(pktyp);
142:
143: dbms_pipe.unpack_message (end_date);
144: enddate := to_char (end_date, 'DD-MON-RR HH24:MI:SS');
145:
146:
147: dbms_pipe.unpack_message (reqid);
143: dbms_pipe.unpack_message (end_date);
144: enddate := to_char (end_date, 'DD-MON-RR HH24:MI:SS');
145:
146:
147: dbms_pipe.unpack_message (reqid);
148: dbms_pipe.unpack_message (return_id);
149: dbms_pipe.unpack_message (nlslang);
150: dbms_pipe.unpack_message (nls_num_chars);
151: dbms_pipe.unpack_message (nls_date_lang);
144: enddate := to_char (end_date, 'DD-MON-RR HH24:MI:SS');
145:
146:
147: dbms_pipe.unpack_message (reqid);
148: dbms_pipe.unpack_message (return_id);
149: dbms_pipe.unpack_message (nlslang);
150: dbms_pipe.unpack_message (nls_num_chars);
151: dbms_pipe.unpack_message (nls_date_lang);
152: dbms_pipe.unpack_message (secgrpid);
145:
146:
147: dbms_pipe.unpack_message (reqid);
148: dbms_pipe.unpack_message (return_id);
149: dbms_pipe.unpack_message (nlslang);
150: dbms_pipe.unpack_message (nls_num_chars);
151: dbms_pipe.unpack_message (nls_date_lang);
152: dbms_pipe.unpack_message (secgrpid);
153: dbms_pipe.unpack_message (ops_inst);
146:
147: dbms_pipe.unpack_message (reqid);
148: dbms_pipe.unpack_message (return_id);
149: dbms_pipe.unpack_message (nlslang);
150: dbms_pipe.unpack_message (nls_num_chars);
151: dbms_pipe.unpack_message (nls_date_lang);
152: dbms_pipe.unpack_message (secgrpid);
153: dbms_pipe.unpack_message (ops_inst);
154: dbms_pipe.unpack_message (enable_trace);
147: dbms_pipe.unpack_message (reqid);
148: dbms_pipe.unpack_message (return_id);
149: dbms_pipe.unpack_message (nlslang);
150: dbms_pipe.unpack_message (nls_num_chars);
151: dbms_pipe.unpack_message (nls_date_lang);
152: dbms_pipe.unpack_message (secgrpid);
153: dbms_pipe.unpack_message (ops_inst);
154: dbms_pipe.unpack_message (enable_trace);
155: dbms_pipe.unpack_message (usrid);
148: dbms_pipe.unpack_message (return_id);
149: dbms_pipe.unpack_message (nlslang);
150: dbms_pipe.unpack_message (nls_num_chars);
151: dbms_pipe.unpack_message (nls_date_lang);
152: dbms_pipe.unpack_message (secgrpid);
153: dbms_pipe.unpack_message (ops_inst);
154: dbms_pipe.unpack_message (enable_trace);
155: dbms_pipe.unpack_message (usrid);
156: dbms_pipe.unpack_message (rspapid);
149: dbms_pipe.unpack_message (nlslang);
150: dbms_pipe.unpack_message (nls_num_chars);
151: dbms_pipe.unpack_message (nls_date_lang);
152: dbms_pipe.unpack_message (secgrpid);
153: dbms_pipe.unpack_message (ops_inst);
154: dbms_pipe.unpack_message (enable_trace);
155: dbms_pipe.unpack_message (usrid);
156: dbms_pipe.unpack_message (rspapid);
157: dbms_pipe.unpack_message (rspid);
150: dbms_pipe.unpack_message (nls_num_chars);
151: dbms_pipe.unpack_message (nls_date_lang);
152: dbms_pipe.unpack_message (secgrpid);
153: dbms_pipe.unpack_message (ops_inst);
154: dbms_pipe.unpack_message (enable_trace);
155: dbms_pipe.unpack_message (usrid);
156: dbms_pipe.unpack_message (rspapid);
157: dbms_pipe.unpack_message (rspid);
158: dbms_pipe.unpack_message (logid);
151: dbms_pipe.unpack_message (nls_date_lang);
152: dbms_pipe.unpack_message (secgrpid);
153: dbms_pipe.unpack_message (ops_inst);
154: dbms_pipe.unpack_message (enable_trace);
155: dbms_pipe.unpack_message (usrid);
156: dbms_pipe.unpack_message (rspapid);
157: dbms_pipe.unpack_message (rspid);
158: dbms_pipe.unpack_message (logid);
159: dbms_pipe.unpack_message (apsname);
152: dbms_pipe.unpack_message (secgrpid);
153: dbms_pipe.unpack_message (ops_inst);
154: dbms_pipe.unpack_message (enable_trace);
155: dbms_pipe.unpack_message (usrid);
156: dbms_pipe.unpack_message (rspapid);
157: dbms_pipe.unpack_message (rspid);
158: dbms_pipe.unpack_message (logid);
159: dbms_pipe.unpack_message (apsname);
160: dbms_pipe.unpack_message (program);
153: dbms_pipe.unpack_message (ops_inst);
154: dbms_pipe.unpack_message (enable_trace);
155: dbms_pipe.unpack_message (usrid);
156: dbms_pipe.unpack_message (rspapid);
157: dbms_pipe.unpack_message (rspid);
158: dbms_pipe.unpack_message (logid);
159: dbms_pipe.unpack_message (apsname);
160: dbms_pipe.unpack_message (program);
161: dbms_pipe.unpack_message (org_type);
154: dbms_pipe.unpack_message (enable_trace);
155: dbms_pipe.unpack_message (usrid);
156: dbms_pipe.unpack_message (rspapid);
157: dbms_pipe.unpack_message (rspid);
158: dbms_pipe.unpack_message (logid);
159: dbms_pipe.unpack_message (apsname);
160: dbms_pipe.unpack_message (program);
161: dbms_pipe.unpack_message (org_type);
162: dbms_pipe.unpack_message (org_id);
155: dbms_pipe.unpack_message (usrid);
156: dbms_pipe.unpack_message (rspapid);
157: dbms_pipe.unpack_message (rspid);
158: dbms_pipe.unpack_message (logid);
159: dbms_pipe.unpack_message (apsname);
160: dbms_pipe.unpack_message (program);
161: dbms_pipe.unpack_message (org_type);
162: dbms_pipe.unpack_message (org_id);
163:
156: dbms_pipe.unpack_message (rspapid);
157: dbms_pipe.unpack_message (rspid);
158: dbms_pipe.unpack_message (logid);
159: dbms_pipe.unpack_message (apsname);
160: dbms_pipe.unpack_message (program);
161: dbms_pipe.unpack_message (org_type);
162: dbms_pipe.unpack_message (org_id);
163:
164: numargs := 0;
157: dbms_pipe.unpack_message (rspid);
158: dbms_pipe.unpack_message (logid);
159: dbms_pipe.unpack_message (apsname);
160: dbms_pipe.unpack_message (program);
161: dbms_pipe.unpack_message (org_type);
162: dbms_pipe.unpack_message (org_id);
163:
164: numargs := 0;
165: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
158: dbms_pipe.unpack_message (logid);
159: dbms_pipe.unpack_message (apsname);
160: dbms_pipe.unpack_message (program);
161: dbms_pipe.unpack_message (org_type);
162: dbms_pipe.unpack_message (org_id);
163:
164: numargs := 0;
165: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
166: dbms_pipe.unpack_message (arg_1);
161: dbms_pipe.unpack_message (org_type);
162: dbms_pipe.unpack_message (org_id);
163:
164: numargs := 0;
165: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
166: dbms_pipe.unpack_message (arg_1);
167: numargs := numargs + 1;
168: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
169: dbms_pipe.unpack_message (arg_2);
162: dbms_pipe.unpack_message (org_id);
163:
164: numargs := 0;
165: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
166: dbms_pipe.unpack_message (arg_1);
167: numargs := numargs + 1;
168: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
169: dbms_pipe.unpack_message (arg_2);
170: numargs := numargs + 1;
164: numargs := 0;
165: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
166: dbms_pipe.unpack_message (arg_1);
167: numargs := numargs + 1;
168: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
169: dbms_pipe.unpack_message (arg_2);
170: numargs := numargs + 1;
171: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
172: dbms_pipe.unpack_message (arg_3);
165: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
166: dbms_pipe.unpack_message (arg_1);
167: numargs := numargs + 1;
168: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
169: dbms_pipe.unpack_message (arg_2);
170: numargs := numargs + 1;
171: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
172: dbms_pipe.unpack_message (arg_3);
173: numargs := numargs + 1;
167: numargs := numargs + 1;
168: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
169: dbms_pipe.unpack_message (arg_2);
170: numargs := numargs + 1;
171: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
172: dbms_pipe.unpack_message (arg_3);
173: numargs := numargs + 1;
174: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
175: dbms_pipe.unpack_message (arg_4);
168: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
169: dbms_pipe.unpack_message (arg_2);
170: numargs := numargs + 1;
171: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
172: dbms_pipe.unpack_message (arg_3);
173: numargs := numargs + 1;
174: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
175: dbms_pipe.unpack_message (arg_4);
176: numargs := numargs + 1;
170: numargs := numargs + 1;
171: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
172: dbms_pipe.unpack_message (arg_3);
173: numargs := numargs + 1;
174: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
175: dbms_pipe.unpack_message (arg_4);
176: numargs := numargs + 1;
177: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
178: dbms_pipe.unpack_message (arg_5);
171: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
172: dbms_pipe.unpack_message (arg_3);
173: numargs := numargs + 1;
174: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
175: dbms_pipe.unpack_message (arg_4);
176: numargs := numargs + 1;
177: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
178: dbms_pipe.unpack_message (arg_5);
179: numargs := numargs + 1;
173: numargs := numargs + 1;
174: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
175: dbms_pipe.unpack_message (arg_4);
176: numargs := numargs + 1;
177: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
178: dbms_pipe.unpack_message (arg_5);
179: numargs := numargs + 1;
180: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
181: dbms_pipe.unpack_message (arg_6);
174: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
175: dbms_pipe.unpack_message (arg_4);
176: numargs := numargs + 1;
177: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
178: dbms_pipe.unpack_message (arg_5);
179: numargs := numargs + 1;
180: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
181: dbms_pipe.unpack_message (arg_6);
182: numargs := numargs + 1;
176: numargs := numargs + 1;
177: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
178: dbms_pipe.unpack_message (arg_5);
179: numargs := numargs + 1;
180: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
181: dbms_pipe.unpack_message (arg_6);
182: numargs := numargs + 1;
183: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
184: dbms_pipe.unpack_message (arg_7);
177: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
178: dbms_pipe.unpack_message (arg_5);
179: numargs := numargs + 1;
180: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
181: dbms_pipe.unpack_message (arg_6);
182: numargs := numargs + 1;
183: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
184: dbms_pipe.unpack_message (arg_7);
185: numargs := numargs + 1;
179: numargs := numargs + 1;
180: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
181: dbms_pipe.unpack_message (arg_6);
182: numargs := numargs + 1;
183: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
184: dbms_pipe.unpack_message (arg_7);
185: numargs := numargs + 1;
186: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
187: dbms_pipe.unpack_message (arg_8);
180: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
181: dbms_pipe.unpack_message (arg_6);
182: numargs := numargs + 1;
183: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
184: dbms_pipe.unpack_message (arg_7);
185: numargs := numargs + 1;
186: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
187: dbms_pipe.unpack_message (arg_8);
188: numargs := numargs + 1;
182: numargs := numargs + 1;
183: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
184: dbms_pipe.unpack_message (arg_7);
185: numargs := numargs + 1;
186: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
187: dbms_pipe.unpack_message (arg_8);
188: numargs := numargs + 1;
189: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
190: dbms_pipe.unpack_message (arg_9);
183: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
184: dbms_pipe.unpack_message (arg_7);
185: numargs := numargs + 1;
186: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
187: dbms_pipe.unpack_message (arg_8);
188: numargs := numargs + 1;
189: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
190: dbms_pipe.unpack_message (arg_9);
191: numargs := numargs + 1;
185: numargs := numargs + 1;
186: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
187: dbms_pipe.unpack_message (arg_8);
188: numargs := numargs + 1;
189: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
190: dbms_pipe.unpack_message (arg_9);
191: numargs := numargs + 1;
192: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
193: dbms_pipe.unpack_message (arg_10);
186: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
187: dbms_pipe.unpack_message (arg_8);
188: numargs := numargs + 1;
189: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
190: dbms_pipe.unpack_message (arg_9);
191: numargs := numargs + 1;
192: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
193: dbms_pipe.unpack_message (arg_10);
194: numargs := numargs + 1;
188: numargs := numargs + 1;
189: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
190: dbms_pipe.unpack_message (arg_9);
191: numargs := numargs + 1;
192: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
193: dbms_pipe.unpack_message (arg_10);
194: numargs := numargs + 1;
195: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
196: dbms_pipe.unpack_message (arg_11);
189: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
190: dbms_pipe.unpack_message (arg_9);
191: numargs := numargs + 1;
192: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
193: dbms_pipe.unpack_message (arg_10);
194: numargs := numargs + 1;
195: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
196: dbms_pipe.unpack_message (arg_11);
197: numargs := numargs + 1;
191: numargs := numargs + 1;
192: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
193: dbms_pipe.unpack_message (arg_10);
194: numargs := numargs + 1;
195: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
196: dbms_pipe.unpack_message (arg_11);
197: numargs := numargs + 1;
198: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
199: dbms_pipe.unpack_message (arg_12);
192: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
193: dbms_pipe.unpack_message (arg_10);
194: numargs := numargs + 1;
195: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
196: dbms_pipe.unpack_message (arg_11);
197: numargs := numargs + 1;
198: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
199: dbms_pipe.unpack_message (arg_12);
200: numargs := numargs + 1;
194: numargs := numargs + 1;
195: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
196: dbms_pipe.unpack_message (arg_11);
197: numargs := numargs + 1;
198: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
199: dbms_pipe.unpack_message (arg_12);
200: numargs := numargs + 1;
201: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
202: dbms_pipe.unpack_message (arg_13);
195: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
196: dbms_pipe.unpack_message (arg_11);
197: numargs := numargs + 1;
198: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
199: dbms_pipe.unpack_message (arg_12);
200: numargs := numargs + 1;
201: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
202: dbms_pipe.unpack_message (arg_13);
203: numargs := numargs + 1;
197: numargs := numargs + 1;
198: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
199: dbms_pipe.unpack_message (arg_12);
200: numargs := numargs + 1;
201: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
202: dbms_pipe.unpack_message (arg_13);
203: numargs := numargs + 1;
204: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
205: dbms_pipe.unpack_message (arg_14);
198: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
199: dbms_pipe.unpack_message (arg_12);
200: numargs := numargs + 1;
201: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
202: dbms_pipe.unpack_message (arg_13);
203: numargs := numargs + 1;
204: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
205: dbms_pipe.unpack_message (arg_14);
206: numargs := numargs + 1;
200: numargs := numargs + 1;
201: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
202: dbms_pipe.unpack_message (arg_13);
203: numargs := numargs + 1;
204: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
205: dbms_pipe.unpack_message (arg_14);
206: numargs := numargs + 1;
207: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
208: dbms_pipe.unpack_message (arg_15);
201: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
202: dbms_pipe.unpack_message (arg_13);
203: numargs := numargs + 1;
204: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
205: dbms_pipe.unpack_message (arg_14);
206: numargs := numargs + 1;
207: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
208: dbms_pipe.unpack_message (arg_15);
209: numargs := numargs + 1;
203: numargs := numargs + 1;
204: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
205: dbms_pipe.unpack_message (arg_14);
206: numargs := numargs + 1;
207: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
208: dbms_pipe.unpack_message (arg_15);
209: numargs := numargs + 1;
210: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
211: dbms_pipe.unpack_message (arg_16);
204: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
205: dbms_pipe.unpack_message (arg_14);
206: numargs := numargs + 1;
207: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
208: dbms_pipe.unpack_message (arg_15);
209: numargs := numargs + 1;
210: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
211: dbms_pipe.unpack_message (arg_16);
212: numargs := numargs + 1;
206: numargs := numargs + 1;
207: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
208: dbms_pipe.unpack_message (arg_15);
209: numargs := numargs + 1;
210: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
211: dbms_pipe.unpack_message (arg_16);
212: numargs := numargs + 1;
213: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
214: dbms_pipe.unpack_message (arg_17);
207: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
208: dbms_pipe.unpack_message (arg_15);
209: numargs := numargs + 1;
210: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
211: dbms_pipe.unpack_message (arg_16);
212: numargs := numargs + 1;
213: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
214: dbms_pipe.unpack_message (arg_17);
215: numargs := numargs + 1;
209: numargs := numargs + 1;
210: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
211: dbms_pipe.unpack_message (arg_16);
212: numargs := numargs + 1;
213: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
214: dbms_pipe.unpack_message (arg_17);
215: numargs := numargs + 1;
216: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
217: dbms_pipe.unpack_message (arg_18);
210: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
211: dbms_pipe.unpack_message (arg_16);
212: numargs := numargs + 1;
213: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
214: dbms_pipe.unpack_message (arg_17);
215: numargs := numargs + 1;
216: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
217: dbms_pipe.unpack_message (arg_18);
218: numargs := numargs + 1;
212: numargs := numargs + 1;
213: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
214: dbms_pipe.unpack_message (arg_17);
215: numargs := numargs + 1;
216: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
217: dbms_pipe.unpack_message (arg_18);
218: numargs := numargs + 1;
219: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
220: dbms_pipe.unpack_message (arg_19);
213: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
214: dbms_pipe.unpack_message (arg_17);
215: numargs := numargs + 1;
216: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
217: dbms_pipe.unpack_message (arg_18);
218: numargs := numargs + 1;
219: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
220: dbms_pipe.unpack_message (arg_19);
221: numargs := numargs + 1;
215: numargs := numargs + 1;
216: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
217: dbms_pipe.unpack_message (arg_18);
218: numargs := numargs + 1;
219: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
220: dbms_pipe.unpack_message (arg_19);
221: numargs := numargs + 1;
222: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
223: dbms_pipe.unpack_message (arg_20);
216: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
217: dbms_pipe.unpack_message (arg_18);
218: numargs := numargs + 1;
219: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
220: dbms_pipe.unpack_message (arg_19);
221: numargs := numargs + 1;
222: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
223: dbms_pipe.unpack_message (arg_20);
224: numargs := numargs + 1;
218: numargs := numargs + 1;
219: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
220: dbms_pipe.unpack_message (arg_19);
221: numargs := numargs + 1;
222: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
223: dbms_pipe.unpack_message (arg_20);
224: numargs := numargs + 1;
225:
226: <
219: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
220: dbms_pipe.unpack_message (arg_19);
221: numargs := numargs + 1;
222: if (dbms_pipe.next_item_type = 0) then goto end_args; end if;
223: dbms_pipe.unpack_message (arg_20);
224: numargs := numargs + 1;
225:
226: <
227:
261:
262: begin
263: e_code := FNDCP_TMSRV.E_SUCCESS;
264:
265: dbms_pipe.reset_buffer;
266:
267: dbms_pipe.pack_message (pktyp);
268:
269: -- Pack reply only if it's a valid reply
263: e_code := FNDCP_TMSRV.E_SUCCESS;
264:
265: dbms_pipe.reset_buffer;
266:
267: dbms_pipe.pack_message (pktyp);
268:
269: -- Pack reply only if it's a valid reply
270: if (pktyp = FNDCP_TMSRV.PK_REP) then
271: dbms_pipe.pack_message (reqid);
267: dbms_pipe.pack_message (pktyp);
268:
269: -- Pack reply only if it's a valid reply
270: if (pktyp = FNDCP_TMSRV.PK_REP) then
271: dbms_pipe.pack_message (reqid);
272: dbms_pipe.pack_message (outcome);
273: dbms_pipe.pack_message (message);
274: for i in 1..FNDCP_TMSRV.P_RETVALCOUNT loop
275: dbms_pipe.pack_message (FNDCP_TMSRV.P_RETURN_VALS (i));
268:
269: -- Pack reply only if it's a valid reply
270: if (pktyp = FNDCP_TMSRV.PK_REP) then
271: dbms_pipe.pack_message (reqid);
272: dbms_pipe.pack_message (outcome);
273: dbms_pipe.pack_message (message);
274: for i in 1..FNDCP_TMSRV.P_RETVALCOUNT loop
275: dbms_pipe.pack_message (FNDCP_TMSRV.P_RETURN_VALS (i));
276: end loop;
269: -- Pack reply only if it's a valid reply
270: if (pktyp = FNDCP_TMSRV.PK_REP) then
271: dbms_pipe.pack_message (reqid);
272: dbms_pipe.pack_message (outcome);
273: dbms_pipe.pack_message (message);
274: for i in 1..FNDCP_TMSRV.P_RETVALCOUNT loop
275: dbms_pipe.pack_message (FNDCP_TMSRV.P_RETURN_VALS (i));
276: end loop;
277: end if;
271: dbms_pipe.pack_message (reqid);
272: dbms_pipe.pack_message (outcome);
273: dbms_pipe.pack_message (message);
274: for i in 1..FNDCP_TMSRV.P_RETVALCOUNT loop
275: dbms_pipe.pack_message (FNDCP_TMSRV.P_RETURN_VALS (i));
276: end loop;
277: end if;
278:
279: FNDCP_TMSRV.P_RETVALCOUNT := 0; -- Reset the return values table.
284: NULL, 'S');
285:
286: end if;
287:
288: e_code := dbms_pipe.send_message (return_id);
289:
290: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then
291: fndcp_tmsrv.debug_info('TMSRV_PIPE.write_message',
292: 'Sent Message' ,