Searched refs:peer_seq (Results 1 - 2 of 2) sorted by relevance

/linux-4.4.14/drivers/block/drbd/
H A Ddrbd_receiver.c875 device->peer_seq = 0; drbd_connected()
2017 static void update_peer_seq(struct drbd_peer_device *peer_device, unsigned int peer_seq) update_peer_seq() argument
2024 newest_peer_seq = seq_max(device->peer_seq, peer_seq); update_peer_seq()
2025 device->peer_seq = newest_peer_seq; update_peer_seq()
2027 /* wake up only if we actually changed device->peer_seq */ update_peer_seq()
2028 if (peer_seq == newest_peer_seq) update_peer_seq()
2066 * In case packet_seq is larger than device->peer_seq number, there are
2068 * In case we are the logically next packet, we update device->peer_seq
2078 static int wait_for_and_update_peer_seq(struct drbd_peer_device *peer_device, const u32 peer_seq) wait_for_and_update_peer_seq() argument
2090 if (!seq_greater(peer_seq - 1, device->peer_seq)) { wait_for_and_update_peer_seq()
2091 device->peer_seq = seq_max(device->peer_seq, peer_seq); wait_for_and_update_peer_seq()
2279 u32 peer_seq = be32_to_cpu(p->seq_num); receive_Data() local
2292 err = wait_for_and_update_peer_seq(peer_device, peer_seq); receive_Data()
2374 err = wait_for_and_update_peer_seq(peer_device, peer_seq); receive_Data()
2388 update_peer_seq(peer_device, peer_seq); receive_Data()
H A Ddrbd_int.h951 unsigned int peer_seq; member in struct:drbd_device

Completed in 188 milliseconds