DBA Data[Home] [Help]

APPS.XDP_ADAPTER_CORE_DB dependencies on XDP_ADAPTER

Line 1: PACKAGE BODY XDP_ADAPTER_CORE_DB AS

1: PACKAGE BODY XDP_ADAPTER_CORE_DB AS
2: /* $Header: XDPACODB.pls 120.1 2005/06/08 23:24:55 appldev $ */
3:
4: -- Private variables
5:

Line 57: insert into xdp_adapter_reg (

53: is
54: begin
55:
56:
57: insert into xdp_adapter_reg (
58: channel_name,
59: fe_id,
60: adapter_status,
61: process_id,

Line 99: XDP_ADAPTER.pv_AppID,

95: p_CmdLineOpts,
96: p_CmdLineArgs,
97: p_LogFileName,
98: p_SeqInFE,
99: XDP_ADAPTER.pv_AppID,
100: FND_GLOBAL.USER_ID,
101: sysdate,
102: FND_GLOBAL.USER_ID,
103: sysdate,

Line 119: select XDP_ADAPTER_ADMIN_REQS_S.NEXTVAL into p_RequestID from dual;

115: p_JobID OUT NOCOPY number)
116: is
117:
118: begin
119: select XDP_ADAPTER_ADMIN_REQS_S.NEXTVAL into p_RequestID from dual;
120:
121: XDP_CRON_UTIL.SubmitAdapterAdminJob(p_request => p_RequestID,
122: p_RunDate => SubmitAdapterAdminReq.p_RequestDate,
123: p_RunFreq => SubmitAdapterAdminReq.p_Freq,

Line 126: insert into xdp_adapter_admin_reqs

122: p_RunDate => SubmitAdapterAdminReq.p_RequestDate,
123: p_RunFreq => SubmitAdapterAdminReq.p_Freq,
124: p_JobNumber => p_JobID);
125:
126: insert into xdp_adapter_admin_reqs
127: (request_id,
128: channel_name,
129: request_type,
130: request_date,

Line 169: update xdp_adapter_admin_reqs set

165: p_request => p_RequestID,
166: p_ReqDate => p_RequestDate,
167: p_Freq => p_Freq);
168:
169: update xdp_adapter_admin_reqs set
170: request_date = p_RequestDate,
171: requested_by_user = p_RequestedBy,
172: request_frequency = p_Freq,
173: last_update_date = sysdate,

Line 189: delete from xdp_adapter_admin_reqs where request_id = p_RequestID;

185: l_jobID := Get_Job_Id_For_Request (p_RequestID);
186:
187: dbms_job.remove(l_jobID);
188:
189: delete from xdp_adapter_admin_reqs where request_id = p_RequestID;
190:
191: end RemoveAdapterAdminReq;
192:
193:

Line 206: from xdp_adapter_admin_reqs xar

202:
203: cursor c_GetAdapterAdmin is
204: select xar.request_type, xar.request_date, xar.requested_by_user, xar.request_frequency,
205: xar.channel_name, xar.job_id
206: from xdp_adapter_admin_reqs xar
207: where request_id = p_RequestID;
208:
209: l_Found varchar2(1) := 'N';
210: begin

Line 235: from xdp_adapter_admin_reqs

231: p_RequestDate in date) return number
232: is
233: cursor c_CheckReq is
234: select request_id, job_id
235: from xdp_adapter_admin_reqs
236: where channel_name = DoesSystemReqAlreadyExist.p_ChannelName
237: and request_type = DoesSystemReqAlreadyExist.p_RequestType
238: and requested_by_user = XDP_ADAPTER.pv_adminReqBySystem
239: and request_date <= nvl(p_RequestDate,sysdate);

Line 238: and requested_by_user = XDP_ADAPTER.pv_adminReqBySystem

234: select request_id, job_id
235: from xdp_adapter_admin_reqs
236: where channel_name = DoesSystemReqAlreadyExist.p_ChannelName
237: and request_type = DoesSystemReqAlreadyExist.p_RequestType
238: and requested_by_user = XDP_ADAPTER.pv_adminReqBySystem
239: and request_date <= nvl(p_RequestDate,sysdate);
240:
241: -- l_RequestFound boolean := false;
242: l_JobId number := 0;

Line 260: p_ChannelName := XDP_ADAPTER_CORE_PIPE.GetUniqueChannelName(p_FeName);

256: is
257:
258: begin
259:
260: p_ChannelName := XDP_ADAPTER_CORE_PIPE.GetUniqueChannelName(p_FeName);
261: p_ChannelName := XDP_ADAPTER_CORE_PIPE.ConstructChannelName( 'CONTROL', p_ChannelName);
262:
263: end CreateNewAdapterChannel;
264:

Line 261: p_ChannelName := XDP_ADAPTER_CORE_PIPE.ConstructChannelName( 'CONTROL', p_ChannelName);

257:
258: begin
259:
260: p_ChannelName := XDP_ADAPTER_CORE_PIPE.GetUniqueChannelName(p_FeName);
261: p_ChannelName := XDP_ADAPTER_CORE_PIPE.ConstructChannelName( 'CONTROL', p_ChannelName);
262:
263: end CreateNewAdapterChannel;
264:
265:

Line 274: from xdp_adapter_reg

270: is
271:
272: cursor c_GetAdapter is
273: select fe_id, process_id, service_instance_id
274: from xdp_adapter_reg
275: where channel_name = p_ChannelName;
276:
277: l_Found varchar2(1) := 'N';
278: begin

Line 330: xdp_adapter_types_b xat,

326: xag.log_level,
327: xag.log_file_name,
328: xag.service_instance_id
329: from xdp_fes xfe,
330: xdp_adapter_types_b xat,
331: xdp_adapter_reg xag
332: where xag.channel_name = p_ChannelName
333: and xag.fe_id = xfe.fe_id
334: and xag.adapter_type = xat.adapter_type;

Line 331: xdp_adapter_reg xag

327: xag.log_file_name,
328: xag.service_instance_id
329: from xdp_fes xfe,
330: xdp_adapter_types_b xat,
331: xdp_adapter_reg xag
332: where xag.channel_name = p_ChannelName
333: and xag.fe_id = xfe.fe_id
334: and xag.adapter_type = xat.adapter_type;
335:

Line 409: p_ApplChannelName := XDP_ADAPTER_CORE_PIPE.ConstructChannelName

405: p_CmdArgs := p_CmdArgs || l_SubCmdArgs;
406: end if;
407:
408: if p_ApplMode = 'PIPE' then
409: p_ApplChannelName := XDP_ADAPTER_CORE_PIPE.ConstructChannelName
410: ('APPL', p_ChannelName);
411: elsif p_ApplMode = 'QUEUE' then
412: p_ApplChannelName := pv_OutboundChannelName;
413: else

