glusterfs.git -

diff options

author	Raghavendra G <raghavendra@zresearch.com>	2009-04-15 03:11:21 -0700
committer	Anand V. Avati <avati@amp.gluster.com>	2009-04-16 17:10:01 +0530
commit	34f8f0b3e1f992cf59da2c2d410471e440e6ed92 (patch)
tree	daca3fb634f4ab78148db3a99587c5f578eae8b0 /libglusterfs/src
parent	ffb863c3a8cbfb2105ac23ce5fc5be1df372458c (diff)

write-behind aggregate-size related changes

This patch brings in following changes: 1. make aggregate-size as non-configurable and make it to be equal to maximum iobuf size. 2. best effort to write data in chunks of length as close to aggregate-size as possible but not greater than aggregate-size, since aggregate-size is made equal to Maximum size of iobuf. Signed-off-by: Anand V. Avati <avati@amp.gluster.com>

Diffstat (limited to 'libglusterfs/src')

0 files changed, 0 insertions, 0 deletions

(call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, inode_t *inode, struct iatt *buf, struct iatt *preparent, struct iatt *postparent, dict_t *xdata) { FOP_CBK (mkdir, frame, cookie, op_ret, op_errno, inode, buf, preparent, postparent, xdata); return 0; } int32_t cluster_unlink_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct iatt *preparent, struct iatt *postparent, dict_t *xdata) { FOP_CBK (unlink, frame, cookie, op_ret, op_errno, preparent, postparent, xdata); return 0; } int32_t cluster_rmdir_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct iatt *preparent, struct iatt *postparent, dict_t *xdata) { FOP_CBK (rmdir, frame, cookie, op_ret, op_errno, preparent, postparent, xdata); return 0; } int32_t cluster_symlink_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, inode_t *inode, struct iatt *buf, struct iatt *preparent, struct iatt *postparent, dict_t *xdata) { FOP_CBK (symlink, frame, cookie, op_ret, op_errno, inode, buf, preparent, postparent, xdata); return 0; } int32_t cluster_rename_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct iatt *buf, struct iatt *preoldparent, struct iatt *postoldparent, struct iatt *prenewparent, struct iatt *postnewparent, dict_t *xdata) { FOP_CBK (rename, frame, cookie, op_ret, op_errno, buf, preoldparent, postoldparent, prenewparent, postnewparent, xdata); return 0; } int32_t cluster_link_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, inode_t *inode, struct iatt *buf, struct iatt *preparent, struct iatt *postparent, dict_t *xdata) { FOP_CBK (link, frame, cookie, op_ret, op_errno, inode, buf, preparent, postparent, xdata); return 0; } int32_t cluster_create_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, fd_t *fd, inode_t *inode, struct iatt *buf, struct iatt *preparent, struct iatt *postparent, dict_t *xdata) { FOP_CBK (create, frame, cookie, op_ret, op_errno, fd, inode, buf, preparent, postparent, xdata); return 0; } int32_t cluster_open_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, fd_t *fd, dict_t *xdata) { FOP_CBK (open, frame, cookie, op_ret, op_errno, fd, xdata); return 0; } int32_t cluster_readv_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct iovec *vector, int32_t count, struct iatt *stbuf, struct iobref *iobref, dict_t *xdata) { FOP_CBK (readv, frame, cookie, op_ret, op_errno, vector, count, stbuf, iobref, xdata); return 0; } int32_t cluster_writev_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct iatt *prebuf, struct iatt *postbuf, dict_t *xdata) { FOP_CBK (writev, frame, cookie, op_ret, op_errno, prebuf, postbuf, xdata); return 0; } int32_t cluster_flush_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *xdata) { FOP_CBK (flush, frame, cookie, op_ret, op_errno, xdata); return 0; } int32_t cluster_fsync_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct iatt *prebuf, struct iatt *postbuf, dict_t *xdata) { FOP_CBK (fsync, frame, cookie, op_ret, op_errno, prebuf, postbuf, xdata); return 0; } int32_t cluster_fstat_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct iatt *buf, dict_t *xdata) { FOP_CBK (fstat, frame, cookie, op_ret, op_errno, buf, xdata); return 0; } int32_t cluster_opendir_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, fd_t *fd, dict_t *xdata) { FOP_CBK (opendir, frame, cookie, op_ret, op_errno, fd, xdata); return 0; } int32_t cluster_fsyncdir_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *xdata) { FOP_CBK (fsyncdir, frame, cookie, op_ret, op_errno, xdata); return 0; } int32_t cluster_statfs_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct statvfs *buf, dict_t *xdata) { FOP_CBK (statfs, frame, cookie, op_ret, op_errno, buf, xdata); return 0; } int32_t cluster_setxattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *xdata) { FOP_CBK (setxattr, frame, cookie, op_ret, op_errno, xdata); return 0; } int32_t cluster_fsetxattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *xdata) { FOP_CBK (fsetxattr, frame, cookie, op_ret, op_errno, xdata); return 0; } int32_t cluster_fgetxattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *dict, dict_t *xdata) { FOP_CBK (fgetxattr, frame, cookie, op_ret, op_errno, dict, xdata); return 0; } int32_t cluster_getxattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *dict, dict_t *xdata) { FOP_CBK (getxattr, frame, cookie, op_ret, op_errno, dict, xdata); return 0; } int32_t cluster_xattrop_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *dict, dict_t *xdata) { FOP_CBK (xattrop, frame, cookie, op_ret, op_errno, dict, xdata); return 0; } int32_t cluster_fxattrop_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *dict, dict_t *xdata) { FOP_CBK (fxattrop, frame, cookie, op_ret, op_errno, dict, xdata); return 0; } int32_t cluster_removexattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *xdata) { FOP_CBK (removexattr, frame, cookie, op_ret, op_errno, xdata); return 0; } int32_t cluster_fremovexattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *xdata) { FOP_CBK (fremovexattr, frame, cookie, op_ret, op_errno, xdata); return 0; } int32_t cluster_lk_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct gf_flock *lock, dict_t *xdata) { FOP_CBK (lk, frame, cookie, op_ret, op_errno, lock, xdata); return 0; } int32_t cluster_inodelk_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *xdata) { FOP_CBK (inodelk, frame, cookie, op_ret, op_errno, xdata); return 0; } int32_t cluster_finodelk_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *xdata) { FOP_CBK (finodelk, frame, cookie, op_ret, op_errno, xdata); return 0; } int32_t cluster_entrylk_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *xdata) { FOP_CBK (entrylk, frame, cookie, op_ret, op_errno, xdata); return 0; } int32_t cluster_fentrylk_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *xdata) { FOP_CBK (fentrylk, frame, cookie, op_ret, op_errno, xdata); return 0; } int32_t cluster_rchecksum_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, uint32_t weak_checksum, uint8_t *strong_checksum, dict_t *xdata) { FOP_CBK (rchecksum, frame, cookie, op_ret, op_errno, weak_checksum, strong_checksum, xdata); return 0; } int32_t cluster_readdir_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, gf_dirent_t *entries, dict_t *xdata) { FOP_CBK (readdir, frame, cookie, op_ret, op_errno, entries, xdata); return 0; } int32_t cluster_readdirp_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, gf_dirent_t *entries, dict_t *xdata) { FOP_CBK (readdirp, frame, cookie, op_ret, op_errno, entries, xdata); return 0; } int32_t cluster_setattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct iatt *statpre, struct iatt *statpost, dict_t *xdata) { FOP_CBK (setattr, frame, cookie, op_ret, op_errno, statpre, statpost, xdata); return 0; } int32_t cluster_fsetattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct iatt *statpre, struct iatt *statpost, dict_t *xdata) { FOP_CBK (fsetattr, frame, cookie, op_ret, op_errno, statpre, statpost, xdata); return 0; } int32_t cluster_fallocate_cbk(call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct iatt *pre, struct iatt *post, dict_t *xdata) { FOP_CBK (fallocate, frame, cookie, op_ret, op_errno, pre, post, xdata); return 0; } int32_t cluster_discard_cbk(call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct iatt *pre, struct iatt *post, dict_t *xdata) { FOP_CBK (discard, frame, cookie, op_ret, op_errno, pre, post, xdata); return 0; } int32_t cluster_zerofill_cbk(call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, struct iatt *pre, struct iatt *post, dict_t *xdata) { FOP_CBK (zerofill, frame, cookie, op_ret, op_errno, pre, post, xdata); return 0; } int32_t cluster_ipc_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret, int32_t op_errno, dict_t *xdata) { FOP_CBK (ipc, frame, cookie, op_ret, op_errno, xdata); return 0; } int32_t cluster_fgetxattr (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, fd_t *fd, const char *name, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, fgetxattr, fd, name, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_fsetxattr (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, fd_t *fd, dict_t *dict, int32_t flags, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, fsetxattr, fd, dict, flags, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_setxattr (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, loc_t *loc, dict_t *dict, int32_t flags, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, setxattr, loc, dict, flags, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_statfs (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, loc_t *loc, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, statfs, loc, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_fsyncdir (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, fd_t *fd, int32_t flags, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, fsyncdir, fd, flags, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_opendir (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, loc_t *loc, fd_t *fd, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, opendir, loc, fd, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_fstat (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, fd_t *fd, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, fstat, fd, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_fsync (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, fd_t *fd, int32_t flags, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, fsync, fd, flags, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_flush (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, fd_t *fd, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, flush, fd, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_writev (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, fd_t *fd, struct iovec *vector, int32_t count, off_t off, uint32_t flags, struct iobref *iobref, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, writev, fd, vector, count, off, flags, iobref, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_readv (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, fd_t *fd, size_t size, off_t offset, uint32_t flags, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, readv, fd, size, offset, flags, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_open (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, loc_t *loc, int32_t flags, fd_t *fd, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, open, loc, flags, fd, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_create (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, loc_t *loc, int32_t flags, mode_t mode, mode_t umask, fd_t *fd, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, create, loc, flags, mode, umask, fd, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_link (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, loc_t *oldloc, loc_t *newloc, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, link, oldloc, newloc, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_rename (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, loc_t *oldloc, loc_t *newloc, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, rename, oldloc, newloc, xdata); return fop_success_fill (replies, numsubvols, output); } int cluster_symlink (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, const char *linkpath, loc_t *loc, mode_t umask, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, symlink, linkpath, loc, umask, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_rmdir (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, loc_t *loc, int flags, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, rmdir, loc, flags, xdata); return fop_success_fill (replies, numsubvols, output); } int32_t cluster_unlink (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, loc_t *loc, int xflag, dict_t *xdata) { FOP_ONLIST (subvols, on, numsubvols, replies, output, frame, unlink, loc, xflag, xdata); return fop_success_fill (replies, numsubvols, output); } int cluster_mkdir (xlator_t **subvols, unsigned char *on, int numsubvols, default_args_cbk_t *replies, unsigned char *output, call_frame_t *frame, xlator_t *this, loc_t *loc, mode_t mode, mode_t umask, dict_t *xdata)


context:
space:
mode: