看下Stage中关于terminal的作用

看完了前面的系列，对于Stageable、StageableKey是如何起作用的应该有一定的了解。今天再来看下Stage中关于terminal的作用

》terminal

在Stage中，有关terminal的定义牵涉到两个terminal函数和一个LinkedHashSet:

def terminal(key : StageableKey) : StageableKey = {
internals.stageableTerminal += key
key
}
def terminal[T <: Data](key : Stageable[T], key2 : Any) : StageableKey = {
????terminal(StageableKey(key.asInstanceOf[Stageable[Data]], key2))
??}
val stageableTerminal = mutable.LinkedHashSet[StageableKey]()

可以看到，对一个stageable、stageableKey调用terminal，其会将数据压到stageableTerminal中。

我们之前说过，pipeline的构建核心在Pipeline中的build函数上。那么来看下在pipeline的build函数中stageableTerminal都起了什么作用。

stageableTerminal在build函数中出现了两次。第一次是pipeline的payload填充：

//Fill payload holes in the pipeline
def propagateData(key : StageableKey, stage : Stage): Boolean ={
if(stage.internals.stageableTerminal.contains(key)) returnfalse
stage.stageableToData.get(key) match {
caseNone => {
val hits = ArrayBuffer[Stage]()
for(m <- stageMasters(stage)){
????????????if(propagateData(key, m)){
??????????????stage.apply(key) //Force creation
??????????????hits += m
????????????}
??????????}
??????????hits.size match {
????????????case?0?=> false
case1=> true
case2=> PendingError(s"$key at $stage has multiple drivers : ${hits.mkString(",")}"); false
}
}
caseSome(x) => true
}
}

我们前面提过，propagatedData用于向stage填充其前级有，后级stage中也有，但本级没有的stageable/stageableKey至stageableToData，可以看到，这里的处理一旦发现stageableKey在当前stage的stageableTerminal中包含，那么其将会不再向前级搜索，也就意味着这个信号的传递在当前Stage中止。

另一处出现的地方则是Interconnect stages:

for(c<- connections){
??????val stageables = (c.m.stageableToData.keys).filter(key => c.s.stageableToData.contains(key) && !c.m.stageableTerminal.contains(key))
var m= ConnectionPoint(c.m.output.valid, c.m.output.ready, stageables.map(c.m.outputOf(_)).toList)
for((l, id) <- c.logics.zipWithIndex){

????????val s = if(l?== c.logics.last)
??????????ConnectionPoint(c.s.input.valid, c.s.input.ready, stageables.map(c.s.stageableToData(_)).toList)
????????else?{
??????????ConnectionPoint(Bool(), (m.ready != null) generate Bool(), stageables.map(_.stageable.craft()).toList)
????????}
????????val area = l.on(m, s, clFlush(l), clFlushNext(l), clFlushNextHit(l), clThrowOne(l), clThrowOneHit(l))
????????if(c.logics.size != 1)
??????????area.setCompositeName(c, s"level_$id", true)
????????else
??????????area.setCompositeName(c, true)
????????m?= s
??????}

????}

可以看到，这里在选择master stage要传递到slave stage中的stageables时，是将stageableTerminal中的信号给过滤掉了，也就意味着在stageableTerminal对应的信号将不会进行Connection连接。也就意味着在进行Stage之间的连接时，会将相邻两级的stageableToData中共有的信号进行连接，如果该信号也同时被注册到了stageableTerminal中，那么该信号将会排除在外，即terminal提供了一个能够终止stageable在Stage之间传播连接的途径。

》Demo

来看下下面的例子：

caseclassTest2() extendsComponent{
val io=newBundle{
val data_in=slave(Flow(Vec(UInt(8bits),4)))
val data_out=master(Flow(UInt(8bits)))
}
noIoPrefix()
val A,B,C=Stageable(UInt(8bits))
val pip=newPipeline{
val staeg0=newStage{
this.internals.input.valid:=io.data_in.valid
A:=io.data_in.payload(0)+io.data_in.payload(1)
B:=io.data_in.payload(2)+io.data_in.payload(3)
C:=io.data_in.payload(1)+io.data_in.payload(3)
this.terminal(C,null)
}
val stage1=newStage(Connection.M2S()){
C:=A+B
io.data_out.payload:=C
io.data_out.valid:=this.internals.output.valid
}
}
}

我们在stage0中为C注册了termianl，此时对于stage0中的stageableToData包含三个元素A，B，C，而stageableTerminal中则包含了C。而对于Stage1，其stageableToData包含了A,B,C三个元素，那么也就意味着stage0中的C将不会传递到stage1中，仅有A、B两个元素会在stage之间连接。所有stage1中的C将会由stage1中的A+B驱动，而不是stage0中的C驱动。

审核编辑：刘清