6 #include <sys/resource.h>
7 #include "fsdev/file-op-9p.h"
8 #include "fsdev/9p-iov-marshal.h"
9 #include "qemu/thread.h"
10 #include "qemu/coroutine.h"
97 enum p9_proto_version
{
98 V9FS_PROTO_2000U
= 0x01,
99 V9FS_PROTO_2000L
= 0x02,
102 #define P9_NOTAG UINT16_MAX
103 #define P9_NOFID UINT32_MAX
104 #define P9_MAXWELEM 16
106 #define FID_REFERENCED 0x1
107 #define FID_NON_RECLAIMABLE 0x2
108 static inline char *rpath(FsContext
*ctx
, const char *path
)
110 return g_strdup_printf("%s/%s", ctx
->fs_root
, path
);
114 * ample room for Twrite/Rread header
115 * size[4] Tread/Twrite tag[2] fid[4] offset[8] count[4]
117 #define P9_IOHDRSZ 24
119 typedef struct V9fsPDU V9fsPDU
;
126 } QEMU_PACKED P9MsgHeader
;
136 QLIST_ENTRY(V9fsPDU
) next
;
142 * 1) change user needs to set groups and stuff
146 #define MAX_TAG_LEN 32
148 #define BUG_ON(cond) assert(!(cond))
150 typedef struct V9fsFidState V9fsFidState
;
159 typedef struct V9fsConf
161 /* tag name for the device */
166 typedef struct V9fsXattr
176 typedef struct V9fsDir
{
178 QemuMutex readdir_mutex
;
181 static inline void v9fs_readdir_lock(V9fsDir
*dir
)
183 qemu_mutex_lock(&dir
->readdir_mutex
);
186 static inline void v9fs_readdir_unlock(V9fsDir
*dir
)
188 qemu_mutex_unlock(&dir
->readdir_mutex
);
191 static inline void v9fs_readdir_init(V9fsDir
*dir
)
193 qemu_mutex_init(&dir
->readdir_mutex
);
197 * Filled by fs driver on open and other
200 union V9fsFidOpenState
{
205 * private pointer for fs drivers, that
206 * have its own internal representation of
218 V9fsFidOpenState fs_reclaim
;
225 V9fsFidState
*rclm_lst
;
228 typedef struct V9fsState
230 QLIST_HEAD(, V9fsPDU
) free_list
;
231 QLIST_HEAD(, V9fsPDU
) active_list
;
232 V9fsFidState
*fid_list
;
236 enum p9_proto_version proto_version
;
238 V9fsPDU pdus
[MAX_REQ
];
239 const struct V9fsTransport
*transport
;
241 * lock ensuring atomic path update
244 CoRwlock rename_lock
;
246 Error
*migration_blocker
;
251 /* 9p2000.L open flags */
252 #define P9_DOTL_RDONLY 00000000
253 #define P9_DOTL_WRONLY 00000001
254 #define P9_DOTL_RDWR 00000002
255 #define P9_DOTL_NOACCESS 00000003
256 #define P9_DOTL_CREATE 00000100
257 #define P9_DOTL_EXCL 00000200
258 #define P9_DOTL_NOCTTY 00000400
259 #define P9_DOTL_TRUNC 00001000
260 #define P9_DOTL_APPEND 00002000
261 #define P9_DOTL_NONBLOCK 00004000
262 #define P9_DOTL_DSYNC 00010000
263 #define P9_DOTL_FASYNC 00020000
264 #define P9_DOTL_DIRECT 00040000
265 #define P9_DOTL_LARGEFILE 00100000
266 #define P9_DOTL_DIRECTORY 00200000
267 #define P9_DOTL_NOFOLLOW 00400000
268 #define P9_DOTL_NOATIME 01000000
269 #define P9_DOTL_CLOEXEC 02000000
270 #define P9_DOTL_SYNC 04000000
272 /* 9p2000.L at flags */
273 #define P9_DOTL_AT_REMOVEDIR 0x200
275 /* 9P2000.L lock type */
276 #define P9_LOCK_TYPE_RDLCK 0
277 #define P9_LOCK_TYPE_WRLCK 1
278 #define P9_LOCK_TYPE_UNLCK 2
280 #define P9_LOCK_SUCCESS 0
281 #define P9_LOCK_BLOCKED 1
282 #define P9_LOCK_ERROR 2
283 #define P9_LOCK_GRACE 3
285 #define P9_LOCK_FLAGS_BLOCK 1
286 #define P9_LOCK_FLAGS_RECLAIM 2
288 typedef struct V9fsFlock
292 uint64_t start
; /* absolute offset */
295 V9fsString client_id
;
298 typedef struct V9fsGetlock
301 uint64_t start
; /* absolute offset */
304 V9fsString client_id
;
307 extern int open_fd_hw
;
308 extern int total_open_fd
;
310 static inline void v9fs_path_write_lock(V9fsState
*s
)
312 if (s
->ctx
.export_flags
& V9FS_PATHNAME_FSCONTEXT
) {
313 qemu_co_rwlock_wrlock(&s
->rename_lock
);
317 static inline void v9fs_path_read_lock(V9fsState
*s
)
319 if (s
->ctx
.export_flags
& V9FS_PATHNAME_FSCONTEXT
) {
320 qemu_co_rwlock_rdlock(&s
->rename_lock
);
324 static inline void v9fs_path_unlock(V9fsState
*s
)
326 if (s
->ctx
.export_flags
& V9FS_PATHNAME_FSCONTEXT
) {
327 qemu_co_rwlock_unlock(&s
->rename_lock
);
331 static inline uint8_t v9fs_request_cancelled(V9fsPDU
*pdu
)
333 return pdu
->cancelled
;
336 void coroutine_fn
v9fs_reclaim_fd(V9fsPDU
*pdu
);
337 void v9fs_path_init(V9fsPath
*path
);
338 void v9fs_path_free(V9fsPath
*path
);
339 void v9fs_path_sprintf(V9fsPath
*path
, const char *fmt
, ...);
340 void v9fs_path_copy(V9fsPath
*lhs
, V9fsPath
*rhs
);
341 int v9fs_name_to_path(V9fsState
*s
, V9fsPath
*dirpath
,
342 const char *name
, V9fsPath
*path
);
343 int v9fs_device_realize_common(V9fsState
*s
, Error
**errp
);
344 void v9fs_device_unrealize_common(V9fsState
*s
, Error
**errp
);
346 ssize_t
pdu_marshal(V9fsPDU
*pdu
, size_t offset
, const char *fmt
, ...);
347 ssize_t
pdu_unmarshal(V9fsPDU
*pdu
, size_t offset
, const char *fmt
, ...);
348 V9fsPDU
*pdu_alloc(V9fsState
*s
);
349 void pdu_free(V9fsPDU
*pdu
);
350 void pdu_submit(V9fsPDU
*pdu
);
351 void v9fs_reset(V9fsState
*s
);
353 struct V9fsTransport
{
354 ssize_t (*pdu_vmarshal
)(V9fsPDU
*pdu
, size_t offset
, const char *fmt
,
356 ssize_t (*pdu_vunmarshal
)(V9fsPDU
*pdu
, size_t offset
, const char *fmt
,
358 void (*init_in_iov_from_pdu
)(V9fsPDU
*pdu
, struct iovec
**piov
,
359 unsigned int *pniov
, size_t size
);
360 void (*init_out_iov_from_pdu
)(V9fsPDU
*pdu
, struct iovec
**piov
,
361 unsigned int *pniov
);
362 void (*push_and_notify
)(V9fsPDU
*pdu
);
365 static inline int v9fs_register_transport(V9fsState
*s
,
366 const struct V9fsTransport
*t
)
368 assert(!s
->transport
);