Several updates on gr-trellis: 1) new fsm constructor for a joint trellis, 2) Corresp...
[debian/gnuradio] / gr-trellis / src / lib / fsm.cc
1 /* -*- c++ -*- */
2 /*
3  * Copyright 2002 Free Software Foundation, Inc.
4  *
5  * This file is part of GNU Radio
6  *
7  * GNU Radio is free software; you can redistribute it and/or modify
8  * it under the terms of the GNU General Public License as published by
9  * the Free Software Foundation; either version 3, or (at your option)
10  * any later version.
11  *
12  * GNU Radio is distributed in the hope that it will be useful,
13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15  * GNU General Public License for more details.
16  *
17  * You should have received a copy of the GNU General Public License
18  * along with GNU Radio; see the file COPYING.  If not, write to
19  * the Free Software Foundation, Inc., 51 Franklin Street,
20  * Boston, MA 02110-1301, USA.
21  */
22
23 #include <cstdio>
24 #include <string>
25 #include <iostream>
26 #include <fstream>
27 #include <stdexcept>
28 #include <cmath>
29 #include <stdlib.h>
30 #include "base.h"
31 #include "fsm.h"
32
33
34 fsm::fsm()
35 {
36   d_I=0;
37   d_S=0;
38   d_O=0;
39   d_NS.resize(0);
40   d_OS.resize(0);
41   d_PS.resize(0);
42   d_PI.resize(0);
43   d_TMi.resize(0);
44   d_TMl.resize(0);
45 }
46
47 fsm::fsm(const fsm &FSM)
48 {
49   d_I=FSM.I();
50   d_S=FSM.S();
51   d_O=FSM.O();
52   d_NS=FSM.NS();
53   d_OS=FSM.OS();
54   d_PS=FSM.PS(); // is this going to make a deep copy?
55   d_PI=FSM.PI();
56   d_TMi=FSM.TMi();
57   d_TMl=FSM.TMl();
58 }
59
60 fsm::fsm(int I, int S, int O, const std::vector<int> &NS, const std::vector<int> &OS)
61 {
62   d_I=I;
63   d_S=S;
64   d_O=O;
65   d_NS=NS;
66   d_OS=OS;
67  
68   generate_PS_PI();
69   generate_TM();
70 }
71
72 //######################################################################
73 //# Read an FSM specification from a file.
74 //# Format (hopefully will become more flexible in the future...):
75 //# I S O (in the first line)
76 //# blank line
77 //# Next state matrix (S lines, each with I integers separated by spaces)
78 //# blank line
79 //# output symbol matrix (S lines, each with I integers separated by spaces)
80 //# optional comments
81 //######################################################################
82 fsm::fsm(const char *name) 
83 {
84   FILE *fsmfile;
85
86   if((fsmfile=fopen(name,"r"))==NULL) 
87     throw std::runtime_error ("fsm::fsm(const char *name): file open error\n");
88     //printf("file open error in fsm()\n");
89   
90   fscanf(fsmfile,"%d %d %d\n",&d_I,&d_S,&d_O);
91   d_NS.resize(d_I*d_S);
92   d_OS.resize(d_I*d_S);
93
94   for(int i=0;i<d_S;i++) {
95     for(int j=0;j<d_I;j++) fscanf(fsmfile,"%d",&(d_NS[i*d_I+j]));
96   }
97   for(int i=0;i<d_S;i++) {
98     for(int j=0;j<d_I;j++) fscanf(fsmfile,"%d",&(d_OS[i*d_I+j]));
99   }
100  
101   generate_PS_PI();
102   generate_TM();
103 }
104
105
106
107 //######################################################################
108 //# Automatically generate the FSM from the generator matrix
109 //# of a (n,k) binary convolutional code
110 //######################################################################
111 fsm::fsm(int k, int n, const std::vector<int> &G)
112 {
113
114   // calculate maximum memory requirements for each input stream
115   std::vector<int> max_mem_x(k,-1);
116   int max_mem = -1;
117   for(int i=0;i<k;i++) {
118     for(int j=0;j<n;j++) {
119       int mem = -1;
120       if(G[i*n+j]!=0)
121         mem=(int)(log(G[i*n+j])/log(2.0));
122       if(mem>max_mem_x[i])
123         max_mem_x[i]=mem;
124       if(mem>max_mem)
125         max_mem=mem;
126     }
127   }
128   
129 //printf("max_mem_x\n");
130 //for(int j=0;j<max_mem_x.size();j++) printf("%d ",max_mem_x[j]); printf("\n");
131
132   // calculate total memory requirements to set S
133   int sum_max_mem = 0;
134   for(int i=0;i<k;i++)
135     sum_max_mem += max_mem_x[i];
136
137 //printf("sum_max_mem = %d\n",sum_max_mem);
138
139   d_I=1<<k;
140   d_S=1<<sum_max_mem;
141   d_O=1<<n;
142  
143   // binary representation of the G matrix
144   std::vector<std::vector<int> > Gb(k*n);
145   for(int j=0;j<k*n;j++) {
146     Gb[j].resize(max_mem+1);
147     dec2base(G[j],2,Gb[j]);
148 //printf("Gb\n");
149 //for(int m=0;m<Gb[j].size();m++) printf("%d ",Gb[j][m]); printf("\n");
150   }
151
152   // alphabet size of each shift register 
153   std::vector<int> bases_x(k);
154   for(int j=0;j<k ;j++) 
155     bases_x[j] = 1 << max_mem_x[j];
156 //printf("bases_x\n");
157 //for(int j=0;j<max_mem_x.size();j++) printf("%d ",max_mem_x[j]); printf("\n");
158
159   d_NS.resize(d_I*d_S);
160   d_OS.resize(d_I*d_S);
161
162   std::vector<int> sx(k);
163   std::vector<int> nsx(k);
164   std::vector<int> tx(k);
165   std::vector<std::vector<int> > tb(k);
166   for(int j=0;j<k;j++)
167     tb[j].resize(max_mem+1);
168   std::vector<int> inb(k);
169   std::vector<int> outb(n);
170
171
172   for(int s=0;s<d_S;s++) {
173     dec2bases(s,bases_x,sx); // split s into k values, each representing on of the k shift registers
174 //printf("state = %d \nstates = ",s);
175 //for(int j=0;j<sx.size();j++) printf("%d ",sx[j]); printf("\n");
176     for(int i=0;i<d_I;i++) {
177       dec2base(i,2,inb); // input in binary
178 //printf("input = %d \ninputs = ",i);
179 //for(int j=0;j<inb.size();j++) printf("%d ",inb[j]); printf("\n");
180
181       // evaluate next state
182       for(int j=0;j<k;j++)
183         nsx[j] = (inb[j]*bases_x[j]+sx[j])/2; // next state (for each shift register) MSB first
184       d_NS[s*d_I+i]=bases2dec(nsx,bases_x); // collect all values into the new state
185
186       // evaluate transitions
187       for(int j=0;j<k;j++)
188         tx[j] = inb[j]*bases_x[j]+sx[j]; // transition (for each shift register)MSB first
189       for(int j=0;j<k;j++) {
190         dec2base(tx[j],2,tb[j]); // transition in binary
191 //printf("transition = %d \ntransitions = ",tx[j]);
192 //for(int m=0;m<tb[j].size();m++) printf("%d ",tb[j][m]); printf("\n");
193       }
194
195       // evaluate outputs
196       for(int nn=0;nn<n;nn++) {
197         outb[nn] = 0;
198         for(int j=0;j<k;j++) {
199           for(int m=0;m<max_mem+1;m++)
200             outb[nn] = (outb[nn] + Gb[j*n+nn][m]*tb[j][m]) % 2; // careful: polynomial 1+D ir represented as 110, not as 011
201 //printf("output %d equals %d\n",nn,outb[nn]);
202         }
203       }
204       d_OS[s*d_I+i] = base2dec(outb,2);
205     }
206   }
207
208   generate_PS_PI();
209   generate_TM();
210 }
211
212
213
214
215 //######################################################################
216 //# Automatically generate an FSM specification describing the 
217 //# ISI for a channel
218 //# of length ch_length and a modulation of size mod_size
219 //######################################################################
220 fsm::fsm(int mod_size, int ch_length)
221 {
222   d_I=mod_size;
223   d_S=(int) (pow(1.0*d_I,1.0*ch_length-1)+0.5);
224   d_O=d_S*d_I;
225
226   d_NS.resize(d_I*d_S);
227   d_OS.resize(d_I*d_S);
228
229   for(int s=0;s<d_S;s++) {
230     for(int i=0;i<d_I;i++) { 
231       int t=i*d_S+s;
232       d_NS[s*d_I+i] = t/d_I;
233       d_OS[s*d_I+i] = t;
234     }
235   }
236  
237   generate_PS_PI();
238   generate_TM();
239 }
240
241
242 //######################################################################
243 //# Automatically generate an FSM specification describing the 
244 //# the joint trellis of fsm1 and fsm2
245 //######################################################################
246 fsm::fsm(const fsm &FSM1, const fsm &FSM2)
247 {
248   d_I=FSM1.I()*FSM2.I();
249   d_S=FSM1.S()*FSM2.S();
250   d_O=FSM1.O()*FSM2.O();
251
252   d_NS.resize(d_I*d_S);
253   d_OS.resize(d_I*d_S);
254
255   for(int s=0;s<d_S;s++) {
256     for(int i=0;i<d_I;i++) {
257       int s1=s/FSM2.S();
258       int s2=s%FSM2.S();
259       int i1=i/FSM2.I();
260       int i2=i%FSM2.I();
261       d_NS[s*d_I+i] = FSM1.NS()[s1 * FSM1.I() + i1] * FSM2.S() + FSM2.NS()[s2 * FSM2.I() + i2];
262       d_OS[s*d_I+i] = FSM1.OS()[s1 * FSM1.I() + i1] * FSM2.O() + FSM2.OS()[s2 * FSM2.I() + i2];
263     }
264   }
265
266   generate_PS_PI();
267   generate_TM();
268 }
269
270
271 //######################################################################
272 //# generate the PS and PI tables for later use
273 //######################################################################
274 void fsm::generate_PS_PI()
275 {
276   d_PS.resize(d_S);
277   d_PI.resize(d_S);
278
279   for(int i=0;i<d_S;i++) {
280     d_PS[i].resize(d_I*d_S); // max possible size
281     d_PI[i].resize(d_I*d_S);
282     int j=0;
283     for(int ii=0;ii<d_S;ii++) for(int jj=0;jj<d_I;jj++) {
284       if(d_NS[ii*d_I+jj]!=i) continue;
285       d_PS[i][j]=ii;
286       d_PI[i][j]=jj;
287       j++;
288     }
289     d_PS[i].resize(j);
290     d_PI[i].resize(j);
291   }
292 }
293
294
295 //######################################################################
296 //# generate the termination matrices TMl and TMi for later use
297 //######################################################################
298 void fsm::generate_TM()
299 {
300   d_TMi.resize(d_S*d_S);
301   d_TMl.resize(d_S*d_S);
302
303   for(int i=0;i<d_S*d_S;i++) {
304     d_TMi[i] = -1; // no meaning
305     d_TMl[i] = d_S; //infinity: you need at most S-1 steps
306     if (i/d_S == i%d_S)
307       d_TMl[i] = 0;
308   }
309
310   for(int s=0;s<d_S;s++) {
311     bool done = false;
312     int attempts = 0;
313     while (done == false && attempts < d_S-1) {
314       done = find_es(s);
315       attempts ++;
316     }
317     if (done == false) {
318       //throw std::runtime_error ("fsm::generate_TM(): FSM appears to be disconnected\n");
319       printf("fsm::generate_TM(): FSM appears to be disconnected\n");
320       printf("state %d cannot be reached from all other states\n",s);
321     }
322   }
323 }
324
325
326 // find a path from any state to the ending state "es"
327 bool fsm::find_es(int es)
328 {
329   bool done = true;
330   for(int s=0;s<d_S;s++) {
331     if(d_TMl[s*d_S+es] < d_S) 
332       continue;
333     int minl=d_S;
334     int mini=-1;
335     for(int i=0;i<d_I;i++) {
336       if( 1 + d_TMl[d_NS[s*d_I+i]*d_S+es] < minl) {
337         minl = 1 + d_TMl[d_NS[s*d_I+i]*d_S+es];
338         mini = i;
339       }
340     }
341     if (mini != -1) {
342       d_TMl[s*d_S+es]=minl;
343       d_TMi[s*d_S+es]=mini;
344     }
345     else
346       done = false;
347   }
348   return done;
349 }
350
351
352
353
354
355 //######################################################################
356 //#  generate trellis representation of FSM as an SVG file
357 //######################################################################
358 void fsm::write_trellis_svg( std::string filename ,int number_stages)
359 {
360    std::ofstream trellis_fname (filename.c_str());
361    if (!trellis_fname) {std::cout << "file not found " << std::endl ; exit(-1);}
362    const int TRELLIS_Y_OFFSET = 30;
363    const int TRELLIS_X_OFFSET = 20;
364    const int STAGE_LABEL_Y_OFFSET = 25;
365    const int STAGE_LABEL_X_OFFSET = 20;
366    const int STATE_LABEL_Y_OFFSET = 30;
367    const int STATE_LABEL_X_OFFSET = 5;
368    const int STAGE_STATE_OFFSETS = 10;
369 //   std::cout << "################## BEGIN SVG TRELLIS PIC #####################" << std::endl;
370    trellis_fname << "<svg viewBox = \"0 0 200 200\" version = \"1.1\">" << std::endl;
371
372     for( int stage_num = 0;stage_num < number_stages;stage_num ++){
373     // draw states
374       for ( int state_num = 0;state_num < d_S ; state_num ++ ) {
375         trellis_fname << "<circle cx = \"" << stage_num * STAGE_STATE_OFFSETS + TRELLIS_X_OFFSET << 
376         "\" cy = \"" << state_num * STAGE_STATE_OFFSETS + TRELLIS_Y_OFFSET << "\" r = \"1\"/>" << std::endl;
377       //draw branches
378         if(stage_num != number_stages-1){
379           for( int branch_num = 0;branch_num < d_I; branch_num++){
380             trellis_fname << "<line x1 =\"" << STAGE_STATE_OFFSETS * stage_num+ TRELLIS_X_OFFSET  << "\" ";
381             trellis_fname << "y1 =\"" << state_num * STAGE_STATE_OFFSETS + TRELLIS_Y_OFFSET<< "\" ";
382             trellis_fname << "x2 =\"" <<  STAGE_STATE_OFFSETS *stage_num + STAGE_STATE_OFFSETS+ TRELLIS_X_OFFSET << "\" ";
383             trellis_fname << "y2 =\"" << d_NS[d_I * state_num + branch_num] * STAGE_STATE_OFFSETS + TRELLIS_Y_OFFSET << "\" ";
384             trellis_fname << " stroke-dasharray = \"3," <<  branch_num << "\" ";
385             trellis_fname << " stroke = \"black\" stroke-width = \"0.3\"/>" << std::endl;
386           }
387         }
388       }
389     }
390   // label the stages
391   trellis_fname << "<g font-size = \"4\" font= \"times\" fill = \"black\">" << std::endl;
392   for( int stage_num = 0;stage_num < number_stages ;stage_num ++){
393     trellis_fname << "<text x = \"" << stage_num * STAGE_STATE_OFFSETS + STAGE_LABEL_X_OFFSET << 
394       "\" y = \""  << STAGE_LABEL_Y_OFFSET  << "\" >" << std::endl;
395     trellis_fname << stage_num <<  std::endl;
396     trellis_fname << "</text>" << std::endl;
397   }
398   trellis_fname << "</g>" << std::endl;
399
400   // label the states
401   trellis_fname << "<g font-size = \"4\" font= \"times\" fill = \"black\">" << std::endl;
402   for( int state_num = 0;state_num < d_S ; state_num ++){
403     trellis_fname << "<text y = \"" << state_num * STAGE_STATE_OFFSETS + STATE_LABEL_Y_OFFSET << 
404       "\" x = \""  << STATE_LABEL_X_OFFSET  << "\" >" << std::endl;
405     trellis_fname << state_num <<  std::endl;
406     trellis_fname << "</text>" << std::endl;
407   }
408   trellis_fname << "</g>" << std::endl;
409
410
411   trellis_fname << "</svg>" << std::endl;
412 //  std::cout << "################## END SVG TRELLIS PIC ##################### " << std::endl;
413   trellis_fname.close();
414 }
415
416
417
418
419
420
421 //######################################################################
422 //# Write trellis specification to a text files,
423 //# in the same format used when reading FSM files
424 //######################################################################
425 void fsm::write_fsm_txt(std::string filename)
426 {
427    std::ofstream trellis_fname (filename.c_str());
428    if (!trellis_fname) {std::cout << "file not found " << std::endl ; exit(-1);}
429    trellis_fname << d_I << ' ' << d_S << ' ' << d_O << std::endl;
430    trellis_fname << std::endl;
431    for(int i=0;i<d_S;i++) {
432      for(int j=0;j<d_I;j++)  trellis_fname << d_NS[i*d_I+j] << ' ';
433      trellis_fname << std::endl;
434    }
435    trellis_fname << std::endl;
436    for(int i=0;i<d_S;i++) {
437      for(int j=0;j<d_I;j++) trellis_fname << d_OS[i*d_I+j] << ' ';
438      trellis_fname << std::endl;
439    }
440    trellis_fname << std::endl;
441    trellis_fname.close();
442 }
443