DBA Data[Home] [Help]

APPS.AD_EVENT_REGISTRY_PKG dependencies on AD_EVENT_VERSIONS

Line 17: Event_Status ad_event_versions.status%TYPE,

13: Owner ad_events.owner%TYPE,
14: Event_Name ad_events.event_name%TYPE,
15: Event_Context ad_events.event_context%TYPE,
16: Event_Id ad_events.event_id%TYPE,
17: Event_Status ad_event_versions.status%TYPE,
18: -- worker status will be a string indicating status of all the workers
19: Worker_Status ad_event_versions.worker_status%TYPE,
20: Event_Version ad_events.last_version%TYPE,
21: Event_Type ad_events.event_type%TYPE ,

Line 19: Worker_Status ad_event_versions.worker_status%TYPE,

15: Event_Context ad_events.event_context%TYPE,
16: Event_Id ad_events.event_id%TYPE,
17: Event_Status ad_event_versions.status%TYPE,
18: -- worker status will be a string indicating status of all the workers
19: Worker_Status ad_event_versions.worker_status%TYPE,
20: Event_Version ad_events.last_version%TYPE,
21: Event_Type ad_events.event_type%TYPE ,
22: Module_Name ad_event_transitions.module_name%TYPE,
23: Worker_Id ad_event_transitions.worker_id%TYPE,

Line 24: Max_Workers ad_event_versions.num_workers%TYPE );

20: Event_Version ad_events.last_version%TYPE,
21: Event_Type ad_events.event_type%TYPE ,
22: Module_Name ad_event_transitions.module_name%TYPE,
23: Worker_Id ad_event_transitions.worker_id%TYPE,
24: Max_Workers ad_event_versions.num_workers%TYPE );
25:
26: -- Type of table to store the list of events.
27: TYPE Event_Tbl_Type IS TABLE OF Event_Rec_Type INDEX BY BINARY_INTEGER ;
28:

Line 255: l_Event_Status ad_event_versions.status%TYPE;

251: -- Local variable declarations
252: l_Version ad_events.last_version%TYPE;
253: l_Event_Id ad_events.event_id%TYPE;
254: l_Event_Type ad_events.event_type%TYPE;
255: l_Event_Status ad_event_versions.status%TYPE;
256: l_Worker_Status_String ad_event_versions.worker_status%TYPE;
257: l_Event_Index NUMBER(3) ;
258: l_Commit_Flag BOOLEAN := FALSE ;
259:

Line 256: l_Worker_Status_String ad_event_versions.worker_status%TYPE;

252: l_Version ad_events.last_version%TYPE;
253: l_Event_Id ad_events.event_id%TYPE;
254: l_Event_Type ad_events.event_type%TYPE;
255: l_Event_Status ad_event_versions.status%TYPE;
256: l_Worker_Status_String ad_event_versions.worker_status%TYPE;
257: l_Event_Index NUMBER(3) ;
258: l_Commit_Flag BOOLEAN := FALSE ;
259:
260: -- The following variables will be used to store the IN parameter value

Line 267: l_Prev_Max_Workers ad_event_versions.num_workers%TYPE ;

263: l_p_Version ad_events.last_version%TYPE;
264:
265: -- The following variable holds the value of number of workers in the last
266: -- call, in case the event fails and restarted this value will be useful.
267: l_Prev_Max_Workers ad_event_versions.num_workers%TYPE ;
268: l_Error_Message VARCHAR2 (100);
269:
270: BEGIN -- Begin Procedure
271: --

Line 334: -- It has to be inserted into AD_EVENT_VERSIONS.

