glusterfs

1
#include <fcntl.h>
2
#include <unistd.h>
3
#include <time.h>
4
#include <limits.h>
5
#include <string.h>
6
#include <stdio.h>
7
#include <stdlib.h>
8
#include <errno.h>
9
#include <glusterfs/api/glfs.h>
10
#include <glusterfs/api/glfs-handles.h>
11

12
#define LOG_ERR(msg)                                                           \
13
    do {                                                                       \
14
        fprintf(stderr, "%s : Error (%s)\n", msg, strerror(errno));            \
15
    } while (0)
16

17
glfs_t *
18
init_glfs(const char *hostname, const char *volname, const char *logfile)
19
{
20
    int ret = -1;
21
    glfs_t *fs = NULL;
22

23
    fs = glfs_new(volname);
24
    if (!fs) {
25
        LOG_ERR("glfs_new failed");
26
        return NULL;
27
    }
28

29
    ret = glfs_set_volfile_server(fs, "tcp", hostname, 24007);
30
    if (ret < 0) {
31
        LOG_ERR("glfs_set_volfile_server failed");
32
        goto out;
33
    }
34

35
    ret = glfs_set_logging(fs, logfile, 7);
36
    if (ret < 0) {
37
        LOG_ERR("glfs_set_logging failed");
38
        goto out;
39
    }
40

41
    ret = glfs_init(fs);
42
    if (ret < 0) {
43
        LOG_ERR("glfs_init failed");
44
        goto out;
45
    }
46

47
    ret = 0;
48
out:
49
    if (ret) {
50
        glfs_fini(fs);
51
        fs = NULL;
52
    }
53

54
    return fs;
55
}
56

57
int
58
glfs_test_function(const char *hostname, const char *volname,
59
                   const char *logfile, const char *syncfile)
60
{
61
    int ret = -1;
62
    int flags = O_CREAT | O_RDWR;
63
    glfs_t *fs = NULL;
64
    glfs_fd_t *glfd = NULL;
65
    const char *buff = "This is from my prog\n";
66
    const char *filename = "glfs_test.txt";
67
    struct stat buf = {0};
68

69
    fs = init_glfs(hostname, volname, logfile);
70
    if (fs == NULL) {
71
        LOG_ERR("init_glfs failed");
72
        return -1;
73
    }
74

75
    glfd = glfs_creat(fs, filename, flags, 0644);
76
    if (glfd == NULL) {
77
        LOG_ERR("glfs_creat failed");
78
        goto out;
79
    }
80

81
    while (glfs_stat(fs, syncfile, &buf) == 0) {
82
        ret = glfs_write(glfd, buff, strlen(buff), flags);
83
        if (ret < 0) {
84
            LOG_ERR("glfs_write failed");
85
            goto out;
86
        }
87
    }
88

89
    ret = glfs_close(glfd);
90
    if (ret < 0) {
91
        LOG_ERR("glfs_write failed");
92
        goto out;
93
    }
94

95
out:
96
    ret = glfs_fini(fs);
97
    if (ret) {
98
        LOG_ERR("glfs_fini failed");
99
    }
100

101
    return ret;
102
}
103

104
int
105
main(int argc, char *argv[])
106
{
107
    int ret = 0;
108
    char *hostname = NULL;
109
    char *volname = NULL;
110
    char *logfile = NULL;
111
    char *syncfile = NULL;
112

113
    if (argc != 5) {
114
        fprintf(stderr, "Invalid argument\n");
115
        exit(1);
116
    }
117

118
    hostname = argv[1];
119
    volname = argv[2];
120
    logfile = argv[3];
121
    syncfile = argv[4];
122

123
    ret = glfs_test_function(hostname, volname, logfile, syncfile);
124
    if (ret) {
125
        LOG_ERR("glfs_test_function failed");
126
    }
127

128
    return ret;
129
}
130