X-Git-Url: https://gerrit.simantics.org/r/gitweb?p=simantics%2Fplatform.git;a=blobdiff_plain;f=bundles%2Forg.simantics.db.procore%2Fsrc%2Ffi%2Fvtt%2Fsimantics%2Fprocore%2Finternal%2FSessionMonitorSupportImpl.java;h=a178f99b3c999974b8b60c953b509b06650bf6d0;hp=2e8b0e46ab526464f3f2b2e8f6ba1422eb787184;hb=d09be9d2b8bf2e982ab7cf5760d39014e7ca4fa1;hpb=969bd23cab98a79ca9101af33334000879fb60c5

diff --git a/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/SessionMonitorSupportImpl.java b/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/SessionMonitorSupportImpl.java
index 2e8b0e46a..a178f99b3 100644
--- a/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/SessionMonitorSupportImpl.java
+++ b/bundles/org.simantics.db.procore/src/fi/vtt/simantics/procore/internal/SessionMonitorSupportImpl.java
@@ -1,63 +1,63 @@
-package fi.vtt.simantics.procore.internal;
-
-import org.simantics.db.MonitorContext;
-import org.simantics.db.MonitorHandler;
-import org.simantics.db.SessionVariables;
-import org.simantics.db.service.SessionMonitorSupport;
-
-public class SessionMonitorSupportImpl implements SessionMonitorSupport {
-	
-	final private SessionImplSocket session;
-	
-	SessionMonitorSupportImpl(SessionImplSocket session) {
-		this.session = session;
-	}
-    
-    @Override
-    public synchronized MonitorContext registerMonitor(MonitorHandler h) {
-        assert h != null;
-
-        MonitorContext ctx = new MonitorContext() {
-            @Override
-            public int getInteger(String key) {
-                if (SessionVariables.QUEUED_READS.equals(key)) {
-                    return session.state.getReadCount();
-                } else if (SessionVariables.QUEUED_WRITES.equals(key)) {
-                    return session.state.getWriteCount();
-                }
-                return -1;
-            }
-
-            @Override
-            public String getString(String key) {
-                return null;
-            }
-        };
-        session.monitorContexts.map(ctx, h);
-
-        MonitorHandler[] newHandlers = new MonitorHandler[session.monitorHandlers.length + 1];
-        System.arraycopy(session.monitorHandlers, 0, newHandlers, 0, session.monitorHandlers.length);
-        newHandlers[session.monitorHandlers.length] = h;
-        session.monitorHandlers = newHandlers;
-
-        return ctx;
-    }
-
-    @Override
-    public synchronized void unregisterMonitor(MonitorContext ctx) {
-        MonitorHandler h = session.monitorContexts.getRight(ctx);
-        if (h == null)
-            return;
-        int i = 0;
-        for (i = 0; i < session.monitorHandlers.length; i++) {
-            if (h.equals(session.monitorHandlers))
-                break;
-        }
-        if (i < session.monitorHandlers.length) {
-            MonitorHandler[] newHandlers = new MonitorHandler[session.monitorHandlers.length - 1];
-            System.arraycopy(session.monitorHandlers, 0, newHandlers, 0, i);
-            System.arraycopy(session.monitorHandlers, i + 1, newHandlers, i, session.monitorHandlers.length - i - 1);
-        }
-    }
-    
-}
+package fi.vtt.simantics.procore.internal;
+
+import org.simantics.db.MonitorContext;
+import org.simantics.db.MonitorHandler;
+import org.simantics.db.SessionVariables;
+import org.simantics.db.service.SessionMonitorSupport;
+
+public class SessionMonitorSupportImpl implements SessionMonitorSupport {
+	
+	final private SessionImplSocket session;
+	
+	SessionMonitorSupportImpl(SessionImplSocket session) {
+		this.session = session;
+	}
+    
+    @Override
+    public synchronized MonitorContext registerMonitor(MonitorHandler h) {
+        assert h != null;
+
+        MonitorContext ctx = new MonitorContext() {
+            @Override
+            public int getInteger(String key) {
+                if (SessionVariables.QUEUED_READS.equals(key)) {
+                    return session.state.getReadCount();
+                } else if (SessionVariables.QUEUED_WRITES.equals(key)) {
+                    return session.state.getWriteCount();
+                }
+                return -1;
+            }
+
+            @Override
+            public String getString(String key) {
+                return null;
+            }
+        };
+        session.monitorContexts.map(ctx, h);
+
+        MonitorHandler[] newHandlers = new MonitorHandler[session.monitorHandlers.length + 1];
+        System.arraycopy(session.monitorHandlers, 0, newHandlers, 0, session.monitorHandlers.length);
+        newHandlers[session.monitorHandlers.length] = h;
+        session.monitorHandlers = newHandlers;
+
+        return ctx;
+    }
+
+    @Override
+    public synchronized void unregisterMonitor(MonitorContext ctx) {
+        MonitorHandler h = session.monitorContexts.getRight(ctx);
+        if (h == null)
+            return;
+        int i = 0;
+        for (i = 0; i < session.monitorHandlers.length; i++) {
+            if (h.equals(session.monitorHandlers))
+                break;
+        }
+        if (i < session.monitorHandlers.length) {
+            MonitorHandler[] newHandlers = new MonitorHandler[session.monitorHandlers.length - 1];
+            System.arraycopy(session.monitorHandlers, 0, newHandlers, 0, i);
+            System.arraycopy(session.monitorHandlers, i + 1, newHandlers, i, session.monitorHandlers.length - i - 1);
+        }
+    }
+    
+}