Line 457: if ((l_Status is not null) and (l_Status = XDP_ADAPTER.pv_statusStoppedError) and

453: begin
454:
455: l_Status := p_Status;
456:
457: if ((l_Status is not null) and (l_Status = XDP_ADAPTER.pv_statusStoppedError) and
458: (Is_Adapter_Automatic(p_ChannelName))) then
459:
460: l_errorCount := XDP_ERRORS_PKG.GET_ERROR_COUNT (
461: p_object_type => XDP_ADAPTER.pv_errorObjectTypeAdapter,

Line 461: p_object_type => XDP_ADAPTER.pv_errorObjectTypeAdapter,

457: if ((l_Status is not null) and (l_Status = XDP_ADAPTER.pv_statusStoppedError) and
458: (Is_Adapter_Automatic(p_ChannelName))) then
459:
460: l_errorCount := XDP_ERRORS_PKG.GET_ERROR_COUNT (
461: p_object_type => XDP_ADAPTER.pv_errorObjectTypeAdapter,
462: p_object_key => p_ChannelName);
463:
464: l_errorCount := l_errorCount + 1;
465:

Line 467: p_object_type => XDP_ADAPTER.pv_errorObjectTypeAdapter,

463:
464: l_errorCount := l_errorCount + 1;
465:
466: XDP_ERRORS_PKG.UPDATE_ERROR_COUNT (
467: p_object_type => XDP_ADAPTER.pv_errorObjectTypeAdapter,
468: p_object_key => p_ChannelName,
469: p_error_count => l_errorCount);
470:
471: if (l_errorCount >= GetAdapterRestartCount()) then

Line 473: l_Status := XDP_ADAPTER.pv_statusDeactivatedSystem;

469: p_error_count => l_errorCount);
470:
471: if (l_errorCount >= GetAdapterRestartCount()) then
472:
473: l_Status := XDP_ADAPTER.pv_statusDeactivatedSystem;
474:
475: if (p_AdapterDispName is null) then
476: select adapter_display_name into l_AdapterDisplayName
477: from xdp_adapter_reg where channel_name = p_ChannelName;

Line 477: from xdp_adapter_reg where channel_name = p_ChannelName;

473: l_Status := XDP_ADAPTER.pv_statusDeactivatedSystem;
474:
475: if (p_AdapterDispName is null) then
476: select adapter_display_name into l_AdapterDisplayName
477: from xdp_adapter_reg where channel_name = p_ChannelName;
478: else
479: l_AdapterDisplayName := p_AdapterDispName;
480: end if;
481:

Line 482: XDP_ADAPTER_CORE.NotifyAdapterSysDeactivation (l_AdapterDisplayName);

478: else
479: l_AdapterDisplayName := p_AdapterDispName;
480: end if;
481:
482: XDP_ADAPTER_CORE.NotifyAdapterSysDeactivation (l_AdapterDisplayName);
483: END IF;
484:
485: END IF;
486:

Line 489: update xdp_adapter_reg

485: END IF;
486:
487: -- status_active_time is updated anytime status is updated
488:
489: update xdp_adapter_reg
490: set adapter_status = nvl(l_Status, adapter_status),
491: status_active_time = decode(l_Status,
492: null, status_active_time,
493: sysdate),

Line 496: XDP_ADAPTER.pv_statusStopped, -1,

492: null, status_active_time,
493: sysdate),
494: process_id = nvl(p_ProcessId,
495: decode(l_Status,
496: XDP_ADAPTER.pv_statusStopped, -1,
497: XDP_ADAPTER.pv_statusStoppedError, -1,
498: XDP_ADAPTER.pv_statusTerminated, -1,
499: XDP_ADAPTER.pv_statusStarting, -1,
500: XDP_ADAPTER.pv_statusDeactivated, -1,

Line 497: XDP_ADAPTER.pv_statusStoppedError, -1,

493: sysdate),
494: process_id = nvl(p_ProcessId,
495: decode(l_Status,
496: XDP_ADAPTER.pv_statusStopped, -1,
497: XDP_ADAPTER.pv_statusStoppedError, -1,
498: XDP_ADAPTER.pv_statusTerminated, -1,
499: XDP_ADAPTER.pv_statusStarting, -1,
500: XDP_ADAPTER.pv_statusDeactivated, -1,
501: XDP_ADAPTER.pv_statusDeactivatedSystem, -1,

Line 498: XDP_ADAPTER.pv_statusTerminated, -1,

494: process_id = nvl(p_ProcessId,
495: decode(l_Status,
496: XDP_ADAPTER.pv_statusStopped, -1,
497: XDP_ADAPTER.pv_statusStoppedError, -1,
498: XDP_ADAPTER.pv_statusTerminated, -1,
499: XDP_ADAPTER.pv_statusStarting, -1,
500: XDP_ADAPTER.pv_statusDeactivated, -1,
501: XDP_ADAPTER.pv_statusDeactivatedSystem, -1,
502: process_id)),

Line 499: XDP_ADAPTER.pv_statusStarting, -1,

495: decode(l_Status,
496: XDP_ADAPTER.pv_statusStopped, -1,
497: XDP_ADAPTER.pv_statusStoppedError, -1,
498: XDP_ADAPTER.pv_statusTerminated, -1,
499: XDP_ADAPTER.pv_statusStarting, -1,
500: XDP_ADAPTER.pv_statusDeactivated, -1,
501: XDP_ADAPTER.pv_statusDeactivatedSystem, -1,
502: process_id)),
503: node = decode(l_Status,

Line 500: XDP_ADAPTER.pv_statusDeactivated, -1,

496: XDP_ADAPTER.pv_statusStopped, -1,
497: XDP_ADAPTER.pv_statusStoppedError, -1,
498: XDP_ADAPTER.pv_statusTerminated, -1,
499: XDP_ADAPTER.pv_statusStarting, -1,
500: XDP_ADAPTER.pv_statusDeactivated, -1,
501: XDP_ADAPTER.pv_statusDeactivatedSystem, -1,
502: process_id)),
503: node = decode(l_Status,
504: XDP_ADAPTER.pv_statusStopped, null,

Line 501: XDP_ADAPTER.pv_statusDeactivatedSystem, -1,

497: XDP_ADAPTER.pv_statusStoppedError, -1,
498: XDP_ADAPTER.pv_statusTerminated, -1,
499: XDP_ADAPTER.pv_statusStarting, -1,
500: XDP_ADAPTER.pv_statusDeactivated, -1,
501: XDP_ADAPTER.pv_statusDeactivatedSystem, -1,
502: process_id)),
503: node = decode(l_Status,
504: XDP_ADAPTER.pv_statusStopped, null,
505: XDP_ADAPTER.pv_statusStoppedError, null,

Line 504: XDP_ADAPTER.pv_statusStopped, null,

500: XDP_ADAPTER.pv_statusDeactivated, -1,
501: XDP_ADAPTER.pv_statusDeactivatedSystem, -1,
502: process_id)),
503: node = decode(l_Status,
504: XDP_ADAPTER.pv_statusStopped, null,
505: XDP_ADAPTER.pv_statusStoppedError, null,
506: XDP_ADAPTER.pv_statusTerminated, null,
507: XDP_ADAPTER.pv_statusDeactivated, null,
508: XDP_ADAPTER.pv_statusDeactivatedSystem, null,

Line 505: XDP_ADAPTER.pv_statusStoppedError, null,

501: XDP_ADAPTER.pv_statusDeactivatedSystem, -1,
502: process_id)),
503: node = decode(l_Status,
504: XDP_ADAPTER.pv_statusStopped, null,
505: XDP_ADAPTER.pv_statusStoppedError, null,
506: XDP_ADAPTER.pv_statusTerminated, null,
507: XDP_ADAPTER.pv_statusDeactivated, null,
508: XDP_ADAPTER.pv_statusDeactivatedSystem, null,
509: node),

Line 506: XDP_ADAPTER.pv_statusTerminated, null,

502: process_id)),
503: node = decode(l_Status,
504: XDP_ADAPTER.pv_statusStopped, null,
505: XDP_ADAPTER.pv_statusStoppedError, null,
506: XDP_ADAPTER.pv_statusTerminated, null,
507: XDP_ADAPTER.pv_statusDeactivated, null,
508: XDP_ADAPTER.pv_statusDeactivatedSystem, null,
509: node),
510: usage_code = nvl(p_UsageCode, usage_code),

Line 507: XDP_ADAPTER.pv_statusDeactivated, null,

503: node = decode(l_Status,
504: XDP_ADAPTER.pv_statusStopped, null,
505: XDP_ADAPTER.pv_statusStoppedError, null,
506: XDP_ADAPTER.pv_statusTerminated, null,
507: XDP_ADAPTER.pv_statusDeactivated, null,
508: XDP_ADAPTER.pv_statusDeactivatedSystem, null,
509: node),
510: usage_code = nvl(p_UsageCode, usage_code),
511: startup_mode = nvl(p_StartupMode, startup_mode),

Line 508: XDP_ADAPTER.pv_statusDeactivatedSystem, null,

504: XDP_ADAPTER.pv_statusStopped, null,
505: XDP_ADAPTER.pv_statusStoppedError, null,
506: XDP_ADAPTER.pv_statusTerminated, null,
507: XDP_ADAPTER.pv_statusDeactivated, null,
508: XDP_ADAPTER.pv_statusDeactivatedSystem, null,
509: node),
510: usage_code = nvl(p_UsageCode, usage_code),
511: startup_mode = nvl(p_StartupMode, startup_mode),
512: adapter_name = nvl(p_AdapterName, adapter_name),

Line 531: XDP_ADAPTER.pv_statusStarting, last_verified_time,

