Index: trunk/ippTools/share/Makefile.am =================================================================== --- trunk/ippTools/share/Makefile.am (revision 23904) +++ trunk/ippTools/share/Makefile.am (revision 23912) @@ -106,9 +106,13 @@ disttool_pendingcomponent.sql \ disttool_pendingfileset.sql \ + disttool_pendingdest.sql \ disttool_processedcomponent.sql \ + disttool_queuercrun.sql \ + disttool_revertrcrun.sql \ disttool_revertrun_update.sql \ disttool_revertrun_delete.sql \ disttool_revertfileset.sql \ disttool_toadvance.sql \ + disttool_updatercrun.sql \ faketool_change_exp_state.sql \ faketool_change_imfile_data_state.sql \ Index: trunk/ippTools/share/difftool_pendingcleanupskyfile.sql =================================================================== --- trunk/ippTools/share/difftool_pendingcleanupskyfile.sql (revision 23904) +++ trunk/ippTools/share/difftool_pendingcleanupskyfile.sql (revision 23912) @@ -10,2 +10,3 @@ WHERE diffRun.state = 'goto_cleaned' + AND diffSkyfile.data_state = 'full' Index: trunk/ippTools/share/disttool_pendingdest.sql =================================================================== --- trunk/ippTools/share/disttool_pendingdest.sql (revision 23912) +++ trunk/ippTools/share/disttool_pendingdest.sql (revision 23912) @@ -0,0 +1,12 @@ +SELECT DISTINCT + rcDestination.*, + count(fs_id) as pending_fs +FROM rcDestination +JOIN rcRun using(dest_id) +WHERE rcRun.state = 'new' + AND rcDestination.state = 'enabled' + AND status_uri IS NOT NULL + -- where hook %s +GROUP BY dest_id +HAVING count(fs_id) > 0 + Index: trunk/ippTools/share/disttool_queuercrun.sql =================================================================== --- trunk/ippTools/share/disttool_queuercrun.sql (revision 23912) +++ trunk/ippTools/share/disttool_queuercrun.sql (revision 23912) @@ -0,0 +1,21 @@ +-- create rcRun's for all destinations that have filesets that they are interested in available +INSERT INTO rcRun +SELECT -- rows in this select must match rcRun + 0, -- rc_id (auto-increment) + fs_id, + dest_id, + 'new', + NULL, -- status_fs + NULL, -- registered (database sets this to CURRENT_TIMESTAMP) + 0 -- fault + +FROM rcDestination +JOIN rcInterest USING(dest_id) +JOIN distTarget USING(target_id) +JOIN rcDSProduct USING(prod_id) +JOIN distRun USING(target_id, stage) +JOIN rcDSFileset USING(prod_id, dist_id) +LEFT JOIN rcRun using(fs_id, dest_id) +WHERE rcRun.rc_id IS NULL + AND rcDSFileset.state = 'full' + AND rcDSFileset.fault = 0 Index: trunk/ippTools/share/disttool_revertrcrun.sql =================================================================== --- trunk/ippTools/share/disttool_revertrcrun.sql (revision 23912) +++ trunk/ippTools/share/disttool_revertrcrun.sql (revision 23912) @@ -0,0 +1,3 @@ +UPDATE rcRun SET fault = 0 +WHERE fault != 0 + Index: trunk/ippTools/share/disttool_updatercrun.sql =================================================================== --- trunk/ippTools/share/disttool_updatercrun.sql (revision 23912) +++ trunk/ippTools/share/disttool_updatercrun.sql (revision 23912) @@ -0,0 +1,9 @@ +UPDATE rcRun +JOIN rcDestination USING(dest_id) +JOIN rcDSProduct USING(prod_id) +JOIN rcDSFileset using(prod_id, fs_id) +SET + -- set hook %s +WHERE + rcRun.state = 'new' + Index: trunk/ippTools/share/pxadmin_create_tables.sql =================================================================== --- trunk/ippTools/share/pxadmin_create_tables.sql (revision 23904) +++ trunk/ippTools/share/pxadmin_create_tables.sql (revision 23912) @@ -1297,5 +1297,7 @@ dest_id BIGINT, state VARCHAR(64), + status_fs_name VARCHAR(64), registered TIMESTAMP DEFAULT CURRENT_TIMESTAMP, + fault SMALLINT DEFAULT 0, PRIMARY KEY(rc_id), FOREIGN KEY(fs_id) REFERENCES rcDSFileset(fs_id), Index: trunk/ippTools/share/rcserver_updatercrun.sql =================================================================== --- trunk/ippTools/share/rcserver_updatercrun.sql (revision 23912) +++ trunk/ippTools/share/rcserver_updatercrun.sql (revision 23912) @@ -0,0 +1,9 @@ +UPDATE rcRun +JOIN rcDestination USING(dest_id) +JOIN rcDSProduct USING(prod_id) +JOIN rcDSFileset using(prod_id, fs_id) +SET +rcRun.fault= 42, rcDestination.last_fileset = 'o4741g0236o.chip.14519.33.1' + + + Index: trunk/ippTools/src/disttool.c =================================================================== --- trunk/ippTools/src/disttool.c (revision 23904) +++ trunk/ippTools/src/disttool.c (revision 23912) @@ -45,5 +45,5 @@ static bool updatercrunMode(pxConfig *config); static bool revertrcrunMode(pxConfig *config); -static bool pendingdatastoresMode(pxConfig *config); +static bool pendingdestMode(pxConfig *config); # define MODECASE(caseName, func) \ @@ -80,5 +80,5 @@ MODECASE(DISTTOOL_MODE_UPDATERCRUN, updatercrunMode); MODECASE(DISTTOOL_MODE_REVERTRCRUN, revertrcrunMode); - MODECASE(DISTTOOL_MODE_PENDINGDATASTORES, pendingdatastoresMode); + MODECASE(DISTTOOL_MODE_PENDINGDEST, pendingdestMode); default: psAbort("invalid option (this should not happen)"); @@ -952,12 +952,11 @@ } -static bool pendingdatastoresMode(pxConfig *config) +static bool pendingdestMode(pxConfig *config) { PS_ASSERT_PTR_NON_NULL(config, false); -#ifdef notyet psMetadata *where = psMetadataAlloc(); - PXOPT_COPY_S64(config->args, where, "-dist_id", "dist_id", "=="); - PXOPT_COPY_STR(config->args, where, "-label", "label", "=="); + PXOPT_COPY_S64(config->args, where, "-dest_id", "dist_id", "=="); +// PXOPT_COPY_STR(config->args, where, "-label", "label", "=="); PXOPT_LOOKUP_U64(limit, config->args, "-limit", false, false); @@ -965,5 +964,5 @@ // look for "inputs" that need to processed - psString query = pxDataGet("disttool_pendingfileset.sql"); + psString query = pxDataGet("disttool_pendingdest.sql"); if (!query) { psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement"); @@ -971,7 +970,9 @@ } + psString whereString = NULL; if (psListLength(where->list)) { psString whereClause = psDBGenerateWhereConditionSQL(where, NULL); - psStringAppend(&query, " AND %s", whereClause); + // where string gets added by hook, not at the end of the query + psStringAppend(&whereString, "\n AND %s", whereClause); psFree(whereClause); } @@ -985,6 +986,7 @@ } - if (!p_psDBRunQuery(config->dbh, query)) { - psError(PS_ERR_UNKNOWN, false, "database error"); + if (!p_psDBRunQueryF(config->dbh, query, whereString ? whereString : "")) { + psError(PS_ERR_UNKNOWN, false, "database error"); + psFree(whereString); psFree(query); return false; @@ -1022,5 +1024,5 @@ psFree(output); -# endif // notdef + return true; } @@ -1029,14 +1031,184 @@ { PS_ASSERT_PTR_NON_NULL(config, false); - return true; -} + psMetadata *where = psMetadataAlloc(); + + PXOPT_COPY_S64(config->args, where, "-dist_id", "dist_id", "=="); + PXOPT_COPY_S64(config->args, where, "-dest_id", "dest_id", "=="); + PXOPT_COPY_S64(config->args, where, "-prod_id", "prod_id", "=="); + PXOPT_COPY_S64(config->args, where, "-target_id","target_id", "=="); + PXOPT_COPY_S64(config->args, where, "-fs_id", "fs_id", "=="); + PXOPT_COPY_STR(config->args, where, "-stage", "stage", "==");; + PXOPT_COPY_S64(config->args, where, "-stage_id", "stage_id", "=="); + PXOPT_COPY_STR(config->args, where, "-label", "label", "=="); + + PXOPT_LOOKUP_U64(limit, config->args, "-limit", false, false); + + psString query = pxDataGet("disttool_queuercrun.sql"); + if (!query) { + psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement"); + return false; + } + + if (psListLength(where->list)) { + psString whereClause = psDBGenerateWhereConditionSQL(where, NULL); + psStringAppend(&query, " AND %s", whereClause); + psFree(whereClause); + } + psFree(where); + + // treat limit == 0 as "no limit" + if (limit) { + psString limitString = psDBGenerateLimitSQL(limit); + psStringAppend(&query, " %s", limitString); + psFree(limitString); + } + + if (!p_psDBRunQuery(config->dbh, query)) { + psError(PS_ERR_UNKNOWN, false, "database error"); + psFree(query); + return false; + } + psFree(query); + + long numUpdated = psDBAffectedRows(config->dbh); + + psLogMsg("disttool", PS_LOG_INFO, "Inserted %ld rcRuns", numUpdated); + + return true; +} + + static bool updatercrunMode(pxConfig *config) { PS_ASSERT_PTR_NON_NULL(config, false); - return true; -} + + psMetadata *where = psMetadataAlloc(); + + PXOPT_LOOKUP_S64(rc_id, config->args, "-rc_id", false, false); + PXOPT_LOOKUP_STR(fs_name, config->args, "-fs_name", false, false); + PXOPT_LOOKUP_STR(status_fs_name, config->args, "-status_fs_name", false, false); + PXOPT_LOOKUP_S64(dest_id, config->args, "-dest_id", false, false); + + // We either need rc_id or (dest_id and fs_name) to identifiy the rcRun + if ((!rc_id) && !(dest_id && fs_name)) { + psError(PXTOOLS_ERR_DATA, true, "either -rc_id or (-fs_name and -dest_id) are required"); + return false; + } + + // now that we have done the argument checking + PXOPT_COPY_S64(config->args, where, "-rc_id", "rc_id", "=="); + PXOPT_COPY_STR(config->args, where, "-fs_name", "rcDSFileset.name", "=="); + PXOPT_COPY_S64(config->args, where, "-dest_id", "rcRun.dest_id", "=="); + + if (!psListLength(where->list)) { + // this can't happen because we checked above + psFree(where); + psError(PXTOOLS_ERR_DATA, false, "search parameters are required"); + return false; + } + + + PXOPT_LOOKUP_STR(last_fileset, config->args, "-last_fileset", false, false); + PXOPT_LOOKUP_STR(state, config->args, "-set_state", false, false); + PXOPT_LOOKUP_S16(fault, config->args, "-fault", false, false); + + if (!state && (fault < 0)) { + psError(PXTOOLS_ERR_DATA, false, "parameters (-fault or -set_state) are required"); + psFree(where); + return false; + } + + psString query = pxDataGet("disttool_updatercrun.sql"); + if (!query) { + psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement"); + return false; + } + + psString setString = psStringCopy("\n"); + psString separator = ""; + if (state) { + psStringAppend(&setString, " rcRun.state = '%s'", state); + separator = ","; + } + + // default for fault is -1, so set it if it's zero or higher. This allows clearing fault + // without forcing revert first + if (fault >= 0) { + psStringAppend(&setString, "%s rcRun.fault = %d", separator, fault); + } + + if (status_fs_name) { + psStringAppend(&setString, ", rcRun.status_fs_name = '%s'", status_fs_name); + } + + if (last_fileset) { + psStringAppend(&setString, ", rcDestination.last_fileset = '%s'", last_fileset); + } + + psString whereClause = psDBGenerateWhereConditionSQL(where, NULL); + psStringAppend(&query, " AND %s", whereClause); + psFree(whereClause); + psFree(where); + + if (!p_psDBRunQueryF(config->dbh, query, setString)) { + psError(PS_ERR_UNKNOWN, false, "database error"); + psFree(setString); + psFree(query); + return false; + } + psFree(setString); + psFree(query); + + long numUpdated = psDBAffectedRows(config->dbh); + + psLogMsg("disttool", PS_LOG_INFO, "Updated %ld rows", numUpdated); + + return true; +} + static bool revertrcrunMode(pxConfig *config) { PS_ASSERT_PTR_NON_NULL(config, false); - return true; -} + psMetadata *where = psMetadataAlloc(); + PXOPT_COPY_S64(config->args, where, "-rc_id", "rc_id", "=="); + PXOPT_COPY_S64(config->args, where, "-fs_id", "fs_id", "=="); + PXOPT_COPY_S64(config->args, where, "-dest_id", "dest_id", "=="); + PXOPT_COPY_S64(config->args, where, "-fault", "fault", "=="); + + if (!psListLength(where->list) && !psMetadataLookupBool(NULL, config->args, "-all")) { + psFree(where); + psError(PXTOOLS_ERR_DATA, false, "search parameters are required"); + return false; + } + + psString query = pxDataGet("disttool_revertrcrun.sql"); + if (!query) { + psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement"); + if (!psDBRollback(config->dbh)) { + psError(PS_ERR_UNKNOWN, false, "database error"); + } + return false; + } + + if (psListLength(where->list)) { + psString whereClause = psDBGenerateWhereConditionSQL(where, NULL); + psStringAppend(&query, " AND %s", whereClause); + psFree(whereClause); + } + + if (!p_psDBRunQuery(config->dbh, query)) { + psError(PS_ERR_UNKNOWN, false, "database error"); + psFree(query); + if (!psDBRollback(config->dbh)) { + psError(PS_ERR_UNKNOWN, false, "database error"); + } + return false; + } + psFree(query); + + long numUpdated = psDBAffectedRows(config->dbh); + + psLogMsg("disttool", PS_LOG_INFO, "Updated %ld rcRuns", numUpdated); + + return true; +} Index: trunk/ippTools/src/disttool.h =================================================================== --- trunk/ippTools/src/disttool.h (revision 23904) +++ trunk/ippTools/src/disttool.h (revision 23912) @@ -39,5 +39,5 @@ DISTTOOL_MODE_UPDATERCRUN, DISTTOOL_MODE_REVERTRCRUN, - DISTTOOL_MODE_PENDINGDATASTORES, + DISTTOOL_MODE_PENDINGDEST, } disttoolMode; Index: trunk/ippTools/src/disttoolConfig.c =================================================================== --- trunk/ippTools/src/disttoolConfig.c (revision 23904) +++ trunk/ippTools/src/disttoolConfig.c (revision 23912) @@ -120,6 +120,6 @@ psMetadata *toadvanceArgs = psMetadataAlloc(); psMetadataAddS64(toadvanceArgs, PS_LIST_TAIL, "-dist_id", 0, "define dist_id", 0); - psMetadataAddStr(toadvanceArgs, PS_LIST_TAIL, "-label", 0, "limit updates to label", NULL); - psMetadataAddU64(toadvanceArgs, PS_LIST_TAIL, "-limit", 0, "limit result set to N items", 0); + psMetadataAddStr(toadvanceArgs, PS_LIST_TAIL, "-label", 0, "limit updates to label", NULL); + psMetadataAddU64(toadvanceArgs, PS_LIST_TAIL, "-limit", 0, "limit result set to N items", 0); psMetadataAddBool(toadvanceArgs, PS_LIST_TAIL, "-simple", 0, "use the simple output format", false); @@ -127,7 +127,7 @@ psMetadata *pendingfilesetArgs = psMetadataAlloc(); psMetadataAddS64(pendingfilesetArgs, PS_LIST_TAIL, "-dist_id", 0, "define dist_id", 0); - psMetadataAddStr(pendingfilesetArgs, PS_LIST_TAIL, "-label", 0, "limit results to label", NULL); - psMetadataAddStr(pendingfilesetArgs, PS_LIST_TAIL, "-stage", 0, "limit results to runs for stage", NULL); - psMetadataAddU64(pendingfilesetArgs, PS_LIST_TAIL, "-limit", 0, "limit result set to N items", 0); + psMetadataAddStr(pendingfilesetArgs, PS_LIST_TAIL, "-label", 0, "limit results to label", NULL); + psMetadataAddStr(pendingfilesetArgs, PS_LIST_TAIL, "-stage", 0, "limit results to runs for stage", NULL); + psMetadataAddU64(pendingfilesetArgs, PS_LIST_TAIL, "-limit", 0, "limit result set to N items", 0); psMetadataAddBool(pendingfilesetArgs, PS_LIST_TAIL, "-simple", 0, "use the simple output format", false); @@ -136,26 +136,56 @@ psMetadataAddS64(addfilesetArgs, PS_LIST_TAIL, "-dist_id", 0, "define dist_id", 0); psMetadataAddS64(addfilesetArgs, PS_LIST_TAIL, "-prod_id", 0, "define prod_id", 0); - psMetadataAddStr(addfilesetArgs, PS_LIST_TAIL, "-name", 0, "define file name", NULL); - psMetadataAddS32(addfilesetArgs, PS_LIST_TAIL, "-fault", 0, "define fault code", 0); - // - // -pendingfileset - psMetadata *pendingdatastoresArgs = psMetadataAlloc(); - psMetadataAddS64(pendingdatastoresArgs, PS_LIST_TAIL, "-dist_id", 0, "define dist_id", 0); - psMetadataAddStr(pendingdatastoresArgs, PS_LIST_TAIL, "-label", 0, "limit results to label", NULL); - psMetadataAddStr(pendingdatastoresArgs, PS_LIST_TAIL, "-stage", 0, "limit results to runs for stage", NULL); - psMetadataAddU64(pendingdatastoresArgs, PS_LIST_TAIL, "-limit", 0, "limit result set to N items", 0); - psMetadataAddBool(pendingdatastoresArgs, PS_LIST_TAIL, "-simple", 0, "use the simple output format", false); + psMetadataAddStr(addfilesetArgs, PS_LIST_TAIL, "-name", 0, "define file name", NULL); + psMetadataAddS32(addfilesetArgs, PS_LIST_TAIL, "-fault", 0, "define fault code", 0); + + // -pendingdest + psMetadata *pendingdestArgs = psMetadataAlloc(); + psMetadataAddS64(pendingdestArgs, PS_LIST_TAIL, "-dest_id", 0, "define dest_id", 0); + psMetadataAddU64(pendingdestArgs, PS_LIST_TAIL, "-limit", 0, "limit result set to N items", 0); + psMetadataAddBool(pendingdestArgs, PS_LIST_TAIL, "-simple", 0, "use the simple output format", false); + psMetadataAddStr(pendingdestArgs, PS_LIST_TAIL, "-label", 0, "limit results to label", NULL); // -revertfileset psMetadata *revertfilesetArgs = psMetadataAlloc(); - psMetadataAddS64(revertfilesetArgs, PS_LIST_TAIL, "-fs_id", 0, "define fs_id", 0); + psMetadataAddS64(revertfilesetArgs, PS_LIST_TAIL, "-fs_id", 0, "define fs_id", 0); psMetadataAddS64(revertfilesetArgs, PS_LIST_TAIL, "-dist_id", 0, "define dist_id", 0); psMetadataAddS64(revertfilesetArgs, PS_LIST_TAIL, "-prod_id", 0, "define dist_id", 0); - psMetadataAddStr(revertfilesetArgs, PS_LIST_TAIL, "-stage", 0, "define stage", NULL); - psMetadataAddS64(revertfilesetArgs, PS_LIST_TAIL, "-stage_id", 0, "define stage_id", 0); - psMetadataAddStr(revertfilesetArgs, PS_LIST_TAIL, "-state", 0, "define state", NULL); - psMetadataAddStr(revertfilesetArgs, PS_LIST_TAIL, "-label", 0, "define label", NULL); - psMetadataAddS16(revertfilesetArgs, PS_LIST_TAIL, "-fault", 0, "define fault code", 0); + psMetadataAddStr(revertfilesetArgs, PS_LIST_TAIL, "-stage", 0, "define stage", NULL); + psMetadataAddS64(revertfilesetArgs, PS_LIST_TAIL, "-stage_id",0, "define stage_id", 0); + psMetadataAddStr(revertfilesetArgs, PS_LIST_TAIL, "-state", 0, "define state", NULL); + psMetadataAddStr(revertfilesetArgs, PS_LIST_TAIL, "-label", 0, "define label", NULL); + psMetadataAddS16(revertfilesetArgs, PS_LIST_TAIL, "-fault", 0, "define fault code", 0); psMetadataAddBool(revertfilesetArgs, PS_LIST_TAIL, "-all", 0, "revert all faulted runs", NULL); + + // -queuercrun + psMetadata *queuercrunArgs = psMetadataAlloc(); + psMetadataAddS64(queuercrunArgs, PS_LIST_TAIL, "-dist_id", 0, "define dist_id", 0); + psMetadataAddS64(queuercrunArgs, PS_LIST_TAIL, "-dest_id", 0, "define dest_id", 0); + psMetadataAddS64(queuercrunArgs, PS_LIST_TAIL, "-prod_id", 0, "define prod_id", 0); + psMetadataAddS64(queuercrunArgs, PS_LIST_TAIL, "-target_id", 0, "define target_id", 0); + psMetadataAddS64(queuercrunArgs, PS_LIST_TAIL, "-fs_id", 0, "define fs_id", 0); + psMetadataAddStr(queuercrunArgs, PS_LIST_TAIL, "-stage", 0, "define stage", NULL); + psMetadataAddS64(queuercrunArgs, PS_LIST_TAIL, "-stage_id", 0, "define stage_id", 0); + psMetadataAddStr(queuercrunArgs, PS_LIST_TAIL, "-state", 0, "define state", NULL); + psMetadataAddStr(queuercrunArgs, PS_LIST_TAIL, "-label", 0, "define label", NULL); + psMetadataAddU64(queuercrunArgs, PS_LIST_TAIL, "-limit", 0, "limit number of runs queued to N", 0); + + // -updatercrun + psMetadata *updatercrunArgs = psMetadataAlloc(); + psMetadataAddS64(updatercrunArgs, PS_LIST_TAIL, "-rc_id", 0, "define rc_id", 0); + psMetadataAddS64(updatercrunArgs, PS_LIST_TAIL, "-dest_id", 0, "define dest_id", 0); + psMetadataAddStr(updatercrunArgs, PS_LIST_TAIL, "-fs_name", 0, "define fileset name", NULL); + psMetadataAddStr(updatercrunArgs, PS_LIST_TAIL, "-status_fs_name", 0, "define status fileset name", NULL); + psMetadataAddStr(updatercrunArgs, PS_LIST_TAIL, "-set_state",0, "new value for state", NULL); + psMetadataAddStr(updatercrunArgs, PS_LIST_TAIL, "-last_fileset",0, "new value for last_fileset", NULL); + psMetadataAddS16(updatercrunArgs, PS_LIST_TAIL, "-fault", 0, "define fault code", -1); + + // -revertrcrun + psMetadata *revertrcrunArgs = psMetadataAlloc(); + psMetadataAddS64(revertrcrunArgs, PS_LIST_TAIL, "-rc_id", 0, "define rc_id", 0); + psMetadataAddS64(revertrcrunArgs, PS_LIST_TAIL, "-fs_id", 0, "define fs_id", 0); + psMetadataAddS64(revertrcrunArgs, PS_LIST_TAIL, "-dest_id", 0, "define dest_id", 0); + psMetadataAddS16(revertrcrunArgs, PS_LIST_TAIL, "-fault", 0, "define fault code", 0); + psMetadataAddBool(revertrcrunArgs, PS_LIST_TAIL, "-all", 0, "revert all faulted runs", NULL); psMetadata *argSets = psMetadataAlloc(); @@ -168,10 +198,13 @@ PXOPT_ADD_MODE("-pendingcomponent", "", DISTTOOL_MODE_PENDINGCOMPONENT, pendingcomponentArgs); PXOPT_ADD_MODE("-addprocessedcomponent", "", DISTTOOL_MODE_ADDPROCESSEDCOMPONENT, addprocessedcomponentArgs); - PXOPT_ADD_MODE("-processedcomponent", "", DISTTOOL_MODE_PROCESSEDCOMPONENT, processedcomponentArgs); - PXOPT_ADD_MODE("-toadvance", "", DISTTOOL_MODE_TOADVANCE, toadvanceArgs); - PXOPT_ADD_MODE("-pendingfileset", "", DISTTOOL_MODE_PENDINGFILESET, pendingfilesetArgs); - PXOPT_ADD_MODE("-addfileset", "", DISTTOOL_MODE_ADDFILESET, addfilesetArgs); + PXOPT_ADD_MODE("-processedcomponent", "", DISTTOOL_MODE_PROCESSEDCOMPONENT, processedcomponentArgs); + PXOPT_ADD_MODE("-toadvance", "", DISTTOOL_MODE_TOADVANCE, toadvanceArgs); + PXOPT_ADD_MODE("-pendingfileset", "", DISTTOOL_MODE_PENDINGFILESET, pendingfilesetArgs); + PXOPT_ADD_MODE("-addfileset", "", DISTTOOL_MODE_ADDFILESET, addfilesetArgs); PXOPT_ADD_MODE("-revertfileset", "", DISTTOOL_MODE_REVERTFILESET, revertfilesetArgs); - PXOPT_ADD_MODE("-pendingdatastores", "", DISTTOOL_MODE_PENDINGDATASTORES, pendingdatastoresArgs); + PXOPT_ADD_MODE("-queuercrun", "", DISTTOOL_MODE_QUEUERCRUN, queuercrunArgs); + PXOPT_ADD_MODE("-updatercrun", "", DISTTOOL_MODE_UPDATERCRUN, updatercrunArgs); + PXOPT_ADD_MODE("-revertrcrun", "", DISTTOOL_MODE_REVERTRCRUN, revertrcrunArgs); + PXOPT_ADD_MODE("-pendingdest", "", DISTTOOL_MODE_PENDINGDEST, pendingdestArgs); if (!pxGetOptions(stderr, argc, argv, config, modes, argSets)) {