261             long r_delta = streamDelta;

   261             long r_delta = streamDelta;

   262             r_delta += delta;

   262             r_delta += delta;

   263             if (r_delta >= r_period) {

   263             if (r_delta >= r_period) {

   264                 r_delta = 0;

   264                 r_delta = 0;

   265                 MetadataRepository.getInstance().flush();

   265                 MetadataRepository.getInstance().flush();

   266             }

   267             }

   267             long left = (r_period - r_delta);

   268             long left = (r_period - r_delta);

   268             if (left < 0) {

   269             if (left < 0) {

   269                 left = 0;

   270                 left = 0;

   270             }

   271             }