Lines Matching refs:peer_seq
874 device->peer_seq = 0; in drbd_connected()
2016 static void update_peer_seq(struct drbd_peer_device *peer_device, unsigned int peer_seq) in update_peer_seq() argument
2023 newest_peer_seq = seq_max(device->peer_seq, peer_seq); in update_peer_seq()
2024 device->peer_seq = newest_peer_seq; in update_peer_seq()
2027 if (peer_seq == newest_peer_seq) in update_peer_seq()
2077 static int wait_for_and_update_peer_seq(struct drbd_peer_device *peer_device, const u32 peer_seq) in wait_for_and_update_peer_seq() argument
2089 if (!seq_greater(peer_seq - 1, device->peer_seq)) { in wait_for_and_update_peer_seq()
2090 device->peer_seq = seq_max(device->peer_seq, peer_seq); in wait_for_and_update_peer_seq()
2278 u32 peer_seq = be32_to_cpu(p->seq_num); in receive_Data() local
2291 err = wait_for_and_update_peer_seq(peer_device, peer_seq); in receive_Data()
2373 err = wait_for_and_update_peer_seq(peer_device, peer_seq); in receive_Data()
2387 update_peer_seq(peer_device, peer_seq); in receive_Data()