]>
git.proxmox.com Git - mirror_qemu.git/blob - block/qed-table.c
2 * QEMU Enhanced Disk Format Table I/O
4 * Copyright IBM, Corp. 2010
7 * Stefan Hajnoczi <stefanha@linux.vnet.ibm.com>
8 * Anthony Liguori <aliguori@us.ibm.com>
10 * This work is licensed under the terms of the GNU LGPL, version 2 or later.
11 * See the COPYING.LIB file in the top-level directory.
15 #include "qemu/osdep.h"
17 #include "qemu/sockets.h" /* for EINPROGRESS on Windows */
19 #include "qemu/bswap.h"
21 static int qed_read_table(BDRVQEDState
*s
, uint64_t offset
, QEDTable
*table
)
28 .iov_base
= table
->offsets
,
29 .iov_len
= s
->header
.cluster_size
* s
->header
.table_size
,
31 qemu_iovec_init_external(&qiov
, &iov
, 1);
33 trace_qed_read_table(s
, offset
, table
);
35 ret
= bdrv_preadv(s
->bs
->file
, offset
, &qiov
);
40 /* Byteswap offsets */
42 noffsets
= qiov
.size
/ sizeof(uint64_t);
43 for (i
= 0; i
< noffsets
; i
++) {
44 table
->offsets
[i
] = le64_to_cpu(table
->offsets
[i
]);
51 trace_qed_read_table_cb(s
, table
, ret
);
56 * Write out an updated part or all of a table
59 * @offset: Offset of table in image file, in bytes
61 * @index: Index of first element
62 * @n: Number of elements
63 * @flush: Whether or not to sync to disk
64 * @cb: Completion function
65 * @opaque: Argument for completion function
67 static void qed_write_table(BDRVQEDState
*s
, uint64_t offset
, QEDTable
*table
,
68 unsigned int index
, unsigned int n
, bool flush
,
69 BlockCompletionFunc
*cb
, void *opaque
)
71 unsigned int sector_mask
= BDRV_SECTOR_SIZE
/ sizeof(uint64_t) - 1;
72 unsigned int start
, end
, i
;
79 trace_qed_write_table(s
, offset
, table
, index
, n
);
81 /* Calculate indices of the first and one after last elements */
82 start
= index
& ~sector_mask
;
83 end
= (index
+ n
+ sector_mask
) & ~sector_mask
;
85 len_bytes
= (end
- start
) * sizeof(uint64_t);
87 new_table
= qemu_blockalign(s
->bs
, len_bytes
);
88 iov
= (struct iovec
) {
89 .iov_base
= new_table
->offsets
,
92 qemu_iovec_init_external(&qiov
, &iov
, 1);
95 for (i
= start
; i
< end
; i
++) {
96 uint64_t le_offset
= cpu_to_le64(table
->offsets
[i
]);
97 new_table
->offsets
[i
- start
] = le_offset
;
100 /* Adjust for offset into table */
101 offset
+= start
* sizeof(uint64_t);
103 ret
= bdrv_pwritev(s
->bs
->file
, offset
, &qiov
);
104 trace_qed_write_table_cb(s
, table
, flush
, ret
);
111 ret
= bdrv_flush(s
->bs
);
120 qemu_vfree(new_table
);
125 * Propagate return value from async callback
127 static void qed_sync_cb(void *opaque
, int ret
)
129 *(int *)opaque
= ret
;
132 int qed_read_l1_table_sync(BDRVQEDState
*s
)
134 return qed_read_table(s
, s
->header
.l1_table_offset
, s
->l1_table
);
137 void qed_write_l1_table(BDRVQEDState
*s
, unsigned int index
, unsigned int n
,
138 BlockCompletionFunc
*cb
, void *opaque
)
140 BLKDBG_EVENT(s
->bs
->file
, BLKDBG_L1_UPDATE
);
141 qed_write_table(s
, s
->header
.l1_table_offset
,
142 s
->l1_table
, index
, n
, false, cb
, opaque
);
145 int qed_write_l1_table_sync(BDRVQEDState
*s
, unsigned int index
,
148 int ret
= -EINPROGRESS
;
150 qed_write_l1_table(s
, index
, n
, qed_sync_cb
, &ret
);
151 BDRV_POLL_WHILE(s
->bs
, ret
== -EINPROGRESS
);
156 int qed_read_l2_table(BDRVQEDState
*s
, QEDRequest
*request
, uint64_t offset
)
160 qed_unref_l2_cache_entry(request
->l2_table
);
162 /* Check for cached L2 entry */
163 request
->l2_table
= qed_find_l2_cache_entry(&s
->l2_cache
, offset
);
164 if (request
->l2_table
) {
168 request
->l2_table
= qed_alloc_l2_cache_entry(&s
->l2_cache
);
169 request
->l2_table
->table
= qed_alloc_table(s
);
171 BLKDBG_EVENT(s
->bs
->file
, BLKDBG_L2_LOAD
);
172 ret
= qed_read_table(s
, offset
, request
->l2_table
->table
);
176 /* can't trust loaded L2 table anymore */
177 qed_unref_l2_cache_entry(request
->l2_table
);
178 request
->l2_table
= NULL
;
180 request
->l2_table
->offset
= offset
;
182 qed_commit_l2_cache_entry(&s
->l2_cache
, request
->l2_table
);
184 /* This is guaranteed to succeed because we just committed the entry
187 request
->l2_table
= qed_find_l2_cache_entry(&s
->l2_cache
, offset
);
188 assert(request
->l2_table
!= NULL
);
195 int qed_read_l2_table_sync(BDRVQEDState
*s
, QEDRequest
*request
, uint64_t offset
)
197 return qed_read_l2_table(s
, request
, offset
);
200 void qed_write_l2_table(BDRVQEDState
*s
, QEDRequest
*request
,
201 unsigned int index
, unsigned int n
, bool flush
,
202 BlockCompletionFunc
*cb
, void *opaque
)
204 BLKDBG_EVENT(s
->bs
->file
, BLKDBG_L2_UPDATE
);
205 qed_write_table(s
, request
->l2_table
->offset
,
206 request
->l2_table
->table
, index
, n
, flush
, cb
, opaque
);
209 int qed_write_l2_table_sync(BDRVQEDState
*s
, QEDRequest
*request
,
210 unsigned int index
, unsigned int n
, bool flush
)
212 int ret
= -EINPROGRESS
;
214 qed_write_l2_table(s
, request
, index
, n
, flush
, qed_sync_cb
, &ret
);
215 BDRV_POLL_WHILE(s
->bs
, ret
== -EINPROGRESS
);