--- libaitio/src/aitio.c 2011/04/20 22:55:41 1.4.2.2 +++ libaitio/src/aitio.c 2011/12/13 02:23:08 1.8 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: aitio.c,v 1.4.2.2 2011/04/20 22:55:41 misho Exp $ +* $Id: aitio.c,v 1.8 2011/12/13 02:23:08 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -58,19 +58,22 @@ char io_Error[STRSIZ]; // io_GetErrno() Get error code of last operation -inline int io_GetErrno() +inline int +io_GetErrno() { return io_Errno; } // io_GetError() Get error text of last operation -inline const char *io_GetError() +inline const char * +io_GetError() { return io_Error; } // io_SetErr() Set error to variables for internal use!!! -inline void io_SetErr(int eno, char *estr, ...) +inline void +io_SetErr(int eno, char *estr, ...) { va_list lst; @@ -90,7 +93,8 @@ inline void io_SetErr(int eno, char *estr, ...) * @dataLen = Length of data * return: 0 EOF; -1 error:: can`t read; >0 count of readed chars */ -int ioPromptRead(int *h, const char *csPrompt, char * __restrict psData, int dataLen) +int +ioPromptRead(int *h, const char *csPrompt, char * __restrict psData, int dataLen) { int ok = 0; FILE *inp, *out; @@ -143,7 +147,8 @@ int ioPromptRead(int *h, const char *csPrompt, char * * @confirm = Confirm password, 0 - get password, !=0 Ask for confirmation * return: 0 EOF; -1 error:: can`t read; >0 count of readed chars */ -int ioPromptPassword(int *h, const char *csPrompt, char * __restrict psPass, int passLen, int confirm) +int +ioPromptPassword(int *h, const char *csPrompt, char * __restrict psPass, int passLen, int confirm) { int ret, ok = 0; FILE *inp, *out; @@ -227,7 +232,8 @@ next: * @endPos = Return end positions * return: NULL not match or error; !=NULL begin of matched data */ -const char *ioRegexVerify(const char *csRegex, const char *csData, int *startPos, int *endPos) +const char * +ioRegexVerify(const char *csRegex, const char *csData, int *startPos, int *endPos) { regex_t re; regmatch_t match; @@ -274,7 +280,8 @@ const char *ioRegexVerify(const char *csRegex, const c * @strLen = Length of string * return: 0 not match; >0 count of returned chars */ -int ioRegexGet(const char *csRegex, const char *csData, char * __restrict psString, int strLen) +int +ioRegexGet(const char *csRegex, const char *csData, char * __restrict psString, int strLen) { int sp, ep, len; const char *str; @@ -302,7 +309,8 @@ int ioRegexGet(const char *csRegex, const char *csData * @csNew = Data for replace * return: NULL not match or error; !=NULL allocated new string, must be free after use! */ -char *ioRegexReplace(const char *csRegex, const char *csData, const char *csNew) +char * +ioRegexReplace(const char *csRegex, const char *csData, const char *csNew) { int sp, ep, len; char *str = NULL; @@ -344,12 +352,12 @@ char *ioRegexReplace(const char *csRegex, const char * } /* - * ioVarAst() Function for evaluate string like asterisk variable "{text[:[-]#[:#]]}" + * ioStrAst() Function for evaluate string like asterisk variable "{text[:[-]#[:#]]}" * @csString = Input string * return: NULL error, !=NULL Allocated new string evaluated from input string, must be free() */ char * -ioVarAst(const char *csString) +ioStrAst(const char *csString) { char *ext, *str, *out = NULL; int e[2] = { 0 }; @@ -549,4 +557,172 @@ ioWatchDirLoop(const char *csDir, int (*callback)(cons close(d); close(kq); return n; +} + +/* + * ioCreatePIDFile() Create PID file + * @csName = PID filename + * @ifExists = !=0 if filename exists return error + * return: -1 error or 0 ok + */ +inline int +ioCreatePIDFile(const char *csName, int ifExists) +{ + int fd; + char str[STRSIZ] = { 0 }; + + if (!csName) + return -1; + + fd = open(csName, O_WRONLY | O_CREAT | (ifExists ? O_EXCL : 0), 0644); + if (fd == -1) { + LOGERR; + return -1; + } + snprintf(str, sizeof str, "%d", getpid()); + write(fd, str, strlen(str)); + close(fd); + return 0; +} + + +/* + * ioSendFile() AITNET sendfile() userland implementation, not dependant from OS + * @s = socket + * @csFile = file for send + * @sendLen = bytes to send, if 0 send all data + * @offset = start file offset + * @sndbuf = SO_SNDBUF value, if 0 use default + * return: 0 error, >0 ok, sended bytes + */ +size_t +ioSendFile(int s, const char *csFile, size_t sendLen, off_t offset, int sndbuf) +{ + void *addr; + int fd; + size_t len = 0; + register size_t off = 0; + + if (!csFile) + return 0; + + if (sndbuf) + if (setsockopt(s, SOL_SOCKET, SO_SNDBUF, &sndbuf, sizeof sndbuf) == -1) { + LOGERR; + return 0; + } + + fd = open(csFile, O_RDONLY); + if (fd == -1) { + LOGERR; + return 0; + } + if (!sendLen) { + sendLen = lseek(fd, 0, SEEK_END); + if (sendLen == -1) { + LOGERR; + close(fd); + return 0; + } + } + addr = mmap(NULL, sendLen, PROT_READ, MAP_SHARED, fd, offset); + if (addr == MAP_FAILED) { + LOGERR; + close(fd); + return 0; + } else + close(fd); + + while (off < sendLen && (len = write(s, addr + off, sendLen - off)) != -1) + off += len; + if (len == -1) { + LOGERR; + munmap(addr, sendLen); + return 0; + } else + len = off; + + if (len != sendLen) { + io_SetErr(ECANCELED, "Different sizes - request %u bytes, actually sended %u bytes\n", + sendLen, len); + len ^= len; + } + + munmap(addr, sendLen); + return len; +} + +/* + * ioRecvFile() Receive file from socket, fastest (zero-copy) way + * @s = socket + * @csFile = file for receive + * @recvLen = receive bytes + * @over = overwrite file if exists with mode like 0644 + * @rcvbuf = SO_RCVBUF value, if 0 use default + * return: 0 error, >0 ok, received bytes + */ +size_t +ioRecvFile(int s, const char *csFile, size_t recvLen, int over, int rcvbuf) +{ + void *addr; + int fd; + size_t len = 0; + register size_t off = 0; + struct pollfd pfd = { s, POLLIN | POLLPRI, 0 }; + + if (!csFile || !recvLen) + return 0; + if (!over && !access(csFile, F_OK)) + return 0; + + if (rcvbuf) + if (setsockopt(s, SOL_SOCKET, SO_RCVBUF, &rcvbuf, sizeof rcvbuf) == -1) { + LOGERR; + return 0; + } + + fd = open(csFile, O_WRONLY | O_CREAT | O_TRUNC, over); + if (fd == -1) { + LOGERR; + unlink(csFile); + return 0; + } + if (lseek(fd, recvLen - 1, SEEK_SET) == -1) { + LOGERR; + close(fd); + unlink(csFile); + return 0; + } + if (write(fd, "", 1) == -1) { + LOGERR; + close(fd); + unlink(csFile); + return 0; + } + addr = mmap(NULL, recvLen, PROT_WRITE, MAP_SHARED, fd, 0); + if (addr == MAP_FAILED) { + LOGERR; + close(fd); + unlink(csFile); + return 0; + } else + close(fd); + + while (off < recvLen && poll(&pfd, 1, RECV_TIMEOUT) != -1) + while (off < recvLen && (len = read(s, addr + off, recvLen - off)) != -1) + off += len; + if (len == -1) { + LOGERR; + munmap(addr, recvLen); + unlink(csFile); + return 0; + } else + len = off; + + if (len != recvLen) + io_SetErr(EAGAIN, "Different sizes - request %u bytes, actually received %u bytes\n", + recvLen, len); + + munmap(addr, recvLen); + return len; }