Method packetToMsgRoutine

nhp/core/device.go:314–428

Asynchronous multi-channel processing.

(id int)

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

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

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

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

			// packet decryption workflow: connection.RecvQueue -> raw packet -> decryption -> raw message
			func() {
				msgType := HeaderTypeToString(pd.BasePacket.HeaderType)
				log.Debug("packetToMsgRoutine %d: decrypting [%s] raw packet", id, msgType)
				log.Evaluate("packetToMsgRoutine %d: decrypting [%s] raw packet", id, msgType)

				var ppd *PacketParserData
				var err error

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

						// inform preset channel with error
						if ppd.feedbackMsgCh != nil {
							ppd.feedbackMsgCh <- ppd
						}
						if ppd.decryptedMsgCh != nil {
							ppd.decryptedMsgCh <- ppd
						}
					}
				}()

				ppd, err = d.createPacketParserData(pd)
				if err != nil {
					log.Debug("packetToMsgRoutine %d: [%s] packet precheck failed: %v", id, msgType, err)
					log.Evaluate("packetToMsgRoutine %d: [%s] packet precheck failed: %v", id, msgType, err)
					return
				}

				err = ppd.validatePeer()
				if err != nil {
					log.Debug("packetToMsgRoutine %d: [%s] packet validation failed: %v", id, msgType, err)
					log.Evaluate("packetToMsgRoutine %d: [%s] packet validation failed: %v", id, msgType, err)
					return
				}