irods  4.2.8
About: iRODS (the integrated Rule Oriented Data System) is a distributed data-management system for creating data grids, digital libraries, persistent archives, and real-time data systems.
  Fossies Dox: irods-4.2.8.tar.gz  ("unofficial" and yet experimental doxygen-generated source code documentation)  

rcPortalOpr.h
Go to the documentation of this file.
1 
4 /* rcPortalOpr.h - header file for rcPortalOpr.c
5  */
6 
7 
8 
9 #ifndef RC_PORTAL_OPR_H__
10 #define RC_PORTAL_OPR_H__
11 
12 #include "rods.h"
13 #include "objInfo.h"
14 #include "dataObjInpOut.h"
15 #include "QUANTAnet_rbudpBase_c.h"
16 #include "QUANTAnet_rbudpSender_c.h"
17 #include "QUANTAnet_rbudpReceiver_c.h"
18 
19 #define MAX_PROGRESS_CNT 8
20 
21 typedef struct RcPortalTransferInp {
23  int destFd;
24  int srcFd;
25  int threadNum;
26  int status;
28  unsigned char shared_secret[ NAME_LEN ];
30 
31 typedef enum {
35 
36 #ifdef __cplusplus
37 extern "C" {
38 #endif
39 
40 int
42  int destFd, int srcFd, int threadNum );
43 int
45  char *locFilePath, char *objPath, rodsLong_t dataSize );
46 int
48  char *locFilePath, char *objPath, rodsLong_t dataSize );
49 void
51 void
53 int
54 rcvTranHeader( int sock, transferHeader_t *myHeader );
55 
56 int
57 sendTranHeader( int sock, int oprType, int flags, rodsLong_t offset,
58  rodsLong_t length );
59 int
60 fillBBufWithFile( rcComm_t *conn, bytesBuf_t *myBBuf, char *locFilePath,
61  rodsLong_t dataSize );
62 int
63 putFile( rcComm_t *conn, int l1descInx, char *locFilePath, char *objPath,
64  rodsLong_t dataSize );
65 int
66 getIncludeFile( rcComm_t *conn, bytesBuf_t *dataObjOutBBuf, char *locFilePath );
67 int
68 getFile( rcComm_t *conn, int l1descInx, char *locFilePath, char *objPath,
69  rodsLong_t dataSize );
70 int
72  char *locFilePath, int locFd,
73  int veryVerbose, int sendRate, int packetSize );
74 int
76  char *locFilePath, int locFd,
77  int veryVerbose, int packetSize );
78 int
79 initRbudpClient( rbudpBase_t *rbudpBase, portList_t *myPortList );
80 int
81 initFileRestart( rcComm_t *conn, char *fileName, char *objPath,
82  rodsLong_t fileSize, int numThr );
83 int
84 writeLfRestartFile( char *infoFile, fileRestartInfo_t *info );
85 int
86 readLfRestartFile( char *infoFile, fileRestartInfo_t **info );
87 int
88 clearLfRestartFile( fileRestart_t *fileRestart );
89 int
91 int
93 int
94 putSeg( rcComm_t *conn, rodsLong_t segSize, int localFd,
95  openedDataObjInp_t *dataObjWriteInp, bytesBuf_t *dataObjWriteInpBBuf,
96  int bufLen, int *writtenSinceUpdated, fileRestartInfo_t *info,
97  rodsLong_t *dataSegLen );
98 int
99 getSeg( rcComm_t *conn, rodsLong_t segSize, int localFd,
100  openedDataObjInp_t *dataObjReadInp, bytesBuf_t *dataObjReadInpBBuf,
101  int bufLen, int *writtenSinceUpdated, fileRestartInfo_t *info,
102  rodsLong_t *dataSegLen );
103 int
104 catDataObj( rcComm_t *conn, char *objPath );
105 #ifdef __cplusplus
106 }
107 #endif
108 #endif // RC_PORTAL_OPR_H__
OpenedDataObjInp
Definition: dataObjInpOut.h:104
rcComm_t
Definition: rcConnect.h:95
sendTranHeader
int sendTranHeader(int sock, int oprType, int flags, rodsLong_t offset, rodsLong_t length)
Definition: rcPortalOpr.cpp:36
putSeg
int putSeg(rcComm_t *conn, rodsLong_t segSize, int localFd, openedDataObjInp_t *dataObjWriteInp, bytesBuf_t *dataObjWriteInpBBuf, int bufLen, int *writtenSinceUpdated, fileRestartInfo_t *info, rodsLong_t *dataSegLen)
Definition: rcPortalOpr.cpp:1661
rcvTranHeader
int rcvTranHeader(int sock, transferHeader_t *myHeader)
Definition: rcPortalOpr.cpp:65
portalOprOut
Definition: dataObjInpOut.h:114
fillBBufWithFile
int fillBBufWithFile(rcComm_t *conn, bytesBuf_t *myBBuf, char *locFilePath, rodsLong_t dataSize)
Definition: rcPortalOpr.cpp:93
catDataObj
int catDataObj(rcComm_t *conn, char *objPath)
Definition: rcPortalOpr.cpp:1886
RcPortalTransferInp::bytesWritten
rodsLong_t bytesWritten
Definition: rcPortalOpr.h:27
readLfRestartFile
int readLfRestartFile(char *infoFile, fileRestartInfo_t **info)
Definition: rcPortalOpr.cpp:1475
getSeg
int getSeg(rcComm_t *conn, rodsLong_t segSize, int localFd, openedDataObjInp_t *dataObjReadInp, bytesBuf_t *dataObjReadInpBBuf, int bufLen, int *writtenSinceUpdated, fileRestartInfo_t *info, rodsLong_t *dataSegLen)
Definition: rcPortalOpr.cpp:1826
RBUDP_SERVER
@ RBUDP_SERVER
Definition: rcPortalOpr.h:33
RcPortalTransferInp::shared_secret
unsigned char shared_secret[64]
Definition: rcPortalOpr.h:28
putFileToPortal
int putFileToPortal(rcComm_t *conn, portalOprOut_t *portalOprOut, char *locFilePath, char *objPath, rodsLong_t dataSize)
Definition: rcPortalOpr.cpp:136
fileRestart_t
Definition: rcConnect.h:81
RcPortalTransferInp::conn
rcComm_t * conn
Definition: rcPortalOpr.h:22
initRbudpClient
int initRbudpClient(rbudpBase_t *rbudpBase, portList_t *myPortList)
Definition: rcPortalOpr.cpp:1352
getIncludeFile
int getIncludeFile(rcComm_t *conn, bytesBuf_t *dataObjOutBBuf, char *locFilePath)
Definition: rcPortalOpr.cpp:639
rbudpProcType_t
rbudpProcType_t
Definition: rcPortalOpr.h:31
dataObjInpOut.h
RcPortalTransferInp::status
int status
Definition: rcPortalOpr.h:26
rcPortalTransferInp_t
struct RcPortalTransferInp rcPortalTransferInp_t
TransferHeader
Definition: dataObjInpOut.h:208
rcPartialDataPut
void rcPartialDataPut(rcPortalTransferInp_t *myInput)
Definition: rcPortalOpr.cpp:291
writeLfRestartFile
int writeLfRestartFile(char *infoFile, fileRestartInfo_t *info)
Definition: rcPortalOpr.cpp:1435
lfRestartGetWithInfo
int lfRestartGetWithInfo(rcComm_t *conn, fileRestartInfo_t *info)
Definition: rcPortalOpr.cpp:1710
getFile
int getFile(rcComm_t *conn, int l1descInx, char *locFilePath, char *objPath, rodsLong_t dataSize)
Definition: rcPortalOpr.cpp:688
putFileToPortalRbudp
int putFileToPortalRbudp(portalOprOut_t *portalOprOut, char *locFilePath, int locFd, int veryVerbose, int sendRate, int packetSize)
Definition: rcPortalOpr.cpp:1210
getFileToPortalRbudp
int getFileToPortalRbudp(portalOprOut_t *portalOprOut, char *locFilePath, int locFd, int veryVerbose, int packetSize)
Definition: rcPortalOpr.cpp:1281
portList_t
Definition: dataObjInpOut.h:29
initFileRestart
int initFileRestart(rcComm_t *conn, char *fileName, char *objPath, rodsLong_t fileSize, int numThr)
Definition: rcPortalOpr.cpp:1409
putFile
int putFile(rcComm_t *conn, int l1descInx, char *locFilePath, char *objPath, rodsLong_t dataSize)
Definition: rcPortalOpr.cpp:528
fileRestartInfo_t
Definition: rcConnect.h:72
BytesBuf
Definition: rodsDef.h:197
objInfo.h
rcPartialDataGet
void rcPartialDataGet(rcPortalTransferInp_t *myInput)
Definition: rcPortalOpr.cpp:976
fillRcPortalTransferInp
int fillRcPortalTransferInp(rcComm_t *conn, rcPortalTransferInp_t *myInput, int destFd, int srcFd, int threadNum)
Definition: rcPortalOpr.cpp:274
RcPortalTransferInp
Definition: rcPortalOpr.h:21
RcPortalTransferInp::srcFd
int srcFd
Definition: rcPortalOpr.h:24
getFileFromPortal
int getFileFromPortal(rcComm_t *conn, portalOprOut_t *portalOprOut, char *locFilePath, char *objPath, rodsLong_t dataSize)
Definition: rcPortalOpr.cpp:833
NAME_LEN
#define NAME_LEN
Definition: rodsDef.h:55
RcPortalTransferInp::destFd
int destFd
Definition: rcPortalOpr.h:23
RcPortalTransferInp::threadNum
int threadNum
Definition: rcPortalOpr.h:25
rods.h
rodsLong_t
long long rodsLong_t
Definition: rodsType.h:32
clearLfRestartFile
int clearLfRestartFile(fileRestart_t *fileRestart)
Definition: rcPortalOpr.cpp:1535
lfRestartPutWithInfo
int lfRestartPutWithInfo(rcComm_t *conn, fileRestartInfo_t *info)
Definition: rcPortalOpr.cpp:1543
RBUDP_CLIENT
@ RBUDP_CLIENT
Definition: rcPortalOpr.h:32