PeerStreamer

  void *data;

  int size;

  int id;

};

static struct outbuf *buff;

  buff[i].data = NULL;

  dprintf("Next Chunk: %d -> %d\n", next_chunk, buff[i].id + 1);

#ifdef MONL

#endif

  next_chunk = buff[i].id + 1;

}

        buffer_free(i % buff_size);

      } else {

#ifdef MONL

#endif

        next_chunk++;

      }

    dprintf("\tOut Chunk[%d] - %d: %s\n", c->id, c->id % buff_size, c->data);

    chunk_write(c->id, c->data, c->size);

#ifdef MONL

#endif

    next_chunk++;

    buffer_flush(next_chunk);

    memcpy(buff[c->id % buff_size].data, c->data, c->size);

    buff[c->id % buff_size].size = c->size;

    buff[c->id % buff_size].id = c->id;

  }

}