eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.XDPCORE_FA dependencies on XDP_ADAPTER

Line 205: insert into XDP_ADAPTER_JOB_QUEUE (

201: l_ReProcessEnqTime := SYSDATE;
202: end if;
203:
204:
205: insert into XDP_ADAPTER_JOB_QUEUE (
206: JOB_ID,
207: FE_ID,
208: ORDER_ID,
209: WORKITEM_INSTANCE_ID,

Line 222: values (XDP_ADAPTER_JOB_QUEUE_S.NEXTVAL,

218: last_updated_by,
219: last_update_date,
220: last_update_login
221: )
222: values (XDP_ADAPTER_JOB_QUEUE_S.NEXTVAL,
223: l_FeID,
224: l_OrderID,
225: l_WIInstanceID,
226: l_FAInstanceID,

Line 2052: if XDP_ADAPTER_CORE_DB.checkLockRequired( l_ChannelName ) then

2048:
2049: --skilaru 05/17/2002
2050: --Lock the channel only if it is pipe based adapter...
2051:
2052: if XDP_ADAPTER_CORE_DB.checkLockRequired( l_ChannelName ) then
2053: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
2054: p_ChannelName => l_ChannelName,
2055: p_Status => XDP_ADAPTER.pv_statusInUse,
2056: p_WFItemType => IsChannelAvailable.itemtype,

Line 2053: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

2049: --skilaru 05/17/2002
2050: --Lock the channel only if it is pipe based adapter...
2051:
2052: if XDP_ADAPTER_CORE_DB.checkLockRequired( l_ChannelName ) then
2053: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
2054: p_ChannelName => l_ChannelName,
2055: p_Status => XDP_ADAPTER.pv_statusInUse,
2056: p_WFItemType => IsChannelAvailable.itemtype,
2057: p_WFItemKey => IsChannelAvailable.itemkey);

Line 2055: p_Status => XDP_ADAPTER.pv_statusInUse,

2051:
2052: if XDP_ADAPTER_CORE_DB.checkLockRequired( l_ChannelName ) then
2053: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
2054: p_ChannelName => l_ChannelName,
2055: p_Status => XDP_ADAPTER.pv_statusInUse,
2056: p_WFItemType => IsChannelAvailable.itemtype,
2057: p_WFItemKey => IsChannelAvailable.itemkey);
2058: end if;
2059: end if;

Line 2099: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => l_ChannelName);

2095: exception
2096: when others then
2097: x_Progress := 'XDPCORE_FA.IsChannelAvailable. Unhandled Exception: ' || SUBSTR(SQLERRM, 1,1500);
2098: wf_core.context('XDPCORE_FA', 'IsChannelAvailable', itemtype, itemkey, null, x_Progress);
2099: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => l_ChannelName);
2100: raise;
2101: end IsChannelAvailable;
2102:
2103:

Line 2124: from XDP_ADAPTER_REG

2120: l_channelstatus varchar2(1) ;
2121:
2122: cursor c_CheckChannel(ChannelName varchar2) is
2123: select adapter_status
2124: from XDP_ADAPTER_REG
2125: where channel_name = ChannelName;
2126:
2127: resource_busy exception;
2128: pragma exception_init(resource_busy, -00054);

Line 2160: l_isLockRequired := XDP_ADAPTER_CORE_DB.checkLockRequired( l_ChannelName );

2156: end if;
2157: -- skilaru 05/16/2002
2158: -- ER# 2013681 Lock the channel only if it is of application mode PIPE..
2159:
2160: l_isLockRequired := XDP_ADAPTER_CORE_DB.checkLockRequired( l_ChannelName );
2161: IF( l_isLockRequired ) THEN
2162:
2163: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA
2164: (p_ChannelName => l_ChannelName);

Line 2163: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA

2159:
2160: l_isLockRequired := XDP_ADAPTER_CORE_DB.checkLockRequired( l_ChannelName );
2161: IF( l_isLockRequired ) THEN
2162:
2163: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA
2164: (p_ChannelName => l_ChannelName);
2165:
2166: END IF;
2167:

Line 2182: if XDP_ADAPTER_CORE_DB.Verify_Adapter (l_ChannelName) then

2178: /* Update the Adapter Status to be BUSY */
2179:
2180: -- Also why are we checking for above statuses?
2181:
2182: if XDP_ADAPTER_CORE_DB.Verify_Adapter (l_ChannelName) then
2183: l_Result := 'CONTINUE';
2184: else
2185: -- Release the Lock
2186: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (l_ChannelName);

Line 2186: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (l_ChannelName);

2182: if XDP_ADAPTER_CORE_DB.Verify_Adapter (l_ChannelName) then
2183: l_Result := 'CONTINUE';
2184: else
2185: -- Release the Lock
2186: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (l_ChannelName);
2187: l_Result := 'RE_PROCESS';
2188: END IF;
2189:
2190: -- skilaru 05/16/2002 ER# 2013681

Line 2196: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

