1
0

default_dialer.go 507 B

12345678910111213141516171819202122232425
  1. package cproxy
  2. import (
  3. "net"
  4. "time"
  5. )
  6. type defaultDialer struct {
  7. timeout time.Duration
  8. logger logger
  9. }
  10. func newDialer(config *configuration) *defaultDialer {
  11. return &defaultDialer{timeout: config.DialTimeout, logger: config.Logger}
  12. }
  13. func (this *defaultDialer) Dial(address string) Socket {
  14. if socket, err := net.DialTimeout("tcp", address, this.timeout); err == nil {
  15. return socket
  16. } else {
  17. this.logger.Printf("Unable to establish connection to [%s]: %s", address, err)
  18. }
  19. return nil
  20. }