#include <errno.h>
#include <set>
#include <string>
-#include <boost/assign/list_of.hpp>
using namespace cls::journal;
std::set<Client> clients;
ASSERT_EQ(0, client::client_list(ioctx, oid, &clients));
- std::set<Client> expected_clients = boost::assign::list_of(
- Client("id1", "desc1"));
+ std::set<Client> expected_clients = {Client("id1", "desc1")};
ASSERT_EQ(expected_clients, clients);
}
ASSERT_EQ(0, client::client_register(ioctx, oid, "id1", "desc1"));
cls::journal::EntryPositions entry_positions;
- entry_positions = boost::assign::list_of(
- cls::journal::EntryPosition("tag1", 120))(
- cls::journal::EntryPosition("tag2", 121));
+ entry_positions = {
+ cls::journal::EntryPosition("tag1", 120),
+ cls::journal::EntryPosition("tag2", 121)};
cls::journal::ObjectSetPosition object_set_position(
1, entry_positions);
std::set<Client> clients;
ASSERT_EQ(0, client::client_list(ioctx, oid, &clients));
- std::set<Client> expected_clients = boost::assign::list_of(
- Client("id1", "desc1", object_set_position));
+ std::set<Client> expected_clients = {
+ Client("id1", "desc1", object_set_position)};
ASSERT_EQ(expected_clients, clients);
}
ASSERT_EQ(0, client::client_register(ioctx, oid, "id1", "desc1"));
cls::journal::EntryPositions entry_positions;
- entry_positions = boost::assign::list_of(
- cls::journal::EntryPosition("tag1", 120))(
- cls::journal::EntryPosition("tag1", 121))(
- cls::journal::EntryPosition("tag2", 121));
+ entry_positions = {
+ cls::journal::EntryPosition("tag1", 120),
+ cls::journal::EntryPosition("tag1", 121),
+ cls::journal::EntryPosition("tag2", 121)};
cls::journal::ObjectSetPosition object_set_position(
1, entry_positions);
#include "test/journal/RadosTestFixture.h"
#include "common/Cond.h"
#include "common/Mutex.h"
-#include <boost/assign/list_of.hpp>
#include <map>
class TestJournalMetadata : public RadosTestFixture {
ASSERT_EQ(commit_position, read_commit_position);
journal::JournalMetadata::EntryPositions entry_positions;
- entry_positions = boost::assign::list_of(
- cls::journal::EntryPosition("tag1", 122));
+ entry_positions = {
+ cls::journal::EntryPosition("tag1", 122)};
commit_position = journal::JournalMetadata::ObjectSetPosition(1, entry_positions);
C_SaferCond cond;
#include "gtest/gtest.h"
#include "test/journal/RadosTestFixture.h"
#include <list>
-#include <boost/assign/list_of.hpp>
class TestJournalPlayer : public RadosTestFixture {
public:
std::string oid = get_temp_oid();
journal::JournalPlayer::EntryPositions positions;
- positions = boost::assign::list_of(
- cls::journal::EntryPosition("tag1", 122));
+ positions = {
+ cls::journal::EntryPosition("tag1", 122) };
cls::journal::ObjectSetPosition commit_position(0, positions);
ASSERT_EQ(0, create(oid));
ASSERT_TRUE(wait_for_complete(player));
Entries expected_entries;
- expected_entries = boost::assign::list_of(
- create_entry("tag1", 123))(
- create_entry("tag1", 124))(
- create_entry("tag1", 125));
+ expected_entries = {
+ create_entry("tag1", 123),
+ create_entry("tag1", 124),
+ create_entry("tag1", 125)};
ASSERT_EQ(expected_entries, entries);
uint64_t last_tid;
ASSERT_TRUE(wait_for_complete(player));
Entries expected_entries;
- expected_entries = boost::assign::list_of(
- create_entry("tag1", 122))(
- create_entry("tag1", 123));
+ expected_entries = {
+ create_entry("tag1", 122),
+ create_entry("tag1", 123)};
ASSERT_EQ(expected_entries, entries);
}
std::string oid = get_temp_oid();
journal::JournalPlayer::EntryPositions positions;
- positions = boost::assign::list_of(
- cls::journal::EntryPosition("tag1", 122))(
- cls::journal::EntryPosition("tag2", 1));
+ positions = {
+ cls::journal::EntryPosition("tag1", 122),
+ cls::journal::EntryPosition("tag2", 1)};
cls::journal::ObjectSetPosition commit_position(0, positions);
ASSERT_EQ(0, create(oid));
std::string oid = get_temp_oid();
journal::JournalPlayer::EntryPositions positions;
- positions = boost::assign::list_of(
- cls::journal::EntryPosition("tag1", 122));
+ positions = {
+ cls::journal::EntryPosition("tag1", 122)};
cls::journal::ObjectSetPosition commit_position(0, positions);
ASSERT_EQ(0, create(oid));
ASSERT_TRUE(wait_for_entries(player, 1, &entries));
Entries expected_entries;
- expected_entries = boost::assign::list_of(create_entry("tag1", 123));
+ expected_entries = {create_entry("tag1", 123)};
ASSERT_EQ(expected_entries, entries);
ASSERT_EQ(0, write_entry(oid, 0, "tag1", 124));
ASSERT_TRUE(wait_for_entries(player, 1, &entries));
- expected_entries = boost::assign::list_of(create_entry("tag1", 124));
+ expected_entries = {create_entry("tag1", 124)};
ASSERT_EQ(expected_entries, entries);
}
#include "gtest/gtest.h"
#include "test/librados/test.h"
#include "test/journal/RadosTestFixture.h"
-#include <boost/assign/list_of.hpp>
class TestObjectPlayer : public RadosTestFixture {
public:
object->get_entries(&entries);
ASSERT_EQ(2U, entries.size());
- journal::ObjectPlayer::Entries expected_entries = boost::assign::list_of(
- entry1)(entry2);
+ journal::ObjectPlayer::Entries expected_entries = {entry1, entry2};
ASSERT_EQ(expected_entries, entries);
}
object->get_entries(&entries);
ASSERT_EQ(1U, entries.size());
- journal::ObjectPlayer::Entries expected_entries = boost::assign::list_of(
- entry1);
+ journal::ObjectPlayer::Entries expected_entries = {entry1};
ASSERT_EQ(expected_entries, entries);
}
object->get_entries(&entries);
ASSERT_EQ(1U, entries.size());
- journal::ObjectPlayer::Entries expected_entries = boost::assign::list_of(
- entry2);
+ journal::ObjectPlayer::Entries expected_entries = {entry2};
ASSERT_EQ(expected_entries, entries);
}
object->get_entries(&entries);
ASSERT_EQ(2U, entries.size());
- journal::ObjectPlayer::Entries expected_entries = boost::assign::list_of(
- entry1)(entry2);
+ journal::ObjectPlayer::Entries expected_entries = {entry1, entry2};
ASSERT_EQ(expected_entries, entries);
}
object->get_entries(&entries);
ASSERT_EQ(1U, entries.size());
- journal::ObjectPlayer::Entries expected_entries = boost::assign::list_of(
- entry1);
+ journal::ObjectPlayer::Entries expected_entries = {entry1};
ASSERT_EQ(expected_entries, entries);
bl.clear();
object->get_entries(&entries);
ASSERT_EQ(2U, entries.size());
- expected_entries = boost::assign::list_of(entry1)(entry2);
+ expected_entries = {entry1, entry2};
ASSERT_EQ(expected_entries, entries);
}
ASSERT_EQ(1U, entries.size());
journal::ObjectPlayer::Entries expected_entries;
- expected_entries = boost::assign::list_of(entry1);
+ expected_entries = {entry1};
ASSERT_EQ(expected_entries, entries);
C_SaferCond cond2;
object->get_entries(&entries);
ASSERT_EQ(2U, entries.size());
- expected_entries = boost::assign::list_of(entry1)(entry2);
+ expected_entries = {entry1, entry2};
ASSERT_EQ(expected_entries, entries);
}
#include "test/librados/test.h"
#include "test/journal/RadosTestFixture.h"
#include <limits>
-#include <boost/assign/list_of.hpp>
class TestObjectRecorder : public RadosTestFixture {
public:
journal::AppendBuffer append_buffer1 = create_append_buffer("tag", 123,
"payload");
journal::AppendBuffers append_buffers;
- append_buffers = boost::assign::list_of(append_buffer1);
+ append_buffers = {append_buffer1};
ASSERT_FALSE(object->append(append_buffers));
ASSERT_EQ(1U, object->get_pending_appends());
journal::AppendBuffer append_buffer2 = create_append_buffer("tag", 124,
"payload");
- append_buffers = boost::assign::list_of(append_buffer2);
+ append_buffers = {append_buffer2};
ASSERT_FALSE(object->append(append_buffers));
ASSERT_EQ(2U, object->get_pending_appends());
journal::AppendBuffer append_buffer1 = create_append_buffer("tag", 123,
"payload");
journal::AppendBuffers append_buffers;
- append_buffers = boost::assign::list_of(append_buffer1);
+ append_buffers = {append_buffer1};
ASSERT_FALSE(object->append(append_buffers));
ASSERT_EQ(1U, object->get_pending_appends());
journal::AppendBuffer append_buffer2 = create_append_buffer("tag", 124,
"payload");
- append_buffers = boost::assign::list_of(append_buffer2);
+ append_buffers = {append_buffer2};
ASSERT_FALSE(object->append(append_buffers));
ASSERT_EQ(0U, object->get_pending_appends());
journal::AppendBuffer append_buffer1 = create_append_buffer("tag", 123,
"payload");
journal::AppendBuffers append_buffers;
- append_buffers = boost::assign::list_of(append_buffer1);
+ append_buffers = {append_buffer1};
ASSERT_FALSE(object->append(append_buffers));
ASSERT_EQ(1U, object->get_pending_appends());
journal::AppendBuffer append_buffer2 = create_append_buffer("tag", 124,
"payload");
- append_buffers = boost::assign::list_of(append_buffer2);
+ append_buffers = {append_buffer2};
ASSERT_FALSE(object->append(append_buffers));
ASSERT_EQ(0U, object->get_pending_appends());
journal::AppendBuffer append_buffer1 = create_append_buffer("tag", 123,
"payload");
journal::AppendBuffers append_buffers;
- append_buffers = boost::assign::list_of(append_buffer1);
+ append_buffers = {append_buffer1};
ASSERT_FALSE(object->append(append_buffers));
journal::AppendBuffer append_buffer2 = create_append_buffer("tag", 124,
"payload");
- append_buffers = boost::assign::list_of(append_buffer2);
+ append_buffers = {append_buffer2};
ASSERT_FALSE(object->append(append_buffers));
C_SaferCond cond;
journal::AppendBuffer append_buffer1 = create_append_buffer("tag", 123,
payload);
journal::AppendBuffers append_buffers;
- append_buffers = boost::assign::list_of(append_buffer1);
+ append_buffers = {append_buffer1};
ASSERT_FALSE(object->append(append_buffers));
journal::AppendBuffer append_buffer2 = create_append_buffer("tag", 124,
payload);
- append_buffers = boost::assign::list_of(append_buffer2);
+ append_buffers = {append_buffer2};
ASSERT_TRUE(object->append(append_buffers));
C_SaferCond cond;
journal::AppendBuffer append_buffer1 = create_append_buffer("tag", 123,
"payload");
journal::AppendBuffers append_buffers;
- append_buffers = boost::assign::list_of(append_buffer1);
+ append_buffers = {append_buffer1};
ASSERT_FALSE(object->append(append_buffers));
ASSERT_EQ(1U, object->get_pending_appends());
journal::AppendBuffer append_buffer = create_append_buffer("tag", 123,
"payload");
journal::AppendBuffers append_buffers;
- append_buffers = boost::assign::list_of(append_buffer);
+ append_buffers = {append_buffer};
ASSERT_FALSE(object->append(append_buffers));
ASSERT_EQ(1U, object->get_pending_appends());
"payload");
journal::AppendBuffers append_buffers;
- append_buffers = boost::assign::list_of(append_buffer);
+ append_buffers = {append_buffer};
object->flush(append_buffer.first);
ASSERT_FALSE(append_buffer.first->is_flush_in_progress());
journal::AppendBuffer append_buffer2 = create_append_buffer("tag", 124,
payload);
journal::AppendBuffers append_buffers;
- append_buffers = boost::assign::list_of(append_buffer1)(append_buffer2);
+ append_buffers = {append_buffer1, append_buffer2};
ASSERT_TRUE(object1->append(append_buffers));
C_SaferCond cond;
journal::AppendBuffer append_buffer3 = create_append_buffer("bar", 123,
payload);
- append_buffers = boost::assign::list_of(append_buffer3);
+ append_buffers = {append_buffer3};
ASSERT_FALSE(object2->append(append_buffers));
append_buffer3.first->flush(NULL);