Complete afs event handling.

[paraslash.git] / blob.c

diff --git a/blob.c b/blob.c
index 2abf26283f599327398c0558270e0cb29f4f611a..3539453ec0e5a174e0e962ae3b84946e4f837f25 100644 (file)
--- a/blob.c
+++ b/blob.c
@@ -225,7 +225,7 @@ static int remove_blob(struct osl_table *table, struct osl_row *row,
 
 static int com_rmblob_callback(struct osl_table *table,
                const struct osl_object *query,
-               __a_unused struct osl_object *result)
+               struct osl_object *result)
 {
        int ret;
        struct rmblob_data rmbd = {.num_removed = 0};
@@ -244,14 +244,16 @@ static int com_rmblob_callback(struct osl_table *table,
                para_printf(&rmbd.pb, "%s\n", PARA_STRERROR(-ret));
        if (!rmbd.num_removed)
                para_printf(&rmbd.pb, "no matches, nothing removed\n");
-       else
+       else {
                para_printf(&rmbd.pb, "removed %d blobs\n", rmbd.num_removed);
+               afs_event(BLOB_RENAME, NULL, table);
+       }
        result->data = rmbd.pb.buf;
        result->size = rmbd.pb.size;
        return 1;
 }
 
-static int com_rmblob(callback_function *f, __a_unused int fd, int argc,
+static int com_rmblob(callback_function *f, int fd, int argc,
                char * const * const argv)
 {
        int ret;
@@ -328,7 +330,11 @@ static int com_addblob_callback(struct osl_table *table,
        objs[BLOBCOL_NAME].size = name_len;
        objs[BLOBCOL_DEF].data = name + name_len;
        objs[BLOBCOL_DEF].size = query->size - name_len;
-       return osl_add_row(table, objs);
+       ret = osl_add_row(table, objs);
+       if (ret < 0)
+               return ret;
+       afs_event(BLOB_ADD, NULL, table);
+       return 1;
 }
 
 static int com_addblob(callback_function *f, int fd, int argc,
@@ -360,10 +366,14 @@ static int com_mvblob_callback(struct osl_table *table,
                return ret;
        obj.data = dest;
        obj.size = strlen(dest) + 1;
-       return osl_update_object(table, row, BLOBCOL_NAME, &obj);
+       ret = osl_update_object(table, row, BLOBCOL_NAME, &obj);
+       if (ret < 0)
+               return ret;
+       afs_event(BLOB_RENAME, NULL, table);
+       return 1;
 }
 
-static int com_mvblob(callback_function *f,  __a_unused int fd,
+static int com_mvblob(callback_function *f, __a_unused int fd,
                int argc, char * const * const argv)
 {
        if (argc != 3)