2192: -- always Running. Dont update to In Use
2193:
2194: IF( l_isLockRequired ) THEN
2195:
2196: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
2197: p_ChannelName => l_ChannelName,
2198: p_Status => XDP_ADAPTER.pv_statusInUse,
2199: p_WFItemType => VerifyChannel.itemtype,
2200: p_WFItemKey => VerifyChannel.itemkey);

Line 2198: p_Status => XDP_ADAPTER.pv_statusInUse,

2194: IF( l_isLockRequired ) THEN
2195:
2196: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
2197: p_ChannelName => l_ChannelName,
2198: p_Status => XDP_ADAPTER.pv_statusInUse,
2199: p_WFItemType => VerifyChannel.itemtype,
2200: p_WFItemKey => VerifyChannel.itemkey);
2201:
2202: END IF;

Line 2205: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (l_ChannelName);

2201:
2202: END IF;
2203: l_Result := 'CONTINUE';
2204: else
2205: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (l_ChannelName);
2206: l_Result := 'RE_PROCESS';
2207: end if;
2208: end if;
2209:

Line 2251: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => l_ChannelName);

2247: close c_CheckChannel;
2248: end if;
2249:
2250: IF l_channellock THEN
2251: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => l_ChannelName);
2252: END IF ;
2253:
2254: Rollback to VerifyChannel;
2255:

Line 2417: from XDP_ADAPTER_REG

2413: P_RETURN_CODE => l_ErrCode,
2414: P_ERROR_DESCRIPTION => l_ErrStr);
2415:
2416: select adapter_status into l_AdapterStatus
2417: from XDP_ADAPTER_REG
2418: where channel_name = l_ChannelName;
2419:
2420:
2421: --skilaru 05/19/2002

Line 2423: if NOT XDP_ADAPTER_CORE_DB.checkLockRequired( l_ChannelName ) then

2419:
2420:
2421: --skilaru 05/19/2002
2422: --NON-PIPE based adapters are always available never be BUSY..
2423: if NOT XDP_ADAPTER_CORE_DB.checkLockRequired( l_ChannelName ) then
2424: wf_engine.SetItemAttrText(itemtype => ProvisionFe.itemtype,
2425: itemkey => ProvisionFe.itemkey,
2426: aname => 'HANDOVER_CHANNEL_FLAG',
2427: avalue => 'TRUE');

Line 2517: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

2513:
2514: x_parameters := 'PROC_NAME='||l_FPName||'#XDP#'||
2515: 'ERROR_STRING='||substr(l_ErrStr,1,1500)||'#XDP#';
2516:
2517: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
2518: p_ChannelName => l_ChannelName,
2519: p_Status => XDP_ADAPTER.pv_statusError,
2520: p_ErrorMsg => 'XDP_DYNAMIC_PROC_EXEC_ERROR',
2521: p_ErrorMsgParams => x_parameters

Line 2519: p_Status => XDP_ADAPTER.pv_statusError,

2515: 'ERROR_STRING='||substr(l_ErrStr,1,1500)||'#XDP#';
2516:
2517: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
2518: p_ChannelName => l_ChannelName,
2519: p_Status => XDP_ADAPTER.pv_statusError,
2520: p_ErrorMsg => 'XDP_DYNAMIC_PROC_EXEC_ERROR',
2521: p_ErrorMsgParams => x_parameters
2522: );
2523:

Line 2552: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

2548: 'ERROR_STRING='||substr(l_ErrStr,1,1500)||'#XDP#';
2549:
2550:
2551:
2552: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
2553: p_ChannelName => l_ChannelName,
2554: p_Status => XDP_ADAPTER.pv_statusError,
2555: p_ErrorMsg => 'XDP_INTERNAL_CHANNEL_ERROR',
2556: p_ErrorMsgParams => x_parameters

Line 2554: p_Status => XDP_ADAPTER.pv_statusError,

2550:
2551:
2552: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
2553: p_ChannelName => l_ChannelName,
2554: p_Status => XDP_ADAPTER.pv_statusError,
2555: p_ErrorMsg => 'XDP_INTERNAL_CHANNEL_ERROR',
2556: p_ErrorMsgParams => x_parameters
2557: );
2558:

Line 2577: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

2573:
2574: /* bug fix 1945013
2575: dont set the adapte status to error..
2576:
2577: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
2578: p_ChannelName => l_ChannelName,
2579: p_Status => XDP_ADAPTER.pv_statusDisconnected
2580: );
2581:

Line 2579: p_Status => XDP_ADAPTER.pv_statusDisconnected

2575: dont set the adapte status to error..
2576:
2577: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
2578: p_ChannelName => l_ChannelName,
2579: p_Status => XDP_ADAPTER.pv_statusDisconnected
2580: );
2581:
2582: COMMIT;
2583: */

Line 2614: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

2610:
2611: x_parameters := 'PROC_NAME='||l_FPName||'#XDP#'||
2612: 'ERROR_STRING='||substr(l_ErrStr,1,1500)||'#XDP#';
2613:
2614: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
2615: p_ChannelName => l_ChannelName,
2616: p_Status => XDP_ADAPTER.pv_statusError,
2617: p_ErrorMsg => 'XDP_UNHANDLED_FP_EXEC_ERROR',
2618: p_ErrorMsgParams => x_parameters

