Skip to content

Commit e1ed09c

Browse files
committed
init_capacity -> init_buf_size rename
1 parent 7477c5c commit e1ed09c

File tree

3 files changed

+16
-16
lines changed

3 files changed

+16
-16
lines changed

cpp_test/test_line_sender.cpp

+4-4
Original file line numberDiff line numberDiff line change
@@ -384,17 +384,17 @@ TEST_CASE("Validation of bad chars in key names.")
384384

385385
TEST_CASE("Buffer move and copy ctor testing")
386386
{
387-
const size_t init_capacity = 128;
387+
const size_t init_buf_size = 128;
388388

389-
questdb::ingress::line_sender_buffer buffer1{init_capacity};
389+
questdb::ingress::line_sender_buffer buffer1{init_buf_size};
390390
buffer1.table("buffer1");
391391
CHECK(buffer1.peek() == "buffer1");
392392

393-
questdb::ingress::line_sender_buffer buffer2{2 * init_capacity};
393+
questdb::ingress::line_sender_buffer buffer2{2 * init_buf_size};
394394
buffer2.table("buffer2");
395395
CHECK(buffer2.peek() == "buffer2");
396396

397-
questdb::ingress::line_sender_buffer buffer3{3 * init_capacity};
397+
questdb::ingress::line_sender_buffer buffer3{3 * init_buf_size};
398398
buffer3.table("buffer3");
399399
CHECK(buffer3.peek() == "buffer3");
400400

include/questdb/ingress/line_sender.hpp

+10-10
Original file line numberDiff line numberDiff line change
@@ -315,28 +315,28 @@ namespace questdb::ingress
315315
class line_sender_buffer
316316
{
317317
public:
318-
explicit line_sender_buffer(size_t init_capacity = 64 * 1024) noexcept
319-
: line_sender_buffer{init_capacity, 127}
318+
explicit line_sender_buffer(size_t init_buf_size = 64 * 1024) noexcept
319+
: line_sender_buffer{init_buf_size, 127}
320320
{}
321321

322322
line_sender_buffer(
323-
size_t init_capacity,
323+
size_t init_buf_size,
324324
size_t max_name_len) noexcept
325325
: _impl{nullptr}
326-
, _init_capacity{init_capacity}
326+
, _init_buf_size{init_buf_size}
327327
, _max_name_len{max_name_len}
328328
{
329329
}
330330

331331
line_sender_buffer(const line_sender_buffer& other) noexcept
332332
: _impl{::line_sender_buffer_clone(other._impl)}
333-
, _init_capacity{other._init_capacity}
333+
, _init_buf_size{other._init_buf_size}
334334
, _max_name_len{other._max_name_len}
335335
{}
336336

337337
line_sender_buffer(line_sender_buffer&& other) noexcept
338338
: _impl{other._impl}
339-
, _init_capacity{other._init_capacity}
339+
, _init_buf_size{other._init_buf_size}
340340
, _max_name_len{other._max_name_len}
341341
{
342342
other._impl = nullptr;
@@ -351,7 +351,7 @@ namespace questdb::ingress
351351
_impl = ::line_sender_buffer_clone(other._impl);
352352
else
353353
_impl = nullptr;
354-
_init_capacity = other._init_capacity;
354+
_init_buf_size = other._init_buf_size;
355355
_max_name_len = other._max_name_len;
356356
}
357357
return *this;
@@ -363,7 +363,7 @@ namespace questdb::ingress
363363
{
364364
::line_sender_buffer_free(_impl);
365365
_impl = other._impl;
366-
_init_capacity = other._init_capacity;
366+
_init_buf_size = other._init_buf_size;
367367
_max_name_len = other._max_name_len;
368368
other._impl = nullptr;
369369
}
@@ -717,12 +717,12 @@ namespace questdb::ingress
717717
if (!_impl)
718718
{
719719
_impl = ::line_sender_buffer_with_max_name_len(_max_name_len);
720-
::line_sender_buffer_reserve(_impl, _init_capacity);
720+
::line_sender_buffer_reserve(_impl, _init_buf_size);
721721
}
722722
}
723723

724724
::line_sender_buffer* _impl;
725-
size_t _init_capacity;
725+
size_t _init_buf_size;
726726
size_t _max_name_len;
727727

728728
friend class line_sender;

system_test/questdb_line_sender.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -529,10 +529,10 @@ def __init__(self, micros: int):
529529

530530

531531
class Buffer:
532-
def __init__(self, init_capacity=65536, max_name_len=127):
532+
def __init__(self, init_buf_size=65536, max_name_len=127):
533533
self._impl = _DLL.line_sender_buffer_with_max_name_len(
534534
c_size_t(max_name_len))
535-
_DLL.line_sender_buffer_reserve(self._impl, c_size_t(init_capacity))
535+
_DLL.line_sender_buffer_reserve(self._impl, c_size_t(init_buf_size))
536536

537537
def __len__(self):
538538
return _DLL.line_sender_buffer_size(self._impl)

0 commit comments

Comments
 (0)