330: l_Worker_Status_String := Initialize_Worker_String(p_Num_Workers);
331: --
332: -- I.e. A version with a lesser version number exists.
333: -- A higher version is being registered.
334: -- It has to be inserted into AD_EVENT_VERSIONS.
335: --
336: INSERT INTO ad_event_versions(
337: event_id,
338: version,

Line 336: INSERT INTO ad_event_versions(

332: -- I.e. A version with a lesser version number exists.
333: -- A higher version is being registered.
334: -- It has to be inserted into AD_EVENT_VERSIONS.
335: --
336: INSERT INTO ad_event_versions(
337: event_id,
338: version,
339: status,
340: creation_date,

Line 377: FROM ad_Event_Versions

373: num_workers
374: INTO l_Event_Status,
375: l_Worker_Status_String,
376: l_Prev_Max_Workers
377: FROM ad_Event_Versions
378: WHERE event_id = l_Event_Id
379: AND version = l_p_Version;
380: EXCEPTION
381: WHEN OTHERS THEN

Line 412: -- Insert the version details into AD_EVENT_VERSIONS

408: SYSDATE )
409: RETURNING event_id
410: INTO l_Event_Id;
411:
412: -- Insert the version details into AD_EVENT_VERSIONS
413: --
414: -- Form the worker status string
415: --
416: l_Worker_Status_String := Initialize_Worker_String(p_Num_Workers);

Line 418: INSERT INTO ad_event_versions(

414: -- Form the worker status string
415: --
416: l_Worker_Status_String := Initialize_Worker_String(p_Num_Workers);
417:
418: INSERT INTO ad_event_versions(
419: event_id,
420: version,
421: status,
422: creation_date,

Line 497: -- in ad_event_versions

493: --
494: g_Events_Tbl(l_Event_Index).Worker_Status :=
495: Initialize_Worker_String(p_Num_Workers);
496: -- reset the worker status string and number_workers
497: -- in ad_event_versions
498: UPDATE ad_event_versions
499: SET num_workers = p_Num_Workers,
500: worker_status = g_Events_Tbl(l_Event_Index).Worker_Status ,
501: last_update_date = SYSDATE

Line 498: UPDATE ad_event_versions

494: g_Events_Tbl(l_Event_Index).Worker_Status :=
495: Initialize_Worker_String(p_Num_Workers);
496: -- reset the worker status string and number_workers
497: -- in ad_event_versions
498: UPDATE ad_event_versions
499: SET num_workers = p_Num_Workers,
500: worker_status = g_Events_Tbl(l_Event_Index).Worker_Status ,
501: last_update_date = SYSDATE
502: WHERE event_id = l_Event_Id

Line 553: l_Event_Status ad_event_versions.status%TYPE;

549: p_Event_Name IN VARCHAR2,
550: p_Context IN VARCHAR2 := NULL
551: )
552: IS
553: l_Event_Status ad_event_versions.status%TYPE;
554: l_Event_type ad_events.event_type%TYPE;
555: l_Event_Id ad_events.event_id%TYPE;
556: l_Version ad_event_versions.version%TYPE;
557: l_Worker_Id ad_event_transitions.worker_id%TYPE ;

Line 556: l_Version ad_event_versions.version%TYPE;

552: IS
553: l_Event_Status ad_event_versions.status%TYPE;
554: l_Event_type ad_events.event_type%TYPE;
555: l_Event_Id ad_events.event_id%TYPE;
556: l_Version ad_event_versions.version%TYPE;
557: l_Worker_Id ad_event_transitions.worker_id%TYPE ;
558: l_Worker_Status_String ad_event_versions.worker_status%TYPE ;
559: l_Module_Name ad_event_transitions.module_name%TYPE ;
560: l_Event_Index NUMBER ;

Line 558: l_Worker_Status_String ad_event_versions.worker_status%TYPE ;

554: l_Event_type ad_events.event_type%TYPE;
555: l_Event_Id ad_events.event_id%TYPE;
556: l_Version ad_event_versions.version%TYPE;
557: l_Worker_Id ad_event_transitions.worker_id%TYPE ;
558: l_Worker_Status_String ad_event_versions.worker_status%TYPE ;
559: l_Module_Name ad_event_transitions.module_name%TYPE ;
560: l_Event_Index NUMBER ;
561: -- this variable is used to hold in the IN parameter
562: l_p_Context ad_events.event_context%TYPE ;

Line 617: -- Update the start time and last update date in AD_EVENT_VERSIONS.

613: --
614: RAISE_APPLICATION_ERROR(-20010,'Event is Already Completed');
615: ELSIF ( l_Event_Status = INITIALIZED_STATUS ) THEN --else if event status
616: --
617: -- Update the start time and last update date in AD_EVENT_VERSIONS.
618: --
619: UPDATE ad_event_versions
620: SET start_time = SYSDATE ,
621: last_update_date = SYSDATE

Line 619: UPDATE ad_event_versions

615: ELSIF ( l_Event_Status = INITIALIZED_STATUS ) THEN --else if event status
616: --
617: -- Update the start time and last update date in AD_EVENT_VERSIONS.
618: --
619: UPDATE ad_event_versions
620: SET start_time = SYSDATE ,
621: last_update_date = SYSDATE
622: WHERE event_id = l_Event_Id
623: AND version = l_Version;

Line 657: l_Event_Status ad_event_versions.status%TYPE;

653: p_Event_Name IN VARCHAR2,
654: p_Context IN VARCHAR2 := NULL
655: )
656: IS
657: l_Event_Status ad_event_versions.status%TYPE;
658: l_New_Status ad_event_versions.status%TYPE;
659: l_Event_type ad_events.event_type%TYPE;
660: l_Event_Id ad_events.event_id%TYPE;
661: l_Version ad_event_versions.version%TYPE;

Line 658: l_New_Status ad_event_versions.status%TYPE;

654: p_Context IN VARCHAR2 := NULL
655: )
656: IS
657: l_Event_Status ad_event_versions.status%TYPE;
658: l_New_Status ad_event_versions.status%TYPE;
659: l_Event_type ad_events.event_type%TYPE;
660: l_Event_Id ad_events.event_id%TYPE;
661: l_Version ad_event_versions.version%TYPE;
662: l_Worker_Status_String ad_event_versions.worker_status%TYPE;

Line 661: l_Version ad_event_versions.version%TYPE;

657: l_Event_Status ad_event_versions.status%TYPE;
658: l_New_Status ad_event_versions.status%TYPE;
659: l_Event_type ad_events.event_type%TYPE;
660: l_Event_Id ad_events.event_id%TYPE;
661: l_Version ad_event_versions.version%TYPE;
662: l_Worker_Status_String ad_event_versions.worker_status%TYPE;
663: l_End_Time DATE ;
664: l_Max_Workers ad_event_versions.num_workers%TYPE ;
665: l_Worker_Id ad_event_transitions.worker_id%TYPE ;

Line 662: l_Worker_Status_String ad_event_versions.worker_status%TYPE;

658: l_New_Status ad_event_versions.status%TYPE;
659: l_Event_type ad_events.event_type%TYPE;
660: l_Event_Id ad_events.event_id%TYPE;
661: l_Version ad_event_versions.version%TYPE;
662: l_Worker_Status_String ad_event_versions.worker_status%TYPE;
663: l_End_Time DATE ;
664: l_Max_Workers ad_event_versions.num_workers%TYPE ;
665: l_Worker_Id ad_event_transitions.worker_id%TYPE ;
666: l_Module_Name ad_event_transitions.module_name%TYPE ;

Line 664: l_Max_Workers ad_event_versions.num_workers%TYPE ;

660: l_Event_Id ad_events.event_id%TYPE;
661: l_Version ad_event_versions.version%TYPE;
662: l_Worker_Status_String ad_event_versions.worker_status%TYPE;
663: l_End_Time DATE ;
664: l_Max_Workers ad_event_versions.num_workers%TYPE ;
665: l_Worker_Id ad_event_transitions.worker_id%TYPE ;
666: l_Module_Name ad_event_transitions.module_name%TYPE ;
667: -- the following variable stores the index that points to the current
668: -- event's record in the event list

Line 709: -- AD_EVENT_VERSIONS by joining using the version.

705: p_Event_Name);
706:
707: --
708: -- Select the details of the event joining AD_EVENTS and
709: -- AD_EVENT_VERSIONS by joining using the version.
710: --
711:
712: SELECT status,
713: event_type,

