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
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* Copyright (C) 2017 Red Hat, Inc.
*
* This is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License version 2.1, as published by the Free Software
* Foundation. See file COPYING.
*
*/
#include <seastar/core/sharded.hh>
#include <seastar/net/packet.hh>
#include "include/buffer_raw.h"
#include "buffer_seastar.h"
using temporary_buffer = seastar::temporary_buffer<char>;
namespace ceph::buffer {
class raw_seastar_foreign_ptr : public raw {
seastar::foreign_ptr<temporary_buffer> ptr;
public:
raw_seastar_foreign_ptr(temporary_buffer&& buf)
: raw(buf.get_write(), buf.size()), ptr(std::move(buf)) {}
raw* clone_empty() override {
return create(len).release();
}
};
class raw_seastar_local_ptr : public raw {
temporary_buffer buf;
public:
raw_seastar_local_ptr(temporary_buffer&& buf)
: raw(buf.get_write(), buf.size()), buf(std::move(buf)) {}
raw* clone_empty() override {
return create(len).release();
}
};
inline namespace v15_2_0 {
ceph::unique_leakable_ptr<buffer::raw> create_foreign(temporary_buffer&& buf) {
return ceph::unique_leakable_ptr<buffer::raw>(
new raw_seastar_foreign_ptr(std::move(buf)));
}
ceph::unique_leakable_ptr<buffer::raw> create(temporary_buffer&& buf) {
return ceph::unique_leakable_ptr<buffer::raw>(
new raw_seastar_local_ptr(std::move(buf)));
}
} // inline namespace v15_2_0
// buffer::ptr conversions
ptr::operator seastar::temporary_buffer<char>() &
{
return {c_str(), _len, seastar::make_object_deleter(*this)};
}
ptr::operator seastar::temporary_buffer<char>() &&
{
auto data = c_str();
auto length = _len;
return {data, length, seastar::make_object_deleter(std::move(*this))};
}
// buffer::list conversions
list::operator seastar::net::packet() &&
{
seastar::net::packet p(_num);
for (auto& ptr : _buffers) {
// append each ptr as a temporary_buffer
p = seastar::net::packet(std::move(p), std::move(ptr));
}
clear();
return p;
}
} // namespace ceph::buffer
namespace {
using ceph::buffer::raw;
class raw_seastar_local_shared_ptr : public raw {
temporary_buffer buf;
public:
raw_seastar_local_shared_ptr(temporary_buffer& buf)
: raw(buf.get_write(), buf.size()), buf(buf.share()) {}
raw* clone_empty() override {
return ceph::buffer::create(len).release();
}
};
}
buffer::ptr seastar_buffer_iterator::get_ptr(size_t len)
{
buffer::ptr p{ceph::unique_leakable_ptr<buffer::raw>(
new raw_seastar_local_shared_ptr{buf})};
p.set_length(len);
return p;
}
buffer::ptr const_seastar_buffer_iterator::get_ptr(size_t len)
{
return buffer::ptr{ buffer::copy(get_pos_add(len), len) };
}
|
