@@ -112,7 +112,7 @@ obj-$(CONFIG_FDT) += device_tree.o
obj-$(CONFIG_KVM) += kvm-all.o
obj-y += memory.o savevm.o cputlb.o
obj-$(CONFIG_HAVE_GET_MEMORY_MAPPING) += memory_mapping.o
-obj-$(CONFIG_HAVE_CORE_DUMP) += dump.o dump_bitmap.o
+obj-$(CONFIG_HAVE_CORE_DUMP) += dump.o dump_bitmap.o cache_data.o
obj-$(CONFIG_NO_GET_MEMORY_MAPPING) += memory_mapping-stub.o
obj-$(CONFIG_NO_CORE_DUMP) += dump-stub.o
LIBS+=$(libs_softmmu)
new file mode 100644
@@ -0,0 +1,121 @@
+/*
+ * QEMU cache data
+ *
+ * Copyright Fujitsu, Corp. 2013
+ *
+ * Authors:
+ * Qiao Nuohan <qiaonuohan@cn.fujitsu.com>
+ *
+ * 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 "qemu-common.h"
+#include "cache_data.h"
+
+int init_cache_data(struct cache_data *cd, const char *filename)
+{
+ int fd;
+ char *tmpname;
+
+ /* init the tmp file */
+ tmpname = getenv("TMPDIR");
+ if (!tmpname) {
+ tmpname = (char *)P_tmpdir;
+ }
+
+ cd->file_name = (char *)g_strdup_printf("%s/%s", tmpname, filename);
+
+ fd = mkstemp(cd->file_name);
+ if (fd < 0) {
+ return -1;
+ }
+
+ cd->fd = fd;
+ unlink(cd->file_name);
+
+ /* init buf */
+ cd->buf_size = BUFSIZE_CACHE_DATA;
+ cd->cache_size = 0;
+ cd->buf = g_malloc0(BUFSIZE_CACHE_DATA);
+
+ cd->offset = 0;
+
+ return 0;
+}
+
+int write_cache(struct cache_data *cd, void *buf, size_t size)
+{
+ /*
+ * check if the space is enough to cache data, if not write cached
+ * data to the tmp file
+ */
+ if (cd->cache_size + size > cd->buf_size) {
+ if (lseek(cd->fd, cd->offset, SEEK_SET) < 0) {
+ return -1;
+ }
+
+ if (write(cd->fd, cd->buf, cd->cache_size) != cd->cache_size) {
+ return -1;
+ }
+
+ cd->offset += cd->cache_size;
+ cd->cache_size = 0;
+ }
+
+ memcpy(cd->buf + cd->cache_size, buf, size);
+ cd->cache_size += size;
+
+ return 0;
+}
+
+int sync_cache(struct cache_data *cd)
+{
+ /* no data is cached in cache_data */
+ if (cd->cache_size == 0) {
+ return 0;
+ }
+
+ if (lseek(cd->fd, cd->offset, SEEK_SET) < 0) {
+ return -1;
+ }
+
+ if (write(cd->fd, cd->buf, cd->cache_size) != cd->cache_size) {
+ return -1;
+ }
+
+ cd->offset += cd->cache_size;
+
+ return 0;
+}
+
+int read_cache(struct cache_data *cd)
+{
+ if (lseek(cd->fd, cd->offset, SEEK_SET) < 0) {
+ return -1;
+ }
+
+ if (read(cd->fd, cd->buf, cd->cache_size) != cd->cache_size) {
+ return -1;
+ }
+
+ cd->offset += cd->cache_size;
+
+ return 0;
+}
+
+void free_cache_data(struct cache_data *cd)
+{
+ if (cd) {
+ if (cd->file_name) {
+ g_free(cd->file_name);
+ }
+
+ if (cd->buf) {
+ g_free(cd->buf);
+ }
+
+ g_free(cd);
+ }
+}
new file mode 100644
@@ -0,0 +1,56 @@
+/*
+ * QEMU cache data
+ *
+ * Copyright Fujitsu, Corp. 2013
+ *
+ * Authors:
+ * Qiao Nuohan <qiaonuohan@cn.fujitsu.com>
+ *
+ * This work is licensed under the terms of the GNU GPL, version 2 or later.
+ * See the COPYING file in the top-level directory.
+ *
+ */
+
+#ifndef CACHE_DATA_H
+#define CACHE_DATA_H
+
+#define BUFSIZE_CACHE_DATA (4096 * 4)
+
+struct cache_data {
+ int fd; /* fd of the tmp file used to store cache data */
+ char *file_name; /* name of the tmp file */
+ char *buf; /* used to cache data */
+ size_t buf_size; /* size of the buf */
+ size_t cache_size; /* size of cached data in buf */
+ off_t offset; /* offset of the tmp file */
+};
+
+/*
+ * create a tmp file used to store cache data, then init the buf
+ */
+int init_cache_data(struct cache_data *cd, const char *filename);
+
+/*
+ * write data to the tmp file, the data may first be cached in the buf of
+ * cache_data
+ */
+int write_cache(struct cache_data *cd, void *buf, size_t size);
+
+/*
+ * when cache_data is caching data in the buf, sync_cache is needed to write the
+ * data back to tmp file
+ */
+int sync_cache(struct cache_data *cd);
+
+/* read data from the tmp file to the buf of 'cd', the start place is set by
+ * cd->offset, and the size is set by cd->cache_size. cd->offset is changed
+ * automaticlly according to the size of data read this time.
+ */
+int read_cache(struct cache_data *cd);
+
+/*
+ * free the space used by cache_data
+ */
+void free_cache_data(struct cache_data *cd);
+
+#endif