Line 722: FROM ad_events ae, ad_event_versions av

718: l_Event_type,
719: l_Event_Id,
720: l_Version,
721: l_Worker_Status_String
722: FROM ad_events ae, ad_event_versions av
723: WHERE ae.event_id = av.event_id
724: AND ae.last_version = av.version
725: AND ae.owner = p_Owner
726: AND ae.event_name = p_Event_Name

Line 766: UPDATE ad_event_versions

762: l_New_Status := COMPLETED_STATUS;
763: l_End_Time := SYSDATE;
764: END IF;
765:
766: UPDATE ad_event_versions
767: SET status = l_New_Status,
768: end_time = l_End_Time,
769: last_update_date = SYSDATE ,
770: worker_status = l_Worker_Status_String

Line 802: UPDATE ad_event_versions

798: -- New status will be - completed status.
799: --
800: l_New_Status := COMPLETED_STATUS;
801:
802: UPDATE ad_event_versions
803: SET status = l_New_Status,
804: end_time = SYSDATE ,
805: last_update_date = SYSDATE
806: WHERE event_id = l_Event_Id

Line 896: ad_Event_Versions av

892: --
893: SELECT 1
894: INTO l_Temp_Var
895: FROM ad_events ae,
896: ad_Event_Versions av
897: WHERE ae.owner = p_Owner
898: AND ae.event_name = p_Event_Name
899: AND ae.event_context = l_p_Context
900: AND ae.event_id = av.event_id

