EVEDemo.PSWEEP
Class ViewChange

java.lang.Object
  |
  +--java.lang.Thread
        |
        +--EVEDemo.PSWEEP.ViewChange

public class ViewChange
extends java.lang.Thread

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
, activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, exit, getContextClassLoader, getName, getPriority, getThreadGroup, init, interrupt, interrupt0, interrupted, isAlive, isDaemon, isInterrupted, isInterrupted, join, join, join, nextThreadNum, registerNatives, resume, resume0, setContextClassLoader, setDaemon, setName, setPriority, setPriority0, sleep, sleep, start, stop, stop, stop0, suspend, suspend0, toString, yield
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

count

static int count
The instance ID + ":" + COUNT of the ViewChange. To distinguish different threads.

id

int id

clcnt

int clcnt
count how many concurrent DU for this du.

DeltaView

Relation DeltaView

theIndex

int theIndex

du

UpdateData du

PPU

PPUSet PPU

RPU

RPUSet RPU

UMQ

MessageQueue UMQ

publicFIFOChannel

MultiQueue publicFIFOChannel

View

ViewDefinition View

EVEview

View EVEview

uv

UpdateView uv
the UpdateView reference

n

int n
Total number of ISs.
Constructor Detail

ViewChange

public ViewChange(UpdateData theUpdate,
                  ViewDefinition theView,
                  View theEVEview,
                  MultiQueue theFIFO,
                  MessageQueue theMessageQueue,
                  PPUSet pu,
                  RPUSet ru,
                  int totalISs,
                  UpdateView theUV)
Method Detail

incCount

static void incCount()
increase the count.

isConcurrent

boolean isConcurrent(int j)

processSubQuery

Relation processSubQuery(Relation Delta,
                         int j)
                   throws java.lang.Exception

incClcnt

void incClcnt()

run

public void run()
Overrides:
run in class java.lang.Thread

commitUpdate

void commitUpdate(Relation deltaView)