Line 2616: p_Status => XDP_ADAPTER.pv_statusError,

2612: 'ERROR_STRING='||substr(l_ErrStr,1,1500)||'#XDP#';
2613:
2614: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
2615: p_ChannelName => l_ChannelName,
2616: p_Status => XDP_ADAPTER.pv_statusError,
2617: p_ErrorMsg => 'XDP_UNHANDLED_FP_EXEC_ERROR',
2618: p_ErrorMsgParams => x_parameters
2619: );
2620:

Line 2681: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock

2677:
2678: exception
2679: when e_HandOverChannelException then
2680:
2681: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock
2682: (p_ChannelName => l_ChannelName);
2683:
2684: wf_core.context('XDPCORE_FA', 'HandOverChannel', null, null, x_Progress,null);
2685: raise;

Line 2689: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock

2685: raise;
2686:
2687: when others then
2688:
2689: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock
2690: (p_ChannelName => l_ChannelName);
2691:
2692: /* Set the FP_FUNC_MODE to be RETRY so that when the user retries the activity it goes
2693: ** back to the regular get Channel Process

Line 2815: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock

2811: if l_ResubmissionJobID <> 0 then
2812: l_ChannelUsageCode := 'RESUBMISSION';
2813: end if;
2814:
2815: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock
2816: (p_ChannelName => l_ChannelName);
2817:
2818: if l_HandOverChannelFlag = 'TRUE' then
2819: /* Call the HAND Over Process which releases the channel to the next waiting wf process */

Line 2846: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => l_ChannelName);

2842: exception
2843: when others then
2844: x_Progress := 'XDPCORE_FA.ReleaseFEChannel. Unhandled Exception: ' || SUBSTR(SQLERRM, 1,1500);
2845: wf_core.context('XDPCORE_FA', 'ReleaseFEChannel', itemtype, itemkey, null, x_Progress);
2846: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => l_ChannelName);
2847: raise;
2848: end ReleaseFEChannel;
2849:
2850:

Line 3658: from XDP_ADAPTER_JOB_QUEUE

3654: is
3655:
3656: cursor c_AdapterJobQueue(p_FeID number, p_ChannelUsageCode varchar2) is
3657: select ROWID
3658: from XDP_ADAPTER_JOB_QUEUE
3659: where FE_ID = p_FeID
3660: and channel_usage_code = p_ChannelUsageCode
3661: and SYSTEM_HOLD = 'N'
3662: order by QUEUED_ON ASC;

Line 3710: from xdp_adapter_reg

3706: where fulfillment_element_name = p_FeName;
3707:
3708: cursor c_GetUsageCode is
3709: select USAGE_CODE
3710: from xdp_adapter_reg
3711: where channel_name = p_ChannelName;
3712:
3713: BEGIN
3714:

Line 3745: l_isLockRequired := XDP_ADAPTER_CORE_DB.checkLockRequired( HandOverChannel.p_ChannelName );

3741: --
3742: -- skilaru 05/16/2002
3743: -- ER# 2013681 Lock the channel only if it is of application mode PIPE..
3744:
3745: l_isLockRequired := XDP_ADAPTER_CORE_DB.checkLockRequired( HandOverChannel.p_ChannelName );
3746:
3747: IF( l_isLockRequired ) THEN
3748:
3749: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA

Line 3749: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA

3745: l_isLockRequired := XDP_ADAPTER_CORE_DB.checkLockRequired( HandOverChannel.p_ChannelName );
3746:
3747: IF( l_isLockRequired ) THEN
3748:
3749: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA
3750: (p_ChannelName => HandOverChannel.p_ChannelName);
3751: END IF;
3752:
3753: if l_Status = 'N' AND l_isLockRequired then

Line 3799: from XDP_ADAPTER_JOB_QUEUE

3795: */
3796: BEGIN
3797: select WF_ITEM_TYPE, WF_ITEM_KEY, ROWID, ORDER_ID, WORKITEM_INSTANCE_ID, FA_INSTANCE_ID
3798: into l_New_itemtype, l_New_itemkey, l_rowID, l_OrderID, l_WIInstanceID, l_FAInstanceID
3799: from XDP_ADAPTER_JOB_QUEUE
3800: where ROWID = idarr(i)
3801: for update NOWAIT;
3802:
3803: /* Check if the FA Waiting has been CANCELED

Line 3814: delete from XDP_ADAPTER_JOB_QUEUE

3810: GOTO l_EndofLoop;
3811: else
3812: eligible := FALSE;
3813:
3814: delete from XDP_ADAPTER_JOB_QUEUE
3815: where ROWID = l_rowid;
3816: end if;
3817:
3818: EXCEPTION

Line 3839: delete from XDP_ADAPTER_JOB_QUEUE

3835: BEGIN
3836:
3837: SAVEPOINT HandOverPoint;
3838:
3839: delete from XDP_ADAPTER_JOB_QUEUE
3840: where ROWID = l_rowid;
3841:
3842: /* Need to Enqueue in the AQ */
3843:

