CDEBUG(D_NET, "starting connect to %s\n",
libcfs_nid2str(peer->gnp_nid));
- LASSERTF(peer->gnp_connecting == GNILND_PEER_IDLE, "Peer was idle and we"
- "have a write_lock, state issue %d\n", peer->gnp_connecting);
+ LASSERTF(peer->gnp_connecting == GNILND_PEER_IDLE,
+ "Peer was idle and we have a write_lock, state issue %d\n",
+ peer->gnp_connecting);
peer->gnp_connecting = GNILND_PEER_CONNECT;
kgnilnd_peer_addref(peer); /* extra ref for connd */
/* set overrun too */
event_data |= (1UL << 63);
LASSERTF(GNI_CQ_OVERRUN(event_data),
- "(1UL << 63) is no longer the bit to"
- "set to indicate CQ_OVERRUN\n");
+ "(1UL << 63) is no longer the bit to set to indicate CQ_OVERRUN\n");
}
}
/* sender should get error event too and take care
*incarnation = hello->kshm_src_incarnation;
- if (hello->kshm_src_nid == LNET_NID_ANY) {
- CERROR("Expecting a HELLO hdr with a NID, but got LNET_NID_ANY"
- "from %pI4h\n", &conn->ksnc_ipaddr);
- return -EPROTO;
- }
+ if (hello->kshm_src_nid == LNET_NID_ANY) {
+ CERROR("Expecting a HELLO hdr with a NID, but got LNET_NID_ANY from %pI4h\n",
+ &conn->ksnc_ipaddr);
+ return -EPROTO;
+ }
if (!active &&
conn->ksnc_port > LNET_ACCEPTOR_MAX_RESERVED_PORT) {
accept_timeout);
if (rc != 0)
- CERROR("Error sending magic+version in response"
- "to LNET magic from %pI4h: %d\n",
+ CERROR("Error sending magic+version in response to LNET magic from %pI4h: %d\n",
&peer_ip, rc);
return -EPROTO;
}
accept_timeout);
if (rc != 0)
- CERROR("Error sending magic+version in response"
- "to version %d from %pI4h: %d\n",
+ CERROR("Error sending magic+version in response to version %d from %pI4h: %d\n",
peer_version, &peer_ip, rc);
return -EPROTO;
}
if (!list_empty(&the_lnet.ln_drop_rules) &&
lnet_drop_rule_match(hdr, ni->ni_nid, NULL)) {
- CDEBUG(D_NET, "%s, src %s, dst %s: Dropping %s to simulate"
- "silent message loss\n",
+ CDEBUG(D_NET,
+ "%s, src %s, dst %s: Dropping %s to simulate silent message loss\n",
libcfs_nid2str(from_nid), libcfs_nid2str(src_nid),
libcfs_nid2str(dest_nid), lnet_msgtyp2str(type));
goto drop;
if (flags & (LNTF_CHECK_LINKEA | LNTF_CHECK_PARENT) &&
!(lfsck->li_bookmark_ram.lb_param & LPF_ALL_TGT)) {
- CDEBUG(D_LFSCK, "%s: some MDT(s) maybe NOT take part in the"
- "the namespace LFSCK, then the LFSCK cannot guarantee"
- "all the name entries have been verified in first-stage"
- "scanning. So have to skip orphan related handling for"
- "the directory object "DFID" with remote name entry\n",
+ CDEBUG(D_LFSCK,
+ "%s: some MDT(s) maybe NOT take part in the the namespace LFSCK, then the LFSCK cannot guarantee all the name entries have been verified in first-stage scanning. So have to skip orphan related handling for the directory object "DFID" with remote name entry\n",
lfsck_lfsck2name(lfsck), PFID(cfid));
RETURN(0);
struct ll_inode_info *lli = ll_i2info(dir);
rc = PTR_ERR(page);
- CERROR("%s: reading dir "DFID" at %llu"
- "opendir_pid = %u : rc = %d\n",
+ CERROR("%s: reading dir "DFID" at %llu opendir_pid = %u : rc = %d\n",
ll_i2sbi(dir)->ll_fsname,
PFID(ll_inode2fid(dir)), pos,
lli->lli_opendir_pid, rc);
*symname = req_capsule_server_get(&(*request)->rq_pill, &RMF_MDT_MD);
if (!*symname || strnlen(*symname, symlen) != symlen - 1) {
/* not full/NULL terminated */
- CERROR("%s: inode "DFID": symlink not NULL terminated string"
- "of length %d\n", sbi->ll_fsname,
+ CERROR("%s: inode "DFID": symlink not NULL terminated string of length %d\n",
+ sbi->ll_fsname,
PFID(ll_inode2fid(inode)), symlen - 1);
GOTO(failed, rc = -EPROTO);
}
/* no need to setattr anymore */
if (la_copy->la_valid == 0) {
- CDEBUG(D_INODE, "%s: no valid attribute on "DFID", previous"
- "valid is %#llx\n", mdd2obd_dev(mdd)->obd_name,
+ CDEBUG(D_INODE,
+ "%s: no valid attribute on "DFID", previous valid is %#llx\n",
+ mdd2obd_dev(mdd)->obd_name,
PFID(mdo2fid(mdd_obj)), la->la_valid);
RETURN(0);
* object anyway XXX*/
if (lh->mlh_type == MDT_PDO_LOCK &&
lh->mlh_pdo_hash != 0) {
- CDEBUG(D_INFO, "%s: "DFID" convert PDO lock to"
- "EX lock.\n", mdt_obd_name(info->mti_mdt),
+ CDEBUG(D_INFO,
+ "%s: "DFID" convert PDO lock to EX lock.\n",
+ mdt_obd_name(info->mti_mdt),
PFID(mdt_object_fid(o)));
lh->mlh_pdo_hash = 0;
lh->mlh_rreg_mode = LCK_EX;
rc = cfs_cpt_set_node(mdt_io_cptable, cpt++, i);
if (!rc) {
- CWARN("MDS Failed to set node %d for"
- "IO CPT table\n", i);
+ CWARN("MDS Failed to set node %d for IO CPT table\n",
+ i);
cfs_cpt_table_free(mdt_io_cptable);
mdt_io_cptable = NULL;
break;
/* Ensure this is not a failover node that is connecting first*/
static int mgs_check_failover_reg(struct mgs_target_info *mti)
{
- lnet_nid_t nid;
- char *ptr;
- int i;
+ lnet_nid_t nid;
+ char *ptr;
+ int i;
- ptr = mti->mti_params;
- while (class_find_param(ptr, PARAM_FAILNODE, &ptr) == 0) {
+ ptr = mti->mti_params;
+ while (class_find_param(ptr, PARAM_FAILNODE, &ptr) == 0) {
while (class_parse_nid_quiet(ptr, &nid, &ptr) == 0) {
- for (i = 0; i < mti->mti_nid_count; i++) {
- if (nid == mti->mti_nids[i]) {
- LCONSOLE_WARN("Denying initial registra"
- "tion attempt from nid %s"
- ", specified as failover"
- "\n",libcfs_nid2str(nid));
- return -EADDRNOTAVAIL;
- }
- }
- }
- }
- return 0;
+ for (i = 0; i < mti->mti_nid_count; i++) {
+ if (nid == mti->mti_nids[i]) {
+ LCONSOLE_WARN("Denying initial registration attempt from nid %s, specified as failover\n",
+ libcfs_nid2str(nid));
+ return -EADDRNOTAVAIL;
+ }
+ }
+ }
+ }
+ return 0;
}
/* Called whenever a target starts up. Flags indicate first connect, etc. */
if (class_match_param(ptr, PARAM_NETWORK, NULL) == 0)
GOTO(end, rc);
- /* Processed in mgs_write_log_ost */
- if (class_match_param(ptr, PARAM_FAILMODE, NULL) == 0) {
- if (mti->mti_flags & LDD_F_PARAM) {
- LCONSOLE_ERROR_MSG(0x169, "%s can only be "
- "changed with tunefs.lustre"
- "and --writeconf\n", ptr);
- rc = -EPERM;
- }
- GOTO(end, rc);
- }
+ /* Processed in mgs_write_log_ost */
+ if (class_match_param(ptr, PARAM_FAILMODE, NULL) == 0) {
+ if (mti->mti_flags & LDD_F_PARAM) {
+ LCONSOLE_ERROR_MSG(0x169,
+ "%s can only be changed with tunefs.lustre and --writeconf\n",
+ ptr);
+ rc = -EPERM;
+ }
+ GOTO(end, rc);
+ }
if (class_match_param(ptr, PARAM_SRPC, NULL) == 0) {
rc = mgs_srpc_set_param(env, mgs, fsdb, mti, ptr);
}
active_err:
if (rc < 0) {
- LCONSOLE_ERROR_MSG(0x145, "Couldn't find %s in"
- "log (%d). No permanent "
- "changes were made to the "
- "config log.\n",
+ LCONSOLE_ERROR_MSG(0x145,
+ "Couldn't find %s in log (%d). No permanent changes were made to the config log.\n",
mti->mti_svname, rc);
if (test_bit(FSDB_OLDLOG14, &fsdb->fsdb_flags))
- LCONSOLE_ERROR_MSG(0x146, "This may be"
- " because the log"
- "is in the old 1.4"
- "style. Consider "
- " --writeconf to "
- "update the logs.\n");
+ LCONSOLE_ERROR_MSG(0x146,
+ "This may be because the log is in the old 1.4 style. Consider --writeconf to update the logs.\n");
GOTO(end, rc);
}
/* Fall through to osc/mdc proc for deactivating live
spin_unlock(&cli->cl_mod_rpcs_lock);
/* tag 0 is reserved for non-modify RPCs */
- CDEBUG(D_RPCTRACE, "%s: modify RPC slot %u is allocated"
- "opc %u, max %hu\n",
+ CDEBUG(D_RPCTRACE,
+ "%s: modify RPC slot %u is allocated opc %u, max %hu\n",
cli->cl_import->imp_obd->obd_name,
i + 1, opc, max);
lustre_swab_llog_rec(last_rec);
if (last_rec->lrh_index != tail->lrt_index) {
- CERROR("%s: invalid llog tail at log id "DFID":%x "
- "offset %llu last_rec idx %u tail idx %u"
- "lrt len %u read_size %d\n",
+ CERROR("%s: invalid llog tail at log id "DFID":%x offset %llu last_rec idx %u tail idx %u lrt len %u read_size %d\n",
o->do_lu.lo_dev->ld_obd->obd_name,
PFID(&loghandle->lgh_id.lgl_oi.oi_fid),
loghandle->lgh_id.lgl_ogen, *cur_offset,
GOTO(out_close, rc);
}
if (process_count != plain_counter) {
- CERROR("7_sub: Reverse/direct processing found different"
- "number of records: %d/%d\n",
+ CERROR("7_sub: Reverse/direct processing found different number of records: %d/%d\n",
plain_counter, process_count);
GOTO(out_close, rc = -EINVAL);
}
int rc = 0;
if (*nr_local > PTLRPC_MAX_BRW_PAGES) {
- CERROR("%s: bulk has too many pages %d, which exceeds the"
- "maximum pages per RPC of %d\n",
+ CERROR("%s: bulk has too many pages %d, which exceeds the maximum pages per RPC of %d\n",
exp->exp_obd->obd_name, *nr_local, PTLRPC_MAX_BRW_PAGES);
RETURN(-EPROTO);
}
sizeof(*zde) / 8, (void *)zde);
if (rc) {
if (rc != -ENOENT)
- CWARN("%s: initial OI scrub failed to find"
- "the entry %s under .lustre: rc = %d\n",
+ CWARN("%s: initial OI scrub failed to find the entry %s under .lustre: rc = %d\n",
osd_name(dev), map->olm_name, rc);
else if (!fid_is_zero(&map->olm_fid))
/* Try to remove the stale OI mapping. */
rc = cfs_cpt_set_node(ost_io_cptable, cpt++, i);
if (!rc) {
- CWARN("OSS Failed to set node %d for"
- "IO CPT table\n", i);
+ CWARN("OSS Failed to set node %d for IO CPT table\n",
+ i);
cfs_cpt_table_free(ost_io_cptable);
ost_io_cptable = NULL;
break;
0444, &lprocfs_quota_seq_fops,
obj);
if (rc)
- CWARN("%s: Error adding procfs file for global"
- "quota index "DFID", rc:%d\n",
+ CWARN("%s: Error adding procfs file for global quota index "DFID": rc = %d\n",
qmt->qmt_svname, PFID(&qti->qti_fid), rc);
#endif
}
}
if (lsd->lsd_osd_index != index) {
- LCONSOLE_ERROR_MSG(0x157, "%s: index %d in last rcvd "
- "is different with the index %d in"
- "config log, It might be disk"
- "corruption!\n", tgt_name(tgt),
+ LCONSOLE_ERROR_MSG(0x157,
+ "%s: index %d in last rcvd is different with the index %d in config log, It might be disk corruption!\n",
+ tgt_name(tgt),
lsd->lsd_osd_index, index);
RETURN(-EINVAL);
}
/* LU-3403 llite: error of listxattr when buffer is small */
if (ret_null < 2) {
- fprintf(stderr, "listxattr(%s, NULL, 0) returned"
- "a sizes less than 2", path);
+ fprintf(stderr,
+ "listxattr(%s, NULL, 0) returned a sizes less than 2",
+ path);
ret = EINVAL;
goto out;
}
ple = gssd_get_realm_ple((void *)&kte.principal->realm);
if (ple) {
if (ple->fl_mds) {
- printerr(2,"mds service entry: found a"
- "duplicated one, it's like a "
- "mis-configuration, skip\n");
+ printerr(2,
+ "mds service entry: found a duplicated one, it's like a mis-configuration, skip\n");
goto next;
}
+ ple = gssd_get_realm_ple((void *)&kte.principal->realm);
+ if (ple) {
+ if (ple->fl_mds) {
-+ printerr(2,"mds service entry: found a"
++ printerr(2,"mds service entry: found a "
+ "duplicated one, it's like a "
+ "mis-configuration, skip\n");
+ goto next;
+ ple = gssd_get_realm_ple((void *)&kte.principal->realm);
+ if (ple) {
+ if (ple->fl_mds) {
-+ printerr(2,"mds service entry: found a"
++ printerr(2,"mds service entry: found a "
+ "duplicated one, it's like a "
+ "mis-configuration, skip\n");
+ goto next;
else if (lustre_mech == LGSS_MECH_NULL)
rc = handle_null(&snd);
else
- printerr(0, "WARNING: Received or request for"
- "subflavor that is not enabled: %d\n", lustre_mech);
+ printerr(0,
+ "WARNING: Received or request for subflavor that is not enabled: %d\n",
+ lustre_mech);
out_err:
/* Failures send a null token */
{"===== network config =====", NULL, 0, "network config"},
{"--net", jt_opt_net, 0, "run <command> after selecting network <net>\n"
"usage: --net <tcp/o2ib/...> <command>"},
- {"network", jt_ptl_network, 0, "configure LNET"
+ {"network", jt_ptl_network, 0, "configure LNET\n"
"usage: network up|down"},
- {"net", jt_ptl_network, 0, "configure LNET"
+ {"net", jt_ptl_network, 0, "configure LNET\n"
"usage: net up|down"},
- {"list_nids", jt_ptl_list_nids, 0, "list local NIDs"
+ {"list_nids", jt_ptl_list_nids, 0, "list local NIDs\n"
"usage: list_nids [all]"},
- {"which_nid", jt_ptl_which_nid, 0, "choose a NID"
+ {"which_nid", jt_ptl_which_nid, 0, "choose a NID\n"
"usage: which_nid NID [NID...]"},
{"replace_nids", jt_replace_nids, 0,
"replace primary NIDs for a device\n"
"add a range to a nodemap\n"
"usage: nodemap_del_range <nid_range>"},
{"nodemap_modify", jt_nodemap_modify, 0,
- "modify a nodemap parameters"
+ "modify a nodemap parameters\n"
"usage: nodemap_modify nodemap_name param value"},
{"nodemap_add_idmap", jt_nodemap_add_idmap, 0,
"add a UID or GID mapping to a nodemap"},
opt.o_archive_id_cnt = 0;
opt.o_archive_id_used = 0;
all_id = true;
- CT_WARN("archive-id = 0 is found, any backend"
- "will be served\n");
+ CT_WARN("archive-id = 0 is found, any backend will be served\n");
goto repeat;
}
"to enable this feature.\n");
#endif
if (make_backfs)
- fprintf(stderr, "Feature will not be enabled until %s"
- "is updated and '%s -O %s %%{device}' "
- "is run.\n\n", E2FSPROGS, TUNE2FS, feature);
+ fprintf(stderr,
+ "Feature will not be enabled until %s is updated and '%s -O %s %%{device}' is run.\n\n",
+ E2FSPROGS, TUNE2FS, feature);
}
/* Check whether the file exists in the device */
case 'c':
chunksize = (strtoul(optarg, NULL, 0) * ONE_MB);
if (!chunksize) {
- fprintf(stderr, "%s: chunk size value should be"
- "nonzero and multiple of 1MB\n",
+ fprintf(stderr,
+ "%s: chunk size value should be nonzero and multiple of 1MB\n",
progname);
return -1;
}
ext2_filsys fs;
if ((fp = setmntent("/etc/mtab", "r")) == NULL) {
- fprintf(stderr, "%s: fail to open /etc/mtab in read"
- "mode :%s\n", progname, strerror(errno));
+ fprintf(stderr, "%s: fail to open /etc/mtab in read mode :%s\n",
+ progname, strerror(errno));
goto guess;
}
}
if (stripe_count == 0 && stripe_index != -1) {
- fprintf(stderr, "If stripe_count is 0, stripe_index can not"
- "be specified\n");
+ fprintf(stderr, "If stripe_count is 0, stripe_index can not be specified\n");
return CMD_HELP;
}
if (parent_basedir == NULL) {
char *last_lash;
if (name == NULL) {
- fprintf(stderr, "parent_basedir or name must be"
- "indicated!\n");
+ fprintf(stderr,
+ "parent_basedir or name must be indicated!\n");
return CMD_HELP;
}
/*Get directory and name from name*/