1035 lines
40 KiB
Scala
1035 lines
40 KiB
Scala
package BACK
|
||
|
||
import chisel3._
|
||
import chisel3.util._
|
||
|
||
|
||
class FrameHeader extends Bundle{
|
||
val frameLenAim = UInt(12.W) //帧长度目标
|
||
val frameStyle = UInt(2.W) //包类型
|
||
val frameInfo = UInt(16.W) //其它信息,如probe
|
||
}
|
||
|
||
class SubMsgHeader extends Bundle{
|
||
val devIndex = UInt(14.W) // 子报文中设备索引
|
||
val style = UInt(2.W) // 子报文类型
|
||
val address = UInt(16.W) //子报文地址
|
||
val operator = UInt(4.W) //子报文命令类型
|
||
val length = UInt(12.W) //子报文负载长度
|
||
|
||
|
||
def isSeqIndex = style === 0.U
|
||
def isLgcIndex = style === 2.U
|
||
}
|
||
|
||
class SubMsgTail extends Bundle{
|
||
val workCnt = UInt(16.W) //子报文工作计数
|
||
}
|
||
|
||
|
||
// class ShareSRAMIO extends Bundle{
|
||
// val addr = Input(UInt(15.W))
|
||
// val dataw = Input( UInt(8.W) )
|
||
// val datar = Output( UInt(8.W) )
|
||
// val enw = Input(Bool())
|
||
// val enr = Input(Bool())
|
||
// }
|
||
|
||
|
||
|
||
class SlaveParserIO extends Bundle{
|
||
val downIn = Flipped( Decoupled(new AXIS_Bundle(8)) )
|
||
val downOut = Decoupled(new AXIS_Bundle(8))
|
||
|
||
val upIn = Flipped( Decoupled(new AXIS_Bundle(8)) )
|
||
val upOut = Decoupled(new AXIS_Bundle(8))
|
||
|
||
val sram_w = Vec( 4, Flipped(new SRAM2kWRIO))
|
||
val sram_r = Vec( 4, Flipped(new SRAM2kRDIO))
|
||
|
||
val dSMenq = Output( Vec(4, Bool()) )
|
||
val uSMdeq = Output( Vec(4, Bool()) )
|
||
|
||
|
||
|
||
|
||
val localDevIndex = Output(UInt(16.W))
|
||
|
||
//开放链路寄存器组给interface
|
||
// val isDevOnLeft = Output(UInt(2.W))
|
||
// val isDevOnLeftModify = Output(Bool())
|
||
// val indexOfLeftDev = Output(UInt(14.W))
|
||
val isDevOnRight = Output(UInt(2.W))
|
||
val isDevOnRightModify = Output(Bool())
|
||
val indexOfRightDev = Output(UInt(14.W))
|
||
|
||
|
||
val mstDeltaTimeStamp = Output(UInt(32.W))
|
||
val slvDeltaTime = Output(UInt(32.W))
|
||
val deltaFinal = Output(UInt(64.W))
|
||
|
||
val isLoop = Output(Bool())
|
||
|
||
val cReg = Input(new CommonRegisterBundle)
|
||
val sReg = Input(new SlaveRegisterBundle)
|
||
|
||
val lvds = new RegAccessInterfaceIO
|
||
|
||
val intHWTrig = Output(Vec(2, Bool()))
|
||
val intHWClr = Input (Vec(2, Bool()))
|
||
|
||
val downRecStat = Output(new Stat_IO_Bundle)
|
||
val upRecStat = Output(new Stat_IO_Bundle)
|
||
}
|
||
|
||
abstract class SlaveParserBase extends Module with RequireAsyncReset{
|
||
val io: SlaveParserIO = IO(new SlaveParserIO)
|
||
|
||
val sReg = io.sReg
|
||
|
||
|
||
|
||
val FRAME_STYLE_COMMON = 0.U
|
||
val FRAME_STYLE_PROBE = 1.U
|
||
|
||
val SUBMSG_OPERATOR_UNIREAD = 0.U
|
||
val SUBMSG_OPERATOR_UNIWRITE = 1.U
|
||
val SUBMSG_OPERATOR_UNIRDWR = 2.U
|
||
val SUBMSG_OPERATOR_INDEX = "hb".U
|
||
val SUBMSG_OPERATOR_SYNC = "hc".U
|
||
val SUBMSG_OPERATOR_BOARDREAD = "hd".U
|
||
val SUBMSG_OPERATOR_BOARDWRITE = "he".U
|
||
val SUBMSG_OPERATOR_BOARDRDWR = "hf".U
|
||
|
||
|
||
val STATE_IDLE = 0.U //空闲
|
||
val STATE_HEADER = 1.U //长度/ /保留2bits //包类型
|
||
val STATE_SUBMSG_HEADER = 2.U //子报文设备索引 //子报文类型
|
||
val STATE_PAYLOAD_DATA = 3.U //子报文数据
|
||
val STATE_SUBMSG_TAIL = 4.U
|
||
val STATE_CRC = 5.U //CRC校验
|
||
val STATE_ERROR = 6.U //
|
||
val STATE_WAIT = 7.U
|
||
|
||
|
||
|
||
val downRecParser = Module(new SlaveRecParser)
|
||
val upRecParser = Module(new SlaveRecParser)
|
||
val downSendGen = Module(new SlaveSendGen)
|
||
val upSendGen = Module(new SlaveSendGen)
|
||
|
||
val isReadyToProbe = RegInit(false.B)
|
||
val isAckProbe = RegInit(false.B)
|
||
val isLastDevice: Bool = RegInit(true.B)
|
||
|
||
|
||
io.isDevOnRight := Mux( isLastDevice, "b00".U, "b01".U )
|
||
val isDevOnRightModify = RegInit(false.B); io.isDevOnRightModify := isDevOnRightModify
|
||
val indexOfRightDev = RegInit(0.U(14.W)); io.indexOfRightDev := indexOfRightDev
|
||
|
||
val localDevIndex = RegInit(0.U(14.W)); io.localDevIndex := localDevIndex //当前设备索引
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
//处理主报文
|
||
|
||
|
||
downSendGen.io.frameReq.valid := downRecParser.io.frameReq.fire
|
||
assert( ~(downSendGen.io.frameReq.valid & ~downSendGen.io.frameReq.ready) )
|
||
|
||
{
|
||
downSendGen.io.frameReq.bits := downRecParser.io.frameReq.bits
|
||
//voerride
|
||
downSendGen.io.frameReq.bits.frameInfo := localDevIndex
|
||
}
|
||
|
||
|
||
val upFrameProbeInfo: FrameHeader = Wire(new FrameHeader)
|
||
upFrameProbeInfo.frameLenAim := 0.U //帧长度目标
|
||
upFrameProbeInfo.frameStyle := FRAME_STYLE_PROBE //包类型
|
||
upFrameProbeInfo.frameInfo := localDevIndex //其它信息,如probe
|
||
|
||
upSendGen.io.frameReq.valid :=
|
||
(upRecParser.io.frameReq.fire & upRecParser.io.frameReq.bits.frameStyle === FRAME_STYLE_COMMON) |
|
||
isAckProbe
|
||
|
||
assert( ~(upSendGen.io.frameReq.valid & ~upSendGen.io.frameReq.ready) )
|
||
|
||
|
||
assert( ~(upRecParser.io.frameReq.fire & isAckProbe), "Assert Failed, Check Softwave, Probe is Sent while transfering!\n" )
|
||
|
||
upSendGen.io.frameReq.bits := Mux1H(Seq(
|
||
upRecParser.io.frameReq.fire -> upRecParser.io.frameReq.bits, //上行转发
|
||
isAckProbe -> upFrameProbeInfo, //上行探针
|
||
))
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
////////////////////////////////////////
|
||
|
||
//子报文
|
||
val isDownSubMsgHeadValid = for( _ <- 0 until 2 ) yield { RegInit(false.B) }
|
||
val isUpSubMsgHeadValid = for( _ <- 0 until 2 ) yield { RegInit(false.B) }
|
||
|
||
val isDownSubMsgTailValid = for( _ <- 0 until 2 ) yield { RegInit(false.B) }
|
||
val isUpSubMsgTailValid = for( _ <- 0 until 2 ) yield { RegInit(false.B) }
|
||
|
||
|
||
|
||
//接收子报文
|
||
|
||
val downSubMsgHeadInfo = for( _ <- 0 until 2 ) yield { Reg(new SubMsgTxInfo) } //子报文头
|
||
val upSubMsgHeadInfo = for( _ <- 0 until 2 ) yield { Reg(new SubMsgTxInfo) }
|
||
|
||
val downSubMsgTailInfo = for( _ <- 0 until 2 ) yield { Reg(new SubMsgTail) } //子报文头
|
||
val upSubMsgTailInfo = for( _ <- 0 until 2 ) yield { Reg(new SubMsgTail) }
|
||
|
||
|
||
val downRecFifo = for( _ <- 0 until 2 ) yield { Module(new Queue(UInt(8.W), 20)) } //子报文负载
|
||
val upRecFifo = for( _ <- 0 until 2 ) yield { Module(new Queue(UInt(8.W), 20)) }
|
||
|
||
val isDownRecPing = RegInit(false.B)
|
||
val isUpRecPing = RegInit(false.B)
|
||
|
||
|
||
|
||
//下行接收
|
||
when( downRecParser.io.subMsgHeadReq.fire ){
|
||
when( isDownRecPing ){
|
||
downSubMsgHeadInfo(0).devIndex := downRecParser.io.subMsgHeadReq.bits.devIndex
|
||
downSubMsgHeadInfo(0).style := downRecParser.io.subMsgHeadReq.bits.style
|
||
downSubMsgHeadInfo(0).address := downRecParser.io.subMsgHeadReq.bits.address
|
||
downSubMsgHeadInfo(0).operator := downRecParser.io.subMsgHeadReq.bits.operator
|
||
downSubMsgHeadInfo(0).length := downRecParser.io.subMsgHeadReq.bits.length
|
||
downSubMsgHeadInfo(0).source := 0.U
|
||
} .otherwise{ //pong
|
||
downSubMsgHeadInfo(1).devIndex := downRecParser.io.subMsgHeadReq.bits.devIndex
|
||
downSubMsgHeadInfo(1).style := downRecParser.io.subMsgHeadReq.bits.style
|
||
downSubMsgHeadInfo(1).address := downRecParser.io.subMsgHeadReq.bits.address
|
||
downSubMsgHeadInfo(1).operator := downRecParser.io.subMsgHeadReq.bits.operator
|
||
downSubMsgHeadInfo(1).length := downRecParser.io.subMsgHeadReq.bits.length
|
||
downSubMsgHeadInfo(1).source := 1.U
|
||
}
|
||
}
|
||
|
||
when( downRecParser.io.subMsgTailReq.fire ){
|
||
when( isDownRecPing ){
|
||
downSubMsgTailInfo(0).workCnt := downRecParser.io.subMsgTailReq.bits.workCnt
|
||
} .otherwise{ //pong
|
||
downSubMsgTailInfo(1).workCnt := downRecParser.io.subMsgTailReq.bits.workCnt
|
||
}
|
||
}
|
||
|
||
|
||
|
||
|
||
when( isDownRecPing ){ //req fire 后
|
||
downRecFifo(0).io.enq.valid := downRecParser.io.data.valid
|
||
downRecFifo(0).io.enq.bits := downRecParser.io.data.bits
|
||
downRecParser.io.data.ready := downRecFifo(0).io.enq.ready
|
||
|
||
downRecFifo(1).io.enq.valid := false.B
|
||
downRecFifo(1).io.enq.bits := 0.U
|
||
} .otherwise{
|
||
downRecFifo(0).io.enq.valid := false.B
|
||
downRecFifo(0).io.enq.bits := 0.U
|
||
|
||
downRecFifo(1).io.enq.valid := downRecParser.io.data.valid
|
||
downRecFifo(1).io.enq.bits := downRecParser.io.data.bits
|
||
downRecParser.io.data.ready := downRecFifo(1).io.enq.ready
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
//上行接收
|
||
when( upRecParser.io.subMsgHeadReq.fire ){
|
||
when( isUpRecPing ){
|
||
upSubMsgHeadInfo(0).devIndex := upRecParser.io.subMsgHeadReq.bits.devIndex
|
||
upSubMsgHeadInfo(0).style := upRecParser.io.subMsgHeadReq.bits.style
|
||
upSubMsgHeadInfo(0).address := upRecParser.io.subMsgHeadReq.bits.address
|
||
upSubMsgHeadInfo(0).operator := upRecParser.io.subMsgHeadReq.bits.operator
|
||
upSubMsgHeadInfo(0).length := upRecParser.io.subMsgHeadReq.bits.length
|
||
upSubMsgHeadInfo(0).source := 0.U
|
||
} .otherwise{
|
||
upSubMsgHeadInfo(1).devIndex := upRecParser.io.subMsgHeadReq.bits.devIndex
|
||
upSubMsgHeadInfo(1).style := upRecParser.io.subMsgHeadReq.bits.style
|
||
upSubMsgHeadInfo(1).address := upRecParser.io.subMsgHeadReq.bits.address
|
||
upSubMsgHeadInfo(1).operator := upRecParser.io.subMsgHeadReq.bits.operator
|
||
upSubMsgHeadInfo(1).length := upRecParser.io.subMsgHeadReq.bits.length
|
||
upSubMsgHeadInfo(1).source := 1.U
|
||
}
|
||
}
|
||
|
||
when( upRecParser.io.subMsgTailReq.fire ){
|
||
when( isUpRecPing ){
|
||
upSubMsgTailInfo(0).workCnt := upRecParser.io.subMsgTailReq.bits.workCnt
|
||
} .otherwise{
|
||
upSubMsgTailInfo(1).workCnt := upRecParser.io.subMsgTailReq.bits.workCnt
|
||
}
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
|
||
//子报文下行发送
|
||
|
||
val isDownSendPing = RegInit(false.B)
|
||
val isUpSendPing = RegInit(false.B)
|
||
|
||
|
||
|
||
downSendGen.io.subMsgHeadReq.valid :=
|
||
( isDownSendPing & isDownSubMsgHeadValid(0) ) | (~isDownSendPing & isDownSubMsgHeadValid(1))
|
||
|
||
downSendGen.io.subMsgHeadReq.bits := Mux( isDownSendPing, downSubMsgHeadInfo(0), downSubMsgHeadInfo(1) )
|
||
|
||
downSendGen.io.subMsgTailReq.valid :=
|
||
( isDownSendPing & isDownSubMsgTailValid(0) ) | ( ~isDownSendPing & isDownSubMsgTailValid(1))
|
||
|
||
downSendGen.io.subMsgTailReq.bits := Mux( isDownSendPing, downSubMsgTailInfo(0), downSubMsgTailInfo(1) )
|
||
|
||
|
||
|
||
when( downSendGen.io.subMsgHeadReq.fire ){ //ready
|
||
when( isDownSendPing ){
|
||
assert( isDownSubMsgHeadValid(0) )
|
||
isDownSubMsgHeadValid(0) := false.B
|
||
} .otherwise{
|
||
assert( isDownSubMsgHeadValid(1) )
|
||
isDownSubMsgHeadValid(1) := false.B
|
||
}
|
||
} .elsewhen( downRecParser.io.subMsgHeadReq.fire ){
|
||
when( isDownRecPing ){
|
||
assert( ~isDownSubMsgHeadValid(0) )
|
||
isDownSubMsgHeadValid(0) := true.B
|
||
} .otherwise{
|
||
assert( ~isDownSubMsgHeadValid(1) )
|
||
isDownSubMsgHeadValid(1) := true.B
|
||
}
|
||
}
|
||
|
||
when( downSendGen.io.subMsgTailReq.fire ){
|
||
when( isDownSendPing ){
|
||
assert( isDownSubMsgTailValid(0) )
|
||
isDownSubMsgTailValid(0) := false.B
|
||
} .otherwise{
|
||
assert( isDownSubMsgTailValid(1) )
|
||
isDownSubMsgTailValid(1) := false.B
|
||
}
|
||
} .elsewhen( downRecParser.io.subMsgTailReq.fire ){
|
||
when( isDownRecPing ){
|
||
assert( ~isDownSubMsgTailValid(0) )
|
||
isDownSubMsgTailValid(0) := true.B
|
||
} .otherwise{
|
||
assert( ~isDownSubMsgTailValid(1) )
|
||
isDownSubMsgTailValid(1) := true.B
|
||
}
|
||
}
|
||
|
||
when( downSendGen.io.subMsgTailReq.fire ){ //ready
|
||
isDownSendPing := ~isDownSendPing
|
||
} .elsewhen( downRecParser.io.subMsgTailReq.fire ){
|
||
isDownRecPing := ~isDownRecPing
|
||
}
|
||
|
||
downRecFifo(0).io.deq <> downSendGen.io.data(0)
|
||
downRecFifo(1).io.deq <> downSendGen.io.data(1)
|
||
|
||
|
||
//子报文上行发送
|
||
|
||
|
||
upSendGen.io.subMsgHeadReq.valid :=
|
||
( isUpSendPing & isUpSubMsgHeadValid(0) ) |
|
||
( ~isUpSendPing & isUpSubMsgHeadValid(1) )
|
||
|
||
upSendGen.io.subMsgHeadReq.bits := Mux( isUpSendPing, upSubMsgHeadInfo(0), upSubMsgHeadInfo(1) )
|
||
|
||
upSendGen.io.subMsgTailReq.valid :=
|
||
( isUpSendPing & isUpSubMsgTailValid(0) ) |
|
||
( ~isUpSendPing & isUpSubMsgTailValid(1) )
|
||
|
||
upSendGen.io.subMsgTailReq.bits := Mux( isUpSendPing, upSubMsgTailInfo(0), upSubMsgTailInfo(1) )
|
||
|
||
when( upSendGen.io.subMsgHeadReq.fire ){ //ready
|
||
when( isUpSendPing ){
|
||
assert( isUpSubMsgHeadValid(0) )
|
||
isUpSubMsgHeadValid(0) := false.B
|
||
} .otherwise{
|
||
assert( isUpSubMsgHeadValid(1) )
|
||
isUpSubMsgHeadValid(1) := false.B
|
||
}
|
||
}.elsewhen( upRecParser.io.subMsgHeadReq.fire ){
|
||
when( isUpRecPing ){
|
||
assert( ~isUpSubMsgHeadValid(0) )
|
||
isUpSubMsgHeadValid(0) := true.B
|
||
} .otherwise{
|
||
assert( ~isUpSubMsgHeadValid(1) )
|
||
isUpSubMsgHeadValid(1) := true.B
|
||
}
|
||
}
|
||
|
||
when( upSendGen.io.subMsgTailReq.fire ){
|
||
when( isUpSendPing ){
|
||
assert( isUpSubMsgTailValid(0) )
|
||
isUpSubMsgTailValid(0) := false.B
|
||
} .otherwise{
|
||
assert( isUpSubMsgTailValid(1) )
|
||
isUpSubMsgTailValid(1) := false.B
|
||
}
|
||
} .elsewhen( upRecParser.io.subMsgTailReq.fire ){
|
||
when( isUpRecPing ){
|
||
assert( ~isUpSubMsgTailValid(0) )
|
||
isUpSubMsgTailValid(0) := true.B
|
||
} .otherwise{
|
||
assert( ~isUpSubMsgTailValid(1) )
|
||
isUpSubMsgTailValid(1) := true.B
|
||
}
|
||
}
|
||
|
||
|
||
when( upSendGen.io.subMsgTailReq.fire ){ //ready
|
||
isUpSendPing := ~isUpSendPing
|
||
}.elsewhen( upRecParser.io.subMsgTailReq.fire ){
|
||
isUpRecPing := ~isUpRecPing
|
||
}
|
||
|
||
upRecFifo(0).io.deq <> upSendGen.io.data(0)
|
||
upRecFifo(1).io.deq <> upSendGen.io.data(1)
|
||
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
trait SlaveParserIndex{ this: SlaveParserBase =>
|
||
//下行接收
|
||
when( downRecParser.io.subMsgTailReq.fire ){
|
||
when( isDownRecPing &
|
||
downSubMsgHeadInfo(0).devIndex === 0.U &
|
||
downSubMsgHeadInfo(0).style === 0.U &
|
||
downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_INDEX
|
||
){
|
||
localDevIndex := downRecParser.io.subMsgTailReq.bits.workCnt + 1.U
|
||
indexOfRightDev := Mux(isLastDevice, 0.U, downRecParser.io.subMsgTailReq.bits.workCnt + 2.U)
|
||
downSubMsgTailInfo(0).workCnt := downRecParser.io.subMsgTailReq.bits.workCnt + 1.U
|
||
} .elsewhen( ~isDownRecPing &
|
||
downSubMsgHeadInfo(1).devIndex === 0.U &
|
||
downSubMsgHeadInfo(1).style === 0.U &
|
||
downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_INDEX
|
||
){ //pong
|
||
localDevIndex := downRecParser.io.subMsgTailReq.bits.workCnt + 1.U
|
||
indexOfRightDev := Mux(isLastDevice, 0.U, downRecParser.io.subMsgTailReq.bits.workCnt + 2.U)
|
||
downSubMsgTailInfo(1).workCnt := downRecParser.io.subMsgTailReq.bits.workCnt + 1.U
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
trait SlaveParserRW{ this: SlaveParserBase =>
|
||
|
||
val isDownLgcWorked = RegInit(false.B)
|
||
val isUpLgcWorked = RegInit(false.B)
|
||
|
||
//下行接收
|
||
when( downRecParser.io.subMsgTailReq.fire ){
|
||
when( isDownRecPing ){
|
||
//override
|
||
when(
|
||
( ( (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIWRITE) | (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIRDWR) ) & ( (downSubMsgHeadInfo(0).isSeqIndex & downSubMsgHeadInfo(0).devIndex === localDevIndex) || ( downSubMsgHeadInfo(0).isLgcIndex & isDownLgcWorked ) ) ) |
|
||
( ( (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_BOARDWRITE) | (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_BOARDRDWR) ) )
|
||
) { //自身包//写操作或读写操作)
|
||
downSubMsgTailInfo(0).workCnt := downRecParser.io.subMsgTailReq.bits.workCnt + 1.U
|
||
}
|
||
|
||
} .otherwise{ //pong
|
||
//override
|
||
when(
|
||
( ( (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIWRITE ) | (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIRDWR ) ) & ( (downSubMsgHeadInfo(1).isSeqIndex & downSubMsgHeadInfo(1).devIndex === localDevIndex) || ( downSubMsgHeadInfo(1).isLgcIndex & isDownLgcWorked ) ) ) |
|
||
( ( (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_BOARDWRITE) | (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_BOARDRDWR) ) )
|
||
) { //自身包//写操作或读写操作 )
|
||
downSubMsgTailInfo(1).workCnt := downRecParser.io.subMsgTailReq.bits.workCnt + 1.U
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
|
||
//写入 SM或寄存器空间
|
||
|
||
val addrw = Reg(UInt(15.W))
|
||
val logicAddrwNext = Wire( UInt(30.W) )
|
||
val logicAddrw = RegNext(logicAddrwNext)
|
||
|
||
val isWRReg = (addrw(14,11) === "b0000".U)
|
||
val isWRSM0 = (addrw(14,11) === "b0001".U)
|
||
val isWRSM2 = (addrw(14,11) === "b0011".U)
|
||
val isWRSM4 = (addrw(14,11) === "b0101".U)
|
||
val isWRSM6 = (addrw(14,11) === "b0111".U)
|
||
|
||
val downTransLenCnt = RegInit(0.U)
|
||
|
||
val isWrite = (downRecParser.io.stateCurr === STATE_PAYLOAD_DATA) & ( //req fire 后 已经反相
|
||
( isDownRecPing & ( (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIWRITE) | (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIRDWR ) ) & ( (downSubMsgHeadInfo(0).isSeqIndex & downSubMsgHeadInfo(0).devIndex === localDevIndex) || ( downSubMsgHeadInfo(0).isLgcIndex & downTransLenCnt =/= 0.U) ) ) |
|
||
( ~isDownRecPing & ( (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIWRITE) | (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIRDWR ) ) & ( (downSubMsgHeadInfo(1).isSeqIndex & downSubMsgHeadInfo(1).devIndex === localDevIndex) || ( downSubMsgHeadInfo(1).isLgcIndex & downTransLenCnt =/= 0.U) ) ) |
|
||
( isDownRecPing & ( (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_BOARDWRITE) | (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_BOARDRDWR) ) ) |
|
||
( ~isDownRecPing & ( (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_BOARDWRITE) | (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_BOARDRDWR) ) )
|
||
)
|
||
|
||
|
||
val isDownLgcAddrwAcquireTrans = //是否触发地址转换
|
||
(downTransLenCnt === 0.U) & ( (0 until 16).map{ i =>
|
||
sReg.ebmmu(i).isEnable & (sReg.ebmmu(i).EBMMU_OP_WR || sReg.ebmmu(i).EBMMU_OP_RW) & (logicAddrwNext === sReg.ebmmu(i).lAddr)
|
||
}.reduce(_|_))
|
||
|
||
val acquireDownPhyAddrw = Mux1H( //选择一个ebmmu
|
||
(0 until 16).map{ i =>
|
||
(sReg.ebmmu(i).isEnable & (sReg.ebmmu(i).EBMMU_OP_WR || sReg.ebmmu(i).EBMMU_OP_RW) & (logicAddrwNext === sReg.ebmmu(i).lAddr)) ->
|
||
sReg.ebmmu(i).pAddr
|
||
}
|
||
)
|
||
|
||
val acquireDownTransLen = Mux1H( //选择一个ebmmu
|
||
(0 until 16).map{ i =>
|
||
(sReg.ebmmu(i).isEnable & (sReg.ebmmu(i).EBMMU_OP_WR || sReg.ebmmu(i).EBMMU_OP_RW) & (logicAddrwNext === sReg.ebmmu(i).lAddr)) ->
|
||
sReg.ebmmu(i).length
|
||
}
|
||
)
|
||
|
||
when( isDownLgcAddrwAcquireTrans ){ //装填计数器
|
||
downTransLenCnt := acquireDownTransLen
|
||
} .elsewhen( downRecParser.io.data.fire & downTransLenCnt =/= 0.U){
|
||
downTransLenCnt := downTransLenCnt - 1.U
|
||
}
|
||
|
||
when( downRecParser.io.subMsgTailReq.fire ){
|
||
isDownLgcWorked := false.B
|
||
} .elsewhen( isDownLgcAddrwAcquireTrans ){
|
||
isDownLgcWorked := true.B
|
||
}
|
||
|
||
//组合逻辑
|
||
when( downRecParser.io.subMsgHeadReq.fire & (
|
||
(downRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIWRITE | downRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIRDWR) & downRecParser.io.subMsgHeadReq.bits.isLgcIndex
|
||
)){//组合逻辑
|
||
logicAddrwNext := Cat( downRecParser.io.subMsgHeadReq.bits.devIndex, downRecParser.io.subMsgHeadReq.bits.address )
|
||
} .elsewhen( downRecParser.io.data.fire & (
|
||
( isDownRecPing & ( (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIWRITE) | (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIRDWR ) ) & downSubMsgHeadInfo(0).isLgcIndex ) |
|
||
( ~isDownRecPing & ( (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIWRITE) | (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIRDWR ) ) & downSubMsgHeadInfo(1).isLgcIndex )
|
||
)){//组合逻辑
|
||
logicAddrwNext := logicAddrw + 1.U
|
||
} .otherwise{//组合逻辑
|
||
logicAddrwNext := logicAddrw
|
||
}
|
||
|
||
when(
|
||
( (downRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIWRITE | downRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIRDWR) & downRecParser.io.subMsgHeadReq.bits.isSeqIndex & downRecParser.io.subMsgHeadReq.bits.devIndex === localDevIndex ) |
|
||
( downRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_BOARDWRITE | downRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_BOARDRDWR )
|
||
){ //常规寻址
|
||
when( downRecParser.io.subMsgHeadReq.fire ){ //子包头装填
|
||
addrw := downRecParser.io.subMsgHeadReq.bits.address
|
||
} .elsewhen( isWrite & downRecParser.io.data.fire ){
|
||
addrw := addrw + 1.U
|
||
}
|
||
} .elsewhen( isDownLgcAddrwAcquireTrans & (
|
||
( downRecParser.io.subMsgHeadReq.fire & (downRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIWRITE | downRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIRDWR) & downRecParser.io.subMsgHeadReq.bits.isLgcIndex ) |
|
||
( isDownRecPing & ( (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIWRITE) | (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIRDWR ) ) & downSubMsgHeadInfo(0).isLgcIndex ) |
|
||
( ~isDownRecPing & ( (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIWRITE) | (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIRDWR ) ) & downSubMsgHeadInfo(1).isLgcIndex )
|
||
)){
|
||
addrw := acquireDownPhyAddrw
|
||
} .elsewhen(
|
||
isWrite & downRecParser.io.data.fire & (
|
||
( isDownRecPing & ( (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIWRITE) | (downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIRDWR ) ) & downSubMsgHeadInfo(0).isLgcIndex ) |
|
||
( ~isDownRecPing & ( (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIWRITE) | (downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIRDWR ) ) & downSubMsgHeadInfo(1).isLgcIndex )
|
||
) ){
|
||
assert(~isDownLgcAddrwAcquireTrans)
|
||
addrw := Mux( downTransLenCnt === 0.U, 0.U, addrw + 1.U )
|
||
}
|
||
|
||
io.lvds.isEnW := isWrite & isWRReg & downRecParser.io.data.fire
|
||
io.lvds.dataw := downRecParser.io.data.bits
|
||
|
||
io.sram_w(0).enw := isWrite & isWRSM0 & downRecParser.io.data.fire
|
||
io.sram_w(0).addrw := addrw(10,0)
|
||
io.sram_w(0).dataw := downRecParser.io.data.bits
|
||
|
||
io.sram_w(1).enw := isWrite & isWRSM2 & downRecParser.io.data.fire
|
||
io.sram_w(1).addrw := addrw(10,0)
|
||
io.sram_w(1).dataw := downRecParser.io.data.bits
|
||
|
||
io.sram_w(2).enw := isWrite & isWRSM4 & downRecParser.io.data.fire
|
||
io.sram_w(2).addrw := addrw(10,0)
|
||
io.sram_w(2).dataw := downRecParser.io.data.bits
|
||
|
||
io.sram_w(3).enw := isWrite & isWRSM6 & downRecParser.io.data.fire
|
||
io.sram_w(3).addrw := addrw(10,0)
|
||
io.sram_w(3).dataw := downRecParser.io.data.bits
|
||
|
||
|
||
|
||
|
||
|
||
//上行接收
|
||
when( upRecParser.io.subMsgTailReq.fire ){
|
||
when( isUpRecPing ){
|
||
//override
|
||
when(
|
||
( ( (upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIREAD ) | (upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIRDWR ) ) & ((upSubMsgHeadInfo(0).isSeqIndex & upSubMsgHeadInfo(0).devIndex === localDevIndex) || (upSubMsgHeadInfo(0).isLgcIndex & isUpLgcWorked =/= 0.U ) ) ) |
|
||
( ( (upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_BOARDREAD) | (upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_BOARDRDWR) ) )
|
||
){ //自身包//读或读写
|
||
upSubMsgTailInfo(0).workCnt := upRecParser.io.subMsgTailReq.bits.workCnt + 1.U
|
||
}
|
||
} .otherwise{
|
||
//override
|
||
when(
|
||
( ( (upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIREAD ) | (upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIRDWR ) ) & ((upSubMsgHeadInfo(1).isSeqIndex & upSubMsgHeadInfo(1).devIndex === localDevIndex) || (upSubMsgHeadInfo(1).isLgcIndex & isUpLgcWorked =/= 0.U ) ) ) |
|
||
( ( (upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_BOARDREAD) | (upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_BOARDRDWR) ) )
|
||
){ //自身包//读或读写 )
|
||
upSubMsgTailInfo(1).workCnt := upRecParser.io.subMsgTailReq.bits.workCnt + 1.U
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
val upTransLenCnt = RegInit(0.U)
|
||
|
||
|
||
val addrr = Reg(UInt(15.W))
|
||
val logicAddrrNext = Wire( UInt(30.W) )
|
||
val logicAddrr = RegNext(logicAddrrNext)
|
||
|
||
|
||
val isUpLgcAddrrAcquireTrans = //是否触发地址转换
|
||
(upTransLenCnt === 0.U) & ( (0 until 16).map{ i =>
|
||
sReg.ebmmu(i).isEnable & (sReg.ebmmu(i).EBMMU_OP_RD || sReg.ebmmu(i).EBMMU_OP_RW) & (logicAddrrNext === sReg.ebmmu(i).lAddr)
|
||
}.reduce(_|_))
|
||
|
||
val acquireUpPhyAddrr = Mux1H( //选择一个ebmmu
|
||
(0 until 16).map{ i =>
|
||
(sReg.ebmmu(i).isEnable & (sReg.ebmmu(i).EBMMU_OP_RD || sReg.ebmmu(i).EBMMU_OP_RW) & (logicAddrrNext === sReg.ebmmu(i).lAddr)) ->
|
||
sReg.ebmmu(i).pAddr
|
||
}
|
||
)
|
||
|
||
val acquireUpTransLen = Mux1H( //选择一个ebmmu
|
||
(0 until 16).map{ i =>
|
||
(sReg.ebmmu(i).isEnable & (sReg.ebmmu(i).EBMMU_OP_RD || sReg.ebmmu(i).EBMMU_OP_RW) & (logicAddrrNext === sReg.ebmmu(i).lAddr)) ->
|
||
sReg.ebmmu(i).length
|
||
}
|
||
)
|
||
|
||
when( isUpLgcAddrrAcquireTrans & (
|
||
(upRecParser.io.subMsgHeadReq.fire & (upRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIREAD | upRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIRDWR) & upRecParser.io.subMsgHeadReq.bits.isLgcIndex) |
|
||
( isUpRecPing & (upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIRDWR ) & ( upSubMsgHeadInfo(0).isLgcIndex )) |
|
||
(~isUpRecPing & (upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIRDWR ) & ( upSubMsgHeadInfo(1).isLgcIndex ))
|
||
)){ //装填计数器
|
||
upTransLenCnt := acquireUpTransLen
|
||
} .elsewhen( upRecParser.io.data.fire & upTransLenCnt =/= 0.U ){
|
||
upTransLenCnt := upTransLenCnt - 1.U
|
||
}
|
||
|
||
when( upRecParser.io.subMsgTailReq.fire ){
|
||
isUpLgcWorked := false.B
|
||
} .elsewhen( isUpLgcAddrrAcquireTrans ){
|
||
isUpLgcWorked := true.B
|
||
}
|
||
|
||
//组合逻辑
|
||
when( upRecParser.io.subMsgHeadReq.fire & (
|
||
(upRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIREAD | upRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIRDWR) & upRecParser.io.subMsgHeadReq.bits.isLgcIndex
|
||
)){//组合逻辑
|
||
logicAddrrNext := Cat( upRecParser.io.subMsgHeadReq.bits.devIndex, upRecParser.io.subMsgHeadReq.bits.address )
|
||
} .elsewhen( upRecParser.io.data.fire){
|
||
when(
|
||
( isUpRecPing & (upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIRDWR ) & upSubMsgHeadInfo(0).isLgcIndex ) |
|
||
(~isUpRecPing & (upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIRDWR ) & upSubMsgHeadInfo(1).isLgcIndex )
|
||
){//组合逻辑
|
||
logicAddrrNext := logicAddrr + 1.U
|
||
} .otherwise{
|
||
logicAddrrNext := 0.U
|
||
}
|
||
} .otherwise{//组合逻辑
|
||
logicAddrrNext := logicAddrr
|
||
}
|
||
|
||
|
||
val isRDReg = addrr(14,11) === "b0000".U
|
||
val isRDSM1 = addrr(14,11) === "b0010".U
|
||
val isRDSM3 = addrr(14,11) === "b0100".U
|
||
val isRDSM5 = addrr(14,11) === "b0110".U
|
||
val isRDSM7 = addrr(14,11) === "b1000".U
|
||
|
||
val isSeqRead =
|
||
((upRecParser.io.stateCurr === STATE_PAYLOAD_DATA) & (
|
||
( isUpRecPing & (upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIRDWR ) & ((upSubMsgHeadInfo(0).isSeqIndex & upSubMsgHeadInfo(0).devIndex === localDevIndex) )) |
|
||
(~isUpRecPing & (upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIRDWR ) & ((upSubMsgHeadInfo(1).isSeqIndex & upSubMsgHeadInfo(1).devIndex === localDevIndex) )) |
|
||
( isUpRecPing & (upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_BOARDREAD | upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_BOARDRDWR ) ) |
|
||
(~isUpRecPing & (upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_BOARDREAD | upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_BOARDRDWR ) )
|
||
)
|
||
) & ( (RegNext(upRecParser.io.stateCurr) =/= STATE_PAYLOAD_DATA) | upRecParser.io.data.fire )
|
||
|
||
val isLgcRead =
|
||
((upRecParser.io.stateCurr === STATE_PAYLOAD_DATA) & (
|
||
( isUpRecPing & (upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIRDWR ) & ( (upSubMsgHeadInfo(0).isLgcIndex & upTransLenCnt =/= 0.U ) )) |
|
||
(~isUpRecPing & (upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIRDWR ) & ( (upSubMsgHeadInfo(1).isLgcIndex & upTransLenCnt =/= 0.U ) ))
|
||
)
|
||
) & ( RegNext(isUpLgcAddrrAcquireTrans) | upRecParser.io.data.fire )
|
||
|
||
val isLvdsEnR = isSeqRead | isLgcRead
|
||
|
||
|
||
|
||
when(
|
||
((upRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIREAD | upRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIRDWR ) & (upRecParser.io.subMsgHeadReq.bits.isSeqIndex & upRecParser.io.subMsgHeadReq.bits.devIndex === localDevIndex)) |
|
||
( upRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_BOARDREAD | upRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_BOARDRDWR)
|
||
){
|
||
when( upRecParser.io.subMsgHeadReq.fire){
|
||
addrr := upRecParser.io.subMsgHeadReq.bits.address
|
||
} .elsewhen(isLvdsEnR){
|
||
addrr := addrr + 1.U
|
||
}
|
||
} .elsewhen( isUpLgcAddrrAcquireTrans & (
|
||
(upRecParser.io.subMsgHeadReq.fire & (upRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIREAD | upRecParser.io.subMsgHeadReq.bits.operator === SUBMSG_OPERATOR_UNIRDWR) & upRecParser.io.subMsgHeadReq.bits.isLgcIndex) |
|
||
( isUpRecPing & (upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIRDWR ) & ( upSubMsgHeadInfo(0).isLgcIndex )) |
|
||
(~isUpRecPing & (upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIRDWR ) & ( upSubMsgHeadInfo(1).isLgcIndex ))
|
||
)){
|
||
addrr := acquireUpPhyAddrr
|
||
} .elsewhen( isLvdsEnR & (
|
||
( isUpRecPing & (upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIRDWR ) & ( upSubMsgHeadInfo(0).isLgcIndex )) |
|
||
(~isUpRecPing & (upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIRDWR ) & ( upSubMsgHeadInfo(1).isLgcIndex ))
|
||
)){
|
||
assert(~isUpLgcAddrrAcquireTrans)
|
||
addrr := Mux( upTransLenCnt === 0.U, 0.U, addrr + 1.U )
|
||
}
|
||
|
||
|
||
|
||
val upStreamData = Mux1H(Seq(
|
||
isRDReg -> io.lvds.datar,
|
||
isRDSM1 -> io.sram_r(0).datar,
|
||
isRDSM3 -> io.sram_r(1).datar,
|
||
isRDSM5 -> io.sram_r(2).datar,
|
||
isRDSM7 -> io.sram_r(3).datar,
|
||
))
|
||
|
||
|
||
when( isUpRecPing ){
|
||
upRecFifo(0).io.enq.valid := upRecParser.io.data.valid
|
||
upRecFifo(0).io.enq.bits :=
|
||
Mux(
|
||
( upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_UNIRDWR ) & ((upSubMsgHeadInfo(0).isSeqIndex & upSubMsgHeadInfo(0).devIndex === localDevIndex) | (upSubMsgHeadInfo(0).isLgcIndex & upTransLenCnt =/= 0.U)), upStreamData,
|
||
Mux( upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_BOARDREAD | upSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_BOARDRDWR, upStreamData | upRecParser.io.data.bits,
|
||
upRecParser.io.data.bits )
|
||
)
|
||
upRecParser.io.data.ready := upRecFifo(0).io.enq.ready
|
||
|
||
upRecFifo(1).io.enq.valid := false.B
|
||
upRecFifo(1).io.enq.bits := 0.U
|
||
} .otherwise{
|
||
upRecFifo(0).io.enq.valid := false.B
|
||
upRecFifo(0).io.enq.bits := 0.U
|
||
|
||
upRecFifo(1).io.enq.valid := upRecParser.io.data.valid
|
||
upRecFifo(1).io.enq.bits :=
|
||
Mux(
|
||
( upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIREAD | upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_UNIRDWR ) & ((upSubMsgHeadInfo(1).isSeqIndex & upSubMsgHeadInfo(1).devIndex === localDevIndex) | (upSubMsgHeadInfo(1).isLgcIndex & upTransLenCnt =/= 0.U)), upStreamData,
|
||
Mux( upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_BOARDREAD | upSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_BOARDRDWR, upStreamData | upRecParser.io.data.bits,
|
||
upRecParser.io.data.bits
|
||
)
|
||
)
|
||
upRecParser.io.data.ready := upRecFifo(1).io.enq.ready
|
||
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
io.lvds.addrr := addrr(10,0)
|
||
io.lvds.addrw := addrw(10,0)
|
||
|
||
|
||
// assert( ~(isRead & isWrite) )
|
||
|
||
|
||
|
||
io.lvds.isEnR := isRDReg & isLvdsEnR
|
||
io.sram_r(0).enr := isRDSM1 & isLvdsEnR
|
||
io.sram_r(1).enr := isRDSM3 & isLvdsEnR
|
||
io.sram_r(2).enr := isRDSM5 & isLvdsEnR
|
||
io.sram_r(3).enr := isRDSM7 & isLvdsEnR
|
||
|
||
io.sram_r(0).addrr := addrr(10,0)
|
||
io.sram_r(1).addrr := addrr(10,0)
|
||
io.sram_r(2).addrr := addrr(10,0)
|
||
io.sram_r(3).addrr := addrr(10,0)
|
||
|
||
|
||
io.dSMenq(0) := io.sram_w(0).enw & isWRSM0 & (io.cReg.smTrigLen(0) - 1.U) === addrw(10,0)
|
||
io.uSMdeq(0) := isLvdsEnR & isRDSM1 & (io.cReg.smTrigLen(1) - 1.U + 1.U) === addrr(10,0)
|
||
io.dSMenq(1) := io.sram_w(1).enw & isWRSM2 & (io.cReg.smTrigLen(2) - 1.U) === addrw(10,0)
|
||
io.uSMdeq(1) := isLvdsEnR & isRDSM3 & (io.cReg.smTrigLen(3) - 1.U + 1.U) === addrr(10,0)
|
||
io.dSMenq(2) := io.sram_w(2).enw & isWRSM4 & (io.cReg.smTrigLen(4) - 1.U) === addrw(10,0)
|
||
io.uSMdeq(2) := isLvdsEnR & isRDSM5 & (io.cReg.smTrigLen(5) - 1.U + 1.U) === addrr(10,0)
|
||
io.dSMenq(3) := io.sram_w(3).enw & isWRSM6 & (io.cReg.smTrigLen(6) - 1.U) === addrw(10,0)
|
||
io.uSMdeq(3) := isLvdsEnR & isRDSM7 & (io.cReg.smTrigLen(7) - 1.U + 1.U) === addrr(10,0)
|
||
|
||
|
||
}
|
||
|
||
|
||
trait SlaveParserSync{ this: SlaveParserBase =>
|
||
val addr64_op1 = WireDefault( 0.U(64.W) )
|
||
val addr64_op2 = WireDefault( 0.U(64.W) )
|
||
def subOp2(x:UInt) = ~x + 1.U
|
||
val addr64_res = addr64_op1 + addr64_op2
|
||
|
||
val addrConflict = WireDefault(VecInit(Seq.fill(4){false.B}))
|
||
assert( PopCount(addrConflict) <= 1.U )
|
||
|
||
|
||
//下行接收
|
||
when( downRecParser.io.subMsgTailReq.fire ){
|
||
when( isDownRecPing ){
|
||
//override
|
||
when( downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_SYNC ) { //同步包
|
||
downSubMsgTailInfo(0).workCnt := downRecParser.io.subMsgTailReq.bits.workCnt + 1.U
|
||
}
|
||
|
||
} .otherwise{ //pong
|
||
//override
|
||
when( downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_SYNC ) { //同步包 )
|
||
downSubMsgTailInfo(1).workCnt := downRecParser.io.subMsgTailReq.bits.workCnt + 1.U
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
|
||
val downTimeStamp = Reg(UInt(64.W)) //下行本地时间戳寄存器
|
||
val upTimeStamp = Reg(UInt(64.W)) //上行本地时间戳寄存器
|
||
val mstTimeStamp = Reg(UInt(64.W)) //主站时间戳
|
||
val mstDeltaTimeStamp = Reg(UInt(32.W)); io.mstDeltaTimeStamp := mstDeltaTimeStamp //主站时间戳差值
|
||
val slvDeltaTimeStamp = Reg(UInt(32.W)); io.slvDeltaTime := slvDeltaTimeStamp //从站时间戳差值
|
||
|
||
val mstSlvDeltaTimeStamp = Reg(UInt(64.W)) //主发从接时间差(中间变量)
|
||
val deltaMstSlvDeltaTimeStamp = Reg(UInt(64.W)) //主差从差时间差(中间变量)
|
||
val deltaFinal = Reg(UInt(64.W)); io.deltaFinal := deltaFinal //当前时间戳与主站时间差
|
||
|
||
|
||
// val recoTimeStamp = Reg(UInt(64.W)) //时钟补偿寄存器
|
||
|
||
// dontTouch(recoTimeStamp)
|
||
|
||
// recoTimeStamp = io.timeStamp + deltaFinal
|
||
// recoTimeStamp = io.timeStamp + mstSlvDeltaTimeStamp + deltaMstSlvDeltaTimeStamp
|
||
// recoTimeStamp = io.timeStamp + mstTimeStamp - downTimeStamp + (mstDeltaTimeStamp - slvDeltaTimeStamp ) >> 1
|
||
// recoTimeStamp = io.timeStamp + mstTimeStamp - downTimeStamp + (mstDeltaTimeStamp - (upTimeStamp - downTimeStamp)) >> 1
|
||
|
||
|
||
//更新下行本地时间戳寄存器
|
||
when( downRecParser.io.frameReq.fire & downRecParser.io.frameReq.bits.frameStyle === FRAME_STYLE_COMMON ){
|
||
downTimeStamp := io.cReg.timeStamp
|
||
}
|
||
|
||
//更新上行本地时间戳寄存器
|
||
when( upRecParser.io.frameReq.fire & upRecParser.io.frameReq.bits.frameStyle === FRAME_STYLE_COMMON ){
|
||
upTimeStamp := io.cReg.timeStamp
|
||
|
||
// slvDeltaTimeStamp := io.cReg.timeStamp - downTimeStamp
|
||
addr64_op1 := io.cReg.timeStamp //组合逻辑
|
||
addr64_op2 := subOp2(downTimeStamp) //组合逻辑
|
||
addrConflict(0) := true.B //组合逻辑
|
||
slvDeltaTimeStamp := addr64_res //时序逻辑
|
||
}
|
||
|
||
//下行接收
|
||
val isSync = (downRecParser.io.stateCurr === STATE_PAYLOAD_DATA) & ( //req fire 后 已经反相
|
||
( isDownRecPing & downSubMsgHeadInfo(0).devIndex === 0.U & downSubMsgHeadInfo(0).operator === SUBMSG_OPERATOR_SYNC ) |
|
||
( ~isDownRecPing & downSubMsgHeadInfo(1).devIndex === 0.U & downSubMsgHeadInfo(1).operator === SUBMSG_OPERATOR_SYNC )
|
||
)
|
||
|
||
val syncCnt = Reg(UInt(4.W))
|
||
|
||
when( downRecParser.io.rec.fire ){
|
||
when( isSync ){
|
||
syncCnt := syncCnt + 1.U
|
||
} .otherwise{
|
||
syncCnt := 0.U
|
||
}
|
||
}
|
||
|
||
|
||
when( isSync & downRecParser.io.rec.fire ){
|
||
when( syncCnt === 0.U ){
|
||
mstTimeStamp := Cat( mstTimeStamp(63, 8), downRecParser.io.data.bits )
|
||
} .elsewhen( syncCnt === 1.U ){
|
||
mstTimeStamp := Cat( mstTimeStamp(63,16), downRecParser.io.data.bits, mstTimeStamp(7,0) )
|
||
} .elsewhen( syncCnt === 2.U ){
|
||
mstTimeStamp := Cat( mstTimeStamp(63,24), downRecParser.io.data.bits, mstTimeStamp(15,0) )
|
||
} .elsewhen( syncCnt === 3.U ){
|
||
mstTimeStamp := Cat( mstTimeStamp(63,32), downRecParser.io.data.bits, mstTimeStamp(23,0) )
|
||
} .elsewhen( syncCnt === 4.U ){
|
||
mstTimeStamp := Cat( mstTimeStamp(63,40), downRecParser.io.data.bits, mstTimeStamp(31,0) )
|
||
} .elsewhen( syncCnt === 5.U ){
|
||
mstTimeStamp := Cat( mstTimeStamp(63,48), downRecParser.io.data.bits, mstTimeStamp(39,0) )
|
||
} .elsewhen( syncCnt === 6.U ){
|
||
mstTimeStamp := Cat( mstTimeStamp(63,56), downRecParser.io.data.bits, mstTimeStamp(47,0) )
|
||
} .elsewhen( syncCnt === 7.U ){
|
||
mstTimeStamp := Cat( downRecParser.io.data.bits, mstTimeStamp(55,0) )
|
||
} .elsewhen( syncCnt === 8.U ){
|
||
// mstSlvDeltaTimeStamp := mstTimeStamp - downTimeStamp
|
||
|
||
addr64_op1 := mstTimeStamp //组合逻辑
|
||
addr64_op2 := subOp2(downTimeStamp) //组合逻辑
|
||
addrConflict(1) := true.B //组合逻辑
|
||
mstSlvDeltaTimeStamp := addr64_res //时序逻辑
|
||
|
||
mstDeltaTimeStamp := Cat( mstDeltaTimeStamp(31, 8), downRecParser.io.data.bits )
|
||
} .elsewhen( syncCnt === 9.U ){
|
||
mstDeltaTimeStamp := Cat( mstDeltaTimeStamp(31,16), downRecParser.io.data.bits, mstDeltaTimeStamp(7,0) )
|
||
} .elsewhen( syncCnt === 10.U ){
|
||
mstDeltaTimeStamp := Cat( mstDeltaTimeStamp(31,24), downRecParser.io.data.bits, mstDeltaTimeStamp(15,0) )
|
||
} .elsewhen( syncCnt === 11.U ){
|
||
mstDeltaTimeStamp := Cat( downRecParser.io.data.bits, mstDeltaTimeStamp(23, 0) )
|
||
} .otherwise{
|
||
assert(false.B, "Wrong Sync SubMsg!\n")
|
||
}
|
||
}
|
||
|
||
when( RegNext(isSync) & ~isSync ){
|
||
// deltaMstSlvDeltaTimeStamp := (mstDeltaTimeStamp - slvDeltaTimeStamp) >>> 1 //(mstDeltaTimeStamp - slvDeltaTimeStamp) >> 1
|
||
|
||
addr64_op1 := mstDeltaTimeStamp //组合逻辑
|
||
addr64_op2 := subOp2(slvDeltaTimeStamp) //组合逻辑
|
||
addrConflict(2) := true.B //组合逻辑
|
||
deltaMstSlvDeltaTimeStamp := Cat(addr64_res(63),addr64_res(63,1)) //时序逻辑
|
||
|
||
} .elsewhen( RegNext(RegNext(isSync)) & ~RegNext(isSync) ){
|
||
// deltaFinal := mstSlvDeltaTimeStamp + deltaMstSlvDeltaTimeStamp
|
||
addr64_op1 := mstSlvDeltaTimeStamp //组合逻辑
|
||
addr64_op2 := deltaMstSlvDeltaTimeStamp //组合逻辑
|
||
addrConflict(3) := true.B //组合逻辑
|
||
deltaFinal := addr64_res //时序逻辑
|
||
}
|
||
|
||
|
||
}
|
||
|
||
trait SlaveParserProbe{ this: SlaveParserBase =>
|
||
|
||
val probeRecCnt = RegInit(0.U(9.W))
|
||
val isWatchDogOverflow = probeRecCnt.andR
|
||
|
||
when( downRecParser.io.frameReq.fire & downRecParser.io.frameReq.bits.frameStyle === FRAME_STYLE_PROBE ){ //下行来了一个嗅探包
|
||
isReadyToProbe := true.B
|
||
when( downSendGen.io.stateCurr =/= STATE_IDLE ){
|
||
printf("Error! downSendGen is busy while a Probe-Frame arrival!\n")
|
||
}
|
||
} .elsewhen( upRecParser.io.frameReq.fire & upRecParser.io.frameReq.bits.frameStyle === FRAME_STYLE_PROBE ){ //上行来了一个嗅探包
|
||
isReadyToProbe := false.B
|
||
} .elsewhen( isWatchDogOverflow ){
|
||
isReadyToProbe := false.B
|
||
}
|
||
|
||
when( downRecParser.io.frameReq.fire & downRecParser.io.frameReq.bits.frameStyle === FRAME_STYLE_PROBE ){ //下行来了一个嗅探包
|
||
isAckProbe := true.B
|
||
} .elsewhen( upSendGen.io.frameReq.fire & upSendGen.io.frameReq.bits.frameStyle === FRAME_STYLE_PROBE ){ //上行发送回复嗅探包
|
||
isAckProbe := false.B
|
||
}
|
||
|
||
when( upRecParser.io.frameReq.fire & upRecParser.io.frameReq.bits.frameStyle === FRAME_STYLE_PROBE ){ //上行来了一个嗅探包
|
||
isLastDevice := false.B
|
||
} .elsewhen( isWatchDogOverflow ){
|
||
isLastDevice := true.B
|
||
}
|
||
|
||
|
||
when( upRecParser.io.frameReq.fire & upRecParser.io.frameReq.bits.frameStyle === FRAME_STYLE_PROBE ){ //上行来了一个嗅探包
|
||
probeRecCnt := 0.U
|
||
} .elsewhen( isWatchDogOverflow ){
|
||
probeRecCnt := 0.U
|
||
} .elsewhen( isReadyToProbe ){
|
||
probeRecCnt := probeRecCnt + 1.U
|
||
}
|
||
|
||
|
||
when( upRecParser.io.frameReq.fire & upRecParser.io.frameReq.bits.frameStyle === FRAME_STYLE_PROBE ){ //上行来了一个嗅探包
|
||
indexOfRightDev := upRecParser.io.frameReq.bits.frameInfo
|
||
when( upRecParser.io.frameReq.bits.frameInfo =/= localDevIndex + 1.U ){ //索引不对
|
||
isDevOnRightModify := true.B
|
||
} .otherwise{
|
||
isDevOnRightModify := false.B
|
||
}
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
|
||
io.upOut <> Queue( upSendGen.io.send, 4, true, false )
|
||
io.downIn <> downRecParser.io.rec
|
||
|
||
io.downOut <> Queue( downSendGen.io.send, 4, true, false )
|
||
io.upIn <> upRecParser.io.rec
|
||
|
||
io.isLoop := isLastDevice & ~isReadyToProbe
|
||
|
||
}
|
||
|
||
class SlaveParser extends SlaveParserBase
|
||
with SlaveParserIndex
|
||
with SlaveParserRW
|
||
with SlaveParserSync
|
||
with SlaveParserProbe{
|
||
io.intHWTrig(0) := downRecParser.io.isError
|
||
io.intHWTrig(1) := upRecParser.io.isError
|
||
|
||
downRecParser.io.flush := RegNext(downRecParser.io.isError & io.intHWClr(0))
|
||
downSendGen.io.flush := RegNext(downRecParser.io.isError & io.intHWClr(0))
|
||
|
||
upRecParser.io.flush := RegNext(upRecParser.io.isError & io.intHWClr(1))
|
||
upSendGen.io.flush := RegNext(upRecParser.io.isError & io.intHWClr(1))
|
||
|
||
io.downRecStat := downRecParser.io.stat
|
||
io.upRecStat := upRecParser.io.stat
|
||
}
|
||
|
||
|
||
|
||
|