summaryrefslogtreecommitdiffstats
path: root/libglusterfsclient/src/libglusterfsclient.c
diff options
context:
space:
mode:
authorRaghavendra G <raghavendra@gluster.com>2009-11-18 01:16:33 +0000
committerAnand V. Avati <avati@dev.gluster.com>2009-11-18 21:14:20 -0800
commit9c5547193f637cb52cbb91c0409dd3580acafdcb (patch)
tree8cd3f75cd209a4f3c2b77ed0f0efd0b82a6a1e49 /libglusterfsclient/src/libglusterfsclient.c
parenta0c05848d2ed0b0600d73214594a161cbb42302c (diff)
libglusterfsclient: implement glusterfs_truncate.
Signed-off-by: Raghavendra G <raghavendra@gluster.com> Signed-off-by: Anand V. Avati <avati@dev.gluster.com> BUG: 369 (Samba does not work with booster.) URL: http://bugs.gluster.com/cgi-bin/bugzilla3/show_bug.cgi?id=369
Diffstat (limited to 'libglusterfsclient/src/libglusterfsclient.c')
-rwxr-xr-xlibglusterfsclient/src/libglusterfsclient.c105
1 files changed, 104 insertions, 1 deletions
diff --git a/libglusterfsclient/src/libglusterfsclient.c b/libglusterfsclient/src/libglusterfsclient.c
index 179f2c217..1e50e004e 100755
--- a/libglusterfsclient/src/libglusterfsclient.c
+++ b/libglusterfsclient/src/libglusterfsclient.c
@@ -7468,7 +7468,6 @@ out:
return off;
}
-
struct libgf_client_sendfile_data {
int reads_sent;
int reads_completed;
@@ -7909,6 +7908,110 @@ unlock:
return res;
}
+int32_t
+libgf_client_truncate_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
+ int32_t op_ret, int32_t op_errno,
+ struct stat *prebuf, struct stat *postbuf)
+{
+ libgf_client_local_t *local = frame->local;
+
+ local->reply_stub = fop_truncate_cbk_stub (frame, NULL, op_ret,
+ op_errno, prebuf, postbuf);
+
+ LIBGF_REPLY_NOTIFY (local);
+ return 0;
+}
+
+int32_t
+libgf_client_truncate (libglusterfs_client_ctx_t *ctx,
+ loc_t *loc, off_t length)
+{
+ call_stub_t *stub = NULL;
+ int32_t op_ret = 0;
+ libgf_client_local_t *local = NULL;
+
+ LIBGF_CLIENT_FOP (ctx, stub, truncate, local, loc, length);
+
+ op_ret = stub->args.truncate_cbk.op_ret;
+ errno = stub->args.truncate_cbk.op_errno;
+ libgf_transform_iattr (ctx, loc->inode,
+ &stub->args.truncate_cbk.postbuf);
+
+ gf_log (LIBGF_XL_NAME, GF_LOG_DEBUG, "path %s, status %d, errno %d",
+ loc->path, op_ret, errno);
+ libgf_update_iattr_cache (loc->inode, LIBGF_UPDATE_STAT,
+ &stub->args.truncate_cbk.postbuf);
+ call_stub_destroy (stub);
+
+ return op_ret;
+}
+
+int
+glusterfs_glh_truncate (glusterfs_handle_t handle, const char *path,
+ off_t length)
+{
+ int32_t op_ret = -1;
+ loc_t loc = {0, };
+ libglusterfs_client_ctx_t *ctx = handle;
+ char *name = NULL, *pathname = NULL;
+
+ GF_VALIDATE_OR_GOTO (LIBGF_XL_NAME, ctx, out);
+ GF_VALIDATE_ABSOLUTE_PATH_OR_GOTO (LIBGF_XL_NAME, path, out);
+
+ loc.path = strdup (path);
+ if (!loc.path) {
+ gf_log (LIBGF_XL_NAME, GF_LOG_ERROR, "strdup failed");
+ goto out;
+ }
+
+ op_ret = libgf_client_path_lookup (&loc, ctx, 1);
+ if (op_ret == -1) {
+ gf_log ("libglusterfsclient", GF_LOG_ERROR,
+ "path lookup failed for (%s)", loc.path);
+ goto out;
+ }
+
+ pathname = strdup (loc.path);
+ name = basename (pathname);
+
+ op_ret = libgf_client_loc_fill (&loc, ctx, 0, loc.parent->ino, name);
+ if (op_ret == -1) {
+ gf_log ("libglusterfsclient",
+ GF_LOG_ERROR,
+ "libgf_client_loc_fill returned -1, returning EINVAL");
+ errno = EINVAL;
+ goto out;
+ }
+
+ op_ret = libgf_client_truncate (ctx, &loc, length);
+
+out:
+ libgf_client_loc_wipe (&loc);
+
+ return op_ret;
+}
+
+int
+glusterfs_truncate (const char *path, off_t length)
+{
+ int op_ret = -1;
+ char vpath[PATH_MAX];
+ glusterfs_handle_t h = NULL;
+
+ GF_VALIDATE_OR_GOTO (LIBGF_XL_NAME, path, out);
+
+ gf_log (LIBGF_XL_NAME, GF_LOG_DEBUG, "path:%s length:%"PRIu64, path,
+ length);
+ h = libgf_resolved_path_handle (path, vpath);
+ if (!h) {
+ errno = ENODEV;
+ goto out;
+ }
+
+ op_ret = glusterfs_glh_truncate (h, vpath, length);
+out:
+ return op_ret;
+}
static struct xlator_fops libgf_client_fops = {
};