Line 3850: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

3846: -- always Running. Dont update to In Use
3847:
3848: IF( l_isLockRequired ) THEN
3849:
3850: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
3851: p_ChannelName => p_ChannelName,
3852: p_Status => XDP_ADAPTER.pv_statusInUse
3853: );
3854:

Line 3852: p_Status => XDP_ADAPTER.pv_statusInUse

3848: IF( l_isLockRequired ) THEN
3849:
3850: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
3851: p_ChannelName => p_ChannelName,
3852: p_Status => XDP_ADAPTER.pv_statusInUse
3853: );
3854:
3855: END IF;
3856:

Line 3891: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

3887: 'FE_NAME='||p_FeName||'#XDP#'||
3888: 'ERROR_STRING='||substr(x_progress,1,1500)||'#XDP#';
3889:
3890:
3891: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
3892: p_ChannelName => p_ChannelName,
3893: p_Status => XDP_ADAPTER.pv_statusError,
3894: p_ErrorMsg => 'XDP_INTERNAL_CHANNEL_ERROR',
3895: p_ErrorMsgParams => x_parameters

Line 3893: p_Status => XDP_ADAPTER.pv_statusError,

3889:
3890:
3891: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
3892: p_ChannelName => p_ChannelName,
3893: p_Status => XDP_ADAPTER.pv_statusError,
3894: p_ErrorMsg => 'XDP_INTERNAL_CHANNEL_ERROR',
3895: p_ErrorMsgParams => x_parameters
3896: );
3897:

Line 3910: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

3906: /* No jobs found */
3907:
3908: BEGIN
3909:
3910: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
3911: p_ChannelName => p_ChannelName,
3912: p_Status => XDP_ADAPTER.pv_statusRunning
3913: );
3914:

Line 3912: p_Status => XDP_ADAPTER.pv_statusRunning

3908: BEGIN
3909:
3910: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
3911: p_ChannelName => p_ChannelName,
3912: p_Status => XDP_ADAPTER.pv_statusRunning
3913: );
3914:
3915:
3916: EXCEPTION

Line 3938: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock

3934:
3935: -- 11.5.6 On-Wards..
3936: -- Release Lock...
3937:
3938: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock
3939: (p_ChannelName => HandOverChannel.p_ChannelName);
3940:
3941: exception
3942: when e_UnhandledException then

Line 3947: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => HandOverChannel.p_ChannelName);

3943: IF c_AdapterJobQueue%ISOPEN THEN
3944: close c_AdapterJobQueue;
3945: END IF;
3946: IF l_channellock THEN
3947: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => HandOverChannel.p_ChannelName);
3948: END IF ;
3949:
3950: x_Progress := 'XDPCORE_FA.HandOverChannel. Unhandled Exception: ' || SUBSTR(SQLERRM, 1,1500);
3951: wf_core.context('XDPCORE_FA', 'HandOverChannel', null, null, x_Progress,null);

Line 3960: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => HandOverChannel.p_ChannelName);

3956: close c_AdapterJobQueue;
3957: END IF;
3958:
3959: IF l_channellock THEN
3960: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => HandOverChannel.p_ChannelName);
3961: END IF ;
3962:
3963: wf_core.context('XDPCORE_FA', 'HandOverChannel', null, null, x_Progress,null);
3964: raise;

Line 3972: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => HandOverChannel.p_ChannelName);

3968: close c_AdapterJobQueue;
3969: END IF;
3970:
3971: IF l_channellock THEN
3972: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => HandOverChannel.p_ChannelName);
3973: END IF ;
3974:
3975: wf_core.context('XDPCORE_FA', 'HandOverChannel', null, null, x_Progress,null);
3976: raise;

Line 3984: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => HandOverChannel.p_ChannelName);

3980: close c_AdapterJobQueue;
3981: END IF;
3982:
3983: IF l_channellock THEN
3984: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => HandOverChannel.p_ChannelName);
3985: END IF ;
3986:
3987: x_Progress := 'XDPCORE_FA.HandOverChannel. Unhandled Exception: ' || SUBSTR(SQLERRM, 1,1500);
3988: wf_core.context('XDPCORE_FA', 'HandOverChannel', null, null, x_Progress,null);

Line 4007: from XDP_ADAPTER_JOB_QUEUE

4003: is
4004:
4005: cursor c_AdapterJobQueue(p_FeID number, p_ChannelUsageCode varchar2) is
4006: select ROWID
4007: from XDP_ADAPTER_JOB_QUEUE
4008: where FE_ID = p_FeID
4009: and channel_usage_code = p_ChannelUsageCode
4010: and SYSTEM_HOLD = 'N'
4011: order by QUEUED_ON ASC;

Line 4073: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock

4069: --
4070: --
4071:
4072: -- TO DO ERROR HANDLING!!
4073: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock
4074: (p_ChannelName => HandOverChannel.ChannelName);
4075:
4076:
4077: /* This part of the Code is to support the Adapter's hand over process.

Line 4090: from XDP_ADAPTER_REG

4086:
4087: if FeID = 0 then
4088: select fe_id, usage_code
4089: into l_FeID, l_ChannelUsageCode
4090: from XDP_ADAPTER_REG
4091: where channel_name = ChannelName;
4092: else
4093: l_FeID := FeID;
4094: l_ChannelUsageCode := ChannelUsageCode;

Line 4104: l_isLockRequired := XDP_ADAPTER_CORE_DB.checkLockRequired( HandOverChannel.ChannelName );

4100: --
4101: -- skilaru 05/16/2002
4102: -- ER# 2013681 Lock the channel only if it is of application mode PIPE..
4103:
4104: l_isLockRequired := XDP_ADAPTER_CORE_DB.checkLockRequired( HandOverChannel.ChannelName );
4105:
4106: IF( l_isLockRequired ) THEN
4107:
4108: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA

Line 4108: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA

4104: l_isLockRequired := XDP_ADAPTER_CORE_DB.checkLockRequired( HandOverChannel.ChannelName );
4105:
4106: IF( l_isLockRequired ) THEN
4107:
4108: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA
4109: (p_ChannelName => HandOverChannel.ChannelName);
4110: END IF;
4111:
4112: if l_Status = 'N' then

Line 4158: from XDP_ADAPTER_JOB_QUEUE

4154: */
4155: BEGIN
4156: select WF_ITEM_TYPE, WF_ITEM_KEY, ROWID, ORDER_ID, WORKITEM_INSTANCE_ID, FA_INSTANCE_ID
4157: into l_New_itemtype, l_New_itemkey, l_rowID, l_OrderID, l_WIInstanceID, l_FAInstanceID
4158: from XDP_ADAPTER_JOB_QUEUE
4159: where ROWID = idarr(i)
4160: for update NOWAIT;
4161:
4162: /* Check if the FA Waiting has been CANCELED

Line 4173: delete from XDP_ADAPTER_JOB_QUEUE

4169: GOTO l_EndofLoop;
4170: else
4171: eligible := FALSE;
4172:
4173: delete from XDP_ADAPTER_JOB_QUEUE
4174: where ROWID = l_rowid;
4175: end if;
4176:
4177: EXCEPTION

Line 4198: delete from XDP_ADAPTER_JOB_QUEUE

4194: BEGIN
4195:
4196: SAVEPOINT HandOverPoint;
4197:
4198: delete from XDP_ADAPTER_JOB_QUEUE
4199: where ROWID = l_rowid;
4200:
4201: /* Need to Enqueue in the AQ */
4202:

Line 4215: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

4211: -- always Running. Dont update to In Use
4212:
4213: IF( l_isLockRequired ) THEN
4214:
4215: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
4216: p_ChannelName => ChannelName,
4217: p_Status => XDP_ADAPTER.pv_statusInUse
4218: );
4219: END IF;

Line 4217: p_Status => XDP_ADAPTER.pv_statusInUse

4213: IF( l_isLockRequired ) THEN
4214:
4215: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
4216: p_ChannelName => ChannelName,
4217: p_Status => XDP_ADAPTER.pv_statusInUse
4218: );
4219: END IF;
4220:
4221: end if;

Line 4257: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

4253: 'FE_NAME='||l_FeName||'#XDP#'||
4254: 'ERROR_STRING='||substr(x_progress,1,1500)||'#XDP#';
4255:
4256:
4257: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
4258: p_ChannelName => ChannelName,
4259: p_Status => XDP_ADAPTER.pv_statusError,
4260: p_ErrorMsg => 'XDP_INTERNAL_CHANNEL_ERROR',
4261: p_ErrorMsgParams => x_parameters

Line 4259: p_Status => XDP_ADAPTER.pv_statusError,

4255:
4256:
4257: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
4258: p_ChannelName => ChannelName,
4259: p_Status => XDP_ADAPTER.pv_statusError,
4260: p_ErrorMsg => 'XDP_INTERNAL_CHANNEL_ERROR',
4261: p_ErrorMsgParams => x_parameters
4262: );
4263:

Line 4276: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

4272: /* No jobs found */
4273:
4274: BEGIN
4275:
4276: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
4277: p_ChannelName => ChannelName,
4278: p_Status => XDP_ADAPTER.pv_statusRunning
4279: );
4280:

Line 4278: p_Status => XDP_ADAPTER.pv_statusRunning

4274: BEGIN
4275:
4276: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
4277: p_ChannelName => ChannelName,
4278: p_Status => XDP_ADAPTER.pv_statusRunning
4279: );
4280:
4281:
4282: EXCEPTION

Line 4304: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock

4300:
4301: -- 11.5.6 On-Wards..
4302: -- Release Lock...
4303:
4304: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock
4305: (p_ChannelName => HandOverChannel.ChannelName);
4306:
4307: exception
4308: when e_UnhandledException then