527: 'CmdLineArgs', cmd_line_args,
528: p_CmdLineArgs),
529: last_verified_time = nvl(p_LastVerified,
530: decode(l_Status,
531: XDP_ADAPTER.pv_statusStarting, last_verified_time,
532: XDP_ADAPTER.pv_statusStopping, last_verified_time,
533: XDP_ADAPTER.pv_statusSuspending, last_verified_time,
534: XDP_ADAPTER.pv_statusResuming, last_verified_time,
535: XDP_ADAPTER.pv_statusConnecting, last_verified_time,

Line 532: XDP_ADAPTER.pv_statusStopping, last_verified_time,

528: p_CmdLineArgs),
529: last_verified_time = nvl(p_LastVerified,
530: decode(l_Status,
531: XDP_ADAPTER.pv_statusStarting, last_verified_time,
532: XDP_ADAPTER.pv_statusStopping, last_verified_time,
533: XDP_ADAPTER.pv_statusSuspending, last_verified_time,
534: XDP_ADAPTER.pv_statusResuming, last_verified_time,
535: XDP_ADAPTER.pv_statusConnecting, last_verified_time,
536: XDP_ADAPTER.pv_statusDisconnecting, last_verified_time,

Line 533: XDP_ADAPTER.pv_statusSuspending, last_verified_time,

529: last_verified_time = nvl(p_LastVerified,
530: decode(l_Status,
531: XDP_ADAPTER.pv_statusStarting, last_verified_time,
532: XDP_ADAPTER.pv_statusStopping, last_verified_time,
533: XDP_ADAPTER.pv_statusSuspending, last_verified_time,
534: XDP_ADAPTER.pv_statusResuming, last_verified_time,
535: XDP_ADAPTER.pv_statusConnecting, last_verified_time,
536: XDP_ADAPTER.pv_statusDisconnecting, last_verified_time,
537: XDP_ADAPTER.pv_statusTerminating, last_verified_time,

Line 534: XDP_ADAPTER.pv_statusResuming, last_verified_time,

530: decode(l_Status,
531: XDP_ADAPTER.pv_statusStarting, last_verified_time,
532: XDP_ADAPTER.pv_statusStopping, last_verified_time,
533: XDP_ADAPTER.pv_statusSuspending, last_verified_time,
534: XDP_ADAPTER.pv_statusResuming, last_verified_time,
535: XDP_ADAPTER.pv_statusConnecting, last_verified_time,
536: XDP_ADAPTER.pv_statusDisconnecting, last_verified_time,
537: XDP_ADAPTER.pv_statusTerminating, last_verified_time,
538: sysdate)),

Line 535: XDP_ADAPTER.pv_statusConnecting, last_verified_time,

531: XDP_ADAPTER.pv_statusStarting, last_verified_time,
532: XDP_ADAPTER.pv_statusStopping, last_verified_time,
533: XDP_ADAPTER.pv_statusSuspending, last_verified_time,
534: XDP_ADAPTER.pv_statusResuming, last_verified_time,
535: XDP_ADAPTER.pv_statusConnecting, last_verified_time,
536: XDP_ADAPTER.pv_statusDisconnecting, last_verified_time,
537: XDP_ADAPTER.pv_statusTerminating, last_verified_time,
538: sysdate)),
539: log_level = nvl(p_LogLevel, log_level),

Line 536: XDP_ADAPTER.pv_statusDisconnecting, last_verified_time,

532: XDP_ADAPTER.pv_statusStopping, last_verified_time,
533: XDP_ADAPTER.pv_statusSuspending, last_verified_time,
534: XDP_ADAPTER.pv_statusResuming, last_verified_time,
535: XDP_ADAPTER.pv_statusConnecting, last_verified_time,
536: XDP_ADAPTER.pv_statusDisconnecting, last_verified_time,
537: XDP_ADAPTER.pv_statusTerminating, last_verified_time,
538: sysdate)),
539: log_level = nvl(p_LogLevel, log_level),
540: log_file_name = decode(p_LogFileName,

Line 537: XDP_ADAPTER.pv_statusTerminating, last_verified_time,

533: XDP_ADAPTER.pv_statusSuspending, last_verified_time,
534: XDP_ADAPTER.pv_statusResuming, last_verified_time,
535: XDP_ADAPTER.pv_statusConnecting, last_verified_time,
536: XDP_ADAPTER.pv_statusDisconnecting, last_verified_time,
537: XDP_ADAPTER.pv_statusTerminating, last_verified_time,
538: sysdate)),
539: log_level = nvl(p_LogLevel, log_level),
540: log_file_name = decode(p_LogFileName,
541: 'LogFileName', log_file_name,

Line 559: UPDATE xdp_adapter_reg

555: Procedure Update_Adapter_Active_Time(p_ChannelName IN VARCHAR2)
556: IS
557:
558: BEGIN
559: UPDATE xdp_adapter_reg
560: SET status_active_time = sysdate,
561: last_update_date = sysdate,
562: last_updated_by = fnd_global.user_id,
563: last_update_login = fnd_global.login_id

Line 576: FROM xdp_adapter_reg a,

572:
573:
574: CURSOR c_GetASyncAdapterStatus IS
575: SELECT a.adapter_status
576: FROM xdp_adapter_reg a,
577: xdp_adapter_types_b b
578: WHERE a.adapter_type = b.adapter_type AND
579: a.fe_id = p_fe_id AND
580: (b.application_mode = 'QUEUE' OR

Line 577: xdp_adapter_types_b b

573:
574: CURSOR c_GetASyncAdapterStatus IS
575: SELECT a.adapter_status
576: FROM xdp_adapter_reg a,
577: xdp_adapter_types_b b
578: WHERE a.adapter_type = b.adapter_type AND
579: a.fe_id = p_fe_id AND
580: (b.application_mode = 'QUEUE' OR
581: (b.application_mode = 'NONE' AND b.inbound_required_flag = 'Y'));

Line 585: FROM xdp_adapter_reg a,

581: (b.application_mode = 'NONE' AND b.inbound_required_flag = 'Y'));
582:
583: CURSOR c_GetSyncAdapterStatus IS
584: SELECT a.adapter_status
585: FROM xdp_adapter_reg a,
586: xdp_adapter_types_b b
587: WHERE a.adapter_type = b.adapter_type AND
588: a.fe_id = p_fe_id AND
589: NOT(b.application_mode = 'QUEUE' OR

Line 586: xdp_adapter_types_b b

582:
583: CURSOR c_GetSyncAdapterStatus IS
584: SELECT a.adapter_status
585: FROM xdp_adapter_reg a,
586: xdp_adapter_types_b b
587: WHERE a.adapter_type = b.adapter_type AND
588: a.fe_id = p_fe_id AND
589: NOT(b.application_mode = 'QUEUE' OR
590: (b.application_mode = 'NONE' AND b.inbound_required_flag = 'Y'));

Line 601: IF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusError, XDP_ADAPTER.pv_statusSessionLost, XDP_ADAPTER.pv_statusStoppedError, XDP_ADAPTER.pv_statusTerminated)

597: IF p_mode = 'ASYNC' THEN
598:
599: FOR v_GetAdapterStatus IN c_GetAsyncAdapterStatus LOOP
600:
601: IF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusError, XDP_ADAPTER.pv_statusSessionLost, XDP_ADAPTER.pv_statusStoppedError, XDP_ADAPTER.pv_statusTerminated)
602: THEN
603: l_fe_status := XDP_ADAPTER.pv_rolledStatusError;
604: RETURN l_fe_status;
605: ELSIF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusInUse, XDP_ADAPTER.pv_statusRunning, XDP_ADAPTER.pv_statusDisconnected, XDP_ADAPTER.pv_statusSuspended)

Line 603: l_fe_status := XDP_ADAPTER.pv_rolledStatusError;

599: FOR v_GetAdapterStatus IN c_GetAsyncAdapterStatus LOOP
600:
601: IF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusError, XDP_ADAPTER.pv_statusSessionLost, XDP_ADAPTER.pv_statusStoppedError, XDP_ADAPTER.pv_statusTerminated)
602: THEN
603: l_fe_status := XDP_ADAPTER.pv_rolledStatusError;
604: RETURN l_fe_status;
605: ELSIF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusInUse, XDP_ADAPTER.pv_statusRunning, XDP_ADAPTER.pv_statusDisconnected, XDP_ADAPTER.pv_statusSuspended)
606: THEN
607: l_match_found := TRUE;

Line 605: ELSIF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusInUse, XDP_ADAPTER.pv_statusRunning, XDP_ADAPTER.pv_statusDisconnected, XDP_ADAPTER.pv_statusSuspended)

601: IF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusError, XDP_ADAPTER.pv_statusSessionLost, XDP_ADAPTER.pv_statusStoppedError, XDP_ADAPTER.pv_statusTerminated)
602: THEN
603: l_fe_status := XDP_ADAPTER.pv_rolledStatusError;
604: RETURN l_fe_status;
605: ELSIF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusInUse, XDP_ADAPTER.pv_statusRunning, XDP_ADAPTER.pv_statusDisconnected, XDP_ADAPTER.pv_statusSuspended)
606: THEN
607: l_match_found := TRUE;
608: exit;
609: END IF;

Line 616: IF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusError, XDP_ADAPTER.pv_statusSessionLost, XDP_ADAPTER.pv_statusStoppedError, XDP_ADAPTER.pv_statusTerminated)

612: ELSE
613:
614: FOR v_GetAdapterStatus IN c_GetSyncAdapterStatus LOOP
615:
616: IF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusError, XDP_ADAPTER.pv_statusSessionLost, XDP_ADAPTER.pv_statusStoppedError, XDP_ADAPTER.pv_statusTerminated)
617: THEN
618: l_fe_status := XDP_ADAPTER.pv_rolledStatusError;
619: RETURN l_fe_status;
620: ELSIF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusInUse, XDP_ADAPTER.pv_statusRunning, XDP_ADAPTER.pv_statusDisconnected, XDP_ADAPTER.pv_statusSuspended)

Line 618: l_fe_status := XDP_ADAPTER.pv_rolledStatusError;

614: FOR v_GetAdapterStatus IN c_GetSyncAdapterStatus LOOP
615:
616: IF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusError, XDP_ADAPTER.pv_statusSessionLost, XDP_ADAPTER.pv_statusStoppedError, XDP_ADAPTER.pv_statusTerminated)
617: THEN
618: l_fe_status := XDP_ADAPTER.pv_rolledStatusError;
619: RETURN l_fe_status;
620: ELSIF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusInUse, XDP_ADAPTER.pv_statusRunning, XDP_ADAPTER.pv_statusDisconnected, XDP_ADAPTER.pv_statusSuspended)
621: THEN
622: l_match_found := TRUE;

Line 620: ELSIF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusInUse, XDP_ADAPTER.pv_statusRunning, XDP_ADAPTER.pv_statusDisconnected, XDP_ADAPTER.pv_statusSuspended)

