| 345 | } |
| 346 | |
| 347 | func (c *Client) dialForever(connectNotifyChan chan bool) { |
| 348 | dial := func() error { |
| 349 | if !c.reconnect() { |
| 350 | return nil |
| 351 | } |
| 352 | |
| 353 | c.LocalKite.Log.Info("Dialing '%s' kite: %s", c.Kite.Name, c.URL) |
| 354 | |
| 355 | if err := c.dial(0); err != nil { |
| 356 | c.LocalKite.Log.Warning("Dialing '%s' kite error: %s: %v", c.Kite.Name, c.URL, err) |
| 357 | |
| 358 | return err |
| 359 | } |
| 360 | |
| 361 | return nil |
| 362 | } |
| 363 | |
| 364 | backoff.Retry(dial, c.redialBackOff) // this will retry dial forever |
| 365 | |
| 366 | if connectNotifyChan != nil { |
| 367 | close(connectNotifyChan) |
| 368 | } |
| 369 | |
| 370 | go c.run() |
| 371 | } |
| 372 | |
| 373 | func (c *Client) RemoteAddr() string { |
| 374 | session := c.getSession() |