-
Notifications
You must be signed in to change notification settings - Fork 150
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Implement async Posix I/O and deferred file open.
- Loading branch information
Showing
23 changed files
with
1,456 additions
and
150 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,119 @@ | ||
| #ifndef __XRDPOSIXCACHEBC_HH__ | ||
| #define __XRDPOSIXCACHEBC_HH__ | ||
| /******************************************************************************/ | ||
| /* */ | ||
| /* X r d P o s i x C a c h e B C . h h */ | ||
| /* */ | ||
| /* (c) 2016 by the Board of Trustees of the Leland Stanford, Jr., University */ | ||
| /* All Rights Reserved */ | ||
| /* Produced by Andrew Hanushevsky for Stanford University under contract */ | ||
| /* DE-AC02-76-SFO0515 with the Department of Energy */ | ||
| /* */ | ||
| /* This file is part of the XRootD software suite. */ | ||
| /* */ | ||
| /* XRootD is free software: you can redistribute it and/or modify it under */ | ||
| /* the terms of the GNU Lesser General Public License as published by the */ | ||
| /* Free Software Foundation, either version 3 of the License, or (at your */ | ||
| /* option) any later version. */ | ||
| /* */ | ||
| /* XRootD is distributed in the hope that it will be useful, but WITHOUT */ | ||
| /* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or */ | ||
| /* FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public */ | ||
| /* License for more details. */ | ||
| /* */ | ||
| /* You should have received a copy of the GNU Lesser General Public License */ | ||
| /* along with XRootD in a file called COPYING.LESSER (LGPL license) and file */ | ||
| /* COPYING (GPL license). If not, see <http://www.gnu.org/licenses/>. */ | ||
| /* */ | ||
| /* The copyright holder's institutional names and contributor's names may not */ | ||
| /* be used to endorse or promote products derived from this software without */ | ||
| /* specific prior written permission of the institution or contributor. */ | ||
| /******************************************************************************/ | ||
|
|
||
| #include "XrdOuc/XrdOucCache2.hh" | ||
|
|
||
| /******************************************************************************/ | ||
| /* X r d P o s i x C a c h e B C I O */ | ||
| /******************************************************************************/ | ||
|
|
||
| class XrdPosixCacheBCIO : public XrdOucCacheIO2 | ||
| { | ||
| public: | ||
|
|
||
| virtual | ||
| XrdOucCacheIO2 *Base() {return cacheIO2;} | ||
|
|
||
| virtual | ||
| XrdOucCacheIO2 *Detach() {XrdOucCacheIO2 *theCIO = cacheIO2; | ||
| cacheIO1->Detach(); | ||
| delete this; | ||
| return theCIO; | ||
| } | ||
|
|
||
| virtual | ||
| long long FSize() {return cacheIO1->FSize();} | ||
|
|
||
| virtual | ||
| const char *Path() {return cacheIO1->Path();} | ||
|
|
||
| virtual int Read (char *Buffer, long long Offset, int Length) | ||
| {return cacheIO1->Read(Buffer, Offset, Length);} | ||
|
|
||
| virtual int ReadV(const XrdOucIOVec *readV, int n) | ||
| {return cacheIO1->ReadV(readV, n);} | ||
|
|
||
| virtual int Sync() {return cacheIO1->Sync();} | ||
|
|
||
| virtual int Trunc(long long Offset) {return cacheIO1->Trunc(Offset);} | ||
|
|
||
| virtual int Write(char *Buffer, long long Offset, int Length) | ||
| {return cacheIO1->Write(Buffer, Offset, Length);} | ||
|
|
||
| virtual bool ioActive() { return cacheIO1->ioActive();} | ||
|
|
||
| virtual void Preread (long long Offset, int Length, int Opts=0) | ||
| {return cacheIO1->Preread(Offset, Length, Opts);} | ||
|
|
||
| virtual void Preread(aprParms &Parms) { cacheIO1->Preread(Parms);} | ||
|
|
||
| XrdPosixCacheBCIO(XrdOucCacheIO *urCIO, XrdOucCacheIO2 *myCIO) | ||
| : cacheIO1(urCIO), cacheIO2(myCIO) {} | ||
| virtual ~XrdPosixCacheBCIO() {} | ||
|
|
||
| private: | ||
| XrdOucCacheIO *cacheIO1; | ||
| XrdOucCacheIO2 *cacheIO2; | ||
| }; | ||
|
|
||
| /******************************************************************************/ | ||
| /* X r d P o s i x C a c h e B C */ | ||
| /******************************************************************************/ | ||
|
|
||
| class XrdPosixCacheBC : public XrdOucCache2 | ||
| { | ||
| public: | ||
| virtual | ||
| XrdOucCacheIO2 *Attach(XrdOucCacheIO2 *ioP, int opts=0) | ||
| {XrdOucCacheIO *newIOP = v1Cache->Attach(ioP, opts); | ||
| if (newIOP == (XrdOucCacheIO *)newIOP) return ioP; | ||
| return new XrdPosixCacheBCIO(newIOP, ioP); | ||
| } | ||
|
|
||
| virtual int isAttached() {return v1Cache->isAttached();} | ||
|
|
||
| virtual int Rmdir(const char* path) {return v1Cache->Rmdir(path);} | ||
|
|
||
| virtual int Rename(const char* pathO, const char* pathN) | ||
| {return v1Cache->Rename(pathO, pathN);} | ||
|
|
||
| virtual int Truncate(const char* path, off_t size) | ||
| {return v1Cache->Truncate(path, size);} | ||
|
|
||
| virtual int Unlink(const char* path) {return v1Cache->Unlink(path);} | ||
|
|
||
| XrdPosixCacheBC(XrdOucCache *cP) : v1Cache(cP) {} | ||
| virtual ~XrdPosixCacheBC() {} | ||
| private: | ||
| XrdOucCache *v1Cache; | ||
| }; | ||
| #endif |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,53 @@ | ||
| /******************************************************************************/ | ||
| /* */ | ||
| /* X r d P o s i x C a l l B a c k . c c */ | ||
| /* */ | ||
| /* (c) 2016 by the Board of Trustees of the Leland Stanford, Jr., University */ | ||
| /* All Rights Reserved */ | ||
| /* Produced by Andrew Hanushevsky for Stanford University under contract */ | ||
| /* DE-AC02-76-SFO0515 with the Department of Energy */ | ||
| /* */ | ||
| /* This file is part of the XRootD software suite. */ | ||
| /* */ | ||
| /* XRootD is free software: you can redistribute it and/or modify it under */ | ||
| /* the terms of the GNU Lesser General Public License as published by the */ | ||
| /* Free Software Foundation, either version 3 of the License, or (at your */ | ||
| /* option) any later version. */ | ||
| /* */ | ||
| /* XRootD is distributed in the hope that it will be useful, but WITHOUT */ | ||
| /* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or */ | ||
| /* FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public */ | ||
| /* License for more details. */ | ||
| /* */ | ||
| /* You should have received a copy of the GNU Lesser General Public License */ | ||
| /* along with XRootD in a file called COPYING.LESSER (LGPL license) and file */ | ||
| /* COPYING (GPL license). If not, see <http://www.gnu.org/licenses/>. */ | ||
| /* */ | ||
| /* The copyright holder's institutional names and contributor's names may not */ | ||
| /* be used to endorse or promote products derived from this software without */ | ||
| /* specific prior written permission of the institution or contributor. */ | ||
| /******************************************************************************/ | ||
|
|
||
| #include <errno.h> | ||
|
|
||
| #include "XrdPosix/XrdPosixCallBack.hh" | ||
| #include "XrdPosix/XrdPosixFile.hh" | ||
|
|
||
| /******************************************************************************/ | ||
| /* D o n e */ | ||
| /******************************************************************************/ | ||
|
|
||
| void XrdPosixCallBackIO::Done(int result) | ||
| { | ||
| // Unreference the file so that the callback is able to close it. | ||
| // | ||
| theFile->unRef(); | ||
|
|
||
| // Diagnose the problem here, if there is a problem | ||
| // | ||
| if (result < 0) {errno = -result; result = -1;} | ||
|
|
||
| // Invoke the callback | ||
| // | ||
| Complete((ssize_t)result); | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.