mac add nfs 添加了存储中心

src/context/mdb/mdb.go

@@ -59,19 +59,18 @@ func (mdb *MDB) Start(m *ctx.Message, arg ...string) bool { // {{{
 
 // }}}
 func (mdb *MDB) Close(m *ctx.Message, arg ...string) bool { // {{{
-	if mdb.Context == Index {
-		return false
-	}
-
 	switch mdb.Context {
 	case m.Target:
-	case m.Source:
+		if mdb.Context == Index {
-	}
+			return false
+		}
 
-	if mdb.DB != nil {
+		if mdb.DB != nil {
-		m.Log("info", nil, "%d close %s %s", m.Capi("nsource", -1)+1, m.Cap("driver"), m.Cap("source"))
+			m.Log("info", nil, "%d close %s %s", m.Capi("nsource", -1)+1, m.Cap("driver"), m.Cap("source"))
-		mdb.DB.Close()
+			mdb.DB.Close()
-		mdb.DB = nil
+			mdb.DB = nil
+		}
+	case m.Source:
 	}
 
 	return true

src/context/nfs/nfs.go

@@ -1,38 +1,149 @@
-package nfs
+package nfs // {{{
-
+// }}}
-import (
+import ( // {{{
 	"context"
+
+	"fmt"
+	"io"
+	"os"
+	"strconv"
 )
 
+// }}}
+
 type NFS struct {
+	file *os.File
 	*ctx.Context
 }
 
-func (nfs *NFS) Spawn(m *ctx.Message, c *ctx.Context, arg ...string) ctx.Server {
+func (nfs *NFS) Spawn(m *ctx.Message, c *ctx.Context, arg ...string) ctx.Server { // {{{
-	c.Caches = map[string]*ctx.Cache{}
+	info, ok := m.Data["info"].(os.FileInfo)
+	m.Assert(ok)
+
+	c.Caches = map[string]*ctx.Cache{
+		"name": &ctx.Cache{Name: "name", Value: info.Name(), Help: "文件名"},
+		"mode": &ctx.Cache{Name: "mode", Value: info.Mode().String(), Help: "文件名"},
+		"time": &ctx.Cache{Name: "time", Value: info.ModTime().Format("15:03:04"), Help: "文件名"},
+		"size": &ctx.Cache{Name: "size", Value: fmt.Sprintf("%d", info.Size()), Help: "文件名"},
+		"pos":  &ctx.Cache{Name: "pos", Value: "0", Help: "文件名"},
+	}
 	c.Configs = map[string]*ctx.Config{}
 
 	s := new(NFS)
 	s.Context = c
 	return s
+
 }
 
-func (nfs *NFS) Begin(m *ctx.Message, arg ...string) ctx.Server {
+// }}}
+func (nfs *NFS) Begin(m *ctx.Message, arg ...string) ctx.Server { // {{{
+	if nfs.Context == Index {
+		Pulse = m
+	}
 	return nfs
+
 }
 
-func (nfs *NFS) Start(m *ctx.Message, arg ...string) bool {
+// }}}
+func (nfs *NFS) Start(m *ctx.Message, arg ...string) bool { // {{{
+	m.Log("info", nil, "%d open %s", Pulse.Capi("nfile", 1), m.Cap("name"))
+	m.Cap("stream", m.Cap("name"))
 	return false
 }
 
-func (nfs *NFS) Exit(m *ctx.Message, arg ...string) bool {
+// }}}
-	return false
+func (nfs *NFS) Close(m *ctx.Message, arg ...string) bool { // {{{
+	switch nfs.Context {
+	case m.Target:
+		if nfs.Context == Index {
+			return false
+		}
+
+		if nfs.file != nil {
+			m.Log("info", nil, "%d close %s", Pulse.Capi("nfile", -1)+1, m.Cap("name"))
+			nfs.file.Close()
+			return true
+		}
+	case m.Source:
+	}
+
+	return true
 }
 
+// }}}
+
+var Pulse *ctx.Message
 var Index = &ctx.Context{Name: "nfs", Help: "存储中心",
-	Caches:   map[string]*ctx.Cache{},
+	Caches: map[string]*ctx.Cache{
-	Configs:  map[string]*ctx.Config{},
+		"nfile": &ctx.Cache{Name: "nfile", Value: "0", Help: "已经打开的文件数量"},
-	Commands: map[string]*ctx.Command{},
+	},
+	Configs: map[string]*ctx.Config{
+		"size": &ctx.Config{Name: "size", Value: "1024", Help: "读取文件的默认大小值"},
+	},
+	Commands: map[string]*ctx.Command{
+		"open": &ctx.Command{Name: "open file", Help: "打开文件, file: 文件名", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) string {
+			file, e := os.OpenFile(arg[0], os.O_RDWR|os.O_CREATE, os.ModePerm) // {{{
+			m.Assert(e)
+			info, e := os.Stat(arg[0])
+			m.Assert(e)
+			m.Put("option", "info", info).Start("file"+m.Cap("nfile"), "打开文件", arg...)
+
+			nfs, ok := m.Target.Server.(*NFS)
+			m.Assert(ok)
+
+			nfs.file = file
+			return ""
+			// }}}
+		}},
+		"read": &ctx.Command{Name: "read [size [pos]]", Help: "读取文件, size: 读取大小, pos: 读取位置", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) string {
+			nfs, ok := m.Target.Server.(*NFS) // {{{
+			m.Assert(ok)
+
+			var e error
+			n := m.Confi("size")
+			if len(arg) > 0 {
+				n, e = strconv.Atoi(arg[0])
+				m.Assert(e)
+			}
+
+			buf := make([]byte, n)
+			if len(arg) > 1 {
+				m.Cap("pos", arg[1])
+			}
+
+			if n, e = nfs.file.ReadAt(buf, int64(m.Capi("pos"))); e != io.EOF {
+				m.Assert(e)
+			}
+
+			if m.Capi("pos", n); m.Capi("pos") == m.Capi("size") {
+				m.Cap("pos", "0")
+			}
+
+			return string(buf)
+			// }}}
+		}},
+		"write": &ctx.Command{Name: "write string [pos]", Help: "写入文件, string: 写入内容, pos: 写入位置", Hand: func(m *ctx.Message, c *ctx.Context, key string, arg ...string) string {
+			nfs, ok := m.Target.Server.(*NFS) // {{{
+			if m.Assert(ok); len(arg) > 1 {
+				m.Cap("pos", arg[1])
+			}
+
+			if len(arg[0]) == 0 {
+				e := nfs.file.Truncate(0)
+				m.Assert(e)
+				m.Cap("size", "0")
+				m.Cap("pos", "0")
+				return ""
+			}
+
+			n, e := nfs.file.WriteAt([]byte(arg[0]), int64(m.Capi("pos")))
+			if m.Assert(e); m.Capi("pos", n) > m.Capi("size") {
+				m.Cap("size", m.Cap("pos"))
+			}
+			return m.Cap("pos")
+			// }}}
+		}},
+	},
 }
 
 func init() {

src/context/tcp/tcp.go

@@ -56,6 +56,16 @@ func (tcp *TCP) Start(m *ctx.Message, arg ...string) bool { // {{{
 		m.Log("info", nil, "dial(%d) %v->%v", m.Capi("nclient", 1), tcp.LocalAddr(), tcp.RemoteAddr())
 		m.Cap("stream", fmt.Sprintf("%s->%s", tcp.LocalAddr(), tcp.RemoteAddr()))
 
+		msg := m.Spawn(m.Source).Put("option", "io", c)
+		msg.Cmd("open")
+		msg.Cap("stream", tcp.RemoteAddr().String())
+
+		if tcp.Sessions == nil {
+			tcp.Sessions = make(map[string]*ctx.Message)
+		}
+		tcp.Sessions["open"] = msg
+		msg.Name = "open"
+
 		// m.Reply(c.LocalAddr().String()).Put("option", "io", c).Cmd("open")
 		return false
 	case "accept":
@@ -98,12 +108,12 @@ func (tcp *TCP) Start(m *ctx.Message, arg ...string) bool { // {{{
 
 // }}}
 func (tcp *TCP) Close(m *ctx.Message, arg ...string) bool { // {{{
-	if tcp.Context == Index {
-		return false
-	}
-
 	switch tcp.Context {
 	case m.Target:
+		if tcp.Context == Index {
+			return false
+		}
+
 		if tcp.Listener != nil {
 			m.Log("info", nil, "%d close %v", Pulse.Capi("nlisten", -1)+1, tcp.Listener.Addr())
 			tcp.Listener.Close()

src/context/web/web.go

@@ -194,7 +194,12 @@ func (web *WEB) Start(m *ctx.Message, arg ...string) bool { // {{{
 
 // }}}
 func (web *WEB) Close(m *ctx.Message, arg ...string) bool { // {{{
-	return false
+	switch web.Context {
+	case m.Target:
+	case m.Source:
+	}
+
+	return true
 }
 
 // }}}