[BACK]Return to aitio.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / libaitio / src

Diff for /libaitio/src/aitio.c between versions 1.9 and 1.15

version 1.9, 2012/03/29 01:31:33 version 1.15, 2013/05/30 09:10:13
Line 12  terms: Line 12  terms:
 All of the documentation and software included in the ELWIX and AITNET  All of the documentation and software included in the ELWIX and AITNET
 Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org>  Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org>
   
Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012, 2013
         by Michael Pounov <misho@elwix.org>.  All rights reserved.          by Michael Pounov <misho@elwix.org>.  All rights reserved.
   
 Redistribution and use in source and binary forms, with or without  Redistribution and use in source and binary forms, with or without
Line 46  SUCH DAMAGE. Line 46  SUCH DAMAGE.
 #include "global.h"  #include "global.h"
   
   
 int io_Debug;  
   
   
 #pragma GCC visibility push(hidden)  #pragma GCC visibility push(hidden)
   
 int io_Errno;  int io_Errno;
Line 58  char io_Error[STRSIZ]; Line 55  char io_Error[STRSIZ];
   
   
 // io_GetErrno() Get error code of last operation  // io_GetErrno() Get error code of last operation
inline intint
 io_GetErrno()  io_GetErrno()
 {  {
         return io_Errno;          return io_Errno;
 }  }
   
 // io_GetError() Get error text of last operation  // io_GetError() Get error text of last operation
inline const char *const char *
 io_GetError()  io_GetError()
 {  {
         return io_Error;          return io_Error;
 }  }
   
 // io_SetErr() Set error to variables for internal use!!!  // io_SetErr() Set error to variables for internal use!!!
