![]() |
XRootD
|
#include <sys/types.h>
#include <stdarg.h>
#include <dirent.h>
#include <XrdOuc/XrdOucEnv.hh>
#include <XrdSys/XrdSysXAttr.hh>
Go to the source code of this file.
Typedefs | |
typedef void() | AioCB(XrdSfsAio *, size_t) |
Functions | |
ssize_t | ceph_aio_read (int fd, XrdSfsAio *aiop, AioCB *cb) |
ssize_t | ceph_aio_write (int fd, XrdSfsAio *aiop, AioCB *cb) |
int | ceph_posix_close (int fd) |
int | ceph_posix_closedir (DIR *dirp) |
void | ceph_posix_disconnect_all () |
int | ceph_posix_fcntl (int fd, int cmd,...) |
ssize_t | ceph_posix_fgetxattr (int fd, const char *name, void *value, size_t size) |
int | ceph_posix_flistxattrs (int fd, XrdSysXAttr::AList **aPL, int getSz) |
void | ceph_posix_freexattrlist (XrdSysXAttr::AList *aPL) |
int | ceph_posix_fremovexattr (int fd, const char *name) |
int | ceph_posix_fsetxattr (int fd, const char *name, const void *value, size_t size, int flags) |
int | ceph_posix_fstat (int fd, struct stat *buf) |
int | ceph_posix_fsync (int fd) |
int | ceph_posix_ftruncate (int fd, unsigned long long size) |
ssize_t | ceph_posix_getxattr (XrdOucEnv *env, const char *path, const char *name, void *value, size_t size) |
int | ceph_posix_listxattrs (XrdOucEnv *env, const char *path, XrdSysXAttr::AList **aPL, int getSz) |
off_t | ceph_posix_lseek (int fd, off_t offset, int whence) |
off64_t | ceph_posix_lseek64 (int fd, off64_t offset, int whence) |
int | ceph_posix_open (XrdOucEnv *env, const char *pathname, int flags, mode_t mode) |
DIR * | ceph_posix_opendir (XrdOucEnv *env, const char *pathname) |
ssize_t | ceph_posix_pread (int fd, void *buf, size_t count, off64_t offset) |
ssize_t | ceph_posix_pwrite (int fd, const void *buf, size_t count, off64_t offset) |
ssize_t | ceph_posix_read (int fd, void *buf, size_t count) |
int | ceph_posix_readdir (DIR *dirp, char *buff, int blen) |
int | ceph_posix_removexattr (XrdOucEnv *env, const char *path, const char *name) |
void | ceph_posix_set_defaults (const char *value) |
void | ceph_posix_set_logfunc (void(*logfunc)(char *, va_list argp)) |
ssize_t | ceph_posix_setxattr (XrdOucEnv *env, const char *path, const char *name, const void *value, size_t size, int flags) |
int | ceph_posix_stat (XrdOucEnv *env, const char *pathname, struct stat *buf) |
int | ceph_posix_statfs (long long *totalSpace, long long *freeSpace) |
int | ceph_posix_truncate (XrdOucEnv *env, const char *pathname, unsigned long long size) |
int | ceph_posix_unlink (XrdOucEnv *env, const char *pathname) |
ssize_t | ceph_posix_write (int fd, const void *buf, size_t count) |
typedef void() AioCB(XrdSfsAio *, size_t) |
Definition at line 39 of file XrdCephPosix.hh.
Definition at line 953 of file XrdCephPosix.cc.
References aiocb::aio_nbytes, aiocb::aio_offset, CephFileRef::asyncRdStartCount, ceph_aio_read_complete(), checkAndCreateCluster(), CephFileRef::flags, getCephPoolIdxAndIncrease(), getFileRef(), getRadosStriper(), CephFile::name, XrdSfsAio::sfsAio, and CephFileRef::statsMutex.
Referenced by XrdCephOssFile::Read().
Definition at line 839 of file XrdCephPosix.cc.
References aiocb::aio_buf, aiocb::aio_nbytes, aiocb::aio_offset, CephFileRef::asyncWrStartCount, CephFileRef::bytesAsyncWritePending, ceph_aio_write_complete(), checkAndCreateCluster(), CephFileRef::flags, getCephPoolIdxAndIncrease(), getFileRef(), getRadosStriper(), if(), CephFileRef::lastAsyncSubmission, CephFile::name, XrdSfsAio::sfsAio, and CephFileRef::statsMutex.
Referenced by XrdCephOssFile::Write().
int ceph_posix_close | ( | int | fd | ) |
Definition at line 696 of file XrdCephPosix.cc.
References CephFileRef::asyncRdCompletionCount, CephFileRef::asyncRdStartCount, CephFileRef::asyncWrCompletionCount, CephFileRef::asyncWrStartCount, CephFileRef::bytesAsyncWritePending, CephFileRef::bytesWritten, deleteFileRef(), getFileRef(), CephFileRef::lastAsyncSubmission, logwrapper(), CephFileRef::longestAsyncWriteTime, CephFileRef::longestCallbackInvocation, CephFileRef::maxOffsetWritten, CephFile::name, CephFileRef::rdcount, CephFileRef::statsMutex, and CephFileRef::wrcount.
Referenced by XrdCephOssFile::Close().
int ceph_posix_closedir | ( | DIR * | dirp | ) |
Definition at line 1319 of file XrdCephPosix.cc.
Referenced by XrdCephOssDir::Close().
void ceph_posix_disconnect_all | ( | ) |
Definition at line 609 of file XrdCephPosix.cc.
References g_cluster, g_ioCtx, g_maxCephPoolIdx, g_radosStripers, and g_striper_mutex.
Referenced by XrdCephOss::~XrdCephOss().
int ceph_posix_fcntl | ( | int | fd, |
int | cmd, | ||
... | |||
) |
Definition at line 1058 of file XrdCephPosix.cc.
References getFileRef(), logwrapper(), and CephFileRef::mode.
ssize_t ceph_posix_fgetxattr | ( | int | fd, |
const char * | name, | ||
void * | value, | ||
size_t | size | ||
) |
Definition at line 1095 of file XrdCephPosix.cc.
References ceph_posix_internal_getxattr(), getFileRef(), and logwrapper().
Referenced by XrdCephXAttr::Get().
int ceph_posix_flistxattrs | ( | int | fd, |
XrdSysXAttr::AList ** | aPL, | ||
int | getSz | ||
) |
Definition at line 1207 of file XrdCephPosix.cc.
References ceph_posix_internal_listxattrs(), getFileRef(), and logwrapper().
Referenced by XrdCephXAttr::List().
void ceph_posix_freexattrlist | ( | XrdSysXAttr::AList * | aPL | ) |
Definition at line 1217 of file XrdCephPosix.cc.
References XrdSysXAttr::AList::Name, and XrdSysXAttr::AList::Next.
Referenced by XrdCephXAttr::Free().
int ceph_posix_fremovexattr | ( | int | fd, |
const char * | name | ||
) |
Definition at line 1158 of file XrdCephPosix.cc.
References ceph_posix_internal_removexattr(), getFileRef(), and logwrapper().
int ceph_posix_fsetxattr | ( | int | fd, |
const char * | name, | ||
const void * | value, | ||
size_t | size, | ||
int | flags | ||
) |
Definition at line 1128 of file XrdCephPosix.cc.
References ceph_posix_internal_setxattr(), getFileRef(), and logwrapper().
Referenced by XrdCephXAttr::Set().
int ceph_posix_fstat | ( | int | fd, |
struct stat * | buf | ||
) |
Definition at line 993 of file XrdCephPosix.cc.
References getFileRef(), getRadosStriper(), logwrapper(), and CephFile::name.
Referenced by XrdCephOssFile::Fstat().
int ceph_posix_fsync | ( | int | fd | ) |
Definition at line 1047 of file XrdCephPosix.cc.
References getFileRef(), and logwrapper().
Referenced by XrdCephOssFile::Fsync().
int ceph_posix_ftruncate | ( | int | fd, |
unsigned long long | size | ||
) |
Definition at line 1253 of file XrdCephPosix.cc.
References ceph_posix_internal_truncate(), getFileRef(), and logwrapper().
Referenced by XrdCephOssFile::Ftruncate().
ssize_t ceph_posix_getxattr | ( | XrdOucEnv * | env, |
const char * | path, | ||
const char * | name, | ||
void * | value, | ||
size_t | size | ||
) |
Definition at line 1088 of file XrdCephPosix.cc.
References ceph_posix_internal_getxattr(), getCephFile(), and logwrapper().
Referenced by XrdCephXAttr::Get().
int ceph_posix_listxattrs | ( | XrdOucEnv * | env, |
const char * | path, | ||
XrdSysXAttr::AList ** | aPL, | ||
int | getSz | ||
) |
Definition at line 1202 of file XrdCephPosix.cc.
References ceph_posix_internal_listxattrs(), getCephFile(), and logwrapper().
Referenced by XrdCephXAttr::List().
off_t ceph_posix_lseek | ( | int | fd, |
off_t | offset, | ||
int | whence | ||
) |
Definition at line 737 of file XrdCephPosix.cc.
References getFileRef(), logwrapper(), and lseek_compute_offset().
off64_t ceph_posix_lseek64 | ( | int | fd, |
off64_t | offset, | ||
int | whence | ||
) |
Definition at line 747 of file XrdCephPosix.cc.
References getFileRef(), logwrapper(), and lseek_compute_offset().
int ceph_posix_open | ( | XrdOucEnv * | env, |
const char * | pathname, | ||
int | flags, | ||
mode_t | mode | ||
) |
Definition at line 649 of file XrdCephPosix.cc.
References ceph_posix_unlink(), getCephFileRef(), getRadosStriper(), insertFileRef(), logwrapper(), CephFile::name, and stat().
Referenced by XrdCephOssFile::Open().
DIR* ceph_posix_opendir | ( | XrdOucEnv * | env, |
const char * | pathname | ||
) |
Definition at line 1281 of file XrdCephPosix.cc.
References getCephFile(), getIoCtx(), logwrapper(), DirIterator::m_ioctx, DirIterator::m_iterator, and CephFile::name.
Referenced by XrdCephOssDir::Opendir().
ssize_t ceph_posix_pread | ( | int | fd, |
void * | buf, | ||
size_t | count, | ||
off64_t | offset | ||
) |
Definition at line 908 of file XrdCephPosix.cc.
References CephFileRef::flags, getFileRef(), getRadosStriper(), CephFile::name, CephFileRef::rdcount, and CephFileRef::statsMutex.
Referenced by XrdCephOssFile::Read().
ssize_t ceph_posix_pwrite | ( | int | fd, |
const void * | buf, | ||
size_t | count, | ||
off64_t | offset | ||
) |
Definition at line 783 of file XrdCephPosix.cc.
References CephFileRef::bytesWritten, CephFileRef::flags, getFileRef(), getRadosStriper(), CephFileRef::maxOffsetWritten, CephFile::name, CephFileRef::statsMutex, and CephFileRef::wrcount.
Referenced by XrdCephOssFile::Write().
ssize_t ceph_posix_read | ( | int | fd, |
void * | buf, | ||
size_t | count | ||
) |
Definition at line 883 of file XrdCephPosix.cc.
References CephFileRef::flags, getFileRef(), getRadosStriper(), CephFile::name, CephFileRef::offset, CephFileRef::rdcount, and CephFileRef::statsMutex.
int ceph_posix_readdir | ( | DIR * | dirp, |
char * | buff, | ||
int | blen | ||
) |
Definition at line 1300 of file XrdCephPosix.cc.
Referenced by XrdCephOssDir::Readdir().
int ceph_posix_removexattr | ( | XrdOucEnv * | env, |
const char * | path, | ||
const char * | name | ||
) |
Definition at line 1152 of file XrdCephPosix.cc.
References ceph_posix_internal_removexattr(), getCephFile(), and logwrapper().
Referenced by XrdCephXAttr::Del().
void ceph_posix_set_defaults | ( | const char * | value | ) |
sets the default userId, pool and file layout syntax is [user@]pool[,nbStripes[,stripeUnit[,objectSize]]] may throw std::invalid_argument or std::out_of_range in case of error
Definition at line 386 of file XrdCephPosix.cc.
References fillCephFileParams(), and g_defaultParams.
Referenced by XrdOssGetStorageSystem(), and XrdSysGetXAttrObject().
void ceph_posix_set_logfunc | ( | void(*)(char *, va_list argp) | logfunc | ) |
Definition at line 629 of file XrdCephPosix.cc.
References g_logfunc.
Referenced by XrdOssGetStorageSystem().
ssize_t ceph_posix_setxattr | ( | XrdOucEnv * | env, |
const char * | path, | ||
const char * | name, | ||
const void * | value, | ||
size_t | size, | ||
int | flags | ||
) |
Definition at line 1121 of file XrdCephPosix.cc.
References ceph_posix_internal_setxattr(), getCephFile(), and logwrapper().
Referenced by XrdCephXAttr::Set().
Definition at line 1019 of file XrdCephPosix.cc.
References getCephFile(), getRadosStriper(), isOpenForWrite(), logwrapper(), and CephFile::name.
Referenced by XrdCephOss::Stat().
int ceph_posix_statfs | ( | long long * | totalSpace, |
long long * | freeSpace | ||
) |
Definition at line 1226 of file XrdCephPosix.cc.
References checkAndCreateCluster(), getCephPoolIdxAndIncrease(), and logwrapper().
Referenced by XrdCephOss::StatVS().
int ceph_posix_truncate | ( | XrdOucEnv * | env, |
const char * | pathname, | ||
unsigned long long | size | ||
) |
Definition at line 1263 of file XrdCephPosix.cc.
References ceph_posix_internal_truncate(), getCephFile(), and logwrapper().
Referenced by XrdCephOss::Truncate().
int ceph_posix_unlink | ( | XrdOucEnv * | env, |
const char * | pathname | ||
) |
Definition at line 1270 of file XrdCephPosix.cc.
References getCephFile(), getRadosStriper(), logwrapper(), and CephFile::name.
Referenced by ceph_posix_open(), and XrdCephOss::Unlink().
ssize_t ceph_posix_write | ( | int | fd, |
const void * | buf, | ||
size_t | count | ||
) |
Definition at line 757 of file XrdCephPosix.cc.
References CephFileRef::bytesWritten, CephFileRef::flags, getFileRef(), getRadosStriper(), logwrapper(), CephFileRef::maxOffsetWritten, CephFile::name, CephFileRef::offset, CephFileRef::statsMutex, and CephFileRef::wrcount.