From fd76d49c7d7bbed4775818390e47b958ee50f469 Mon Sep 17 00:00:00 2001
From: Dmitriy Kargapolov <dmitriy.kargapolov@gmail.com>
Date: Sat, 31 Jan 2015 23:18:23 -0500
Subject: jinterface: transport factory implementation

Transport factory basic implementation added. This makes possible
creating connections between nodes using ssh channels for example.
Default transport factory based on standart Socket/ServerSocket
classes is provided. Modifications are backward compatible.
---
 .../com/ericsson/otp/erlang/OtpLocalNode.java      | 30 ++++++++++++++++------
 1 file changed, 22 insertions(+), 8 deletions(-)

(limited to 'lib/jinterface/java_src/com/ericsson/otp/erlang/OtpLocalNode.java')

diff --git a/lib/jinterface/java_src/com/ericsson/otp/erlang/OtpLocalNode.java b/lib/jinterface/java_src/com/ericsson/otp/erlang/OtpLocalNode.java
index b996ba6f6c..dd1d299297 100644
--- a/lib/jinterface/java_src/com/ericsson/otp/erlang/OtpLocalNode.java
+++ b/lib/jinterface/java_src/com/ericsson/otp/erlang/OtpLocalNode.java
@@ -29,12 +29,7 @@ public class OtpLocalNode extends AbstractNode {
     private int refId[];
 
     protected int port;
-    protected java.net.Socket epmd;
-
-    protected OtpLocalNode() {
-        super();
-        init();
-    }
+    protected OtpTransport epmd;
 
     /**
      * Create a node with the given name and the default cookie.
@@ -44,6 +39,16 @@ public class OtpLocalNode extends AbstractNode {
         init();
     }
 
+    /**
+     * Create a node with the given name, transport factory and the default
+     * cookie.
+     */
+    protected OtpLocalNode(final String node,
+            final OtpTransportFactory transportFactory) {
+        super(node, transportFactory);
+        init();
+    }
+
     /**
      * Create a node with the given name and cookie.
      */
@@ -52,6 +57,15 @@ public class OtpLocalNode extends AbstractNode {
         init();
     }
 
+    /**
+     * Create a node with the given name, cookie and transport factory.
+     */
+    protected OtpLocalNode(final String node, final String cookie,
+            final OtpTransportFactory transportFactory) {
+        super(node, cookie, transportFactory);
+        init();
+    }
+
     private void init() {
         serial = 0;
         pidCount = 1;
@@ -77,7 +91,7 @@ public class OtpLocalNode extends AbstractNode {
      * @param s
      *            The socket connecting this node to Epmd.
      */
-    protected void setEpmd(final java.net.Socket s) {
+    protected void setEpmd(final OtpTransport s) {
         epmd = s;
     }
 
@@ -86,7 +100,7 @@ public class OtpLocalNode extends AbstractNode {
      *
      * @return The socket connecting this node to Epmd.
      */
-    protected java.net.Socket getEpmd() {
+    protected OtpTransport getEpmd() {
         return epmd;
     }
 
-- 
cgit v1.2.3