616: IF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusError, XDP_ADAPTER.pv_statusSessionLost, XDP_ADAPTER.pv_statusStoppedError, XDP_ADAPTER.pv_statusTerminated)
617: THEN
618: l_fe_status := XDP_ADAPTER.pv_rolledStatusError;
619: RETURN l_fe_status;
620: ELSIF v_GetAdapterStatus.adapter_status IN (XDP_ADAPTER.pv_statusInUse, XDP_ADAPTER.pv_statusRunning, XDP_ADAPTER.pv_statusDisconnected, XDP_ADAPTER.pv_statusSuspended)
621: THEN
622: l_match_found := TRUE;
623: exit;
624: END IF;

Line 630: l_fe_status := XDP_ADAPTER.pv_rolledStatusRunning;

626:
627: END IF;
628:
629: IF l_match_found THEN
630: l_fe_status := XDP_ADAPTER.pv_rolledStatusRunning;
631: RETURN l_fe_status;
632: ELSE
633: l_fe_status := XDP_ADAPTER.pv_rolledStatusUnavailable;
634: RETURN l_fe_status;

Line 633: l_fe_status := XDP_ADAPTER.pv_rolledStatusUnavailable;

629: IF l_match_found THEN
630: l_fe_status := XDP_ADAPTER.pv_rolledStatusRunning;
631: RETURN l_fe_status;
632: ELSE
633: l_fe_status := XDP_ADAPTER.pv_rolledStatusUnavailable;
634: RETURN l_fe_status;
635: END IF;
636: END GetOAMFERolledStatus;
637:

Line 653: FROM xdp_adapter_reg a, xdp_adapter_types_b b

649: IF p_mode = 'ASYNC' THEN
650:
651: SELECT count(*)
652: INTO l_adapter_status_cnt
653: FROM xdp_adapter_reg a, xdp_adapter_types_b b
654: WHERE a.adapter_type = b.adapter_type
655: AND a.fe_id = p_fe_id
656: AND (b.application_mode = 'QUEUE' OR
657: (b.application_mode = 'NONE' AND b.inbound_required_flag = 'Y'))

Line 658: AND a.adapter_status IN (XDP_ADAPTER.pv_statusInUse, XDP_ADAPTER.pv_statusRunning);

654: WHERE a.adapter_type = b.adapter_type
655: AND a.fe_id = p_fe_id
656: AND (b.application_mode = 'QUEUE' OR
657: (b.application_mode = 'NONE' AND b.inbound_required_flag = 'Y'))
658: AND a.adapter_status IN (XDP_ADAPTER.pv_statusInUse, XDP_ADAPTER.pv_statusRunning);
659:
660: ELSE
661:
662: SELECT count(*)

Line 664: FROM xdp_adapter_reg a, xdp_adapter_types_b b

660: ELSE
661:
662: SELECT count(*)
663: INTO l_adapter_status_cnt
664: FROM xdp_adapter_reg a, xdp_adapter_types_b b
665: WHERE a.adapter_type = b.adapter_type
666: AND a.fe_id = p_fe_id
667: AND NOT(b.application_mode = 'QUEUE' OR
668: (b.application_mode = 'NONE' AND b.inbound_required_flag = 'Y'))

Line 669: AND a.adapter_status IN (XDP_ADAPTER.pv_statusInUse, XDP_ADAPTER.pv_statusRunning);

665: WHERE a.adapter_type = b.adapter_type
666: AND a.fe_id = p_fe_id
667: AND NOT(b.application_mode = 'QUEUE' OR
668: (b.application_mode = 'NONE' AND b.inbound_required_flag = 'Y'))
669: AND a.adapter_status IN (XDP_ADAPTER.pv_statusInUse, XDP_ADAPTER.pv_statusRunning);
670:
671: END IF;
672:
673: RETURN l_adapter_status_cnt;

Line 698: FROM xdp_adapter_job_queue xaj, xdp_adapter_reg xar, xdp_adapter_types_b xat

694: else
695:
696: SELECT COUNT(DISTINCT xaj.job_id) num_of_jobs
697: INTO l_num_of_job_cnt
698: FROM xdp_adapter_job_queue xaj, xdp_adapter_reg xar, xdp_adapter_types_b xat
699: WHERE xaj.fe_id = xar.fe_id
700: AND xar.adapter_type = xat.adapter_type
701: AND xaj.fe_id = p_fe_id
702: AND xat.application_mode <> 'QUEUE';

Line 716: from xdp_adapter_reg xag

712: Function GetCurrentAdapterStatus(p_ChannelName in varchar2) return varchar2
713: is
714: cursor c_GetAdapterStatus is
715: select xag.adapter_status
716: from xdp_adapter_reg xag
717: where channel_name = p_ChannelName;
718:
719: l_CurrentAdapterStatus varchar2(40);
720: l_exists varchar2(1) := 'N';

Line 779: select node into l_InstanceName from xdp_adapter_reg where channel_name = l_ChannelName;

775: ELSE
776: l_ChannelName := p_ChannelName;
777: END IF;
778:
779: select node into l_InstanceName from xdp_adapter_reg where channel_name = l_ChannelName;
780: --Adapter is running on different instance than this session
781: if l_InstanceName is not null and l_InstanceName <> pv_InstanceName then
782: l_LockFlag := ReleaseAdapterLock(p_ChannelName => p_ChannelName);
783: l_LockFlag := 'N';

Line 809: update xdp_adapter_reg set node = pv_InstanceName where channel_name = l_ChannelName;

805: ELSE
806: l_ChannelName := p_ChannelName;
807: END IF;
808:
809: update xdp_adapter_reg set node = pv_InstanceName where channel_name = l_ChannelName;
810: commit;
811: end if;
812:
813: return l_LockFlag;

Line 842: from xdp_adapter_reg

838: l_CODFlag varchar2(1) := 'N';
839: begin
840:
841: select NVL(CONNECT_ON_DEMAND_FLAG, 'N') into l_CODFlag
842: from xdp_adapter_reg
843: where CHANNEL_NAME = p_ChannelName;
844:
845: return (l_CODFlag);
846:

Line 859: ( select JOB_ID from xdp_adapter_job_queue a, xdp_adapter_reg b

855: begin
856: select 'Y' into l_check
857: from dual
858: where exists
859: ( select JOB_ID from xdp_adapter_job_queue a, xdp_adapter_reg b
860: where b.channel_name = p_ChannelName
861: and b.fe_id = a.fe_id);
862: exception
863: when no_data_found then

Line 912: if fnd_profile.defined('XDP_ADAPTER_LOCK_TIMEOUT') then

908: is
909: l_ProfileValue varchar2(40);
910: begin
911: -- 1 hr = 60 * 60 = 3600 secs
912: if fnd_profile.defined('XDP_ADAPTER_LOCK_TIMEOUT') then
913: fnd_profile.get('XDP_ADAPTER_LOCK_TIMEOUT', l_ProfileValue);
914: if to_number(l_ProfileValue) <= 0 then
915: l_ProfileValue := '3600';
916: end if;

Line 913: fnd_profile.get('XDP_ADAPTER_LOCK_TIMEOUT', l_ProfileValue);

909: l_ProfileValue varchar2(40);
910: begin
911: -- 1 hr = 60 * 60 = 3600 secs
912: if fnd_profile.defined('XDP_ADAPTER_LOCK_TIMEOUT') then
913: fnd_profile.get('XDP_ADAPTER_LOCK_TIMEOUT', l_ProfileValue);
914: if to_number(l_ProfileValue) <= 0 then
915: l_ProfileValue := '3600';
916: end if;
917: else

Line 942: p_object_type => XDP_ADAPTER.pv_errorObjectTypeAdapter,

938: p_WFItemKey => p_WFItemKey
939: );
940: if p_ErrorMsg is not null then
941: XDP_ERRORS_PKG.Set_Message (
942: p_object_type => XDP_ADAPTER.pv_errorObjectTypeAdapter,
943: p_object_key => p_ChannelName,
944: p_message_name => p_ErrorMsg,
945: p_message_parameters => p_ErrorMsgParams);
946: end if;

Line 954: from xdp_adapter_admin_reqs

950: Function Get_Job_Id_For_Request (p_RequestId in number) return number
951: is
952: cursor c_GetJobID is
953: select job_id
954: from xdp_adapter_admin_reqs
955: where request_id = p_RequestId;
956:
957: l_JobId number := -1;
958:

Line 1008: from XDP_ADAPTER_REG

