#define DEBUG_SUBSYSTEM S_FILTER
-#ifndef AUTOCONF_INCLUDED
-#include <linux/config.h>
-#endif
#include <linux/module.h>
#include <linux/pagemap.h> // XXX kill me soon
#include <linux/version.h>
if (exp->exp_nid_stats && exp->exp_nid_stats->nid_stats)
lprocfs_counter_add(exp->exp_nid_stats->nid_stats,
LPROC_FILTER_READ_BYTES, tot_bytes);
-
+ filter_counter_incr(exp, LPROC_FILTER_STATS_READ,
+ oti ? oti->oti_jobid : NULL, tot_bytes);
EXIT;
cleanup:
if (tmp)
bytes += blocksize - tmp;
+ lnb[n].rc = 0;
if ((lnb[n].flags & OBD_BRW_FROM_GRANT) &&
(oa->o_valid & OBD_MD_FLGRANT)) {
if (resend) {
obd_size left;
unsigned long now = jiffies, timediff;
int rc = 0, i, tot_bytes = 0, cleanup_phase = 0, localreq = 0;
+ int retries = 0;
ENTRY;
LASSERT(objcount == 1);
LASSERT(obj->ioo_bufcnt > 0);
noa->o_valid = OBD_MD_FLID;
}
- if (filter_create(exp, noa, NULL, oti) == 0) {
+ if (filter_create(NULL, exp, noa, NULL, oti) == 0) {
f_dput(dentry);
dentry = filter_fid2dentry(exp->exp_obd, NULL,
obj->ioo_seq,
* already exist so we can store the reservation handle there. */
fmd = filter_fmd_find(exp, obj->ioo_id, obj->ioo_seq);
- LASSERT(oa != NULL);
- cfs_spin_lock(&obd->obd_osfs_lock);
- filter_grant_incoming(exp, oa);
- if (fmd && fmd->fmd_mactime_xid > oti->oti_xid)
- oa->o_valid &= ~(OBD_MD_FLMTIME | OBD_MD_FLCTIME |
- OBD_MD_FLATIME);
- else
- obdo_to_inode(dentry->d_inode, oa, OBD_MD_FLATIME |
- OBD_MD_FLMTIME | OBD_MD_FLCTIME);
- cleanup_phase = 3;
-
- left = filter_grant_space_left(exp);
-
- fso.fso_dentry = dentry;
- fso.fso_bufcnt = *npages;
-
- rc = filter_grant_check(exp, oa, objcount, &fso, *npages, res,
- &left, dentry->d_inode);
-
- /* do not zero out oa->o_valid as it is used in filter_commitrw_write()
- * for setting UID/GID and fid EA in first write time. */
- /* If OBD_FL_SHRINK_GRANT is set, the client just returned us some grant
- * so no sense in allocating it some more. We either return the grant
- * back to the client if we have plenty of space or we don't return
- * anything if we are short. This was decided in filter_grant_incoming*/
- if ((oa->o_valid & OBD_MD_FLGRANT) &&
- (!(oa->o_valid & OBD_MD_FLFLAGS) ||
- !(oa->o_flags & OBD_FL_SHRINK_GRANT)))
- oa->o_grant = filter_grant(exp, oa->o_grant, oa->o_undirty,
- left, 1);
-
- cfs_spin_unlock(&obd->obd_osfs_lock);
+ LASSERT(oa != NULL);
+retry:
+ cfs_spin_lock(&obd->obd_osfs_lock);
+ if (retries == 0)
+ filter_grant_incoming(exp, oa);
+ if (fmd && fmd->fmd_mactime_xid > oti->oti_xid)
+ oa->o_valid &= ~(OBD_MD_FLMTIME | OBD_MD_FLCTIME |
+ OBD_MD_FLATIME);
+ else
+ obdo_to_inode(dentry->d_inode, oa, OBD_MD_FLATIME |
+ OBD_MD_FLMTIME | OBD_MD_FLCTIME);
+ cleanup_phase = 3;
+
+ left = filter_grant_space_left(exp);
+
+ fso.fso_dentry = dentry;
+ fso.fso_bufcnt = *npages;
+
+ rc = filter_grant_check(exp, oa, objcount, &fso, *npages, res,
+ &left, dentry->d_inode);
+
+ /* do not zero out oa->o_valid as it is used in filter_commitrw_write()
+ * for setting UID/GID and fid EA in first write time. */
+ /* If OBD_FL_SHRINK_GRANT is set, the client just returned us some grant
+ * so no sense in allocating it some more. We either return the grant
+ * back to the client if we have plenty of space or we don't return
+ * anything if we are short. This was decided in filter_grant_incoming*/
+ if ((retries == 0) && (oa->o_valid & OBD_MD_FLGRANT) &&
+ (!(oa->o_valid & OBD_MD_FLFLAGS) ||
+ !(oa->o_flags & OBD_FL_SHRINK_GRANT)))
+ oa->o_grant = filter_grant(exp, oa->o_grant, oa->o_undirty,
+ left, 1);
+
+ cfs_spin_unlock(&obd->obd_osfs_lock);
+
+ if (rc == -ENOSPC && retries == 0) {
+ void *handle = NULL;
+
+ CDEBUG(D_INODE, "retry after commit pending journals");
+
+ retries = 1;
+ handle = fsfilt_start(obd, dentry->d_inode,
+ FSFILT_OP_SETATTR, NULL);
+ if (handle != NULL &&
+ fsfilt_commit(obd, dentry->d_inode, handle, 1) == 0)
+ goto retry;
+ }
+
filter_fmd_put(exp, fmd);
OBD_FAIL_TIMEOUT(OBD_FAIL_OST_BRW_PAUSE_BULK2, (obd_timeout + 1) / 4);
if (exp->exp_nid_stats && exp->exp_nid_stats->nid_stats)
lprocfs_counter_add(exp->exp_nid_stats->nid_stats,
LPROC_FILTER_WRITE_BYTES, tot_bytes);
+ filter_counter_incr(exp, LPROC_FILTER_STATS_WRITE,
+ oti ? oti->oti_jobid : NULL, tot_bytes);
EXIT;
cleanup:
switch(cleanup_phase) {
return rc;
}
-int filter_preprw(int cmd, struct obd_export *exp, struct obdo *oa,
- int objcount, struct obd_ioobj *obj,
+int filter_preprw(const struct lu_env *env, int cmd, struct obd_export *exp,
+ struct obdo *oa, int objcount, struct obd_ioobj *obj,
struct niobuf_remote *nb, int *npages,
struct niobuf_local *res, struct obd_trans_info *oti,
struct lustre_capa *capa)
cfs_spin_unlock(&exp->exp_obd->obd_osfs_lock);
}
-int filter_commitrw(int cmd, struct obd_export *exp, struct obdo *oa,
- int objcount, struct obd_ioobj *obj,
+int filter_commitrw(const struct lu_env *env, int cmd, struct obd_export *exp,
+ struct obdo *oa, int objcount, struct obd_ioobj *obj,
struct niobuf_remote *nb, int npages,
struct niobuf_local *res, struct obd_trans_info *oti,
int rc)
LBUG();
return -EPROTO;
}
-
git://git.whamcloud.com / fs / lustre-release.git / blobdiff