Line 930: l_Event_Status ad_event_versions.status%TYPE;

926: p_Num_Workers IN NUMBER := NULL )
927: RETURN BOOLEAN
928: IS
929: -- Local variable declarations.
930: l_Event_Status ad_event_versions.status%TYPE;
931: l_Worker_Status_String ad_event_versions.worker_status%TYPE;
932: l_Num_Workers ad_event_versions.num_workers%TYPE;
933: l_Return_Status BOOLEAN;
934: l_Event_Version ad_event_versions.version%TYPE;

Line 931: l_Worker_Status_String ad_event_versions.worker_status%TYPE;

927: RETURN BOOLEAN
928: IS
929: -- Local variable declarations.
930: l_Event_Status ad_event_versions.status%TYPE;
931: l_Worker_Status_String ad_event_versions.worker_status%TYPE;
932: l_Num_Workers ad_event_versions.num_workers%TYPE;
933: l_Return_Status BOOLEAN;
934: l_Event_Version ad_event_versions.version%TYPE;
935: -- this variable is used to hold in the IN parameter

Line 932: l_Num_Workers ad_event_versions.num_workers%TYPE;

928: IS
929: -- Local variable declarations.
930: l_Event_Status ad_event_versions.status%TYPE;
931: l_Worker_Status_String ad_event_versions.worker_status%TYPE;
932: l_Num_Workers ad_event_versions.num_workers%TYPE;
933: l_Return_Status BOOLEAN;
934: l_Event_Version ad_event_versions.version%TYPE;
935: -- this variable is used to hold in the IN parameter
936: l_p_Context ad_events.event_context%TYPE ;

Line 934: l_Event_Version ad_event_versions.version%TYPE;

930: l_Event_Status ad_event_versions.status%TYPE;
931: l_Worker_Status_String ad_event_versions.worker_status%TYPE;
932: l_Num_Workers ad_event_versions.num_workers%TYPE;
933: l_Return_Status BOOLEAN;
934: l_Event_Version ad_event_versions.version%TYPE;
935: -- this variable is used to hold in the IN parameter
936: l_p_Context ad_events.event_context%TYPE ;
937:
938: BEGIN

Line 959: -- AD_EVENT_VERSIONS are joined on this column.

955:
956: --
957: -- Select the details of the event based on the input details.
958: -- Since the event id is available in AD_EVENTS only AD_EVENTS and
959: -- AD_EVENT_VERSIONS are joined on this column.
960: -- If a specific version is supplied use that version in the where
961: -- clause otherwise use the last_version column of ad_events.
962: --
963: SELECT av.status,

