Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
quorum: Create quorum.c, add QuorumChildRequest and QuorumAIOCB.
Quorum is a block filter mirroring writes to num_children children. For reads quorum reads each children and does a vote. If more than vote_threshold versions are identical the quorum is reached and this winning version is returned to the guest. So quorum prevents bit corruption. For high availability purpose minority errors are reported via QMP but the guest does not see them. This patch creates the driver C source file and introduces the structures that will be used in asynchronous reads and writes. Signed-off-by: Benoit Canet <benoit@irqsave.net> Reviewed-by: Max Reitz <mreitz@redhat.com> Signed-off-by: Kevin Wolf <kwolf@redhat.com>
- Loading branch information
1 parent
6475758
commit 27cec15
Showing
2 changed files
with
54 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,53 @@ | ||
/* | ||
* Quorum Block filter | ||
* | ||
* Copyright (C) 2012-2014 Nodalink, EURL. | ||
* | ||
* Author: | ||
* Benoît Canet <benoit.canet@irqsave.net> | ||
* | ||
* Based on the design and code of blkverify.c (Copyright (C) 2010 IBM, Corp) | ||
* and blkmirror.c (Copyright (C) 2011 Red Hat, Inc). | ||
* | ||
* This work is licensed under the terms of the GNU GPL, version 2 or later. | ||
* See the COPYING file in the top-level directory. | ||
*/ | ||
|
||
#include "block/block_int.h" | ||
|
||
typedef struct QuorumAIOCB QuorumAIOCB; | ||
|
||
/* Quorum will create one instance of the following structure per operation it | ||
* performs on its children. | ||
* So for each read/write operation coming from the upper layer there will be | ||
* $children_count QuorumChildRequest. | ||
*/ | ||
typedef struct QuorumChildRequest { | ||
BlockDriverAIOCB *aiocb; | ||
QEMUIOVector qiov; | ||
uint8_t *buf; | ||
int ret; | ||
QuorumAIOCB *parent; | ||
} QuorumChildRequest; | ||
|
||
/* Quorum will use the following structure to track progress of each read/write | ||
* operation received by the upper layer. | ||
* This structure hold pointers to the QuorumChildRequest structures instances | ||
* used to do operations on each children and track overall progress. | ||
*/ | ||
struct QuorumAIOCB { | ||
BlockDriverAIOCB common; | ||
|
||
/* Request metadata */ | ||
uint64_t sector_num; | ||
int nb_sectors; | ||
|
||
QEMUIOVector *qiov; /* calling IOV */ | ||
|
||
QuorumChildRequest *qcrs; /* individual child requests */ | ||
int count; /* number of completed AIOCB */ | ||
int success_count; /* number of successfully completed AIOCB */ | ||
|
||
bool is_read; | ||
int vote_ret; | ||
}; |