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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
|
/*
Copyright (C) 2003-2004 Douglas Thain and the University of Wisconsin
Copyright (C) 2005- The University of Notre Dame
This software is distributed under the GNU General Public License.
See the file COPYING for details.
*/
/** @file chirp_types.h
All of the structure and type definitions used by the Chirp API.
*/
#ifndef CHIRP_TYPES_H
#define CHIRP_TYPES_H
#include "chirp_protocol.h"
#include "buffer.h"
#include "int_sizes.h"
#include <fcntl.h>
#include <sys/types.h>
#include <inttypes.h>
#include <stdint.h>
#include <time.h>
/** Describes the properties of a file, much like the Unix <tt>stat</tt> structure.
Note that @ref cst_uid, @ref cst_gid, and @ref cst_mode are provided for backwards compatibility, but are
ignored by Chirp when enforcing access control. See @ref chirp_reli_setacl and @ref chirp_reli_getacl
for more information about enforcing access controls.
@see chirp_reli_stat, chirp_reli_lstat, chirp_reli_fstat, chirp_reli_open
*/
struct chirp_stat {
INT64_T cst_dev; /**< The device number on which the file is stored. */
INT64_T cst_ino; /**< The inode number of the file. */
INT64_T cst_mode; /**< The Unix mode bits of the file. */
INT64_T cst_nlink; /**< The number of hard links to this file. */
INT64_T cst_uid; /**< The Unix UID of the file's owner. */
INT64_T cst_gid; /**< The Unix GID of the file's group varship. */
INT64_T cst_rdev; /**< The device number, if this represents a device. */
INT64_T cst_size; /**< The size of the file, in bytes. */
INT64_T cst_blksize; /**< The recommended transfer block size for accessing this file. */
INT64_T cst_blocks; /**< The number of blocks consumed by this file in the file system. Note that this value has nothing to do with @ref cst_blksize. The size of the actual storage blocks is given by <tt>f_bsize</tt> in @ref chirp_statfs. */
INT64_T cst_atime; /**< The last time the file was accessed, in <tt>time_t</tt> format. */
INT64_T cst_mtime; /**< The last time the file data was modified, <tt>time_t</tt> format. */
INT64_T cst_ctime; /**< The last time the inode was changed, in <tt>time_t</tt> format. */
};
#define chirp_stat_encode(B, info) \
do {\
buffer_putfstring(B, "%" PRId64, (info)->cst_dev);\
buffer_putfstring(B, " %" PRId64, (info)->cst_ino);\
buffer_putfstring(B, " %" PRId64, (info)->cst_mode);\
buffer_putfstring(B, " %" PRId64, (info)->cst_nlink);\
buffer_putfstring(B, " %" PRId64, (info)->cst_uid);\
buffer_putfstring(B, " %" PRId64, (info)->cst_gid);\
buffer_putfstring(B, " %" PRId64, (info)->cst_rdev);\
buffer_putfstring(B, " %" PRId64, (info)->cst_size);\
buffer_putfstring(B, " %" PRId64, (info)->cst_blksize);\
buffer_putfstring(B, " %" PRId64, (info)->cst_blocks);\
buffer_putfstring(B, " %" PRId64, (info)->cst_atime);\
buffer_putfstring(B, " %" PRId64, (info)->cst_mtime);\
buffer_putfstring(B, " %" PRId64, (info)->cst_ctime);\
} while (0)
/** Describes the properties of a file system, much like the Unix <tt>statfs</tt> structure.
@see chirp_reli_statfs, chirp_reli_fstatfs
*/
struct chirp_statfs {
INT64_T f_type; /**< The integer type of the filesystem */
INT64_T f_blocks; /**< The total number of blocks in the filesystem. */
INT64_T f_bavail; /**< The number of blocks available to an ordinary user. */
INT64_T f_bsize; /**< The size in bytes of a block. */
INT64_T f_bfree; /**< The number of blocks free. */
INT64_T f_files; /**< The maximum number of files (inodes) on the filesystem. */
INT64_T f_ffree; /**< The number of files (inodes) currently in use. */
};
#define chirp_statfs_encode(B, info) \
do {\
buffer_putfstring(B, "%" PRId64, (info)->f_type);\
buffer_putfstring(B, " %" PRId64, (info)->f_bsize);\
buffer_putfstring(B, " %" PRId64, (info)->f_blocks);\
buffer_putfstring(B, " %" PRId64, (info)->f_bfree);\
buffer_putfstring(B, " %" PRId64, (info)->f_bavail);\
buffer_putfstring(B, " %" PRId64, (info)->f_files);\
buffer_putfstring(B, " %" PRId64, (info)->f_ffree);\
} while (0)
/** Describes a directory entry returned by @ref chirp_reli_readdir */
struct chirp_dirent {
char *name; /**< The name of the directory entry. */
int lstatus; /**< The result of lstat on the entry. */
struct chirp_stat info; /**< The properties of the directory entry. */
struct chirp_dirent *next;
};
/** Describes a result from a search operation */
struct chirp_searchent {
char path[CHIRP_PATH_MAX]; /**< Path of the matching file. */
struct chirp_stat info; /**< The properties of the matching file. */
int errsource;
int err;
};
/** Keeps track of the state of a search stream */
struct chirp_searchstream {
struct chirp_searchent entry;
const char *current;
buffer_t B;
};
#define CHIRP_SEARCH struct chirp_searchstream
/** Bit flags for the search operation */
#define CHIRP_SEARCH_STOPATFIRST (1<<0)
#define CHIRP_SEARCH_METADATA (1<<1)
#define CHIRP_SEARCH_INCLUDEROOT (1<<2)
#define CHIRP_SEARCH_PERIOD (1<<3)
#define CHIRP_SEARCH_R_OK (1<<4)
#define CHIRP_SEARCH_W_OK (1<<5)
#define CHIRP_SEARCH_X_OK (1<<6)
/** Streaming errors for the search operation */
#define CHIRP_SEARCH_ERR_OPEN 1
#define CHIRP_SEARCH_ERR_READ 2
#define CHIRP_SEARCH_ERR_CLOSE 3
#define CHIRP_SEARCH_ERR_STAT 4
/** Options for the search operation */
#define CHIRP_SEARCH_DELIMITER '|'
#define CHIRP_SEARCH_DEPTH_MAX 200
/** Describes the type of a bulk I/O operation. Used by @ref chirp_bulkio */
typedef enum {
CHIRP_BULKIO_PREAD, /**< Perform a chirp_reli_pread.*/
CHIRP_BULKIO_PWRITE, /**< Perform a chirp_reli_pwrite.*/
CHIRP_BULKIO_SREAD, /**< Perform a chirp_reli_sread.*/
CHIRP_BULKIO_SWRITE, /**< Perform a chirp_reli_swrite.*/
CHIRP_BULKIO_FSTAT, /**< Perform a chirp_reli_fstat.*/
CHIRP_BULKIO_FSYNC /**< Perform a chirp_reli_fsync.*/
} chirp_bulkio_t;
/** Describes a bulk I/O operation.
An array of chirp_bulkio structures passed to @ref chirp_reli_bulkio describes a list of multiple operatons to be performed simultaneously. Not all fields are relevant to all operations.
*/
struct chirp_bulkio {
chirp_bulkio_t type; /**< The type of I/O to perform. */
struct chirp_file *file; /**< The file to access for all operations. */
struct chirp_stat *info; /**< Pointer to a data buffer for FSTAT */
void *buffer; /**< Pointer to data buffer for PREAD, PWRITE, SREAD, and SWRITE */
INT64_T length; /**< Length of the data, in bytes, for PREAD, WRITE, SREAD, and SWRITE. */
INT64_T stride_length; /**< Length of each stride for SREAD and SWRITE. */
INT64_T stride_skip; /**< Distance between start of each stride for SREAD and SWRITE. */
INT64_T offset; /**< Starting offset in file for PREAD, PWRITE, SREAD, and SWRITE. */
INT64_T result; /**< On completion, contains result of operation. */
INT64_T errnum; /**< On failure, contains the errno for the call. */
};
/** Descibes the space consumed by a single user on a Chirp server.
@see chirp_reli_audit
*/
struct chirp_audit {
char name[CHIRP_PATH_MAX]; /**< The identity of the user. */
INT64_T nfiles; /**< The number of files owned by that user. */
INT64_T ndirs; /**< The number of directories owned by that user. */
INT64_T nbytes; /**< The total bytes consumed by that user. */
};
/** A callback function typedef used to display a directory or access control list.
A function matching this type is called by @ref chirp_reli_getdir
to display or otherwise act upon each line in a directory or access control list.
@param path The short name of the file, directory, or ACL to display.
@param arg A convenience pointer corresponding to the <tt>arg</tt> passed from @ref chirp_reli_getdir.
@see chirp_reli_getdir, chirp_reli_getacl
*/
typedef void (*chirp_dir_t) (const char *path, void *arg);
/** A callback function typedef used to display a detailed directory.
A function matching this type is called by @ref chirp_reli_getlongdir
to display or otherwise act upon each line in a directory listing.
@param path The short name of the file or directory to display.
@param info The details of the named file.
@param arg A convenience pointer corresponding to the <tt>arg</tt> passed from @ref chirp_reli_getlongdir.
@see chirp_reli_getlongdir
*/
typedef void (*chirp_longdir_t) (const char *path, struct chirp_stat * info, void *arg);
/** A callback function typedef used to display a file's location(s).
A function matching this type is called by @ref chirp_reli_locate
to display or otherwise act upon each location at which a given file is stored.
@param location The location of a file (usually hostname:local_path).
@param arg A convenience pointer corresponding to the <tt>arg</tt> passed from @ref chirp_reli_locate.
@see chirp_reli_locate
*/
typedef void (*chirp_loc_t) (const char *location, void *arg);
/** The type of Chirp job identifiers. It is a 64 bit unsigned integer.
*/
typedef int64_t chirp_jobid_t;
#define PRICHIRP_JOBID_T PRId64
#define SCNCHIRP_JOBID_T SCNd64
/** Maximum digest size for a supported hash function.
*/
#define CHIRP_DIGEST_MAX 128
#endif
/* vim: set noexpandtab tabstop=4: */
|