Skip to content

Commit

Permalink
Merge pull request #2788 from ipfs/fix/buffer-err-chan
Browse files Browse the repository at this point in the history
Fix/buffer err chan
  • Loading branch information
whyrusleeping committed Jun 1, 2016
2 parents 393ae7b + 82a2218 commit acd5765
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion namesys/publisher.go
Original file line number Diff line number Diff line change
Expand Up @@ -135,6 +135,9 @@ func checkCtxTTL(ctx context.Context) (time.Duration, bool) {
}

func PutRecordToRouting(ctx context.Context, k ci.PrivKey, value path.Path, seqnum uint64, eol time.Time, r routing.IpfsRouting, id peer.ID) error {
ctx, cancel := context.WithCancel(ctx)
defer cancel()

namekey, ipnskey := IpnsKeysForID(id)
entry, err := CreateRoutingEntryData(k, value, seqnum, eol)
if err != nil {
Expand All @@ -146,7 +149,7 @@ func PutRecordToRouting(ctx context.Context, k ci.PrivKey, value path.Path, seqn
entry.Ttl = proto.Uint64(uint64(ttl.Nanoseconds()))
}

errs := make(chan error)
errs := make(chan error, 2)

go func() {
errs <- PublishEntry(ctx, r, ipnskey, entry)
Expand Down

0 comments on commit acd5765

Please sign in to comment.