(isAnonymous bool)
| 49 | } |
| 50 | |
| 51 | func (c *PersistentCaller) initClient(isAnonymous bool) (err error) { |
| 52 | c.Lock() |
| 53 | defer c.Unlock() |
| 54 | if c.client == nil { |
| 55 | c.client, err = DialToNodeWithPool(c.pool, c.TargetID, isAnonymous) |
| 56 | if err != nil { |
| 57 | err = errors.Wrap(err, "dial to node failed") |
| 58 | return |
| 59 | } |
| 60 | //c.TargetAddr = conn.RemoteAddr().String() |
| 61 | } |
| 62 | return |
| 63 | } |
| 64 | |
| 65 | // Call invokes the named function, waits for it to complete, and returns its error status. |
| 66 | func (c *PersistentCaller) Call(method string, args interface{}, reply interface{}) (err error) { |
no test coverage detected