Commit d95531fc authored by James Simmons's avatar James Simmons Committed by Greg Kroah-Hartman

staging: lustre: libcfs: remove != 0 testing

Testing != 0 is not kernel style so remove this
type of testing from libcfs.
Signed-off-by: default avatarJames Simmons <jsimmons@infradead.org>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent c54f7991
...@@ -278,7 +278,7 @@ libcfs_debug_mask2str(char *str, int size, int mask, int is_subsys) ...@@ -278,7 +278,7 @@ libcfs_debug_mask2str(char *str, int size, int mask, int is_subsys)
len++; len++;
} }
while (*token != 0) { while (*token) {
if (len < size) if (len < size)
str[len] = *token; str[len] = *token;
token++; token++;
...@@ -315,7 +315,7 @@ libcfs_debug_str2mask(int *mask, const char *str, int is_subsys) ...@@ -315,7 +315,7 @@ libcfs_debug_str2mask(int *mask, const char *str, int is_subsys)
t = sscanf(str, "%i%n", &m, &matched); t = sscanf(str, "%i%n", &m, &matched);
if (t >= 1 && matched == n) { if (t >= 1 && matched == n) {
/* don't print warning for lctl set_param debug=0 or -1 */ /* don't print warning for lctl set_param debug=0 or -1 */
if (m != 0 && m != -1) if (m && m != -1)
CWARN("You are trying to use a numerical value for the mask - this will be deprecated in a future release.\n"); CWARN("You are trying to use a numerical value for the mask - this will be deprecated in a future release.\n");
*mask = m; *mask = m;
return 0; return 0;
......
...@@ -492,7 +492,7 @@ cfs_hash_bd_get(struct cfs_hash *hs, const void *key, struct cfs_hash_bd *bd) ...@@ -492,7 +492,7 @@ cfs_hash_bd_get(struct cfs_hash *hs, const void *key, struct cfs_hash_bd *bd)
cfs_hash_bd_from_key(hs, hs->hs_buckets, cfs_hash_bd_from_key(hs, hs->hs_buckets,
hs->hs_cur_bits, key, bd); hs->hs_cur_bits, key, bd);
} else { } else {
LASSERT(hs->hs_rehash_bits != 0); LASSERT(hs->hs_rehash_bits);
cfs_hash_bd_from_key(hs, hs->hs_rehash_buckets, cfs_hash_bd_from_key(hs, hs->hs_rehash_buckets,
hs->hs_rehash_bits, key, bd); hs->hs_rehash_bits, key, bd);
} }
...@@ -629,7 +629,7 @@ cfs_hash_bd_lookup_intent(struct cfs_hash *hs, struct cfs_hash_bd *bd, ...@@ -629,7 +629,7 @@ cfs_hash_bd_lookup_intent(struct cfs_hash *hs, struct cfs_hash_bd *bd,
struct hlist_head *hhead = cfs_hash_bd_hhead(hs, bd); struct hlist_head *hhead = cfs_hash_bd_hhead(hs, bd);
struct hlist_node *ehnode; struct hlist_node *ehnode;
struct hlist_node *match; struct hlist_node *match;
int intent_add = (intent & CFS_HS_LOOKUP_MASK_ADD) != 0; int intent_add = intent & CFS_HS_LOOKUP_MASK_ADD;
/* with this function, we can avoid a lot of useless refcount ops, /* with this function, we can avoid a lot of useless refcount ops,
* which are expensive atomic operations most time. * which are expensive atomic operations most time.
...@@ -643,13 +643,13 @@ cfs_hash_bd_lookup_intent(struct cfs_hash *hs, struct cfs_hash_bd *bd, ...@@ -643,13 +643,13 @@ cfs_hash_bd_lookup_intent(struct cfs_hash *hs, struct cfs_hash_bd *bd,
continue; continue;
/* match and ... */ /* match and ... */
if ((intent & CFS_HS_LOOKUP_MASK_DEL) != 0) { if (intent & CFS_HS_LOOKUP_MASK_DEL) {
cfs_hash_bd_del_locked(hs, bd, ehnode); cfs_hash_bd_del_locked(hs, bd, ehnode);
return ehnode; return ehnode;
} }
/* caller wants refcount? */ /* caller wants refcount? */
if ((intent & CFS_HS_LOOKUP_MASK_REF) != 0) if (intent & CFS_HS_LOOKUP_MASK_REF)
cfs_hash_get(hs, ehnode); cfs_hash_get(hs, ehnode);
return ehnode; return ehnode;
} }
...@@ -815,7 +815,7 @@ cfs_hash_dual_bd_get(struct cfs_hash *hs, const void *key, ...@@ -815,7 +815,7 @@ cfs_hash_dual_bd_get(struct cfs_hash *hs, const void *key,
return; return;
} }
LASSERT(hs->hs_rehash_bits != 0); LASSERT(hs->hs_rehash_bits);
cfs_hash_bd_from_key(hs, hs->hs_rehash_buckets, cfs_hash_bd_from_key(hs, hs->hs_rehash_buckets,
hs->hs_rehash_bits, key, &bds[1]); hs->hs_rehash_bits, key, &bds[1]);
...@@ -976,7 +976,7 @@ static void cfs_hash_depth_wi_cancel(struct cfs_hash *hs) ...@@ -976,7 +976,7 @@ static void cfs_hash_depth_wi_cancel(struct cfs_hash *hs)
return; return;
spin_lock(&hs->hs_dep_lock); spin_lock(&hs->hs_dep_lock);
while (hs->hs_dep_bits != 0) { while (hs->hs_dep_bits) {
spin_unlock(&hs->hs_dep_lock); spin_unlock(&hs->hs_dep_lock);
cond_resched(); cond_resched();
spin_lock(&hs->hs_dep_lock); spin_lock(&hs->hs_dep_lock);
...@@ -1010,16 +1010,16 @@ cfs_hash_create(char *name, unsigned int cur_bits, unsigned int max_bits, ...@@ -1010,16 +1010,16 @@ cfs_hash_create(char *name, unsigned int cur_bits, unsigned int max_bits,
LASSERT(ops->hs_get); LASSERT(ops->hs_get);
LASSERT(ops->hs_put_locked); LASSERT(ops->hs_put_locked);
if ((flags & CFS_HASH_REHASH) != 0) if (flags & CFS_HASH_REHASH)
flags |= CFS_HASH_COUNTER; /* must have counter */ flags |= CFS_HASH_COUNTER; /* must have counter */
LASSERT(cur_bits > 0); LASSERT(cur_bits > 0);
LASSERT(cur_bits >= bkt_bits); LASSERT(cur_bits >= bkt_bits);
LASSERT(max_bits >= cur_bits && max_bits < 31); LASSERT(max_bits >= cur_bits && max_bits < 31);
LASSERT(ergo((flags & CFS_HASH_REHASH) == 0, cur_bits == max_bits)); LASSERT(ergo((flags & CFS_HASH_REHASH) == 0, cur_bits == max_bits));
LASSERT(ergo((flags & CFS_HASH_REHASH) != 0, LASSERT(ergo(flags & CFS_HASH_REHASH,
(flags & CFS_HASH_NO_LOCK) == 0)); (flags & CFS_HASH_NO_LOCK) == 0));
LASSERT(ergo((flags & CFS_HASH_REHASH_KEY) != 0, ops->hs_keycpy)); LASSERT(ergo(flags & CFS_HASH_REHASH_KEY, ops->hs_keycpy));
len = (flags & CFS_HASH_BIGNAME) == 0 ? len = (flags & CFS_HASH_BIGNAME) == 0 ?
CFS_HASH_NAME_LEN : CFS_HASH_BIGNAME_LEN; CFS_HASH_NAME_LEN : CFS_HASH_BIGNAME_LEN;
...@@ -1948,7 +1948,7 @@ cfs_hash_rehash_worker(struct cfs_workitem *wi) ...@@ -1948,7 +1948,7 @@ cfs_hash_rehash_worker(struct cfs_workitem *wi)
/* can't refer to @hs anymore because it could be destroyed */ /* can't refer to @hs anymore because it could be destroyed */
if (bkts) if (bkts)
cfs_hash_buckets_free(bkts, bsize, new_size, old_size); cfs_hash_buckets_free(bkts, bsize, new_size, old_size);
if (rc != 0) if (rc)
CDEBUG(D_INFO, "early quit of rehashing: %d\n", rc); CDEBUG(D_INFO, "early quit of rehashing: %d\n", rc);
/* return 1 only if cfs_wi_exit is called */ /* return 1 only if cfs_wi_exit is called */
return rc == -ESRCH; return rc == -ESRCH;
...@@ -2017,7 +2017,7 @@ cfs_hash_full_bkts(struct cfs_hash *hs) ...@@ -2017,7 +2017,7 @@ cfs_hash_full_bkts(struct cfs_hash *hs)
if (!hs->hs_rehash_buckets) if (!hs->hs_rehash_buckets)
return hs->hs_buckets; return hs->hs_buckets;
LASSERT(hs->hs_rehash_bits != 0); LASSERT(hs->hs_rehash_bits);
return hs->hs_rehash_bits > hs->hs_cur_bits ? return hs->hs_rehash_bits > hs->hs_cur_bits ?
hs->hs_rehash_buckets : hs->hs_buckets; hs->hs_rehash_buckets : hs->hs_buckets;
} }
...@@ -2029,7 +2029,7 @@ cfs_hash_full_nbkt(struct cfs_hash *hs) ...@@ -2029,7 +2029,7 @@ cfs_hash_full_nbkt(struct cfs_hash *hs)
if (!hs->hs_rehash_buckets) if (!hs->hs_rehash_buckets)
return CFS_HASH_NBKT(hs); return CFS_HASH_NBKT(hs);
LASSERT(hs->hs_rehash_bits != 0); LASSERT(hs->hs_rehash_bits);
return hs->hs_rehash_bits > hs->hs_cur_bits ? return hs->hs_rehash_bits > hs->hs_cur_bits ?
CFS_HASH_RH_NBKT(hs) : CFS_HASH_NBKT(hs); CFS_HASH_RH_NBKT(hs) : CFS_HASH_NBKT(hs);
} }
......
...@@ -391,7 +391,7 @@ cfs_expr_list_print(char *buffer, int count, struct cfs_expr_list *expr_list) ...@@ -391,7 +391,7 @@ cfs_expr_list_print(char *buffer, int count, struct cfs_expr_list *expr_list)
i += scnprintf(buffer + i, count - i, "["); i += scnprintf(buffer + i, count - i, "[");
list_for_each_entry(expr, &expr_list->el_exprs, re_link) { list_for_each_entry(expr, &expr_list->el_exprs, re_link) {
if (j++ != 0) if (j++)
i += scnprintf(buffer + i, count - i, ","); i += scnprintf(buffer + i, count - i, ",");
i += cfs_range_expr_print(buffer + i, count - i, expr, i += cfs_range_expr_print(buffer + i, count - i, expr,
numexprs > 1); numexprs > 1);
...@@ -533,7 +533,7 @@ cfs_expr_list_parse(char *str, int len, unsigned int min, unsigned int max, ...@@ -533,7 +533,7 @@ cfs_expr_list_parse(char *str, int len, unsigned int min, unsigned int max,
} }
rc = cfs_range_expr_parse(&tok, min, max, 1, &expr); rc = cfs_range_expr_parse(&tok, min, max, 1, &expr);
if (rc != 0) if (rc)
break; break;
list_add_tail(&expr->re_link, &expr_list->el_exprs); list_add_tail(&expr->re_link, &expr_list->el_exprs);
...@@ -544,7 +544,7 @@ cfs_expr_list_parse(char *str, int len, unsigned int min, unsigned int max, ...@@ -544,7 +544,7 @@ cfs_expr_list_parse(char *str, int len, unsigned int min, unsigned int max,
list_add_tail(&expr->re_link, &expr_list->el_exprs); list_add_tail(&expr->re_link, &expr_list->el_exprs);
} }
if (rc != 0) if (rc)
cfs_expr_list_free(expr_list); cfs_expr_list_free(expr_list);
else else
*elpp = expr_list; *elpp = expr_list;
......
...@@ -712,7 +712,7 @@ cfs_cpt_num_estimate(void) ...@@ -712,7 +712,7 @@ cfs_cpt_num_estimate(void)
*/ */
ncpt = min(2U, ncpt); ncpt = min(2U, ncpt);
#endif #endif
while (ncpu % ncpt != 0) while (ncpu % ncpt)
ncpt--; /* worst case is 1 */ ncpt--; /* worst case is 1 */
return ncpt; return ncpt;
...@@ -737,7 +737,7 @@ cfs_cpt_table_create(int ncpt) ...@@ -737,7 +737,7 @@ cfs_cpt_table_create(int ncpt)
ncpt, rc); ncpt, rc);
} }
if (num_online_cpus() % ncpt != 0) { if (num_online_cpus() % ncpt) {
CERROR("CPU number %d is not multiple of cpu_npartition %d, please try different cpu_npartitions value or set pattern string by cpu_pattern=STRING\n", CERROR("CPU number %d is not multiple of cpu_npartition %d, please try different cpu_npartitions value or set pattern string by cpu_pattern=STRING\n",
(int)num_online_cpus(), ncpt); (int)num_online_cpus(), ncpt);
goto failed; goto failed;
...@@ -888,7 +888,7 @@ cfs_cpt_table_create_pattern(char *pattern) ...@@ -888,7 +888,7 @@ cfs_cpt_table_create_pattern(char *pattern)
int n; int n;
if (!bracket) { if (!bracket) {
if (*str != 0) { if (*str) {
CERROR("Invalid pattern %s\n", str); CERROR("Invalid pattern %s\n", str);
goto failed; goto failed;
} }
...@@ -911,7 +911,7 @@ cfs_cpt_table_create_pattern(char *pattern) ...@@ -911,7 +911,7 @@ cfs_cpt_table_create_pattern(char *pattern)
goto failed; goto failed;
} }
if (cfs_cpt_weight(cptab, cpt) != 0) { if (cfs_cpt_weight(cptab, cpt)) {
CERROR("Partition %d has already been set.\n", cpt); CERROR("Partition %d has already been set.\n", cpt);
goto failed; goto failed;
} }
...@@ -930,14 +930,14 @@ cfs_cpt_table_create_pattern(char *pattern) ...@@ -930,14 +930,14 @@ cfs_cpt_table_create_pattern(char *pattern)
} }
if (cfs_expr_list_parse(str, (bracket - str) + 1, if (cfs_expr_list_parse(str, (bracket - str) + 1,
0, high, &el) != 0) { 0, high, &el)) {
CERROR("Can't parse number range: %s\n", str); CERROR("Can't parse number range: %s\n", str);
goto failed; goto failed;
} }
list_for_each_entry(range, &el->el_exprs, re_link) { list_for_each_entry(range, &el->el_exprs, re_link) {
for (i = range->re_lo; i <= range->re_hi; i++) { for (i = range->re_lo; i <= range->re_hi; i++) {
if ((i - range->re_lo) % range->re_stride != 0) if ((i - range->re_lo) % range->re_stride)
continue; continue;
rc = node ? cfs_cpt_set_node(cptab, cpt, i) : rc = node ? cfs_cpt_set_node(cptab, cpt, i) :
...@@ -1044,7 +1044,7 @@ cfs_cpu_init(void) ...@@ -1044,7 +1044,7 @@ cfs_cpu_init(void)
register_hotcpu_notifier(&cfs_cpu_notifier); register_hotcpu_notifier(&cfs_cpu_notifier);
#endif #endif
if (*cpu_pattern != 0) { if (*cpu_pattern) {
cfs_cpt_table = cfs_cpt_table_create_pattern(cpu_pattern); cfs_cpt_table = cfs_cpt_table_create_pattern(cpu_pattern);
if (!cfs_cpt_table) { if (!cfs_cpt_table) {
CERROR("Failed to create cptab from pattern %s\n", CERROR("Failed to create cptab from pattern %s\n",
......
...@@ -93,12 +93,12 @@ static int cfs_crypto_hash_alloc(enum cfs_crypto_hash_alg hash_alg, ...@@ -93,12 +93,12 @@ static int cfs_crypto_hash_alloc(enum cfs_crypto_hash_alg hash_alg,
if (key) if (key)
err = crypto_ahash_setkey(tfm, key, key_len); err = crypto_ahash_setkey(tfm, key, key_len);
else if ((*type)->cht_key != 0) else if ((*type)->cht_key)
err = crypto_ahash_setkey(tfm, err = crypto_ahash_setkey(tfm,
(unsigned char *)&((*type)->cht_key), (unsigned char *)&((*type)->cht_key),
(*type)->cht_size); (*type)->cht_size);
if (err != 0) { if (err) {
ahash_request_free(*req); ahash_request_free(*req);
crypto_free_ahash(tfm); crypto_free_ahash(tfm);
return err; return err;
...@@ -156,7 +156,7 @@ int cfs_crypto_hash_digest(enum cfs_crypto_hash_alg hash_alg, ...@@ -156,7 +156,7 @@ int cfs_crypto_hash_digest(enum cfs_crypto_hash_alg hash_alg,
return -EINVAL; return -EINVAL;
err = cfs_crypto_hash_alloc(hash_alg, &type, &req, key, key_len); err = cfs_crypto_hash_alloc(hash_alg, &type, &req, key, key_len);
if (err != 0) if (err)
return err; return err;
if (!hash || *hash_len < type->cht_size) { if (!hash || *hash_len < type->cht_size) {
......
...@@ -224,21 +224,21 @@ void cfs_print_to_console(struct ptldebug_header *hdr, int mask, ...@@ -224,21 +224,21 @@ void cfs_print_to_console(struct ptldebug_header *hdr, int mask,
{ {
char *prefix = "Lustre", *ptype = NULL; char *prefix = "Lustre", *ptype = NULL;
if ((mask & D_EMERG) != 0) { if (mask & D_EMERG) {
prefix = dbghdr_to_err_string(hdr); prefix = dbghdr_to_err_string(hdr);
ptype = KERN_EMERG; ptype = KERN_EMERG;
} else if ((mask & D_ERROR) != 0) { } else if (mask & D_ERROR) {
prefix = dbghdr_to_err_string(hdr); prefix = dbghdr_to_err_string(hdr);
ptype = KERN_ERR; ptype = KERN_ERR;
} else if ((mask & D_WARNING) != 0) { } else if (mask & D_WARNING) {
prefix = dbghdr_to_info_string(hdr); prefix = dbghdr_to_info_string(hdr);
ptype = KERN_WARNING; ptype = KERN_WARNING;
} else if ((mask & (D_CONSOLE | libcfs_printk)) != 0) { } else if (mask & (D_CONSOLE | libcfs_printk)) {
prefix = dbghdr_to_info_string(hdr); prefix = dbghdr_to_info_string(hdr);
ptype = KERN_INFO; ptype = KERN_INFO;
} }
if ((mask & D_CONSOLE) != 0) { if (mask & D_CONSOLE) {
printk("%s%s: %.*s", ptype, prefix, len, buf); printk("%s%s: %.*s", ptype, prefix, len, buf);
} else { } else {
printk("%s%s: %d:%d:(%s:%d:%s()) %.*s", ptype, prefix, printk("%s%s: %d:%d:(%s:%d:%s()) %.*s", ptype, prefix,
......
...@@ -547,7 +547,7 @@ static int libcfs_init(void) ...@@ -547,7 +547,7 @@ static int libcfs_init(void)
} }
rc = cfs_cpu_init(); rc = cfs_cpu_init();
if (rc != 0) if (rc)
goto cleanup_debug; goto cleanup_debug;
rc = misc_register(&libcfs_dev); rc = misc_register(&libcfs_dev);
...@@ -566,7 +566,7 @@ static int libcfs_init(void) ...@@ -566,7 +566,7 @@ static int libcfs_init(void)
rc = min(cfs_cpt_weight(cfs_cpt_table, CFS_CPT_ANY), 4); rc = min(cfs_cpt_weight(cfs_cpt_table, CFS_CPT_ANY), 4);
rc = cfs_wi_sched_create("cfs_rh", cfs_cpt_table, CFS_CPT_ANY, rc = cfs_wi_sched_create("cfs_rh", cfs_cpt_table, CFS_CPT_ANY,
rc, &cfs_sched_rehash); rc, &cfs_sched_rehash);
if (rc != 0) { if (rc) {
CERROR("Startup workitem scheduler: error: %d\n", rc); CERROR("Startup workitem scheduler: error: %d\n", rc);
goto cleanup_deregister; goto cleanup_deregister;
} }
......
...@@ -432,7 +432,7 @@ int libcfs_debug_vmsg2(struct libcfs_debug_msg_data *msgdata, ...@@ -432,7 +432,7 @@ int libcfs_debug_vmsg2(struct libcfs_debug_msg_data *msgdata,
if (cdls) { if (cdls) {
if (libcfs_console_ratelimit && if (libcfs_console_ratelimit &&
cdls->cdls_next != 0 && /* not first time ever */ cdls->cdls_next && /* not first time ever */
!cfs_time_after(cfs_time_current(), cdls->cdls_next)) { !cfs_time_after(cfs_time_current(), cdls->cdls_next)) {
/* skipping a console message */ /* skipping a console message */
cdls->cdls_count++; cdls->cdls_count++;
...@@ -489,7 +489,7 @@ int libcfs_debug_vmsg2(struct libcfs_debug_msg_data *msgdata, ...@@ -489,7 +489,7 @@ int libcfs_debug_vmsg2(struct libcfs_debug_msg_data *msgdata,
put_cpu(); put_cpu();
} }
if (cdls && cdls->cdls_count != 0) { if (cdls && cdls->cdls_count) {
string_buf = cfs_trace_get_console_buffer(); string_buf = cfs_trace_get_console_buffer();
needed = snprintf(string_buf, CFS_TRACE_CONSOLE_BUFFER_SIZE, needed = snprintf(string_buf, CFS_TRACE_CONSOLE_BUFFER_SIZE,
...@@ -847,12 +847,12 @@ int cfs_trace_dump_debug_buffer_usrstr(void __user *usr_str, int usr_str_nob) ...@@ -847,12 +847,12 @@ int cfs_trace_dump_debug_buffer_usrstr(void __user *usr_str, int usr_str_nob)
int rc; int rc;
rc = cfs_trace_allocate_string_buffer(&str, usr_str_nob + 1); rc = cfs_trace_allocate_string_buffer(&str, usr_str_nob + 1);
if (rc != 0) if (rc)
return rc; return rc;
rc = cfs_trace_copyin_string(str, usr_str_nob + 1, rc = cfs_trace_copyin_string(str, usr_str_nob + 1,
usr_str, usr_str_nob); usr_str, usr_str_nob);
if (rc != 0) if (rc)
goto out; goto out;
if (str[0] != '/') { if (str[0] != '/') {
...@@ -912,7 +912,7 @@ int cfs_trace_daemon_command_usrstr(void __user *usr_str, int usr_str_nob) ...@@ -912,7 +912,7 @@ int cfs_trace_daemon_command_usrstr(void __user *usr_str, int usr_str_nob)
int rc; int rc;
rc = cfs_trace_allocate_string_buffer(&str, usr_str_nob + 1); rc = cfs_trace_allocate_string_buffer(&str, usr_str_nob + 1);
if (rc != 0) if (rc)
return rc; return rc;
rc = cfs_trace_copyin_string(str, usr_str_nob + 1, rc = cfs_trace_copyin_string(str, usr_str_nob + 1,
...@@ -1003,7 +1003,7 @@ static int tracefiled(void *arg) ...@@ -1003,7 +1003,7 @@ static int tracefiled(void *arg)
filp = NULL; filp = NULL;
cfs_tracefile_read_lock(); cfs_tracefile_read_lock();
if (cfs_tracefile[0] != 0) { if (cfs_tracefile[0]) {
filp = filp_open(cfs_tracefile, filp = filp_open(cfs_tracefile,
O_CREAT | O_RDWR | O_LARGEFILE, O_CREAT | O_RDWR | O_LARGEFILE,
0600); 0600);
...@@ -1141,7 +1141,7 @@ int cfs_tracefile_init(int max_pages) ...@@ -1141,7 +1141,7 @@ int cfs_tracefile_init(int max_pages)
int factor; int factor;
rc = cfs_tracefile_init_arch(); rc = cfs_tracefile_init_arch();
if (rc != 0) if (rc)
return rc; return rc;
cfs_tcd_for_each(tcd, i, j) { cfs_tcd_for_each(tcd, i, j) {
......
...@@ -208,7 +208,7 @@ static int cfs_wi_scheduler(void *arg) ...@@ -208,7 +208,7 @@ static int cfs_wi_scheduler(void *arg)
/* CPT affinity scheduler? */ /* CPT affinity scheduler? */
if (sched->ws_cptab) if (sched->ws_cptab)
if (cfs_cpt_bind(sched->ws_cptab, sched->ws_cpt) != 0) if (cfs_cpt_bind(sched->ws_cptab, sched->ws_cpt))
CWARN("Failed to bind %s on CPT %d\n", CWARN("Failed to bind %s on CPT %d\n",
sched->ws_name, sched->ws_cpt); sched->ws_name, sched->ws_cpt);
...@@ -247,7 +247,7 @@ static int cfs_wi_scheduler(void *arg) ...@@ -247,7 +247,7 @@ static int cfs_wi_scheduler(void *arg)
rc = (*wi->wi_action) (wi); rc = (*wi->wi_action) (wi);
spin_lock(&sched->ws_lock); spin_lock(&sched->ws_lock);
if (rc != 0) /* WI should be dead, even be freed! */ if (rc) /* WI should be dead, even be freed! */
continue; continue;
wi->wi_running = 0; wi->wi_running = 0;
...@@ -447,7 +447,7 @@ cfs_wi_shutdown(void) ...@@ -447,7 +447,7 @@ cfs_wi_shutdown(void)
list_for_each_entry(sched, &cfs_wi_data.wi_scheds, ws_list) { list_for_each_entry(sched, &cfs_wi_data.wi_scheds, ws_list) {
spin_lock(&cfs_wi_data.wi_glock); spin_lock(&cfs_wi_data.wi_glock);
while (sched->ws_nthreads != 0) { while (sched->ws_nthreads) {
spin_unlock(&cfs_wi_data.wi_glock); spin_unlock(&cfs_wi_data.wi_glock);
set_current_state(TASK_UNINTERRUPTIBLE); set_current_state(TASK_UNINTERRUPTIBLE);
schedule_timeout(cfs_time_seconds(1) / 20); schedule_timeout(cfs_time_seconds(1) / 20);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment