DBA Data[Home] [Help]

APPS.XDP_MACROS dependencies on XDP_ADAPTER

Line 55: XDP_ADAPTER_CORE.SendSync(p_ChannelName => pv_ApplChannelName);

51: Procedure SEND_SYNC
52: is
53: begin
54:
55: XDP_ADAPTER_CORE.SendSync(p_ChannelName => pv_ApplChannelName);
56:
57: end SEND_SYNC;
58:
59: --

Line 140: xdp_adapter.pv_AdapterExitCode := null;

136: -- reset the Log Locator for every SEND
137: pv_ResponseLob := null;
138: DBMS_LOB.createtemporary(pv_ResponseLob, TRUE);
139:
140: xdp_adapter.pv_AdapterExitCode := null;
141:
142: -- dbms_output.put_line('Sending: ' || substr(l_ActualStr, 1, 200));
143: -- dbms_output.put_line('Prompt: ' || substr(l_PromptValue, 1, 200));
144:

Line 145: XDP_ADAPTER_CORE.SendApplicationMessage(p_ChannelName => pv_ApplChannelName,

141:
142: -- dbms_output.put_line('Sending: ' || substr(l_ActualStr, 1, 200));
143: -- dbms_output.put_line('Prompt: ' || substr(l_PromptValue, 1, 200));
144:
145: XDP_ADAPTER_CORE.SendApplicationMessage(p_ChannelName => pv_ApplChannelName,
146: p_Command => l_ActualStr,
147: p_Response => l_PromptValue);
148:
149: -- dbms_output.put_line('Waiting for response...');

Line 151: XDP_ADAPTER_CORE.WaitForMessage(p_ChannelName => pv_ReturnChannelName,

147: p_Response => l_PromptValue);
148:
149: -- dbms_output.put_line('Waiting for response...');
150: -- dbms_output.put_line('Timeout: ' || to_char(pv_MesgTimeout));
151: XDP_ADAPTER_CORE.WaitForMessage(p_ChannelName => pv_ReturnChannelName,
152: p_Timeout => pv_MesgTimeout + 5,
153: p_ResponseMessage => l_RespXML);
154:
155: l_Status := XDP_ADAPTER_CORE_XML.DecodeMessage(p_WhattoDecode => 'STATUS',

Line 155: l_Status := XDP_ADAPTER_CORE_XML.DecodeMessage(p_WhattoDecode => 'STATUS',

151: XDP_ADAPTER_CORE.WaitForMessage(p_ChannelName => pv_ReturnChannelName,
152: p_Timeout => pv_MesgTimeout + 5,
153: p_ResponseMessage => l_RespXML);
154:
155: l_Status := XDP_ADAPTER_CORE_XML.DecodeMessage(p_WhattoDecode => 'STATUS',
156: p_XMLMessage => l_RespXML);
157:
158: -- dbms_output.put_line('Status: ' || l_Status);
159:

Line 161: XDP_ADAPTER_CORE.SendAck(p_ChannelName => pv_ApplChannelName);

157:
158: -- dbms_output.put_line('Status: ' || l_Status);
159:
160: -- dbms_output.put_line('Sending ACK');
161: XDP_ADAPTER_CORE.SendAck(p_ChannelName => pv_ApplChannelName);
162:
163: -- dbms_output.put_line('After Sending ACK');
164:
165: xdp_adapter.pv_AdapterExitCode := XDP_ADAPTER_CORE_XML.DecodeMessage

Line 165: xdp_adapter.pv_AdapterExitCode := XDP_ADAPTER_CORE_XML.DecodeMessage

161: XDP_ADAPTER_CORE.SendAck(p_ChannelName => pv_ApplChannelName);
162:
163: -- dbms_output.put_line('After Sending ACK');
164:
165: xdp_adapter.pv_AdapterExitCode := XDP_ADAPTER_CORE_XML.DecodeMessage
166: (p_WhattoDecode => 'EXIT_CODE',
167: p_XMLMessage => l_RespXML);
168:
169: -- dbms_output.put_line('Exit Code: ' || xdp_adapter.pv_AdapterExitCode);

Line 169: -- dbms_output.put_line('Exit Code: ' || xdp_adapter.pv_AdapterExitCode);

165: xdp_adapter.pv_AdapterExitCode := XDP_ADAPTER_CORE_XML.DecodeMessage
166: (p_WhattoDecode => 'EXIT_CODE',
167: p_XMLMessage => l_RespXML);
168:
169: -- dbms_output.put_line('Exit Code: ' || xdp_adapter.pv_AdapterExitCode);
170: if (l_Status = g_StatusSuccess) then
171:
172: l_MoreFlag := XDP_ADAPTER_CORE_XML.DecodeMessage(
173: p_WhattoDecode => 'MORE_FLAG',

Line 172: l_MoreFlag := XDP_ADAPTER_CORE_XML.DecodeMessage(

168:
169: -- dbms_output.put_line('Exit Code: ' || xdp_adapter.pv_AdapterExitCode);
170: if (l_Status = g_StatusSuccess) then
171:
172: l_MoreFlag := XDP_ADAPTER_CORE_XML.DecodeMessage(
173: p_WhattoDecode => 'MORE_FLAG',
174: p_XMLMessage => l_RespXML);
175:
176: -- dbms_output.put_line('More Flag : ' || l_MoreFlag);

Line 178: XDP_ADAPTER_CORE_XML.DecodeMessage(p_WhattoDecode => 'DATA',

174: p_XMLMessage => l_RespXML);
175:
176: -- dbms_output.put_line('More Flag : ' || l_MoreFlag);
177: SFM_int_response_buffer :=
178: XDP_ADAPTER_CORE_XML.DecodeMessage(p_WhattoDecode => 'DATA',
179: p_XMLMessage => l_RespXML);
180:
181: if SFM_int_response_buffer is not null then
182: -- dbms_output.put_line('After Reponse' || SFM_int_response_buffer);

Line 192: XDP_ADAPTER_CORE.WaitForMessage(

188: while (l_MoreFlag is not null and l_MoreFlag = 'Y' ) loop
189:
190: -- dbms_output.put_line('Waiting for message(LOOP)');
191: -- dbms_output.put_line('Timeout: ' || to_char(pv_MesgTimeout));
192: XDP_ADAPTER_CORE.WaitForMessage(
193: p_ChannelName => pv_ReturnChannelName,
194: p_Timeout => pv_MesgTimeout + 5,
195: p_ResponseMessage => l_RespXML);
196:

Line 197: l_Status := XDP_ADAPTER_CORE_XML.DecodeMessage(

193: p_ChannelName => pv_ReturnChannelName,
194: p_Timeout => pv_MesgTimeout + 5,
195: p_ResponseMessage => l_RespXML);
196:
197: l_Status := XDP_ADAPTER_CORE_XML.DecodeMessage(
198: p_WhattoDecode => 'STATUS',
199: p_XMLMessage => l_RespXML);
200: -- dbms_output.put_line('Status: (LOOP) ' || l_Status);
201:

Line 203: XDP_ADAPTER_CORE.SendAck(p_ChannelName => pv_ApplChannelName);

199: p_XMLMessage => l_RespXML);
200: -- dbms_output.put_line('Status: (LOOP) ' || l_Status);
201:
202: -- dbms_output.put_line('Sending ACK (LOOP)');
203: XDP_ADAPTER_CORE.SendAck(p_ChannelName => pv_ApplChannelName);
204: -- dbms_output.put_line('After Sending ACK (LOOP)');
205:
206: xdp_adapter.pv_AdapterExitCode := XDP_ADAPTER_CORE_XML.DecodeMessage
207: (p_WhattoDecode => 'EXIT_CODE',

Line 206: xdp_adapter.pv_AdapterExitCode := XDP_ADAPTER_CORE_XML.DecodeMessage

202: -- dbms_output.put_line('Sending ACK (LOOP)');
203: XDP_ADAPTER_CORE.SendAck(p_ChannelName => pv_ApplChannelName);
204: -- dbms_output.put_line('After Sending ACK (LOOP)');
205:
206: xdp_adapter.pv_AdapterExitCode := XDP_ADAPTER_CORE_XML.DecodeMessage
207: (p_WhattoDecode => 'EXIT_CODE',
208: p_XMLMessage => l_RespXML);
209:
210: -- dbms_output.put_line('Exit Code:(LOOP) ' || xdp_adapter.pv_AdapterExitCode);

Line 210: -- dbms_output.put_line('Exit Code:(LOOP) ' || xdp_adapter.pv_AdapterExitCode);

206: xdp_adapter.pv_AdapterExitCode := XDP_ADAPTER_CORE_XML.DecodeMessage
207: (p_WhattoDecode => 'EXIT_CODE',
208: p_XMLMessage => l_RespXML);
209:
210: -- dbms_output.put_line('Exit Code:(LOOP) ' || xdp_adapter.pv_AdapterExitCode);
211: if (l_Status = g_StatusSuccess ) then
212:
213: l_MoreFlag := XDP_ADAPTER_CORE_XML.DecodeMessage(
214: p_WhattoDecode => 'MORE_FLAG',

Line 213: l_MoreFlag := XDP_ADAPTER_CORE_XML.DecodeMessage(

209:
210: -- dbms_output.put_line('Exit Code:(LOOP) ' || xdp_adapter.pv_AdapterExitCode);
211: if (l_Status = g_StatusSuccess ) then
212:
213: l_MoreFlag := XDP_ADAPTER_CORE_XML.DecodeMessage(
214: p_WhattoDecode => 'MORE_FLAG',
215: p_XMLMessage => l_RespXML);
216:
217: -- dbms_output.put_line('More Flag: (LOOP) ' || l_MoreFlag);

Line 218: l_TempResponse := XDP_ADAPTER_CORE_XML.DecodeMessage(

214: p_WhattoDecode => 'MORE_FLAG',
215: p_XMLMessage => l_RespXML);
216:
217: -- dbms_output.put_line('More Flag: (LOOP) ' || l_MoreFlag);
218: l_TempResponse := XDP_ADAPTER_CORE_XML.DecodeMessage(
219: p_WhattoDecode => 'DATA',
220: p_XMLMessage => l_RespXML);
221:
222: if l_TempResponse is not null then

Line 239: SFM_SQLERRM := XDP_ADAPTER_CORE_XML.DecodeMessage(

235: 32766 - length(SFM_int_response_buffer) );
236: end if;
237:
238: else
239: SFM_SQLERRM := XDP_ADAPTER_CORE_XML.DecodeMessage(
240: p_WhattoDecode => 'DATA',
241: p_XMLMessage => l_RespXML);
242: exit;
243: end if;

Line 247: SFM_SQLERRM := XDP_ADAPTER_CORE_XML.DecodeMessage(

243: end if;
244: end loop;
245:
246: else
247: SFM_SQLERRM := XDP_ADAPTER_CORE_XML.DecodeMessage(
248: p_WhattoDecode => 'DATA',
249: p_XMLMessage => l_RespXML);
250: end if;
251: exception

Line 277: -- XDP_ADAPTER_CORE.SendSync(p_ChannelName => pv_ApplChannelName,

273: -- Mainly chr(0)'s
274: StripOffendingChars;
275:
276: -- dbms_output.put_line('Sending Sync..');
277: -- XDP_ADAPTER_CORE.SendSync(p_ChannelName => pv_ApplChannelName,
278: -- p_CleanupPipe => 'N');
279: -- dbms_output.put_line('After Sending Sync..');
280:
281: -- Log the Response

Line 300: SFM_SQLCODE := xdp_adapter.pv_AdapterFailure;

296: pv_MesgTimeout,
297: SFM_int_response_buffer);
298:
299: if (l_Status = g_StatusFailure) then
300: SFM_SQLCODE := xdp_adapter.pv_AdapterFailure;
301: xdpcore.raise(xdp_adapter.pv_AdapterFailure, SFM_SQLERRM);
302:
303: elsif (l_Status = g_StatusTimeout) then
304: SFM_SQLCODE := xdp_adapter.pv_AdapterTimeOut;

Line 301: xdpcore.raise(xdp_adapter.pv_AdapterFailure, SFM_SQLERRM);

297: SFM_int_response_buffer);
298:
299: if (l_Status = g_StatusFailure) then
300: SFM_SQLCODE := xdp_adapter.pv_AdapterFailure;
301: xdpcore.raise(xdp_adapter.pv_AdapterFailure, SFM_SQLERRM);
302:
303: elsif (l_Status = g_StatusTimeout) then
304: SFM_SQLCODE := xdp_adapter.pv_AdapterTimeOut;
305: xdpcore.raise(xdp_adapter.pv_AdapterTimeOut, SFM_SQLERRM);

Line 304: SFM_SQLCODE := xdp_adapter.pv_AdapterTimeOut;

300: SFM_SQLCODE := xdp_adapter.pv_AdapterFailure;
301: xdpcore.raise(xdp_adapter.pv_AdapterFailure, SFM_SQLERRM);
302:
303: elsif (l_Status = g_StatusTimeout) then
304: SFM_SQLCODE := xdp_adapter.pv_AdapterTimeOut;
305: xdpcore.raise(xdp_adapter.pv_AdapterTimeOut, SFM_SQLERRM);
306:
307: elsif (l_Status = g_StatusWarning) then
308: SFM_SQLCODE := xdp_adapter.pv_AdapterWarning;

Line 305: xdpcore.raise(xdp_adapter.pv_AdapterTimeOut, SFM_SQLERRM);

301: xdpcore.raise(xdp_adapter.pv_AdapterFailure, SFM_SQLERRM);
302:
303: elsif (l_Status = g_StatusTimeout) then
304: SFM_SQLCODE := xdp_adapter.pv_AdapterTimeOut;
305: xdpcore.raise(xdp_adapter.pv_AdapterTimeOut, SFM_SQLERRM);
306:
307: elsif (l_Status = g_StatusWarning) then
308: SFM_SQLCODE := xdp_adapter.pv_AdapterWarning;
309: xdpcore.raise(xdp_adapter.pv_AdapterWarning, SFM_SQLERRM);

Line 308: SFM_SQLCODE := xdp_adapter.pv_AdapterWarning;

304: SFM_SQLCODE := xdp_adapter.pv_AdapterTimeOut;
305: xdpcore.raise(xdp_adapter.pv_AdapterTimeOut, SFM_SQLERRM);
306:
307: elsif (l_Status = g_StatusWarning) then
308: SFM_SQLCODE := xdp_adapter.pv_AdapterWarning;
309: xdpcore.raise(xdp_adapter.pv_AdapterWarning, SFM_SQLERRM);
310:
311: elsif (l_Status = g_StatusSessionLost) then
312: SFM_SQLCODE := xdp_adapter.pv_AdapterSessionLost;

Line 309: xdpcore.raise(xdp_adapter.pv_AdapterWarning, SFM_SQLERRM);

305: xdpcore.raise(xdp_adapter.pv_AdapterTimeOut, SFM_SQLERRM);
306:
307: elsif (l_Status = g_StatusWarning) then
308: SFM_SQLCODE := xdp_adapter.pv_AdapterWarning;
309: xdpcore.raise(xdp_adapter.pv_AdapterWarning, SFM_SQLERRM);
310:
311: elsif (l_Status = g_StatusSessionLost) then
312: SFM_SQLCODE := xdp_adapter.pv_AdapterSessionLost;
313: xdpcore.raise(xdp_adapter.pv_AdapterSessionLost, SFM_SQLERRM);

Line 312: SFM_SQLCODE := xdp_adapter.pv_AdapterSessionLost;

308: SFM_SQLCODE := xdp_adapter.pv_AdapterWarning;
309: xdpcore.raise(xdp_adapter.pv_AdapterWarning, SFM_SQLERRM);
310:
311: elsif (l_Status = g_StatusSessionLost) then
312: SFM_SQLCODE := xdp_adapter.pv_AdapterSessionLost;
313: xdpcore.raise(xdp_adapter.pv_AdapterSessionLost, SFM_SQLERRM);
314: else
315: xdpcore.raise(g_Unhandled, SFM_SQLERRM);
316: end if;

Line 313: xdpcore.raise(xdp_adapter.pv_AdapterSessionLost, SFM_SQLERRM);

309: xdpcore.raise(xdp_adapter.pv_AdapterWarning, SFM_SQLERRM);
310:
311: elsif (l_Status = g_StatusSessionLost) then
312: SFM_SQLCODE := xdp_adapter.pv_AdapterSessionLost;
313: xdpcore.raise(xdp_adapter.pv_AdapterSessionLost, SFM_SQLERRM);
314: else
315: xdpcore.raise(g_Unhandled, SFM_SQLERRM);
316: end if;
317: end if;

Line 348: if SFM_SQLCODE = xdp_adapter.pv_AdapterTimeOut then

344: x_ErrorString := SFM_SQLERRM;
345: -- For Backward Compatibility. Do not raise exception
346: -- in cases of timeout Only. SessionLost, Failure etc will still
347: -- Raise the exception
348: if SFM_SQLCODE = xdp_adapter.pv_AdapterTimeOut then
349: -- NO OP
350: null;
351: else
352: raise;

Line 385: if SFM_SQLCODE = xdp_adapter.pv_AdapterTimeOut then

381: x_ErrorString := SFM_SQLERRM;
382: -- For Backward Compatibility. Do not raise exception
383: -- in cases of timeout Only. SessionLost, Failure etc will still
384: -- Raise the exception
385: if SFM_SQLCODE = xdp_adapter.pv_AdapterTimeOut then
386: -- NO OP
387: null;
388: else
389: raise;

Line 1134: if (XDP_ADAPTER_CORE_DB.Is_Adapter_Implemented (pv_ChannelName)) then

1130: -- and another channel for the responses from the adapter
1131:
1132: -- Bug 2486815
1133: -- Send Sync for only Implemented Adapters
1134: if (XDP_ADAPTER_CORE_DB.Is_Adapter_Implemented (pv_ChannelName)) then
1135: pv_ApplChannelName := XDP_ADAPTER_CORE_PIPE.ConstructChannelName
1136: (p_ChannelType => 'APPL',
1137: p_ChannelName => pv_ChannelName);
1138:

Line 1135: pv_ApplChannelName := XDP_ADAPTER_CORE_PIPE.ConstructChannelName

1131:
1132: -- Bug 2486815
1133: -- Send Sync for only Implemented Adapters
1134: if (XDP_ADAPTER_CORE_DB.Is_Adapter_Implemented (pv_ChannelName)) then
1135: pv_ApplChannelName := XDP_ADAPTER_CORE_PIPE.ConstructChannelName
1136: (p_ChannelType => 'APPL',
1137: p_ChannelName => pv_ChannelName);
1138:
1139: pv_ReturnChannelName := XDP_ADAPTER_CORE_PIPE.GetReturnChannelName

Line 1139: pv_ReturnChannelName := XDP_ADAPTER_CORE_PIPE.GetReturnChannelName

1135: pv_ApplChannelName := XDP_ADAPTER_CORE_PIPE.ConstructChannelName
1136: (p_ChannelType => 'APPL',
1137: p_ChannelName => pv_ChannelName);
1138:
1139: pv_ReturnChannelName := XDP_ADAPTER_CORE_PIPE.GetReturnChannelName
1140: (p_ChannelName => pv_ApplChannelName);
1141:
1142: Send_Sync;
1143: end if;