28#include <XrdCl/XrdClURL.hh>
29#include <XrdCl/XrdClFile.hh>
30#include <XrdCl/XrdClXRootDResponses.hh>
31#include <XrdCl/XrdClDefaultEnv.hh>
32#include <XrdVersion.hh>
57 XrdCl::AnyObject *response)
override
99 XrdCl::AnyObject *response)
override
136 :
TFile((lurl ? lurl : url),
137 strstr(
mode,
"_WITHOUT_GLOBALREGISTRATION") != nullptr ?
"NET_WITHOUT_GLOBALREGISTRATION" :
"NET", title,
140 using namespace XrdCl;
145 if (!val.
IsNull()) XrdCl::DefaultEnv::SetLogLevel(val.
Data());
151 TUrl urlnoanchor(url);
153 fUrl =
new URL(std::string(urlnoanchor.
GetUrl()));
158 fUrl->SetProtocol(std::string(
"root"));
164 Error(
"Open",
"could not parse open mode %s",
mode);
186 status =
fFile->Open(
fUrl->GetURL(),
fMode, Access::None, handler);
187 if (!status.IsOK()) {
188 Error(
"Open",
"%s", status.ToStr().c_str());
196 if (!status.IsOK()) {
197#if XrdVNUMBER >= 40000
198 if( status.code == errRedirect )
199 fNewUrl = status.GetErrorMessage().c_str();
201 Error(
"Open",
"%s", status.ToStr().c_str());
203 Error(
"Open",
"%s", status.ToStr().c_str());
209 if( (
fMode & OpenFlags::New) || (
fMode & OpenFlags::Delete) ||
210 (
fMode & OpenFlags::Update) )
215 if( (
fMode & OpenFlags::New) || (
fMode & OpenFlags::Delete) )
240 using namespace XrdCl;
243 if (
gDebug > 1)
Info(
"Init",
"TFile::Init already called once");
279 using namespace XrdCl;
285 bool forceStat =
true;
286 if(
fMode == XrdCl::OpenFlags::Read )
290 if( !
fFile->Stat( forceStat, info ).IsOK() )
327 XrdCl::XRootDStatus status =
fFile->Close();
328 if (!status.IsOK()) {
329 Error(
"Close",
"%s", status.ToStr().c_str());
347 using namespace XrdCl;
349 OpenFlags::Flags
mode;
354 if (parseres<0 || (
mode != OpenFlags::Read &&
mode != OpenFlags::Update)) {
355 Error(
"ReOpen",
"mode must be either READ or UPDATE, not %s", modestr);
361 &&
fMode == OpenFlags::New)) {
365 XRootDStatus st =
fFile->Close();
367 Error(
"ReOpen",
"%s", st.ToStr().c_str());
375 Error(
"ReOpen",
"%s", st.ToStr().c_str());
404 using namespace XrdCl;
406 Info(
"ReadBuffer",
"offset: %lld length: %d", position,
length);
425 uint32_t bytesRead = 0;
428 Info(
"ReadBuffer",
"%s bytes read: %u", st.ToStr().c_str(), bytesRead);
431 Error(
"ReadBuffer",
"%s", st.ToStr().c_str());
436 Error(
"ReadBuffer",
"error reading all requested bytes, got %u of %d",
472 using namespace XrdCl;
478 std::vector<ChunkList> chunkLists;
480 std::vector<XRootDStatus*> *statuses;
482 Int_t totalBytes = 0;
490 for (
Int_t i = 0; i < nbuffs; i++)
494 for (
Int_t i = 0; i < nbuffs; ++i) {
504 for (j = 0; j < nsplit; ++j) {
515 chunks.push_back(ChunkInfo(position[i],
length[i],
cursor));
521 chunkLists.push_back(chunks);
522 chunks = ChunkList();
524 chunkLists.push_back(ChunkList(chunks.begin(),
526 chunks = ChunkList(chunks.begin() +
fReadvIovMax, chunks.end());
531 if( !chunks.empty() )
532 chunkLists.push_back(chunks);
537 statuses =
new std::vector<XRootDStatus*>(chunkLists.size());
540 std::vector<ChunkList>::iterator it;
541 for (it = chunkLists.begin(); it != chunkLists.end(); ++it)
545 status =
fFile->VectorRead(*it, 0, handler);
547 if (!status.IsOK()) {
548 Error(
"ReadBuffers",
"%s", status.ToStr().c_str());
554 for (it = chunkLists.begin(); it != chunkLists.end(); ++it) {
559 for (it = chunkLists.begin(); it != chunkLists.end(); ++it) {
560 XRootDStatus *st = statuses->at(it - chunkLists.begin());
563 Error(
"ReadBuffers",
"%s", st->ToStr().c_str());
564 for( ; it != chunkLists.end(); ++it )
566 st = statuses->at( it - chunkLists.begin() );
585 gPerfStats->FileReadEvent(
this, totalBytes, start);
605 using namespace XrdCl;
613 Info(
"WriteBuffer",
"file not writable");
628 Error(
"WriteBuffer",
"%s", st.ToStr().c_str());
649 Info(
"Flush",
"file not writable - do nothing");
657 XrdCl::XRootDStatus status =
fFile->Sync();
659 Error(
"Flush",
"%s", status.ToStr().c_str());
662 Info(
"Flush",
"XrdClient::Sync succeeded.");
688 XrdCl::OpenFlags::Flags &
mode,
691 using namespace XrdCl;
694 if (modestr ==
"NEW" || modestr ==
"CREATE")
mode = OpenFlags::New;
695 else if (modestr ==
"RECREATE")
mode = OpenFlags::Delete;
696 else if (modestr ==
"UPDATE")
mode = OpenFlags::Update;
697 else if (modestr ==
"READ")
mode = OpenFlags::Read;
703 mode = OpenFlags::Read;
715 Error(
"TNetXNGFile",
"Object is in 'zombie' state");
720 Error(
"TNetXNGFile",
"The remote file is not open");
733 using namespace XrdCl;
742#if XrdVNUMBER >= 40000
744 fFile->GetProperty(
"LastURL",lasturl);
748 if(lrl.GetProtocol().compare(
"file") == 0 &&
749 lrl.GetHostId().compare(
"localhost") == 0){
751 Info(
"GetVectorReadLimits",
"Local redirect, using default values");
755 std::string dataServerStr;
756 if( !
fFile->GetProperty(
"DataServer", dataServerStr ) )
758 URL dataServer(dataServerStr);
760 URL dataServer(
fFile->GetDataServer());
762 FileSystem
fs(dataServer);
765 arg.FromString(std::string(
"readv_ior_max readv_iov_max"));
767 XRootDStatus status =
fs.Query(QueryCode::Config, arg, response);
774 std::vector<TString> resps;
776 resps.push_back(token);
778 if (resps.size() != 2)
781 if (resps[0].IsDigit())
784 if (resps[1].IsDigit())
805 XrdCl::Env *env = XrdCl::DefaultEnv::GetEnv();
806 const char *cenv = 0;
811 || strlen(cenv) <= 0))
812 env->PutInt(
"ConnectionWindow", val.
Atoi());
816 || strlen(cenv) <= 0))
817 env->PutInt(
"RequestTimeout", val.
Atoi());
821 || strlen(cenv) <= 0))
822 env->PutInt(
"RequestTimeout", val.
Atoi());
824 val =
gEnv->
GetValue(
"NetXNG.SubStreamsPerChannel",
"");
826 || strlen(cenv) <= 0))
827 env->PutInt(
"SubStreamsPerChannel", val.
Atoi());
831 || strlen(cenv) <= 0))
832 env->PutInt(
"TimeoutResolution", val.
Atoi());
836 || strlen(cenv) <= 0))
837 env->PutInt(
"StreamErrorWindow", val.
Atoi());
841 || strlen(cenv) <= 0))
842 env->PutInt(
"RunForkHandler", val.
Atoi());
846 || strlen(cenv) <= 0))
847 env->PutInt(
"RedirectLimit", val.
Atoi());
851 || strlen(cenv) <= 0))
852 env->PutInt(
"WorkerThreads", val.
Atoi());
856 || strlen(cenv) <= 0))
857 env->PutInt(
"CPChunkSize", val.
Atoi());
861 || strlen(cenv) <= 0))
862 env->PutInt(
"CPParallelChunks", val.
Atoi());
866 || strlen(cenv) <= 0))
867 env->PutString(
"PollerPreference", val.
Data());
871 || strlen(cenv) <= 0))
872 env->PutString(
"ClientMonitor", val.
Data());
876 || strlen(cenv) <= 0))
877 env->PutString(
"ClientMonitorParam", val.
Data());
880 env->PutInt(
"MultiProtocol",
gEnv->
GetValue(
"TFile.CrossProtocolRedirects", 1));
930 || strlen(cenv) <= 0))
935 || strlen(cenv) <= 0))
940 || strlen(cenv) <= 0))
945 || strlen(cenv) <= 0))
950 || strlen(cenv) <= 0))
955 || strlen(cenv) <= 0))
RooAbsTestStatistic * create(const char *name, const char *title, RooAbsReal &real, RooAbsData &adata, const RooArgSet &projDeps, RooAbsTestStatistic::Configuration const &cfg) override
size_t size(const MatrixT &matrix)
retrieve the size of a square matrix
void Info(const char *location, const char *msgfmt,...)
Use this function for informational messages.
void Error(const char *location, const char *msgfmt,...)
Use this function in case an error occurred.
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t cursor
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char Int_t count const char ColorStruct_t color const char Pixmap_t Pixmap_t PictureAttributes_t attr const char char ret_data h unsigned char height h offset
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char Int_t count const char ColorStruct_t color const char Pixmap_t Pixmap_t PictureAttributes_t attr const char char ret_data h unsigned char height h length
Option_t Option_t TPoint TPoint const char mode
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize fs
TString ToUpper(const TString &s)
Return an upper-case version of str.
R__EXTERN TSystem * gSystem
R__EXTERN TVirtualMonitoringWriter * gMonitoringWriter
TArchiveMember * GetMember() const
Long64_t GetDecompressedSize() const
void HandleResponse(XrdCl::XRootDStatus *status, XrdCl::AnyObject *response) override
TAsyncOpenHandler(TNetXNGFile *file)
std::vector< XrdCl::XRootDStatus * > * fStatuses
TAsyncReadvHandler(std::vector< XrdCl::XRootDStatus * > *statuses, Int_t statusIndex, TSemaphore *semaphore)
void HandleResponse(XrdCl::XRootDStatus *status, XrdCl::AnyObject *response) override
virtual void SetOwner(Bool_t enable=kTRUE)
Set whether this collection is the owner (enable==true) of its content.
Bool_t fWritable
True if directory is writable.
virtual Int_t GetValue(const char *name, Int_t dflt) const
Returns the integer value for a resource.
A ROOT file is composed of a header, followed by consecutive data records (TKey instances) with a wel...
static std::atomic< Long64_t > fgBytesRead
Number of bytes read by all TFile objects.
Int_t fReadCalls
Number of read calls ( not counting the cache calls )
Long64_t fBytesRead
Number of bytes read from this file.
TArchiveFile * fArchive
!Archive file from which we read this file
TList * fOpenPhases
!Time info about open phases
Int_t WriteBufferViaCache(const char *buf, Int_t len)
Write buffer via cache.
Int_t ReadBufferViaCache(char *buf, Int_t len)
Read buffer via cache.
Long64_t fArchiveOffset
!Offset at which file starts in archive
virtual void Init(Bool_t create)
Initialize a TFile object.
Long64_t GetRelOffset() const
TString fOption
File options.
EAsyncOpenStatus
Asynchronous open request status.
Bool_t FlushWriteCache()
Flush the write cache if active.
Long64_t fBytesWrite
Number of bytes written to this file.
Bool_t fInitDone
!True if the file has been initialized
virtual void SetOffset(Long64_t offset, ERelativeTo pos=kBeg)
Set position from where to start reading.
Long64_t fOffset
!Seek offset cache
static std::atomic< Long64_t > fgBytesWrite
Number of bytes written by all TFile objects.
EAsyncOpenStatus fAsyncOpenStatus
!Status of an asynchronous open request
void Close(Option_t *option="") override
Close a file.
static std::atomic< Int_t > fgReadCalls
Number of bytes read from all TFile objects.
void Seek(Long64_t offset, ERelativeTo position=kBeg) override
Set the position within the file.
virtual void SetEnv()
Map ROOT and xrootd environment variables.
virtual Bool_t IsUseable() const
Check the file is open and isn't a zombie.
virtual void SetAsyncOpenStatus(EAsyncOpenStatus status)
Set the status of an asynchronous file open.
Bool_t ReadBuffer(char *buffer, Int_t length) override
Read a data chunk of the given size.
XrdCl::OpenFlags::Flags fMode
void Close(const Option_t *option="") override
Close the file.
Bool_t ReadBuffers(char *buffer, Long64_t *position, Int_t *length, Int_t nbuffs) override
Read scattered data chunks in one operation.
Int_t ParseOpenMode(Option_t *in, TString &modestr, XrdCl::OpenFlags::Flags &mode, Bool_t assumeRead)
Parse a file open mode given as a string into a canonically formatted output mode string and an integ...
void Flush() override
Synchronize a file's in-memory and on-disk states.
Bool_t WriteBuffer(const char *buffer, Int_t length) override
Write a data chunk.
Int_t ReOpen(Option_t *modestr) override
Reopen the file with the new access mode.
XrdSysCondVar * fInitCondVar
Long64_t GetSize() const override
Get the file size.
virtual ~TNetXNGFile()
Destructor.
void Init(Bool_t create) override
Initialize the file.
virtual Bool_t GetVectorReadLimits()
Find the server-specific readv config params.
Bool_t IsOpen() const override
Check if the file is open.
R__ALWAYS_INLINE Bool_t IsZombie() const
Int_t Post()
Increment the value of the semaphore.
Int_t Wait()
If the semaphore value is > 0 then decrement it and carry on, else block, waiting on the condition un...
Int_t Atoi() const
Return integer value of string.
const char * Data() const
TObjArray * Tokenize(const TString &delim) const
This function is used to isolate sequential tokens in a TString.
void Form(const char *fmt,...)
Formats a string using a printf style format descriptor.
virtual const char * Getenv(const char *env)
Get environment variable.
virtual void Setenv(const char *name, const char *value)
Set environment variable.
virtual const char * HomeDirectory(const char *userName=nullptr)
Return the user's home directory.
The TTimeStamp encapsulates seconds and ns since EPOCH.
This class represents a WWW compatible URL.
const char * GetUrl(Bool_t withDeflt=kFALSE) const
Return full URL.
void SetAnchor(const char *anchor)
virtual Bool_t SendFileOpenProgress(TFile *, TList *, const char *, Bool_t=kFALSE)
virtual Bool_t SendFileReadProgress(TFile *)