- Thread.sleep(1);
- counter++;
- if(counter > 1000) {
- CacheEntryBase base = ((CacheEntryBase)entry);
-// if(base.created != null) {
-// System.err.println("created:");
-// base.created.printStackTrace();
-// }
-// if(base.performed != null) {
-// System.err.println("performed:");
-// base.performed.printStackTrace();
-// }
-// if(base.ready != null) {
-// System.err.println("ready:");
-// base.ready.printStackTrace();
-// }
- new Exception("Timeout waiting for request to complete: " + entry.getOriginalRequest().toString()).printStackTrace();
- throw new DatabaseException("Timeout waiting for request to complete.");
- //System.err.println("asd");
- //base.getQuery().recompute(null, null, entry);
+ SessionTask task = processor.getOwnTask(processor.thread.get());
+ if(task != null) {
+ task.run(processor.thread.get());
+ } else {
+ Thread.sleep(1);
+ counter++;
+ if(counter > 5000) {
+ CacheEntryBase base = ((CacheEntryBase)entry);
+// if(base.created != null) {
+// System.err.println("created:");
+// base.created.printStackTrace();
+// }
+// if(base.performed != null) {
+// System.err.println("performed:");
+// base.performed.printStackTrace();
+// }
+// if(base.ready != null) {
+// System.err.println("ready:");
+// base.ready.printStackTrace();
+// }
+ new Exception("Timeout waiting for request to complete: " + entry.getOriginalRequest().toString()).printStackTrace();
+ throw new DatabaseException("Timeout waiting for request to complete.");
+ //System.err.println("asd");
+ //base.getQuery().recompute(null, null, entry);
+ }