blob: 9afaaeba1bb8f089a6d4c161208f5e731de5641f (
plain)
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
|
/*
* handler.c - File handler for shard files.
*/
#include <logger/logger.h>
#include <siri/err.h>
#include <siri/file/handler.h>
#include <stdlib.h>
siri_fh_t * siri_fh_new(uint16_t size)
{
siri_fh_t * fh = malloc(sizeof(siri_fh_t));
if (fh == NULL)
{
ERR_ALLOC
}
else
{
fh->size = size;
fh->idx = 0;
fh->fpointers = calloc(size, sizeof(siri_fp_t *));
if (fh->fpointers == NULL)
{
ERR_ALLOC
free(fh);
fh = NULL;
}
}
return fh;
}
/*
* Destroy file handler. (closes all open files in the file handler)
* In case closing an open file fails, a SIGNAL will be raised.
*/
void siri_fh_free(siri_fh_t * fh)
{
siri_fp_t ** fp;
uint16_t i;
if (fh == NULL)
{
return;
}
for (i = 0; i < fh->size; i++)
{
fp = fh->fpointers + i;
if (*fp == NULL)
{
break;
}
siri_fp_decref(*fp);
}
free(fh->fpointers);
free(fh);
}
/*
* Returns 0 if successful or -1 in case of an error.
*/
int siri_fopen(
siri_fh_t * fh,
siri_fp_t * fp,
const char * fn,
const char * modes)
{
siri_fp_t ** dest = fh->fpointers + fh->idx;
/* close and possible free file pointer at next position */
if (*dest != NULL)
{
siri_fp_decref(*dest);
}
/* assign file pointer */
*dest = fp;
/* increment reference counter (must be done even if open fails) */
fp->ref++;
if ((fp->fp = fopen(fn, modes)) == NULL)
{
log_critical("Cannot open file: '%s' using mode '%s'", fn, modes);
return -1;
}
/* set file handler pointer to next position */
fh->idx = (fh->idx + 1) % fh->size;
return 0;
}
|
