Permalink
Browse files

removed useless injection of SafeKeeper instance

  • Loading branch information...
1 parent c475042 commit e89e2952adaa64ae73d59afd6904d73d823e348a Matthieu Morel committed Sep 21, 2011
Showing with 0 additions and 4 deletions.
  1. +0 −4 s4-core/src/main/java/io/s4/processor/PEContainer.java
@@ -84,14 +84,11 @@ public void setSafeKeeper(SafeKeeper sk) {
public void addProcessor(AbstractPE processor) {
System.out.println("adding pe: " + processor);
PrototypeWrapper pw = new PrototypeWrapper(processor, clock);
-// pw.setSafeKeeper(safeKeeper);
prototypeWrappers.add(pw);
adviceLists.add(pw.advise());
}
public void setProcessors(AbstractPE[] processors) {
- // prototypeWrappers = new ArrayList<PrototypeWrapper>();
-
for (int i = 0; i < processors.length; i++) {
addProcessor(processors[i]);
}
@@ -111,7 +108,6 @@ public void init() {
workQueue = new LinkedBlockingQueue<EventWrapper>(maxQueueSize);
for (PrototypeWrapper pw : prototypeWrappers) {
adviceLists.add(pw.advise());
- pw.setSafeKeeper(safeKeeper);
}
Thread t = new Thread(this, "PEContainer");
t.start();

0 comments on commit e89e295

Please sign in to comment.