Line 972: ad_event_versions av

968: l_Worker_Status_String,
969: l_Event_Version,
970: l_Num_Workers
971: FROM ad_events ae,
972: ad_event_versions av
973: WHERE ae.owner = p_Owner
974: AND ae.event_name = p_Event_Name
975: AND ae.event_context = l_p_Context
976: AND av.event_id = ae.event_id

Line 1076: l_Status ad_event_versions.status%TYPE;

1072: p_Min_Version IN NUMBER := NULL ,
1073: p_Specific_Version IN NUMBER := NULL )
1074: RETURN VARCHAR2
1075: IS
1076: l_Status ad_event_versions.status%TYPE;
1077: l_Event_Version ad_event_versions.version%TYPE;
1078: -- this variable is used to hold in the IN parameter
1079: l_p_Context ad_events.event_context%TYPE ;
1080: BEGIN

Line 1077: l_Event_Version ad_event_versions.version%TYPE;

1073: p_Specific_Version IN NUMBER := NULL )
1074: RETURN VARCHAR2
1075: IS
1076: l_Status ad_event_versions.status%TYPE;
1077: l_Event_Version ad_event_versions.version%TYPE;
1078: -- this variable is used to hold in the IN parameter
1079: l_p_Context ad_events.event_context%TYPE ;
1080: BEGIN
1081: --

Line 1109: ad_event_versions av

1105: INTO l_Status,
1106: l_Event_Version
1107: FROM
1108: ad_events ae,
1109: ad_event_versions av
1110: WHERE ae.owner = p_Owner
1111: AND ae.event_name = p_Event_Name
1112: AND ae.event_context = l_p_Context
1113: AND av.event_id = ae.event_id

Line 1139: l_Event_Status ad_event_versions.status%TYPE;

1135: p_Event_Name IN VARCHAR2,
1136: p_Status IN VARCHAR2,
1137: p_Context IN VARCHAR2 := NULL )
1138: IS
1139: l_Event_Status ad_event_versions.status%TYPE;
1140: l_Num_Workers ad_event_versions.num_workers%TYPE;
1141: l_Event_Id ad_event_versions.event_id%TYPE;
1142: l_Version ad_event_versions.version%TYPE;
1143: l_Event_Index NUMBER ;

Line 1140: l_Num_Workers ad_event_versions.num_workers%TYPE;

1136: p_Status IN VARCHAR2,
1137: p_Context IN VARCHAR2 := NULL )
1138: IS
1139: l_Event_Status ad_event_versions.status%TYPE;
1140: l_Num_Workers ad_event_versions.num_workers%TYPE;
1141: l_Event_Id ad_event_versions.event_id%TYPE;
1142: l_Version ad_event_versions.version%TYPE;
1143: l_Event_Index NUMBER ;
1144: l_Event_Type ad_events.event_type%TYPE ;

Line 1141: l_Event_Id ad_event_versions.event_id%TYPE;

1137: p_Context IN VARCHAR2 := NULL )
1138: IS
1139: l_Event_Status ad_event_versions.status%TYPE;
1140: l_Num_Workers ad_event_versions.num_workers%TYPE;
1141: l_Event_Id ad_event_versions.event_id%TYPE;
1142: l_Version ad_event_versions.version%TYPE;
1143: l_Event_Index NUMBER ;
1144: l_Event_Type ad_events.event_type%TYPE ;
1145: l_Module_Name ad_event_transitions.module_name%TYPE ;

Line 1142: l_Version ad_event_versions.version%TYPE;

1138: IS
1139: l_Event_Status ad_event_versions.status%TYPE;
1140: l_Num_Workers ad_event_versions.num_workers%TYPE;
1141: l_Event_Id ad_event_versions.event_id%TYPE;
1142: l_Version ad_event_versions.version%TYPE;
1143: l_Event_Index NUMBER ;
1144: l_Event_Type ad_events.event_type%TYPE ;
1145: l_Module_Name ad_event_transitions.module_name%TYPE ;
1146: l_Worker_Id ad_event_transitions.worker_id%TYPE ;

