Method msgToPacketRoutine

nhp/core/device.go:157–265

Asynchronous multi-channel processing.

(id int)

// Asynchronous multi-channel processing.
func (d *Device) msgToPacketRoutine(id int) {
	defer d.wg.Done()
	defer log.Info("msgToPacketRoutine %d: quit", id)

	log.Info("msgToPacketRoutine %d: start", id)

	for {
		select {
		case <-d.signals.stop:
			return

		case md, ok := <-d.msgToPacketQueue:
			if !ok {
				return
			}
			if md == nil {
				log.Warning("msgToPacketRoutine %d: msgToPacketRoutine gets nil data", id)
				continue
			}

			// message encryption workflow: raw message -> encryption -> raw packet -> connection.SendQueue
			func() {
				msgType := HeaderTypeToString(md.HeaderType)
				var msgStr string
				if md.Message != nil {
					msgStr = string(md.Message)
				}
				log.Debug("msgToPacketRoutine %d: encrypting [%s] raw message: %s", id, msgType, msgStr)
				log.Evaluate("msgToPacketRoutine %d: encrypting [%s] raw message: %s", id, msgType, msgStr)

				var mad *MsgAssemblerData
				var err error

				// error handling
				defer func() {
					if err != nil {
						mad.Error = err
						mad.Destroy()

						// inform preset channel with error
						if mad.ResponseMsgCh != nil {
							mad.ResponseMsgCh <- &PacketParserData{
								Error: err,
							}
						}
						if mad.encryptedPktCh != nil {
							mad.encryptedPktCh <- mad
						}
					}
				}()

				// process keepalive separately
				if md.HeaderType == NHP_KPL {
					mad, _ = d.createKeepalivePacket(md)
					// send out keepalive packet
					mad.connData.ForwardOutboundPacket(mad.BasePacket)
					return
				}