• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  *  Copyright (c) 2011 The WebRTC project authors. All Rights Reserved.
3  *
4  *  Use of this source code is governed by a BSD-style license
5  *  that can be found in the LICENSE file in the root of the source
6  *  tree. An additional intellectual property rights grant can be found
7  *  in the file PATENTS.  All contributing project authors may
8  *  be found in the AUTHORS file in the root of the source tree.
9  */
10 
11 /*
12  * arith_routinslogist.c
13  *
14  * This C file contains arithmetic encode and decode logistic
15  *
16  */
17 
18 #include "arith_routins.h"
19 
20 /* Tables for piecewise linear cdf functions: y = k*x */
21 
22 /* x Points for function piecewise() in Q15 */
23 static const int32_t kHistEdges[51] = {
24   -327680, -314573, -301466, -288359, -275252, -262144, -249037, -235930, -222823, -209716,
25   -196608, -183501, -170394, -157287, -144180, -131072, -117965, -104858,  -91751,  -78644,
26   -65536,  -52429,  -39322,  -26215,  -13108,       0,   13107,   26214,   39321,   52428,
27   65536,   78643,   91750,  104857,  117964,  131072,  144179,  157286,  170393,  183500,
28   196608,  209715,  222822,  235929,  249036,  262144,  275251,  288358,  301465,  314572,
29   327680
30 };
31 
32 
33 /* k Points for function piecewise() in Q0 */
34 static const uint16_t kCdfSlope[51] = {
35   5,    5,     5,     5,     5,     5,     5,     5,    5,    5,
36   5,    5,    13,    23,    47,    87,   154,   315,  700, 1088,
37   2471, 6064, 14221, 21463, 36634, 36924, 19750, 13270, 5806, 2312,
38   1095,  660,   316,   145,    86,    41,    32,     5,    5,    5,
39   5,    5,     5,     5,     5,     5,     5,     5,    5,    2,
40   0
41 };
42 
43 /* y Points for function piecewise() in Q0 */
44 static const uint16_t kCdfLogistic[51] = {
45   0,     2,     4,     6,     8,    10,    12,    14,    16,    18,
46   20,    22,    24,    29,    38,    57,    92,   153,   279,   559,
47   994,  1983,  4408, 10097, 18682, 33336, 48105, 56005, 61313, 63636,
48   64560, 64998, 65262, 65389, 65447, 65481, 65497, 65510, 65512, 65514,
49   65516, 65518, 65520, 65522, 65524, 65526, 65528, 65530, 65532, 65534,
50   65535
51 };
52 
53 
54 /****************************************************************************
55  * WebRtcIsacfix_Piecewise(...)
56  *
57  * Piecewise linear function
58  *
59  * Input:
60  *      - xinQ15           : input value x in Q15
61  *
62  * Return value            : korresponding y-value in Q0
63  */
64 
65 
WebRtcIsacfix_Piecewise(int32_t xinQ15)66 static __inline uint16_t WebRtcIsacfix_Piecewise(int32_t xinQ15) {
67   int32_t ind;
68   int32_t qtmp1;
69   uint16_t qtmp2;
70 
71   /* Find index for x-value */
72   qtmp1 = WEBRTC_SPL_SAT(kHistEdges[50],xinQ15,kHistEdges[0]);
73   ind = WEBRTC_SPL_MUL(5, qtmp1 - kHistEdges[0]);
74   ind >>= 16;
75 
76   /* Calculate corresponding y-value ans return*/
77   qtmp1 = qtmp1 - kHistEdges[ind];
78   qtmp2 = (uint16_t)WEBRTC_SPL_RSHIFT_U32(
79       WEBRTC_SPL_UMUL_32_16(qtmp1,kCdfSlope[ind]), 15);
80   return (kCdfLogistic[ind] + qtmp2);
81 }
82 
83 /****************************************************************************
84  * WebRtcIsacfix_EncLogisticMulti2(...)
85  *
86  * Arithmetic coding of spectrum.
87  *
88  * Input:
89  *      - streamData        : in-/output struct containing bitstream
90  *      - dataQ7            : data vector in Q7
91  *      - envQ8             : side info vector defining the width of the pdf
92  *                            in Q8
93  *      - lenData           : data vector length
94  *
95  * Return value             :  0 if ok,
96  *                            <0 otherwise.
97  */
WebRtcIsacfix_EncLogisticMulti2(Bitstr_enc * streamData,int16_t * dataQ7,const uint16_t * envQ8,const int16_t lenData)98 int WebRtcIsacfix_EncLogisticMulti2(Bitstr_enc *streamData,
99                                    int16_t *dataQ7,
100                                    const uint16_t *envQ8,
101                                    const int16_t lenData)
102 {
103   uint32_t W_lower;
104   uint32_t W_upper;
105   uint16_t W_upper_LSB;
106   uint16_t W_upper_MSB;
107   uint16_t *streamPtr;
108   uint16_t *maxStreamPtr;
109   uint16_t *streamPtrCarry;
110   uint16_t negcarry;
111   uint32_t cdfLo;
112   uint32_t cdfHi;
113   int k;
114 
115   /* point to beginning of stream buffer
116    * and set maximum streamPtr value */
117   streamPtr = streamData->stream + streamData->stream_index;
118   maxStreamPtr = streamData->stream + STREAM_MAXW16_60MS - 1;
119   W_upper = streamData->W_upper;
120 
121   for (k = 0; k < lenData; k++)
122   {
123     /* compute cdf_lower and cdf_upper by evaluating the
124      * WebRtcIsacfix_Piecewise linear cdf */
125     cdfLo = WebRtcIsacfix_Piecewise(WEBRTC_SPL_MUL_16_U16(*dataQ7 - 64, *envQ8));
126     cdfHi = WebRtcIsacfix_Piecewise(WEBRTC_SPL_MUL_16_U16(*dataQ7 + 64, *envQ8));
127 
128     /* test and clip if probability gets too small */
129     while ((cdfLo + 1) >= cdfHi) {
130       /* clip */
131       if (*dataQ7 > 0) {
132         *dataQ7 -= 128;
133         cdfHi = cdfLo;
134         cdfLo = WebRtcIsacfix_Piecewise(
135             WEBRTC_SPL_MUL_16_U16(*dataQ7 - 64, *envQ8));
136       } else {
137         *dataQ7 += 128;
138         cdfLo = cdfHi;
139         cdfHi = WebRtcIsacfix_Piecewise(
140             WEBRTC_SPL_MUL_16_U16(*dataQ7 + 64, *envQ8));
141       }
142     }
143 
144     dataQ7++;
145     /* increment only once per 4 iterations */
146     envQ8 += (k & 1) & (k >> 1);
147 
148 
149     /* update interval */
150     W_upper_LSB = (uint16_t)W_upper;
151     W_upper_MSB = (uint16_t)WEBRTC_SPL_RSHIFT_U32(W_upper, 16);
152     W_lower = WEBRTC_SPL_UMUL_32_16(cdfLo, W_upper_MSB);
153     W_lower += (cdfLo * W_upper_LSB) >> 16;
154     W_upper = WEBRTC_SPL_UMUL_32_16(cdfHi, W_upper_MSB);
155     W_upper += (cdfHi * W_upper_LSB) >> 16;
156 
157     /* shift interval such that it begins at zero */
158     W_upper -= ++W_lower;
159 
160     /* add integer to bitstream */
161     streamData->streamval += W_lower;
162 
163     /* handle carry */
164     if (streamData->streamval < W_lower)
165     {
166       /* propagate carry */
167       streamPtrCarry = streamPtr;
168       if (streamData->full == 0) {
169         negcarry = *streamPtrCarry;
170         negcarry += 0x0100;
171         *streamPtrCarry = negcarry;
172         while (!(negcarry))
173         {
174           negcarry = *--streamPtrCarry;
175           negcarry++;
176           *streamPtrCarry = negcarry;
177         }
178       } else {
179         while (!(++(*--streamPtrCarry)));
180       }
181     }
182 
183     /* renormalize interval, store most significant byte of streamval and update streamval
184      * W_upper < 2^24 */
185     while ( !(W_upper & 0xFF000000) )
186     {
187       W_upper <<= 8;
188       if (streamData->full == 0) {
189         *streamPtr++ += (uint16_t) WEBRTC_SPL_RSHIFT_U32(
190             streamData->streamval, 24);
191         streamData->full = 1;
192       } else {
193         *streamPtr = (uint16_t)((streamData->streamval >> 24) << 8);
194         streamData->full = 0;
195       }
196 
197       if( streamPtr > maxStreamPtr )
198         return -ISAC_DISALLOWED_BITSTREAM_LENGTH;
199 
200       streamData->streamval <<= 8;
201     }
202   }
203 
204   /* calculate new stream_index */
205   streamData->stream_index = streamPtr - streamData->stream;
206   streamData->W_upper = W_upper;
207 
208   return 0;
209 }
210 
211 
212 /****************************************************************************
213  * WebRtcIsacfix_DecLogisticMulti2(...)
214  *
215  * Arithmetic decoding of spectrum.
216  *
217  * Input:
218  *      - streamData        : in-/output struct containing bitstream
219  *      - envQ8             : side info vector defining the width of the pdf
220  *                            in Q8
221  *      - lenData           : data vector length
222  *
223  * Input/Output:
224  *      - dataQ7            : input: dither vector, output: data vector
225  *
226  * Return value             : number of bytes in the stream so far
227  *                            -1 if error detected
228  */
WebRtcIsacfix_DecLogisticMulti2(int16_t * dataQ7,Bitstr_dec * streamData,const int32_t * envQ8,const int16_t lenData)229 int WebRtcIsacfix_DecLogisticMulti2(int16_t *dataQ7,
230                                     Bitstr_dec *streamData,
231                                     const int32_t *envQ8,
232                                     const int16_t lenData)
233 {
234   uint32_t    W_lower;
235   uint32_t    W_upper;
236   uint32_t    W_tmp;
237   uint16_t    W_upper_LSB;
238   uint16_t    W_upper_MSB;
239   uint32_t    streamVal;
240   uint16_t    cdfTmp;
241   int32_t     res;
242   int32_t     inSqrt;
243   int32_t     newRes;
244   const uint16_t *streamPtr;
245   int16_t     candQ7;
246   int16_t     envCount;
247   uint16_t    tmpARSpecQ8 = 0;
248   int             k, i;
249   int offset = 0;
250 
251   /* point to beginning of stream buffer */
252   streamPtr = streamData->stream + streamData->stream_index;
253   W_upper = streamData->W_upper;
254 
255   /* Check if it is first time decoder is called for this stream */
256   if (streamData->stream_index == 0)
257   {
258     /* read first word from bytestream */
259     streamVal = (uint32_t)(*streamPtr++) << 16;
260     streamVal |= *streamPtr++;
261 
262   } else {
263     streamVal = streamData->streamval;
264   }
265 
266 
267   res = 1 << (WebRtcSpl_GetSizeInBits(envQ8[0]) >> 1);
268   envCount = 0;
269 
270   /* code assumes lenData%4 == 0 */
271   for (k = 0; k < lenData; k += 4)
272   {
273     int k4;
274 
275     /* convert to magnitude spectrum, by doing square-roots (modified from SPLIB) */
276     inSqrt = envQ8[envCount];
277     i = 10;
278 
279     /* For safty reasons */
280     if (inSqrt < 0)
281       inSqrt=-inSqrt;
282 
283     newRes = (inSqrt / res + res) >> 1;
284     do
285     {
286       res = newRes;
287       newRes = (inSqrt / res + res) >> 1;
288     } while (newRes != res && i-- > 0);
289 
290     tmpARSpecQ8 = (uint16_t)newRes;
291 
292     for(k4 = 0; k4 < 4; k4++)
293     {
294       /* find the integer *data for which streamVal lies in [W_lower+1, W_upper] */
295       W_upper_LSB = (uint16_t) (W_upper & 0x0000FFFF);
296       W_upper_MSB = (uint16_t) WEBRTC_SPL_RSHIFT_U32(W_upper, 16);
297 
298       /* find first candidate by inverting the logistic cdf
299        * Input dither value collected from io-stream */
300       candQ7 = - *dataQ7 + 64;
301       cdfTmp = WebRtcIsacfix_Piecewise(WEBRTC_SPL_MUL_16_U16(candQ7, tmpARSpecQ8));
302 
303       W_tmp = (uint32_t)cdfTmp * W_upper_MSB;
304       W_tmp += ((uint32_t)cdfTmp * (uint32_t)W_upper_LSB) >> 16;
305 
306       if (streamVal > W_tmp)
307       {
308         W_lower = W_tmp;
309         candQ7 += 128;
310         cdfTmp = WebRtcIsacfix_Piecewise(WEBRTC_SPL_MUL_16_U16(candQ7, tmpARSpecQ8));
311 
312         W_tmp = (uint32_t)cdfTmp * W_upper_MSB;
313         W_tmp += ((uint32_t)cdfTmp * (uint32_t)W_upper_LSB) >> 16;
314 
315         while (streamVal > W_tmp)
316         {
317           W_lower = W_tmp;
318           candQ7 += 128;
319           cdfTmp = WebRtcIsacfix_Piecewise(
320               WEBRTC_SPL_MUL_16_U16(candQ7, tmpARSpecQ8));
321 
322           W_tmp = (uint32_t)cdfTmp * W_upper_MSB;
323           W_tmp += ((uint32_t)cdfTmp * (uint32_t)W_upper_LSB) >> 16;
324 
325           /* error check */
326           if (W_lower == W_tmp) {
327             return -1;
328           }
329         }
330         W_upper = W_tmp;
331 
332         /* Output value put in dataQ7: another sample decoded */
333         *dataQ7 = candQ7 - 64;
334       }
335       else
336       {
337         W_upper = W_tmp;
338         candQ7 -= 128;
339         cdfTmp = WebRtcIsacfix_Piecewise(WEBRTC_SPL_MUL_16_U16(candQ7, tmpARSpecQ8));
340 
341         W_tmp = (uint32_t)cdfTmp * W_upper_MSB;
342         W_tmp += ((uint32_t)cdfTmp * (uint32_t)W_upper_LSB) >> 16;
343 
344         while ( !(streamVal > W_tmp) )
345         {
346           W_upper = W_tmp;
347           candQ7 -= 128;
348           cdfTmp = WebRtcIsacfix_Piecewise(
349               WEBRTC_SPL_MUL_16_U16(candQ7, tmpARSpecQ8));
350 
351           W_tmp = (uint32_t)cdfTmp * W_upper_MSB;
352           W_tmp += ((uint32_t)cdfTmp * (uint32_t)W_upper_LSB) >> 16;
353 
354           /* error check */
355           if (W_upper == W_tmp){
356             return -1;
357           }
358         }
359         W_lower = W_tmp;
360 
361         /* Output value put in dataQ7: another sample decoded */
362         *dataQ7 = candQ7 + 64;
363       }
364 
365       dataQ7++;
366 
367       /* shift interval to start at zero */
368       W_upper -= ++W_lower;
369 
370       /* add integer to bitstream */
371       streamVal -= W_lower;
372 
373       /* renormalize interval and update streamVal
374        * W_upper < 2^24 */
375       while ( !(W_upper & 0xFF000000) )
376       {
377         if (streamPtr < streamData->stream + streamData->stream_size) {
378           /* read next byte from stream */
379           if (streamData->full == 0) {
380             streamVal = (streamVal << 8) | (*streamPtr++ & 0x00FF);
381             streamData->full = 1;
382           } else {
383             streamVal = (streamVal << 8) | (*streamPtr >> 8);
384             streamData->full = 0;
385           }
386         } else {
387           /* Intending to read outside the stream. This can happen for the last
388            * two or three bytes. It is how the algorithm is implemented. Do
389            * not read from the bit stream and insert zeros instead. */
390           streamVal <<= 8;
391           if (streamData->full == 0) {
392             offset++;  // We would have incremented the pointer in this case.
393             streamData->full = 1;
394           } else {
395             streamData->full = 0;
396           }
397         }
398         W_upper <<= 8;
399       }
400     }
401     envCount++;
402   }
403 
404   streamData->stream_index = streamPtr + offset - streamData->stream;
405   streamData->W_upper = W_upper;
406   streamData->streamval = streamVal;
407 
408   /* find number of bytes in original stream (determined by current interval width) */
409   if ( W_upper > 0x01FFFFFF )
410     return (streamData->stream_index*2 - 3 + !streamData->full);
411   else
412     return (streamData->stream_index*2 - 2 + !streamData->full);
413 }
414