Revision 14e5c21e streaming.c

View differences:

streaming.c
259 259
  res = decodeChunk(&c, buff + 1, len - 1);
260 260
  if (res > 0) {
261 261
    chunk_attributes_update_received(&c);
262
    reg_chunk_receive(c.id, c.timestamp, chunk_get_hopcount(&c));
263 262
    chunk_unlock(c.id);
264 263
    dprintf("Received chunk %d from peer: %s\n", c.id, node_addr(from));
265 264
    if(chunk_log){fprintf(stderr, "TEO: Received chunk %d from peer: %s at: %lld hopcount: %i\n", c.id, node_addr(from), gettimeofday_in_us(), chunk_get_hopcount(&c));}
266 265
    output_deliver(&c);
267 266
    res = cb_add_chunk(cb, &c);
267
    reg_chunk_receive(c.id, c.timestamp, chunk_get_hopcount(&c), res==E_CB_OLD, res==E_CB_DUPLICATE);
268 268
    cb_print();
269 269
    if (res < 0) {
270 270
      dprintf("\tchunk too old, buffer full with newer chunks\n");

Also available in: Unified diff