Merge pull request #170 from StalkR/sync

xfr: make Transfer.Out synchronous
This commit is contained in:
Miek Gieben 2015-01-15 10:43:15 +00:00
commit 06484909b2
1 changed files with 8 additions and 10 deletions

18
xfr.go
View File

@ -165,17 +165,15 @@ func (t *Transfer) Out(w ResponseWriter, q *Msg, ch chan *Envelope) error {
r.SetReply(q)
r.Authoritative = true
go func() {
for x := range ch {
// assume it fits TODO(miek): fix
r.Answer = append(r.Answer, x.RR...)
if err := w.WriteMsg(r); err != nil {
return
}
for x := range ch {
// assume it fits TODO(miek): fix
r.Answer = append(r.Answer, x.RR...)
if err := w.WriteMsg(r); err != nil {
return err
}
w.TsigTimersOnly(true)
r.Answer = nil
}()
}
w.TsigTimersOnly(true)
r.Answer = nil
return nil
}