liuxiaolong
2019-07-29 b49837ff9dfbd655d47a3429d38694d894b45339
fix sock
1个文件已修改
4 ■■■■ 已修改文件
service/FaceCompareService.go 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
service/FaceCompareService.go
@@ -156,12 +156,12 @@
    }
    sock.AddTransport(ipc.NewTransport())
    sock.AddTransport(tcp.NewTransport())
    sock.SetOption(mangos.OptionMaxRecvSize, 1024*1024*100)
    //sock.SetOption(mangos.OptionRecvDeadline, time.Second*10)
    if err = sock.Dial(url);err !=nil {
        logger.Debug("can't dial on req socket:%s",err.Error())
        return nil
    }
    sock.SetOption(mangos.OptionMaxRecvSize, 1024*1024*100)
    //sock.SetOption(mangos.OptionRecvDeadline, time.Second*10)
    if err = sock.Send(args);err !=nil {
        logger.Debug("can't send message on push socket:%s",err.Error())
        return nil