MessQueue.h
上传用户:woshihumen
上传日期:2013-07-18
资源大小:484k
文件大小:3k
源码类别:

Email服务器

开发平台:

Visual C++

  1. /*
  2.  *  XMail by Davide Libenzi ( Intranet and Internet mail server )
  3.  *  Copyright (C) 1999,..,2004  Davide Libenzi
  4.  *
  5.  *  This program is free software; you can redistribute it and/or modify
  6.  *  it under the terms of the GNU General Public License as published by
  7.  *  the Free Software Foundation; either version 2 of the License, or
  8.  *  (at your option) any later version.
  9.  *
  10.  *  This program is distributed in the hope that it will be useful,
  11.  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  12.  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13.  *  GNU General Public License for more details.
  14.  *
  15.  *  You should have received a copy of the GNU General Public License
  16.  *  along with this program; if not, write to the Free Software
  17.  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  18.  *
  19.  *  Davide Libenzi <davidel@xmailserver.org>
  20.  *
  21.  */
  22. #ifndef _MESSQUEUE_H
  23. #define _MESSQUEUE_H
  24. #define QUEUE_MESS_DIR              "mess"
  25. #define QUEUE_RSND_DIR              "rsnd"
  26. #define QUEUE_INFO_DIR              "info"
  27. #define QUEUE_TEMP_DIR              "temp"
  28. #define QUEUE_SLOG_DIR              "slog"
  29. #define QUEUE_CUST_DIR              "cust"
  30. #define QUEUE_MPRC_DIR              "mprc"
  31. #define QUEUE_FROZ_DIR              "froz"
  32. #define STD_QUEUEFS_DIRS_X_LEVEL    23
  33. #define INVALID_QUEUE_HANDLE        ((QUEUE_HANDLE) 0)
  34. #define INVALID_QMSG_HANDLE         ((QMSG_HANDLE) 0)
  35. typedef struct QUEUE_HANDLE_struct {
  36. } *QUEUE_HANDLE;
  37. typedef struct QMSG_HANDLE_struct {
  38. } *QMSG_HANDLE;
  39. QUEUE_HANDLE QueOpen(char const *pszRootPath, int iMaxRetry, int iRetryTimeout,
  40.      int iRetryIncrRatio, int iNumDirsLevel = STD_QUEUEFS_DIRS_X_LEVEL);
  41. int QueClose(QUEUE_HANDLE hQueue);
  42. int QueGetDirsLevel(QUEUE_HANDLE hQueue);
  43. char const *QueGetRootPath(QUEUE_HANDLE hQueue);
  44. char *QueLoadLastLogEntry(char const *pszLogFilePath);
  45. QMSG_HANDLE QueCreateMessage(QUEUE_HANDLE hQueue);
  46. int QueGetFilePath(QUEUE_HANDLE hQueue, QMSG_HANDLE hMessage, char *pszFilePath,
  47.    char const *pszQueueDir = NULL);
  48. int QueCloseMessage(QUEUE_HANDLE hQueue, QMSG_HANDLE hMessage);
  49. QMSG_HANDLE QueGetHandle(QUEUE_HANDLE hQueue, int iLevel1, int iLevel2, char const *pszQueueDir,
  50.  char const *pszFileName);
  51. char const *QueGetFileName(QMSG_HANDLE hMessage);
  52. int QueGetLevel1(QMSG_HANDLE hMessage);
  53. int QueGetLevel2(QMSG_HANDLE hMessage);
  54. int QueGetTryCount(QMSG_HANDLE hMessage);
  55. time_t QueGetLastTryTime(QMSG_HANDLE hMessage);
  56. time_t QueGetMessageNextOp(QUEUE_HANDLE hQueue, QMSG_HANDLE hMessage);
  57. int QueInitMessageStats(QUEUE_HANDLE hQueue, QMSG_HANDLE hMessage);
  58. int QueCleanupMessage(QUEUE_HANDLE hQueue, QMSG_HANDLE hMessage, bool bFreeze = false);
  59. int QueCommitMessage(QUEUE_HANDLE hQueue, QMSG_HANDLE hMessage);
  60. int QueResendMessage(QUEUE_HANDLE hQueue, QMSG_HANDLE hMessage);
  61. QMSG_HANDLE QueExtractMessage(QUEUE_HANDLE hQueue, int iTimeout);
  62. int QueCheckMessage(QUEUE_HANDLE hQueue, QMSG_HANDLE hMessage);
  63. int QueFlushRsndArena(QUEUE_HANDLE hQueue, char const *pszAddressMatch);
  64. #endif