Line 1227: UPDATE ad_event_versions

1223: p_Event_Name);
1224: --
1225: -- Validations are thru. Now update the status.
1226: --
1227: UPDATE ad_event_versions
1228: SET status = p_Status,
1229: last_update_date = SYSDATE
1230: WHERE event_id = l_Event_Id
1231: AND version = l_Version;

Line 1279: l_Event_Id ad_event_versions.event_id%TYPE;

1275: p_Event_Name IN VARCHAR2 ,
1276: p_Module_Name IN VARCHAR2 ,
1277: p_Context IN VARCHAR2 := NULL )
1278: IS
1279: l_Event_Id ad_event_versions.event_id%TYPE;
1280: l_Event_Version ad_event_versions.version%TYPE;
1281: l_Event_Status ad_event_versions.status%TYPE;
1282: l_Max_Workers ad_event_versions.num_workers%TYPE ;
1283: l_Worker_Status_String ad_event_versions.worker_status%TYPE;

Line 1280: l_Event_Version ad_event_versions.version%TYPE;

1276: p_Module_Name IN VARCHAR2 ,
1277: p_Context IN VARCHAR2 := NULL )
1278: IS
1279: l_Event_Id ad_event_versions.event_id%TYPE;
1280: l_Event_Version ad_event_versions.version%TYPE;
1281: l_Event_Status ad_event_versions.status%TYPE;
1282: l_Max_Workers ad_event_versions.num_workers%TYPE ;
1283: l_Worker_Status_String ad_event_versions.worker_status%TYPE;
1284: l_Worker_Id ad_event_transitions.worker_id%TYPE ;

Line 1281: l_Event_Status ad_event_versions.status%TYPE;

1277: p_Context IN VARCHAR2 := NULL )
1278: IS
1279: l_Event_Id ad_event_versions.event_id%TYPE;
1280: l_Event_Version ad_event_versions.version%TYPE;
1281: l_Event_Status ad_event_versions.status%TYPE;
1282: l_Max_Workers ad_event_versions.num_workers%TYPE ;
1283: l_Worker_Status_String ad_event_versions.worker_status%TYPE;
1284: l_Worker_Id ad_event_transitions.worker_id%TYPE ;
1285: l_Module_Name ad_event_transitions.module_name%TYPE ;

Line 1282: l_Max_Workers ad_event_versions.num_workers%TYPE ;

1278: IS
1279: l_Event_Id ad_event_versions.event_id%TYPE;
1280: l_Event_Version ad_event_versions.version%TYPE;
1281: l_Event_Status ad_event_versions.status%TYPE;
1282: l_Max_Workers ad_event_versions.num_workers%TYPE ;
1283: l_Worker_Status_String ad_event_versions.worker_status%TYPE;
1284: l_Worker_Id ad_event_transitions.worker_id%TYPE ;
1285: l_Module_Name ad_event_transitions.module_name%TYPE ;
1286: l_Event_Index NUMBER ;

Line 1283: l_Worker_Status_String ad_event_versions.worker_status%TYPE;

1279: l_Event_Id ad_event_versions.event_id%TYPE;
1280: l_Event_Version ad_event_versions.version%TYPE;
1281: l_Event_Status ad_event_versions.status%TYPE;
1282: l_Max_Workers ad_event_versions.num_workers%TYPE ;
1283: l_Worker_Status_String ad_event_versions.worker_status%TYPE;
1284: l_Worker_Id ad_event_transitions.worker_id%TYPE ;
1285: l_Module_Name ad_event_transitions.module_name%TYPE ;
1286: l_Event_Index NUMBER ;
1287: -- this variable is used to hold in the IN parameter

Line 1318: FROM ad_events ae, ad_event_versions av

1314: INTO l_Event_Id,
1315: l_Event_Version,
1316: l_Event_Status,
1317: l_Max_Workers
1318: FROM ad_events ae, ad_event_versions av
1319: WHERE ae.owner = p_Owner
1320: AND ae.event_name = p_Event_Name
1321: AND ae.event_context = l_p_Context
1322: AND av.event_id = ae.event_id

