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
|
/*
Copyright (c) 2015 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_JOURNAL_H
#define __GF_CHANGELOG_JOURNAL_H
#include <unistd.h>
#include <pthread.h>
#include "changelog.h"
enum api_conn {
JNL_API_CONNECTED,
JNL_API_CONN_INPROGESS,
JNL_API_DISCONNECTED,
};
typedef struct gf_changelog_entry {
char path[PATH_MAX];
struct list_head list;
} gf_changelog_entry_t;
typedef struct gf_changelog_processor {
pthread_mutex_t lock; /* protects ->entries */
pthread_cond_t cond; /* waiter during empty list */
gf_boolean_t waiting;
pthread_t processor; /* thread-id of journal processing thread */
struct list_head entries;
} gf_changelog_processor_t;
typedef struct gf_changelog_journal {
DIR *jnl_dir; /* 'processing' directory stream */
int jnl_fd; /* fd to the tracker file */
char jnl_brickpath[PATH_MAX]; /* brick path for this end-point */
gf_changelog_processor_t *jnl_proc;
char *jnl_working_dir; /* scratch directory */
char jnl_current_dir[PATH_MAX];
char jnl_processed_dir[PATH_MAX];
char jnl_processing_dir[PATH_MAX];
char rfc3986[256]; /* RFC 3986 string encoding */
struct gf_changelog_journal *hist_jnl;
int hist_done; /* holds 0 done scanning,
1 keep scanning and -1 error */
pthread_spinlock_t lock;
int connected;
} gf_changelog_journal_t;
#define JNL_SET_API_STATE(jnl, state) (jnl->connected = state)
#define JNL_IS_API_DISCONNECTED(jnl) (jnl->connected == JNL_API_DISCONNECTED)
/* History API */
typedef struct gf_changelog_history_data {
int len;
int htime_fd;
/* parallelism count */
int n_parallel;
/* history from, to indexes */
unsigned long from;
unsigned long to;
} gf_changelog_history_data_t;
typedef struct gf_changelog_consume_data {
/** set of inputs */
/* fd to read from */
int fd;
/* from @offset */
off_t offset;
xlator_t *this;
gf_changelog_journal_t *jnl;
/** set of outputs */
/* return value */
int retval;
/* journal processed */
char changelog[PATH_MAX];
} gf_changelog_consume_data_t;
/* event handler */
CALLBACK gf_changelog_handle_journal;
/* init, connect & disconnect handler */
INIT gf_changelog_journal_init;
FINI gf_changelog_journal_fini;
CONNECT gf_changelog_journal_connect;
DISCONNECT gf_changelog_journal_disconnect;
#endif
|
