bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/TransactionSupportImpl.java

   1 package fi.vtt.simantics.procore.internal;\r
   2 \r
   3 import org.simantics.db.service.TransactionSupport;\r
   4 \r
   5 public class TransactionSupportImpl implements TransactionSupport {\r
   6         \r
   7         final private SessionImplSocket session;\r
   8         \r
   9         TransactionSupportImpl(SessionImplSocket session) {\r
  10                 this.session = session;\r
  11         }\r
  12     \r
  13     private int getAsyncCount() {\r
  14         return session.state.getAsyncCount();\r
  15     }\r
  16         \r
  17     @Override\r
  18     public int getReadCount() {\r
  19         return session.state.getReadCount();\r
  20     }\r
  21     \r
  22     @Override\r
  23     public int getWriteCount() {\r
  24         return session.state.getWriteCount();\r
  25     }\r
  26 \r
  27     @Override\r
  28     public void waitCompletion() {\r
  29         while(getReadCount() > 0 || getWriteCount() > 0 || getAsyncCount() > 0) {\r
  30             try {\r
  31                 Thread.sleep(10);\r
  32             } catch (InterruptedException e) {\r
  33                 e.printStackTrace();\r
  34             }\r
  35         }\r
  36     }\r
  37     \r
  38 }\r