Line 4314: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock(p_ChannelName => HandOverChannel.ChannelName);

4310: close c_AdapterJobQueue;
4311: END IF;
4312:
4313: IF l_channellock THEN
4314: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock(p_ChannelName => HandOverChannel.ChannelName);
4315: END IF ;
4316:
4317: x_Progress := 'XDPCORE_FA.HandOverChannel. Unhandled Exception: ' || SUBSTR(SQLERRM, 1,1500);
4318: wf_core.context('XDPCORE_FA', 'HandOverChannel', null, null, x_Progress,null);

Line 4327: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock(p_ChannelName => HandOverChannel.ChannelName);

4323: close c_AdapterJobQueue;
4324: END IF;
4325:
4326: IF l_channellock THEN
4327: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock(p_ChannelName => HandOverChannel.ChannelName);
4328: END IF ;
4329:
4330: wf_core.context('XDPCORE_FA', 'HandOverChannel', null, null, x_Progress,null);
4331: raise;

Line 4339: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock(p_ChannelName => HandOverChannel.ChannelName);

4335: close c_AdapterJobQueue;
4336: END IF;
4337:
4338: IF l_channellock THEN
4339: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock(p_ChannelName => HandOverChannel.ChannelName);
4340: END IF ;
4341:
4342: wf_core.context('XDPCORE_FA', 'HandOverChannel', null, null, x_Progress,null);
4343: raise;

Line 4351: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock(p_ChannelName => HandOverChannel.ChannelName);

4347: close c_AdapterJobQueue;
4348: END IF;
4349:
4350: IF l_channellock THEN
4351: l_channelstatus := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock(p_ChannelName => HandOverChannel.ChannelName);
4352: END IF ;
4353:
4354: x_Progress := 'XDPCORE_FA.HandOverChannel. Unhandled Exception: ' || SUBSTR(SQLERRM, 1,1500);
4355: wf_core.context('XDPCORE_FA', 'HandOverChannel', null, null, x_Progress,null);

Line 4366: from XDP_ADAPTER_ADMIN_REQS

