From d162429ffb4e99cf75aa8253f5acca62cff65a32 Mon Sep 17 00:00:00 2001
From: free will <2647778488@qq.com>
Date: Fri, 16 Apr 2021 15:38:18 +0800
Subject: [PATCH] add logicface: UnixStreamTransport

---
 .../java/logicface/UnixStreamTransport.java   | 32 +++++++++++++++++++
 1 file changed, 32 insertions(+)
 create mode 100644 src/main/java/logicface/UnixStreamTransport.java

diff --git a/src/main/java/logicface/UnixStreamTransport.java b/src/main/java/logicface/UnixStreamTransport.java
new file mode 100644
index 0000000..63f05f9
--- /dev/null
+++ b/src/main/java/logicface/UnixStreamTransport.java
@@ -0,0 +1,32 @@
+package logicface;
+
+import java.io.IOException;
+import java.nio.channels.SocketChannel;
+
+/*
+ * @Author: Wang Feng
+ * @Description:
+ * @Version: 1.0.0
+ * @Date: 15:37 2021/4/16
+ * @Copyright: MIN-Group；国家重大科技基础设施——未来网络北大实验室；深圳市信息论与未来网络重点实验室
+ */
+public class UnixStreamTransport extends StreamTransport{
+    /**
+     * 初始化UnixStreamTransport
+     * @param channel
+     */
+    public void init(SocketChannel channel) throws LogicFaceException {
+        try {
+            this.channel=channel;
+            this.localAddr=channel.getLocalAddress().toString();
+            this.localUri="unix://"+this.localAddr;
+            this.remoteAddr=channel.getRemoteAddress().toString();
+            this.remoteUri="unix://"+this.remoteAddr;
+            this.recvBuf=new byte[1024*1028*4];
+            this.recvLen=0;
+        } catch (IOException e) {
+            throw new LogicFaceException("TcpTransport.init: "+e.getMessage());
+        }
+
+    }
+}