X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=blob.c;h=3539453ec0e5a174e0e962ae3b84946e4f837f25;hp=2abf26283f599327398c0558270e0cb29f4f611a;hb=02d818d9;hpb=c2ac39f76d245816a919d94790672fb66e9a7253 diff --git a/blob.c b/blob.c index 2abf2628..3539453e 100644 --- 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)