inline voidvoid
 io_SetErr(int eno, char *estr, ...)  io_SetErr(int eno, char *estr, ...)
 {  {
         va_list lst;          va_list lst;
   
         io_Errno = eno;          io_Errno = eno;
        memset(io_Error, 0, STRSIZ);        memset(io_Error, 0, sizeof io_Error);
         va_start(lst, estr);          va_start(lst, estr);
        vsnprintf(io_Error, STRSIZ, estr, lst);        vsnprintf(io_Error, sizeof io_Error, estr, lst);
         va_end(lst);          va_end(lst);
 }  }
   
   
 /*  /*
 * ioPromptRead() Read data from input h[0] with prompt to output h[1] * ioPromptRead() - Read data from input h[0] with prompt to output h[1]
  *   *
  * @h = file handles h[0] = input, h[1] = output, if NULL use stdin, stdout   * @h = file handles h[0] = input, h[1] = output, if NULL use stdin, stdout
  * @csPrompt = Prompt before input, may be NULL   * @csPrompt = Prompt before input, may be NULL
Line 140  ioPromptRead(int *h, const char *csPrompt, char * __re Line 137  ioPromptRead(int *h, const char *csPrompt, char * __re
 }  }
   
 /*  /*
 * ioPromptPassword() Read password from input h[0] with prompt to output h[1] * ioPromptPassword() - Read password from input h[0] with prompt to output h[1]
  *   *
  * @h = file handles h[0] = input, h[1] = output, if NULL use stdin, stdout   * @h = file handles h[0] = input, h[1] = output, if NULL use stdin, stdout
  * @csPrompt = Prompt before input, may be NULL   * @csPrompt = Prompt before input, may be NULL
Line 227  next: Line 224  next:
 }  }
   
 /*  /*
 * ioRegexVerify() Function for verify data match in regex expression * ioMkDir() - Function for racursive directory creation and validation
  *   *
  * @csRegex = Regulare expression pattern  
  * @csData = Data for check and verify  
  * @startPos = Return start positions  
  * @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)  
 {  
         regex_t re;  
         regmatch_t match;  
         char szErr[STRSIZ];  
         int ret, flg;  
         const char *pos;  
   
         if (!csRegex || !csData)  
                 return NULL;  
   
         if ((ret = regcomp(&re, csRegex, REG_EXTENDED))) {  
                 regerror(ret, &re, szErr, STRSIZ);  
                 io_SetErr(ret, "Error:: %s\n", szErr);  
                 regfree(&re);  
                 return NULL;  
         }  
   
         for (ret = flg = 0, pos = csData; !(ret = regexec(&re, pos, 1, &match, flg));   
                         pos += match.rm_eo, flg = REG_NOTBOL) {  
                 if (startPos)  
                         *startPos = match.rm_so;  
                 if (endPos)  
                         *endPos = match.rm_eo;  
   
                 pos += match.rm_so;  
                 break;  
         }  
   
         if (ret) {  
                 regerror(ret, &re, szErr, STRSIZ);  
                 io_SetErr(ret, "Error:: %s\n", szErr);  
                 pos = NULL;  
         }  
   
         regfree(&re);  
         return pos;  
 }  
   
 /*  
  * ioRegexGet() Function for get data match in regex expression  
  *  
  * @csRegex = Regulare expression pattern  
  * @csData = Data from get  
  * @psString = Returned string if match  
  * @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 sp, ep, len;  
         const char *str;  
   
         if (!csRegex || !csData)  
                 return -1;  
   
         str = ioRegexVerify(csRegex, csData, &sp, &ep);  
         if (!str)  
                 return 0;  
   
         len = ep - sp;  
         if (psString && strLen) {  
                 memset(psString, 0, strLen);  
                 strncpy(psString, str, strLen <= len ? strLen - 1 : len);  
         }  
   
         return len;  
 }  
   
 /*  
  * ioRegexReplace() Function for replace data match in regex expression with newdata  
  *  
  * @csRegex = Regulare expression pattern  
  * @csData = Source data  
  * @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)  
 {  
         int sp, ep, len;  
         char *str = NULL;  
   
         if (!csRegex || !csData)  
                 return NULL;  
   
         if (!ioRegexVerify(csRegex, csData, &sp, &ep))  
                 return NULL;  
   
         // ___ before match  
         len = sp + 1;  
         str = malloc(len);  
         if (!str) {  
                 LOGERR;  
                 return NULL;  
         } else  
                 strlcpy(str, csData, len);  
         // * replace match *  
         if (csNew) {  
                 len += strlen(csNew);  
                 str = realloc(str, len);  
                 if (!str) {  
                         LOGERR;  
                         return NULL;  
                 } else  
                         strlcat(str, csNew, len);  
         }  
         // after match ___  
         len += strlen(csData) - ep;  
         str = realloc(str, len);  
         if (!str) {  
                 LOGERR;  
                 return NULL;  
         } else  
                 strlcat(str, csData + ep, len);  
   
         return str;  
 }  
   
 /*  
  * 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 *  
 ioStrAst(const char *csString)  
 {  
         char *ext, *str, *out = NULL;  
         int e[2] = { 0 };  
   
         if (!csString)  
                 return NULL;  
   
         if (!strchr(csString, '{') || !strrchr(csString, '}')) {  
                 memset(io_Error, 0, STRSIZ);  
                 snprintf(io_Error, STRSIZ, "Error:: Invalid input string format ... "  
                                 "must be like {text[:[-]#[:#]]}");  
                 io_Errno = EINVAL;  
                 return NULL;  
         } else {  
                 str = strdup(strchr(csString, '{') + 1);  
                 *strrchr(str, '}') = 0;  
         }  
   
         if ((ext = strchr(str, ':'))) {  
                 *ext++ = 0;  
                 e[0] = strtol(ext, NULL, 0);  
                 if ((ext = strchr(ext, ':')))  
                         e[1] = strtol(++ext, NULL, 0);  
   
                 /* make cut prefix */  
                 if (e[0] >= 0)  
                         ext = str + e[0];  
                 else  
                         ext = str + strlen(str) + e[0];  
                 /* make cut suffix */  
                 if (e[1] > 0)  
                         *(ext + e[1]) = 0;  
         } else  
                 /* ok, clear show */  
                 ext = str;  
   
         out = strdup(ext);  
         free(str);  
   
         return out;  
 }  
   
   
 /*  
  * ioMkDir() Function for racursive directory creation and validation  
  *  
  * @csDir = Full directory path   * @csDir = Full directory path
  * @mode = Mode for directory creation if missing dir   * @mode = Mode for directory creation if missing dir
  * return: -1 error, 0 directory path exist, >0 created missing dirs   * return: -1 error, 0 directory path exist, >0 created missing dirs
Line 423  ioMkDir(const char *csDir, int mode) Line 239  ioMkDir(const char *csDir, int mode)
         if (!csDir)          if (!csDir)
                 return cx;                  return cx;
   
        str = strdup(csDir);        str = e_strdup(csDir);
         if (!str) {          if (!str) {
                 LOGERR;                  LOGERR;
                 return cx;                  return cx;
Line 451  ioMkDir(const char *csDir, int mode) Line 267  ioMkDir(const char *csDir, int mode)
         }          }
 end:  end:
         chdir(szOld);          chdir(szOld);
        free(str);        e_free(str);
         return cx;          return cx;
 }  }
   
 /*  /*
 * ioWatchDirLoop() Function for watching changes in directory and fire callback * ioWatchDirLoop() - Function for watching changes in directory and fire callback
  *   *
  * @csDir = Full directory path   * @csDir = Full directory path
  * @callback = Callback if raise event! nOp -1 delete, 0 change/move, 1 create   * @callback = Callback if raise event! nOp -1 delete, 0 change/move, 1 create
Line 568  ioWatchDirLoop(const char *csDir, int (*callback)(cons Line 384  ioWatchDirLoop(const char *csDir, int (*callback)(cons
 }  }
   
 /*  /*
 * ioCreatePIDFile() Create PID file * ioCreatePIDFile() - Create PID file
  *   *
  * @csName = PID filename   * @csName = PID filename
  * @ifExists = !=0 if filename exists return error   * @ifExists = !=0 if filename exists return error
  * return: -1 error or 0 ok   * return: -1 error or 0 ok
  */   */
