12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358 |
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.IO;
- using System.Text;
- using System.Threading.Tasks;
- using System.Diagnostics;
- using System.Threading;
- using Uestc.Auto6.Dso.ComModel;
- using Uestc.Auto6.Dso.Hardware.Calibration.Data.Base;
- using Uestc.Auto6.Dso.MathExt;
- using System.Diagnostics.CodeAnalysis;
- namespace Uestc.Auto6.Dso.Hardware.Driver
- {
- /// <summary>
- /// 模拟通道波形采集
- /// </summary>
- public abstract class AbstractAcquirer_AnalogChannel : AbstractAcquirer
- {
- internal Abstract_LongStorage? LongStorage
- {
- get;
- init;
- }
- /// <summary>
- /// 正在采集的采集参数
- /// </summary>
- internal readonly AcquireAttribute AcquingParameters = new AcquireAttribute();
- /// <summary>
- /// 已经采集的数据的采集参数。在读回数据后赋值
- /// </summary>
- internal readonly AcquireAttribute AcquedParameters = new AcquireAttribute();
- Dictionary<DbiCoefficientsTablesType, List<DBI_CoefTableSendItem>> EmptyAcqBdCoefTablesSendDefine = new Dictionary<DbiCoefficientsTablesType, List<DBI_CoefTableSendItem>>();
- /// <summary>
- /// 获取采集板各种系数表的发送配置。只有DBI项目存在!!!
- /// </summary>
- internal virtual Dictionary<DbiCoefficientsTablesType, List<DBI_CoefTableSendItem>> AcqBdCoefTablesSendDefine
- {
- get => EmptyAcqBdCoefTablesSendDefine;
- }
- internal virtual Dictionary<string, AmpCoefficientFileInfo>? ChannelPerScaleAmpFreqCoefficientsDefine
- {
- get => ourChannelPerScaleAmpFreqCoefficientsDefine;
- }
- private readonly Dictionary<string, AmpCoefficientFileInfo>? ourChannelPerScaleAmpFreqCoefficientsDefine = new()
- {
- ["C1_1"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C1_1mV.txt" },
- ["C1_2"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C1_2mV.txt" },
- ["C1_5"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C1_5mV.txt" },
- ["C1_10"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C1_10mV.txt" },
- ["C1_20"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C1_20mV.txt" },
- ["C1_50"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C1_50mV.txt" },
- ["C1_100"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C1_100mV.txt" },
- ["C1_200"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C1_200mV.txt" },
- ["C1_500"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C1_500mV.txt" },
- ["C1_1000"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C1_1000mV.txt" },
- ["C2_1"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C2_1mV.txt" },
- ["C2_2"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C2_2mV.txt" },
- ["C2_5"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C2_5mV.txt" },
- ["C2_10"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C2_10mV.txt" },
- ["C2_20"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C2_20mV.txt" },
- ["C2_50"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C2_50mV.txt" },
- ["C2_100"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C2_100mV.txt" },
- ["C2_200"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C2_200mV.txt" },
- ["C2_500"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C2_500mV.txt" },
- ["C2_1000"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C2_1000mV.txt" },
- ["C3_1"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C3_1mV.txt" },
- ["C3_2"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C3_2mV.txt" },
- ["C3_5"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C3_5mV.txt" },
- ["C3_10"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C3_10mV.txt" },
- ["C3_20"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C3_20mV.txt" },
- ["C3_50"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C3_50mV.txt" },
- ["C3_100"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C3_100mV.txt" },
- ["C3_200"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C3_200mV.txt" },
- ["C3_500"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C3_500mV.txt" },
- ["C3_1000"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C3_1000mV.txt" },
- ["C4_1"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C4_1mV.txt" },
- ["C4_2"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C4_2mV.txt" },
- ["C4_5"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C4_5mV.txt" },
- ["C4_10"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C4_10mV.txt" },
- ["C4_20"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C4_20mV.txt" },
- ["C4_50"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C4_50mV.txt" },
- ["C4_100"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C4_100mV.txt" },
- ["C4_200"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C4_200mV.txt" },
- ["C4_500"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C4_500mV.txt" },
- ["C4_1000"] = new AmpCoefficientFileInfo() { FileName = $@".\AfcCaliDataFiles\Afc_C4_1000mV.txt" },
- };
- internal virtual List<List<ChannelBdAdcInputDefine>>? FirstInitChannelBdAdcInputDefines => null;
- #region 触发深度等
- internal virtual void DiscardDotAtTriggerTypeIsSerialMode()
- {
- if ((!Hd.CurrDebugVarints.bEnable_DigitTrigger) || Hd.CurrDebugVarints.bEnable_AdcDataDebugMode)
- return;
- if (Hd.CurrHdMessage!.Trigger!.TrigType != TriggerType.Serial)
- return;
- UInt32 trigSource = Hd.currProduct.Ctrl_Trigger!.CurrentTrigSource();
- if (trigSource >= ChannelIdExt.AnaChnlNum)
- return;
- ChannelBdAdcInputDefine channelBdAdcInputDefine = GetChannelAcqBdAdcInputCorresponding((int)trigSource) ?? new ChannelBdAdcInputDefine() { BdNo = AcqBdNo.B3 };
- UInt32 skipcount = (UInt32)(Hd.currProduct!.AcqBd!.ReadReg(AcqBdReg.R.Decoder_TimeDelaycntlock, channelBdAdcInputDefine.BdNo));
- UInt32 skipcount_bound = (UInt32)(Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.HardwareExtractNum) - 1;
- if (skipcount < skipcount_bound)
- {
- skipcount = skipcount +(UInt32) (Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.HardwareExtractNum);
- }
- SerialProtocolType protocolType = Hd.CurrHdMessage!.Trigger!.TrigDecoder!.ProtocolType;
- if ((Hd.CurrHdMessage!.Trigger!.TrigDecoder.ProtocolOptions is HdMessage.ProtocolUSBOptions usb && usb.SignalRate == ProtocolUSB.SignalRate.HighRate ) || protocolType == SerialProtocolType.PCIe || protocolType == SerialProtocolType.SATA || Hd.CurrHdMessage!.Timebase!.TmbScaleIndex <= (int)AnaChnlTimebaseIndex.Lv100n)
- skipcount = 0;
- long mergeRoadCount = 40;
- if (Hd.currProduct.ProductType == ProductType.B21_DBI16G || Hd.currProduct.ProductType == ProductType.B21_DBI20G || Hd.currProduct.ProductType == ProductType.B21_MD8G || Hd.currProduct.ProductType == ProductType.B21_HB8G)
- mergeRoadCount = 80;
- skipcount = (UInt32)(mergeRoadCount * skipcount / ((long)(Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.HardwareExtractNum ?? 1U)));
- if (skipcount > 0 && (skipcount<500)) //500????????
- {
- for (int displayChIndex = 0; displayChIndex < ChannelIdExt.AnaChnlNum; displayChIndex++)
- AcqedDataPool.AnalogChData.AllChannelData[displayChIndex].RemoveRange(0, (int)skipcount);
- }
- }
- internal virtual UInt32 DefaultTrigSensitivity
- {
- get => 100;
- }
- internal virtual Int32 Trig_LS_TrigOffset
- {
- get
- {
- return 8 * 15;
- }
- }
- internal virtual Int32 Trig_LS_DiscardNumMax
- {
- get
- {
- return 4096;
- }
- }
- internal virtual ChannelBdAdcInputDefine? GetChannelAcqBdAdcInputCorresponding(int channelIndex) => null;
- internal const int Trig_XDepthFixedAddDots = 400;
- internal virtual TrigSourceParams GetTrigSourceParams(UInt32 trigChannelFromSoft)
- {
- UInt32 AcqBd_TrigCtrl_1st_SourceWhichAdcStartWith0 = 0;
- UInt32 ProcBd_TrigCtrl_1st_SourceWhichAcqBdStartWith0 = 0;
- UInt32 ProcBd_TrigCtrl_2nd_SourceWhichChannelStartWith0 = 0;
- //1.判断触发信号来自于采集板哪个ADC,所有采集板配置相同,所有被选中通道的触发信号都送到处理板做二次选择
- //相当于对应一个采集板上的哪个ADC。以触发的物理通道接入的那个ADC为准。ADC1:发0,ADC2:发1,两片:发0
- if (trigChannelFromSoft < ChannelIdExt.AnaChnlNum)
- {
- if (Hd.currProduct!.Acquirer_AnalogChannel!.ChannelBdAdcInputDefines != null)
- AcqBd_TrigCtrl_1st_SourceWhichAdcStartWith0 = (UInt32)Hd.currProduct!.Acquirer_AnalogChannel!.ChannelBdAdcInputDefines![0][(int)trigChannelFromSoft][0].AdcIndex;
- }
- //2.一级触发源:表示来自于那个采集板的信号。用0,1,2,表示。
- if (trigChannelFromSoft < ChannelIdExt.AnaChnlNum)
- {
- uint acqBdIndex = 0;
- if (Hd.currProduct!.Acquirer_AnalogChannel!.ChannelBdAdcInputDefines != null)
- {
- AcqBdNo acqBd = Hd.currProduct!.Acquirer_AnalogChannel!.ChannelBdAdcInputDefines![0][(int)trigChannelFromSoft][0].BdNo;
- for (AcqBdNo acqBdNo = AcqBdNo.B1; acqBdNo <= AcqBdNo.B8; acqBdNo++)
- {
- if (Hd.currProduct?.AcqBd?.ExistsDefines?[(int)acqBdNo] ?? false)
- {
- if (acqBd == acqBdNo)
- break;
- acqBdIndex++;
- }
- }
- }
- ProcBd_TrigCtrl_1st_SourceWhichAcqBdStartWith0 = acqBdIndex;
- }
- //二级触发,表示对应的物理通道,与DMA中的数据路数一致
- if (trigChannelFromSoft < ChannelIdExt.AnaChnlNum)
- ProcBd_TrigCtrl_2nd_SourceWhichChannelStartWith0 = trigChannelFromSoft;
- else
- ProcBd_TrigCtrl_2nd_SourceWhichChannelStartWith0 = (uint)(trigChannelFromSoft % ChannelIdExt.AnaChnlNum);//乱整
- return new TrigSourceParams()
- {
- AcqBd_TrigCtrl_1st_SourceWhichAdcStartWith0 = AcqBd_TrigCtrl_1st_SourceWhichAdcStartWith0,
- ProcBd_TrigCtrl_1st_SourceWhichAcqBdStartWith0 = ProcBd_TrigCtrl_1st_SourceWhichAcqBdStartWith0,
- ProcBd_TrigCtrl_2nd_SourceWhichChannelStartWith0 = ProcBd_TrigCtrl_2nd_SourceWhichChannelStartWith0
- };
- }
- private Boolean IsInterpolation()
- {
- return Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.InterpolationNum > 1 ? true : false;
- }
- internal virtual Int64 GetTrigXDepth()
- {
- double tmbScale = Hd.CurrHdMessage?.Timebase?.TmbScale ?? 1.0;
- double tmbPosition = Hd.CurrHdMessage?.Timebase?.TmbPosition ?? 0;
- double perDataByfs_AtStorage = (Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.PerDataByfs_AtStorage ?? 50_000_000); //20G sample,50_000_000
- Int64 depth = (Int64)((tmbScale * Constants.VIS_XDIVS_NUM / 2 - tmbPosition) * 1_000_000_000 / perDataByfs_AtStorage);
- if (!Hd.AnalogChannel?.IsNeedPostProcessByMatlab ?? false)
- return depth;
- else
- return depth + Trig_XDepthFixedAddDots;
- }
- //point 1
- /// <summary>
- /// 应该这样计算
- /// </summary>
- /// <param name="xdepth"></param>
- /// <param name="trigSource"></param>
- /// <returns></returns>
- internal virtual UInt32 GetAcqBdTrigDiscardColumnNums(Int64 xdepth, UInt32 trigSource)
- {
- if (xdepth < 0)
- return 0;
- double mergeRoadCount = 40d;
- UInt64 discard_tmp = (UInt64)(xdepth % mergeRoadCount); ;
- if (IsInterpolation())
- {
- AnaChnlTimebaseIndex TmbScaleIndex = (AnaChnlTimebaseIndex)(Hd.CurrHdMessage?.Timebase?.TmbScaleIndex ?? (int)AnaChnlTimebaseIndex.Lv10n);//20220218
- if (discard_tmp == 0)
- return (uint)(discard_tmp + mergeRoadCount * (ulong)Hd.currProduct.Ctrl_Trigger!.InterpolationLevelDiscardNumTable![TmbScaleIndex] - 2 + 20);
- else
- return (uint)((mergeRoadCount - discard_tmp) * (ulong)Hd.currProduct.Ctrl_Trigger!.InterpolationLevelDiscardNumTable![TmbScaleIndex] + mergeRoadCount - 2 + 20);
- }
- else
- {
- if (discard_tmp == 0)
- return (uint)(discard_tmp - 2 + 20);
- else
- return (uint)(mergeRoadCount - discard_tmp - 2 + 20);
- }
- }
- //point 2
- internal virtual UInt32 ourGetSigProDiscardNum() //计算总的数字信号处理丢点数
- {
- int LengthOfInterpFilter_1st = Hd.currProduct!.HardwareConfig!.LocalCoefficientsTableMeanings[Calibration.Data.Base.CoefficientsTableType.Coefficients1].LengthOfPartA; //一级插值滤波器阶数
- int LengthOfInterpFilter_2nd = Hd.currProduct!.HardwareConfig!.LocalCoefficientsTableMeanings[Calibration.Data.Base.CoefficientsTableType.Coefficients1].LengthOfPartB; //二级插值滤波器阶数
- //int LengthOfTiadc = Hd.currProduct!.HardwareConfig!.LocalCoefficientsTableMeanings[Calibration.Data.Base.CoefficientsTableType.Coefficients2].Length; //TIADC滤波器阶数
- UInt32 TiADCDiscard = 256; //进入TIADC模块会丢掉256个点
- int LengthOfAfc = 0;
- if (Hd.currProduct!.HardwareConfig!.LocalCoefficientsTableMeanings.ContainsKey(Calibration.Data.Base.CoefficientsTableType.Coefficients3))
- LengthOfAfc = Hd.currProduct!.HardwareConfig!.LocalCoefficientsTableMeanings[Calibration.Data.Base.CoefficientsTableType.Coefficients3].Length; //AFC滤波器阶数
- int LengthOfPfc = 0;
- if (Hd.currProduct!.HardwareConfig!.LocalCoefficientsTableMeanings.ContainsKey(Calibration.Data.Base.CoefficientsTableType.Coefficients4))
- LengthOfPfc = Hd.currProduct!.HardwareConfig!.LocalCoefficientsTableMeanings[Calibration.Data.Base.CoefficientsTableType.Coefficients4].Length; //PFC滤波器阶数
- UInt32 InterpDiscard = ourGetInterpDiscardNum(LengthOfInterpFilter_1st, LengthOfInterpFilter_2nd);
- //UInt32 Discard = (uint)(InterpDiscard + LengthOfTiadc / 2 + LengthOfAfc / 2 + LengthOfPfc / 2);
- UInt32 Discard = (uint)(InterpDiscard + TiADCDiscard + LengthOfAfc / 2 + 2 * LengthOfPfc / 5);
- return Discard;
- }
- internal virtual UInt32 ourGetInterpDiscardNum(int LengthOfInterpFilter_1st, int LengthOfInterpFilter_2nd) //计算总的插值滤波器丢点数
- {
- AnaChnlTimebaseIndex currAnaChnlTimebaseIndex = (AnaChnlTimebaseIndex)(Hd.CurrHdMessage?.Timebase?.TmbScaleIndex ?? (int)AnaChnlTimebaseIndex.Lv100u);
- UInt32 ExtractNum = (UInt32)(Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.HardwareExtractNum ?? 1U);
- UInt32 InterpNum = (UInt32)(Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.InterpolationNum ?? 1U);
- UInt32 Max_1stInterpRatio = 10; //一级最大插值倍率
- UInt32 DiscardBforeInterp = 2; //进入插值模块之前丢掉两个点
- UInt32 InterpDiscard = 0;
- if (InterpNum > Max_1stInterpRatio)
- InterpDiscard = (UInt32)(DiscardBforeInterp * InterpNum + LengthOfInterpFilter_1st / ExtractNum / 2);
- else
- InterpDiscard = (UInt32)((DiscardBforeInterp * InterpNum + LengthOfInterpFilter_1st / ExtractNum / 2) * InterpNum + LengthOfInterpFilter_2nd / ExtractNum / 2);
- return InterpDiscard;
- }
- internal virtual UInt64 GetProcBd_LA_TrigCtrl_1st_PreDepth(Int64 xdepth, uint trigSource)
- {
- return GetProcBdTrigCtrl_1st_PreDepth(xdepth, trigSource);
- }
- internal virtual UInt64 GetProcBdTrigCtrl_1st_PreDepth(Int64 xdepth, uint trigSource)
- {
- //计算触发信号板间通信偏移量
- uint trigChannel = (uint)trigSource;
- UInt32 SigProDiscardNum = ourGetSigProDiscardNum();
- AnaChnlTimebaseIndex curTimeBase = (AnaChnlTimebaseIndex)(Hd.CurrHdMessage?.Timebase?.TmbScaleIndex ?? (Int32)AnaChnlTimebaseIndex.Lv5n);
- //if (!adjustnumTableNew.ContainsKey(curTimeBase))
- // throw new Exception("adjustnumTableNew not contain curTimeBase:" + curTimeBase.ToString());
- UInt32 adjust_num = 0;// adjustnumTableNew[curTimeBase];
- UInt32 xdpeth_fix;
- double mergeRoadCount;//并行路数
- // ulong hardwareExtractNum = Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.HardwareExtractNum ?? 1; 硬件抽取数
- if (Hd.CurrHdMessage!.Analog![trigSource].InputSource == AnaChnlIpnutSource.BNC)
- {
- mergeRoadCount = 40d;
- }
- else
- {
- mergeRoadCount = 80d;
- }
- bool condition = false;
- if (condition == true)
- {
- xdpeth_fix = (UInt32)xdepth + SigProDiscardNum + adjust_num;
- }
- else
- {
- xdpeth_fix = (UInt32)xdepth + adjust_num;
- }
- UInt32 PreDepth = (UInt32)Math.Floor(xdpeth_fix / mergeRoadCount) + (UInt32)SysAutoCalibration.Default.Trig_AcqProcBdLooptimBySysClockCount((int)trigChannel);
- return PreDepth;
- }
- //point 3
- internal virtual UInt64 GetProcBdTrigCtrl_1st_PosDepth(Int64 xdepth, UInt32 trigSource)
- {
- if (xdepth > 0)
- return 0;
- ulong hardwareExtractNum = Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.HardwareExtractNum ?? 1;
- double mergeRoadCount = 40d;
- UInt64 result = (UInt64)Math.Floor(-xdepth / mergeRoadCount) * hardwareExtractNum;
- return result;
- }
- //point 4
- internal virtual UInt32 GetProcBdTrigCtrl_2nd_PreDepth(Int64 xdepth, UInt32 trigSource)
- {
- UInt32 result = 0;
- if (xdepth > 0)
- result = (uint)(xdepth);
- return result;
- }
- //point 5
- internal virtual UInt32 GetProcBdTrigCtrl_2nd_SearchRange(Int64 xdepth, UInt32 trigSource)
- {
- UInt32 result = 0;
- if (xdepth < 0)
- result = 0;
- else if (IsInterpolation())
- result = (uint)(16 * 1024 - (1000 - xdepth) - 1000);
- else
- result = 5000;
- return result;
- }
- internal virtual (UInt32 Up, UInt32 Dn, UInt32 Edge) GetDigitTrigCompVolt()
- {
- UInt32 compVolt;
- int trigSource = (int)Hd.currProduct!.Ctrl_Trigger!.CurrentTrigSource();
- int trigSourceYPos = AbstractController_Trigger.AdcCenterValue;
- bool isPositive = true;
- if (trigSource < ChannelIdExt.AnaChnlNum)
- {
- HdMessage.AnalogOptions analogParameters = Hd.CurrHdMessage!.Analog![trigSource];
- trigSourceYPos = (int)(Constants.SAMPS_PER_YDIV * analogParameters.Position / analogParameters.Scale + AbstractController_Trigger.AdcCenterValue);
- }
- else
- return (0, 0, (UInt32)(((Hd.CurrHdMessage!.Trigger!.TrigType == TriggerType.Edge && ChannelIdExt.IsDigital((ChannelId)trigSource) ? 1 : 0) << 1) | ((Hd.CurrHdMessage!.Trigger!.Edge!.Slope == EdgeSlope.Rise ? 1 : 0))));//LA
- switch (Hd.CurrHdMessage?.Trigger?.TrigType)
- {
- case TriggerType.Edge:
- compVolt = (UInt32)((Hd.CurrHdMessage!.Trigger!.Edge!.PosIndex) / Constants.IDX_PER_YDIV * AbstractController_Trigger.PerYDivAdcSamples + trigSourceYPos);
- isPositive = Hd.CurrHdMessage!.Trigger!.Edge!.Slope == EdgeSlope.Rise;
- break;
- case TriggerType.PulseWidth:
- compVolt = (UInt32)((Hd.CurrHdMessage!.Trigger!.Pulse!.PosIndex) / Constants.IDX_PER_YDIV * AbstractController_Trigger.PerYDivAdcSamples + trigSourceYPos);//正脉宽以下降沿为判断基准,反之亦然
- isPositive = Hd.CurrHdMessage!.Trigger!.Pulse!.Polarity == PulsePolarity.Positive;
- break;
- case TriggerType.Runt:
- compVolt = (UInt32)((Hd.CurrHdMessage!.Trigger!.Runt!.LowerPosIndex) / Constants.IDX_PER_YDIV * AbstractController_Trigger.PerYDivAdcSamples + trigSourceYPos);//同上
- isPositive = Hd.CurrHdMessage!.Trigger!.Runt!.Polarity == PulsePolarity.Positive;
- break;
- case TriggerType.Transition:
- compVolt = (UInt32)((Hd.CurrHdMessage!.Trigger!.Transition!.LowerPosIndex) / Constants.IDX_PER_YDIV * AbstractController_Trigger.PerYDivAdcSamples + trigSourceYPos);
- isPositive = Hd.CurrHdMessage!.Trigger!.Transition!.Slope == EdgeSlope.Rise;
- break;
- case TriggerType.TimeOut:
- compVolt = (UInt32)((Hd.CurrHdMessage!.Trigger!.TimeOut!.PosIndex) / Constants.IDX_PER_YDIV * AbstractController_Trigger.PerYDivAdcSamples + trigSourceYPos);
- isPositive = Hd.CurrHdMessage!.Trigger!.TimeOut!.Polarity == LevelPolarity.Positive;
- break;
- case TriggerType.Glitch:
- compVolt = (UInt32)((Hd.CurrHdMessage!.Trigger!.Glitch!.PosIndex) / Constants.IDX_PER_YDIV * AbstractController_Trigger.PerYDivAdcSamples + trigSourceYPos);
- isPositive = Hd.CurrHdMessage!.Trigger!.Glitch!.Polarity == PulsePolarity.Positive;
- break;
- case TriggerType.SetupHold:
- compVolt = (UInt32)((Hd.CurrHdMessage!.Trigger!.SetupHold!.ClkPosition.Value) * 10 / Constants.IDX_PER_YDIV * AbstractController_Trigger.PerYDivAdcSamples + trigSourceYPos);
- break;
- case TriggerType.Pattern:
- //10是换算
- compVolt = (UInt32)((Hd.CurrHdMessage?.Trigger?.Pattern.Positions[trigSource].Value) * 10 / Constants.IDX_PER_YDIV * AbstractController_Trigger.PerYDivAdcSamples + trigSourceYPos);
- isPositive = Hd.CurrHdMessage!.Trigger!.Pattern!.Positions[trigSource].Condition == PatLevelCondition.GreaterThan;
- break;
- case TriggerType.State:
- compVolt = (UInt32)((Hd.CurrHdMessage?.Trigger?.State?.Positions[trigSource].Value) * 10 / Constants.IDX_PER_YDIV * AbstractController_Trigger.PerYDivAdcSamples + trigSourceYPos);
- break;
- case TriggerType.Interval:
- compVolt = (UInt32)((Hd.CurrHdMessage!.Trigger!.Interval!.PosIndex) / Constants.IDX_PER_YDIV * AbstractController_Trigger.PerYDivAdcSamples + AbstractController_Trigger.AdcCenterValue);
- isPositive = Hd.CurrHdMessage!.Trigger!.Interval!.Polarity == PulsePolarity.Positive;
- break;
- case TriggerType.Window:
- compVolt = (UInt32)((Hd.CurrHdMessage!.Trigger!.Window!.LowerPosIndex) / Constants.IDX_PER_YDIV * AbstractController_Trigger.PerYDivAdcSamples + AbstractController_Trigger.AdcCenterValue);
- isPositive = (Hd.CurrHdMessage?.Trigger?.Window?.Range ?? WindowRange.Inside) == WindowRange.Outside;
- break;
- default:
- compVolt = (UInt32)((Hd.CurrHdMessage!.Trigger!.Edge!.PosIndex) / Constants.IDX_PER_YDIV * AbstractController_Trigger.PerYDivAdcSamples + trigSourceYPos);
- isPositive = Hd.CurrHdMessage!.Trigger!.Edge!.Slope == EdgeSlope.Rise;
- break;
- }
- uint currDefaultTrigSensitivity = DefaultTrigSensitivity;
- if ((TriggerCoupling)(Hd.CurrHdMessage?.Trigger?.Edge?.Coupling ?? TriggerCoupling.DC) == TriggerCoupling.NR)
- currDefaultTrigSensitivity /= 2;
- switch (Hd.CurrHdMessage?.Trigger?.TrigType)
- {
- case TriggerType.PulseWidth:
- case TriggerType.Runt:
- case TriggerType.TimeOut:
- case TriggerType.Glitch:
- case TriggerType.Pattern:
- case TriggerType.Window:
- if (isPositive)
- {
- if ((compVolt - DefaultTrigSensitivity) < 0)
- compVolt = DefaultTrigSensitivity;
- return (Up: compVolt + DefaultTrigSensitivity, Dn: compVolt, 1);
- }
- else
- {
- if ((compVolt + DefaultTrigSensitivity) > 4095)
- compVolt = 4095 - DefaultTrigSensitivity;
- return (Up: compVolt, Dn: compVolt - DefaultTrigSensitivity, 0);
- }
- break;
- default:
- if (isPositive)
- {
- if ((compVolt - DefaultTrigSensitivity) < 0)
- compVolt = DefaultTrigSensitivity;
- return (Up: compVolt, Dn: compVolt - DefaultTrigSensitivity, 1);
- }
- else
- {
- if ((compVolt + DefaultTrigSensitivity) > 4095)
- compVolt = 4095 - DefaultTrigSensitivity;
- return (Up: compVolt + DefaultTrigSensitivity, Dn: compVolt, 0);
- }
- break;
- }
- }
- internal virtual void Trig_SpecailConfig(Int64 xdepth, UInt32 trigSource)
- {
- if (Hd.CurrHdMessage?.Timebase?.TmbScaleIndex! > (int)AnaChnlTimebaseIndex.Lv5n)
- {
- HdIO.WriteReg(ProcBdReg.W.TrigCtrl_2nd_SerialTrigEnable, Hd.CurrDebugVarints.bEnable_DigitTrigger ? 9U : 0);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.TrigCtrl_Location_TrigDiscardColumnEn, Hd.CurrDebugVarints.bEnable_DigitTrigger ? 1U : 0U);
- }
- else
- {
- HdIO.WriteReg(ProcBdReg.W.TrigCtrl_2nd_SerialTrigEnable, Hd.CurrDebugVarints.bEnable_DigitTrigger ? 9U : 0);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.TrigCtrl_Location_TrigDiscardColumnEn, Hd.CurrDebugVarints.bEnable_DigitTrigger ? 1U : 0U);
- }
- }
- #endregion
- protected virtual UInt64 MaxPerDataByps
- {
- get;
- set;
- } = 50;//20G 采样
- protected const long uS2fs = 1_000_000_000;
- internal record ExtractNumInterpolationNumPair(UInt64 ExtractNum, UInt32 InterpolationNum, UInt32 HardwareFifoLen, UInt32 SoftwareFifoLen);
- #region LA 抽取插值表
- internal virtual Dictionary<AnaChnlTimebaseIndex, ExtractNumInterpolationNumPair> LA_ExtractInterpolationNumTable => standardLA_ExtractInterpolationNumTable;
- private static Dictionary<AnaChnlTimebaseIndex, ExtractNumInterpolationNumPair> standardLA_ExtractInterpolationNumTable = new()
- {
- //小于80,必须能够整除,大于80,10的倍数就可以
- // ExtractNum,InterpolationNum,HardwareFifoLen,SoftwareFifoLen
- [AnaChnlTimebaseIndex.Lv20p] = new ExtractNumInterpolationNumPair(1, 400, 800, 800),
- [AnaChnlTimebaseIndex.Lv50p] = new ExtractNumInterpolationNumPair(1, 200, 1000, 1000),
- [AnaChnlTimebaseIndex.Lv100p] = new ExtractNumInterpolationNumPair(1, 100, 1000, 1000),
- [AnaChnlTimebaseIndex.Lv200p] = new ExtractNumInterpolationNumPair(1, 40, 800, 800),
- [AnaChnlTimebaseIndex.Lv500p] = new ExtractNumInterpolationNumPair(1, 20, 1000, 1000),
- [AnaChnlTimebaseIndex.Lv1n] = new ExtractNumInterpolationNumPair(1, 10, 1000, 1000),
- [AnaChnlTimebaseIndex.Lv2n] = new ExtractNumInterpolationNumPair(1, 5, 1000, 1000), //50/I * L=scale *10
- [AnaChnlTimebaseIndex.Lv5n] = new ExtractNumInterpolationNumPair(1, 2, 1000, 1000),//5ns时10G才开始需要插值,20G这里刚好不需要插值
- [AnaChnlTimebaseIndex.Lv10n] = new ExtractNumInterpolationNumPair(1, 1, 1000, 1000),
- [AnaChnlTimebaseIndex.Lv20n] = new ExtractNumInterpolationNumPair(1, 1, 2000, 2000),
- [AnaChnlTimebaseIndex.Lv50n] = new ExtractNumInterpolationNumPair(1, 1, 5000, 5000),//以上采用20G,也可采用10G
- [AnaChnlTimebaseIndex.Lv100n] = new ExtractNumInterpolationNumPair(1, 1, 10_000, 10_000),//以下必须采用10G
- [AnaChnlTimebaseIndex.Lv200n] = new ExtractNumInterpolationNumPair(2, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv500n] = new ExtractNumInterpolationNumPair(5, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv1u] = new ExtractNumInterpolationNumPair(10, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv2u] = new ExtractNumInterpolationNumPair(20, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv5u] = new ExtractNumInterpolationNumPair(50, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv10u] = new ExtractNumInterpolationNumPair(100, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv20u] = new ExtractNumInterpolationNumPair(200, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv50u] = new ExtractNumInterpolationNumPair(500, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv100u] = new ExtractNumInterpolationNumPair(1_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv200u] = new ExtractNumInterpolationNumPair(2_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv500u] = new ExtractNumInterpolationNumPair(5_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv1m] = new ExtractNumInterpolationNumPair(10_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv2m] = new ExtractNumInterpolationNumPair(20_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv5m] = new ExtractNumInterpolationNumPair(50_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv10m] = new ExtractNumInterpolationNumPair(100_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv20m] = new ExtractNumInterpolationNumPair(200_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv50m] = new ExtractNumInterpolationNumPair(500_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv100m] = new ExtractNumInterpolationNumPair(1_000_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv200m] = new ExtractNumInterpolationNumPair(2_000_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv500m] = new ExtractNumInterpolationNumPair(5_000_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv1] = new ExtractNumInterpolationNumPair(10_000_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv2] = new ExtractNumInterpolationNumPair(20_000_000, 1, 10_000, 10_000),
- [AnaChnlTimebaseIndex.Lv5] = new ExtractNumInterpolationNumPair(50_000_000, 1, 10_000, 10_000),
- };
- #endregion
- internal UInt32 DDR_TrigAddrTableStartAddr { get => 1000; }//与硬件协商
- public virtual int ReadTriggerStatus()
- {
- return 0;
- }
- internal override void Init()
- {
- InitPhyAnalogChAmplitudeTemperaturesCompensationCoefficient();
- LongStorage?.Init();
- InitAmpCoefficientFile();
- }
- internal virtual void InitAmpCoefficientFile()
- {
- if (ChannelPerScaleAmpFreqCoefficientsDefine == null)
- return;
- foreach(var v in ChannelPerScaleAmpFreqCoefficientsDefine)
- {
- var info = v.Value;
- int[]? dataArray = Misc.ReadCaliCoefDataFronmFile(info.FileName);
- if (dataArray == null)
- {
- info.CRCCode = 0; info.bOk = false;
- continue;
- }
- info.CRCCode = Misc.GenerateCRCCode(dataArray!);
- info.bOk = true;
- }
- }
- internal virtual HdCmd ResponseSpecialScpiCmd(string message)
- {
- return HdCmd.None;
- }
- protected virtual bool bOpenAverageModule
- {
- get
- {
- if (Hd.CurrDebugVarints.bEnable_ProcBd_Average)
- {
- if (AcquingParameters.HardwareExtractNum > 1)
- return false;
- if (Hd.CurrHdMessage!.Timebase!.AcqLength == AnaChnlStorageMode.Long)
- return false;
- if (Hd.CurrHdMessage!.Trigger!.Mode != TriggerMode.Auto)
- return false;
- if (Hd.CurrHdMessage!.Timebase!.AcqLength == AnaChnlStorageMode.Fast)
- return false;
- return true;
- }
- else
- return false;
- }
- }
- internal override void InitAcq()
- {
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_StorageMode, AcquingParameters.bIsLongStorageMode ? 1 : 0U);
- //Acquisition.SwitchDataPathMuxTo(DMAReadSourceMuxType.AnalogChanneData);
- HdIO.WriteReg(ProcBdReg.W.Average_Enable, bOpenAverageModule ? 1U : 0);
- if (!AcquingParameters.bIsLongStorageMode)
- {
- HdIO.WriteReg(PcieBdReg.W.DataPath_pcie_linkdemux_select, (UInt32)DMAReadSourceMuxType.AnalogChanneData);
- HdIO.WriteReg(ProcBdReg.W.DataPath_pro_linkdemux_select, (UInt32)DMAReadSourceMuxType.AnalogChanneData);
- HdIO.WriteReg(ProcBdReg.W.DataPath_pro_linkmux_select, (UInt32)DMAReadSourceMuxType.AnalogChanneData);
- //Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.FifoCtrl_FullProgDepth, 1024);//采集板并行FIFO深度
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.FifoCtrl_FullProgDepth, 500);//采集板并行FIFO深度
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_StorageMode, AcquingParameters.bIsLongStorageMode ? 1u : 0);
- HdIO.WriteReg(PcieBdReg.W.DataPath_pcie_linkdemux_select, (UInt32)DMAReadSourceMuxType.AnalogChanneData);
- #region 发送FIFO深度
- //在DPX模式下,可能更改此参数,故需要重发
- HdIO.WriteReg(ProcBdReg.W.DataPath_pro_linkdemux_select, (UInt32)DMAReadSourceMuxType.AnalogChanneData);
- bool bEnableInterpolation = Hd.CurrDebugVarints.bEnable_AcqbdInterpolation;
- if (bEnableInterpolation)
- bEnableInterpolation = AcquingParameters.InterpolationNum > 1;
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Interpolate_Enable, bEnableInterpolation ? 1U : 0);
- bool bFast = (Hd.CurrHdMessage?.Timebase?.AcqLength ?? AnaChnlStorageMode.Normal) == AnaChnlStorageMode.Fast;
- if (bFast) return;
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.DataPath_acq_linkmux_select, 0);
- //Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.TrigCtrl_AcqSerialFIFODepth, 16000);//采集板串行FIFO深度 16000 -->25600 zy0830 --> 53248
- HdIO.WriteReg(ProcBdReg.W.FifoCtrl_FullProgDepth, 12288);//12288 -->22528 --> 53248
- HdIO.WriteReg(PcieBdReg.W.FifoCtrl_FullProgDepth, 12288);
- HdIO.WriteReg(PcieBdReg.W.FifoCtrl_ReadFromFIFO_Num, 15000);//zy0830 15000-->25000--> 53248
- #endregion
- }
- else
- {
- LongStorage?.InitAcq();
- }
- }
- protected virtual void AnalogChannelDataSplit(int dotCount)
- {
- for (int curr_channelIndex = 0; curr_channelIndex < ChannelIdExt.AnaChnlNum; curr_channelIndex++)
- {
- for (int dotIndex = 0; dotIndex < dotCount; dotIndex++)//0
- {
- ushort data = curr_channelIndex switch
- {
- 0 => (UInt16)((AcqedDataPool.AnalogChData.DMAData[8 * dotIndex]) | ((AcqedDataPool.AnalogChData.DMAData[8 * dotIndex + 1] & 0x0F) << 8)),
- 1 => (UInt16)(((AcqedDataPool.AnalogChData.DMAData[8 * dotIndex + 1] & 0xF0) >> 4 | AcqedDataPool.AnalogChData.DMAData[8 * dotIndex + 2] << 4)),
- 2 => (UInt16)((AcqedDataPool.AnalogChData.DMAData[8 * dotIndex + 3] | (AcqedDataPool.AnalogChData.DMAData[8 * dotIndex + 4] & 0x0F) << 8)),
- 3 => (UInt16)(((AcqedDataPool.AnalogChData.DMAData[8 * dotIndex + 4] & 0xF0) >> 4 | AcqedDataPool.AnalogChData.DMAData[8 * dotIndex + 5] << 4)),
- _ => 0,
- };
- AcqedDataPool.AnalogChData.AllChannelData[curr_channelIndex].Add(data);
- }
- }
- DiscardDotAtTriggerTypeIsSerialMode();
- AbstractController_AnalogChannel.SoftwareBandwidthProcess();
- }
- internal override bool ReadAcqData()
- {
- bDataVaild = false;
- bool bOk = false;
- if (Hd.CurrHdMessage == null)
- return bOk;
- AcquingParameters.CloneTo(AcquedParameters);
- Int32 scanExistDots = 0;
- if (HdIO.CurrDriver == null || !HdIO.CurrDriver.bOpen || Hd.bPowerOff)
- {
- if (Hd.CurrHdMessage?.Timebase?.IsScan ?? false)
- {
- //模拟
- Random random = new Random();
- int a = random.Next(100, 1000);
- AcqAnalogChannelSimulateWaveform();
- for (int iChannelID = 0; iChannelID < ChannelIdExt.AnaChnlNum; iChannelID++)
- AcqedDataPool.AnalogChData.AllChannelData[iChannelID].RemoveRange(a, AcqedDataPool.AnalogChData.AllChannelData[iChannelID].Count - a);
- return true;
- }
- else
- return AcqAnalogChannelSimulateWaveform();
- }
- if (!AcquingParameters.bIsLongStorageMode)
- {
- if (Hd.CurrHdMessage!.Timebase!.IsScan)
- {
- scanExistDots = (Int32)HdIO.ReadReg(ProcBdReg.R.Scan_DatacountUploading);
- HdIO.WriteReg(ProcBdReg.W.Scan_DatacountPassback, (UInt32)(scanExistDots | 0x0 << 14));
- HdIO.WriteReg(ProcBdReg.W.Scan_DatacountPassback, (UInt32)(scanExistDots | 0x1 << 14));
- HdIO.CheckRegisterValue((UInt32)PcieBdReg.R.FifoCtrl_FullFlag, 0x01, 1, 4);
- bOk = HdIO.DMARead(DMAReadDataTypes.AnalogChannelFifo, (uint)AcquingParameters.AnaWaveDMALength, ref AcqedDataPool.AnalogChData.DMAData);
- HdIO.WriteReg(ProcBdReg.W.Scan_DatacountPassback, (UInt32)(scanExistDots | 0x0 << 14));
- }
- else
- {
- bool bFast = (Hd.CurrHdMessage?.Timebase?.AcqLength ?? AnaChnlStorageMode.Normal) == AnaChnlStorageMode.Fast;
- if (!bFast)
- {
- HdIO.WriteReg((uint)PcieBdReg.W.ReadFromAcqOrDpo, 0);
- HdIO.WriteReg((uint)PcieBdReg.W.ReadTotalBytes, (uint)AcquingParameters.AnaWaveDMALength);
- bOk = HdIO.DMARead(0, (uint)AcquingParameters.AnaWaveDMALength, ref AcqedDataPool.AnalogChData.DMAData);
- }
- else
- {
- Int64 currPerXDivByps = (Int64)((Hd.CurrHdMessage?.Timebase?.TmbScale ?? 1) * 1_000_000);//TmbScale 以us为单位,*1_000_000,us==>ps
- UInt32 length = 0;
- if (ChannelIdExt.AnaChnlNum <= 4)
- length = (UInt32)(((currPerXDivByps * Constants.VIS_XDIVS_NUM) * 8 * 1000 + AcquingParameters.PerDataByfs_AtStorage - 1) / ((long)AcquingParameters.PerDataByfs_AtStorage));
- else
- length = (UInt32)(((currPerXDivByps * Constants.VIS_XDIVS_NUM) * 16 * 1000 + AcquingParameters.PerDataByfs_AtStorage - 1) / ((long)AcquingParameters.PerDataByfs_AtStorage));
- // UInt32 length = 8192;//须归一化256byte整除
- length = ((length / 1024 + 1) * 1024);
- HdIO.WriteReg(PcieBdReg.W.DataPath_pcie_linkdemux_select, (UInt32)DMAReadSourceMuxType.AnalogChanneData);
- HdIO.WriteReg((uint)PcieBdReg.W.ReadFromAcqOrDpo, 0);
- HdIO.WriteReg((uint)PcieBdReg.W.ReadTotalBytes, length);
- bOk = HdIO.DMARead(0, length, ref AcqedDataPool.AnalogChData.DMAData);
- }
- }
- }
- else
- {
- LongStorage?.SwitchPingpong();
- bOk = LongStorage?.ReadTrigPosTable() ?? false;
- bOk = LongStorage?.ReadAcqedData() ?? false;
- return bOk;
- }
- bDataVaild = bOk;
- if (!bOk)
- return bOk;
- #region 数据拆分 本拆分方法是按通道交替组织数据的方式进行拆分的。不同的硬件的数据组织方式,需要修改此拆分方法。
- Monitor.Enter(AcqedDataPool.UpdateDataLock);
- int channelCount = ChannelIdExt.AnaChnlNum;
- if (Hd.currProduct.ProductType == ProductType.B21_DBI16G)
- channelCount = 4;
- while (AcqedDataPool.AnalogChData.AllChannelData.Count < channelCount)
- AcqedDataPool.AnalogChData.AllChannelData.Add(new List<ushort>());
- for (int iChannelID = 0; iChannelID < channelCount; iChannelID++)
- AcqedDataPool.AnalogChData.AllChannelData[iChannelID].Clear();
- int channelDotCount = 0;
- if (Hd.CurrHdMessage?.Timebase?.IsScan ?? false)
- {
- channelDotCount = scanExistDots > Constants.CHNL_DATA_NUM ? Constants.CHNL_DATA_NUM : scanExistDots;
- }
- else
- channelDotCount = Constants.CHNL_DATA_NUM;
- AnalogChannelDataSplit(channelDotCount);
- Monitor.Exit(AcqedDataPool.UpdateDataLock);
- #endregion
- return bOk;
- }
- internal override void PostProcess()
- {
- if (!AcquingParameters.bIsLongStorageMode)
- {
- if (IsNeedPostProcessByMatlab)
- {
- #region 需要MATLAB处理
- #endregion
- }
- }
- else
- {
- //长存储时的处理
- LongStorage?.PostProcess();
- }
- }
- #region Core->U2调用函数
- public virtual bool TryTakeWave(Int32 channelIndex, [NotNullWhen(true)] out List<ushort> waveData, [NotNullWhen(true)] out WfmSampleInfo wfmSampleInfo)
- {
- waveData = new List<ushort>();
- wfmSampleInfo = new WfmSampleInfo();
- wfmSampleInfo.SampleIntervalByus = AcquedParameters.PerDataByfs_AfterPostProcess * 1.0 / 1E9;//1_000:fs==>ps
- if ((channelIndex < 0) || (channelIndex > ChannelIdExt.AnaChnlNum - 1))
- return false;
- if ((Hd.CurrHdMessage?.Timebase?.AcqLength ?? AnaChnlStorageMode.Normal) == AnaChnlStorageMode.Long)
- {
- Hd.bAcqedNewData = LongStorage?.TakeWave() ?? false;
- if (Hd.bAcqedNewData)
- wfmSampleInfo.SampleIntervalByus = AcquedParameters.PerDataByfs_AfterPostProcess * 1.0 / 1E9;//1_000:fs==>ps
- }
- if (AcqedDataPool.AnalogChData.AllChannelData.Count <= channelIndex)
- return false;
- Monitor.Enter(AcqedDataPool.UpdateDataLock);
- waveData.AddRange(AcqedDataPool.AnalogChData.AllChannelData[channelIndex]);
- Monitor.Exit(AcqedDataPool.UpdateDataLock);
- return Hd.bAcqedNewData;
- }
- public virtual Double TakeSamplingRate()
- {
- return 1E15 / AcquingParameters.PerDataByfs_AtStorage;
- }
- public virtual bool TryTakeDdrSourceWave(Int32 channel, double startTimeBySecond, double totalTime, [NotNullWhen(true)] out List<ushort> waveData, [NotNullWhen(true)] out WfmSampleInfo wfmSampleInfo)
- {
- if (LongStorage != null)
- return LongStorage!.TryTakeDdrSourceWave(channel, startTimeBySecond, totalTime, out waveData, out wfmSampleInfo);
- else
- {
- waveData = new List<ushort>();
- wfmSampleInfo = new WfmSampleInfo() { SampleIntervalByus = 0.5 };
- return false;
- }
- }
- public bool TryTakeSegmentWave(Int32 channelIndex, Int32 segmentIndex, out List<ushort> waveData, out WfmSampleInfo wfmSampleInfo, out Double SecondByps)
- {
- waveData = new List<ushort>();
- wfmSampleInfo = new WfmSampleInfo();
- wfmSampleInfo.SampleIntervalByus = AcquedParameters.PerDataByfs_AfterPostProcess * 1.0 / 1E9;
- if (segmentIndex < (LongStorage?.TrigAddressTable.Count ?? 0))
- SecondByps = LongStorage?.TrigAddressTable[segmentIndex].FrameTimeByns ?? 0.0;
- else
- SecondByps = 0.0;
- return LongStorage?.TryTakeSegmentWave(channelIndex, segmentIndex, out waveData) ?? false;
- }
- public Int32 TryTakeCollectedSegmentCnt()
- {
- return LongStorage?.ReadCollectedFrameCnt() ?? 0;
- }
- #endregion
- protected virtual bool AcqAnalogChannelSimulateWaveform()
- {
- //AcqedDataPool.AnalogChData.AllChannelData.Clear();
- //ushort[] list = { 2048, 1648, 1248, 2448 };
- //for (int channelID = 0; channelID < ChannelIdExt.AnaChnlNum; channelID++)
- //{
- // AcqedDataPool.AnalogChData.AllChannelData.Add(new List<ushort>());
- // for (int i = 0; i < 10000; i++)
- // AcqedDataPool.AnalogChData.AllChannelData[channelID].Add(list[channelID]);
- //}
- Monitor.Enter(AcqedDataPool.UpdateDataLock);
- AcqedDataPool.AnalogChData.AllChannelData.Clear();
- int Length = Constants.CHNL_DATA_NUM;
- double SampIntByns = Hd.CurrHdMessage?.Timebase?.TmbScale * Constants.VIS_XDIVS_NUM * 1000 / Constants.CHNL_DATA_NUM ?? 0.5;
- //var cycles = Length * (SampIntByns * 1E-9) * (Constants.AWG_SIN_FRQ_DEF * 1E-6);
- double cycles = 10;
- double NoiseByPercent = 0.05;
- ArbWfmType[] allChannelArbWfmType;
- if (!Hd.bPowerOff)
- allChannelArbWfmType = new ArbWfmType[] { ArbWfmType.Sinc, ArbWfmType.Square, ArbWfmType.Ramp, ArbWfmType.DC, ArbWfmType.Sinc, ArbWfmType.Square, ArbWfmType.Ramp, ArbWfmType.Haversine };
- else
- allChannelArbWfmType = new ArbWfmType[] { ArbWfmType.DC, ArbWfmType.DC, ArbWfmType.DC, ArbWfmType.DC, ArbWfmType.DC, ArbWfmType.DC, ArbWfmType.DC, ArbWfmType.DC };
- int channelCount = ChannelIdExt.AnaChnlNum;
- if (Hd.currProduct.ProductType == ProductType.B21_DBI16G || Hd.currProduct.ProductType == ProductType.B21_DBI20G)
- channelCount = 4;//按子带数来处理,而不是物理通道数
- for (int channelID = 0; channelID < channelCount; channelID++)
- {
- double anaChannelPosition = 0;// Constants.IDX_PER_YDIV * 5;// Hd.CurrHdMessage?.Analog?[channelID].PositionIndex ?? 0;
- double amplitude = 1.0;// (Hd.CurrHdMessage?.Analog?[channelID].Scale ?? 0) * 6;
- ArbWfmType arbWfmType = allChannelArbWfmType[channelID];
- IEnumerable<Double> y = arbWfmType switch
- {
- ArbWfmType.Pulse or ArbWfmType.Square => Generator.Rectangular(anaChannelPosition, amplitude, cycles / Length, Length, 0.05, NoiseByPercent, 0.1),
- ArbWfmType.DC => Generator.DirectCurrent(anaChannelPosition, amplitude, Length, 0.05),
- ArbWfmType.Haversine => Generator.Haversine(anaChannelPosition, amplitude, cycles / Length, Length, NoiseByPercent, 0.05),
- _ => Generator.Sine(anaChannelPosition, amplitude, cycles / Length, Length, 0.02, 0.0),
- };
- y = y.Select(o => o * 1E3);
- double pos0 = 0;
- if (channelID < ChannelIdExt.AnaChnlNum)//因为DBI的缘故,子带模式与物理通道模式不一样
- pos0 = (Hd.CurrHdMessage?.Analog?[channelID].PositionIndex ?? 0) / Constants.IDX_PER_YDIV * Constants.SAMPS_PER_YDIV + Constants.MAX_ADC_RES / 2;
- else
- pos0 = (Hd.CurrHdMessage?.Analog?[ChannelIdExt.AnaChnlNum - 1].PositionIndex ?? 0) / Constants.IDX_PER_YDIV * Constants.SAMPS_PER_YDIV + Constants.MAX_ADC_RES / 2;
- y = y.Select((o) => o /*(Hd.CurrHdMessage?.Analog?[channelID].Scale ?? 100)*/ / Constants.IDX_PER_YDIV * Constants.SAMPS_PER_YDIV + pos0);
- Double[] data = y.ToArray();// .ToRowVector();
- AcqedDataPool.AnalogChData.AllChannelData.Add(new List<ushort>());
- for (int i = 0; i < Length; i++)
- AcqedDataPool.AnalogChData.AllChannelData[channelID].Add((ushort)(data[i]));
- }
- AcquedParameters.PerDataByfs_AfterPostProcess = (Hd.CurrHdMessage?.Timebase?.TmbScale * Constants.VIS_XDIVS_NUM * 1000_000_000 / Constants.CHNL_DATA_NUM ?? 50 * 1000);
- AbstractController_AnalogChannel.SoftwareBandwidthProcess();
- Monitor.Exit(AcqedDataPool.UpdateDataLock);
- return true;
- }
- #region Cali Tool 调用函数
- public virtual bool TakeAllChannelWaveform(out List<List<ushort>> waveData)
- {
- waveData = new List<List<ushort>>();
- Monitor.Enter(AcqedDataPool.UpdateDataLock);
- for (int channelIndex = 0; channelIndex < ChannelIdExt.AnaChnlNum; channelIndex++)
- {
- List<ushort> oneChannelData = new List<ushort>();
- oneChannelData.AddRange(AcqedDataPool.AnalogChData.AllChannelData[channelIndex].ToArray());
- if (oneChannelData.Count < Constants.CHNL_DATA_NUM)
- oneChannelData.AddRange(new ushort[Constants.CHNL_DATA_NUM - oneChannelData.Count]);//补齐数据长度,否则Tool端可能不能读到数据
- waveData.Add(oneChannelData);
- }
- Monitor.Exit(AcqedDataPool.UpdateDataLock);
- return true;
- }
- public virtual bool TakeAdcWaveform(out List<List<ushort>> waveData)
- {
- waveData = new List<List<ushort>>();
- int totalCoreCount = ChannelIdExt.AnaChnlNum * Constants.ADC_NUM * Constants.ADC_CORE_NUM;
- for (int coreIndex = 0; coreIndex < totalCoreCount; coreIndex++)
- waveData.Add(new List<ushort>());
- Monitor.Enter(AcqedDataPool.UpdateDataLock);
- int totalCoreIndex = 0;
- for (int channelIndex = 0; channelIndex < ChannelIdExt.AnaChnlNum; channelIndex++)
- {
- for (int adcIndex = 0; adcIndex < Constants.ADC_NUM; adcIndex++)
- {
- for (int coreIndex = 0; coreIndex < Constants.ADC_CORE_NUM; coreIndex++)
- {
- for (int dotIndex = 0; dotIndex < Constants.CORE_DATA_NUM; dotIndex++)
- {
- ushort data = (adcIndex % Constants.ADC_NUM, coreIndex) switch
- {
- (0, 0) => AcqedDataPool.AnalogChData.AllChannelData[channelIndex][dotIndex * 4],
- (0, 1) => AcqedDataPool.AnalogChData.AllChannelData[channelIndex][dotIndex * 4 + 2],
- (1, 0) => AcqedDataPool.AnalogChData.AllChannelData[channelIndex][dotIndex * 4 + 1],
- (1, 1) => AcqedDataPool.AnalogChData.AllChannelData[channelIndex][dotIndex * 4 + 3],
- _ => 0,
- };
- waveData[totalCoreIndex].Add(data);
- }
- totalCoreIndex++;
- }
- }
- }
- Monitor.Exit(AcqedDataPool.UpdateDataLock);
- return true;
- }
- #endregion
- internal virtual bool IsNeedPostProcessByMatlab => false;
- internal virtual void AnalogChannelActiveChanged() { }
- private Dictionary<UInt64, UInt32> _ExtramTable = new Dictionary<UInt64, UInt32>()
- {
- // 抽取倍数 下发参数
- {1, 0 },
- {2, 1 },
- {4, 2 },
- {5, 3 },
- {8, 4 },
- {10, 5 },
- {20, 6 },
- {40, 7 },
- };
- /// <summary>
- /// 根据抽取模式和并行路数下发抽取参数
- /// </summary>
- /// <param name="extramNum">抽取倍数:最大是36位</param>
- /// <param name="parallelRoads">并行路数:40/80</param>
- /// <param name="extramMode"></param>
- internal void ConfigExtramNum(UInt64 extramNum, UInt32 parallelRoads, AnaChnlAcqMode extramMode)
- {
- if (_ExtramTable.ContainsKey(extramNum) && extramNum < parallelRoads)
- {
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_Decimation_Multiple_Pattern, _ExtramTable[extramNum]);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_Decimation_quotient_L16, 0);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_Decimation_quotient_M16, 0);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_Decimation_quotient_H4, 0);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_Decimation_remainder_additional_Processing, 0);
- return;
- }
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_Decimation_Multiple_Pattern, 8);
- UInt64 decimationQuotient;
- UInt64 remainderAdditional;
- switch (extramMode)
- {
- case AnaChnlAcqMode.Normal:
- decimationQuotient = extramNum / parallelRoads;
- remainderAdditional = (extramNum / (parallelRoads / 4)) % 4;
- break;
- case AnaChnlAcqMode.Peak:
- decimationQuotient = extramNum * 2 / parallelRoads;
- if (extramNum * 2 % parallelRoads == 0)
- remainderAdditional = 0x1 << 7;
- else
- remainderAdditional = parallelRoads / (extramNum * 2 % parallelRoads);
- break;
- case AnaChnlAcqMode.HighRes:
- decimationQuotient = extramNum / parallelRoads;
- if (extramNum % parallelRoads == 0)
- remainderAdditional = 0x1 << 7;
- else
- remainderAdditional = parallelRoads / (extramNum % parallelRoads);
- break;
- default:
- return;
- }
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_Decimation_remainder_additional_Processing, (UInt32)remainderAdditional);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_Decimation_quotient_L16, (UInt32)(decimationQuotient & 0xffff));
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_Decimation_quotient_M16, (UInt32)(decimationQuotient >> 16 & 0xffff));
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_Decimation_quotient_H4, (UInt32)(decimationQuotient >> 32 & 0xf));
- }
- struct ExtramPara
- {
- internal UInt32 Multiple_Pattern;
- internal UInt64 RemainderAdditional;
- internal UInt64 DecimationQuotient;
- }
- private ExtramPara GetExtramPara(UInt64 extramNum, UInt32 parallelRoads, AnaChnlAcqMode extramMode)
- {
- ExtramPara ectram = new ExtramPara();
- if (_ExtramTable.ContainsKey(extramNum) && extramNum < parallelRoads)
- {
- ectram.Multiple_Pattern = _ExtramTable[extramNum];
- ectram.RemainderAdditional = 0;
- ectram.DecimationQuotient = 0;
- }
- else
- {
- ectram.Multiple_Pattern = 8;
- switch (extramMode)
- {
- case AnaChnlAcqMode.Normal:
- ectram.DecimationQuotient = extramNum / parallelRoads;
- ectram.RemainderAdditional = (extramNum / (parallelRoads / 4)) % 4;
- break;
- case AnaChnlAcqMode.Peak:
- ectram.DecimationQuotient = extramNum * 2 / parallelRoads;
- if (extramNum * 2 % parallelRoads == 0)
- ectram.RemainderAdditional = 0x1 << 7;
- else
- ectram.RemainderAdditional = parallelRoads / (extramNum * 2 % parallelRoads);
- break;
- case AnaChnlAcqMode.HighRes:
- ectram.DecimationQuotient = extramNum / parallelRoads;
- if (extramNum % parallelRoads == 0)
- ectram.RemainderAdditional = 0x1 << 7;
- else
- ectram.RemainderAdditional = parallelRoads / (extramNum % parallelRoads);
- break;
- default:
- break;
- }
- }
- return ectram;
- }
- internal void ConfigExtramNum(UInt64 extramNum, UInt32 parallelRoads, AnaChnlAcqMode extramMode, AcqBdNo acqBd)
- {
- ExtramPara ectramPara = GetExtramPara(extramNum, parallelRoads, extramMode);
- Hd.currProduct?.AcqBd?.WriteReg(AcqBdReg.W.Decimation_Decimation_Multiple_Pattern, acqBd, ectramPara.Multiple_Pattern);
- Hd.currProduct?.AcqBd?.WriteReg(AcqBdReg.W.Decimation_Decimation_remainder_additional_Processing, acqBd, (UInt32)ectramPara.RemainderAdditional);
- Hd.currProduct?.AcqBd?.WriteReg(AcqBdReg.W.Decimation_Decimation_quotient_L16, acqBd, (UInt32)(ectramPara.DecimationQuotient & 0xffff));
- Hd.currProduct?.AcqBd?.WriteReg(AcqBdReg.W.Decimation_Decimation_quotient_M16, acqBd, (UInt32)(ectramPara.DecimationQuotient >> 16 & 0xffff));
- Hd.currProduct?.AcqBd?.WriteReg(AcqBdReg.W.Decimation_Decimation_quotient_H4, acqBd, (UInt32)(ectramPara.DecimationQuotient >> 32 & 0xf));
- }
- internal virtual void ConfigLongStorage()
- {
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_StorageMode, AcquingParameters.bIsLongStorageMode ? 1 : 0U);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_RcdRstEnable, AcquingParameters.LS_SegmentCount > 1 ? 1u : 0);
- }
- internal virtual void FilterChannelAtSpecailBandwidth(ChannelId channelId)
- {
- //Uestc.Auto6.Dso.MathExt.Filter.
- }
- internal virtual void ConfigExtractProcessRoadParameters()
- {
- //要使FIFO 满,在确保ADC工作正常的情况下,需要正确配置的参数包括:
- //采集板
- //1、FifoCtrl_OutSpeed 串并转换CH_MODE_SamplingMode
- //2、CH_MODE_SamplingMode
- //3、Interpolate_Enable 、Interpolate_Ratio
- //4、Decimation_Hardware、Decimation_HighResolution、Decimation_Peak等整个采集板处理路径
- //5、FIFO深度FifoCtrl_FullProgDepth(可以在初始化时一次性设置)
- //处理板
- //FifoCtrl_ParallelFifoDepth、FifoCtrl_FullProgDepth(可以在初始化时一次性设置)
- //PCIE 板
- //FifoCtrl_ProgEmpty、FifoCtrl_FullProgDepth、FifoCtrl_ReadFromFIFO_Num(可以在初始化时一次性设置)
- //FifoCtrl_ChannelMode
- //modifyNote20220117 1、原来的不同模式采用不同的寄存器,现在呢?
- bool bEnableInterpolation = Hd.CurrDebugVarints.bEnable_AcqbdInterpolation;
- if (bEnableInterpolation)
- {
- if ((Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.InterpolationNum ?? 1) <= 1)
- bEnableInterpolation = false;
- }
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Interpolate_Enable, bEnableInterpolation ? 1U : 0U);
- UInt32 acqMode = (Hd.CurrHdMessage?.Timebase?.AcqMode ?? AnaChnlAcqMode.Normal) switch
- {
- AnaChnlAcqMode.Peak => 1,
- AnaChnlAcqMode.HighRes => 3,
- _ => 0,
- };
- HdIO.WriteReg(ProcBdReg.W.ext_10m_ext_10m_sel, Hd.CurrHdMessage!.Timebase!.ClockSrc==AnaChnlClkSrc.Inner ? 0U : 1U);
- UInt64 extractNum = (UInt64)(Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.HardwareExtractNum ?? 1U);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Interpolate_Ratio, (UInt32)(Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.InterpolationNum ?? 1));
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_Decimation_L16, (UInt32)(extractNum & 0xffff));
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_Decimation_M16, (UInt32)((extractNum >> 16) & 0xffff));
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_Decimation_H16, (UInt32)(extractNum >> 32) & 0xffff);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.Decimation_DecimationMode, acqMode & 0xffff);
- ConfigExtramNum(extractNum, Hd.currProduct!.Acquirer_AnalogChannel!.AcquingParameters.AcqAdcMergeRoadCount, (Hd.CurrHdMessage?.Timebase?.AcqMode ?? AnaChnlAcqMode.Normal));
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.FifoCtrl_OutSpeed, 1U);
- AnaChnlStorageMode anaChnlAcqLength = (Hd.CurrHdMessage?.Timebase?.AcqLength ?? AnaChnlStorageMode.Normal);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_StorageMode, anaChnlAcqLength == AnaChnlStorageMode.Long ? 1U : 0U);
- if (anaChnlAcqLength == AnaChnlStorageMode.Long)
- {
- //merged modify
- //Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_SegmentCount, (UInt32)(Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.LS_SegmentCount ?? 1));
- //end merged modify
- UInt32 tmp = (UInt32)(Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.LS_Addr_FirstSegment ?? 0);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_SegmentBeginAddr_L, (UInt32)(tmp) & 0xffff);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_SegmentBeginAddr_L, (UInt32)(tmp >> 16) & 0xffff);
- tmp = (UInt32)(Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.LS_Addr_PreTrig ?? 0);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_TrigAddrTableStartAddr_L, (UInt32)tmp & 0xffff);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_TrigAddrTableStartAddr_H, (UInt32)(tmp >> 16) & 0xffff);
- tmp = (UInt32)(Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.LS_SegmentAddrCount ?? 0);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_SegmentBeginAddr_L, (UInt32)tmp & 0xffff);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_SegmentBeginAddr_H, (UInt32)(tmp >> 16) & 0xffff);
- tmp = (UInt32)(Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.LS_Addr_TrigTable ?? 0);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_TrigAddrTableStartAddr_L, (UInt32)tmp & 0xffff);
- Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_TrigAddrTableStartAddr_H, (UInt32)(tmp >> 16) & 0xffff);
- AnaChnlAcqMode anaChnlAcqMode = Hd.CurrHdMessage?.Timebase?.AcqMode ?? AnaChnlAcqMode.Normal;
- //Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_PickMode, anaChnlAcqMode == AnaChnlAcqMode.Peak ? 0U : 1U);
- //Hd.currProduct?.AcqBd?.WriteToAllFpga(AcqBdReg.W.LSCtrl_PickMode, anaChnlAcqMode == AnaChnlAcqMode.Peak ? 0U : 1U);
- }
- }
- internal virtual Dictionary<int /*mergeMode*/, List<List<ChannelBdAdcInputDefine>>>? ChannelBdAdcInputDefines
- {
- get;
- }
- internal virtual Int32 Dpx_AcqFifoDepth()
- {
- Int64 currPerXDivByps = (Int64)((Hd.CurrHdMessage?.Timebase?.TmbScale ?? 1) * 1_000_000);//TmbScale 以us为单位,*1_000_000,us==>ps
- return (Int32)((currPerXDivByps * 1000 * Constants.VIS_XDIVS_NUM / Hd.currProduct!.Acquirer_AnalogChannel!.AcquingParameters.PerDataByfs_AtStorage + 200) / 40);
- }
- #region AFC(幅频特性) 系数
- private Dictionary<ChannelId, AnaChnlScaleIndex> lastChannelYScale = new Dictionary<ChannelId, AnaChnlScaleIndex>()
- {
- [ChannelId.C1] = AnaChnlScaleIndex.Lv100,
- [ChannelId.C2] = AnaChnlScaleIndex.Lv100,
- [ChannelId.C3] = AnaChnlScaleIndex.Lv100,
- [ChannelId.C4] = AnaChnlScaleIndex.Lv100,
- [ChannelId.C5] = AnaChnlScaleIndex.Lv100,
- [ChannelId.C6] = AnaChnlScaleIndex.Lv100,
- [ChannelId.C7] = AnaChnlScaleIndex.Lv100,
- [ChannelId.C8] = AnaChnlScaleIndex.Lv100,
- };
- protected virtual void CheckResendAfc()
- {
- Calibration.Data.Base.CoefficientsTableType coefficientsTableType = CoefficientsTableType.Coefficients8;
- bool bFound = false;
- foreach (var v in Hd.currProduct!.HardwareConfig!.LocalCoefficientsTableMeanings)
- {
- if (v.Value.CoeffType == CommCoefficientsTableType.AcqBd_AFC)
- {
- coefficientsTableType = v.Key;
- bFound = true;
- break;
- }
- }
- if (!bFound)
- return;
- bFound = false;
- for (int channelId = (int)ChannelId.C1; channelId < ChannelIdExt.AnaChnlNum; channelId++)
- {
- if (lastChannelYScale[(ChannelId)channelId] != (AnaChnlScaleIndex)Hd.CurrHdMessage!.Analog![channelId]!.ScaleIndex)
- {
- lastChannelYScale[(ChannelId)channelId] = (AnaChnlScaleIndex)Hd.CurrHdMessage!.Analog![channelId]!.ScaleIndex;
- bFound = true;
- }
- }
- if (bFound)
- {
- CaliDataManager.DataChangedCoefficientsTableType.Add(coefficientsTableType);
- Hd.LocalCommands |= (long)HdCmd.CaliDataChanged;
- }
- }
- internal virtual bool Afc_Sender_ByRegisterMode(CoefficientsTableType coefficientsTableType, int[] dataArray, AcqBdNo acqBdNo, ChannelId channelId)
- {
- int partALength = Hd.currProduct!.HardwareConfig!.LocalCoefficientsTableMeanings[coefficientsTableType].LengthOfPartA;
- int dataCount = dataArray.Length;
- for (int i = 0; i < dataCount; i++)
- {
- Hd.currProduct!.AcqBd!.WriteReg(AcqBdReg.W.Fir_FactorTableWriteEnable, acqBdNo, 0);
- if (i < partALength) //10G系数
- Hd.currProduct!.AcqBd!.WriteReg(AcqBdReg.W.Fir_FactorTableWriteAddr, acqBdNo, (UInt32)i);
- else //20G系数(修改系数长度后需要修改此处)
- Hd.currProduct!.AcqBd!.WriteReg(AcqBdReg.W.Fir_FactorTableWriteAddr, acqBdNo, (UInt32)(i + 0b00100000000 - partALength));//(适用200阶)下发地址11位,通过高位为1下发的则是20G的系数
- Int32 data = dataArray[i];
- //低16位
- Hd.currProduct!.AcqBd!.WriteReg(AcqBdReg.W.Fir_FactorTableWriteData_L, acqBdNo, (UInt32)data & 0xffff);
- //高位
- Hd.currProduct!.AcqBd!.WriteReg(AcqBdReg.W.Fir_FactorTableWriteData_H, acqBdNo, (UInt32)(data >> 16) & 0xff);
- HdIO.DelayByUs(10);
- Hd.currProduct!.AcqBd!.WriteReg(AcqBdReg.W.Fir_FactorTableWriteEnable, acqBdNo, 1);
- }
- Hd.currProduct!.AcqBd!.WriteReg(AcqBdReg.W.Fir_FactorTableWriteEnable, acqBdNo, 0);
- Hd.currProduct!.AcqBd!.WriteReg(AcqBdReg.W.Fir_Enable, acqBdNo, Hd.CurrDebugVarints.bEnable_AcqBd_Afc ? 1U : 0);
- return true;
- }
- internal virtual bool Afc_Sender_ByDMAMode(CoefficientsTableType coefficientsTableType, int[] dataArray, AcqBdNo acqBdNo, ChannelId channelId)
- {
- return false;
- }
- /// <summary>
- /// Key = $"{acqBdNo}_{((ChannelId)channelId)}",Value=crcCode
- /// </summary>
- protected Dictionary<string, int> AfcSendHistory = new Dictionary<string, int>();
- internal virtual void ClearSendHistory() => AfcSendHistory.Clear();
- internal virtual void SendCoefficients_Afc(CoefficientsTableType coefficientsTableType, bool bForce)
- {
- if (Hd.currProduct!.Acquirer_AnalogChannel!.ChannelPerScaleAmpFreqCoefficientsDefine == null)
- return;
- Dictionary<int /*mergeMode*/, List<List<ChannelBdAdcInputDefine>>>? channelBdAdcInputDefines = Hd.currProduct?.Acquirer_AnalogChannel?.ChannelBdAdcInputDefines;
- if (channelBdAdcInputDefines == null)
- return;
- for (int channelId = (int)ChannelId.C1; channelId < ChannelIdExt.AnaChnlNum; channelId++)
- {
- string key = ((ChannelId)channelId).ToString() + "_" + ((int)Hd.CurrHdMessage!.Analog![channelId].Scale).ToString();
- if (Hd.currProduct!.Acquirer_AnalogChannel!.ChannelPerScaleAmpFreqCoefficientsDefine.TryGetValue(key, out var info))
- {
- if (!info.bOk)
- continue;
- AcqBdNo acqBdNo = channelBdAdcInputDefines[1][(int)channelId][0].BdNo;//1=20G, 0=只取第一条记录,与ADC的顺序无关
- string SendHistoryKey = $"{acqBdNo}_{((ChannelId)channelId)}";
- if (AfcSendHistory.ContainsKey(SendHistoryKey))
- {
- if (AfcSendHistory[SendHistoryKey] == info.CRCCode)
- continue;
- AfcSendHistory[SendHistoryKey] = info.CRCCode;
- }
- else
- AfcSendHistory.Add(SendHistoryKey, info.CRCCode);
- int[]? dataArray = Misc.ReadCaliCoefDataFronmFile(info.FileName);
- if (Hd.currProduct!.HardwareConfig!.DownloadBlockDataMode == DownloadBlockDataMode.DMA)
- Afc_Sender_ByDMAMode(coefficientsTableType, dataArray!, acqBdNo, (ChannelId)channelId);
- else
- Afc_Sender_ByRegisterMode(coefficientsTableType, dataArray!, acqBdNo, (ChannelId)channelId);
- }
- }
- return;
- }
- #endregion
- internal virtual bool AutoCaliAtInit(HdMessage? hdMessage) => false;
- internal virtual Boolean IsInterpolation_LS(Int32 channelId)
- {
- return false;
- }
- #region 模拟通道幅度增益温度补偿
- protected DateTime LastPhyAnalogChAmplitudeTemperaturesCompensationCalced_Datetime = DateTime.Now;
- Dictionary<ChannelId, string> PhyAnalogChAmplitudeTemperaturesCompensationCoefficientFile = new Dictionary<ChannelId, string>()
- {
- {ChannelId.C1,$@".\CaliData\CoeFiles\AnalogChannelTemperatureCompensation_C1.txt" },
- {ChannelId.C2,$@".\CaliData\CoeFiles\AnalogChannelTemperatureCompensation_C2.txt" },
- {ChannelId.C3,$@".\CaliData\CoeFiles\AnalogChannelTemperatureCompensation_C3.txt" },
- {ChannelId.C4,$@".\CaliData\CoeFiles\AnalogChannelTemperatureCompensation_C4.txt" },
- {ChannelId.C5,$@".\CaliData\CoeFiles\AnalogChannelTemperatureCompensation_C5.txt" },
- {ChannelId.C6,$@".\CaliData\CoeFiles\AnalogChannelTemperatureCompensation_C6.txt" },
- };
- Dictionary<ChannelId, Dictionary<double, double>> allChannelAmplitudeTemperaturesCompensationCoefficient = new Dictionary<ChannelId, Dictionary<double, double>>();
- protected List<double> LastPhyAnalogChAmplitudeTemperaturesCompensationCoefficient = new List<double>() { 1, 1, 1, 1, 1, 1, 1, 1 };
- protected List<double> PhyAnalogChAmplitudeBaselineTemperature = new List<double>() { 40, 40, 40, 40, 40, 40, 40, 40 };//校准基准温度
- internal virtual void InitPhyAnalogChAmplitudeTemperaturesCompensationCoefficient()
- {
- allChannelAmplitudeTemperaturesCompensationCoefficient.Clear();
- string rootPath = AppDomain.CurrentDomain.BaseDirectory;
- for (ChannelId channelId = ChannelId.C1; channelId <= ChannelId.C8; channelId++)
- {
- if (PhyAnalogChAmplitudeTemperaturesCompensationCoefficientFile.ContainsKey(channelId))
- {
- var result = Misc.ReadAmplitudeTemperaturesCompensationCoefficientFile(PhyAnalogChAmplitudeTemperaturesCompensationCoefficientFile[channelId], out double baselineTemperature);
- if (result.Count > 0)
- {
- if (allChannelAmplitudeTemperaturesCompensationCoefficient.ContainsKey(channelId))
- allChannelAmplitudeTemperaturesCompensationCoefficient[channelId] = result;
- else
- allChannelAmplitudeTemperaturesCompensationCoefficient.Add(channelId, result);
- PhyAnalogChAmplitudeBaselineTemperature[(int)channelId] = baselineTemperature;
- }
- }
- }
- }
- internal virtual bool GetPhyAnalogChAmplitudeTemperaturesCompensationCoefficient(out List<double> Coefficient)
- {
- Coefficient = LastPhyAnalogChAmplitudeTemperaturesCompensationCoefficient;
- if ((DateTime.Now - LastPhyAnalogChAmplitudeTemperaturesCompensationCalced_Datetime).TotalMilliseconds < Acquisition.PhyAnalogChAmplitudeTemperaturesCompensationIntervalByMs)
- return false;
- double currTemperature = SysMonitor.Default.AnalogChannelTemperatures[0];//只有一个通道板
- for (ChannelId channelId = ChannelId.C1; channelId <= ChannelIdExt.MaxAChId; channelId++)
- {
- ChannelId key = channelId;
- if (allChannelAmplitudeTemperaturesCompensationCoefficient.ContainsKey(key))
- {
- double result = 1;
- KeyValuePair<double, double> first;
- try
- {
- first = allChannelAmplitudeTemperaturesCompensationCoefficient[key].First((o) => o.Key <= currTemperature);
- }
- catch
- {
- first = (allChannelAmplitudeTemperaturesCompensationCoefficient[key].First());
- result = first.Value;
- if (allChannelAmplitudeTemperaturesCompensationCoefficient[key].ContainsKey(PhyAnalogChAmplitudeBaselineTemperature[(int)key]))
- result = result / allChannelAmplitudeTemperaturesCompensationCoefficient[key][PhyAnalogChAmplitudeBaselineTemperature[(int)key]];
- LastPhyAnalogChAmplitudeTemperaturesCompensationCoefficient[(int)channelId] = result;
- return true;
- }
- KeyValuePair<double, double> last;
- try
- {
- last = allChannelAmplitudeTemperaturesCompensationCoefficient[key].First((o) => o.Key >= currTemperature);
- }
- catch
- {
- last = allChannelAmplitudeTemperaturesCompensationCoefficient[key].Last();
- result = last.Value;
- if (allChannelAmplitudeTemperaturesCompensationCoefficient[key].ContainsKey(PhyAnalogChAmplitudeBaselineTemperature[(int)key]))
- result = result / allChannelAmplitudeTemperaturesCompensationCoefficient[key][PhyAnalogChAmplitudeBaselineTemperature[(int)key]];
- LastPhyAnalogChAmplitudeTemperaturesCompensationCoefficient[(int)channelId] = result;
- return true; ;
- }
- if (Math.Abs(first.Key - currTemperature) < 0.01)//==
- result = first.Value;
- else if (Math.Abs(last.Key - currTemperature) < 0.01)//==
- result = last.Value;
- else if (first.Key != last.Key)
- result = first.Value + (last.Value - first.Value) * (currTemperature - first.Key) / (last.Key - first.Key);//局部线性插值
- if (allChannelAmplitudeTemperaturesCompensationCoefficient[channelId].ContainsKey(PhyAnalogChAmplitudeBaselineTemperature[(int)channelId]))
- result = result / allChannelAmplitudeTemperaturesCompensationCoefficient[channelId][PhyAnalogChAmplitudeBaselineTemperature[(int)channelId]];
- LastPhyAnalogChAmplitudeTemperaturesCompensationCoefficient[(int)channelId] = result;
- }
- }
- LastPhyAnalogChAmplitudeTemperaturesCompensationCalced_Datetime = DateTime.Now;
- return true;
- }
- #endregion
- #region Dpx
- internal virtual DpxAcqParameters CreateDpxAcqParameters()
- {
- bool bInterpolation = Hd.currProduct?.Acquirer_AnalogChannel?.AcquingParameters.InterpolationNum > 1 ? true : false;//修改为真正得读取插值
- bool bEdgeTrig = Hd.CurrHdMessage?.Trigger?.TrigType == TriggerType.Edge;
- bool bSerialDpx = (bInterpolation | (!bEdgeTrig));
- Int64 currPerXDivByps = (Int64)((Hd.CurrHdMessage?.Timebase?.TmbScale ?? 1) * 1_000_000);//TmbScale 以us为单位,*1_000_000,us==>ps
- Int32 ParallelMapFifoDepth = (Int32)(currPerXDivByps * 1000 * Constants.VIS_XDIVS_NUM / (long)AcquingParameters.PerDataByfs_AtStorage / 5 / 4);//PerDataByfs_AtStorage 或者Dpx_PerDataByfs_AtStorage
- Int32 SoftFifoDepth = (Int32)(currPerXDivByps * 1024 * Constants.VIS_XDIVS_NUM / (long)AcquingParameters.PerDataByfs_AtStorage / 4 + 15);
- return new DpxAcqParameters()
- {
- bSerialDpx = bSerialDpx
- };
- }
- #endregion
- }
- internal class ChannelBdAdcInputDefine
- {
- public AcqBdNo BdNo { get; set; }
- public Int32 AdcIndex { get; set; }
- public int InputPort_AIs1 { get; set; }
- public bool bIs20GMode { get; set; } = false;
- }
- internal class AmpCoefficientFileInfo
- {
- public string FileName = "";
- public int CRCCode = 0;
- public bool bOk=false;
- }
- }
|