|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--java.lang.Thread | +--EVEDemo.PSWEEP.ViewChange
New thread created by PSWEEP. One ViewChange thread will handle one data updates.
Field Summary | |
(package private) int |
clcnt
count how many concurrent DU for this du. |
(package private) static int |
count
The instance ID + ":" + COUNT of the ViewChange. |
(package private) Relation |
DeltaView
|
(package private) UpdateData |
du
|
(package private) View |
EVEview
|
(package private) int |
id
|
(package private) int |
n
Total number of ISs. |
(package private) PPUSet |
PPU
|
(package private) MultiQueue |
publicFIFOChannel
|
(package private) RPUSet |
RPU
|
(package private) int |
theIndex
|
(package private) MessageQueue |
UMQ
|
(package private) UpdateView |
uv
the UpdateView reference |
(package private) ViewDefinition |
View
|
Fields inherited from class java.lang.Thread |
contextClassLoader,
daemon,
eetop,
group,
inheritedAccessControlContext,
MAX_PRIORITY,
MIN_PRIORITY,
name,
NORM_PRIORITY,
priority,
single_step,
stillborn,
stopThreadPermission,
target,
threadInitNumber,
threadQ,
values |
Constructor Summary | |
ViewChange(UpdateData theUpdate,
ViewDefinition theView,
View theEVEview,
MultiQueue theFIFO,
MessageQueue theMessageQueue,
PPUSet pu,
RPUSet ru,
int totalISs,
UpdateView theUV)
|
Method Summary | |
(package private) void |
commitUpdate(Relation deltaView)
|
(package private) void |
incClcnt()
|
(package private) static void |
incCount()
increase the count. |
(package private) boolean |
isConcurrent(int j)
|
(package private) Relation |
processSubQuery(Relation Delta,
int j)
|
void |
run()
|
Methods inherited from class java.lang.Thread |
|
Methods inherited from class java.lang.Object |
clone,
equals,
finalize,
getClass,
hashCode,
notify,
notifyAll,
wait,
wait,
wait |
Field Detail |
static int count
int id
int clcnt
Relation DeltaView
int theIndex
UpdateData du
PPUSet PPU
RPUSet RPU
MessageQueue UMQ
MultiQueue publicFIFOChannel
ViewDefinition View
View EVEview
UpdateView uv
int n
Constructor Detail |
public ViewChange(UpdateData theUpdate, ViewDefinition theView, View theEVEview, MultiQueue theFIFO, MessageQueue theMessageQueue, PPUSet pu, RPUSet ru, int totalISs, UpdateView theUV)
Method Detail |
static void incCount()
boolean isConcurrent(int j)
Relation processSubQuery(Relation Delta, int j) throws java.lang.Exception
void incClcnt()
public void run()
void commitUpdate(Relation deltaView)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |