1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
/*
* pfqueue backend
*/
#ifndef PFQ_BACKEND_H
#define PFQ_BACKEND_H
#define LOGLEVEL LOG_USER | LOG_ERR
#define BECAPS_MSG_DEL 1 // Can delete messages
#define BECAPS_MSG_HOLD 2 // Can hold (freeze) messages
#define BECAPS_MSG_REQUEUE 4 // Can requeue messages
#define BECAPS_MSG_ENVELOPE 8 // Can extract from/to from envelope
#define BECAPS_MIXED_QUEUE 16 // Backend is single-queue, with status somewhere in some files
#define BECAPS_MSG_LOG 32 // Each message has its own log
#define BUF_SIZE 250
#ifndef FALSE
#define FALSE 0
#endif
#include "../pfqmessage.h"
#define PFQ_API_VERSION 3
#define PFBE_OK 0
#define PFBE_ERROR -3
#define PFBE_UNUSABLE 1
#define PFBE_MSGNOTEX -1
#define PFBE_MSGCACHED -2
#define PFBE_SERROR "*Error*"
#define PFBE_SNOTFOUND "*Not found*"
struct pfb_conf_t {
int max_char; /* char buffer max length */
char command_path[200]; /* path to executables */
char config_path[200]; /* path to config */
int msg_max; /* max num of messages */
int scan_limit; /* max secs for a single scan */
char version[200]; /* version of mta to use */
char host[200]; /* remote host (only for socket backend) */
int port; /* remote port (only for socket backend) */
};
int pfb_caps;
int pfb_using_envelope;
// Returns backend API version
int pfb_apiversion();
// Returns backend id string
const char *pfb_id();
// Returns backend version
const char *pfb_version();
// Returns conf structure
struct pfb_conf_t *pfb_getconf();
// Init backend
int pfb_init();
// Setup backend
int pfb_setup ( struct msg_t*, struct be_msg_t* );
// Closes backend
int pfb_close();
// Fill message queue (called from pthread)
int pfb_fill_queue ();
// Retreive from/to/subject fields
int pfb_retr_headers ( const char* );
// Retreive message status
int pfb_retr_status ( const char* );
// Retreive message body
int pfb_retr_body ( const char*, char*, size_t );
// Delete a message
int pfb_message_delete ( const char* );
// Hold a message
int pfb_message_hold ( const char* );
//
// Release a message
int pfb_message_release ( const char* );
// Requeue a message
int pfb_message_requeue ( const char* );
// Change current queue
int pfb_set_queue ( int );
// Set/unset use of envelope for from/to retreival
void pfb_use_envelope ( int );
// Get backend caps
int pfb_get_caps();
// Returns the queue name
char* pfb_queue_name( int );
// Returns the number of the queues
int pfb_queue_count();
// Ptr to main queue
struct be_msg_t *my_queue;
// Ptr to backend queue
struct msg_t *ext_queue;
// Sets the number of seconds the queue scanning should not exceed
int dig_limit;
// Time digging was last started
int dig_start;
// Max number of messages to handle
int msg_max;
#endif
|
