ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/Algorithm-FEC/FEC.xs
(Generate patch)

Comparing Algorithm-FEC/FEC.xs (file contents):
Revision 1.4 by root, Sat Sep 13 20:35:49 2003 UTC vs.
Revision 1.6 by root, Sat Sep 13 21:16:33 2003 UTC

… …
26 26
27 void **b_addr; 27 void **b_addr;
28 void **b_mmap; 28 void **b_mmap;
29 int *b_sz; 29 int *b_sz;
30 SV **b_sv; 30 SV **b_sv;
31 int *idx; /* the decoding indices */
31} *Algorithm__FEC; 32} *Algorithm__FEC;
32 33
33static void 34static void
34chk_array (SV *sv, int size, const char *func, const char *var) 35chk_array (SV *sv, int size, const char *func, const char *var)
35{ 36{
… …
53 54
54 Safefree (self->b_addr); self->b_addr = 0; 55 Safefree (self->b_addr); self->b_addr = 0;
55 Safefree (self->b_mmap); self->b_mmap = 0; 56 Safefree (self->b_mmap); self->b_mmap = 0;
56 Safefree (self->b_sz ); self->b_sz = 0; 57 Safefree (self->b_sz ); self->b_sz = 0;
57 Safefree (self->b_sv ); self->b_sv = 0; 58 Safefree (self->b_sv ); self->b_sv = 0;
59 Safefree (self->idx ); self->idx = 0;
58} 60}
59 61
60static void 62static void
61realloc_files (struct state *self) 63realloc_files (struct state *self)
62{ 64{
… …
179 RETVAL->ep = encoded_packets; 181 RETVAL->ep = encoded_packets;
180 OUTPUT: 182 OUTPUT:
181 RETVAL 183 RETVAL
182 184
183void 185void
184set_blocks (self, blocks) 186set_encode_blocks (self, blocks)
185 Algorithm::FEC self 187 Algorithm::FEC self
186 SV * blocks 188 SV * blocks
187 CODE: 189 CODE:
188 190
189 free_files (self); 191 free_files (self);
190 192
191 if (SvOK (blocks)) 193 if (SvOK (blocks))
192 { 194 {
193 chk_array (blocks, self->dp, "encode", "blocks"); 195 chk_array (blocks, self->dp, "set_encode_blocks", "blocks");
194 open_files (self, (AV *)SvRV (blocks), 0); 196 open_files (self, (AV *)SvRV (blocks), 0);
195 } 197 }
196 198
197SV * 199SV *
198encode (self, block_index) 200encode (self, block_index)
… …
203 if (block_index < 0 || self->ep <= block_index) 205 if (block_index < 0 || self->ep <= block_index)
204 croak ("encode: block_index %d out of range, must be 0 <= block_index < %d", 206 croak ("encode: block_index %d out of range, must be 0 <= block_index < %d",
205 block_index, self->ep); 207 block_index, self->ep);
206 208
207 if (!self->b_addr) 209 if (!self->b_addr)
208 croak ("no blocks specified by a preceding call to set_blocks"); 210 croak ("no blocks specified by a preceding call to set_encode_blocks");
209 211
210 force_addrs (self, self->dp); 212 force_addrs (self, self->dp);
211 213
212 RETVAL = newSV (self->sz); 214 RETVAL = newSV (self->sz);
213 if (!RETVAL) 215 if (!RETVAL)
214 croak ("unable to allocate result block (out of memory)"); 216 croak ("unable to allocate result block (out of memory)");
217
215 SvPOK_only (RETVAL); 218 SvPOK_only (RETVAL);
216 SvCUR_set (RETVAL, self->sz); 219 SvCUR_set (RETVAL, self->sz);
217 220
218 self->imp->fec_encode (self->code, self->b_addr, 221 self->imp->fec_encode (self->code, self->b_addr,
219 SvPVX (RETVAL), block_index, self->sz); 222 SvPVX (RETVAL), block_index, self->sz);
220 223
221 OUTPUT: 224 OUTPUT:
222 RETVAL 225 RETVAL
223 226
224void 227void
225decode (self, blocks, indices) 228set_decode_blocks (self, blocks, indices)
226 Algorithm::FEC self 229 Algorithm::FEC self
227 SV * blocks 230 SV * blocks
228 SV * indices 231 SV * indices
229 CODE: 232 CODE:
230{ 233{
231 int i; 234 int i;
232 int *idx; 235 int *idx;
233 236
234 chk_array (blocks, self->dp, "decode", "blocks"); 237 chk_array (blocks, self->dp, "set_decode_blocks", "blocks");
235 chk_array (indices, self->dp, "decode", "indices"); 238 chk_array (indices, self->dp, "set_decode_blocks", "indices");
236 open_files (self, (AV *)SvRV (blocks), 1);
237
238 force_addrs (self, self->dp);
239 239
240 Newz (0, idx, self->dp, int); 240 Newz (0, idx, self->dp, int);
241 241
242 /* copy and check */ 242 /* copy and check */
243 for (i = 0; i < self->dp; i++) 243 for (i = 0; i < self->dp; i++)
244 { 244 {
245 SV *a = *av_fetch ((AV *)SvRV (indices), i, 1); 245 idx[i] = SvIV (*av_fetch ((AV *)SvRV (indices), i, 1));
246 idx[i] = SvIV (a);
247 sv_setiv (a, i);
248 246
249 if (idx[i] < 0 || idx[i] >= self->ep) 247 if (idx[i] < 0 || idx[i] >= self->ep)
250 { 248 {
251 Safefree (idx); 249 Safefree (idx);
252 croak ("index %d in array out of bounds (0 <= %d < %d != true)", 250 croak ("index %d in array out of bounds (0 <= %d < %d != true)",
… …
259 * so we know the order. 257 * so we know the order.
260 */ 258 */
261 for (i = 0; i < self->dp; i++) 259 for (i = 0; i < self->dp; i++)
262 while (idx[i] < self->dp && idx[i] != i) 260 while (idx[i] < self->dp && idx[i] != i)
263 { 261 {
264 SV **a, **b; 262 SV **a, **b, **e, **f;
265 int d; 263 int d;
266 void *p; 264 void *p;
267 SV *s; 265 SV *s;
268 int c = idx[i]; 266 int j = idx[i];
269 267
270 if (idx[c] == c) 268 if (idx[j] == j)
271 { 269 {
272 Safefree (idx); 270 Safefree (idx);
273 croak ("error while shuffling, duplicate indices? (idx[i]%d i%d idx[c]%d c%d", idx[i],i,idx[c],c); 271 croak ("error while shuffling, duplicate indices?");
274 } 272 }
275 273
276 a = av_fetch ((AV *)SvRV (indices), i, 1); 274 a = av_fetch ((AV *)SvRV (indices), i, 1);
277 b = av_fetch ((AV *)SvRV (indices), c, 1); 275 b = av_fetch ((AV *)SvRV (indices), j, 1);
276 e = av_fetch ((AV *)SvRV (blocks ), i, 1);
277 f = av_fetch ((AV *)SvRV (blocks ), j, 1);
278 278
279 d = idx[i]; idx[i] = idx[c]; idx[c] = d; 279 d = idx[i]; idx[i] = idx[j]; idx[j] = d;
280 p = self->b_addr[i]; self->b_addr[i] = self->b_addr[c]; self->b_addr[c] = p;
281 s = *a; *a = *b; *b = s; 280 s = *a; *a = *b; *b = s;
281 s = *e; *e = *f; *f = s;
282 } 282 }
283 283
284 open_files (self, (AV *)SvRV (blocks), 1);
285 self->idx = idx;
286}
287
288void
289decode (self)
290 Algorithm::FEC self
291 CODE:
292
293 if (!self->idx)
294 croak ("index array must be set by a prior call to set_decode_blocks");
295
296 force_addrs (self, self->dp);
284 self->imp->fec_decode (self->code, self->b_addr, idx, self->sz); 297 self->imp->fec_decode (self->code, self->b_addr, self->idx, self->sz);
285
286 Safefree (idx);
287
288 free_files (self); 298 free_files (self);
289}
290 299
291void 300void
292copy (self, srcblock, dstblock) 301copy (self, srcblock, dstblock)
293 Algorithm::FEC self 302 Algorithm::FEC self
294 SV * srcblock 303 SV * srcblock

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines