Only build compatfd when using AIO and make sure to always init AIO
[qemu] / osdep.c
1 /*
2  * QEMU low level functions
3  *
4  * Copyright (c) 2003 Fabrice Bellard
5  *
6  * Permission is hereby granted, free of charge, to any person obtaining a copy
7  * of this software and associated documentation files (the "Software"), to deal
8  * in the Software without restriction, including without limitation the rights
9  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10  * copies of the Software, and to permit persons to whom the Software is
11  * furnished to do so, subject to the following conditions:
12  *
13  * The above copyright notice and this permission notice shall be included in
14  * all copies or substantial portions of the Software.
15  *
16  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
19  * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
22  * THE SOFTWARE.
23  */
24 #include <stdlib.h>
25 #include <stdio.h>
26 #include <stdarg.h>
27 #include <string.h>
28 #include <errno.h>
29 #include <unistd.h>
30 #include <fcntl.h>
31 #ifdef HOST_SOLARIS
32 #include <sys/types.h>
33 #include <sys/statvfs.h>
34 #endif
35
36 #include "qemu-common.h"
37 #include "sysemu.h"
38
39 #ifdef _WIN32
40 #define WIN32_LEAN_AND_MEAN
41 #include <windows.h>
42 #elif defined(_BSD)
43 #include <stdlib.h>
44 #else
45 #include <malloc.h>
46 #endif
47
48 #if defined(_WIN32)
49 void *qemu_memalign(size_t alignment, size_t size)
50 {
51     return VirtualAlloc(NULL, size, MEM_COMMIT, PAGE_READWRITE);
52 }
53
54 void *qemu_vmalloc(size_t size)
55 {
56     /* FIXME: this is not exactly optimal solution since VirtualAlloc
57        has 64Kb granularity, but at least it guarantees us that the
58        memory is page aligned. */
59     return VirtualAlloc(NULL, size, MEM_COMMIT, PAGE_READWRITE);
60 }
61
62 void qemu_vfree(void *ptr)
63 {
64     VirtualFree(ptr, 0, MEM_RELEASE);
65 }
66
67 #else
68
69 #if defined(USE_KQEMU)
70
71 #ifdef __OpenBSD__
72 #include <sys/param.h>
73 #include <sys/types.h>
74 #include <sys/mount.h>
75 #else
76 #include <sys/vfs.h>
77 #endif
78
79 #include <sys/mman.h>
80 #include <fcntl.h>
81
82 static void *kqemu_vmalloc(size_t size)
83 {
84     static int phys_ram_fd = -1;
85     static int phys_ram_size = 0;
86     void *ptr;
87
88 #ifdef __OpenBSD__ /* no need (?) for a dummy file on OpenBSD */
89     int map_anon = MAP_ANON;
90 #else
91     int map_anon = 0;
92     const char *tmpdir;
93     char phys_ram_file[1024];
94 #ifdef HOST_SOLARIS
95     struct statvfs stfs;
96 #else
97     struct statfs stfs;
98 #endif
99
100     if (phys_ram_fd < 0) {
101         tmpdir = getenv("QEMU_TMPDIR");
102         if (!tmpdir)
103 #ifdef HOST_SOLARIS
104             tmpdir = "/tmp";
105         if (statvfs(tmpdir, &stfs) == 0) {
106 #else
107             tmpdir = "/dev/shm";
108         if (statfs(tmpdir, &stfs) == 0) {
109 #endif
110             int64_t free_space;
111             int ram_mb;
112
113             free_space = (int64_t)stfs.f_bavail * stfs.f_bsize;
114             if ((ram_size + 8192 * 1024) >= free_space) {
115                 ram_mb = (ram_size / (1024 * 1024));
116                 fprintf(stderr,
117                         "You do not have enough space in '%s' for the %d MB of QEMU virtual RAM.\n",
118                         tmpdir, ram_mb);
119                 if (strcmp(tmpdir, "/dev/shm") == 0) {
120                     fprintf(stderr, "To have more space available provided you have enough RAM and swap, do as root:\n"
121                             "mount -o remount,size=%dm /dev/shm\n",
122                             ram_mb + 16);
123                 } else {
124                     fprintf(stderr,
125                             "Use the '-m' option of QEMU to diminish the amount of virtual RAM or use the\n"
126                             "QEMU_TMPDIR environment variable to set another directory where the QEMU\n"
127                             "temporary RAM file will be opened.\n");
128                 }
129                 fprintf(stderr, "Or disable the accelerator module with -no-kqemu\n");
130                 exit(1);
131             }
132         }
133         snprintf(phys_ram_file, sizeof(phys_ram_file), "%s/qemuXXXXXX",
134                  tmpdir);
135         phys_ram_fd = mkstemp(phys_ram_file);
136         if (phys_ram_fd < 0) {
137             fprintf(stderr,
138                     "warning: could not create temporary file in '%s'.\n"
139                     "Use QEMU_TMPDIR to select a directory in a tmpfs filesystem.\n"
140                     "Using '/tmp' as fallback.\n",
141                     tmpdir);
142             snprintf(phys_ram_file, sizeof(phys_ram_file), "%s/qemuXXXXXX",
143                      "/tmp");
144             phys_ram_fd = mkstemp(phys_ram_file);
145             if (phys_ram_fd < 0) {
146                 fprintf(stderr, "Could not create temporary memory file '%s'\n",
147                         phys_ram_file);
148                 exit(1);
149             }
150         }
151         unlink(phys_ram_file);
152     }
153     size = (size + 4095) & ~4095;
154     ftruncate(phys_ram_fd, phys_ram_size + size);
155 #endif /* !__OpenBSD__ */
156     ptr = mmap(NULL,
157                size,
158                PROT_WRITE | PROT_READ, map_anon | MAP_SHARED,
159                phys_ram_fd, phys_ram_size);
160     if (ptr == MAP_FAILED) {
161         fprintf(stderr, "Could not map physical memory\n");
162         exit(1);
163     }
164     phys_ram_size += size;
165     return ptr;
166 }
167
168 static void kqemu_vfree(void *ptr)
169 {
170     /* may be useful some day, but currently we do not need to free */
171 }
172
173 #endif
174
175 void *qemu_memalign(size_t alignment, size_t size)
176 {
177 #if defined(_POSIX_C_SOURCE)
178     int ret;
179     void *ptr;
180     ret = posix_memalign(&ptr, alignment, size);
181     if (ret != 0)
182         return NULL;
183     return ptr;
184 #elif defined(_BSD)
185     return valloc(size);
186 #else
187     return memalign(alignment, size);
188 #endif
189 }
190
191 /* alloc shared memory pages */
192 void *qemu_vmalloc(size_t size)
193 {
194 #if defined(USE_KQEMU)
195     if (kqemu_allowed)
196         return kqemu_vmalloc(size);
197 #endif
198 #ifdef _BSD
199     return valloc(size);
200 #else
201     return memalign(4096, size);
202 #endif
203 }
204
205 void qemu_vfree(void *ptr)
206 {
207 #if defined(USE_KQEMU)
208     if (kqemu_allowed)
209         kqemu_vfree(ptr);
210 #endif
211     free(ptr);
212 }
213
214 #endif
215
216 int qemu_create_pidfile(const char *filename)
217 {
218     char buffer[128];
219     int len;
220 #ifndef _WIN32
221     int fd;
222
223     fd = open(filename, O_RDWR | O_CREAT, 0600);
224     if (fd == -1)
225         return -1;
226
227     if (lockf(fd, F_TLOCK, 0) == -1)
228         return -1;
229
230     len = snprintf(buffer, sizeof(buffer), "%ld\n", (long)getpid());
231     if (write(fd, buffer, len) != len)
232         return -1;
233 #else
234     HANDLE file;
235     DWORD flags;
236     OVERLAPPED overlap;
237     BOOL ret;
238
239     /* Open for writing with no sharing. */
240     file = CreateFile(filename, GENERIC_WRITE, 0, NULL,
241                       OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
242
243     if (file == INVALID_HANDLE_VALUE)
244       return -1;
245
246     flags = LOCKFILE_EXCLUSIVE_LOCK | LOCKFILE_FAIL_IMMEDIATELY;
247     overlap.hEvent = 0;
248     /* Lock 1 byte. */
249     ret = LockFileEx(file, flags, 0, 0, 1, &overlap);
250     if (ret == 0)
251       return -1;
252
253     /* Write PID to file. */
254     len = snprintf(buffer, sizeof(buffer), "%ld\n", (long)getpid());
255     ret = WriteFileEx(file, (LPCVOID)buffer, (DWORD)len,
256                       &overlap, NULL);
257     if (ret == 0)
258       return -1;
259 #endif
260     return 0;
261 }
262
263 #ifdef _WIN32
264
265 /* Offset between 1/1/1601 and 1/1/1970 in 100 nanosec units */
266 #define _W32_FT_OFFSET (116444736000000000ULL)
267
268 int qemu_gettimeofday(qemu_timeval *tp)
269 {
270   union {
271     unsigned long long ns100; /*time since 1 Jan 1601 in 100ns units */
272     FILETIME ft;
273   }  _now;
274
275   if(tp)
276     {
277       GetSystemTimeAsFileTime (&_now.ft);
278       tp->tv_usec=(long)((_now.ns100 / 10ULL) % 1000000ULL );
279       tp->tv_sec= (long)((_now.ns100 - _W32_FT_OFFSET) / 10000000ULL);
280     }
281   /* Always return 0 as per Open Group Base Specifications Issue 6.
282      Do not set errno on error.  */
283   return 0;
284 }
285 #endif /* _WIN32 */