"sequence client %s\n", seq->lss_name,
cli->lcs_name);
- /* asking client for new range, assign that range to ->seq_super and
- * write seq state to backing store should be atomic. */
+ /*
+ * Asking client for new range, assign that range to ->seq_super and
+ * write seq state to backing store should be atomic.
+ */
down(&seq->lss_sem);
- /* assign controller */
+ /* Assign controller */
seq->lss_cli = cli;
- /* get new range from controller only if super-sequence is not yet
- * initialized from backing store or something else. */
+ /*
+ * Get new range from controller only if super-sequence is not yet
+ * initialized from backing store or something else.
+ */
if (range_is_zero(&seq->lss_super)) {
rc = seq_client_alloc_super(cli, env);
if (rc) {
}
EXPORT_SYMBOL(seq_server_set_cli);
-/* on controller node, allocate new super sequence for regular sequence
- * server. */
+/*
+ * On controller node, allocate new super sequence for regular sequence server.
+ */
static int __seq_server_alloc_super(struct lu_server_seq *seq,
struct lu_range *in,
struct lu_range *out,
CERROR("%s: Can't allocate new meta-sequence, "
"rc %d\n", seq->lcs_name, rc);
RETURN(rc);
+ } else {
+ CDEBUG(D_INFO|D_WARNING, "%s: New range - "DRANGE"\n",
+ seq->lcs_name, &seq->lcs_range);
}
}
/* inform caller that sequence switch is performed to allow it
* to setup FLD for it. */
rc = 1;
+
+ CDEBUG(D_INFO|D_WARNING, "%s: New sequence - "LPX64"\n",
+ seq->lcs_name, seqnr);
} else {
seq->lcs_fid.f_oid++;
rc = 0;
seq_record_buf(info),
&pos, th, BYPASS_CAPA);
if (rc == sizeof(info->sti_record)) {
- if (seq->lss_type == LUSTRE_SEQ_SERVER) {
- CDEBUG(D_INFO|D_WARNING, "%s: Pool - "DRANGE"\n",
- seq->lss_name, PRANGE(&seq->lss_super));
- } else {
- CDEBUG(D_INFO|D_WARNING, "%s: Space - "DRANGE
- ", Pool - "DRANGE"\n", seq->lss_name,
- PRANGE(&seq->lss_space), PRANGE(&seq->lss_super));
- }
+ struct lu_range *r = (seq->lss_type == LUSTRE_SEQ_SERVER ?
+ &seq->lss_super : &seq->lss_space);
+
+ CDEBUG(D_INFO|D_WARNING, "%s: Space - "DRANGE"\n",
+ seq->lss_name, PRANGE(r));
rc = 0;
} else if (rc >= 0) {
rc = -EIO;
BYPASS_CAPA);
if (rc == sizeof(info->sti_record)) {
+ struct lu_range *r = (seq->lss_type == LUSTRE_SEQ_SERVER ?
+ &seq->lss_super : &seq->lss_space);
+
range_le_to_cpu(&seq->lss_space, &info->sti_record.ssr_space);
range_le_to_cpu(&seq->lss_super, &info->sti_record.ssr_super);
- if (seq->lss_type == LUSTRE_SEQ_SERVER) {
- CDEBUG(D_INFO|D_WARNING, "%s: Pool - "DRANGE"\n",
- seq->lss_name, PRANGE(&seq->lss_super));
- } else {
- CDEBUG(D_INFO|D_WARNING, "%s: Space - "DRANGE", Pool - "
- DRANGE"\n", seq->lss_name, PRANGE(&seq->lss_space),
- PRANGE(&seq->lss_super));
- }
+ CDEBUG(D_INFO|D_WARNING, "%s: Space - "DRANGE"\n",
+ seq->lss_name, PRANGE(r));
rc = 0;
} else if (rc == 0) {
rc = -ENODATA;