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
|
/*
Copyright (c) 2013 Red Hat, Inc. <http://www.redhat.com>
This file is part of GlusterFS.
This file is licensed to you under your choice of the GNU Lesser
General Public License, version 3 or any later version (LGPLv3 or
later), or the GNU General Public License, version 2 (GPLv2), in all
cases as published by the Free Software Foundation.
*/
#ifndef _GF_CHANGELOG_HELPERS_H
#define _GF_CHANGELOG_HELPERS_H
#include <unistd.h>
#include <dirent.h>
#include <limits.h>
#include <pthread.h>
#include <xlator.h>
#define GF_CHANGELOG_TRACKER "tracker"
#define GF_CHANGELOG_CURRENT_DIR ".current"
#define GF_CHANGELOG_PROCESSED_DIR ".processed"
#define GF_CHANGELOG_PROCESSING_DIR ".processing"
#define GF_CHANGELOG_HISTORY_DIR ".history"
#ifndef MAXLINE
#define MAXLINE 4096
#endif
#define GF_CHANGELOG_FILL_BUFFER(ptr, ascii, off, len) do { \
memcpy (ascii + off, ptr, len); \
off += len; \
} while (0)
typedef struct read_line {
int rl_cnt;
char *rl_bufptr;
char rl_buf[MAXLINE];
} read_line_t;
typedef struct gf_changelog {
xlator_t *this;
/* 'processing' directory stream */
DIR *gfc_dir;
/* fd to the tracker file */
int gfc_fd;
/* connection retries */
int gfc_connretries;
char gfc_sockpath[UNIX_PATH_MAX];
char gfc_brickpath[PATH_MAX];
/* socket for recieving notifications */
int gfc_sockfd;
char *gfc_working_dir;
/* RFC 3986 string encoding */
char rfc3986[256];
char gfc_current_dir[PATH_MAX];
char gfc_processed_dir[PATH_MAX];
char gfc_processing_dir[PATH_MAX];
pthread_t gfc_changelog_processor;
/* Holds gfc for History API */
struct gf_changelog *hist_gfc;
} gf_changelog_t;
int
gf_changelog_notification_init (xlator_t *this, gf_changelog_t *gfc);
void *
gf_changelog_process (void *data);
ssize_t
gf_changelog_read_path (int fd, char *buffer, size_t bufsize);
void
gf_rfc3986_encode (unsigned char *s, char *enc, char *estr);
size_t
gf_changelog_write (int fd, char *buffer, size_t len);
ssize_t
gf_readline (int fd, void *vptr, size_t maxlen);
int
gf_ftruncate (int fd, off_t length);
off_t
gf_lseek (int fd, off_t offset, int whence);
#endif
|
