update

zhangmeng

2019-07-29 4403997708025d6c82122f4b15dcfb109dd3e6c6

 main.go

@@ -48,6 +48,8 @@
   mode         string
   ipc          string
   oneSendnRecv bool

   tmm string
)

const (
@@ -64,6 +66,8 @@
   flag.StringVar(&ipc, "i", "ipc:///tmp/pic.ipc", "ipc label")

   flag.BoolVar(&oneSendnRecv, "n", true, "one send n recv")

   flag.StringVar(&tmm, "t", "server", "")
}

func modeType(t string) deliver.Mode {
@@ -86,6 +90,17 @@
func main() {
   flag.Parse()

   if tmm == "server" {
      c, _ := deliver.NewServerWithTimeout(deliver.PushPull, ipc, 1000)
      // c := deliver.NewServer(deliver.PushPull, ipc)
      nSenderImpl(c, 0)
   } else if tmm == "client" {
      s, _ := deliver.NewServerWithTimeout(deliver.PushPull, ipc, 100)

      oneRecvImpl(s, 0)

   }
   return
   m := modeType(mode)
   if m > deliver.ModeStart {
      if proc == act {