inline intint
 ioCreatePIDFile(const char *csName, int ifExists)  ioCreatePIDFile(const char *csName, int ifExists)
 {  {
         int fd;          int fd;
Line 596  ioCreatePIDFile(const char *csName, int ifExists) Line 412  ioCreatePIDFile(const char *csName, int ifExists)
   
   
 /*  /*
 * ioSendFile() AITNET sendfile() userland implementation, not dependant from OS * ioSendFile() - AITNET sendfile() userland implementation, not dependant from OS
  *   *
  * @s = socket   * @s = socket
  * @csFile = file for send   * @csFile = file for send
Line 663  ioSendFile(int s, const char *csFile, size_t sendLen,  Line 479  ioSendFile(int s, const char *csFile, size_t sendLen, 
 }  }
   
 /*  /*
 * ioRecvFile() Receive file from socket, fastest (zero-copy) way * ioRecvFile() - Receive file from socket, fastest (zero-copy) way
  *   *
  * @s = socket   * @s = socket
  * @csFile = file for receive   * @csFile = file for receive
Line 698  ioRecvFile(int s, const char *csFile, size_t recvLen,  Line 514  ioRecvFile(int s, const char *csFile, size_t recvLen, 
                 unlink(csFile);                  unlink(csFile);
                 return 0;                  return 0;
         }          }
        if (lseek(fd, recvLen - 1, SEEK_SET) == -1) {        if (ftruncate(fd, recvLen) == -1) {
                LOGERR; 
                close(fd); 
                unlink(csFile); 
                return 0; 
        } 
        if (write(fd, "", 1) == -1) { 
                 LOGERR;                  LOGERR;
                 close(fd);                  close(fd);
                 unlink(csFile);                  unlink(csFile);
Removed from v.1.9  
changed lines
  Added in v.1.15

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>