From 9c770865849b34ea48f66763aa11a83a10aa457c Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期二, 27 八月 2019 09:54:05 +0800
Subject: [PATCH] update shm deliver
---
profile/shmsend.go | 25 +++++++++++++------------
1 files changed, 13 insertions(+), 12 deletions(-)
diff --git a/profile/shmsend.go b/profile/shmsend.go
index 2feca8b..e6156d1 100644
--- a/profile/shmsend.go
+++ b/profile/shmsend.go
@@ -22,20 +22,21 @@
return
default:
if err = s.Send(buf); err != nil {
- s.Close()
- url := "hello"
- i, err := deliver.NewClientWithError(deliver.Shm, url)
- for {
- if err == nil {
- break
- }
- time.Sleep(1 * time.Second)
- i, err = deliver.NewClientWithError(deliver.Shm, url)
- fmt.Println("client create failed : ", err)
+ // s.Close()
+ // url := "hello"
+ // i, err := deliver.NewClientWithError(deliver.Shm, url)
+ // for {
+ // if err == nil {
+ // break
+ // }
+ // time.Sleep(1 * time.Second)
+ // i, err = deliver.NewClientWithError(deliver.Shm, url)
- }
- s = i
+ // fmt.Println("client create failed : ", err)
+
+ // }
+ // s = i
fmt.Printf("can't send message on push socket: %s\n", err.Error())
} else {
--
Gitblit v1.8.0