1:
2:
3:
4:
5:
6:
7:
8:
9:
10:

if (waveformDataSource.HasRawData()) {
                                        int[] data = waveformDataSource.GetRawData(blk, startSample + offset, doNow);

                                        if (red.ReductionInfo.Type == DataReductionType.None || red.ReductionInfo.Factor == 1) {
                                            block.AppendRawData(data, 0, doNow);
                                        } else {
                                            List<int> reduced = red.Reduce(data);
                                            block.AppendRawData(reduced.ToArray(), 0, reduced.Count);
                                        }
                                    }					

1:
2:
3:
4:
5:

[DllImport(dllName)]
            public static extern ErrorCode TPC_GetRawData(int deviceIx, int boardAddress, int inputNumber,
                                                          int blockNumber,
                                                          int measurementNumber, UInt64 dataStart, int dataLength,
                                                          IntPtr /*(Int32*)*/ data);					

1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:
13:
14:
15:
16:
17:
18:
19:
20:
21:
22:
23:
24:
25:
26:
27:
28:
29:
30:
31:
32:
33:
34:
35:
36:
37:
38:
39:
40:
41:
42:

BackgroundWorker _worker;

public void RunAsyncTpc5Writer(string filename, DataReductionInfo redInfo, DataReductionInfo redInfoECREvents) {
            _worker = new BackgroundWorker();
            _worker.WorkerReportsProgress = true;
            _worker.WorkerSupportsCancellation = true;

            _CurrentDoFilename = filename;
            _CurrentRedInfo = redInfo;
            _CurrentRedInfoECREvents = redInfoECREvents;

            _worker.DoWork += new DoWorkEventHandler(_worker_WriteTpc5Async);
            _worker.RunWorkerAsync();
        }


        private void _worker_WriteTpc5Async(object sender, DoWorkEventArgs e) {
            WriteTpc5Blocks(_CurrentDoFilename, _CurrentRedInfo, _CurrentRedInfoECREvents, null);
        }


private void WriteTpc5Blocks(string filename, DataReductionInfo redInfo, DataReductionInfo redInfoECREvents, BackgroundWorker worker) {
            //using (Tpc5File f = new Tpc5File(filename, FileMode.Create, FileAccess.ReadWrite)) {
            try {
.......

while (toGo > 0) {
                                    int doNow = (int)Math.Min(toGo, 1 * 1048576); // 1048576

                                    if (waveformDataSource.HasRawData()) {
                                        int[] data = inputSource.GetRawData(blk, startSample + offset, doNow);
                                        //int[] data = waveformDataSource.GetRawData(blk, startSample + offset, doNow);

                                        if (red.ReductionInfo.Type == DataReductionType.None || red.ReductionInfo.Factor == 1) {
                                            block.AppendRawData(data, 0, doNow);
                                        } else {
                                            List<int> reduced = red.Reduce(data);
                                            block.AppendRawData(reduced.ToArray(), 0, reduced.Count);
                                        }
............
}
}					

1:
2:
3:
4:
5:
6:
7:
8:
9:
10:
11:
12:

if (waveformDataSource.HasRawData()) {
                                        int[] data = waveformDataSource.GetRawData(blk, startSample + offset, doNow);
                                        Thread.Sleep(100000);
                                        

                                        if (red.ReductionInfo.Type == DataReductionType.None || red.ReductionInfo.Factor == 1) {
                                            block.AppendRawData(data, 0, doNow);
                                        } else {
                                            List<int> reduced = red.Reduce(data);
                                            block.AppendRawData(reduced.ToArray(), 0, reduced.Count);
                                        }
                                    }