File: test_valid_write_read_fd.cpp

package info (click to toggle)
davix 0.8.10-2
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 37,184 kB
  • sloc: ansic: 164,612; cpp: 38,741; python: 17,726; perl: 14,124; sh: 13,458; xml: 3,567; makefile: 1,959; javascript: 885; pascal: 570; lisp: 7
file content (85 lines) | stat: -rw-r--r-- 2,336 bytes parent folder | download | duplicates (6)
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

#include <cstring>
#include <memory>
#include <algorithm>
#include <cstdlib>
#include <davix.hpp>



#include "davix_test_lib.h"

using namespace Davix;



int main(int argc, char** argv){
    if( argc < 2){
        std::cout << "Usage  : " << std::endl;
        std::cout <<"\t" << argv[0] << " [url]" << std::endl;
        std::cout <<"\t" << argv[0] << " [url] [CERTIFICATE_PATH] " << std::endl;
        return 0;
    }

    srand(time(NULL));

    davix_set_log_level(DAVIX_LOG_ALL);

    DavixError* tmp_err=NULL;
    RequestParams  p;
    dav_ssize_t ret;
    int fd, fd_out, fd_out2;
    Context c;
    const ssize_t size_content = rand()/1000000+2;
    std::cout << " size content" << size_content << std::endl;

    char url[2048];
    generate_random_uri(argv[1], "test_davix_",url, 2048);

    char buffer_mktemp[2048];

    if(argc > 2){
        configure_grid_env(argv[2], p);
    }

    File f(c, std::string(url));

    fd = open("/dev/urandom", O_RDONLY);
    DAV_ASSERT_TRUE( fd > 0,  "Impossible to open random generator");

    TRY_DAVIX{
        f.put(&p, fd, size_content);
    }CATCH_DAVIX(&tmp_err);

    DAV_ASSERT_TRUE( tmp_err == NULL, tmp_err->getErrMsg());


    strcpy(buffer_mktemp, "dav-fd-test-XXXXXXXXX");
    fd_out = mkstemp(buffer_mktemp);
    DAV_ASSERT_TRUE( fd_out > 0,  "Impossible to output file");
    ret = f.getToFd(&p, fd_out, &tmp_err);
    DAV_ASSERT_TRUE( tmp_err == NULL, tmp_err->getErrMsg());
    DAV_ASSERT_TRUE( ret == size_content, "Invalid size" << ret);

    dav_ssize_t half_size = size_content/2;

    strcpy(buffer_mktemp, "dav-fd-test-partial-XXXXXXXXX");
    fd_out2 = mkstemp(buffer_mktemp);
    DAV_ASSERT_TRUE( fd_out2 > 0,  "Impossible to output file");
    ret = f.getToFd(&p, fd_out2, half_size, &tmp_err);
    DAV_ASSERT_TRUE( tmp_err == NULL, tmp_err->getErrMsg());
    DAV_ASSERT_TRUE( ret == half_size, "Invalid size" << ret);

    lseek(fd_out, 0, 0);
    lseek(fd_out2, 0, 0);

    char buffer1[half_size], buffer2[half_size];

    DAV_ASSERT_TRUE( read(fd_out, buffer1, half_size) == half_size, "Invalid read back from local file 1");
    DAV_ASSERT_TRUE( read(fd_out2, buffer2, half_size) == half_size, "Invalid read back from local file 2");
    DAV_ASSERT_TRUE( memcmp(buffer1, buffer2, half_size) ==0, "Corrupted content");

    close(fd);
    return 0;
}