Line 1335: UPDATE ad_event_versions

1331: --
1332: -- Form the worker status string
1333: l_Worker_Status_String := Initialize_Worker_String(l_Max_Workers);
1334:
1335: UPDATE ad_event_versions
1336: SET status = INITIALIZED_STATUS,
1337: start_time = NULL ,
1338: end_time = NULL ,
1339: last_update_date = SYSDATE ,

Line 1409: l_Event_Version ad_event_versions.version%TYPE ;

1405: p_Worker_Id IN NUMBER := NULL ,
1406: p_Num_Workers IN NUMBER := NULL )
1407: IS
1408: l_Event_Id ad_events.event_id%TYPE;
1409: l_Event_Version ad_event_versions.version%TYPE ;
1410: l_Event_Status ad_event_versions.status%TYPE ;
1411: l_New_Status ad_event_versions.status%TYPE ;
1412: l_Worker_Status_String ad_event_versions.worker_status%TYPE ;
1413: l_End_Time ad_event_versions.end_time%TYPE ;

Line 1410: l_Event_Status ad_event_versions.status%TYPE ;

1406: p_Num_Workers IN NUMBER := NULL )
1407: IS
1408: l_Event_Id ad_events.event_id%TYPE;
1409: l_Event_Version ad_event_versions.version%TYPE ;
1410: l_Event_Status ad_event_versions.status%TYPE ;
1411: l_New_Status ad_event_versions.status%TYPE ;
1412: l_Worker_Status_String ad_event_versions.worker_status%TYPE ;
1413: l_End_Time ad_event_versions.end_time%TYPE ;
1414: l_Worker_Id ad_event_transitions.worker_id%TYPE ;

Line 1411: l_New_Status ad_event_versions.status%TYPE ;

1407: IS
1408: l_Event_Id ad_events.event_id%TYPE;
1409: l_Event_Version ad_event_versions.version%TYPE ;
1410: l_Event_Status ad_event_versions.status%TYPE ;
1411: l_New_Status ad_event_versions.status%TYPE ;
1412: l_Worker_Status_String ad_event_versions.worker_status%TYPE ;
1413: l_End_Time ad_event_versions.end_time%TYPE ;
1414: l_Worker_Id ad_event_transitions.worker_id%TYPE ;
1415: l_Prev_Max_Workers ad_event_versions.num_workers%TYPE ;

Line 1412: l_Worker_Status_String ad_event_versions.worker_status%TYPE ;

1408: l_Event_Id ad_events.event_id%TYPE;
1409: l_Event_Version ad_event_versions.version%TYPE ;
1410: l_Event_Status ad_event_versions.status%TYPE ;
1411: l_New_Status ad_event_versions.status%TYPE ;
1412: l_Worker_Status_String ad_event_versions.worker_status%TYPE ;
1413: l_End_Time ad_event_versions.end_time%TYPE ;
1414: l_Worker_Id ad_event_transitions.worker_id%TYPE ;
1415: l_Prev_Max_Workers ad_event_versions.num_workers%TYPE ;
1416: l_Commit_Flag BOOLEAN ;

Line 1413: l_End_Time ad_event_versions.end_time%TYPE ;

1409: l_Event_Version ad_event_versions.version%TYPE ;
1410: l_Event_Status ad_event_versions.status%TYPE ;
1411: l_New_Status ad_event_versions.status%TYPE ;
1412: l_Worker_Status_String ad_event_versions.worker_status%TYPE ;
1413: l_End_Time ad_event_versions.end_time%TYPE ;
1414: l_Worker_Id ad_event_transitions.worker_id%TYPE ;
1415: l_Prev_Max_Workers ad_event_versions.num_workers%TYPE ;
1416: l_Commit_Flag BOOLEAN ;
1417: l_event_completed_EXP EXCEPTION ;

Line 1415: l_Prev_Max_Workers ad_event_versions.num_workers%TYPE ;

