mirror of https://github.com/v2ray/v2ray-core
format code
parent
0857fdb0f8
commit
ea39a6fde6
|
@ -149,7 +149,7 @@ func (this *UDPNameServer) BuildQueryA(domain string, id uint16) *alloc.Buffer {
|
||||||
msg.Id = id
|
msg.Id = id
|
||||||
msg.RecursionDesired = true
|
msg.RecursionDesired = true
|
||||||
msg.Question = []dns.Question{
|
msg.Question = []dns.Question{
|
||||||
dns.Question{
|
{
|
||||||
Name: dns.Fqdn(domain),
|
Name: dns.Fqdn(domain),
|
||||||
Qtype: dns.TypeA,
|
Qtype: dns.TypeA,
|
||||||
Qclass: dns.ClassINET,
|
Qclass: dns.ClassINET,
|
||||||
|
|
|
@ -98,7 +98,7 @@ func (this *InboundDetourHandlerDynamic) refresh() error {
|
||||||
this.ich2Recyle = this.ichs
|
this.ich2Recyle = this.ichs
|
||||||
newIchs := make([]proxy.InboundHandler, config.Allocation.Concurrency)
|
newIchs := make([]proxy.InboundHandler, config.Allocation.Concurrency)
|
||||||
|
|
||||||
for idx, _ := range newIchs {
|
for idx := range newIchs {
|
||||||
err := retry.Timed(5, 100).On(func() error {
|
err := retry.Timed(5, 100).On(func() error {
|
||||||
port := this.pickUnusedPort()
|
port := this.pickUnusedPort()
|
||||||
ich, err := proxyrepo.CreateInboundHandler(config.Protocol, this.space, config.Settings, &proxy.InboundHandlerMeta{
|
ich, err := proxyrepo.CreateInboundHandler(config.Protocol, this.space, config.Settings, &proxy.InboundHandlerMeta{
|
||||||
|
|
Loading…
Reference in New Issue