| | |
|---|
| | | var compareArgInfo protomsg.CompareArgs |
|---|
| | | if err = proto.Unmarshal(request.Payload, &compareArgInfo); err == nil { |
|---|
| | | timeStart := time.Now() |
|---|
| | | result = compare.GetComparePersonBaseInfo(compareArgInfo) |
|---|
| | | result = compare.Walk(compareArgInfo) |
|---|
| | | logger.Debug("用时：", time.Since(timeStart)) |
|---|
| | | } else { |
|---|
| | | logger.Warn("CompareArgs or EsPersonCacheChange json unmarshal error") |
|---|
| | |
|---|
| | | logger.Error("can't get new rep socket: %s", err) |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | if err = sock.SetOption(mangos.OptionRaw, true); err != nil { |
|---|
| | | logger.Error("can't set raw mode: %s", err) |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | sock.AddTransport(ipc.NewTransport()) |
|---|
| | | sock.AddTransport(tcp.NewTransport()) |
|---|
| | | if err = sock.Listen(url); err != nil { |
|---|
