[GFS2] Clean up internal read function
[deliverable/linux.git] / fs / gfs2 / ops_file.c
CommitLineData
b3b94faa
DT
1/*
2 * Copyright (C) Sistina Software, Inc. 1997-2003 All rights reserved.
3a8a9a10 3 * Copyright (C) 2004-2006 Red Hat, Inc. All rights reserved.
b3b94faa
DT
4 *
5 * This copyrighted material is made available to anyone wishing to use,
6 * modify, copy, or redistribute it subject to the terms and conditions
e9fc2aa0 7 * of the GNU General Public License version 2.
b3b94faa
DT
8 */
9
b3b94faa
DT
10#include <linux/slab.h>
11#include <linux/spinlock.h>
12#include <linux/completion.h>
13#include <linux/buffer_head.h>
14#include <linux/pagemap.h>
15#include <linux/uio.h>
16#include <linux/blkdev.h>
17#include <linux/mm.h>
18ec7d5c 18#include <linux/fs.h>
5c676f6d 19#include <linux/gfs2_ondisk.h>
71b86f56
SW
20#include <linux/ext2_fs.h>
21#include <linux/crc32.h>
7d308590 22#include <linux/lm_interface.h>
33c3de32 23#include <linux/writeback.h>
b3b94faa
DT
24#include <asm/uaccess.h>
25
26#include "gfs2.h"
5c676f6d 27#include "incore.h"
b3b94faa
DT
28#include "bmap.h"
29#include "dir.h"
30#include "glock.h"
31#include "glops.h"
32#include "inode.h"
b3b94faa
DT
33#include "lm.h"
34#include "log.h"
35#include "meta_io.h"
b3b94faa
DT
36#include "ops_vm.h"
37#include "quota.h"
38#include "rgrp.h"
39#include "trans.h"
5c676f6d 40#include "util.h"
71b86f56 41#include "eaops.h"
b3b94faa 42
b3b94faa
DT
43/**
44 * gfs2_llseek - seek to a location in a file
45 * @file: the file
46 * @offset: the offset
47 * @origin: Where to seek from (SEEK_SET, SEEK_CUR, or SEEK_END)
48 *
49 * SEEK_END requires the glock for the file because it references the
50 * file's size.
51 *
52 * Returns: The new offset, or errno
53 */
54
55static loff_t gfs2_llseek(struct file *file, loff_t offset, int origin)
56{
feaa7bba 57 struct gfs2_inode *ip = GFS2_I(file->f_mapping->host);
b3b94faa
DT
58 struct gfs2_holder i_gh;
59 loff_t error;
60
b3b94faa
DT
61 if (origin == 2) {
62 error = gfs2_glock_nq_init(ip->i_gl, LM_ST_SHARED, LM_FLAG_ANY,
63 &i_gh);
64 if (!error) {
65 error = remote_llseek(file, offset, origin);
66 gfs2_glock_dq_uninit(&i_gh);
67 }
68 } else
69 error = remote_llseek(file, offset, origin);
70
71 return error;
72}
73
b3b94faa 74/**
f0e522a9 75 * gfs2_readdir - Read directory entries from a directory
b3b94faa
DT
76 * @file: The directory to read from
77 * @dirent: Buffer for dirents
78 * @filldir: Function used to do the copying
79 *
80 * Returns: errno
81 */
82
f0e522a9 83static int gfs2_readdir(struct file *file, void *dirent, filldir_t filldir)
b3b94faa 84{
71b86f56 85 struct inode *dir = file->f_mapping->host;
feaa7bba 86 struct gfs2_inode *dip = GFS2_I(dir);
b3b94faa 87 struct gfs2_holder d_gh;
cd915493 88 u64 offset = file->f_pos;
b3b94faa
DT
89 int error;
90
b3b94faa
DT
91 gfs2_holder_init(dip->i_gl, LM_ST_SHARED, GL_ATIME, &d_gh);
92 error = gfs2_glock_nq_atime(&d_gh);
93 if (error) {
94 gfs2_holder_uninit(&d_gh);
95 return error;
96 }
97
3699e3a4 98 error = gfs2_dir_read(dir, &offset, dirent, filldir);
b3b94faa
DT
99
100 gfs2_glock_dq_uninit(&d_gh);
101
b3b94faa
DT
102 file->f_pos = offset;
103
b3b94faa
DT
104 return error;
105}
106
128e5eba
SW
107/**
108 * fsflags_cvt
109 * @table: A table of 32 u32 flags
110 * @val: a 32 bit value to convert
111 *
112 * This function can be used to convert between fsflags values and
113 * GFS2's own flags values.
114 *
115 * Returns: the converted flags
116 */
117static u32 fsflags_cvt(const u32 *table, u32 val)
118{
119 u32 res = 0;
120 while(val) {
121 if (val & 1)
122 res |= *table;
123 table++;
124 val >>= 1;
125 }
126 return res;
127}
b3b94faa 128
128e5eba
SW
129static const u32 fsflags_to_gfs2[32] = {
130 [3] = GFS2_DIF_SYNC,
131 [4] = GFS2_DIF_IMMUTABLE,
132 [5] = GFS2_DIF_APPENDONLY,
133 [7] = GFS2_DIF_NOATIME,
134 [12] = GFS2_DIF_EXHASH,
b9af7ca6
SW
135 [14] = GFS2_DIF_INHERIT_JDATA,
136 [20] = GFS2_DIF_INHERIT_DIRECTIO,
71b86f56
SW
137};
138
128e5eba
SW
139static const u32 gfs2_to_fsflags[32] = {
140 [gfs2fl_Sync] = FS_SYNC_FL,
141 [gfs2fl_Immutable] = FS_IMMUTABLE_FL,
142 [gfs2fl_AppendOnly] = FS_APPEND_FL,
143 [gfs2fl_NoAtime] = FS_NOATIME_FL,
144 [gfs2fl_ExHash] = FS_INDEX_FL,
128e5eba
SW
145 [gfs2fl_InheritDirectio] = FS_DIRECTIO_FL,
146 [gfs2fl_InheritJdata] = FS_JOURNAL_DATA_FL,
7ea9ea83 147};
71b86f56 148
b09e593d 149static int gfs2_get_flags(struct file *filp, u32 __user *ptr)
71b86f56 150{
81454098 151 struct inode *inode = filp->f_path.dentry->d_inode;
feaa7bba 152 struct gfs2_inode *ip = GFS2_I(inode);
71b86f56
SW
153 struct gfs2_holder gh;
154 int error;
128e5eba 155 u32 fsflags;
71b86f56
SW
156
157 gfs2_holder_init(ip->i_gl, LM_ST_SHARED, GL_ATIME, &gh);
dcd24799 158 error = gfs2_glock_nq_atime(&gh);
71b86f56
SW
159 if (error)
160 return error;
907b9bce 161
128e5eba 162 fsflags = fsflags_cvt(gfs2_to_fsflags, ip->i_di.di_flags);
b9af7ca6
SW
163 if (!S_ISDIR(inode->i_mode)) {
164 if (ip->i_di.di_flags & GFS2_DIF_JDATA)
165 fsflags |= FS_JOURNAL_DATA_FL;
166 if (ip->i_di.di_flags & GFS2_DIF_DIRECTIO)
167 fsflags |= FS_DIRECTIO_FL;
168 }
128e5eba 169 if (put_user(fsflags, ptr))
71b86f56
SW
170 error = -EFAULT;
171
172 gfs2_glock_dq_m(1, &gh);
173 gfs2_holder_uninit(&gh);
174 return error;
175}
176
6b124d8d
SW
177void gfs2_set_inode_flags(struct inode *inode)
178{
179 struct gfs2_inode *ip = GFS2_I(inode);
180 struct gfs2_dinode_host *di = &ip->i_di;
181 unsigned int flags = inode->i_flags;
182
183 flags &= ~(S_SYNC|S_APPEND|S_IMMUTABLE|S_NOATIME|S_DIRSYNC);
184 if (di->di_flags & GFS2_DIF_IMMUTABLE)
185 flags |= S_IMMUTABLE;
186 if (di->di_flags & GFS2_DIF_APPENDONLY)
187 flags |= S_APPEND;
188 if (di->di_flags & GFS2_DIF_NOATIME)
189 flags |= S_NOATIME;
190 if (di->di_flags & GFS2_DIF_SYNC)
191 flags |= S_SYNC;
192 inode->i_flags = flags;
193}
194
71b86f56
SW
195/* Flags that can be set by user space */
196#define GFS2_FLAGS_USER_SET (GFS2_DIF_JDATA| \
197 GFS2_DIF_DIRECTIO| \
198 GFS2_DIF_IMMUTABLE| \
199 GFS2_DIF_APPENDONLY| \
200 GFS2_DIF_NOATIME| \
201 GFS2_DIF_SYNC| \
202 GFS2_DIF_SYSTEM| \
203 GFS2_DIF_INHERIT_DIRECTIO| \
204 GFS2_DIF_INHERIT_JDATA)
205
206/**
207 * gfs2_set_flags - set flags on an inode
208 * @inode: The inode
209 * @flags: The flags to set
210 * @mask: Indicates which flags are valid
211 *
212 */
b09e593d 213static int do_gfs2_set_flags(struct file *filp, u32 reqflags, u32 mask)
71b86f56 214{
81454098 215 struct inode *inode = filp->f_path.dentry->d_inode;
feaa7bba
SW
216 struct gfs2_inode *ip = GFS2_I(inode);
217 struct gfs2_sbd *sdp = GFS2_SB(inode);
71b86f56
SW
218 struct buffer_head *bh;
219 struct gfs2_holder gh;
220 int error;
55eccc6d 221 u32 new_flags, flags;
71b86f56 222
71b86f56 223 error = gfs2_glock_nq_init(ip->i_gl, LM_ST_EXCLUSIVE, 0, &gh);
52f341cf 224 if (error)
71b86f56
SW
225 return error;
226
55eccc6d
SW
227 flags = ip->i_di.di_flags;
228 new_flags = (flags & ~mask) | (reqflags & mask);
71b86f56
SW
229 if ((new_flags ^ flags) == 0)
230 goto out;
231
232 error = -EINVAL;
233 if ((new_flags ^ flags) & ~GFS2_FLAGS_USER_SET)
234 goto out;
235
71b86f56
SW
236 error = -EPERM;
237 if (IS_IMMUTABLE(inode) && (new_flags & GFS2_DIF_IMMUTABLE))
238 goto out;
239 if (IS_APPEND(inode) && (new_flags & GFS2_DIF_APPENDONLY))
240 goto out;
907b9bce 241 if (((new_flags ^ flags) & GFS2_DIF_IMMUTABLE) &&
b9cb9813 242 !capable(CAP_LINUX_IMMUTABLE))
71b86f56 243 goto out;
b9cb9813 244 if (!IS_IMMUTABLE(inode)) {
faf450ef 245 error = permission(inode, MAY_WRITE, NULL);
b9cb9813
SW
246 if (error)
247 goto out;
248 }
71b86f56 249
55eccc6d 250 error = gfs2_trans_begin(sdp, RES_DINODE, 0);
71b86f56
SW
251 if (error)
252 goto out;
55eccc6d
SW
253 error = gfs2_meta_inode_buffer(ip, &bh);
254 if (error)
255 goto out_trans_end;
71b86f56
SW
256 gfs2_trans_add_bh(ip->i_gl, bh, 1);
257 ip->i_di.di_flags = new_flags;
539e5d6b 258 gfs2_dinode_out(ip, bh->b_data);
71b86f56 259 brelse(bh);
6b124d8d 260 gfs2_set_inode_flags(inode);
55eccc6d
SW
261out_trans_end:
262 gfs2_trans_end(sdp);
71b86f56
SW
263out:
264 gfs2_glock_dq_uninit(&gh);
265 return error;
266}
267
b09e593d 268static int gfs2_set_flags(struct file *filp, u32 __user *ptr)
71b86f56 269{
b9af7ca6 270 struct inode *inode = filp->f_path.dentry->d_inode;
128e5eba
SW
271 u32 fsflags, gfsflags;
272 if (get_user(fsflags, ptr))
71b86f56 273 return -EFAULT;
128e5eba 274 gfsflags = fsflags_cvt(fsflags_to_gfs2, fsflags);
b9af7ca6
SW
275 if (!S_ISDIR(inode->i_mode)) {
276 if (gfsflags & GFS2_DIF_INHERIT_JDATA)
277 gfsflags ^= (GFS2_DIF_JDATA | GFS2_DIF_INHERIT_JDATA);
278 if (gfsflags & GFS2_DIF_INHERIT_DIRECTIO)
279 gfsflags ^= (GFS2_DIF_DIRECTIO | GFS2_DIF_INHERIT_DIRECTIO);
280 return do_gfs2_set_flags(filp, gfsflags, ~0);
281 }
282 return do_gfs2_set_flags(filp, gfsflags, ~GFS2_DIF_JDATA);
71b86f56
SW
283}
284
b09e593d 285static long gfs2_ioctl(struct file *filp, unsigned int cmd, unsigned long arg)
71b86f56
SW
286{
287 switch(cmd) {
128e5eba 288 case FS_IOC_GETFLAGS:
b09e593d 289 return gfs2_get_flags(filp, (u32 __user *)arg);
128e5eba 290 case FS_IOC_SETFLAGS:
b09e593d 291 return gfs2_set_flags(filp, (u32 __user *)arg);
71b86f56
SW
292 }
293 return -ENOTTY;
294}
295
296
b3b94faa
DT
297/**
298 * gfs2_mmap -
299 * @file: The file to map
300 * @vma: The VMA which described the mapping
301 *
302 * Returns: 0 or error code
303 */
304
305static int gfs2_mmap(struct file *file, struct vm_area_struct *vma)
306{
feaa7bba 307 struct gfs2_inode *ip = GFS2_I(file->f_mapping->host);
b3b94faa
DT
308 struct gfs2_holder i_gh;
309 int error;
310
b3b94faa
DT
311 gfs2_holder_init(ip->i_gl, LM_ST_SHARED, GL_ATIME, &i_gh);
312 error = gfs2_glock_nq_atime(&i_gh);
313 if (error) {
314 gfs2_holder_uninit(&i_gh);
315 return error;
316 }
317
18ec7d5c
SW
318 /* This is VM_MAYWRITE instead of VM_WRITE because a call
319 to mprotect() can turn on VM_WRITE later. */
320
321 if ((vma->vm_flags & (VM_MAYSHARE | VM_MAYWRITE)) ==
322 (VM_MAYSHARE | VM_MAYWRITE))
323 vma->vm_ops = &gfs2_vm_ops_sharewrite;
324 else
325 vma->vm_ops = &gfs2_vm_ops_private;
b3b94faa
DT
326
327 gfs2_glock_dq_uninit(&i_gh);
328
329 return error;
330}
331
332/**
333 * gfs2_open - open a file
334 * @inode: the inode to open
335 * @file: the struct file for this opening
336 *
337 * Returns: errno
338 */
339
340static int gfs2_open(struct inode *inode, struct file *file)
341{
feaa7bba 342 struct gfs2_inode *ip = GFS2_I(inode);
b3b94faa
DT
343 struct gfs2_holder i_gh;
344 struct gfs2_file *fp;
345 int error;
346
b3b94faa
DT
347 fp = kzalloc(sizeof(struct gfs2_file), GFP_KERNEL);
348 if (!fp)
349 return -ENOMEM;
350
f55ab26a 351 mutex_init(&fp->f_fl_mutex);
b3b94faa 352
feaa7bba 353 gfs2_assert_warn(GFS2_SB(inode), !file->private_data);
5c676f6d 354 file->private_data = fp;
b3b94faa 355
b60623c2 356 if (S_ISREG(ip->i_inode.i_mode)) {
b3b94faa
DT
357 error = gfs2_glock_nq_init(ip->i_gl, LM_ST_SHARED, LM_FLAG_ANY,
358 &i_gh);
359 if (error)
360 goto fail;
361
362 if (!(file->f_flags & O_LARGEFILE) &&
363 ip->i_di.di_size > MAX_NON_LFS) {
a9c62a18 364 error = -EOVERFLOW;
b3b94faa
DT
365 goto fail_gunlock;
366 }
367
368 /* Listen to the Direct I/O flag */
369
370 if (ip->i_di.di_flags & GFS2_DIF_DIRECTIO)
371 file->f_flags |= O_DIRECT;
372
b3b94faa
DT
373 gfs2_glock_dq_uninit(&i_gh);
374 }
375
376 return 0;
377
420b9e5e 378fail_gunlock:
b3b94faa 379 gfs2_glock_dq_uninit(&i_gh);
420b9e5e 380fail:
5c676f6d 381 file->private_data = NULL;
b3b94faa 382 kfree(fp);
b3b94faa
DT
383 return error;
384}
385
386/**
387 * gfs2_close - called to close a struct file
388 * @inode: the inode the struct file belongs to
389 * @file: the struct file being closed
390 *
391 * Returns: errno
392 */
393
394static int gfs2_close(struct inode *inode, struct file *file)
395{
5c676f6d 396 struct gfs2_sbd *sdp = inode->i_sb->s_fs_info;
b3b94faa
DT
397 struct gfs2_file *fp;
398
5c676f6d
SW
399 fp = file->private_data;
400 file->private_data = NULL;
b3b94faa
DT
401
402 if (gfs2_assert_warn(sdp, fp))
403 return -EIO;
404
405 kfree(fp);
406
407 return 0;
408}
409
410/**
411 * gfs2_fsync - sync the dirty data for a file (across the cluster)
412 * @file: the file that points to the dentry (we ignore this)
413 * @dentry: the dentry that points to the inode to sync
414 *
33c3de32
SW
415 * The VFS will flush "normal" data for us. We only need to worry
416 * about metadata here. For journaled data, we just do a log flush
417 * as we can't avoid it. Otherwise we can just bale out if datasync
418 * is set. For stuffed inodes we must flush the log in order to
419 * ensure that all data is on disk.
420 *
34126f9f
SW
421 * The call to write_inode_now() is there to write back metadata and
422 * the inode itself. It does also try and write the data, but thats
423 * (hopefully) a no-op due to the VFS having already called filemap_fdatawrite()
424 * for us.
425 *
b3b94faa
DT
426 * Returns: errno
427 */
428
429static int gfs2_fsync(struct file *file, struct dentry *dentry, int datasync)
430{
33c3de32
SW
431 struct inode *inode = dentry->d_inode;
432 int sync_state = inode->i_state & (I_DIRTY_SYNC|I_DIRTY_DATASYNC);
433 int ret = 0;
33c3de32
SW
434
435 if (gfs2_is_jdata(GFS2_I(inode))) {
436 gfs2_log_flush(GFS2_SB(inode), GFS2_I(inode)->i_gl);
437 return 0;
438 }
b3b94faa 439
33c3de32
SW
440 if (sync_state != 0) {
441 if (!datasync)
34126f9f 442 ret = write_inode_now(inode, 0);
b3b94faa 443
33c3de32
SW
444 if (gfs2_is_stuffed(GFS2_I(inode)))
445 gfs2_log_flush(GFS2_SB(inode), GFS2_I(inode)->i_gl);
446 }
447
448 return ret;
b3b94faa
DT
449}
450
60446067
ME
451/**
452 * gfs2_setlease - acquire/release a file lease
453 * @file: the file pointer
454 * @arg: lease type
455 * @fl: file lock
456 *
457 * Returns: errno
458 */
459
460static int gfs2_setlease(struct file *file, long arg, struct file_lock **fl)
461{
462 struct gfs2_sbd *sdp = GFS2_SB(file->f_mapping->host);
463
464 /*
465 * We don't currently have a way to enforce a lease across the whole
466 * cluster; until we do, disable leases (by just returning -EINVAL),
467 * unless the administrator has requested purely local locking.
468 */
469 if (!sdp->sd_args.ar_localflocks)
470 return -EINVAL;
0af1a450 471 return generic_setlease(file, arg, fl);
60446067
ME
472}
473
b3b94faa
DT
474/**
475 * gfs2_lock - acquire/release a posix lock on a file
476 * @file: the file pointer
477 * @cmd: either modify or retrieve lock state, possibly wait
478 * @fl: type and range of lock
479 *
480 * Returns: errno
481 */
482
483static int gfs2_lock(struct file *file, int cmd, struct file_lock *fl)
484{
feaa7bba
SW
485 struct gfs2_inode *ip = GFS2_I(file->f_mapping->host);
486 struct gfs2_sbd *sdp = GFS2_SB(file->f_mapping->host);
b3b94faa 487 struct lm_lockname name =
dbb7cae2 488 { .ln_number = ip->i_no_addr,
b3b94faa
DT
489 .ln_type = LM_TYPE_PLOCK };
490
b3b94faa
DT
491 if (!(fl->fl_flags & FL_POSIX))
492 return -ENOLCK;
7afaac62 493 if (__mandatory_lock(&ip->i_inode))
b3b94faa
DT
494 return -ENOLCK;
495
496 if (sdp->sd_args.ar_localflocks) {
497 if (IS_GETLK(cmd)) {
9d6a8c5c 498 posix_test_lock(file, fl);
b3b94faa
DT
499 return 0;
500 } else {
8628de05 501 return posix_lock_file_wait(file, fl);
b3b94faa
DT
502 }
503 }
504
586759f0
ME
505 if (cmd == F_CANCELLK) {
506 /* Hack: */
507 cmd = F_SETLK;
508 fl->fl_type = F_UNLCK;
509 }
b3b94faa
DT
510 if (IS_GETLK(cmd))
511 return gfs2_lm_plock_get(sdp, &name, file, fl);
512 else if (fl->fl_type == F_UNLCK)
513 return gfs2_lm_punlock(sdp, &name, file, fl);
514 else
515 return gfs2_lm_plock(sdp, &name, file, cmd, fl);
516}
517
b3b94faa
DT
518static int do_flock(struct file *file, int cmd, struct file_lock *fl)
519{
5c676f6d 520 struct gfs2_file *fp = file->private_data;
b3b94faa 521 struct gfs2_holder *fl_gh = &fp->f_fl_gh;
81454098 522 struct gfs2_inode *ip = GFS2_I(file->f_path.dentry->d_inode);
b3b94faa
DT
523 struct gfs2_glock *gl;
524 unsigned int state;
525 int flags;
526 int error = 0;
527
528 state = (fl->fl_type == F_WRLCK) ? LM_ST_EXCLUSIVE : LM_ST_SHARED;
b4c20166
AD
529 flags = (IS_SETLKW(cmd) ? 0 : LM_FLAG_TRY) | GL_EXACT | GL_NOCACHE
530 | GL_FLOCK;
b3b94faa 531
f55ab26a 532 mutex_lock(&fp->f_fl_mutex);
b3b94faa
DT
533
534 gl = fl_gh->gh_gl;
535 if (gl) {
536 if (fl_gh->gh_state == state)
537 goto out;
b3b94faa 538 flock_lock_file_wait(file,
907b9bce 539 &(struct file_lock){.fl_type = F_UNLCK});
b4c20166
AD
540 gfs2_glock_dq_wait(fl_gh);
541 gfs2_holder_reinit(state, flags, fl_gh);
b3b94faa 542 } else {
feaa7bba 543 error = gfs2_glock_get(GFS2_SB(&ip->i_inode),
dbb7cae2 544 ip->i_no_addr, &gfs2_flock_glops,
b3b94faa
DT
545 CREATE, &gl);
546 if (error)
547 goto out;
b4c20166
AD
548 gfs2_holder_init(gl, state, flags, fl_gh);
549 gfs2_glock_put(gl);
b3b94faa 550 }
b3b94faa
DT
551 error = gfs2_glock_nq(fl_gh);
552 if (error) {
553 gfs2_holder_uninit(fl_gh);
554 if (error == GLR_TRYFAILED)
555 error = -EAGAIN;
556 } else {
557 error = flock_lock_file_wait(file, fl);
feaa7bba 558 gfs2_assert_warn(GFS2_SB(&ip->i_inode), !error);
b3b94faa
DT
559 }
560
420b9e5e 561out:
f55ab26a 562 mutex_unlock(&fp->f_fl_mutex);
b3b94faa
DT
563 return error;
564}
565
566static void do_unflock(struct file *file, struct file_lock *fl)
567{
5c676f6d 568 struct gfs2_file *fp = file->private_data;
b3b94faa
DT
569 struct gfs2_holder *fl_gh = &fp->f_fl_gh;
570
f55ab26a 571 mutex_lock(&fp->f_fl_mutex);
b3b94faa
DT
572 flock_lock_file_wait(file, fl);
573 if (fl_gh->gh_gl)
574 gfs2_glock_dq_uninit(fl_gh);
f55ab26a 575 mutex_unlock(&fp->f_fl_mutex);
b3b94faa
DT
576}
577
578/**
579 * gfs2_flock - acquire/release a flock lock on a file
580 * @file: the file pointer
581 * @cmd: either modify or retrieve lock state, possibly wait
582 * @fl: type and range of lock
583 *
584 * Returns: errno
585 */
586
587static int gfs2_flock(struct file *file, int cmd, struct file_lock *fl)
588{
feaa7bba
SW
589 struct gfs2_inode *ip = GFS2_I(file->f_mapping->host);
590 struct gfs2_sbd *sdp = GFS2_SB(file->f_mapping->host);
b3b94faa 591
b3b94faa
DT
592 if (!(fl->fl_flags & FL_FLOCK))
593 return -ENOLCK;
7afaac62 594 if (__mandatory_lock(&ip->i_inode))
b3b94faa
DT
595 return -ENOLCK;
596
597 if (sdp->sd_args.ar_localflocks)
598 return flock_lock_file_wait(file, fl);
599
600 if (fl->fl_type == F_UNLCK) {
601 do_unflock(file, fl);
602 return 0;
d00223f1 603 } else {
b3b94faa 604 return do_flock(file, cmd, fl);
d00223f1 605 }
b3b94faa
DT
606}
607
b0dd9308 608const struct file_operations gfs2_file_fops = {
26c1a574 609 .llseek = gfs2_llseek,
d00223f1 610 .read = do_sync_read,
26c1a574 611 .aio_read = generic_file_aio_read,
d00223f1 612 .write = do_sync_write,
26c1a574
SW
613 .aio_write = generic_file_aio_write,
614 .unlocked_ioctl = gfs2_ioctl,
615 .mmap = gfs2_mmap,
616 .open = gfs2_open,
617 .release = gfs2_close,
618 .fsync = gfs2_fsync,
619 .lock = gfs2_lock,
26c1a574
SW
620 .flock = gfs2_flock,
621 .splice_read = generic_file_splice_read,
622 .splice_write = generic_file_splice_write,
60446067 623 .setlease = gfs2_setlease,
b3b94faa
DT
624};
625
b0dd9308 626const struct file_operations gfs2_dir_fops = {
26c1a574
SW
627 .readdir = gfs2_readdir,
628 .unlocked_ioctl = gfs2_ioctl,
629 .open = gfs2_open,
630 .release = gfs2_close,
631 .fsync = gfs2_fsync,
632 .lock = gfs2_lock,
633 .flock = gfs2_flock,
b3b94faa
DT
634};
635
This page took 0.211129 seconds and 5 git commands to generate.