@@ -34,6 +34,7 @@ def elaborate(self, platform):
3434 m .d .comb += [
3535 self .source .data .eq (self .stream .payload ),
3636 self .source .valid .eq (self .stream .valid ),
37+ self .source .first .eq (self .stream .first ),
3738 self .source .last .eq (self .stream .last ),
3839 self .stream .ready .eq (self .source .ready ),
3940 ]
@@ -62,6 +63,7 @@ def elaborate(self, platform):
6263 m .d .comb += [
6364 cdc_out .sink .data .eq (self .stream .payload ),
6465 cdc_out .sink .valid .eq (self .stream .valid ),
66+ cdc_out .sink .first .eq (self .stream .first ),
6567 cdc_out .sink .last .eq (self .stream .last ),
6668 self .stream .ready .eq (cdc_out .sink .ready ),
6769 ]
@@ -82,6 +84,7 @@ def elaborate(self, platform):
8284 m .d .comb += [
8385 self .stream .payload .eq (self .sink .data ),
8486 self .stream .valid .eq (self .sink .valid ),
87+ self .stream .first .eq (self .sink .first ),
8588 self .stream .last .eq (self .sink .last ),
8689 self .sink .ready .eq (self .stream .ready ),
8790 ]
@@ -110,6 +113,7 @@ def elaborate(self, platform):
110113 m .d .comb += [
111114 self .stream .payload .eq (cdc_in .source .data ),
112115 self .stream .valid .eq (cdc_in .source .valid ),
116+ self .stream .first .eq (cdc_in .source .first ),
113117 self .stream .last .eq (cdc_in .source .last ),
114118 cdc_in .source .ready .eq (self .stream .ready ),
115119 ]
0 commit comments