Lines Matching refs:state
454 struct nfs4_state *state = exception->state; in nfs4_do_handle_exception() local
464 if (stateid == NULL && state != NULL) in nfs4_do_handle_exception()
465 stateid = nfs4_recoverable_stateid(&state->stateid); in nfs4_do_handle_exception()
498 if (state == NULL) in nfs4_do_handle_exception()
500 ret = nfs4_schedule_stateid_recovery(server, state); in nfs4_do_handle_exception()
632 struct nfs4_state *state, long *timeout) in nfs4_async_handle_error() argument
635 .state = state, in nfs4_async_handle_error()
1379 if (p->state != NULL) in nfs4_opendata_free()
1380 nfs4_put_open_state(p->state); in nfs4_opendata_free()
1400 static bool nfs4_mode_match_open_stateid(struct nfs4_state *state, in nfs4_mode_match_open_stateid() argument
1405 return state->n_rdwr != 0; in nfs4_mode_match_open_stateid()
1407 return state->n_wronly != 0; in nfs4_mode_match_open_stateid()
1409 return state->n_rdonly != 0; in nfs4_mode_match_open_stateid()
1415 static int can_open_cached(struct nfs4_state *state, fmode_t mode, in can_open_cached() argument
1431 ret |= test_bit(NFS_O_RDONLY_STATE, &state->flags) != 0 in can_open_cached()
1432 && state->n_rdonly != 0; in can_open_cached()
1435 ret |= test_bit(NFS_O_WRONLY_STATE, &state->flags) != 0 in can_open_cached()
1436 && state->n_wronly != 0; in can_open_cached()
1439 ret |= test_bit(NFS_O_RDWR_STATE, &state->flags) != 0 in can_open_cached()
1440 && state->n_rdwr != 0; in can_open_cached()
1468 static void update_open_stateflags(struct nfs4_state *state, fmode_t fmode) in update_open_stateflags() argument
1472 state->n_wronly++; in update_open_stateflags()
1475 state->n_rdonly++; in update_open_stateflags()
1478 state->n_rdwr++; in update_open_stateflags()
1480 nfs4_state_set_mode_locked(state, state->state | fmode); in update_open_stateflags()
1484 static bool nfs_open_stateid_recover_openmode(struct nfs4_state *state) in nfs_open_stateid_recover_openmode() argument
1486 if (state->n_rdonly && !test_bit(NFS_O_RDONLY_STATE, &state->flags)) in nfs_open_stateid_recover_openmode()
1488 if (state->n_wronly && !test_bit(NFS_O_WRONLY_STATE, &state->flags)) in nfs_open_stateid_recover_openmode()
1490 if (state->n_rdwr && !test_bit(NFS_O_RDWR_STATE, &state->flags)) in nfs_open_stateid_recover_openmode()
1496 static void nfs_state_log_update_open_stateid(struct nfs4_state *state) in nfs_state_log_update_open_stateid() argument
1498 if (test_and_clear_bit(NFS_STATE_CHANGE_WAIT, &state->flags)) in nfs_state_log_update_open_stateid()
1499 wake_up_all(&state->waitq); in nfs_state_log_update_open_stateid()
1502 static void nfs_state_log_out_of_order_open_stateid(struct nfs4_state *state, in nfs_state_log_out_of_order_open_stateid() argument
1505 u32 state_seqid = be32_to_cpu(state->open_stateid.seqid); in nfs_state_log_out_of_order_open_stateid()
1510 nfs_state_log_update_open_stateid(state); in nfs_state_log_out_of_order_open_stateid()
1512 set_bit(NFS_STATE_CHANGE_WAIT, &state->flags); in nfs_state_log_out_of_order_open_stateid()
1515 static void nfs_test_and_clear_all_open_stateid(struct nfs4_state *state) in nfs_test_and_clear_all_open_stateid() argument
1517 struct nfs_client *clp = state->owner->so_server->nfs_client; in nfs_test_and_clear_all_open_stateid()
1520 if (test_and_clear_bit(NFS_O_RDONLY_STATE, &state->flags) && state->n_rdonly) in nfs_test_and_clear_all_open_stateid()
1522 if (test_and_clear_bit(NFS_O_WRONLY_STATE, &state->flags) && state->n_wronly) in nfs_test_and_clear_all_open_stateid()
1524 if (test_and_clear_bit(NFS_O_RDWR_STATE, &state->flags) && state->n_rdwr) in nfs_test_and_clear_all_open_stateid()
1527 nfs4_state_mark_reclaim_nograce(clp, state); in nfs_test_and_clear_all_open_stateid()
1540 static bool nfs_need_update_open_stateid(struct nfs4_state *state, in nfs_need_update_open_stateid() argument
1543 if (test_bit(NFS_OPEN_STATE, &state->flags) == 0 || in nfs_need_update_open_stateid()
1544 !nfs4_stateid_match_other(stateid, &state->open_stateid)) { in nfs_need_update_open_stateid()
1546 nfs_state_log_update_open_stateid(state); in nfs_need_update_open_stateid()
1548 set_bit(NFS_STATE_CHANGE_WAIT, &state->flags); in nfs_need_update_open_stateid()
1552 if (nfs4_stateid_is_newer(stateid, &state->open_stateid)) { in nfs_need_update_open_stateid()
1553 nfs_state_log_out_of_order_open_stateid(state, stateid); in nfs_need_update_open_stateid()
1559 static void nfs_resync_open_stateid_locked(struct nfs4_state *state) in nfs_resync_open_stateid_locked() argument
1561 if (!(state->n_wronly || state->n_rdonly || state->n_rdwr)) in nfs_resync_open_stateid_locked()
1563 if (state->n_wronly) in nfs_resync_open_stateid_locked()
1564 set_bit(NFS_O_WRONLY_STATE, &state->flags); in nfs_resync_open_stateid_locked()
1565 if (state->n_rdonly) in nfs_resync_open_stateid_locked()
1566 set_bit(NFS_O_RDONLY_STATE, &state->flags); in nfs_resync_open_stateid_locked()
1567 if (state->n_rdwr) in nfs_resync_open_stateid_locked()
1568 set_bit(NFS_O_RDWR_STATE, &state->flags); in nfs_resync_open_stateid_locked()
1569 set_bit(NFS_OPEN_STATE, &state->flags); in nfs_resync_open_stateid_locked()
1572 static void nfs_clear_open_stateid_locked(struct nfs4_state *state, in nfs_clear_open_stateid_locked() argument
1575 clear_bit(NFS_O_RDWR_STATE, &state->flags); in nfs_clear_open_stateid_locked()
1578 clear_bit(NFS_O_RDONLY_STATE, &state->flags); in nfs_clear_open_stateid_locked()
1581 clear_bit(NFS_O_WRONLY_STATE, &state->flags); in nfs_clear_open_stateid_locked()
1584 clear_bit(NFS_O_RDONLY_STATE, &state->flags); in nfs_clear_open_stateid_locked()
1585 clear_bit(NFS_O_WRONLY_STATE, &state->flags); in nfs_clear_open_stateid_locked()
1586 clear_bit(NFS_OPEN_STATE, &state->flags); in nfs_clear_open_stateid_locked()
1591 if (nfs4_stateid_match_other(stateid, &state->open_stateid) && in nfs_clear_open_stateid_locked()
1592 !nfs4_stateid_is_newer(stateid, &state->open_stateid)) { in nfs_clear_open_stateid_locked()
1593 nfs_resync_open_stateid_locked(state); in nfs_clear_open_stateid_locked()
1596 if (test_bit(NFS_DELEGATED_STATE, &state->flags) == 0) in nfs_clear_open_stateid_locked()
1597 nfs4_stateid_copy(&state->stateid, stateid); in nfs_clear_open_stateid_locked()
1598 nfs4_stateid_copy(&state->open_stateid, stateid); in nfs_clear_open_stateid_locked()
1599 trace_nfs4_open_stateid_update(state->inode, stateid, 0); in nfs_clear_open_stateid_locked()
1601 nfs_state_log_update_open_stateid(state); in nfs_clear_open_stateid_locked()
1604 static void nfs_clear_open_stateid(struct nfs4_state *state, in nfs_clear_open_stateid() argument
1608 write_seqlock(&state->seqlock); in nfs_clear_open_stateid()
1610 if (nfs4_state_match_open_stateid_other(state, arg_stateid)) in nfs_clear_open_stateid()
1611 nfs_clear_open_stateid_locked(state, stateid, fmode); in nfs_clear_open_stateid()
1612 write_sequnlock(&state->seqlock); in nfs_clear_open_stateid()
1613 if (test_bit(NFS_STATE_RECLAIM_NOGRACE, &state->flags)) in nfs_clear_open_stateid()
1614 nfs4_schedule_state_manager(state->owner->so_server->nfs_client); in nfs_clear_open_stateid()
1617 static void nfs_set_open_stateid_locked(struct nfs4_state *state, in nfs_set_open_stateid_locked() argument
1619 __must_hold(&state->owner->so_lock) in nfs_set_open_stateid_locked()
1620 __must_hold(&state->seqlock) in nfs_set_open_stateid_locked()
1628 if (!nfs_need_update_open_stateid(state, stateid)) in nfs_set_open_stateid_locked()
1630 if (!test_bit(NFS_STATE_CHANGE_WAIT, &state->flags)) in nfs_set_open_stateid_locked()
1635 if (!nfs4_has_session(NFS_SERVER(state->inode)->nfs_client)) in nfs_set_open_stateid_locked()
1638 prepare_to_wait(&state->waitq, &wait, TASK_KILLABLE); in nfs_set_open_stateid_locked()
1644 write_sequnlock(&state->seqlock); in nfs_set_open_stateid_locked()
1645 spin_unlock(&state->owner->so_lock); in nfs_set_open_stateid_locked()
1647 trace_nfs4_open_stateid_update_wait(state->inode, stateid, 0); in nfs_set_open_stateid_locked()
1655 finish_wait(&state->waitq, &wait); in nfs_set_open_stateid_locked()
1657 spin_lock(&state->owner->so_lock); in nfs_set_open_stateid_locked()
1658 write_seqlock(&state->seqlock); in nfs_set_open_stateid_locked()
1661 if (test_bit(NFS_OPEN_STATE, &state->flags) && in nfs_set_open_stateid_locked()
1662 !nfs4_stateid_match_other(stateid, &state->open_stateid)) { in nfs_set_open_stateid_locked()
1663 nfs4_stateid_copy(freeme, &state->open_stateid); in nfs_set_open_stateid_locked()
1664 nfs_test_and_clear_all_open_stateid(state); in nfs_set_open_stateid_locked()
1667 if (test_bit(NFS_DELEGATED_STATE, &state->flags) == 0) in nfs_set_open_stateid_locked()
1668 nfs4_stateid_copy(&state->stateid, stateid); in nfs_set_open_stateid_locked()
1669 nfs4_stateid_copy(&state->open_stateid, stateid); in nfs_set_open_stateid_locked()
1670 trace_nfs4_open_stateid_update(state->inode, stateid, status); in nfs_set_open_stateid_locked()
1671 nfs_state_log_update_open_stateid(state); in nfs_set_open_stateid_locked()
1674 static void nfs_state_set_open_stateid(struct nfs4_state *state, in nfs_state_set_open_stateid() argument
1683 write_seqlock(&state->seqlock); in nfs_state_set_open_stateid()
1684 nfs_set_open_stateid_locked(state, open_stateid, freeme); in nfs_state_set_open_stateid()
1687 set_bit(NFS_O_RDONLY_STATE, &state->flags); in nfs_state_set_open_stateid()
1690 set_bit(NFS_O_WRONLY_STATE, &state->flags); in nfs_state_set_open_stateid()
1693 set_bit(NFS_O_RDWR_STATE, &state->flags); in nfs_state_set_open_stateid()
1695 set_bit(NFS_OPEN_STATE, &state->flags); in nfs_state_set_open_stateid()
1696 write_sequnlock(&state->seqlock); in nfs_state_set_open_stateid()
1699 static void nfs_state_clear_open_state_flags(struct nfs4_state *state) in nfs_state_clear_open_state_flags() argument
1701 clear_bit(NFS_O_RDWR_STATE, &state->flags); in nfs_state_clear_open_state_flags()
1702 clear_bit(NFS_O_WRONLY_STATE, &state->flags); in nfs_state_clear_open_state_flags()
1703 clear_bit(NFS_O_RDONLY_STATE, &state->flags); in nfs_state_clear_open_state_flags()
1704 clear_bit(NFS_OPEN_STATE, &state->flags); in nfs_state_clear_open_state_flags()
1707 static void nfs_state_set_delegation(struct nfs4_state *state, in nfs_state_set_delegation() argument
1715 write_seqlock(&state->seqlock); in nfs_state_set_delegation()
1716 nfs4_stateid_copy(&state->stateid, deleg_stateid); in nfs_state_set_delegation()
1717 set_bit(NFS_DELEGATED_STATE, &state->flags); in nfs_state_set_delegation()
1718 write_sequnlock(&state->seqlock); in nfs_state_set_delegation()
1721 static void nfs_state_clear_delegation(struct nfs4_state *state) in nfs_state_clear_delegation() argument
1723 write_seqlock(&state->seqlock); in nfs_state_clear_delegation()
1724 nfs4_stateid_copy(&state->stateid, &state->open_stateid); in nfs_state_clear_delegation()
1725 clear_bit(NFS_DELEGATED_STATE, &state->flags); in nfs_state_clear_delegation()
1726 write_sequnlock(&state->seqlock); in nfs_state_clear_delegation()
1729 static int update_open_stateid(struct nfs4_state *state, in update_open_stateid() argument
1734 struct nfs_server *server = NFS_SERVER(state->inode); in update_open_stateid()
1736 struct nfs_inode *nfsi = NFS_I(state->inode); in update_open_stateid()
1744 spin_lock(&state->owner->so_lock); in update_open_stateid()
1746 nfs_state_set_open_stateid(state, open_stateid, fmode, &freeme); in update_open_stateid()
1766 nfs_state_set_delegation(state, &deleg_cur->stateid, fmode); in update_open_stateid()
1772 update_open_stateflags(state, fmode); in update_open_stateid()
1773 spin_unlock(&state->owner->so_lock); in update_open_stateid()
1776 if (test_bit(NFS_STATE_RECLAIM_NOGRACE, &state->flags)) in update_open_stateid()
1780 state->owner->so_cred); in update_open_stateid()
1788 struct nfs4_state *state = lsp->ls_state; in nfs4_update_lock_stateid() local
1791 spin_lock(&state->state_lock); in nfs4_update_lock_stateid()
1799 spin_unlock(&state->state_lock); in nfs4_update_lock_stateid()
1820 struct nfs4_state *state = opendata->state; in nfs4_try_open_cached() local
1829 spin_lock(&state->owner->so_lock); in nfs4_try_open_cached()
1830 if (can_open_cached(state, fmode, open_mode, claim)) { in nfs4_try_open_cached()
1831 update_open_stateflags(state, fmode); in nfs4_try_open_cached()
1832 spin_unlock(&state->owner->so_lock); in nfs4_try_open_cached()
1835 spin_unlock(&state->owner->so_lock); in nfs4_try_open_cached()
1837 delegation = nfs4_get_valid_delegation(state->inode); in nfs4_try_open_cached()
1847 ret = nfs_may_open(state->inode, state->owner->so_cred, open_mode); in nfs4_try_open_cached()
1854 if (update_open_stateid(state, NULL, &stateid, fmode)) in nfs4_try_open_cached()
1860 refcount_inc(&state->count); in nfs4_try_open_cached()
1861 return state; in nfs4_try_open_cached()
1865 nfs4_opendata_check_deleg(struct nfs4_opendata *data, struct nfs4_state *state) in nfs4_opendata_check_deleg() argument
1867 struct nfs_client *clp = NFS_SERVER(state->inode)->nfs_client; in nfs4_opendata_check_deleg()
1872 delegation = rcu_dereference(NFS_I(state->inode)->delegation); in nfs4_opendata_check_deleg()
1888 nfs_inode_set_delegation(state->inode, in nfs4_opendata_check_deleg()
1894 nfs_inode_reclaim_delegation(state->inode, in nfs4_opendata_check_deleg()
1901 nfs_async_inode_return_delegation(state->inode, in nfs4_opendata_check_deleg()
1912 struct inode *inode = data->state->inode; in _nfs4_opendata_reclaim_to_nfs4_state()
1913 struct nfs4_state *state = data->state; in _nfs4_opendata_reclaim_to_nfs4_state() local
1928 nfs4_opendata_check_deleg(data, state); in _nfs4_opendata_reclaim_to_nfs4_state()
1930 if (!update_open_stateid(state, &data->o_res.stateid, in _nfs4_opendata_reclaim_to_nfs4_state()
1933 refcount_inc(&state->count); in _nfs4_opendata_reclaim_to_nfs4_state()
1935 return state; in _nfs4_opendata_reclaim_to_nfs4_state()
1963 struct nfs4_state *state; in nfs4_opendata_find_nfs4_state() local
1969 if (data->state != NULL && data->state->inode == inode) { in nfs4_opendata_find_nfs4_state()
1970 state = data->state; in nfs4_opendata_find_nfs4_state()
1971 refcount_inc(&state->count); in nfs4_opendata_find_nfs4_state()
1973 state = nfs4_get_open_state(inode, data->owner); in nfs4_opendata_find_nfs4_state()
1975 if (state == NULL) in nfs4_opendata_find_nfs4_state()
1976 state = ERR_PTR(-ENOMEM); in nfs4_opendata_find_nfs4_state()
1977 return state; in nfs4_opendata_find_nfs4_state()
1983 struct nfs4_state *state; in _nfs4_opendata_to_nfs4_state() local
1986 state = nfs4_try_open_cached(data); in _nfs4_opendata_to_nfs4_state()
1987 trace_nfs4_cached_open(data->state); in _nfs4_opendata_to_nfs4_state()
1991 state = nfs4_opendata_find_nfs4_state(data); in _nfs4_opendata_to_nfs4_state()
1992 if (IS_ERR(state)) in _nfs4_opendata_to_nfs4_state()
1996 nfs4_opendata_check_deleg(data, state); in _nfs4_opendata_to_nfs4_state()
1997 if (!update_open_stateid(state, &data->o_res.stateid, in _nfs4_opendata_to_nfs4_state()
1999 nfs4_put_open_state(state); in _nfs4_opendata_to_nfs4_state()
2000 state = ERR_PTR(-EAGAIN); in _nfs4_opendata_to_nfs4_state()
2004 return state; in _nfs4_opendata_to_nfs4_state()
2021 nfs4_state_find_open_context_mode(struct nfs4_state *state, fmode_t mode) in nfs4_state_find_open_context_mode() argument
2023 struct nfs_inode *nfsi = NFS_I(state->inode); in nfs4_state_find_open_context_mode()
2028 if (ctx->state != state) in nfs4_state_find_open_context_mode()
2042 nfs4_state_find_open_context(struct nfs4_state *state) in nfs4_state_find_open_context() argument
2046 ctx = nfs4_state_find_open_context_mode(state, FMODE_READ|FMODE_WRITE); in nfs4_state_find_open_context()
2049 ctx = nfs4_state_find_open_context_mode(state, FMODE_WRITE); in nfs4_state_find_open_context()
2052 return nfs4_state_find_open_context_mode(state, FMODE_READ); in nfs4_state_find_open_context()
2056 struct nfs4_state *state, enum open_claim_type4 claim) in nfs4_open_recoverdata_alloc() argument
2060 opendata = nfs4_opendata_alloc(ctx->dentry, state->owner, 0, 0, in nfs4_open_recoverdata_alloc()
2064 opendata->state = state; in nfs4_open_recoverdata_alloc()
2065 refcount_inc(&state->count); in nfs4_open_recoverdata_alloc()
2075 if (!nfs4_mode_match_open_stateid(opendata->state, fmode)) in nfs4_open_recover_helper()
2091 if (newstate != opendata->state) in nfs4_open_recover_helper()
2097 static int nfs4_open_recover(struct nfs4_opendata *opendata, struct nfs4_state *state) in nfs4_open_recover() argument
2116 if (test_bit(NFS_DELEGATED_STATE, &state->flags) == 0 && in nfs4_open_recover()
2117 !nfs4_stateid_match(&state->stateid, &state->open_stateid)) { in nfs4_open_recover()
2118 write_seqlock(&state->seqlock); in nfs4_open_recover()
2119 if (test_bit(NFS_DELEGATED_STATE, &state->flags) == 0) in nfs4_open_recover()
2120 nfs4_stateid_copy(&state->stateid, &state->open_stateid); in nfs4_open_recover()
2121 write_sequnlock(&state->seqlock); in nfs4_open_recover()
2130 static int _nfs4_do_open_reclaim(struct nfs_open_context *ctx, struct nfs4_state *state) in _nfs4_do_open_reclaim() argument
2137 opendata = nfs4_open_recoverdata_alloc(ctx, state, in _nfs4_do_open_reclaim()
2142 delegation = rcu_dereference(NFS_I(state->inode)->delegation); in _nfs4_do_open_reclaim()
2147 status = nfs4_open_recover(opendata, state); in _nfs4_do_open_reclaim()
2152 static int nfs4_do_open_reclaim(struct nfs_open_context *ctx, struct nfs4_state *state) in nfs4_do_open_reclaim() argument
2154 struct nfs_server *server = NFS_SERVER(state->inode); in nfs4_do_open_reclaim()
2158 err = _nfs4_do_open_reclaim(ctx, state); in nfs4_do_open_reclaim()
2169 static int nfs4_open_reclaim(struct nfs4_state_owner *sp, struct nfs4_state *state) in nfs4_open_reclaim() argument
2174 ctx = nfs4_state_find_open_context(state); in nfs4_open_reclaim()
2177 clear_bit(NFS_DELEGATED_STATE, &state->flags); in nfs4_open_reclaim()
2178 nfs_state_clear_open_state_flags(state); in nfs4_open_reclaim()
2179 ret = nfs4_do_open_reclaim(ctx, state); in nfs4_open_reclaim()
2184 static int nfs4_handle_delegation_recall_error(struct nfs_server *server, struct nfs4_state *state,… in nfs4_handle_delegation_recall_error() argument
2218 nfs_inode_find_state_and_recover(state->inode, in nfs4_handle_delegation_recall_error()
2220 nfs4_schedule_stateid_recovery(server, state); in nfs4_handle_delegation_recall_error()
2239 struct nfs4_state *state, const nfs4_stateid *stateid) in nfs4_open_delegation_recall() argument
2241 struct nfs_server *server = NFS_SERVER(state->inode); in nfs4_open_delegation_recall()
2245 opendata = nfs4_open_recoverdata_alloc(ctx, state, in nfs4_open_delegation_recall()
2250 if (!test_bit(NFS_O_RDWR_STATE, &state->flags)) { in nfs4_open_delegation_recall()
2255 if (!test_bit(NFS_O_WRONLY_STATE, &state->flags)) { in nfs4_open_delegation_recall()
2260 if (!test_bit(NFS_O_RDONLY_STATE, &state->flags)) { in nfs4_open_delegation_recall()
2265 nfs_state_clear_delegation(state); in nfs4_open_delegation_recall()
2268 return nfs4_handle_delegation_recall_error(server, state, stateid, NULL, err); in nfs4_open_delegation_recall()
2297 struct nfs4_state *state = NULL; in nfs4_open_confirm_release() local
2305 state = nfs4_opendata_to_nfs4_state(data); in nfs4_open_confirm_release()
2306 if (!IS_ERR(state)) in nfs4_open_confirm_release()
2307 nfs4_close_state(state, data->o_arg.fmode); in nfs4_open_confirm_release()
2373 if (data->state != NULL) { in nfs4_open_prepare()
2376 if (can_open_cached(data->state, data->o_arg.fmode, in nfs4_open_prepare()
2380 delegation = nfs4_get_valid_delegation(data->state->inode); in nfs4_open_prepare()
2416 trace_nfs4_cached_open(data->state); in nfs4_open_prepare()
2458 struct nfs4_state *state = NULL; in nfs4_open_release() local
2469 state = nfs4_opendata_to_nfs4_state(data); in nfs4_open_release()
2470 if (!IS_ERR(state)) in nfs4_open_release()
2471 nfs4_close_state(state, data->o_arg.fmode); in nfs4_open_release()
2561 struct nfs4_state *state, fmode_t fmode, in nfs4_opendata_access() argument
2579 if (S_ISDIR(state->inode->i_mode)) in nfs4_opendata_access()
2588 nfs_access_add_cache(state->inode, &cache); in nfs4_opendata_access()
2651 static int _nfs4_open_expired(struct nfs_open_context *ctx, struct nfs4_state *state) in _nfs4_open_expired() argument
2656 opendata = nfs4_open_recoverdata_alloc(ctx, state, in _nfs4_open_expired()
2660 ret = nfs4_open_recover(opendata, state); in _nfs4_open_expired()
2667 static int nfs4_do_open_expired(struct nfs_open_context *ctx, struct nfs4_state *state) in nfs4_do_open_expired() argument
2669 struct nfs_server *server = NFS_SERVER(state->inode); in nfs4_do_open_expired()
2674 err = _nfs4_open_expired(ctx, state); in nfs4_do_open_expired()
2691 static int nfs4_open_expired(struct nfs4_state_owner *sp, struct nfs4_state *state) in nfs4_open_expired() argument
2696 ctx = nfs4_state_find_open_context(state); in nfs4_open_expired()
2699 ret = nfs4_do_open_expired(ctx, state); in nfs4_open_expired()
2704 static void nfs_finish_clear_delegation_stateid(struct nfs4_state *state, in nfs_finish_clear_delegation_stateid() argument
2707 nfs_remove_bad_delegation(state->inode, stateid); in nfs_finish_clear_delegation_stateid()
2708 nfs_state_clear_delegation(state); in nfs_finish_clear_delegation_stateid()
2711 static void nfs40_clear_delegation_stateid(struct nfs4_state *state) in nfs40_clear_delegation_stateid() argument
2713 if (rcu_access_pointer(NFS_I(state->inode)->delegation) != NULL) in nfs40_clear_delegation_stateid()
2714 nfs_finish_clear_delegation_stateid(state, NULL); in nfs40_clear_delegation_stateid()
2717 static int nfs40_open_expired(struct nfs4_state_owner *sp, struct nfs4_state *state) in nfs40_open_expired() argument
2720 nfs40_clear_delegation_stateid(state); in nfs40_open_expired()
2721 nfs_state_clear_open_state_flags(state); in nfs40_open_expired()
2722 return nfs4_open_expired(sp, state); in nfs40_open_expired()
2764 static int nfs41_check_delegation_stateid(struct nfs4_state *state) in nfs41_check_delegation_stateid() argument
2766 struct nfs_server *server = NFS_SERVER(state->inode); in nfs41_check_delegation_stateid()
2774 delegation = rcu_dereference(NFS_I(state->inode)->delegation); in nfs41_check_delegation_stateid()
2777 nfs_state_clear_delegation(state); in nfs41_check_delegation_stateid()
2793 trace_nfs4_test_delegation_stateid(state, NULL, status); in nfs41_check_delegation_stateid()
2795 nfs_finish_clear_delegation_stateid(state, &stateid); in nfs41_check_delegation_stateid()
2803 static void nfs41_delegation_recover_stateid(struct nfs4_state *state) in nfs41_delegation_recover_stateid() argument
2807 if (test_bit(NFS_DELEGATED_STATE, &state->flags) && in nfs41_delegation_recover_stateid()
2808 nfs4_copy_delegation_stateid(state->inode, state->state, in nfs41_delegation_recover_stateid()
2810 nfs4_stateid_match_other(&state->stateid, &tmp)) in nfs41_delegation_recover_stateid()
2811 nfs_state_set_delegation(state, &tmp, state->state); in nfs41_delegation_recover_stateid()
2813 nfs_state_clear_delegation(state); in nfs41_delegation_recover_stateid()
2824 static int nfs41_check_expired_locks(struct nfs4_state *state) in nfs41_check_expired_locks() argument
2828 struct nfs_server *server = NFS_SERVER(state->inode); in nfs41_check_expired_locks()
2830 if (!test_bit(LK_STATE_IN_USE, &state->flags)) in nfs41_check_expired_locks()
2833 spin_lock(&state->state_lock); in nfs41_check_expired_locks()
2834 list_for_each_entry(lsp, &state->lock_states, ls_locks) { in nfs41_check_expired_locks()
2839 spin_unlock(&state->state_lock); in nfs41_check_expired_locks()
2847 trace_nfs4_test_lock_stateid(state, lsp, status); in nfs41_check_expired_locks()
2859 spin_lock(&state->state_lock); in nfs41_check_expired_locks()
2862 spin_unlock(&state->state_lock); in nfs41_check_expired_locks()
2876 static int nfs41_check_open_stateid(struct nfs4_state *state) in nfs41_check_open_stateid() argument
2878 struct nfs_server *server = NFS_SERVER(state->inode); in nfs41_check_open_stateid()
2879 nfs4_stateid *stateid = &state->open_stateid; in nfs41_check_open_stateid()
2880 const struct cred *cred = state->owner->so_cred; in nfs41_check_open_stateid()
2883 if (test_bit(NFS_OPEN_STATE, &state->flags) == 0) in nfs41_check_open_stateid()
2886 trace_nfs4_test_open_stateid(state, NULL, status); in nfs41_check_open_stateid()
2888 nfs_state_clear_open_state_flags(state); in nfs41_check_open_stateid()
2892 if (nfs_open_stateid_recover_openmode(state)) in nfs41_check_open_stateid()
2897 static int nfs41_open_expired(struct nfs4_state_owner *sp, struct nfs4_state *state) in nfs41_open_expired() argument
2901 status = nfs41_check_delegation_stateid(state); in nfs41_open_expired()
2904 nfs41_delegation_recover_stateid(state); in nfs41_open_expired()
2906 status = nfs41_check_expired_locks(state); in nfs41_open_expired()
2909 status = nfs41_check_open_stateid(state); in nfs41_open_expired()
2911 status = nfs4_open_expired(sp, state); in nfs41_open_expired()
2963 struct nfs4_state *state; in _nfs4_open_and_get_state() local
2974 state = _nfs4_opendata_to_nfs4_state(opendata); in _nfs4_open_and_get_state()
2975 ret = PTR_ERR(state); in _nfs4_open_and_get_state()
2976 if (IS_ERR(state)) in _nfs4_open_and_get_state()
2978 ctx->state = state; in _nfs4_open_and_get_state()
2980 set_bit(NFS_STATE_POSIX_LOCKS, &state->flags); in _nfs4_open_and_get_state()
2982 set_bit(NFS_STATE_MAY_NOTIFY_LOCK, &state->flags); in _nfs4_open_and_get_state()
2988 alias = d_exact_alias(dentry, state->inode); in _nfs4_open_and_get_state()
2990 alias = d_splice_alias(igrab(state->inode), dentry); in _nfs4_open_and_get_state()
3001 pnfs_parse_lgopen(state->inode, opendata->lgp, ctx); in _nfs4_open_and_get_state()
3003 ret = nfs4_opendata_access(sp->so_cred, opendata, state, in _nfs4_open_and_get_state()
3008 if (d_inode(dentry) == state->inode) { in _nfs4_open_and_get_state()
3011 nfs4_schedule_stateid_recovery(server, state); in _nfs4_open_and_get_state()
3030 struct nfs4_state *state = NULL; in _nfs4_do_open() local
3080 opendata->state = nfs4_get_open_state(d_inode(dentry), sp); in _nfs4_do_open()
3085 state = ctx->state; in _nfs4_do_open()
3099 status = nfs4_do_setattr(state->inode, cred, in _nfs4_do_open()
3103 nfs_setattr_update_inode(state->inode, sattr, in _nfs4_do_open()
3105 nfs_setsecurity(state->inode, opendata->o_res.f_attr, olabel); in _nfs4_do_open()
3158 res = ctx->state; in nfs4_do_open()
3230 } else if (ctx != NULL && ctx->state) { in _nfs4_do_setattr()
3232 if (!nfs4_valid_open_stateid(ctx->state)) in _nfs4_do_setattr()
3237 status = nfs4_select_rw_stateid(ctx->state, FMODE_WRITE, l_ctx, in _nfs4_do_setattr()
3265 struct nfs4_state *state = ctx ? ctx->state : NULL; in nfs4_do_setattr() local
3279 .state = state, in nfs4_do_setattr()
3300 if (state && !(state->state & FMODE_WRITE)) { in nfs4_do_setattr()
3326 struct nfs4_state *state) in nfs4_sync_open_stateid() argument
3333 if (!nfs4_valid_open_stateid(state)) in nfs4_sync_open_stateid()
3335 seq = read_seqbegin(&state->seqlock); in nfs4_sync_open_stateid()
3336 if (!nfs4_state_match_open_stateid_other(state, dst)) { in nfs4_sync_open_stateid()
3337 nfs4_stateid_copy(dst, &state->open_stateid); in nfs4_sync_open_stateid()
3338 if (read_seqretry(&state->seqlock, seq)) in nfs4_sync_open_stateid()
3342 seqid_open = state->open_stateid.seqid; in nfs4_sync_open_stateid()
3343 if (read_seqretry(&state->seqlock, seq)) in nfs4_sync_open_stateid()
3358 struct nfs4_state *state) in nfs4_refresh_open_old_stateid() argument
3367 if (!nfs4_valid_open_stateid(state)) in nfs4_refresh_open_old_stateid()
3369 seq = read_seqbegin(&state->seqlock); in nfs4_refresh_open_old_stateid()
3370 if (!nfs4_state_match_open_stateid_other(state, dst)) { in nfs4_refresh_open_old_stateid()
3371 if (read_seqretry(&state->seqlock, seq)) in nfs4_refresh_open_old_stateid()
3375 seqid_open = state->open_stateid.seqid; in nfs4_refresh_open_old_stateid()
3376 if (read_seqretry(&state->seqlock, seq)) in nfs4_refresh_open_old_stateid()
3393 struct nfs4_state *state; member
3410 struct nfs4_state_owner *sp = calldata->state->owner; in nfs4_free_closedata()
3411 struct super_block *sb = calldata->state->inode->i_sb; in nfs4_free_closedata()
3416 nfs4_put_open_state(calldata->state); in nfs4_free_closedata()
3426 struct nfs4_state *state = calldata->state; in nfs4_close_done() local
3430 .state = state, in nfs4_close_done()
3438 trace_nfs4_close(state, &calldata->arg, &calldata->res, task->tk_status); in nfs4_close_done()
3466 state)) in nfs4_close_done()
3486 nfs_clear_open_stateid(state, &calldata->arg.stateid, in nfs4_close_done()
3503 struct nfs4_state *state = calldata->state; in nfs4_close_prepare() local
3514 spin_lock(&state->owner->so_lock); in nfs4_close_prepare()
3515 is_rdwr = test_bit(NFS_O_RDWR_STATE, &state->flags); in nfs4_close_prepare()
3516 is_rdonly = test_bit(NFS_O_RDONLY_STATE, &state->flags); in nfs4_close_prepare()
3517 is_wronly = test_bit(NFS_O_WRONLY_STATE, &state->flags); in nfs4_close_prepare()
3520 if (state->n_rdwr == 0) { in nfs4_close_prepare()
3521 if (state->n_rdonly == 0) in nfs4_close_prepare()
3525 if (state->n_wronly == 0) in nfs4_close_prepare()
3534 nfs4_sync_open_stateid(&calldata->arg.stateid, state); in nfs4_close_prepare()
3535 if (!nfs4_valid_open_stateid(state)) in nfs4_close_prepare()
3537 spin_unlock(&state->owner->so_lock); in nfs4_close_prepare()
3605 int nfs4_do_close(struct nfs4_state *state, gfp_t gfp_mask, int wait) in nfs4_do_close() argument
3607 struct nfs_server *server = NFS_SERVER(state->inode); in nfs4_do_close()
3610 struct nfs4_state_owner *sp = state->owner; in nfs4_do_close()
3614 .rpc_cred = state->owner->so_cred, in nfs4_do_close()
3632 calldata->inode = state->inode; in nfs4_do_close()
3633 calldata->state = state; in nfs4_do_close()
3634 calldata->arg.fh = NFS_FH(state->inode); in nfs4_do_close()
3635 if (!nfs4_copy_open_stateid(&calldata->arg.stateid, state)) in nfs4_do_close()
3639 calldata->arg.seqid = alloc_seqid(&state->owner->so_seqid, gfp_mask); in nfs4_do_close()
3649 calldata->lr.roc = pnfs_roc(state->inode, in nfs4_do_close()
3671 nfs4_put_open_state(state); in nfs4_do_close()
3680 struct nfs4_state *state; in nfs4_atomic_open() local
3686 state = nfs4_do_open(dir, ctx, open_flags, attr, label, opened); in nfs4_atomic_open()
3690 if (IS_ERR(state)) in nfs4_atomic_open()
3691 return ERR_CAST(state); in nfs4_atomic_open()
3692 return state->inode; in nfs4_atomic_open()
3697 if (ctx->state == NULL) in nfs4_close_context()
3700 nfs4_close_sync(ctx->state, _nfs4_ctx_to_openmode(ctx)); in nfs4_close_context()
3702 nfs4_close_state(ctx->state, _nfs4_ctx_to_openmode(ctx)); in nfs4_close_context()
4438 struct nfs4_state *state; in nfs4_proc_create() local
4449 state = nfs4_do_open(dir, ctx, flags, sattr, ilabel, NULL); in nfs4_proc_create()
4450 if (IS_ERR(state)) { in nfs4_proc_create()
4451 status = PTR_ERR(state); in nfs4_proc_create()
5101 return nfs4_select_rw_stateid(ctx->state, fmode, l_ctx, stateid, NULL); in nfs4_set_rw_stateid()
5141 .state = hdr->args.context->state, in nfs4_read_done_cb()
5222 .state = hdr->args.context->state, in nfs4_write_done_cb()
6364 static int _nfs4_proc_getlk(struct nfs4_state *state, int cmd, struct file_lock *request) in _nfs4_proc_getlk() argument
6366 struct inode *inode = state->inode; in _nfs4_proc_getlk()
6380 .rpc_cred = state->owner->so_cred, in _nfs4_proc_getlk()
6386 status = nfs4_set_lock_state(state, request); in _nfs4_proc_getlk()
6406 static int nfs4_proc_getlk(struct nfs4_state *state, int cmd, struct file_lock *request) in nfs4_proc_getlk() argument
6414 err = _nfs4_proc_getlk(state, cmd, request); in nfs4_proc_getlk()
6415 trace_nfs4_get_lock(request, state, cmd, err); in nfs4_proc_getlk()
6416 err = nfs4_handle_exception(NFS_SERVER(state->inode), err, in nfs4_proc_getlk()
6429 struct nfs4_state *state = lsp->ls_state; in nfs4_refresh_lock_old_stateid() local
6432 spin_lock(&state->state_lock); in nfs4_refresh_lock_old_stateid()
6441 spin_unlock(&state->state_lock); in nfs4_refresh_lock_old_stateid()
6448 struct nfs4_state *state = lsp->ls_state; in nfs4_sync_lock_stateid() local
6451 spin_lock(&state->state_lock); in nfs4_sync_lock_stateid()
6454 spin_unlock(&state->state_lock); in nfs4_sync_lock_stateid()
6475 struct nfs4_state *state = lsp->ls_state; in nfs4_alloc_unlockdata() local
6476 struct inode *inode = state->inode; in nfs4_alloc_unlockdata()
6492 spin_lock(&state->state_lock); in nfs4_alloc_unlockdata()
6494 spin_unlock(&state->state_lock); in nfs4_alloc_unlockdata()
6627 static int nfs4_proc_unlck(struct nfs4_state *state, int cmd, struct file_lock *request) in nfs4_proc_unlck() argument
6629 struct inode *inode = state->inode; in nfs4_proc_unlck()
6630 struct nfs4_state_owner *sp = state->owner; in nfs4_proc_unlck()
6639 status = nfs4_set_lock_state(state, request); in nfs4_proc_unlck()
6672 trace_nfs4_unlock(request, state, F_SETLK, status); in nfs4_proc_unlck()
6730 struct nfs4_state *state = data->lsp->ls_state; in nfs4_lock_prepare() local
6741 &state->open_stateid); in nfs4_lock_prepare()
6749 if (!nfs4_valid_open_stateid(state)) { in nfs4_lock_prepare()
6861 static int _nfs4_do_setlk(struct nfs4_state *state, int cmd, struct file_lock *fl, int recovery_typ… in _nfs4_do_setlk() argument
6867 .rpc_cred = state->owner->so_cred, in _nfs4_do_setlk()
6870 .rpc_client = NFS_CLIENT(state->inode), in _nfs4_do_setlk()
6909 trace_nfs4_set_lock(fl, state, &data->res.stateid, cmd, ret); in _nfs4_do_setlk()
6913 static int nfs4_lock_reclaim(struct nfs4_state *state, struct file_lock *request) in nfs4_lock_reclaim() argument
6915 struct nfs_server *server = NFS_SERVER(state->inode); in nfs4_lock_reclaim()
6917 .inode = state->inode, in nfs4_lock_reclaim()
6923 if (test_bit(NFS_DELEGATED_STATE, &state->flags) != 0) in nfs4_lock_reclaim()
6925 err = _nfs4_do_setlk(state, F_SETLK, request, NFS_LOCK_RECLAIM); in nfs4_lock_reclaim()
6933 static int nfs4_lock_expired(struct nfs4_state *state, struct file_lock *request) in nfs4_lock_expired() argument
6935 struct nfs_server *server = NFS_SERVER(state->inode); in nfs4_lock_expired()
6937 .inode = state->inode, in nfs4_lock_expired()
6941 err = nfs4_set_lock_state(state, request); in nfs4_lock_expired()
6949 if (test_bit(NFS_DELEGATED_STATE, &state->flags) != 0) in nfs4_lock_expired()
6951 err = _nfs4_do_setlk(state, F_SETLK, request, NFS_LOCK_EXPIRED); in nfs4_lock_expired()
6966 static int nfs41_lock_expired(struct nfs4_state *state, struct file_lock *request) in nfs41_lock_expired() argument
6971 status = nfs4_set_lock_state(state, request); in nfs41_lock_expired()
6978 return nfs4_lock_expired(state, request); in nfs41_lock_expired()
6982 static int _nfs4_proc_setlk(struct nfs4_state *state, int cmd, struct file_lock *request) in _nfs4_proc_setlk() argument
6984 struct nfs_inode *nfsi = NFS_I(state->inode); in _nfs4_proc_setlk()
6985 struct nfs4_state_owner *sp = state->owner; in _nfs4_proc_setlk()
6990 status = locks_lock_inode_wait(state->inode, request); in _nfs4_proc_setlk()
6995 if (test_bit(NFS_DELEGATED_STATE, &state->flags)) { in _nfs4_proc_setlk()
6999 status = locks_lock_inode_wait(state->inode, request); in _nfs4_proc_setlk()
7006 status = _nfs4_do_setlk(state, cmd, request, NFS_LOCK_NEW); in _nfs4_proc_setlk()
7012 static int nfs4_proc_setlk(struct nfs4_state *state, int cmd, struct file_lock *request) in nfs4_proc_setlk() argument
7015 .state = state, in nfs4_proc_setlk()
7016 .inode = state->inode, in nfs4_proc_setlk()
7022 err = _nfs4_proc_setlk(state, cmd, request); in nfs4_proc_setlk()
7025 err = nfs4_handle_exception(NFS_SERVER(state->inode), in nfs4_proc_setlk()
7035 nfs4_retry_setlk_simple(struct nfs4_state *state, int cmd, in nfs4_retry_setlk_simple() argument
7042 status = nfs4_proc_setlk(state, cmd, request); in nfs4_retry_setlk_simple()
7091 nfs4_retry_setlk(struct nfs4_state *state, int cmd, struct file_lock *request) in nfs4_retry_setlk() argument
7095 struct nfs_server *server = NFS_SERVER(state->inode); in nfs4_retry_setlk()
7102 .inode = state->inode, in nfs4_retry_setlk()
7107 if (!test_bit(NFS_STATE_MAY_NOTIFY_LOCK, &state->flags)) in nfs4_retry_setlk()
7108 return nfs4_retry_setlk_simple(state, cmd, request); in nfs4_retry_setlk()
7116 status = nfs4_proc_setlk(state, cmd, request); in nfs4_retry_setlk()
7133 nfs4_retry_setlk(struct nfs4_state *state, int cmd, struct file_lock *request) in nfs4_retry_setlk() argument
7135 return nfs4_retry_setlk_simple(state, cmd, request); in nfs4_retry_setlk()
7143 struct nfs4_state *state; in nfs4_proc_lock() local
7148 state = ctx->state; in nfs4_proc_lock()
7151 if (state != NULL) in nfs4_proc_lock()
7152 return nfs4_proc_getlk(state, F_GETLK, request); in nfs4_proc_lock()
7160 if (state != NULL) in nfs4_proc_lock()
7161 return nfs4_proc_unlck(state, cmd, request); in nfs4_proc_lock()
7165 if (state == NULL) in nfs4_proc_lock()
7169 !test_bit(NFS_STATE_POSIX_LOCKS, &state->flags)) in nfs4_proc_lock()
7186 status = nfs4_set_lock_state(state, request); in nfs4_proc_lock()
7190 return nfs4_retry_setlk(state, cmd, request); in nfs4_proc_lock()
7193 int nfs4_lock_delegation_recall(struct file_lock *fl, struct nfs4_state *state, const nfs4_stateid … in nfs4_lock_delegation_recall() argument
7195 struct nfs_server *server = NFS_SERVER(state->inode); in nfs4_lock_delegation_recall()
7198 err = nfs4_set_lock_state(state, fl); in nfs4_lock_delegation_recall()
7201 err = _nfs4_do_setlk(state, F_SETLK, fl, NFS_LOCK_NEW); in nfs4_lock_delegation_recall()
7202 return nfs4_handle_delegation_recall_error(server, state, stateid, fl, err); in nfs4_lock_delegation_recall()
9050 exception->state = lgp->args.ctx->state; in nfs4_layoutget_handle_exception()