4362:
4363: is
4364: cursor c_AdapterAdmin(ChannelName varchar2) is
4365: select REQUEST_ID, REQUEST_TYPE
4366: from XDP_ADAPTER_ADMIN_REQS
4367: where CHANNEL_NAME = ChannelName and
4368: REQUEST_STATUS = 'PENDING' and
4369: REQUEST_TYPE IN ('SUSPEND', 'DISCONNECT', 'SHUTDOWN') and
4370: REQUEST_DATE = (

Line 4372: from XDP_ADAPTER_ADMIN_REQS

4368: REQUEST_STATUS = 'PENDING' and
4369: REQUEST_TYPE IN ('SUSPEND', 'DISCONNECT', 'SHUTDOWN') and
4370: REQUEST_DATE = (
4371: select MIN(REQUEST_DATE)
4372: from XDP_ADAPTER_ADMIN_REQS
4373: where CHANNEL_NAME = ChannelName and
4374: REQUEST_STATUS = 'PENDING' and
4375: REQUEST_TYPE IN ('SUSPEND', 'DISCONNECT', 'SHUTDOWN') and
4376: REQUEST_DATE <= SYSDATE );

Line 4649: from XDP_ADAPTER_REG

4645:
4646: cursor c_GetChannel(feid number, ChannelUsageCode varchar2,
4647: AdapterStatus varchar2) is
4648: select ROWID, channel_name
4649: from XDP_ADAPTER_REG
4650: where FE_ID = feid
4651: and ADAPTER_STATUS = AdapterStatus
4652: and USAGE_CODE = ChannelUsageCode
4653: order by NVL(SEQ_IN_FE, 10);

Line 4658: from XDP_ADAPTER_REG

4654:
4655: cursor c_GetCODChannel(feid number, ChannelUsageCode varchar2,
4656: AdapterStatus varchar2, CODFlag varchar2) is
4657: select ROWID, channel_name
4658: from XDP_ADAPTER_REG
4659: where FE_ID = feid
4660: and ADAPTER_STATUS = AdapterStatus
4661: and NVL(CONNECT_ON_DEMAND_FLAG, 'N') = CODFlag
4662: and USAGE_CODE = ChannelUsageCode

Line 4687: IF( XDP_ADAPTER_CORE_DB.checkLockRequired( v_GetChannel.channel_name ) ) THEN

4683:
4684: -- skilaru 05/16/2002
4685: -- ER# 2013681 Lock the channel only if it is of application mode PIPE..
4686:
4687: IF( XDP_ADAPTER_CORE_DB.checkLockRequired( v_GetChannel.channel_name ) ) THEN
4688: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA(v_GetChannel.channel_name);
4689: ELSE
4690: -- skilaru 05/16/2002
4691: -- IF it is NON-PIPE based channel we dont need a lock at all..

Line 4688: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA(v_GetChannel.channel_name);

4684: -- skilaru 05/16/2002
4685: -- ER# 2013681 Lock the channel only if it is of application mode PIPE..
4686:
4687: IF( XDP_ADAPTER_CORE_DB.checkLockRequired( v_GetChannel.channel_name ) ) THEN
4688: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA(v_GetChannel.channel_name);
4689: ELSE
4690: -- skilaru 05/16/2002
4691: -- IF it is NON-PIPE based channel we dont need a lock at all..
4692: -- so mimic as if we acuired a lock..

Line 4703: if XDP_ADAPTER_CORE_DB.Verify_Adapter (v_GetChannel.channel_name) then

4699:
4700: x_LockedFlag := 'Y';
4701: x_ChannelName := v_GetChannel.channel_name;
4702:
4703: if XDP_ADAPTER_CORE_DB.Verify_Adapter (v_GetChannel.channel_name) then
4704: return;
4705: else
4706: -- Release the Lock
4707: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock

Line 4707: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock

4703: if XDP_ADAPTER_CORE_DB.Verify_Adapter (v_GetChannel.channel_name) then
4704: return;
4705: else
4706: -- Release the Lock
4707: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock
4708: (p_ChannelName => v_GetChannel.channel_name);
4709: x_LockedFlag := 'N';
4710: x_ChannelName := NULL;
4711: END IF;

Line 4727: IF( XDP_ADAPTER_CORE_DB.checkLockRequired( v_GetCODChannel.channel_name ) ) THEN

4723:
4724: -- skilaru 05/16/2002
4725: -- ER# 2013681 Lock the channel only if it is of application mode PIPE..
4726:
4727: IF( XDP_ADAPTER_CORE_DB.checkLockRequired( v_GetCODChannel.channel_name ) ) THEN
4728:
4729: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA(v_GetCODChannel.channel_name);
4730: ELSE
4731: -- skilaru 05/16/2002

Line 4729: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA(v_GetCODChannel.channel_name);

4725: -- ER# 2013681 Lock the channel only if it is of application mode PIPE..
4726:
4727: IF( XDP_ADAPTER_CORE_DB.checkLockRequired( v_GetCODChannel.channel_name ) ) THEN
4728:
4729: l_Status := XDP_ADAPTER_CORE_DB.ObtainAdapterLock_FA(v_GetCODChannel.channel_name);
4730: ELSE
4731: -- skilaru 05/16/2002
4732: -- IF it is NON-PIPE based channel we dont need a lock at all..
4733: -- so mimic as if we acuired a lock..

Line 4744: if XDP_ADAPTER_CORE_DB.Verify_Adapter (v_GetCODChannel.channel_name) then

4740:
4741: x_LockedFlag := 'Y';
4742: x_ChannelName := v_GetCODChannel.channel_name;
4743:
4744: if XDP_ADAPTER_CORE_DB.Verify_Adapter (v_GetCODChannel.channel_name) then
4745: return;
4746: else
4747: -- Release the Lock
4748: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock

Line 4748: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock

4744: if XDP_ADAPTER_CORE_DB.Verify_Adapter (v_GetCODChannel.channel_name) then
4745: return;
4746: else
4747: -- Release the Lock
4748: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock
4749: (p_ChannelName => v_GetCODChannel.channel_name);
4750: x_LockedFlag := 'N';
4751: x_ChannelName := NULL;
4752: END IF;

Line 4774: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => x_ChannelName);

4770: close c_GetChannel;
4771: end if;
4772:
4773: IF x_LockedFlag = 'Y' and x_ChannelName is not null THEN
4774: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => x_ChannelName);
4775: END IF ;
4776: raise;
4777: end SearchAndLockChannel;
4778:

Line 4904: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => l_ChannelName);

4900: l_Result := 'FAILURE';
4901: END;
4902:
4903: if l_Result = 'FAILURE' then
4904: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => l_ChannelName);
4905: end if;
4906:
4907: return (l_Result);
4908: end ConnectOnDemand;

Line 4933: if (XDP_ADAPTER_CORE_DB.Is_Adapter_Implemented (p_ChannelName=>p_Channel_Name)) then