1411: l_New_Status ad_event_versions.status%TYPE ;
1412: l_Worker_Status_String ad_event_versions.worker_status%TYPE ;
1413: l_End_Time ad_event_versions.end_time%TYPE ;
1414: l_Worker_Id ad_event_transitions.worker_id%TYPE ;
1415: l_Prev_Max_Workers ad_event_versions.num_workers%TYPE ;
1416: l_Commit_Flag BOOLEAN ;
1417: l_event_completed_EXP EXCEPTION ;
1418: -- these variables are used to hold in the IN parameter
1419: l_p_Context ad_events.event_context%TYPE ;

Line 1459: FROM ad_events ae, ad_event_versions av

1455: l_Event_Id,
1456: l_Worker_Status_String,
1457: l_Prev_Max_Workers,
1458: l_Event_Version
1459: FROM ad_events ae, ad_event_versions av
1460: WHERE ae.event_id = av.event_id
1461: AND ae.last_version = av.version
1462: AND ae.owner = p_Owner
1463: AND ae.event_name = p_Event_Name

Line 1484: -- So, the worker details in ad_event_versions has to be updated

1480: -- number of workers.
1481: -- Here we compare the number of workers in this call with the number
1482: -- of workers from the registry. If there is any change we assume that
1483: -- the event is re-scheduled among a different set of workers.
1484: -- So, the worker details in ad_event_versions has to be updated
1485: -- and a special transition entry has to be inserted into
1486: -- ad_event_transitions.
1487: --
1488: IF ( NVL (l_Prev_Max_Workers,1) <> NVL (p_Num_Workers,1) ) THEN

Line 1541: -- Now update ad_Event_Versions to make the changes happened as a

1537: p_Worker_Id => p_Worker_Id);
1538:
1539: END IF ; -- if # resch_worker
1540: --
1541: -- Now update ad_Event_Versions to make the changes happened as a
1542: -- result of the re-scheduling.
1543: --
1544: UPDATE ad_event_versions
1545: SET num_workers = p_Num_Workers,

Line 1544: UPDATE ad_event_versions

1540: --
1541: -- Now update ad_Event_Versions to make the changes happened as a
1542: -- result of the re-scheduling.
1543: --
1544: UPDATE ad_event_versions
1545: SET num_workers = p_Num_Workers,
1546: status = l_New_Status,
1547: worker_status = l_Worker_Status_String,
1548: start_time = DECODE(start_time,null,SYSDATE,

Line 1588: -- Update ad_event_versions with the new status

1584: l_End_Time := SYSDATE;
1585: END IF;
1586:
1587: --
1588: -- Update ad_event_versions with the new status
1589: --
1590: UPDATE ad_event_versions
1591: SET status = l_New_Status,
1592: end_time = l_End_Time,

Line 1590: UPDATE ad_event_versions

1586:
1587: --
1588: -- Update ad_event_versions with the new status
1589: --
1590: UPDATE ad_event_versions
1591: SET status = l_New_Status,
1592: end_time = l_End_Time,
1593: last_update_date = SYSDATE ,
1594: start_time = DECODE(start_time,null,SYSDATE,

Line 1629: UPDATE ad_event_versions

1625: l_Commit_Flag := TRUE ;
1626: --
1627: -- Mark the event as completed here
1628: --
1629: UPDATE ad_event_versions
1630: SET status = COMPLETED_STATUS,
1631: start_time = DECODE(start_time,null,SYSDATE,
1632: start_time),
1633: end_time = SYSDATE ,

Line 1692: INSERT INTO ad_event_versions (

1688: last_update_date = SYSDATE
1689: WHERE event_id = l_Event_Id;
1690:
1691: -- Insert the version details.
1692: INSERT INTO ad_event_versions (
1693: event_id,
1694: version,
1695: status,
1696: start_time,

Line 1785: INSERT INTO ad_event_versions(

1781: -- Insert the event version details here
1782: -- This insertion is done for both single-worker and multi-worker cases
1783: -- but only for the first time.
1784: --
1785: INSERT INTO ad_event_versions(
1786: event_id,
1787: version,
1788: status,
1789: start_time,