Перейти канал в операторе выбора - не возвращается - PullRequest
Новая
       17

Перейти канал в операторе выбора - не возвращается

0 голосов
/ 01 сентября 2018

Я новичок в golang-каналах в операторах выбора, поэтому я могу упустить что-то очевидное здесь.

Я использую библиотеку hyperledger fabric-sdk-go [1], которая использует операторы select для ожидания ответов на выполнения в блокчейне.

Вот где в моем собственном коде я вызываю выполнение и жду ответа на канале: 

func (mgr *Manager) InvokeTest(value string) (string, error) {

    . . .{code excluded here}. . .
    fmt.Println("InvokeTest - CHECK 01")

    reg, notifier, err := mgr.client.RegisterChaincodeEvent(mgr.ChaincodeID, eventID)
    if err != nil {
        return "", err
    }
    defer mgr.client.UnregisterChaincodeEvent(reg)

    . . .{code excluded here}. . .
    fmt.Println("InvokeTest - CHECK 02")

    // Wait for the result of the submission
    select {
    case ccEvent := <-notifier:
        fmt.Printf("Received CC event: %v\n", ccEvent)
    case <-time.After(time.Second * 20):
        return "", fmt.Errorf("did NOT receive CC event for eventId(%s)", eventID)
    }

    return string(response.TransactionID), nil
}

Вот функция RegisterChaincodeEvent в библиотеке (я добавил WriteString для ведения журнала: 

func (cc *Client) RegisterChaincodeEvent(chainCodeID string, eventFilter string) (fab.Registration, <-chan *fab.CCEvent, error) {

    //-------------------------------
    . . .WriteString("----- chclient-RegisterChaincodeEvent - BEGIN -----\r") . . .
    //-------------------------------

    // Register callback for CE
    return cc.eventService.RegisterChaincodeEvent(chainCodeID, eventFilter)
}

... и вот функция eventService.RegisterChaincodeEvent (опять же, WriteString добавлено для ведения журнала: 

func (s *Service) RegisterChaincodeEvent(ccID, eventFilter string) (fab.Registration, <-chan *fab.CCEvent, error) {

    //-------------------------------
    . . .WriteString("----- service-RegisterChaincodeEvent - BEGIN -----\r") . . .
    //-------------------------------

    . . .{code excluded here}. . .

    eventch := make(chan *fab.CCEvent, s.eventConsumerBufferSize)
    regch := make(chan fab.Registration)
    errch := make(chan error)

    if err := s.Submit(dispatcher.NewRegisterChaincodeEvent(ccID, eventFilter, eventch, regch, errch)); err != nil {

        //-------------------------------
        . . .WriteString("service-RegisterChaincodeEvent - CHECK DISP ERR\r") . . .
        //-------------------------------

        return nil, nil, errors.WithMessage(err, "error registering for chaincode events")
    }

    select {
    case response := <-regch:

        //-------------------------------
        . . .WriteString("service-RegisterChaincodeEvent - CHECK 01\r") . . .
        //-------------------------------

        return response, eventch, nil
    case err := <-errch:
        return nil, nil, err
    }
}

... а вот журнал терминала: 

InvokeTest - CHECK 01
InvokeTest - CHECK 02
did NOT receive CC event for eventId(eventInvoke)

... и соответствующие строки журнала из библиотечных функций: 

----- chclient-RegisterChaincodeEvent - BEGIN -----
----- service-RegisterChaincodeEvent - BEGIN -----
service-RegisterChaincodeEvent - CHECK 01

Похоже, что библиотека работает нормально, а функции RegisterChaincodeEvent возвращают ответ по каналу. Почему мой собственный оператор выбора не будет отвечать на запрос канала? Как я могу отладить процесс выбора / блокировки канала, чтобы понять, почему истекает время ожидания?

[1] https://github.com/hyperledger/fabric-sdk-go

...