Lines Matching refs:expect
395 if (!expect(!(peer_req->flags & EE_CALL_AL_COMPLETE_IO))) { in __drbd_free_peer_req()
1619 if (!expect(IS_ALIGNED(data_size, 512))) in read_in_block()
1622 if (!trim && !expect(data_size <= DRBD_MAX_BIO_SIZE)) in read_in_block()
1711 int digest_size, err, expect; in recv_dless_read() local
1733 expect = min_t(int, data_size, bvec.bv_len); in recv_dless_read()
1734 err = drbd_recv_all_warn(peer_device->connection, mapped, expect); in recv_dless_read()
1738 data_size -= expect; in recv_dless_read()
4820 const int expect = sizeof(struct p_connection_features); in drbd_do_features() local
4838 if (pi.size != expect) { in drbd_do_features()
4840 expect, pi.size); in drbd_do_features()
4845 err = drbd_recv_all_warn(connection, p, expect); in drbd_do_features()
5504 int expect = header_size; in drbd_asender() local
5549 rv = drbd_recv_short(connection->meta.socket, buf, expect-received, 0); in drbd_asender()
5602 if (received == expect && cmd == NULL) { in drbd_asender()
5611 expect = header_size + cmd->pkt_size; in drbd_asender()
5612 if (pi.size != expect - header_size) { in drbd_asender()
5618 if (received == expect) { in drbd_asender()
5637 expect = header_size; in drbd_asender()
5642 rv = drbd_recv_short(connection->meta.socket, buf, expect-received, MSG_DONTWAIT); in drbd_asender()