4929: -- Updated sacsharm
4930: -- Adapter business object API should not be used as it locks/releases lock
4931: -- does Handover, etc.
4932:
4933: if (XDP_ADAPTER_CORE_DB.Is_Adapter_Implemented (p_ChannelName=>p_Channel_Name)) then
4934:
4935: XDP_ADAPTER_CORE.ProcessControlCommand(p_ChannelName => p_Channel_Name,
4936: p_Operation => XDP_ADAPTER.pv_opConnect,
4937: p_Status => l_Status1,

Line 4935: XDP_ADAPTER_CORE.ProcessControlCommand(p_ChannelName => p_Channel_Name,

4931: -- does Handover, etc.
4932:
4933: if (XDP_ADAPTER_CORE_DB.Is_Adapter_Implemented (p_ChannelName=>p_Channel_Name)) then
4934:
4935: XDP_ADAPTER_CORE.ProcessControlCommand(p_ChannelName => p_Channel_Name,
4936: p_Operation => XDP_ADAPTER.pv_opConnect,
4937: p_Status => l_Status1,
4938: p_ErrorMessage => x_error_description);
4939:

Line 4936: p_Operation => XDP_ADAPTER.pv_opConnect,

4932:
4933: if (XDP_ADAPTER_CORE_DB.Is_Adapter_Implemented (p_ChannelName=>p_Channel_Name)) then
4934:
4935: XDP_ADAPTER_CORE.ProcessControlCommand(p_ChannelName => p_Channel_Name,
4936: p_Operation => XDP_ADAPTER.pv_opConnect,
4937: p_Status => l_Status1,
4938: p_ErrorMessage => x_error_description);
4939:
4940: if l_Status1 <> XDP_ADAPTER_CORE.pv_AdapterResponseSuccess then

Line 4940: if l_Status1 <> XDP_ADAPTER_CORE.pv_AdapterResponseSuccess then

4936: p_Operation => XDP_ADAPTER.pv_opConnect,
4937: p_Status => l_Status1,
4938: p_ErrorMessage => x_error_description);
4939:
4940: if l_Status1 <> XDP_ADAPTER_CORE.pv_AdapterResponseSuccess then
4941: x_return_code := XDP_ADAPTER.pv_retAdapterOpFailed;
4942: end if;
4943: END IF;
4944:

Line 4941: x_return_code := XDP_ADAPTER.pv_retAdapterOpFailed;

4937: p_Status => l_Status1,
4938: p_ErrorMessage => x_error_description);
4939:
4940: if l_Status1 <> XDP_ADAPTER_CORE.pv_AdapterResponseSuccess then
4941: x_return_code := XDP_ADAPTER.pv_retAdapterOpFailed;
4942: end if;
4943: END IF;
4944:
4945: exception

Line 4960: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

4956: 'ERROR_DESC='||substr(x_error_description,1,1500)||'#XDP#';
4957:
4958: -- Changed sacsharm Use autonomous transaction instead
4959:
4960: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
4961: p_ChannelName => p_Channel_Name,
4962: -- p_Status => XDP_ADAPTER.pv_statusDisconnected,
4963: p_Status => XDP_ADAPTER.pv_statusError,
4964: p_ErrorMsg => 'INTERNAL_ERROR',

Line 4962: -- p_Status => XDP_ADAPTER.pv_statusDisconnected,

4958: -- Changed sacsharm Use autonomous transaction instead
4959:
4960: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
4961: p_ChannelName => p_Channel_Name,
4962: -- p_Status => XDP_ADAPTER.pv_statusDisconnected,
4963: p_Status => XDP_ADAPTER.pv_statusError,
4964: p_ErrorMsg => 'INTERNAL_ERROR',
4965: p_ErrorMsgParams => x_parameters
4966: );

Line 4963: p_Status => XDP_ADAPTER.pv_statusError,

4959:
4960: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
4961: p_ChannelName => p_Channel_Name,
4962: -- p_Status => XDP_ADAPTER.pv_statusDisconnected,
4963: p_Status => XDP_ADAPTER.pv_statusError,
4964: p_ErrorMsg => 'INTERNAL_ERROR',
4965: p_ErrorMsgParams => x_parameters
4966: );
4967:

Line 4976: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (

4972: l_Result := 'N';
4973: else
4974: -- Update The Adapter Status to be BUSY
4975:
4976: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
4977: p_ChannelName => p_Channel_Name,
4978: p_Status => XDP_ADAPTER.pv_statusInUse
4979: );
4980:

Line 4978: p_Status => XDP_ADAPTER.pv_statusInUse

4974: -- Update The Adapter Status to be BUSY
4975:
4976: XDP_ADAPTER_CORE_DB.Update_Adapter_Status (
4977: p_ChannelName => p_Channel_Name,
4978: p_Status => XDP_ADAPTER.pv_statusInUse
4979: );
4980:
4981: l_Result := 'Y';
4982: end if;

Line 4989: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => p_Channel_Name);

4985: x_return_code := SQLCODE;
4986: x_error_description := SQLERRM;
4987: l_Result := 'N';
4988: END;
4989: l_Status := XDP_ADAPTER_CORE_DB.ReleaseAdapterLock (p_ChannelName => p_Channel_Name);
4990: return (l_Result);
4991: end ConnectOnDemand;
4992:
4993:

Line 5546: UPDATE xdp_adapter_job_queue

5542: -- with System Hold status 'Y' then update them to 'N' so that they
5543: -- will be picked up in Handover Process..
5544: IF (lv_error_count > lv_error_threshold) THEN
5545: -- reset System Hold to 'N' so that adapter will pick it up..
5546: UPDATE xdp_adapter_job_queue
5547: SET system_hold = 'N',
5548: last_updated_by = FND_GLOBAL.USER_ID,
5549: last_update_date = sysdate,
5550: last_update_login = FND_GLOBAL.USER_ID