z.TotalDroppedCount, err = dc.ReadUint64()
			if err != nil {
				err = msgp.WrapError(err, "TotalDroppedCount")
				return
			}
		case "TotalDroppedBytes":
			z.TotalDroppedBytes, err = dc.ReadUint64()
			if err != nil {
				err = msgp.WrapError(err, "TotalDroppedBytes")
				return
			}
		default:
			err = dc.Skip()
			if err != nil {
				err = msgp.WrapError(err)
				return
			}
		}

		atomic.AddUint64(&p.stats.mrfStats.TotalDroppedBytes, uint64(entry.sz))
		return
	}

	select {
	case <-GlobalContext.Done():
		return
	case <-p.mrfStopCh:
		return
	default:
		select {
		case p.mrfSaveCh <- entry:
		default:
			atomic.AddUint64(&p.stats.mrfStats.TotalDroppedCount, 1)
			atomic.AddUint64(&p.stats.mrfStats.TotalDroppedBytes, uint64(entry.sz))
		}
	}
}