}
}
- int thread = request.hashCode() & queryProvider2.THREAD_MASK;
-
- requestManager.scheduleWrite(new SessionTask(true) {
+ requestManager.scheduleWrite(new SessionTask(null) {
@Override
public void run(int thread) {
assert (request != null);
- int thread = request.hashCode() & queryProvider2.THREAD_MASK;
-
- requestManager.scheduleWrite(new SessionTask(true) {
+ requestManager.scheduleWrite(new SessionTask(null) {
@Override
public void run(int thread) {
assert (request != null);
- int thread = request.hashCode() & queryProvider2.THREAD_MASK;
-
- requestManager.scheduleWrite(new SessionTask(true) {
+ requestManager.scheduleWrite(new SessionTask(null) {
@Override
public void run(int thread) {
assert (request != null);
- int thread = request.hashCode() & queryProvider2.THREAD_MASK;
-
- requestManager.scheduleWrite(new SessionTask(true) {
+ requestManager.scheduleWrite(new SessionTask(null) {
@Override
public void run(int thread) {
assert (request != null);
- int thread = request.hashCode() & queryProvider2.THREAD_MASK;
-
- requestManager.scheduleWrite(new SessionTask(true) {
+ requestManager.scheduleWrite(new SessionTask(null) {
@Override
public void run(int thread) {
// final ResultCallWrappedSingleQueryProcedure4<T> wrapper = new ResultCallWrappedSingleQueryProcedure4<T>(
// procedure, "request");
- BlockingAsyncProcedure<T> wrap = new BlockingAsyncProcedure<T>(newGraph, procedure, request);
+ BlockingAsyncProcedure<T> wrap = new BlockingAsyncProcedure<T>(newGraph.asyncBarrier, newGraph, procedure, request);
try {