+ char enabled[5];
+ int rc;
+
+ LASSERT(qsd != NULL);
+
+ memset(enabled, 0, sizeof(enabled));
+ if (qsd_type_enabled(qsd, USRQUOTA))
+ strcat(enabled, "u");
+ if (qsd_type_enabled(qsd, GRPQUOTA))
+ strcat(enabled, "g");
+ if (strlen(enabled) == 0)
+ strcat(enabled, "none");
+
+ rc = snprintf(page, count,
+ "target name: %s\n"
+ "pool ID: %d\n"
+ "type: %s\n"
+ "quota enabled: %s\n"
+ "conn to master: %s\n",
+ qsd->qsd_svname, qsd->qsd_pool_id,
+ qsd->qsd_is_md ? "md" : "dt", enabled,
+ qsd->qsd_exp_valid ? "setup" : "not setup yet");
+
+ if (qsd->qsd_prepared) {
+ memset(enabled, 0, sizeof(enabled));
+ if (qsd->qsd_type_array[USRQUOTA]->qqi_acct_obj != NULL)
+ strcat(enabled, "u");
+ if (qsd->qsd_type_array[GRPQUOTA]->qqi_acct_obj != NULL)
+ strcat(enabled, "g");
+ if (strlen(enabled) == 0)
+ strcat(enabled, "none");
+ rc += snprintf(page + rc, count - rc,
+ "space acct: %s\n"
+ "user uptodate: glb[%d],slv[%d],reint[%d]\n"
+ "group uptodate: glb[%d],slv[%d],reint[%d]\n",
+ enabled,
+ qsd->qsd_type_array[USRQUOTA]->qqi_glb_uptodate,
+ qsd->qsd_type_array[USRQUOTA]->qqi_slv_uptodate,
+ qsd->qsd_type_array[USRQUOTA]->qqi_reint,
+ qsd->qsd_type_array[GRPQUOTA]->qqi_glb_uptodate,
+ qsd->qsd_type_array[GRPQUOTA]->qqi_slv_uptodate,
+ qsd->qsd_type_array[GRPQUOTA]->qqi_reint);
+ }
+ return rc;
+}
+
+static int lprocfs_qsd_rd_enabled(char *page, char **start, off_t off,
+ int count, int *eof, void *data)
+{
+ struct qsd_instance *qsd = (struct qsd_instance *)data;
+ char enabled[5];
+
+ LASSERT(qsd != NULL);
+
+ memset(enabled, 0, sizeof(enabled));
+ if (qsd_type_enabled(qsd, USRQUOTA))
+ strcat(enabled, "u");
+ if (qsd_type_enabled(qsd, GRPQUOTA))
+ strcat(enabled, "g");
+ if (strlen(enabled) == 0)
+ strcat(enabled, "none");
+
+ return snprintf(page, count, "%s\n", enabled);
+}
+
+/* force reintegration procedure to be executed.
+ * Used for test/debugging purpose */
+static int lprocfs_qsd_wr_force_reint(struct file *file, const char *buffer,
+ unsigned long count, void *data)
+{
+ struct qsd_instance *qsd = (struct qsd_instance *)data;
+ int rc = 0, qtype;
+
+ LASSERT(qsd != NULL);
+
+ write_lock(&qsd->qsd_lock);
+ if (qsd->qsd_stopping) {
+ /* don't mess up with shutdown procedure, it is already
+ * complicated enough */
+ rc = -ESHUTDOWN;
+ } else if (!qsd->qsd_prepared) {
+ rc = -EAGAIN;
+ } else {
+ /* mark all indexes as stale */
+ for (qtype = USRQUOTA; qtype < MAXQUOTAS; qtype++) {
+ qsd->qsd_type_array[qtype]->qqi_glb_uptodate = false;
+ qsd->qsd_type_array[qtype]->qqi_slv_uptodate = false;
+ }
+ }
+ write_unlock(&qsd->qsd_lock);
+
+ if (rc)
+ return rc;
+
+ /* kick off reintegration */
+ for (qtype = USRQUOTA; qtype < MAXQUOTAS; qtype++) {
+ rc = qsd_start_reint_thread(qsd->qsd_type_array[qtype]);
+ if (rc)
+ break;
+ }
+ return rc == 0 ? count : rc;
+}
+
+static int lprocfs_qsd_rd_timeout(char *page, char **start, off_t off,
+ int count, int *eof, void *data)
+{
+ struct qsd_instance *qsd = (struct qsd_instance *)data;
+ LASSERT(qsd != NULL);
+
+ return snprintf(page, count, "%d\n", qsd_wait_timeout(qsd));
+}