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
|
#include "retriever.h"
#include "support.h"
#include "support/gutils.h"
int policy = POLICY_SIMPLE;
pthread_mutex_t **file_mutex = NULL;
int cache_limit = DEFAULT_FILE_CACHE_LIMIT;
int (*retrieve)(struct file_system_info *fsinfo, stats_t *stats);
int (*release)(struct file_system_info *fsinfo, stats_t *stats);
int retriever_init_simple(struct file_system_info *fsinfo){
debug(3, "Initializing simple retriever for %d repos;\n", fsinfo->repo_count);
policy = POLICY_SIMPLE;
retrieve = &retrieve_simple;
release = &release_simple;
return retriever_init_common(fsinfo);
};
int retriever_init_limit(struct file_system_info *fsinfo){
debug(3, "Initializing limit retriever for %d repos;\n", fsinfo->repo_count);
policy = POLICY_LIMIT;
retrieve = &retrieve_limit;
release = &release_limit;
return retriever_init_common(fsinfo);
};
char * get_tmp_path(char *path) {
node_t *node = get_open_file(path);
if (!node || !node->tmp_path || !node->count)
return NULL;
return node->tmp_path;
};
|
