Lines 172-177
Link Here
|
172 |
private long bytesRead=0; |
172 |
private long bytesRead=0; |
173 |
// Time of the request - useful to avoid repeated calls to System.currentTime |
173 |
// Time of the request - useful to avoid repeated calls to System.currentTime |
174 |
private long startTimeNanos = -1; |
174 |
private long startTimeNanos = -1; |
|
|
175 |
private long threadId = 0; |
175 |
private int available = 0; |
176 |
private int available = 0; |
176 |
|
177 |
|
177 |
private final RequestInfo reqProcessorMX=new RequestInfo(this); |
178 |
private final RequestInfo reqProcessorMX=new RequestInfo(this); |
Lines 238-244
Link Here
|
238 |
fireListener = true; |
239 |
fireListener = true; |
239 |
} |
240 |
} |
240 |
action(ActionCode.DISPATCH_READ, null); |
241 |
action(ActionCode.DISPATCH_READ, null); |
241 |
if (!ContainerThreadMarker.isContainerThread()) { |
242 |
if (!isRequestThread()) { |
242 |
// Not on a container thread so need to execute the dispatch |
243 |
// Not on a container thread so need to execute the dispatch |
243 |
action(ActionCode.DISPATCH_EXECUTE, null); |
244 |
action(ActionCode.DISPATCH_EXECUTE, null); |
244 |
} |
245 |
} |
Lines 737-742
Link Here
|
737 |
this.startTimeNanos = startTimeNanos; |
738 |
this.startTimeNanos = startTimeNanos; |
738 |
} |
739 |
} |
739 |
|
740 |
|
|
|
741 |
public long getThreadId() { |
742 |
return threadId; |
743 |
} |
744 |
|
745 |
public void setRequestThread() { |
746 |
threadId = Thread.currentThread().getId(); |
747 |
} |
748 |
|
749 |
public boolean isRequestThread() { |
750 |
return Thread.currentThread().getId() == threadId; |
751 |
} |
752 |
|
740 |
// -------------------- Per-Request "notes" -------------------- |
753 |
// -------------------- Per-Request "notes" -------------------- |
741 |
|
754 |
|
742 |
|
755 |
|
Lines 828-833
Link Here
|
828 |
allDataReadEventSent.set(false); |
841 |
allDataReadEventSent.set(false); |
829 |
|
842 |
|
830 |
startTimeNanos = -1; |
843 |
startTimeNanos = -1; |
|
|
844 |
threadId = 0; |
831 |
} |
845 |
} |
832 |
|
846 |
|
833 |
// -------------------- Info -------------------- |
847 |
// -------------------- Info -------------------- |