![]() |
XRootD
|
#include <chrono>
#include <stdio.h>
#include <string>
#include <fcntl.h>
#include <limits.h>
#include "XrdVersion.hh"
#include "XrdCeph/XrdCephOss.hh"
#include "XrdCeph/XrdCephOssDir.hh"
#include "XrdCeph/XrdCephOssFile.hh"
#include "XrdCeph/XrdCephPosix.hh"
#include "XrdCeph/XrdCephOssBufferedFile.hh"
#include "XrdCeph/XrdCephOssReadVFile.hh"
#include "XrdOuc/XrdOucEnv.hh"
#include "XrdSys/XrdSysError.hh"
#include "XrdSys/XrdSysPlatform.hh"
#include "XrdOuc/XrdOucTrace.hh"
#include "XrdOuc/XrdOucStream.hh"
#include "XrdOuc/XrdOucName2Name.hh"
#include "XrdOuc/XrdOucN2NLoader.hh"
Go to the source code of this file.
Functions | |
std::string | extractPool (std::string possPool) |
Extract a pool name (string before the first colon ':') from an object ID. More... | |
int | formatStatLSResponse (char *buff, int &blen, const char *cgroup, long long totalSpace, long long usedSpace, long long freeSpace, long long quota, long long maxFreeChunk) |
ssize_t | getNumericAttr (const char *const path, const char *attrName, const int maxAttrLen) |
Retrieve an integer-value extended attribute. More... | |
static void | logwrapper (char *format, va_list argp) |
void | m_translateFileName (std::string &physName, std::string logName) |
converts a logical filename to physical one if needed More... | |
static std::string | ts () |
timestamp output for logging messages More... | |
XrdOss * | XrdOssGetStorageSystem (XrdOss *native_oss, XrdSysLogger *lp, const char *config_fn, const char *parms) |
XrdVERSIONINFO (XrdOssGetStorageSystem, XrdCephOss) | |
Variables | |
unsigned int | g_cephAioWaitThresh |
char | g_logstring [1024] |
unsigned int | g_maxCephPoolIdx |
XrdOucName2Name * | g_namelib |
XrdSysError | XrdCephEroute (0) |
std::string extractPool | ( | std::string | possPool | ) |
Extract a pool name (string before the first colon ':') from an object ID.
(in) | possPool the object ID |
Implementation: Ian Johnson STFC RAL, ian.j, 2022 ohns on@st fc.a c.uk
Definition at line 421 of file XrdCephOss.cc.
Referenced by XrdCephOss::StatLS().
int formatStatLSResponse | ( | char * | buff, |
int & | blen, | ||
const char * | cgroup, | ||
long long | totalSpace, | ||
long long | usedSpace, | ||
long long | freeSpace, | ||
long long | quota, | ||
long long | maxFreeChunk | ||
) |
Definition at line 556 of file XrdCephOss.cc.
Referenced by XrdCephOss::StatLS().
ssize_t getNumericAttr | ( | const char *const | path, |
const char * | attrName, | ||
const int | maxAttrLen | ||
) |
Retrieve an integer-value extended attribute.
Get an integer numeric value from an extended attribute attached to an object
path | the object ID containing the attribute |
attrName | the name of the attribute to retrieve |
maxAttrLen | the largest number of characters to handle |
Implementation: Ian Johnson, ian.j, 2022 ohns on@st fc.a c.uk
Definition at line 104 of file XrdCephOss.cc.
References ceph_posix_getxattr().
Referenced by XrdCephOss::StatLS().
|
static |
Definition at line 62 of file XrdCephOss.cc.
References g_logstring, XrdSysError::Say(), ts(), and XrdCephEroute.
Referenced by bulkAioRead::bulkAioRead(), and XrdOssGetStorageSystem().
void m_translateFileName | ( | std::string & | physName, |
std::string | logName | ||
) |
converts a logical filename to physical one if needed
Definition at line 74 of file XrdCephOss.cc.
References g_namelib, XrdOucName2Name::lfn2pfn(), XrdSysError::Say(), and XrdCephEroute.
Referenced by XrdCephOss::Stat(), and XrdCephOss::StatLS().
|
static |
timestamp output for logging messages
Definition at line 53 of file XrdCephOss.cc.
Referenced by logwrapper(), XrdOucString::matches(), XrdCl::HttpFilePlugIn::Open(), XrdCephOssReadVFile::ReadV(), XrdScheduler::Reaper(), XrdCl::Log::Say(), and XrdSutParseTime().
XrdOss* XrdOssGetStorageSystem | ( | XrdOss * | native_oss, |
XrdSysLogger * | lp, | ||
const char * | config_fn, | ||
const char * | parms | ||
) |
Definition at line 134 of file XrdCephOss.cc.
References ceph_posix_set_defaults(), ceph_posix_set_logfunc(), XrdSysError::logger(), logwrapper(), XrdSysError::Say(), XrdSysError::SetPrefix(), and XrdCephEroute.
Referenced by XrdCephOss::Configure().
XrdVERSIONINFO | ( | XrdOssGetStorageSystem | , |
XrdCephOss | |||
) |
|
extern |
If aio read operation takes longer than this value, a warning will be issued
Definition at line 91 of file XrdCephPosix.cc.
Referenced by ceph_nonstriper_readv(), ceph_posix_nonstriper_pread(), and XrdCephOss::Configure().
char g_logstring[1024] |
Definition at line 61 of file XrdCephOss.cc.
Referenced by logwrapper().
|
extern |
size of the Striper/IoCtx pool, defaults to 1 may be overwritten in the configuration file (See XrdCephOss::configure)
Definition at line 95 of file XrdCephPosix.cc.
Referenced by ceph_posix_disconnect_all(), XrdCephOss::Configure(), and getCephPoolIdxAndIncrease().
|
extern |
pointer to library providing Name2Name interface. 0 be default populated in case of ceph.namelib entry in the config file used in XrdCephPosix
pointer to library providing Name2Name interface. 0 be default populated in case of ceph.namelib entry in the config file in XrdCephOss
Definition at line 98 of file XrdCephPosix.cc.
Referenced by XrdCephOss::Configure(), m_translateFileName(), and translateFileName().
XrdOucTrace XrdCephTrace & XrdCephEroute | ( | 0 | ) |
Definition at line 50 of file XrdCephOss.cc.
Referenced by logwrapper(), m_translateFileName(), XrdCephOss::Stat(), XrdCephOss::StatFS(), XrdCephOss::StatLS(), XrdCephOss::StatVS(), XrdCephOss::Truncate(), XrdCephOss::Unlink(), and XrdOssGetStorageSystem().