| 
									
										
										
										
											2017-01-11 21:23:57 +00:00
										 |  |  | package test
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | import (
 | 
					
						
							|  |  |  | 	"io/ioutil"
 | 
					
						
							|  |  |  | 	"log"
 | 
					
						
							|  |  |  | 	"testing"
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-02-21 22:51:47 -08:00
										 |  |  | 	"github.com/coredns/coredns/middleware/proxy"
 | 
					
						
							|  |  |  | 	"github.com/coredns/coredns/middleware/test"
 | 
					
						
							|  |  |  | 	"github.com/coredns/coredns/request"
 | 
					
						
							| 
									
										
										
										
											2017-01-11 21:23:57 +00:00
										 |  |  | 
 | 
					
						
							|  |  |  | 	"github.com/miekg/dns"
 | 
					
						
							|  |  |  | )
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | func TestProxyErratic(t *testing.T) {
 | 
					
						
							|  |  |  | 	log.SetOutput(ioutil.Discard)
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	corefile := `example.org:0 {
 | 
					
						
							|  |  |  | 		erratic {
 | 
					
						
							|  |  |  | 			drop 2
 | 
					
						
							|  |  |  | 		}
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | `
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	backend, err := CoreDNSServer(corefile)
 | 
					
						
							|  |  |  | 	if err != nil {
 | 
					
						
							|  |  |  | 		t.Fatalf("Could not get CoreDNS serving instance: %s", err)
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	udp, _ := CoreDNSServerPorts(backend, 0)
 | 
					
						
							|  |  |  | 	if udp == "" {
 | 
					
						
							|  |  |  | 		t.Fatalf("Could not get UDP listening port")
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | 	defer backend.Stop()
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-01-15 08:12:58 +00:00
										 |  |  | 	p := proxy.NewLookup([]string{udp})
 | 
					
						
							| 
									
										
										
										
											2017-01-11 21:23:57 +00:00
										 |  |  | 	state := request.Request{W: &test.ResponseWriter{}, Req: new(dns.Msg)}
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	// We do one lookup that should not time out.
 | 
					
						
							|  |  |  | 	// After this the backend is marked unhealthy anyway. So basically this
 | 
					
						
							|  |  |  | 	// tests that it times out.
 | 
					
						
							|  |  |  | 	p.Lookup(state, "example.org.", dns.TypeA)
 | 
					
						
							|  |  |  | }
 |