Uploaded image for project: 'Couchbase Server'
  1. Couchbase Server
  2. MB-44817

terminate projector getKVTs on timeout

    XMLWordPrintable

Details

    • Untriaged
    • 1
    • No

    Description

           go func() {
               // Retrieves bucketSeqnos if cid is "". Otherwise, retrieves
               // corresponding collection seqnos
               seqnos, err := SeqnosLocal(cluster, "default", bucket, cid, kvaddr)
               respch <- []interface{}{seqnos, err}
           }()
       
           select {
           case <-time.After(time.Duration(5 * time.Second)):
               return nil, errors.New("Timeout in retrieving seqnos")
      

      in case of timeout, the goroutine will forever keep waiting as there is no reader for respch.

      Attachments

        No reviews matched the request. Check your Options in the drop-down menu of this sections header.

        Activity

          People

            deepkaran.salooja Deepkaran Salooja
            deepkaran.salooja Deepkaran Salooja
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Gerrit Reviews

                There are no open Gerrit changes

                PagerDuty