X-Git-Url: http://andersk.mit.edu/gitweb/moira.git/blobdiff_plain/e4ae019062358b54128ff857b08110e009a291cc..433dd8fdad5dc86c222a60aa58649574cdc21f7e:/server/qfollow.pc diff --git a/server/qfollow.pc b/server/qfollow.pc index feff1489..4f7d344d 100644 --- a/server/qfollow.pc +++ b/server/qfollow.pc @@ -526,13 +526,18 @@ int followup_gsnt(struct query *q, struct save_queue *sq, struct validate *v, client *cl) { char **argv; - int status; + int status, idx; + + if (q->version < 8) + idx = 0; + else + idx = 3; while (sq_get_data(sq, &argv)) { mr_trim_args(q->vcnt, argv); - status = fix_ace(argv[7], &argv[8]); + status = fix_ace(argv[7 + idx], &argv[8 + idx]); if (status && status != MR_NO_MATCH) return status; } @@ -552,8 +557,10 @@ int followup_ghst(struct query *q, struct save_queue *sq, struct validate *v, if (q->version < 6) idx = 0; - else + else if (q->version >= 6 && q->version < 8) idx = 1; + else + idx = 2; while (sq_get_data(sq, &argv)) { @@ -812,7 +819,6 @@ int followup_aqot(struct query *q, char *argv[], client *cl) if (dbms_errno) return mr_errcode; - flush_name(argv[0], table); if (q->type == APPEND) { EXEC SQL UPDATE tblstats SET appends = appends + 1, modtime = SYSDATE @@ -877,7 +883,6 @@ int followup_dqot(struct query *q, char **argv, client *cl) if (dbms_errno) return mr_errcode; - flush_name(argv[0], table); EXEC SQL UPDATE tblstats SET deletes = deletes + 1, modtime = SYSDATE WHERE table_name = :tname; @@ -969,3 +974,29 @@ int trigger_dcm(struct query *q, char *argv[], client *cl) return MR_SUCCESS; } } + +/* followup_gcon: fix the ace_name, memace_name, and modby */ + +int followup_gcon(struct query *q, struct save_queue *sq, struct validate *v, + int (*action)(int, char *[], void *), void *actarg, + client *cl) +{ + char **argv; + int status; + + while (sq_get_data(sq, &argv)) + { + mr_trim_args(q->vcnt, argv); + + status = fix_ace(argv[4], &argv[5]); + if (status && status != MR_NO_MATCH) + return status; + + status = fix_ace(argv[6], &argv[7]); + if (status && status != MR_NO_MATCH) + return status; + } + + return followup_fix_modby(q, sq, v, action, actarg, cl); +} +