Lines Matching refs:error
360 int error = 0; in search_rsb_list() local
371 error = -ENOTBLK; in search_rsb_list()
373 return error; in search_rsb_list()
380 int error; in _search_rsb() local
382 error = search_rsb_list(&ls->ls_rsbtbl[b].list, name, len, flags, &r); in _search_rsb()
383 if (!error) { in _search_rsb()
387 error = search_rsb_list(&ls->ls_rsbtbl[b].toss, name, len, flags, &r); in _search_rsb()
388 if (error) in _search_rsb()
408 return error; in _search_rsb()
414 int error; in search_rsb() local
416 error = _search_rsb(ls, name, len, b, flags, r_ret); in search_rsb()
418 return error; in search_rsb()
440 int error = -EINVAL; in find_rsb() local
448 error = 0; in find_rsb()
452 error = search_rsb(ls, name, namelen, bucket, flags, &r); in find_rsb()
453 if (!error) in find_rsb()
456 if (error == -EBADR && !(flags & R_CREATE)) in find_rsb()
460 if (error == -ENOTBLK) in find_rsb()
463 error = -ENOMEM; in find_rsb()
482 error = _search_rsb(ls, name, namelen, bucket, 0, &tmp); in find_rsb()
483 if (!error) { in find_rsb()
491 error = 0; in find_rsb()
494 return error; in find_rsb()
813 int error = 0; in add_to_waiters() local
819 error = -EINVAL; in add_to_waiters()
832 error = -EBUSY; in add_to_waiters()
853 if (error) in add_to_waiters()
855 lkb->lkb_id, error, lkb->lkb_flags, mstype, in add_to_waiters()
858 return error; in add_to_waiters()
921 int error; in remove_from_waiters() local
924 error = _remove_from_waiters(lkb, mstype); in remove_from_waiters()
926 return error; in remove_from_waiters()
935 int error; in remove_from_waiters_ms() local
939 error = _remove_from_waiters(lkb, ms->m_type); in remove_from_waiters_ms()
942 return error; in remove_from_waiters_ms()
1857 int i, error, dir_nodeid, ret_nodeid, our_nodeid = dlm_our_nodeid(); in set_master() local
1898 error = dlm_dir_lookup(ls, our_nodeid, r->res_name, in set_master()
1900 if (!error) in set_master()
1902 log_debug(ls, "dir_lookup error %d %s", error, r->res_name); in set_master()
1905 if (error && error != -EEXIST) in set_master()
1906 return error; in set_master()
1933 static void confirm_master(struct dlm_rsb *r, int error) in confirm_master() argument
1940 switch (error) { in confirm_master()
1966 log_error(r->res_ls, "confirm_master unknown error %d", error); in confirm_master()
2228 int error = 0; in do_request() local
2237 error = -EINPROGRESS; in do_request()
2244 error = -EAGAIN; in do_request()
2250 return error; in do_request()
2255 int error = 0; in do_convert() local
2278 error = -EDEADLK; in do_convert()
2300 error = -EINPROGRESS; in do_convert()
2308 error = -EAGAIN; in do_convert()
2314 return error; in do_convert()
2329 int error; in do_cancel() local
2331 error = revert_lock(r, lkb); in do_cancel()
2332 if (error) { in do_cancel()
2349 int error; in _request_lock() local
2353 error = set_master(r, lkb); in _request_lock()
2354 if (error < 0) in _request_lock()
2356 if (error) { in _request_lock()
2357 error = 0; in _request_lock()
2363 error = send_request(r, lkb); in _request_lock()
2365 error = do_request(r, lkb); in _request_lock()
2367 return error; in _request_lock()
2374 int error; in _convert_lock() local
2378 error = send_convert(r, lkb); in _convert_lock()
2380 error = do_convert(r, lkb); in _convert_lock()
2382 return error; in _convert_lock()
2389 int error; in _unlock_lock() local
2393 error = send_unlock(r, lkb); in _unlock_lock()
2395 error = do_unlock(r, lkb); in _unlock_lock()
2397 return error; in _unlock_lock()
2404 int error; in _cancel_lock() local
2408 error = send_cancel(r, lkb); in _cancel_lock()
2410 error = do_cancel(r, lkb); in _cancel_lock()
2412 return error; in _cancel_lock()
2424 int error; in request_lock() local
2426 error = validate_lock_args(ls, lkb, args); in request_lock()
2427 if (error) in request_lock()
2430 error = find_rsb(ls, name, len, R_CREATE, &r); in request_lock()
2431 if (error) in request_lock()
2439 error = _request_lock(r, lkb); in request_lock()
2445 return error; in request_lock()
2452 int error; in convert_lock() local
2459 error = validate_lock_args(ls, lkb, args); in convert_lock()
2460 if (error) in convert_lock()
2463 error = _convert_lock(r, lkb); in convert_lock()
2467 return error; in convert_lock()
2474 int error; in unlock_lock() local
2481 error = validate_unlock_args(lkb, args); in unlock_lock()
2482 if (error) in unlock_lock()
2485 error = _unlock_lock(r, lkb); in unlock_lock()
2489 return error; in unlock_lock()
2496 int error; in cancel_lock() local
2503 error = validate_unlock_args(lkb, args); in cancel_lock()
2504 if (error) in cancel_lock()
2507 error = _cancel_lock(r, lkb); in cancel_lock()
2511 return error; in cancel_lock()
2532 int error, convert = flags & DLM_LKF_CONVERT; in dlm_lock() local
2541 error = find_lkb(ls, lksb->sb_lkid, &lkb); in dlm_lock()
2543 error = create_lkb(ls, &lkb); in dlm_lock()
2545 if (error) in dlm_lock()
2548 error = set_lock_args(mode, lksb, flags, namelen, 0, ast, in dlm_lock()
2550 if (error) in dlm_lock()
2554 error = convert_lock(ls, lkb, &args); in dlm_lock()
2556 error = request_lock(ls, lkb, name, namelen, &args); in dlm_lock()
2558 if (error == -EINPROGRESS) in dlm_lock()
2559 error = 0; in dlm_lock()
2561 if (convert || error) in dlm_lock()
2563 if (error == -EAGAIN || error == -EDEADLK) in dlm_lock()
2564 error = 0; in dlm_lock()
2568 return error; in dlm_lock()
2580 int error; in dlm_unlock() local
2588 error = find_lkb(ls, lkid, &lkb); in dlm_unlock()
2589 if (error) in dlm_unlock()
2592 error = set_unlock_args(flags, astarg, &args); in dlm_unlock()
2593 if (error) in dlm_unlock()
2597 error = cancel_lock(ls, lkb, &args); in dlm_unlock()
2599 error = unlock_lock(ls, lkb, &args); in dlm_unlock()
2601 if (error == -DLM_EUNLOCK || error == -DLM_ECANCEL) in dlm_unlock()
2602 error = 0; in dlm_unlock()
2603 if (error == -EBUSY && (flags & (DLM_LKF_CANCEL | DLM_LKF_FORCEUNLOCK))) in dlm_unlock()
2604 error = 0; in dlm_unlock()
2610 return error; in dlm_unlock()
2754 int to_nodeid, error; in send_common() local
2756 error = add_to_waiters(lkb, mstype); in send_common()
2757 if (error) in send_common()
2758 return error; in send_common()
2762 error = create_message(r, lkb, to_nodeid, mstype, &ms, &mh); in send_common()
2763 if (error) in send_common()
2768 error = send_message(mh, ms); in send_common()
2769 if (error) in send_common()
2775 return error; in send_common()
2785 int error; in send_convert() local
2787 error = send_common(r, lkb, DLM_MSG_CONVERT); in send_convert()
2790 if (!error && down_conversion(lkb)) { in send_convert()
2798 return error; in send_convert()
2819 int to_nodeid, error; in send_grant() local
2823 error = create_message(r, lkb, to_nodeid, DLM_MSG_GRANT, &ms, &mh); in send_grant()
2824 if (error) in send_grant()
2831 error = send_message(mh, ms); in send_grant()
2833 return error; in send_grant()
2840 int to_nodeid, error; in send_bast() local
2844 error = create_message(r, NULL, to_nodeid, DLM_MSG_BAST, &ms, &mh); in send_bast()
2845 if (error) in send_bast()
2852 error = send_message(mh, ms); in send_bast()
2854 return error; in send_bast()
2861 int to_nodeid, error; in send_lookup() local
2863 error = add_to_waiters(lkb, DLM_MSG_LOOKUP); in send_lookup()
2864 if (error) in send_lookup()
2865 return error; in send_lookup()
2869 error = create_message(r, NULL, to_nodeid, DLM_MSG_LOOKUP, &ms, &mh); in send_lookup()
2870 if (error) in send_lookup()
2875 error = send_message(mh, ms); in send_lookup()
2876 if (error) in send_lookup()
2882 return error; in send_lookup()
2889 int to_nodeid, error; in send_remove() local
2893 error = create_message(r, NULL, to_nodeid, DLM_MSG_REMOVE, &ms, &mh); in send_remove()
2894 if (error) in send_remove()
2900 error = send_message(mh, ms); in send_remove()
2902 return error; in send_remove()
2910 int to_nodeid, error; in send_common_reply() local
2914 error = create_message(r, lkb, to_nodeid, mstype, &ms, &mh); in send_common_reply()
2915 if (error) in send_common_reply()
2922 error = send_message(mh, ms); in send_common_reply()
2924 return error; in send_common_reply()
2953 int error, nodeid = ms_in->m_header.h_nodeid; in send_lookup_reply() local
2955 error = create_message(r, NULL, nodeid, DLM_MSG_LOOKUP_REPLY, &ms, &mh); in send_lookup_reply()
2956 if (error) in send_lookup_reply()
2963 error = send_message(mh, ms); in send_lookup_reply()
2965 return error; in send_lookup_reply()
3081 int error = 0; in validate_message() local
3088 error = -EINVAL; in validate_message()
3097 error = -EINVAL; in validate_message()
3102 error = -EINVAL; in validate_message()
3104 error = -EINVAL; in validate_message()
3108 error = -EINVAL; in validate_message()
3111 if (error) in validate_message()
3116 return error; in validate_message()
3123 int error, namelen; in receive_request() local
3125 error = create_lkb(ls, &lkb); in receive_request()
3126 if (error) in receive_request()
3131 error = receive_request_args(ls, lkb, ms); in receive_request()
3132 if (error) { in receive_request()
3139 error = find_rsb(ls, ms->m_extra, namelen, R_MASTER, &r); in receive_request()
3140 if (error) { in receive_request()
3148 error = do_request(r, lkb); in receive_request()
3149 send_request_reply(r, lkb, error); in receive_request()
3154 if (error == -EINPROGRESS) in receive_request()
3155 error = 0; in receive_request()
3156 if (error) in receive_request()
3162 send_request_reply(&ls->ls_stub_rsb, &ls->ls_stub_lkb, error); in receive_request()
3169 int error, reply = 1; in receive_convert() local
3171 error = find_lkb(ls, ms->m_remid, &lkb); in receive_convert()
3172 if (error) in receive_convert()
3180 error = validate_message(lkb, ms); in receive_convert()
3181 if (error) in receive_convert()
3185 error = receive_convert_args(ls, lkb, ms); in receive_convert()
3186 if (error) in receive_convert()
3190 error = do_convert(r, lkb); in receive_convert()
3193 send_convert_reply(r, lkb, error); in receive_convert()
3202 send_convert_reply(&ls->ls_stub_rsb, &ls->ls_stub_lkb, error); in receive_convert()
3209 int error; in receive_unlock() local
3211 error = find_lkb(ls, ms->m_remid, &lkb); in receive_unlock()
3212 if (error) in receive_unlock()
3220 error = validate_message(lkb, ms); in receive_unlock()
3221 if (error) in receive_unlock()
3225 error = receive_unlock_args(ls, lkb, ms); in receive_unlock()
3226 if (error) in receive_unlock()
3229 error = do_unlock(r, lkb); in receive_unlock()
3231 send_unlock_reply(r, lkb, error); in receive_unlock()
3240 send_unlock_reply(&ls->ls_stub_rsb, &ls->ls_stub_lkb, error); in receive_unlock()
3247 int error; in receive_cancel() local
3249 error = find_lkb(ls, ms->m_remid, &lkb); in receive_cancel()
3250 if (error) in receive_cancel()
3260 error = validate_message(lkb, ms); in receive_cancel()
3261 if (error) in receive_cancel()
3264 error = do_cancel(r, lkb); in receive_cancel()
3265 send_cancel_reply(r, lkb, error); in receive_cancel()
3274 send_cancel_reply(&ls->ls_stub_rsb, &ls->ls_stub_lkb, error); in receive_cancel()
3281 int error; in receive_grant() local
3283 error = find_lkb(ls, ms->m_remid, &lkb); in receive_grant()
3284 if (error) { in receive_grant()
3295 error = validate_message(lkb, ms); in receive_grant()
3296 if (error) in receive_grant()
3314 int error; in receive_bast() local
3316 error = find_lkb(ls, ms->m_remid, &lkb); in receive_bast()
3317 if (error) { in receive_bast()
3328 error = validate_message(lkb, ms); in receive_bast()
3329 if (error) in receive_bast()
3341 int len, error, ret_nodeid, dir_nodeid, from_nodeid, our_nodeid; in receive_lookup() local
3352 error = -EINVAL; in receive_lookup()
3357 error = dlm_dir_lookup(ls, from_nodeid, ms->m_extra, len, &ret_nodeid); in receive_lookup()
3360 if (!error && ret_nodeid == our_nodeid) { in receive_lookup()
3365 send_lookup_reply(ls, ms, ret_nodeid, error); in receive_lookup()
3395 int error, mstype, result; in receive_request_reply() local
3397 error = find_lkb(ls, ms->m_remid, &lkb); in receive_request_reply()
3398 if (error) { in receive_request_reply()
3408 error = validate_message(lkb, ms); in receive_request_reply()
3409 if (error) in receive_request_reply()
3413 error = remove_from_waiters(lkb, DLM_MSG_REQUEST_REPLY); in receive_request_reply()
3414 if (error) in receive_request_reply()
3539 int error; in _receive_convert_reply() local
3544 error = validate_message(lkb, ms); in _receive_convert_reply()
3545 if (error) in _receive_convert_reply()
3549 error = remove_from_waiters_ms(lkb, ms); in _receive_convert_reply()
3550 if (error) in _receive_convert_reply()
3562 int error; in receive_convert_reply() local
3564 error = find_lkb(ls, ms->m_remid, &lkb); in receive_convert_reply()
3565 if (error) { in receive_convert_reply()
3578 int error; in _receive_unlock_reply() local
3583 error = validate_message(lkb, ms); in _receive_unlock_reply()
3584 if (error) in _receive_unlock_reply()
3588 error = remove_from_waiters_ms(lkb, ms); in _receive_unlock_reply()
3589 if (error) in _receive_unlock_reply()
3614 int error; in receive_unlock_reply() local
3616 error = find_lkb(ls, ms->m_remid, &lkb); in receive_unlock_reply()
3617 if (error) { in receive_unlock_reply()
3630 int error; in _receive_cancel_reply() local
3635 error = validate_message(lkb, ms); in _receive_cancel_reply()
3636 if (error) in _receive_cancel_reply()
3640 error = remove_from_waiters_ms(lkb, ms); in _receive_cancel_reply()
3641 if (error) in _receive_cancel_reply()
3666 int error; in receive_cancel_reply() local
3668 error = find_lkb(ls, ms->m_remid, &lkb); in receive_cancel_reply()
3669 if (error) { in receive_cancel_reply()
3683 int error, ret_nodeid; in receive_lookup_reply() local
3685 error = find_lkb(ls, ms->m_lkid, &lkb); in receive_lookup_reply()
3686 if (error) { in receive_lookup_reply()
3698 error = remove_from_waiters(lkb, DLM_MSG_LOOKUP_REPLY); in receive_lookup_reply()
3699 if (error) in receive_lookup_reply()
4072 int error = 0, mstype, err, oc, ou; in dlm_recover_waiters_post() local
4077 error = -EINTR; in dlm_recover_waiters_post()
4155 return error; in dlm_recover_waiters_post()
4350 int error; in dlm_recover_master_copy() local
4353 error = -EOPNOTSUPP; in dlm_recover_master_copy()
4357 error = find_rsb(ls, rl->rl_name, le16_to_cpu(rl->rl_namelen), in dlm_recover_master_copy()
4359 if (error) in dlm_recover_master_copy()
4366 error = -EEXIST; in dlm_recover_master_copy()
4370 error = create_lkb(ls, &lkb); in dlm_recover_master_copy()
4371 if (error) in dlm_recover_master_copy()
4374 error = receive_rcom_lock_args(ls, lkb, r, rc); in dlm_recover_master_copy()
4375 if (error) { in dlm_recover_master_copy()
4382 error = 0; in dlm_recover_master_copy()
4393 if (error) in dlm_recover_master_copy()
4394 log_debug(ls, "recover_master_copy %d %x", error, in dlm_recover_master_copy()
4396 rl->rl_result = cpu_to_le32(error); in dlm_recover_master_copy()
4397 return error; in dlm_recover_master_copy()
4406 int error; in dlm_recover_process_copy() local
4408 error = find_lkb(ls, le32_to_cpu(rl->rl_lkid), &lkb); in dlm_recover_process_copy()
4409 if (error) { in dlm_recover_process_copy()
4412 return error; in dlm_recover_process_copy()
4417 error = le32_to_cpu(rl->rl_result); in dlm_recover_process_copy()
4423 switch (error) { in dlm_recover_process_copy()
4440 error, lkb->lkb_id); in dlm_recover_process_copy()
4460 int error; in dlm_user_request() local
4464 error = create_lkb(ls, &lkb); in dlm_user_request()
4465 if (error) { in dlm_user_request()
4475 error = -ENOMEM; in dlm_user_request()
4484 error = set_lock_args(mode, &ua->lksb, flags, namelen, timeout_cs, in dlm_user_request()
4489 if (error) { in dlm_user_request()
4494 error = request_lock(ls, lkb, name, namelen, &args); in dlm_user_request()
4496 switch (error) { in dlm_user_request()
4500 error = 0; in dlm_user_request()
4503 error = 0; in dlm_user_request()
4517 return error; in dlm_user_request()
4527 int error; in dlm_user_convert() local
4531 error = find_lkb(ls, lkid, &lkb); in dlm_user_convert()
4532 if (error) in dlm_user_convert()
4543 error = -ENOMEM; in dlm_user_convert()
4558 error = set_lock_args(mode, &ua->lksb, flags, 0, timeout_cs, in dlm_user_convert()
4560 if (error) in dlm_user_convert()
4563 error = convert_lock(ls, lkb, &args); in dlm_user_convert()
4565 if (error == -EINPROGRESS || error == -EAGAIN || error == -EDEADLK) in dlm_user_convert()
4566 error = 0; in dlm_user_convert()
4572 return error; in dlm_user_convert()
4581 int error; in dlm_user_unlock() local
4585 error = find_lkb(ls, lkid, &lkb); in dlm_user_unlock()
4586 if (error) in dlm_user_unlock()
4597 error = set_unlock_args(flags, ua, &args); in dlm_user_unlock()
4598 if (error) in dlm_user_unlock()
4601 error = unlock_lock(ls, lkb, &args); in dlm_user_unlock()
4603 if (error == -DLM_EUNLOCK) in dlm_user_unlock()
4604 error = 0; in dlm_user_unlock()
4606 if (error == -EBUSY && (flags & DLM_LKF_FORCEUNLOCK)) in dlm_user_unlock()
4607 error = 0; in dlm_user_unlock()
4608 if (error) in dlm_user_unlock()
4621 return error; in dlm_user_unlock()
4630 int error; in dlm_user_cancel() local
4634 error = find_lkb(ls, lkid, &lkb); in dlm_user_cancel()
4635 if (error) in dlm_user_cancel()
4643 error = set_unlock_args(flags, ua, &args); in dlm_user_cancel()
4644 if (error) in dlm_user_cancel()
4647 error = cancel_lock(ls, lkb, &args); in dlm_user_cancel()
4649 if (error == -DLM_ECANCEL) in dlm_user_cancel()
4650 error = 0; in dlm_user_cancel()
4652 if (error == -EBUSY) in dlm_user_cancel()
4653 error = 0; in dlm_user_cancel()
4659 return error; in dlm_user_cancel()
4668 int error; in dlm_user_deadlock() local
4672 error = find_lkb(ls, lkid, &lkb); in dlm_user_deadlock()
4673 if (error) in dlm_user_deadlock()
4678 error = set_unlock_args(flags, ua, &args); in dlm_user_deadlock()
4679 if (error) in dlm_user_deadlock()
4688 error = validate_unlock_args(lkb, &args); in dlm_user_deadlock()
4689 if (error) in dlm_user_deadlock()
4693 error = _cancel_lock(r, lkb); in dlm_user_deadlock()
4698 if (error == -DLM_ECANCEL) in dlm_user_deadlock()
4699 error = 0; in dlm_user_deadlock()
4701 if (error == -EBUSY) in dlm_user_deadlock()
4702 error = 0; in dlm_user_deadlock()
4707 return error; in dlm_user_deadlock()
4716 int error; in orphan_proc_lock() local
4725 error = cancel_lock(ls, lkb, &args); in orphan_proc_lock()
4726 if (error == -DLM_ECANCEL) in orphan_proc_lock()
4727 error = 0; in orphan_proc_lock()
4728 return error; in orphan_proc_lock()
4737 int error; in unlock_proc_lock() local
4741 error = unlock_lock(ls, lkb, &args); in unlock_proc_lock()
4742 if (error == -DLM_EUNLOCK) in unlock_proc_lock()
4743 error = 0; in unlock_proc_lock()
4744 return error; in unlock_proc_lock()
4883 int error; in send_purge() local
4885 error = _create_message(ls, sizeof(struct dlm_message), nodeid, in send_purge()
4887 if (error) in send_purge()
4888 return error; in send_purge()
4898 int error = 0; in dlm_user_purge() local
4901 error = send_purge(ls, nodeid, pid); in dlm_user_purge()
4910 return error; in dlm_user_purge()