update deliver

zhangmeng

2019-05-22 e0875bfe6196fdf4abdc7c099bbb59e7282f1b48

update deliver

 deliver

@@ -1 +1 @@
Subproject commit a8b90cfcf722f4b1c4aac9f318e35824f02b8787
Subproject commit c2bbe31e7c6c9f83f7bcce26dea98bc18ed8f39c

 runShm.go

File was renamed from shm.go
@@ -38,8 +38,15 @@
}

func shmSender(url string, args ...interface{}) {
    s := deliver.NewServer(deliver.Shm, url, args...)

    s, err := deliver.NewServerWithError(deliver.Shm, url, args...)
    for {
        if err == nil {
            break
        }
        fmt.Println("create shm error : ", err)
        time.Sleep(1 * time.Second)
        s, err = deliver.NewServerWithError(deliver.Shm, url, args)
    }
    go shmSenderImpl(s)

    c := make(chan os.Signal, 1)
@@ -97,7 +104,15 @@
    var cs []deliver.Deliver
    for i := 0; i < count; i++ {
        wg.Add(1)
        c := deliver.NewClient(deliver.Shm, url)
        c, err := deliver.NewClientWithError(deliver.Shm, url)
        for {
            if err == nil {
                break
            }
            time.Sleep(1 * time.Second)
            c, err = deliver.NewClientWithError(deliver.Shm, url)
            fmt.Println(i, " client create failed : ", err)
        }
        cs = append(cs, c)
        go shmRecvImpl(&wg, c, url, i)
    }

 runShm2.go

File was renamed from shm2.go
@@ -37,7 +37,14 @@
}

func shmReciever2(url string, count int, args ...interface{}) {
    s := deliver.NewServer(deliver.Shm, url, args...)
    s, err := deliver.NewServerWithError(deliver.Shm, url, args...)
    for {
        if err == nil {
            break
        }
        time.Sleep(1 * time.Second)
        s, err = deliver.NewServerWithError(deliver.Shm, url, args...)
    }

    go shmRecvImpl2(s, 0)

@@ -92,7 +99,14 @@

    var cs []deliver.Deliver
    for i := 0; i < count; i++ {
        c := deliver.NewClient(deliver.Shm, url)
        c, err := deliver.NewClientWithError(deliver.Shm, url)
        for {
            if err == nil {
                break
            }
            time.Sleep(1 * time.Second)
            c, err = deliver.NewClientWithError(deliver.Shm, url)
        }
        cs = append(cs, c)
        go shmSenderImpl2(c)
    }