1 package fi.vtt.simantics.procore.internal;
3 import org.simantics.db.service.TransactionSupport;
5 public class TransactionSupportImpl implements TransactionSupport {
7 final private SessionImplSocket session;
9 TransactionSupportImpl(SessionImplSocket session) {
10 this.session = session;
13 private int getAsyncCount() {
14 return session.state.getAsyncCount();
18 public int getReadCount() {
19 return session.state.getReadCount();
23 public int getWriteCount() {
24 return session.state.getWriteCount();
28 public void waitCompletion() {
29 while(getReadCount() > 0 || getWriteCount() > 0 || getAsyncCount() > 0) {
32 } catch (InterruptedException e) {