gauc 0.3.0

Couchbase Rust Adapter / CLI
Documentation 
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
115
116
117
118
119
120
121
122
123
124
125
126
127
128

#include "rdbtest.h"

class RopeTest : public ::testing::Test {};
using std::string;

TEST_F(RopeTest, testBasic)
{
    IORope rope;
    nb_IOV iovs;
    unsigned niov = rdb_rdstart(&rope, &iovs, 1);
    ASSERT_EQ(1, niov);
    ASSERT_FALSE(iovs.iov_base == NULL);
    ASSERT_GT(iovs.iov_len, 0U);

    memset(iovs.iov_base, 0x66, iovs.iov_len);
    rdb_rdend(&rope, iovs.iov_len);
    ASSERT_EQ(iovs.iov_len, rope.usedSize());

    for (unsigned ii = 0; ii < iovs.iov_len; ii++) {
        unsigned char tmp;
        rdb_copyread(&rope, &tmp, 1);
        ASSERT_EQ(0x66, tmp);
        rdb_consumed(&rope, 1);
    }
}

TEST_F(RopeTest, testFragmented)
{
    IORope rope(rdb_chunkalloc_new(1));
    nb_IOV iovs[32];
    unsigned niov;
    niov = rdb_rdstart(&rope, iovs, 32);
    ASSERT_EQ(32, niov);

    string hello("Hello World!");
    for (unsigned ii = 0; ii < hello.size(); ii++) {
        memcpy(iovs[ii].iov_base, &hello[ii], 1);
    }

    rdb_rdend(&rope, hello.size());
    ASSERT_EQ(hello.size(), rope.usedSize());

    // Now we should be able to extract it properly
    char tmpbuf[32] = { 0 };
    rdb_copyread(&rope, tmpbuf, hello.size());
    ASSERT_STREQ(tmpbuf, hello.c_str());

    /** Can we read contiguously? */
    nb_IOV iovs2[32];
    rdb_ROPESEG *backs[32];
    int nitems;

    nitems = rdb_refread_ex(&rope, iovs2, backs, 32, hello.size());
    ASSERT_EQ(hello.size(), nitems);
    for (unsigned ii = 0; ii < hello.size(); ii++) {
        nb_IOV *cur = iovs2 + ii;
        ASSERT_EQ(*(char *)cur->iov_base, hello.at(ii));
        ASSERT_EQ(1, cur->iov_len);
    }

    // Solidify them?
    rdb_consolidate(&rope, 5);
    memset(tmpbuf, 0, sizeof(tmpbuf));
    ASSERT_EQ(hello.size(), rope.usedSize());
    rdb_copyread(&rope, tmpbuf, hello.size());
    ASSERT_STREQ(tmpbuf, hello.c_str());

    nitems = rdb_refread_ex(&rope, iovs2, backs, 32, hello.size());
    ASSERT_EQ(hello.size()-4, nitems);
}

// This tests the functionality where we want _subsequent_ reads to be
// consolidated into a single buffer.
TEST_F(RopeTest, testConsolidatedReadAhead)
{
    IORope ior(rdb_chunkalloc_new(1));
    ior.rdsize = 256;

    nb_IOV iovs[32];
    rdb_ROPESEG *segs[32];
    unsigned niov;

    // Feed 4 bytes into the buffer
    ior.feed("1234");

    // Make the next 6 bytes consolidated
    rdb_consolidate(&ior, 6);
    ior.feed("5678");
    niov = rdb_refread_ex(&ior, iovs, segs, 3, 8);

    ASSERT_EQ(3, niov);
    ASSERT_EQ(6, iovs[0].iov_len);
    ASSERT_EQ(0, memcmp(iovs[0].iov_base, "123456", 6));
    ASSERT_EQ(*(char *)iovs[1].iov_base, '7');
    ASSERT_EQ(*(char *)iovs[2].iov_base, '8');
}


// When I was integrating this into LCBIO, I realized this scenario. Trying to
// figure out what the intended outcome is.
// Apparently this cannot work because we can't consume a buffer which is also
// available for reading as this may result in the currently-being-read-into
// buffer being released.
TEST_F(RopeTest, DISABLED_testInterleavedReadConsume)
{
    IORope ior(rdb_bigalloc_new());
    ior.rdsize = 256;
    nb_IOV iov;
    unsigned niov;

    niov = rdb_rdstart(&ior, &iov, 1);
    ASSERT_EQ(1, niov);
    memset(iov.iov_base, '1', 29);

    rdb_rdend(&ior, 29);
    rdb_consumed(&ior, 24);
    ASSERT_EQ(5, rdb_get_nused(&ior));

    nb_IOV iov2;
    niov = rdb_rdstart(&ior, &iov2, 1);
    ASSERT_EQ(1, niov);
    ASSERT_EQ(5, rdb_get_nused(&ior));

    rdb_consumed(&ior, 5);
    ASSERT_EQ(0, rdb_get_nused(&ior));

    rdb_rdend(&ior, 100);
}