1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41#ifndef _OBJLAYOUT_H
42#define _OBJLAYOUT_H
43
44#include <linux/nfs_fs.h>
45#include <linux/pnfs_osd_xdr.h>
46#include "../pnfs.h"
47
48
49
50
51struct objlayout {
52 struct pnfs_layout_hdr pnfs_layout;
53
54
55 enum osd_delta_space_valid_enum {
56 OBJ_DSU_INIT = 0,
57 OBJ_DSU_VALID,
58 OBJ_DSU_INVALID,
59 } delta_space_valid;
60 s64 delta_space_used;
61
62
63 spinlock_t lock;
64 struct list_head err_list;
65};
66
67static inline struct objlayout *
68OBJLAYOUT(struct pnfs_layout_hdr *lo)
69{
70 return container_of(lo, struct objlayout, pnfs_layout);
71}
72
73
74
75
76
77struct objlayout_io_res {
78 struct objlayout *objlay;
79
80 void *rpcdata;
81 int status;
82 int committed;
83
84
85 struct list_head err_list;
86 unsigned num_comps;
87
88
89
90
91
92 struct pnfs_osd_ioerr *ioerrs;
93};
94
95static inline
96void objlayout_init_ioerrs(struct objlayout_io_res *oir, unsigned num_comps,
97 struct pnfs_osd_ioerr *ioerrs, void *rpcdata,
98 struct pnfs_layout_hdr *pnfs_layout_type)
99{
100 oir->objlay = OBJLAYOUT(pnfs_layout_type);
101 oir->rpcdata = rpcdata;
102 INIT_LIST_HEAD(&oir->err_list);
103 oir->num_comps = num_comps;
104 oir->ioerrs = ioerrs;
105}
106
107
108
109
110extern int objio_alloc_lseg(struct pnfs_layout_segment **outp,
111 struct pnfs_layout_hdr *pnfslay,
112 struct pnfs_layout_range *range,
113 struct xdr_stream *xdr,
114 gfp_t gfp_flags);
115extern void objio_free_lseg(struct pnfs_layout_segment *lseg);
116
117
118
119
120extern void objio_free_result(struct objlayout_io_res *oir);
121
122extern int objio_read_pagelist(struct nfs_read_data *rdata);
123extern int objio_write_pagelist(struct nfs_write_data *wdata, int how);
124
125
126
127
128extern void objlayout_io_set_result(struct objlayout_io_res *oir,
129 unsigned index, struct pnfs_osd_objid *pooid,
130 int osd_error, u64 offset, u64 length, bool is_write);
131
132static inline void
133objlayout_add_delta_space_used(struct objlayout *objlay, s64 space_used)
134{
135
136
137
138
139 spin_lock(&objlay->lock);
140 if (objlay->delta_space_valid != OBJ_DSU_INVALID) {
141 objlay->delta_space_valid = OBJ_DSU_VALID;
142 objlay->delta_space_used += space_used;
143 }
144 spin_unlock(&objlay->lock);
145}
146
147extern void objlayout_read_done(struct objlayout_io_res *oir,
148 ssize_t status, bool sync);
149extern void objlayout_write_done(struct objlayout_io_res *oir,
150 ssize_t status, bool sync);
151
152extern int objlayout_get_deviceinfo(struct pnfs_layout_hdr *pnfslay,
153 struct nfs4_deviceid *d_id, struct pnfs_osd_deviceaddr **deviceaddr,
154 gfp_t gfp_flags);
155extern void objlayout_put_deviceinfo(struct pnfs_osd_deviceaddr *deviceaddr);
156
157
158
159
160
161extern struct pnfs_layout_hdr *objlayout_alloc_layout_hdr(struct inode *, gfp_t gfp_flags);
162extern void objlayout_free_layout_hdr(struct pnfs_layout_hdr *);
163
164extern struct pnfs_layout_segment *objlayout_alloc_lseg(
165 struct pnfs_layout_hdr *,
166 struct nfs4_layoutget_res *,
167 gfp_t gfp_flags);
168extern void objlayout_free_lseg(struct pnfs_layout_segment *);
169
170extern enum pnfs_try_status objlayout_read_pagelist(
171 struct nfs_read_data *);
172
173extern enum pnfs_try_status objlayout_write_pagelist(
174 struct nfs_write_data *,
175 int how);
176
177extern void objlayout_encode_layoutcommit(
178 struct pnfs_layout_hdr *,
179 struct xdr_stream *,
180 const struct nfs4_layoutcommit_args *);
181
182extern void objlayout_encode_layoutreturn(
183 struct pnfs_layout_hdr *,
184 struct xdr_stream *,
185 const struct nfs4_layoutreturn_args *);
186
187extern int objlayout_autologin(struct pnfs_osd_deviceaddr *deviceaddr);
188
189#endif
190