~snapcpp/snapcpp/cassandra-cpp-driver

« back to all changes in this revision

Viewing changes to src/ring_buffer.hpp

Committer: R. Douglas Barbieri
Date: 2017-10-16 01:45:58 UTC
Revision ID: doug@dooglio.net-20171016014558-na2sj1b10rxvcm0k

Checked out 2.5.0.

files removed:
bin

bin/README.md

bin/vswhere.exe

build.yaml

examples/duration

examples/duration/CMakeLists.txt

examples/duration/duration.c

src/encode.cpp

src/fixed_allocator.hpp

src/get_time-mac.cpp

src/get_time-unix.cpp

src/get_time-win.cpp

src/small_dense_hash_map.hpp

src/small_vector.hpp

src/third_party/rapidjson/patches/remove_implicit-fallthrough_warnings.diff

test/unit_tests/src/test_encode.cpp

test/unit_tests/src/test_get_time.cpp

test/unit_tests/src/test_serialization.cpp

test/unit_tests/src/test_small_vector.cpp

test/unit_tests/src/test_value.cpp

files modified:
.git/HEAD

.git/index

.git/logs/HEAD

.travis.yml

CHANGELOG.md

CMakeLists.txt

README.md

appveyor.yml

cassconfig.hpp.in

cmake/modules/CppDriver.cmake

cmake/modules/FindOpenSSL.cmake

docs.yaml

include/cassandra.h

packaging/cassandra-cpp-driver.spec

packaging/homebrew/cassandra-cpp-driver.rb

src/abstract_data.hpp

src/batch_request.cpp

src/buffer.hpp

src/cluster.cpp

src/collection.cpp

src/collection.hpp

src/config.hpp

src/connection.cpp

src/connection.hpp

src/constants.hpp

src/control_connection.cpp

src/data_type.cpp

src/data_type.hpp

src/data_type_parser.cpp

src/data_type_parser.hpp

src/encode.hpp

src/error_response.cpp

src/error_response.hpp

src/execute_request.cpp

src/execute_request.hpp

src/external.cpp

src/future.cpp

src/get_time.hpp

src/hash_table.hpp

src/io_worker.cpp

src/io_worker.hpp

src/logger.hpp

src/macros.hpp

src/metadata.cpp

src/metadata.hpp

src/metrics.hpp

src/murmur3.cpp

src/pool.cpp

src/pool.hpp

src/query_request.cpp

src/query_request.hpp

src/random.cpp

src/request_callback.cpp

src/request_handler.hpp

src/response.hpp

src/result_metadata.hpp

src/result_response.cpp

src/ring_buffer.hpp

src/serialization.hpp

src/session.cpp

src/session.hpp

src/ssl/ring_buffer_bio.cpp

src/ssl/ring_buffer_bio.hpp

src/ssl/ssl_openssl_impl.cpp

src/ssl/ssl_openssl_impl.hpp

src/statement.cpp

src/statement.hpp

src/string_ref.hpp

src/third_party/rapidjson/rapidjson/reader.h

src/timestamp_generator.cpp

src/timestamp_generator.hpp

src/token_map_impl.hpp

src/tuple.cpp

src/tuple.hpp

src/types.hpp

src/user_type_value.cpp

src/utils.cpp

src/utils.hpp

src/uuids.cpp

src/value.cpp

test/ccm_bridge/src/bridge.cpp

test/ccm_bridge/src/bridge.hpp

test/ccm_bridge/src/cass_version.hpp

test/integration_tests/src/test_authentication.cpp

test/integration_tests/src/test_basics.cpp

test/integration_tests/src/test_collections.cpp

test/integration_tests/src/test_control_connection.cpp

test/integration_tests/src/test_datatypes.cpp

test/integration_tests/src/test_named_parameters.cpp

test/integration_tests/src/test_prepared.cpp

test/integration_tests/src/test_schema_metadata.cpp

test/integration_tests/src/test_speculative_execution_policy.cpp

test/integration_tests/src/test_ssl.cpp

test/integration_tests/src/test_timestamps.cpp

test/integration_tests/src/test_tuples.cpp

test/integration_tests/src/test_utils.cpp

test/integration_tests/src/test_utils.hpp

test/unit_tests/src/test_class_type_parser.cpp

test/unit_tests/src/test_cql_type_parser.cpp

test/unit_tests/src/test_data_type.cpp

test/unit_tests/src/test_load_balancing.cpp

test/unit_tests/src/test_routing_key.cpp

test/unit_tests/src/test_timestamp_gen.cpp

test/unit_tests/src/test_token_map.cpp

test/unit_tests/src/test_utils.cpp

test/unit_tests/src/test_uuids.cpp

topics/basics/consistency/README.md

topics/basics/handling_results/README.md

topics/building/README.md

topics/configuration/README.md

topics/testing/README.md

topics/testing/running/README.md

vc_build.bat

Show diffs side-by-side

added added

removed removed

src/ring_buffer.hpp

#ifndef __CASS_RING_BUFFER_HPP_INCLUDED__

#define __CASS_RING_BUFFER_HPP_INCLUDED__

#include "small_vector.hpp"

#include "fixed_vector.hpp"

#include <uv.h>

104

// Return pointers and sizes of multiple internal data chunks available for

105

// reading from position

106

template <size_t N>

107

size_t peek_multiple(Position pos, SmallVector<uv_buf_t, N>* bufs);

107

size_t peek_multiple(Position pos, FixedVector<uv_buf_t, N>* bufs);

108

109

// Find first appearance of `delim` in buffer or `limit` if `delim`

110

// wasn't found.

136

};

137

138

template <size_t N>

139

size_t RingBuffer::peek_multiple(Position pos, SmallVector<uv_buf_t, N>* bufs) {

139

size_t RingBuffer::peek_multiple(Position pos, FixedVector<uv_buf_t, N>* bufs) {

140

Buffer* buf = pos.buf;

141

size_t offset = pos.pos;

142

size_t total = 0;

Older »