X-Git-Url: https://code.citadel.org/?a=blobdiff_plain;f=libcitadel%2Flib%2Flibcitadel.h;h=4afcbde893b4ba8bfb889f523054d744fbc65e45;hb=97a1a0d3086fd9a7e52f05687eb039e6ef7a5c79;hp=ac102b1b25b41c1a1f65d9311bcba3b8c89e24d5;hpb=acb05ae4aa9d33cfd3ada9a94bfda79a9bd50639;p=citadel.git diff --git a/libcitadel/lib/libcitadel.h b/libcitadel/lib/libcitadel.h index ac102b1b2..4afcbde89 100644 --- a/libcitadel/lib/libcitadel.h +++ b/libcitadel/lib/libcitadel.h @@ -16,7 +16,7 @@ #include #include -#define LIBCITADEL_VERSION_NUMBER 800 +#define LIBCITADEL_VERSION_NUMBER 801 /* * Here's a bunch of stupid magic to make the MIME parser portable. @@ -236,6 +236,25 @@ typedef struct _file_buffer { int nBlobBytesWanted; } IOBuffer; + +typedef struct __fd_iobuffer { + IOBuffer *IOB; + int OtherFD; + int SplicePipe[2]; + long TotalSendSize; + long TotalSentAlready; + long ChunkSize; + long ChunkSendRemain; + StrBuf *ChunkBuffer; /* just used if we don't have sendfile */ +} FDIOBuffer; + + +void FDIOBufferInit(FDIOBuffer *FDB, IOBuffer *IO, int FD, long TotalSendSize); +void FDIOBufferDelete(FDIOBuffer *FDB); +int FileSendChunked(FDIOBuffer *FDB, const char **Err); +int FileRecvChunked(FDIOBuffer *FDB, const char **Err); +eReadState WriteIOBAlreadyRead(FDIOBuffer *FDB, const char **Error); + long StrBuf_read_one_chunk_callback (int fd, short event, IOBuffer *FB); int StrBuf_write_one_chunk_callback(int fd, short event, IOBuffer *FB); @@ -610,4 +629,8 @@ extern ConstStr RoomNetCfgStrs[maxRoomNetCfg]; /* Convenience function to "perform a function and cut a log record if result != 0" */ #define CtdlLogResult(x) if (x) syslog(LOG_CRIT, "%s:%d %s", __FILE__, __LINE__, strerror(errno)) +/* a nice consistent place to define how we turn a message id into a thread id hash */ +#define ThreadIdHash(Buf) abs(HashLittle(ChrPtr(Buf), StrLength(Buf))) + + #endif // LIBCITADEL_H