Lines Matching refs:send
1313 p->barrier = connection->send.current_epoch_nr; in drbd_send_barrier()
1315 connection->send.current_epoch_writes = 0; in drbd_send_barrier()
1336 if (!connection->send.seen_any_write_yet) { in re_init_if_first_write()
1337 connection->send.seen_any_write_yet = true; in re_init_if_first_write()
1338 connection->send.current_epoch_nr = epoch; in re_init_if_first_write()
1339 connection->send.current_epoch_writes = 0; in re_init_if_first_write()
1346 if (!connection->send.seen_any_write_yet) in maybe_send_barrier()
1348 if (connection->send.current_epoch_nr != epoch) { in maybe_send_barrier()
1349 if (connection->send.current_epoch_writes) in maybe_send_barrier()
1351 connection->send.current_epoch_nr = epoch; in maybe_send_barrier()
1402 connection->send.current_epoch_writes++; in w_send_dblock()
2049 connection->send.current_epoch_nr; in wait_for_work()
2054 connection->send.current_epoch_nr + 1); in wait_for_work()