1004: l_MaxCount number := 0;
1005: begin
1006: select count(*)
1007: into l_CurrentCount
1008: from XDP_ADAPTER_REG
1009: where FE_ID = p_fe_id and
1010: ADAPTER_STATUS not in (XDP_ADAPTER.pv_statusStopped,
1011: XDP_ADAPTER.pv_statusStoppedError,
1012: XDP_ADAPTER.pv_statusTerminated,

Line 1010: ADAPTER_STATUS not in (XDP_ADAPTER.pv_statusStopped,

1006: select count(*)
1007: into l_CurrentCount
1008: from XDP_ADAPTER_REG
1009: where FE_ID = p_fe_id and
1010: ADAPTER_STATUS not in (XDP_ADAPTER.pv_statusStopped,
1011: XDP_ADAPTER.pv_statusStoppedError,
1012: XDP_ADAPTER.pv_statusTerminated,
1013: -- (ankung) XDP_ADAPTER.pv_statusStopping,
1014: -- XDP_ADAPTER.pv_statusTerminating,

Line 1011: XDP_ADAPTER.pv_statusStoppedError,

1007: into l_CurrentCount
1008: from XDP_ADAPTER_REG
1009: where FE_ID = p_fe_id and
1010: ADAPTER_STATUS not in (XDP_ADAPTER.pv_statusStopped,
1011: XDP_ADAPTER.pv_statusStoppedError,
1012: XDP_ADAPTER.pv_statusTerminated,
1013: -- (ankung) XDP_ADAPTER.pv_statusStopping,
1014: -- XDP_ADAPTER.pv_statusTerminating,
1015: XDP_ADAPTER.pv_statusNotAvailable,

Line 1012: XDP_ADAPTER.pv_statusTerminated,

1008: from XDP_ADAPTER_REG
1009: where FE_ID = p_fe_id and
1010: ADAPTER_STATUS not in (XDP_ADAPTER.pv_statusStopped,
1011: XDP_ADAPTER.pv_statusStoppedError,
1012: XDP_ADAPTER.pv_statusTerminated,
1013: -- (ankung) XDP_ADAPTER.pv_statusStopping,
1014: -- XDP_ADAPTER.pv_statusTerminating,
1015: XDP_ADAPTER.pv_statusNotAvailable,
1016: XDP_ADAPTER.pv_statusDeactivated,

Line 1013: -- (ankung) XDP_ADAPTER.pv_statusStopping,

1009: where FE_ID = p_fe_id and
1010: ADAPTER_STATUS not in (XDP_ADAPTER.pv_statusStopped,
1011: XDP_ADAPTER.pv_statusStoppedError,
1012: XDP_ADAPTER.pv_statusTerminated,
1013: -- (ankung) XDP_ADAPTER.pv_statusStopping,
1014: -- XDP_ADAPTER.pv_statusTerminating,
1015: XDP_ADAPTER.pv_statusNotAvailable,
1016: XDP_ADAPTER.pv_statusDeactivated,
1017: XDP_ADAPTER.pv_statusDeactivatedSystem);

Line 1014: -- XDP_ADAPTER.pv_statusTerminating,

1010: ADAPTER_STATUS not in (XDP_ADAPTER.pv_statusStopped,
1011: XDP_ADAPTER.pv_statusStoppedError,
1012: XDP_ADAPTER.pv_statusTerminated,
1013: -- (ankung) XDP_ADAPTER.pv_statusStopping,
1014: -- XDP_ADAPTER.pv_statusTerminating,
1015: XDP_ADAPTER.pv_statusNotAvailable,
1016: XDP_ADAPTER.pv_statusDeactivated,
1017: XDP_ADAPTER.pv_statusDeactivatedSystem);
1018:

Line 1015: XDP_ADAPTER.pv_statusNotAvailable,

1011: XDP_ADAPTER.pv_statusStoppedError,
1012: XDP_ADAPTER.pv_statusTerminated,
1013: -- (ankung) XDP_ADAPTER.pv_statusStopping,
1014: -- XDP_ADAPTER.pv_statusTerminating,
1015: XDP_ADAPTER.pv_statusNotAvailable,
1016: XDP_ADAPTER.pv_statusDeactivated,
1017: XDP_ADAPTER.pv_statusDeactivatedSystem);
1018:
1019: select MAX_CONNECTION

Line 1016: XDP_ADAPTER.pv_statusDeactivated,

1012: XDP_ADAPTER.pv_statusTerminated,
1013: -- (ankung) XDP_ADAPTER.pv_statusStopping,
1014: -- XDP_ADAPTER.pv_statusTerminating,
1015: XDP_ADAPTER.pv_statusNotAvailable,
1016: XDP_ADAPTER.pv_statusDeactivated,
1017: XDP_ADAPTER.pv_statusDeactivatedSystem);
1018:
1019: select MAX_CONNECTION
1020: into l_MaxCount

Line 1017: XDP_ADAPTER.pv_statusDeactivatedSystem);

1013: -- (ankung) XDP_ADAPTER.pv_statusStopping,
1014: -- XDP_ADAPTER.pv_statusTerminating,
1015: XDP_ADAPTER.pv_statusNotAvailable,
1016: XDP_ADAPTER.pv_statusDeactivated,
1017: XDP_ADAPTER.pv_statusDeactivatedSystem);
1018:
1019: select MAX_CONNECTION
1020: into l_MaxCount
1021: from XDP_FES

Line 1039: from xdp_adapter_admin_reqs xar

1035: IS
1036:
1037: cursor c_GetAdapterAdminReqs is
1038: select xar.request_id
1039: from xdp_adapter_admin_reqs xar
1040: where channel_name = p_channel_name;
1041:
1042: BEGIN
1043: -- Cleanup XDP_ERROR_LOG

Line 1046: object_type = XDP_ADAPTER.pv_errorObjectTypeAdapter and

1042: BEGIN
1043: -- Cleanup XDP_ERROR_LOG
1044: BEGIN
1045: DELETE FROM xdp_error_log WHERE
1046: object_type = XDP_ADAPTER.pv_errorObjectTypeAdapter and
1047: object_key = p_channel_name;
1048: EXCEPTION
1049: -- Not an error if no errors exists for the adapter
1050: --

Line 1057: DELETE FROM xdp_adapter_audit WHERE channel_name = p_channel_name;

1053: END;
1054:
1055: -- Cleanup request audit table
1056: BEGIN
1057: DELETE FROM xdp_adapter_audit WHERE channel_name = p_channel_name;
1058: EXCEPTION
1059: -- Not an error if no rows exist in audit table
1060: --
1061: WHEN NO_DATA_FOUND THEN

Line 1066: -- XDP_ADAPTER_ADMIN_REQS table if present

1062: NULL;
1063: END;
1064:
1065: -- Delete all occurences of the requests and dbms_jobs for the adapter from the
1066: -- XDP_ADAPTER_ADMIN_REQS table if present
1067: --
1068: for v_AdapterReq in c_GetAdapterAdminReqs loop
1069: RemoveAdapterAdminReq (p_RequestID => v_AdapterReq.request_id);
1070: END LOOP;

Line 1072: -- Delete the Adapter from the XDP_ADAPTER_REG table

1068: for v_AdapterReq in c_GetAdapterAdminReqs loop
1069: RemoveAdapterAdminReq (p_RequestID => v_AdapterReq.request_id);
1070: END LOOP;
1071:
1072: -- Delete the Adapter from the XDP_ADAPTER_REG table
1073: --
1074: DELETE FROM xdp_adapter_reg WHERE channel_name = p_channel_name;
1075:
1076: END Delete_Adapter;

Line 1074: DELETE FROM xdp_adapter_reg WHERE channel_name = p_channel_name;

1070: END LOOP;
1071:
1072: -- Delete the Adapter from the XDP_ADAPTER_REG table
1073: --
1074: DELETE FROM xdp_adapter_reg WHERE channel_name = p_channel_name;
1075:
1076: END Delete_Adapter;
1077:
1078: --

Line 1086: from xdp_adapter_reg

1082: IS
1083:
1084: cursor c_GetAdapters is
1085: select channel_name
1086: from xdp_adapter_reg
1087: where fe_id = p_fe_id;
1088:
1089: BEGIN
1090: -- Delete all adapters belonging to the FE, if present

Line 1120: xdp_adapter_reg xag

1116: xag.cmd_line_args,
1117: xag.log_level,
1118: xag.log_file_name
1119: from
1120: xdp_adapter_reg xag
1121: where xag.channel_name = p_ChannelName;
1122:
1123: l_AdapterName varchar2(40);
1124: l_AdapterStatus varchar2(40);

Line 1151: insert into xdp_adapter_audit (

1147:
1148: exit;
1149: end loop;
1150:
1151: insert into xdp_adapter_audit (
1152: adapter_audit_id,
1153: channel_name,
1154: request_type,
1155: request_status,

Line 1174: ( XDP_ADAPTER_AUDIT_S.NEXTVAL,

1170: last_updated_by,
1171: last_update_date,
1172: last_update_login)
1173: values
1174: ( XDP_ADAPTER_AUDIT_S.NEXTVAL,
1175: p_ChannelName,
1176: p_RequestType,
1177: p_RequestStatus,
1178: sysdate,

Line 1189: XDP_ADAPTER.pv_AppID,

1185: l_MaxIdleTime,
1186: l_CmdOptions,
1187: l_CmdArgs,
1188: l_LogFileName,
1189: XDP_ADAPTER.pv_AppID,
1190: FND_GLOBAL.USER_ID,
1191: sysdate,
1192: FND_GLOBAL.USER_ID,
1193: sysdate,

Line 1237: FROM xdp_adapter_reg xad, xdp_adapter_types_b t,xdp_fes XFE

1233: --
1234:
1235: cursor c_getadapter IS
1236: SELECT xad.adapter_name
1237: FROM xdp_adapter_reg xad, xdp_adapter_types_b t,xdp_fes XFE
1238: WHERE XAD.fe_id = XFE.fe_id
1239: AND XFE.fulfillment_element_name = p_fe_name
1240: AND xad.adapter_type = t.adapter_type
1241: AND application_mode='QUEUE'

Line 1242: AND xad.adapter_status not in (XDP_ADAPTER.pv_statusNotAvailable)

1238: WHERE XAD.fe_id = XFE.fe_id
1239: AND XFE.fulfillment_element_name = p_fe_name
1240: AND xad.adapter_type = t.adapter_type
1241: AND application_mode='QUEUE'
1242: AND xad.adapter_status not in (XDP_ADAPTER.pv_statusNotAvailable)
1243: ORDER BY
1244: DECODE(adapter_status, xdp_adapter.pv_statusRunning, 1,
1245: xdp_adapter.pv_statusSuspended, 2,
1246: xdp_adapter.pv_statusDisconnected, 3,

Line 1244: DECODE(adapter_status, xdp_adapter.pv_statusRunning, 1,

1240: AND xad.adapter_type = t.adapter_type
1241: AND application_mode='QUEUE'
1242: AND xad.adapter_status not in (XDP_ADAPTER.pv_statusNotAvailable)
1243: ORDER BY
1244: DECODE(adapter_status, xdp_adapter.pv_statusRunning, 1,
1245: xdp_adapter.pv_statusSuspended, 2,
1246: xdp_adapter.pv_statusDisconnected, 3,
1247: xdp_adapter.pv_statusStopped, 4, 5)
1248: ASC ;

Line 1245: xdp_adapter.pv_statusSuspended, 2,

1241: AND application_mode='QUEUE'
1242: AND xad.adapter_status not in (XDP_ADAPTER.pv_statusNotAvailable)
1243: ORDER BY
1244: DECODE(adapter_status, xdp_adapter.pv_statusRunning, 1,
1245: xdp_adapter.pv_statusSuspended, 2,
1246: xdp_adapter.pv_statusDisconnected, 3,
1247: xdp_adapter.pv_statusStopped, 4, 5)
1248: ASC ;
1249:

Line 1246: xdp_adapter.pv_statusDisconnected, 3,

1242: AND xad.adapter_status not in (XDP_ADAPTER.pv_statusNotAvailable)
1243: ORDER BY
1244: DECODE(adapter_status, xdp_adapter.pv_statusRunning, 1,
1245: xdp_adapter.pv_statusSuspended, 2,
1246: xdp_adapter.pv_statusDisconnected, 3,
1247: xdp_adapter.pv_statusStopped, 4, 5)
1248: ASC ;
1249:
1250: BEGIN

Line 1247: xdp_adapter.pv_statusStopped, 4, 5)

1243: ORDER BY
1244: DECODE(adapter_status, xdp_adapter.pv_statusRunning, 1,
1245: xdp_adapter.pv_statusSuspended, 2,
1246: xdp_adapter.pv_statusDisconnected, 3,
1247: xdp_adapter.pv_statusStopped, 4, 5)
1248: ASC ;
1249:
1250: BEGIN
1251: if c_getadapter%ISOPEN then

Line 1281: FROM xdp_adapter_reg xad, xdp_adapter_types_b t

1277: l_adapter_name varchar2(80) := NULL;
1278:
1279: cursor c_getadapter(FEID number) is
1280: SELECT xad.adapter_name
1281: FROM xdp_adapter_reg xad, xdp_adapter_types_b t
1282: WHERE xad.adapter_type = t.adapter_type
1283: AND FE_ID = FEID
1284: AND application_mode='QUEUE'
1285: AND xad.adapter_status not in (XDP_ADAPTER.pv_statusNotAvailable)

Line 1285: AND xad.adapter_status not in (XDP_ADAPTER.pv_statusNotAvailable)

1281: FROM xdp_adapter_reg xad, xdp_adapter_types_b t
1282: WHERE xad.adapter_type = t.adapter_type
1283: AND FE_ID = FEID
1284: AND application_mode='QUEUE'
1285: AND xad.adapter_status not in (XDP_ADAPTER.pv_statusNotAvailable)
1286: order by
1287: DECODE(adapter_status, xdp_adapter.pv_statusRunning, 1,
1288: xdp_adapter.pv_statusSuspended, 2,
1289: xdp_adapter.pv_statusDisconnected, 3,

Line 1287: DECODE(adapter_status, xdp_adapter.pv_statusRunning, 1,

1283: AND FE_ID = FEID
1284: AND application_mode='QUEUE'
1285: AND xad.adapter_status not in (XDP_ADAPTER.pv_statusNotAvailable)
1286: order by
1287: DECODE(adapter_status, xdp_adapter.pv_statusRunning, 1,
1288: xdp_adapter.pv_statusSuspended, 2,
1289: xdp_adapter.pv_statusDisconnected, 3,
1290: xdp_adapter.pv_statusStopped, 4, 5)
1291: ASC ;

Line 1288: xdp_adapter.pv_statusSuspended, 2,

1284: AND application_mode='QUEUE'
1285: AND xad.adapter_status not in (XDP_ADAPTER.pv_statusNotAvailable)
1286: order by
1287: DECODE(adapter_status, xdp_adapter.pv_statusRunning, 1,
1288: xdp_adapter.pv_statusSuspended, 2,
1289: xdp_adapter.pv_statusDisconnected, 3,
1290: xdp_adapter.pv_statusStopped, 4, 5)
1291: ASC ;
1292:

Line 1289: xdp_adapter.pv_statusDisconnected, 3,

1285: AND xad.adapter_status not in (XDP_ADAPTER.pv_statusNotAvailable)
1286: order by
1287: DECODE(adapter_status, xdp_adapter.pv_statusRunning, 1,
1288: xdp_adapter.pv_statusSuspended, 2,
1289: xdp_adapter.pv_statusDisconnected, 3,
1290: xdp_adapter.pv_statusStopped, 4, 5)
1291: ASC ;
1292:
1293: BEGIN

Line 1290: xdp_adapter.pv_statusStopped, 4, 5)

1286: order by
1287: DECODE(adapter_status, xdp_adapter.pv_statusRunning, 1,
1288: xdp_adapter.pv_statusSuspended, 2,
1289: xdp_adapter.pv_statusDisconnected, 3,
1290: xdp_adapter.pv_statusStopped, 4, 5)
1291: ASC ;
1292:
1293: BEGIN
1294:

Line 1332: from XDP_ADAPTER_REG

1328: select 'Y' yahoo
1329: from dual
1330: where exists(
1331: select 1
1332: from XDP_ADAPTER_REG
1333: where fe_id = p_fe_id
1334: and adapter_status not in (XDP_ADAPTER.pv_statusStopped,
1335: XDP_ADAPTER.pv_statusStoppedError,
1336: XDP_ADAPTER.pv_statusTerminated,

Line 1334: and adapter_status not in (XDP_ADAPTER.pv_statusStopped,

1330: where exists(
1331: select 1
1332: from XDP_ADAPTER_REG
1333: where fe_id = p_fe_id
1334: and adapter_status not in (XDP_ADAPTER.pv_statusStopped,
1335: XDP_ADAPTER.pv_statusStoppedError,
1336: XDP_ADAPTER.pv_statusTerminated,
1337: XDP_ADAPTER.pv_statusNotAvailable,
1338: XDP_ADAPTER.pv_statusDeactivated,

Line 1335: XDP_ADAPTER.pv_statusStoppedError,

1331: select 1
1332: from XDP_ADAPTER_REG
1333: where fe_id = p_fe_id
1334: and adapter_status not in (XDP_ADAPTER.pv_statusStopped,
1335: XDP_ADAPTER.pv_statusStoppedError,
1336: XDP_ADAPTER.pv_statusTerminated,
1337: XDP_ADAPTER.pv_statusNotAvailable,
1338: XDP_ADAPTER.pv_statusDeactivated,
1339: XDP_ADAPTER.pv_statusDeactivatedSystem)

Line 1336: XDP_ADAPTER.pv_statusTerminated,

1332: from XDP_ADAPTER_REG
1333: where fe_id = p_fe_id
1334: and adapter_status not in (XDP_ADAPTER.pv_statusStopped,
1335: XDP_ADAPTER.pv_statusStoppedError,
1336: XDP_ADAPTER.pv_statusTerminated,
1337: XDP_ADAPTER.pv_statusNotAvailable,
1338: XDP_ADAPTER.pv_statusDeactivated,
1339: XDP_ADAPTER.pv_statusDeactivatedSystem)
1340: );

Line 1337: XDP_ADAPTER.pv_statusNotAvailable,

1333: where fe_id = p_fe_id
1334: and adapter_status not in (XDP_ADAPTER.pv_statusStopped,
1335: XDP_ADAPTER.pv_statusStoppedError,
1336: XDP_ADAPTER.pv_statusTerminated,
1337: XDP_ADAPTER.pv_statusNotAvailable,
1338: XDP_ADAPTER.pv_statusDeactivated,
1339: XDP_ADAPTER.pv_statusDeactivatedSystem)
1340: );
1341: BEGIN

Line 1338: XDP_ADAPTER.pv_statusDeactivated,

1334: and adapter_status not in (XDP_ADAPTER.pv_statusStopped,
1335: XDP_ADAPTER.pv_statusStoppedError,
1336: XDP_ADAPTER.pv_statusTerminated,
1337: XDP_ADAPTER.pv_statusNotAvailable,
1338: XDP_ADAPTER.pv_statusDeactivated,
1339: XDP_ADAPTER.pv_statusDeactivatedSystem)
1340: );
1341: BEGIN
1342: for v_IsAdapterRunning in c_IsAdapterRunning loop

Line 1339: XDP_ADAPTER.pv_statusDeactivatedSystem)

1335: XDP_ADAPTER.pv_statusStoppedError,
1336: XDP_ADAPTER.pv_statusTerminated,
1337: XDP_ADAPTER.pv_statusNotAvailable,
1338: XDP_ADAPTER.pv_statusDeactivated,
1339: XDP_ADAPTER.pv_statusDeactivatedSystem)
1340: );
1341: BEGIN
1342: for v_IsAdapterRunning in c_IsAdapterRunning loop
1343: lv_exists := v_IsAdapterRunning.yahoo;

Line 1369: from XDP_ADAPTER_REG arn, XDP_FES fet

1365: select 'Y' yahoo
1366: from dual
1367: where exists(
1368: select 1
1369: from XDP_ADAPTER_REG arn, XDP_FES fet
1370: where arn.fe_id = fet.fe_id
1371: and fet.fetype_id = p_fetype_id
1372: and arn.adapter_status not in (XDP_ADAPTER.pv_statusStopped,
1373: XDP_ADAPTER.pv_statusStoppedError,

Line 1372: and arn.adapter_status not in (XDP_ADAPTER.pv_statusStopped,

1368: select 1
1369: from XDP_ADAPTER_REG arn, XDP_FES fet
1370: where arn.fe_id = fet.fe_id
1371: and fet.fetype_id = p_fetype_id
1372: and arn.adapter_status not in (XDP_ADAPTER.pv_statusStopped,
1373: XDP_ADAPTER.pv_statusStoppedError,
1374: XDP_ADAPTER.pv_statusTerminated,
1375: XDP_ADAPTER.pv_statusNotAvailable,
1376: XDP_ADAPTER.pv_statusDeactivated,

Line 1373: XDP_ADAPTER.pv_statusStoppedError,

1369: from XDP_ADAPTER_REG arn, XDP_FES fet
1370: where arn.fe_id = fet.fe_id
1371: and fet.fetype_id = p_fetype_id
1372: and arn.adapter_status not in (XDP_ADAPTER.pv_statusStopped,
1373: XDP_ADAPTER.pv_statusStoppedError,
1374: XDP_ADAPTER.pv_statusTerminated,
1375: XDP_ADAPTER.pv_statusNotAvailable,
1376: XDP_ADAPTER.pv_statusDeactivated,
1377: XDP_ADAPTER.pv_statusDeactivatedSystem)

Line 1374: XDP_ADAPTER.pv_statusTerminated,

1370: where arn.fe_id = fet.fe_id
1371: and fet.fetype_id = p_fetype_id
1372: and arn.adapter_status not in (XDP_ADAPTER.pv_statusStopped,
1373: XDP_ADAPTER.pv_statusStoppedError,
1374: XDP_ADAPTER.pv_statusTerminated,
1375: XDP_ADAPTER.pv_statusNotAvailable,
1376: XDP_ADAPTER.pv_statusDeactivated,
1377: XDP_ADAPTER.pv_statusDeactivatedSystem)
1378: );

Line 1375: XDP_ADAPTER.pv_statusNotAvailable,

1371: and fet.fetype_id = p_fetype_id
1372: and arn.adapter_status not in (XDP_ADAPTER.pv_statusStopped,
1373: XDP_ADAPTER.pv_statusStoppedError,
1374: XDP_ADAPTER.pv_statusTerminated,
1375: XDP_ADAPTER.pv_statusNotAvailable,
1376: XDP_ADAPTER.pv_statusDeactivated,
1377: XDP_ADAPTER.pv_statusDeactivatedSystem)
1378: );
1379: BEGIN

Line 1376: XDP_ADAPTER.pv_statusDeactivated,

1372: and arn.adapter_status not in (XDP_ADAPTER.pv_statusStopped,
1373: XDP_ADAPTER.pv_statusStoppedError,
1374: XDP_ADAPTER.pv_statusTerminated,
1375: XDP_ADAPTER.pv_statusNotAvailable,
1376: XDP_ADAPTER.pv_statusDeactivated,
1377: XDP_ADAPTER.pv_statusDeactivatedSystem)
1378: );
1379: BEGIN
1380:

Line 1377: XDP_ADAPTER.pv_statusDeactivatedSystem)

1373: XDP_ADAPTER.pv_statusStoppedError,
1374: XDP_ADAPTER.pv_statusTerminated,
1375: XDP_ADAPTER.pv_statusNotAvailable,
1376: XDP_ADAPTER.pv_statusDeactivated,
1377: XDP_ADAPTER.pv_statusDeactivatedSystem)
1378: );
1379: BEGIN
1380:
1381: for v_IsAdapterRunning in c_IsAdapterRunning loop

Line 1400: from xdp_adapter_reg a, xdp_adapter_types_b b

1396: is
1397: l_ClassName varchar2(240);
1398: begin
1399: select b.adapter_class into l_ClassName
1400: from xdp_adapter_reg a, xdp_adapter_types_b b
1401: where a.CHANNEL_NAME = p_ChannelName and
1402: a.adapter_type = b.adapter_type;
1403:
1404: if (upper(l_ClassName) = 'NONE') then

Line 1424: FND_LOG.STRING (FND_LOG.LEVEL_PROCEDURE, 'XDP_ADAPTER_CORE_DB.VERIFY_ADAPTER',

1420: l_AdapterLocked1 varchar2(1) := 'N';
1421:
1422: begin
1423: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) then
1424: FND_LOG.STRING (FND_LOG.LEVEL_PROCEDURE, 'XDP_ADAPTER_CORE_DB.VERIFY_ADAPTER',
1425: 'BEGIN:p_ChannelName: '||p_ChannelName);
1426: end if;
1427:
1428: if (XDP_ADAPTER_CORE_DB.Is_Adapter_Implemented (p_ChannelName)) then

Line 1428: if (XDP_ADAPTER_CORE_DB.Is_Adapter_Implemented (p_ChannelName)) then

1424: FND_LOG.STRING (FND_LOG.LEVEL_PROCEDURE, 'XDP_ADAPTER_CORE_DB.VERIFY_ADAPTER',
1425: 'BEGIN:p_ChannelName: '||p_ChannelName);
1426: end if;
1427:
1428: if (XDP_ADAPTER_CORE_DB.Is_Adapter_Implemented (p_ChannelName)) then
1429:
1430: --skilaru 05/17/2002
1431: --If the channel is of type PIPE then we dont need to lock..
1432: IF ( checkLockRequired( p_ChannelName ) ) THEN

Line 1433: l_AdapterLocked1 := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_Verify('SESSION_'||p_ChannelName);

1429:
1430: --skilaru 05/17/2002
1431: --If the channel is of type PIPE then we dont need to lock..
1432: IF ( checkLockRequired( p_ChannelName ) ) THEN
1433: l_AdapterLocked1 := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_Verify('SESSION_'||p_ChannelName);
1434: END IF;
1435:
1436: if l_AdapterLocked1 = 'Y' then
1437:

Line 1443: if XDP_ADAPTER_CORE_DB.ReleaseAdapterLock('SESSION_'||p_ChannelName) = 'N' then

1439:
1440: --dbms_output.put_line('Got SESSION lock for: ' || p_ChannelName);
1441: --dbms_output.put_line('Adapter NOT RUNNING');
1442:
1443: if XDP_ADAPTER_CORE_DB.ReleaseAdapterLock('SESSION_'||p_ChannelName) = 'N' then
1444: if( FND_LOG.LEVEL_UNEXPECTED >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) then
1445: FND_LOG.STRING (FND_LOG.LEVEL_UNEXPECTED, 'XDP_ADAPTER_CORE_DB.VERIFY_ADAPTER',
1446: 'Could not release SESSION lock, Channel name: '||p_ChannelName);
1447: end if;

Line 1445: FND_LOG.STRING (FND_LOG.LEVEL_UNEXPECTED, 'XDP_ADAPTER_CORE_DB.VERIFY_ADAPTER',

1441: --dbms_output.put_line('Adapter NOT RUNNING');
1442:
1443: if XDP_ADAPTER_CORE_DB.ReleaseAdapterLock('SESSION_'||p_ChannelName) = 'N' then
1444: if( FND_LOG.LEVEL_UNEXPECTED >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) then
1445: FND_LOG.STRING (FND_LOG.LEVEL_UNEXPECTED, 'XDP_ADAPTER_CORE_DB.VERIFY_ADAPTER',
1446: 'Could not release SESSION lock, Channel name: '||p_ChannelName);
1447: end if;
1448: end if;
1449:

Line 1450: XDP_ADAPTER_CORE_DB.FetchAdapterInfo(

1446: 'Could not release SESSION lock, Channel name: '||p_ChannelName);
1447: end if;
1448: end if;
1449:
1450: XDP_ADAPTER_CORE_DB.FetchAdapterInfo(
1451: p_ChannelName => p_ChannelName,
1452: p_FEID => l_FeID,
1453: p_ProcessID => l_ProcessID,
1454: p_ConcQID => l_ConcQID);

Line 1456: -- Cannot use XDP_ADAPTER_CORE_DB.Update_Adapter_Status, an autonomous

1452: p_FEID => l_FeID,
1453: p_ProcessID => l_ProcessID,
1454: p_ConcQID => l_ConcQID);
1455:
1456: -- Cannot use XDP_ADAPTER_CORE_DB.Update_Adapter_Status, an autonomous
1457: -- procedure
1458:
1459: XDP_ADAPTER_CORE_DB.UpdateAdapter (
1460: p_ChannelName => p_ChannelName,

Line 1459: XDP_ADAPTER_CORE_DB.UpdateAdapter (

1455:
1456: -- Cannot use XDP_ADAPTER_CORE_DB.Update_Adapter_Status, an autonomous
1457: -- procedure
1458:
1459: XDP_ADAPTER_CORE_DB.UpdateAdapter (
1460: p_ChannelName => p_ChannelName,
1461: p_Status => XDP_ADAPTER.pv_statusStoppedError
1462: );
1463:

Line 1461: p_Status => XDP_ADAPTER.pv_statusStoppedError

1457: -- procedure
1458:
1459: XDP_ADAPTER_CORE_DB.UpdateAdapter (
1460: p_ChannelName => p_ChannelName,
1461: p_Status => XDP_ADAPTER.pv_statusStoppedError
1462: );
1463:
1464: XDP_ERRORS_PKG.Set_Message (
1465: p_object_type => XDP_ADAPTER.pv_errorObjectTypeAdapter,

Line 1465: p_object_type => XDP_ADAPTER.pv_errorObjectTypeAdapter,

1461: p_Status => XDP_ADAPTER.pv_statusStoppedError
1462: );
1463:
1464: XDP_ERRORS_PKG.Set_Message (
1465: p_object_type => XDP_ADAPTER.pv_errorObjectTypeAdapter,
1466: p_object_key => p_ChannelName,
1467: p_message_name => 'XDP_ADAPTER_ABNORMAL_EXIT',
1468: p_message_parameters => 'PROCESS_ID='||l_ProcessID||'#XDP#');
1469:

Line 1467: p_message_name => 'XDP_ADAPTER_ABNORMAL_EXIT',

1463:
1464: XDP_ERRORS_PKG.Set_Message (
1465: p_object_type => XDP_ADAPTER.pv_errorObjectTypeAdapter,
1466: p_object_key => p_ChannelName,
1467: p_message_name => 'XDP_ADAPTER_ABNORMAL_EXIT',
1468: p_message_parameters => 'PROCESS_ID='||l_ProcessID||'#XDP#');
1469:
1470: commit;
1471:

Line 1478: XDP_ADAPTER_CORE_DB.UpdateAdapter (

1474: --dbms_output.put_line('Did not get SESSION lock for: ' || p_ChannelName);
1475: --dbms_output.put_line('Adapter RUNNING');
1476:
1477: -- Could not get lock, Adapter running, update last_verified_date
1478: XDP_ADAPTER_CORE_DB.UpdateAdapter (
1479: p_ChannelName => p_ChannelName,
1480: p_LastVerified => sysdate);
1481: end if;
1482: else

Line 1484: XDP_ADAPTER_CORE_DB.UpdateAdapter (

1480: p_LastVerified => sysdate);
1481: end if;
1482: else
1483: -- Adapter not implemented, so Adapter is 'running', update last_verified_date
1484: XDP_ADAPTER_CORE_DB.UpdateAdapter (
1485: p_ChannelName => p_ChannelName,
1486: p_LastVerified => sysdate);
1487: end if;
1488:

Line 1500: from xdp_adapter_reg a

1496: is
1497: l_StartupMode varchar2(30);
1498: begin
1499: select a.startup_mode into l_StartupMode
1500: from xdp_adapter_reg a
1501: where a.CHANNEL_NAME = p_ChannelName;
1502:
1503: if (upper(l_StartupMode) IN (XDP_ADAPTER.pv_startAutomatic, XDP_ADAPTER.pv_startOnDemand)) then
1504: return TRUE;

Line 1503: if (upper(l_StartupMode) IN (XDP_ADAPTER.pv_startAutomatic, XDP_ADAPTER.pv_startOnDemand)) then

1499: select a.startup_mode into l_StartupMode
1500: from xdp_adapter_reg a
1501: where a.CHANNEL_NAME = p_ChannelName;
1502:
1503: if (upper(l_StartupMode) IN (XDP_ADAPTER.pv_startAutomatic, XDP_ADAPTER.pv_startOnDemand)) then
1504: return TRUE;
1505: else
1506: return FALSE;
1507: END IF;

Line 1515: if fnd_profile.defined('XDP_ADAPTER_RESTART_COUNT') then

1511: Function GetAdapterRestartCount return number
1512: is
1513: l_ProfileValue varchar2(40);
1514: begin
1515: if fnd_profile.defined('XDP_ADAPTER_RESTART_COUNT') then
1516: fnd_profile.get('XDP_ADAPTER_RESTART_COUNT', l_ProfileValue);
1517: if to_number(l_ProfileValue) <= 0 then
1518: l_ProfileValue := '5';
1519: end if;

Line 1516: fnd_profile.get('XDP_ADAPTER_RESTART_COUNT', l_ProfileValue);

1512: is
1513: l_ProfileValue varchar2(40);
1514: begin
1515: if fnd_profile.defined('XDP_ADAPTER_RESTART_COUNT') then
1516: fnd_profile.get('XDP_ADAPTER_RESTART_COUNT', l_ProfileValue);
1517: if to_number(l_ProfileValue) <= 0 then
1518: l_ProfileValue := '5';
1519: end if;
1520: else

Line 1534: FROM xdp_adapter_reg ar, xdp_adapter_types_b atb

1530: Function checkLockRequired( p_Channelname in varchar2) return boolean IS
1531:
1532: cursor getApplMode IS
1533: SELECT atb.application_mode
1534: FROM xdp_adapter_reg ar, xdp_adapter_types_b atb
1535: WHERE ar.channel_name = p_Channelname
1536: AND ar.adapter_type = atb.adapter_type;
1537:
1538: lv_appl_mode VARCHAR2(40);

Line 1568: from XDP_ADAPTER_TYPE_ATTRS_VL

1564: x_errbuf OUT NOCOPY VARCHAR2)
1565: AS
1566: cursor c_adapter_type_attribute is
1567: select ATTRIBUTE_NAME,DEFAULT_VALUE,DISPLAY_NAME,DESCRIPTION
1568: from XDP_ADAPTER_TYPE_ATTRS_VL
1569: where ADAPTER_TYPE = p_adapter_type
1570: and attribute_name not in (
1571: select FE_ATTRIBUTE_NAME from xdp_fe_attribute_def_vl
1572: where fe_sw_gen_lookup_id = p_fe_sw_gen_lookup_id);

Line 1575: SELECT BASE_ADAPTER_TYPE FROM XDP_ADAPTER_TYPES_B

1571: select FE_ATTRIBUTE_NAME from xdp_fe_attribute_def_vl
1572: where fe_sw_gen_lookup_id = p_fe_sw_gen_lookup_id);
1573:
1574: cursor c_adapter_types is
1575: SELECT BASE_ADAPTER_TYPE FROM XDP_ADAPTER_TYPES_B
1576: WHERE ADAPTER_TYPE = p_adapter_type;
1577:
1578: l_rowid ROWID;
1579: l_base_type XDP_ADAPTER_TYPES_B.ADAPTER_TYPE%TYPE;

Line 1579: l_base_type XDP_ADAPTER_TYPES_B.ADAPTER_TYPE%TYPE;

1575: SELECT BASE_ADAPTER_TYPE FROM XDP_ADAPTER_TYPES_B
1576: WHERE ADAPTER_TYPE = p_adapter_type;
1577:
1578: l_rowid ROWID;
1579: l_base_type XDP_ADAPTER_TYPES_B.ADAPTER_TYPE%TYPE;
1580: l_fe_attribute_id number;
1581: BEGIN
1582: x_retcode := 0;
1583: SavePoint CopyFETATTR;

Line 1761: end XDP_ADAPTER_CORE_DB;

1757:
1758: pv_AckTimeout := GetAckTimeOut;
1759: select instance_name into pv_InstanceName from v$instance;
1760:
1761: end XDP_ADAPTER_CORE_DB;