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