ENTRY;
if (cli == NULL) {
- CDEBUG(D_INFO|D_WARNING, "%s: detached "
- "sequence mgr client %s\n",
- seq->lss_name, cli->lcs_name);
+ CDEBUG(D_INFO|D_WARNING, "%s: Detached "
+ "sequence client %s\n", seq->lss_name,
+ cli->lcs_name);
seq->lss_cli = cli;
RETURN(0);
}
if (seq->lss_cli) {
- CERROR("%s: sequence-controller is already "
+ CERROR("%s: Sequence-controller is already "
"assigned\n", seq->lss_name);
RETURN(-EINVAL);
}
- CDEBUG(D_INFO|D_WARNING, "%s: attached "
+ CDEBUG(D_INFO|D_WARNING, "%s: Attached "
"sequence client %s\n", seq->lss_name,
cli->lcs_name);
rc = seq_client_alloc_super(cli, ctx);
if (rc) {
up(&seq->lss_sem);
- CERROR("Can't allocate super-sequence, "
- "rc %d\n", rc);
+ CERROR("%s: Can't allocate super-sequence, "
+ "rc %d\n", seq->lss_name, rc);
RETURN(rc);
}
/* save init seq to backing store. */
rc = seq_store_write(seq, ctx);
if (rc) {
- CERROR("Can't write sequence state, "
- "rc = %d\n", rc);
+ CERROR("%s: Can't write sequence state, "
+ "rc = %d\n", seq->lss_name, rc);
}
}
LASSERT(range_is_sane(space));
if (in != NULL) {
- CDEBUG(D_INFO, "%s: recovery - use input range "
+ CDEBUG(D_INFO, "%s: Recovery - use input range "
DRANGE"\n", seq->lss_name, PRANGE(in));
if (in->lr_start > space->lr_start)
*out = *in;
} else {
if (range_space(space) < seq->lss_super_width) {
- CWARN("Sequences space is going to exhaust soon. "
- "Can allocate only "LPU64" sequences\n",
+ CWARN("%s: Sequences space to be exhausted soon. "
+ "Only "LPU64" sequences left\n", seq->lss_name,
range_space(space));
*out = *space;
space->lr_start = space->lr_end;
} else if (range_is_exhausted(space)) {
- CERROR("Sequences space is exhausted\n");
+ CERROR("%s: Sequences space is exhausted\n",
+ seq->lss_name);
RETURN(-ENOSPC);
} else {
range_alloc(out, space, seq->lss_super_width);
rc = seq_store_write(seq, ctx);
if (rc) {
- CERROR("Can't save state, rc = %d\n",
- rc);
+ CERROR("%s: Can't save state, rc %d\n", seq->lss_name, rc);
RETURN(rc);
}
- CDEBUG(D_INFO, "%s: allocated super-sequence "
+ CDEBUG(D_INFO, "%s: Allocated super-sequence "
DRANGE"\n", seq->lss_name, PRANGE(out));
RETURN(rc);
* it is allocated from new super.
*/
if (in != NULL) {
- CDEBUG(D_INFO, "%s: recovery - use input range "
+ CDEBUG(D_INFO, "%s: Recovery - use input range "
DRANGE"\n", seq->lss_name, PRANGE(in));
if (range_is_exhausted(super)) {
*/
if (range_is_exhausted(super)) {
if (!seq->lss_cli) {
- CERROR("No seq-controller client is setup\n");
+ CERROR("%s: No sequence controller client "
+ "is setup\n", seq->lss_name);
RETURN(-EOPNOTSUPP);
}
rc = seq_client_alloc_super(seq->lss_cli, ctx);
if (rc) {
- CERROR("Can't allocate new super-sequence, "
- "rc %d\n", rc);
+ CERROR("%s: Can't allocate super-sequence, "
+ "rc %d\n", seq->lss_name, rc);
RETURN(rc);
}
rc = seq_store_write(seq, ctx);
if (rc) {
- CERROR("Can't save state, rc = %d\n",
- rc);
+ CERROR("%s: Can't save state, rc = %d\n",
+ seq->lss_name, rc);
}
if (rc == 0) {
- CDEBUG(D_INFO, "%s: allocated meta-sequence "
+ CDEBUG(D_INFO, "%s: Allocated meta-sequence "
DRANGE"\n", seq->lss_name, PRANGE(out));
}
switch (opc) {
case SEQ_ALLOC_META:
if (!site->ls_server_seq) {
- CERROR("Sequence-server is not "
+ CERROR("Sequence server is not "
"initialized\n");
RETURN(-EINVAL);
}
rc = lprocfs_add_vars(seq->lss_proc_dir,
seq_server_proc_list, seq);
if (rc) {
- CERROR("Can't init sequence manager "
- "proc, rc %d\n", rc);
+ CERROR("%s: Can't init sequence manager "
+ "proc, rc %d\n", seq->lss_name, rc);
GOTO(out_cleanup, rc);
}
seq->lss_super_width = LUSTRE_SEQ_SUPER_WIDTH;
seq->lss_meta_width = LUSTRE_SEQ_META_WIDTH;
- snprintf(seq->lss_name, sizeof(seq->lss_name), "%s-%s",
- (is_srv ? "srv" : "ctl"), prefix);
+ snprintf(seq->lss_name, sizeof(seq->lss_name),
+ "%s-%s", (is_srv ? "srv" : "ctl"), prefix);
seq->lss_space = LUSTRE_SEQ_SPACE_RANGE;
seq->lss_super = LUSTRE_SEQ_ZERO_RANGE;
/* request backing store for saved sequence info */
rc = seq_store_read(seq, ctx);
if (rc == -ENODATA) {
- CDEBUG(D_INFO|D_WARNING, "%s: no data on "
- "storage was found, %s\n", seq->lss_name,
+ CDEBUG(D_INFO|D_WARNING, "%s: No data found "
+ "on storage, %s\n", seq->lss_name,
is_srv ? "wait for controller attach" :
"this is first controller run");
} else if (rc) {
- CERROR("can't read sequence state, rc = %d\n",
- rc);
+ CERROR("%s: Can't read sequence state, rc %d\n",
+ seq->lss_name, rc);
GOTO(out, rc);
}
EXIT;
out:
- if (rc) {
+ if (rc)
seq_server_fini(seq, ctx);
- } else {
- CDEBUG(D_INFO|D_WARNING, "%s Sequence Manager\n",
- (is_srv ? "Server" : "Controller"));
- }
return rc;
}
EXPORT_SYMBOL(seq_server_init);
*range = *out;
if (!range_is_sane(range)) {
- CERROR("Invalid seq range obtained from server: "
- DRANGE"\n", PRANGE(range));
+ CERROR("%s: Invalid range received from server: "
+ DRANGE"\n", seq->lcs_name, PRANGE(range));
GOTO(out_req, rc = -EINVAL);
}
if (range_is_exhausted(range)) {
- CERROR("Seq range obtained from server is exhausted: "
- DRANGE"]\n", PRANGE(range));
+ CERROR("%s: Range received from server is exhausted: "
+ DRANGE"]\n", seq->lcs_name, PRANGE(range));
GOTO(out_req, rc = -EINVAL);
}
/* Save server out to request for recovery case. */
*in = *out;
- CDEBUG(D_INFO, "%s: allocated %s-sequence "
- DRANGE"]\n", seq->lcs_name, opcname,
- PRANGE(range));
+ CDEBUG(D_INFO, "%s: Allocated %s-sequence "DRANGE"]\n",
+ seq->lcs_name, opcname, PRANGE(range));
EXIT;
out_req:
if (range_space(&seq->lcs_range) == 0) {
rc = __seq_client_alloc_meta(seq, NULL);
if (rc) {
- CERROR("Can't allocate new meta-sequence, "
- "rc %d\n", rc);
+ CERROR("%s: Can't allocate new meta-sequence, "
+ "rc %d\n", seq->lcs_name, rc);
RETURN(rc);
}
}
*seqnr = seq->lcs_range.lr_start;
seq->lcs_range.lr_start++;
- CDEBUG(D_INFO, "%s: allocated sequence ["LPX64"]\n",
+ CDEBUG(D_INFO, "%s: Allocated sequence ["LPX64"]\n",
seq->lcs_name, *seqnr);
RETURN(rc);
}
* or sequence is exhausted and should be switched. */
rc = __seq_client_alloc_seq(seq, &seqnr);
if (rc) {
- CERROR("Can't allocate new sequence, "
- "rc %d\n", rc);
+ CERROR("%s: Can't allocate new sequence, "
+ "rc %d\n", seq->lcs_name, rc);
GOTO(out, rc);
}
*fid = seq->lcs_fid;
LASSERT(fid_is_sane(fid));
- CDEBUG(D_INFO, "%s: allocated FID "DFID"\n",
+ CDEBUG(D_INFO, "%s: Allocated FID "DFID"\n",
seq->lcs_name, PFID(fid));
EXIT;
NULL, NULL);
if (IS_ERR(seq->lcs_proc_dir)) {
- CERROR("LProcFS failed in seq-init\n");
+ CERROR("%s: LProcFS failed in seq-init\n",
+ seq->lcs_name);
rc = PTR_ERR(seq->lcs_proc_dir);
RETURN(rc);
}
rc = lprocfs_add_vars(seq->lcs_proc_dir,
seq_client_proc_list, seq);
if (rc) {
- CERROR("Can't init sequence manager "
- "proc, rc %d\n", rc);
+ CERROR("%s: Can't init sequence manager "
+ "proc, rc %d\n", seq->lcs_name, rc);
GOTO(out_cleanup, rc);
}
rc = seq_client_proc_init(seq);
if (rc)
seq_client_fini(seq);
- else
- CDEBUG(D_INFO|D_WARNING,
- "Client Sequence Manager\n");
RETURN(rc);
}
EXPORT_SYMBOL(seq_client_init);
}
seq->lcs_srv = NULL;
-
- CDEBUG(D_INFO|D_WARNING,
- "Client Sequence Manager\n");
-
EXIT;
}
EXPORT_SYMBOL(seq_client_fini);
sizeof(info->sti_record),
&pos, th);
if (rc == sizeof(info->sti_record)) {
- CDEBUG(D_INFO|D_WARNING, "store %s ranges: space - "
- DRANGE", super - "DRANGE"\n",
- (seq->lss_type == LUSTRE_SEQ_SERVER ?
- "server" : "controller"),
+ CDEBUG(D_INFO|D_WARNING, "%s: Store ranges: Space - "
+ DRANGE", Super - "DRANGE"\n", seq->lss_name,
PRANGE(&seq->lss_space), PRANGE(&seq->lss_super));
-
rc = 0;
} else if (rc >= 0) {
rc = -EIO;
range_le_to_cpu(&seq->lss_space, &info->sti_record.ssr_space);
range_le_to_cpu(&seq->lss_super, &info->sti_record.ssr_super);
- CDEBUG(D_INFO|D_WARNING, "Read %s ranges: space - "DRANGE", super "
- "- "DRANGE"\n", (seq->lss_type == LUSTRE_SEQ_SERVER ?
- "server" : "controller"),
+ CDEBUG(D_INFO|D_WARNING, "%s: Read ranges: Space - "
+ DRANGE", Super - "DRANGE"\n", seq->lss_name,
PRANGE(&seq->lss_space), PRANGE(&seq->lss_super));
rc = 0;
} else if (rc == 0) {
rc = -ENODATA;
} else if (rc >= 0) {
- CERROR("Read only %d bytes of %d\n", rc,
- sizeof(info->sti_record));
+ CERROR("%s: Read only %d bytes of %d\n", seq->lss_name,
+ rc, sizeof(info->sti_record));
rc = -EIO;
}
ENTRY;
name = seq->lss_type == LUSTRE_SEQ_SERVER ?
- "seq_srv" : "seq_ctl";
+ LUSTRE_SEQ_SRV_NAME : LUSTRE_SEQ_CTL_NAME;
dt_obj = dt_store_open(ctx, dt, name, &fid);
if (!IS_ERR(dt_obj)) {
seq->lss_obj = dt_obj;
rc = 0;
} else {
- CERROR("Can't find \"seq\" obj %d\n",
- (int)PTR_ERR(dt_obj));
+ CERROR("%s: Can't find \"%s\" obj %d\n",
+ seq->lss_name, name, (int)PTR_ERR(dt_obj));
rc = PTR_ERR(dt_obj);
}
LASSERT(range != NULL);
- rc = sscanf(buffer, DRANGE"\n",
- &tmp.lr_start, &tmp.lr_end);
-
- /* did not match 2 values */
- if (rc != 2 || !range_is_sane(&tmp) || range_is_zero(&tmp)) {
- CERROR("Can't parse input string or input is not correct\n");
+ rc = sscanf(buffer, "[%Lx - %Lx]\n", &tmp.lr_start, &tmp.lr_end);
+ if (rc != 2 || !range_is_sane(&tmp) || range_is_zero(&tmp))
RETURN(-EINVAL);
- }
-
*range = tmp;
RETURN(0);
}
rc = seq_proc_write_common(file, buffer, count,
data, &seq->lss_space);
if (rc == 0) {
- CDEBUG(D_WARNING, "%s: sequences space has "
+ CDEBUG(D_WARNING, "%s: Sequences space has "
"changed to "DRANGE"\n", seq->lss_name,
PRANGE(&seq->lss_space));
}
data, &seq->lss_super);
if (rc == 0) {
- CDEBUG(D_WARNING, "%s: super-sequence has "
- "changed to "DRANGE"\n", seq->lss_name,
- PRANGE(&seq->lss_super));
+ CDEBUG(D_WARNING, "%s: Super has changed to "
+ DRANGE"\n", seq->lss_name, PRANGE(&seq->lss_super));
}
up(&seq->lss_sem);
seq->lss_super_width = val;
if (rc == 0) {
- CDEBUG(D_WARNING, "%s: super-sequence width "
- "has changed to "LPU64"\n", seq->lss_name,
- seq->lss_super_width);
+ CDEBUG(D_WARNING, "%s: Super width has changed to "
+ LPU64"\n", seq->lss_name, seq->lss_super_width);
}
up(&seq->lss_sem);
seq->lss_meta_width = val;
if (rc == 0) {
- CDEBUG(D_WARNING, "%s: meta-sequence width "
- "has changed to "LPU64"\n", seq->lss_name,
- seq->lss_meta_width);
+ CDEBUG(D_WARNING, "%s: Meta width has changed to "
+ LPU64"\n", seq->lss_name, seq->lss_meta_width);
}
}
data, &seq->lcs_range);
if (rc == 0) {
- CDEBUG(D_WARNING, "%s: range has changed to "
- DRANGE"\n", seq->lcs_name,
- PRANGE(&seq->lcs_range));
+ CDEBUG(D_WARNING, "%s: Range has changed to "
+ DRANGE"\n", seq->lcs_name, PRANGE(&seq->lcs_range));
}
up(&seq->lcs_sem);
seq->lcs_width = val;
if (rc == 0) {
- CDEBUG(D_WARNING, "%s: sequence width "
+ CDEBUG(D_WARNING, "%s: Sequence width "
"has changed to "LPU64"\n",
seq->lcs_name, seq->lcs_width);
}
for (i = 0; i < hash_size; i++)
INIT_HLIST_HEAD(&cache->fci_hash_table[i]);
- CDEBUG(D_INFO|D_WARNING, "FLD cache - htable: %d, "
- "size: %d, threshold: %d\n", hash_size,
+ CDEBUG(D_INFO|D_WARNING, "FLD cache: Size: %d, Threshold: %d\n",
cache_size, cache_threshold);
RETURN(cache);
out:
if (rc)
fld_server_fini(fld, ctx);
- else
- CDEBUG(D_INFO|D_WARNING, "Server FLD\n");
return rc;
}
EXPORT_SYMBOL(fld_server_init);
if (rc == 0)
LASSERT(dt_obj->do_index_ops != NULL);
else
- CERROR("File \"%s\" is not an index!\n",
- fld_index_name);
+ CERROR("%s: File \"%s\" is not an index!\n",
+ fld->lsf_name, fld_index_name);
} else {
- CERROR("Can't find \"%s\" obj %d\n",
- fld_index_name, (int)PTR_ERR(dt_obj));
+ CERROR("%s: Can't find \"%s\" obj %d\n",
+ fld->lsf_name, fld_index_name, (int)PTR_ERR(dt_obj));
rc = PTR_ERR(dt_obj);
}
LASSERT(tar_name != NULL);
LASSERT(tar->ft_srv != NULL || tar->ft_exp != NULL);
- CDEBUG(D_INFO|D_WARNING, "%s: adding target %s\n",
+ CDEBUG(D_INFO|D_WARNING, "%s: Adding target %s\n",
fld->lcf_name, tar_name);
OBD_ALLOC_PTR(target);
NULL, NULL);
if (IS_ERR(fld->lcf_proc_dir)) {
- CERROR("LProcFS failed in fld-init\n");
+ CERROR("%s: LProcFS failed in fld-init\n",
+ fld->lcf_name);
rc = PTR_ERR(fld->lcf_proc_dir);
RETURN(rc);
}
rc = lprocfs_add_vars(fld->lcf_proc_dir,
fld_client_proc_list, fld);
if (rc) {
- CERROR("Can't init FLD proc, rc %d\n", rc);
+ CERROR("%s: Can't init FLD proc, rc %d\n",
+ fld->lcf_name, rc);
GOTO(out_cleanup, rc);
}
LASSERT(fld != NULL);
+ snprintf(fld->lcf_name, sizeof(fld->lcf_name),
+ "cli-%s", prefix);
+
if (!hash_is_sane(hash)) {
- CERROR("Wrong hash function %#x\n", hash);
+ CERROR("%s: Wrong hash function %#x\n",
+ fld->lcf_name, hash);
RETURN(-EINVAL);
}
fld->lcf_hash = &fld_hash[hash];
INIT_LIST_HEAD(&fld->lcf_targets);
- snprintf(fld->lcf_name, sizeof(fld->lcf_name),
- "cli-%s", prefix);
-
#ifdef __KERNEL__
cache_size = FLD_CACHE_SIZE /
sizeof(struct fld_cache_entry);
fld_client_fini(fld);
else
CDEBUG(D_INFO|D_WARNING,
- "Client FLD, using \"%s\" hash\n",
- fld->lcf_hash->fh_name);
+ "%s: Using \"%s\" hash\n",
+ fld->lcf_name, fld->lcf_hash->fh_name);
return rc;
}
EXPORT_SYMBOL(fld_client_init);
}
#endif
- CDEBUG(D_INFO|D_WARNING, "Client FLD finalized\n");
EXIT;
}
EXPORT_SYMBOL(fld_client_fini);
*/
fld_cache_insert(fld->lcf_cache, seq, mds);
} else {
- CERROR("Can't create FLD entry, rc %d\n", rc);
+ CERROR("%s: Can't create FLD entry, rc %d\n",
+ fld->lcf_name, rc);
}
RETURN(rc);
}
fld->lcf_hash = hash;
spin_unlock(&fld->lcf_lock);
- CDEBUG(D_WARNING, "%s: changed hash to \"%s\"\n",
+ CDEBUG(D_WARNING, "%s: Changed hash to \"%s\"\n",
fld->lcf_name, hash->fh_name);
}
fld_cache_flush(fld->lcf_cache);
- CDEBUG(D_WARNING, "%s: lookup cache is flushed\n",
+ CDEBUG(D_WARNING, "%s: Lookup cache is flushed\n",
fld->lcf_name);
RETURN(count);
return range_space(r) == 0;
}
-#define DRANGE "["LPU64"-"LPU64"]"
+#define DRANGE "["LPX64"-"LPX64"]"
#define PRANGE(range) \
(range)->lr_start, \
return name;
}
-
+#define LUSTRE_SEQ_SRV_NAME "seq_srv"
+#define LUSTRE_SEQ_CTL_NAME "seq_ctl"
/* Range common stuff */
void range_cpu_to_le(struct lu_range *dst, const struct lu_range *src);