… | |
… | |
233 | |
233 | |
234 | int ACC (RW, rate_avail); // current rate balance |
234 | int ACC (RW, rate_avail); // current rate balance |
235 | int ACC (RW, max_rate); // max. # of bytes to send per tick |
235 | int ACC (RW, max_rate); // max. # of bytes to send per tick |
236 | faceidx ACC (RW, scrub_idx); // which face to send next |
236 | faceidx ACC (RW, scrub_idx); // which face to send next |
237 | int ACC (RW, bg_scrub); // how many ticks till the next background face send |
237 | int ACC (RW, bg_scrub); // how many ticks till the next background face send |
|
|
238 | |
|
|
239 | faceidx partial_face; |
|
|
240 | uint32 partial_face_ofs; // if != 0, need to send remaining bytes of partial_face |
238 | std::vector<faceidx> askface; // which faces have been requested by the client |
241 | std::vector<faceidx, slice_allocator<faceidx> > askface; // which faces have been requested by the client |
|
|
242 | |
|
|
243 | std::vector<faceidx, slice_allocator<faceidx> > fxface; // which faces to send using fx |
|
|
244 | MTH void flush_fx (); // send fx if required |
239 | |
245 | |
240 | void do_destroy (); |
246 | void do_destroy (); |
241 | void gather_callbacks (AV *&callbacks, event_type event) const; |
247 | void gather_callbacks (AV *&callbacks, event_type event) const; |
242 | |
248 | |
243 | iow socket_ev; void socket_cb (iow &w, int got); |
249 | iow socket_ev; void socket_cb (iow &w, int got); |