Searched refs:records_sent (Results 1 – 10 of 10) sorted by relevance
158 int records_sent = 0; in RunDoPutTest() local160 while (records_sent < total_records) { in RunDoPutTest()161 if (records_sent + length > total_records) { in RunDoPutTest()162 const int last_length = total_records - records_sent; in RunDoPutTest()167 records_sent += last_length; in RunDoPutTest()173 records_sent += length; in RunDoPutTest()
205 int64_t records_sent = 0; in RunDoPutTest() local208 while (records_sent < total_records) { in RunDoPutTest()209 if (records_sent + length > total_records) { in RunDoPutTest()210 const int last_length = total_records - records_sent; in RunDoPutTest()215 records_sent += last_length; in RunDoPutTest()223 records_sent += length; in RunDoPutTest()
214 int64_t records_sent = 0; in GetPutData() local215 while (records_sent < total_records) { in GetPutData()216 if (records_sent + length > total_records) { in GetPutData()217 const int last_length = total_records - records_sent; in GetPutData()221 records_sent += last_length; in GetPutData()225 records_sent += length; in GetPutData()
58 int records_sent; member
335 buf->records_processed, buf->records_sent, ctx->delivery_stream);
381 buf->records_sent += i; in send_log_events()
345 buf->records_processed, buf->records_sent, ctx->stream_name); in cb_kinesis_flush()
447 buf->records_sent += i; in send_log_events()
64 int records_sent; member154 h->records_sent++; in ctdb_traverse_local_fn()238 res = -(h->records_sent); in ctdb_traverse_local()240 res = h->records_sent; in ctdb_traverse_local()