29 #ifndef _XRD_CEPH_POSIX_H
30 #define _XRD_CEPH_POSIX_H
32 #include <sys/types.h>
44 #define XRDCEPHLOGLEVEL 1
45 #define MAXDIGITSIZE 32
46 #ifdef XRDCEPHLOGLEVEL
51 #define LOGCEPH(x) {std::stringstream _s; _s << x; std::clog << _s.str() << std::endl; _s.clear(); }
83 void* value,
size_t size);
86 const void* value,
size_t size,
int flags);
ssize_t ceph_posix_write(int fd, const void *buf, size_t count)
void ceph_posix_set_logfunc(void(*logfunc)(char *, va_list argp))
int ceph_posix_truncate(XrdOucEnv *env, const char *pathname, unsigned long long size)
ssize_t ceph_aio_write(int fd, XrdSfsAio *aiop, AioCB *cb)
int ceph_posix_unlink(XrdOucEnv *env, const char *pathname)
ssize_t ceph_aio_read(int fd, XrdSfsAio *aiop, AioCB *cb)
int ceph_posix_readdir(DIR *dirp, char *buff, int blen)
void() AioCB(XrdSfsAio *, size_t)
int ceph_posix_fcntl(int fd, int cmd,...)
ssize_t ceph_posix_getxattr(XrdOucEnv *env, const char *path, const char *name, void *value, size_t size)
DIR * ceph_posix_opendir(XrdOucEnv *env, const char *pathname)
ssize_t ceph_nonstriper_readv(int fd, XrdOucIOVec *readV, int n)
ssize_t ceph_posix_read(int fd, void *buf, size_t count)
ssize_t ceph_posix_pread(int fd, void *buf, size_t count, off64_t offset)
int ceph_posix_listxattrs(XrdOucEnv *env, const char *path, XrdSysXAttr::AList **aPL, int getSz)
int ceph_posix_fstat(int fd, struct stat *buf)
void ceph_posix_disconnect_all()
int ceph_posix_fsync(int fd)
int ceph_posix_closedir(DIR *dirp)
int ceph_posix_statfs(long long *totalSpace, long long *freeSpace)
int ceph_posix_fremovexattr(int fd, const char *name)
int ceph_posix_close(int fd)
int ceph_posix_stat_pool(char const *poolName, long long *usedSpace)
Return the amount of space used in a pool.
off_t ceph_posix_lseek(int fd, off_t offset, int whence)
void ceph_posix_set_defaults(const char *value)
int ceph_posix_fsetxattr(int fd, const char *name, const void *value, size_t size, int flags)
int ceph_posix_ftruncate(int fd, unsigned long long size)
int ceph_posix_open(XrdOucEnv *env, const char *pathname, int flags, mode_t mode)
ssize_t ceph_posix_nonstriper_pread(int fd, void *buf, size_t count, off64_t offset)
int ceph_posix_removexattr(XrdOucEnv *env, const char *path, const char *name)
off64_t ceph_posix_lseek64(int fd, off64_t offset, int whence)
ssize_t ceph_striper_readv(int fd, XrdOucIOVec *readV, int n)
int ceph_posix_stat(XrdOucEnv *env, const char *pathname, struct stat *buf)
ssize_t ceph_posix_pwrite(int fd, const void *buf, size_t count, off64_t offset)
ssize_t ceph_posix_setxattr(XrdOucEnv *env, const char *path, const char *name, const void *value, size_t size, int flags)
int ceph_posix_flistxattrs(int fd, XrdSysXAttr::AList **aPL, int getSz)
ssize_t ceph_posix_maybestriper_pread(int fd, void *buf, size_t count, off64_t offset, bool allowStriper=true)
ssize_t ceph_posix_fgetxattr(int fd, const char *name, void *value, size_t size)
void ceph_posix_freexattrlist(XrdSysXAttr::AList *aPL)
int stat(const char *path, struct stat *buf)
uint64_t bytesAsyncWritePending
unsigned asyncRdStartCount
unsigned asyncWrStartCount
uint64_t maxOffsetWritten
::timeval lastAsyncSubmission
double longestCallbackInvocation
double longestAsyncWriteTime
unsigned asyncWrCompletionCount
unsigned asyncRdCompletionCount
small structs to store file metadata
unsigned long long stripeUnit
unsigned long long objectSize