update deliver

zhangmeng

2019-05-20 622b701e27351e28a6c3df579d4423120afe79fc

 main.go

@@ -1,12 +1,15 @@
package main

import (
   "context"
   "demo/deliver"
   "fmt"
   "os"
)

const dLen = 12 * 1024 * 1024

var ctx, cancel = context.WithCancel(context.Background())

func modeType(t string) deliver.Mode {

@@ -18,14 +21,18 @@
      return deliver.Pair
   } else if t == "reqrep" {
      return deliver.ReqRep
   } else if t == "shm" {
      return deliver.Shm
   }

   return deliver.Mode(-1)
   return deliver.NONE
}

func senderMode(ipc string, m deliver.Mode) {
   if m == deliver.ReqRep {
      req(ipc, m)
   } else if m == deliver.Shm {
      shmSender(ipc, 2, 32*1024*1024)
   }
   sender(ipc, m)
}
@@ -33,6 +40,8 @@
func recvMode(ipc string, m deliver.Mode, strCount string) {
   if m == deliver.ReqRep {
      rep(ipc, m)
   } else if m == deliver.Shm {
      shmReciever(ipc, strCount)
   }
   reciever(ipc, m, strCount)
}