Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
38 commits
Select commit Hold shift + click to select a range
b139bcb
Merge remote-tracking branch 'core/2.12.0_prep'
Apr 19, 2019
dd69942
Updating libuv version for *nix builds
Apr 19, 2019
e6e3c59
CPP-766 - Allow RPM packages to be built on Amazon Linux (#230)
mikefero Apr 25, 2019
53354e9
CPP-764 - Move internal components from `namespace cass` to `namespa…
mpenick Apr 29, 2019
0c8d1eb
CPP-770 Fix header file include guards (__CASS_XXX to DATASTAX_XXX) (…
mpenick Apr 30, 2019
a90986b
Manual formatting fixes before clang-format
May 1, 2019
4b8ab03
Add basic support for clang-format
May 1, 2019
4762815
Add format check to Jenkins CI
May 1, 2019
183e10f
Run clang-format
May 1, 2019
28db6f2
Fix clang-format cpp standard (Cpp03)
May 1, 2019
1a37d1f
Rerun clang-format
May 1, 2019
657e8fa
Merge pull request #235 from riptano/CPP-769
mpenick May 1, 2019
232f222
CPP-772 Remove per cpp file LOG_FILE attribute to speed up Windows build
May 1, 2019
95d6e15
Remove `/GL` and `/LTCG` from Windows builds
May 2, 2019
290f3c9
Merge pull request #236 from riptano/CPP-772
mpenick May 2, 2019
772e3a2
Run clang-format
May 7, 2019
625383a
CPP-775 - Add clang-format targets for Windows command line
May 7, 2019
e87cafb
Manually fixing code format before re-running clang-format
May 7, 2019
97ec92a
Merge pull request #240 from riptano/CPP-775
mikefero May 8, 2019
b576485
CPP-774 - Updating Windows binary publishing to Artifactory (#237)
mikefero May 8, 2019
b24fb3e
CPP-776 - test: Ensure mockssandra decodes entire frame (#247)
mikefero May 23, 2019
9b43b92
Merge remote-tracking branch 'core/master' into sync_core
May 29, 2019
a596639
Merge pull request #250 from riptano/sync_core
mikefero May 29, 2019
85a9294
Update copyright in README (#253)
mpenick Jun 6, 2019
3870627
CPP-745 - Exponential reconnection policy with jitter (#254)
mikefero Jun 21, 2019
cad4643
CPP-573 - docs: Fixing broken links and warnings (#257)
mikefero Jun 26, 2019
d7c3fd4
Merge remote-tracking branch 'core/master' into oss_merge
Jun 26, 2019
9ef1b03
Merge pull request #258 from riptano/oss_merge
mikefero Jun 26, 2019
52b42e2
Update CHANGELOG and versions
Jun 25, 2019
f9ef106
test: Updating Cassandra and DSE versions
Jun 26, 2019
09356d0
test: Fixing comparison warnings
Jun 26, 2019
cc05955
Fixing namespacing for core driver
Jun 26, 2019
a0f7023
Merge remote-tracking branch 'core/master' into 1.9.0_release_prep
Jun 27, 2019
7ec952d
test: Fixing comments and correcting values
Jun 28, 2019
b996200
doc: Fixing up formatting
Jun 28, 2019
08c85b3
Merge pull request #259 from riptano/1.9.0_release_prep
mikefero Jul 1, 2019
2670a38
Merge tag '1.9.0' into 2.13.0_release_prep
Jul 1, 2019
3b17f5c
CPP-769 - Adding format target for OSS driver
Jul 1, 2019
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
1 change: 1 addition & 0 deletions .build.sh
Original file line number Diff line number Diff line change
Expand Up @@ -73,6 +73,7 @@ build_driver() {
(
cd build
cmake -DCMAKE_BUILD_TYPE=Release -D${driver_prefix}_BUILD_SHARED=On -D${driver_prefix}_BUILD_STATIC=On -D${driver_prefix}_BUILD_EXAMPLES=On -D${driver_prefix}_BUILD_UNIT_TESTS=On ..
[[ -x $(which clang-format) ]] && make format-check
make -j${PROCS}
)
}
Expand Down
27 changes: 27 additions & 0 deletions .clang-format
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
---
BasedOnStyle: LLVM
Language: Cpp
Standard: Cpp03
AccessModifierOffset: -2
IndentWidth: 2
TabWidth: 8
ColumnLimit: 100
UseTab: Never
IndentCaseLabels: true
AlignAfterOpenBracket: true
AlignEscapedNewlines: Left
BreakConstructorInitializers: BeforeComma
AllowShortBlocksOnASingleLine: false
DerivePointerAlignment: false
PointerAlignment: Left
BinPackParameters: true
BinPackArguments: true
AllowShortIfStatementsOnASingleLine: true
CompactNamespaces: true
AlignOperands: true
SpacesInContainerLiterals: true
ConstructorInitializerAllOnOneLineOrOnePerLine: false
Cpp11BracedListStyle: false
AlwaysBreakTemplateDeclarations: true
BreakBeforeInheritanceComma: true
...
2 changes: 1 addition & 1 deletion .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ Testing
Debug
demo/cassandra_demo
test/unit_tests/cassandra_test
src/cassconfig.hpp
src/driver_config.hpp

# API docs files
Doxyfile
Expand Down
34 changes: 29 additions & 5 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,19 +1,43 @@
2.13.0
===========

Features
--------
* [CPP-745] Exponential reconnection policy with jitter
* [CPP-769] Use `clang-format` to fix up formatting
* [CPP-775] Add `clang-format` to Windows

Other
--------
* [CPP-743] Move internal components from `namespace cass` to `namespace datastax::internal`
* [CPP-764] Rename namespace from `cass` to `datastax`
* [CPP-766] Allow RPM packaging script to build RPM packages for Amazon Linux
* [CPP-770] Fix header files include guard (\_\_CASS_XXX to DATASTAX_XXX)
* [CPP-772] Remove per cpp file LOG_FILE attribute to speed up Windows builds

Community
--------
* Fixed the location of the '[in]' information for Doxygen. (AlexisWilke)
* Added header subdirectory installation capability. (accelerated)
* Changed pkg_config templates to use the library variable name. (accelerated)
* Fix generation of shlib deps file for debian packages. (jirkasilhan)

2.12.0
===========

Features
--------
[CPP-751] Call host listener callback for the initial set of hosts
* [CPP-751] Call host listener callback for the initial set of hosts

Bug Fixes
--------
[CPP-755] UDT metadata not being properly populated/updated
* [CPP-755] UDT metadata not being properly populated/updated

Other
--------
[CPP-705] Deprecate DC-aware multi-DC settings (`used_hosts_per_remote_dc`
and `allowRemoteDCsForLocalConsistencyLevel `)
[CPP-720] Streamline custom allocator
* [CPP-705] Deprecate DC-aware multi-DC settings (`used_hosts_per_remote_dc`
and `allowRemoteDCsForLocalConsistencyLevel `)
* [CPP-720] Streamline custom allocator

2.11.0
===========
Expand Down
1 change: 1 addition & 0 deletions CMakeLists.txt
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@ set(CASS_INCLUDE_DIR "${CASS_ROOT_DIR}/include")
list(APPEND CMAKE_MODULE_PATH ${CASS_ROOT_DIR}/cmake/modules)

include(CppDriver)
include(ClangFormat)

CassInitProject(cassandra)
CassPolicies()
Expand Down
2 changes: 1 addition & 1 deletion appveyor.ps1
Original file line number Diff line number Diff line change
Expand Up @@ -773,7 +773,7 @@ Function Publish-Artifacts {
}

# Create the Uri and FilePath components for the upload
$base_uri = "$($Env:ARTIFACTORY_BASE_URI)/origin/$($Env:APPVEYOR_REPO_BRANCH)/$(Get-Commit-Sha)/windows"
$base_uri = "$($Env:ARTIFACTORY_BASE_URI)/$($Env:DRIVER_VERSION)/$(Get-Commit-Sha)/windows"
$driver_uri = "$($base_uri)/$($driver_type)/v$($Env:DRIVER_VERSION)/$($Env:DRIVER_ARTIFACT_ARCHIVE)"
$driver_archive = "$($Env:DRIVER_ARTIFACTS_DIR)/$($Env:DRIVER_ARTIFACT_ARCHIVE)"
$libuv_uri = "$($base_uri)/dependencies/libuv/v$($Env:LIBUV_VERSION)/$($Env:LIBUV_ARTIFACT_ARCHIVE)"
Expand Down
8 changes: 4 additions & 4 deletions appveyor.yml
Original file line number Diff line number Diff line change
Expand Up @@ -40,10 +40,10 @@ environment:
APPVEYOR_IGNORE_COMMIT_FILTERING_ON_TAG: true
DRIVER_TYPE: CASS
BOOST_VERSION: 1.69.0
LIBSSH2_VERSION: 1.8.2
LIBUV_VERSION: 1.28.0
OPENSSL_1_0_VERSION: 1.0.2r
OPENSSL_1_1_VERSION: 1.1.1b
LIBSSH2_VERSION: 1.9.0
LIBUV_VERSION: 1.29.1
OPENSSL_1_0_VERSION: 1.0.2s
OPENSSL_1_1_VERSION: 1.1.1c
matrix:
- CMAKE_GENERATOR: Visual Studio 10 2010
OPENSSL_MAJOR_MINOR: 1.0
Expand Down
2 changes: 1 addition & 1 deletion build.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ os:
- centos/7-64/cpp
- osx/high-sierra
env:
LIBUV_VERSION: 1.28.0
LIBUV_VERSION: 1.29.1
build:
- script: |
. .build.sh
Expand Down
109 changes: 109 additions & 0 deletions cmake/modules/ClangFormat.cmake
Original file line number Diff line number Diff line change
@@ -0,0 +1,109 @@
#
# Format and verify formatting using clang-format
#
cmake_minimum_required(VERSION 2.6.4)

include(FindPackageHandleStandardArgs)

if(NOT CLANG_FORMAT_EXE_NAME)
set(CLANG_FORMAT_EXE_NAME clang-format)
endif()

if(CLANG_FORMAT_ROOT_DIR)
find_program(CLANG_FORMAT_EXE
NAMES ${CLANG_FORMAT_EXE_NAME}
PATHS ${CLANG_FORMAT_ROOT_DIR}
NO_DEFAULT_PATH)
endif()

find_program(CLANG_FORMAT_EXE NAMES ${CLANG_FORMAT_EXE_NAME})

find_package_handle_standard_args(CLANG_FORMAT DEFAULT_MSG CLANG_FORMAT_EXE)

mark_as_advanced(CLANG_FORMAT_EXE)

if(CLANG_FORMAT_FOUND)
set(CLANG_FORMAT_FILE_EXTENSIONS ${CLANG_FORMAT_CXX_FILE_EXTENSIONS} *.cpp *.hpp *.c *.h)
file(GLOB_RECURSE CLANG_FORMAT_ALL_SOURCE_FILES ${CLANG_FORMAT_FILE_EXTENSIONS})

set(CLANG_FORMAT_EXCLUDE_PATTERNS ${CLANG_FORMAT_EXCLUDE_PATTERNS} "/CMakeFiles/" "cmake" "/build/" "/vendor/" "/third_party/" "cassandra.h" "dse.h")

foreach(SOURCE_FILE ${CLANG_FORMAT_ALL_SOURCE_FILES})
foreach(EXCLUDE_PATTERN ${CLANG_FORMAT_EXCLUDE_PATTERNS})
string(FIND ${SOURCE_FILE} ${EXCLUDE_PATTERN} EXCLUDE_FOUND)
if(NOT ${EXCLUDE_FOUND} EQUAL -1)
list(REMOVE_ITEM CLANG_FORMAT_ALL_SOURCE_FILES ${SOURCE_FILE})
endif()
endforeach()
endforeach()

if(WIN32)
set(CLANG_FORMAT_FILENAME "clang-format.files")
set(CLANG_FORMAT_ABSOLUTE_FILENAME "${CMAKE_BINARY_DIR}/${CLANG_FORMAT_FILENAME}")
if (EXISTS ${CLANG_FORMAT_ABSOLUTE_FILENAME})
file(REMOVE ${CLANG_FORMAT_ABSOLUTE_FILENAME})
endif()

set(COUNT 1)
file(TO_NATIVE_PATH ${CMAKE_BINARY_DIR} CMAKE_WINDOWS_BINARY_DIR)
foreach(SOURCE_FILE ${CLANG_FORMAT_ALL_SOURCE_FILES})
file(RELATIVE_PATH RELATIVE_SOURCE_FILE ${CMAKE_BINARY_DIR} ${SOURCE_FILE})
file(TO_NATIVE_PATH ${RELATIVE_SOURCE_FILE} NATIVE_RELATIVE_SOURCE_FILE)

if(COUNT EQUAL 50)
file(APPEND ${CLANG_FORMAT_ABSOLUTE_FILENAME} " ${NATIVE_RELATIVE_SOURCE_FILE}\n")
set(COUNT 1)
else()
file(APPEND ${CLANG_FORMAT_ABSOLUTE_FILENAME} " ${NATIVE_RELATIVE_SOURCE_FILE}")
MATH(EXPR COUNT "${COUNT} + 1")
endif()
endforeach()

file(TO_NATIVE_PATH ${CLANG_FORMAT_EXE} CLANG_FORMAT_EXE)
file(WRITE "${CMAKE_BINARY_DIR}/clang-format-windows.bat"
"@REM Generated clang-format script for Windows\r\n"
"@ECHO OFF\r\n"
"SETLOCAL ENABLEDELAYEDEXPANSION\r\n"
"SET IS_FAILED_CHECK=0\r\n"
"PUSHD ${CMAKE_WINDOWS_BINARY_DIR}>NUL\r\n"
"FOR /F \"TOKENS=*\" %%A IN (${CLANG_FORMAT_FILENAME}) do (\r\n"
" IF %1 EQU 1 (\r\n"
" \"${CLANG_FORMAT_EXE}\" -i -fallback-style=none -style=file %%A\r\n"
" IF NOT !ERRORLEVEL! EQU 0 (\r\n"
" SET IS_FAILED_CHECK=1\r\n"
" )\r\n"
" )\r\n"
" IF %1 EQU 2 (\r\n"
" \"${CLANG_FORMAT_EXE}\" -output-replacements-xml -fallback-style=none -style=file %%A 2>&1 | FINDSTR /C:\"replacement offset\">NUL\r\n"
" IF !ERRORLEVEL! EQU 0 (\r\n"
" SET IS_FAILED_CHECK=1\r\n"
" )\r\n"
" )\r\n"
")\r\n"
"IF NOT !IS_FAILED_CHECK! EQU 0 (\r\n"
" POPD\r\n"
" EXIT /B 1\r\n"
")\r\n"
"POPD\r\n"
"ENDLOCAL\r\n"
"EXIT /B 0\r\n")

add_custom_target(format
COMMENT "Format source files using clang-format"
COMMAND "${CMAKE_WINDOWS_BINARY_DIR}\\clang-format-windows.bat" 1)

add_custom_target(format-check
COMMENT "Verify source files formatting using clang-format"
COMMAND "${CMAKE_WINDOWS_BINARY_DIR}\\clang-format-windows.bat" 2)
else()
add_custom_target(format
COMMENT "Format source files using clang-format"
COMMAND ${CLANG_FORMAT_EXE} -i -fallback-style=none -style=file ${CLANG_FORMAT_ALL_SOURCE_FILES})

add_custom_target(format-check
COMMENT "Verify source files formatting using clang-format"
COMMAND ! ${CLANG_FORMAT_EXE} -output-replacements-xml -fallback-style=none -style=file ${CLANG_FORMAT_ALL_SOURCE_FILES} | tee replacements.xml | grep -q "replacement offset")
endif()
else()
message(STATUS "Unable to find clang-format. Not creating format targets.")
endif()
31 changes: 3 additions & 28 deletions cmake/modules/CppDriver.cmake
Original file line number Diff line number Diff line change
Expand Up @@ -810,25 +810,6 @@ macro(CassSetCompilerFlags)
add_definitions("/MP")
endif()

# Enable link time optimization for all MSVC build configurations
set(CMAKE_CXX_FLAGS_RELEASE "${CMAKE_CXX_FLAGS_RELEASE} /GL")
set(CMAKE_STATIC_LINKER_FLAGS_RELEASE "${CMAKE_STATIC_LINKER_FLAGS_RELEASE} /LTCG")
set(CMAKE_SHARED_LINKER_FLAGS_RELEASE "${CMAKE_SHARED_LINKER_FLAGS_RELEASE} /LTCG")
set(CMAKE_EXE_LINKER_FLAGS_RELEASE "${CMAKE_EXE_LINKER_FLAGS_RELEASE} /LTCG")

set(CMAKE_CXX_FLAGS_RELWITHDEBINFO "${CMAKE_CXX_FLAGS_RELWITHDEBINFO} /GL")
string(REGEX REPLACE "[-/]INCREMENTAL" "/INCREMENTAL:NO" CMAKE_STATIC_LINKER_FLAGS_RELWITHDEBINFO "${CMAKE_STATIC_LINKER_FLAGS_RELWITHDEBINFO}")
set(CMAKE_STATIC_LINKER_FLAGS_RELWITHDEBINFO "${CMAKE_STATIC_LINKER_FLAGS_RELWITHDEBINFO} /LTCG")
string(REGEX REPLACE "[-/]INCREMENTAL" "/INCREMENTAL:NO" CMAKE_SHARED_LINKER_FLAGS_RELWITHDEBINFO "${CMAKE_SHARED_LINKER_FLAGS_RELWITHDEBINFO}")
set(CMAKE_SHARED_LINKER_FLAGS_RELWITHDEBINFO "${CMAKE_SHARED_LINKER_FLAGS_RELWITHDEBINFO} /LTCG")
string(REGEX REPLACE "[-/]INCREMENTAL" "/INCREMENTAL:NO" CMAKE_EXE_LINKER_FLAGS_RELWITHDEBINFO "${CMAKE_EXE_LINKER_FLAGS_RELWITHDEBINFO}")
set(CMAKE_EXE_LINKER_FLAGS_RELWITHDEBINFO "${CMAKE_EXE_LINKER_FLAGS_RELWITHDEBINFO} /LTCG")

set(CMAKE_CXX_FLAGS_MINSIZEREL "${CMAKE_CXX_FLAGS_MINSIZEREL} /GL")
set(CMAKE_STATIC_LINKER_FLAGS_MINSIZEREL "${CMAKE_STATIC_LINKER_FLAGS_MINSIZEREL} /LTCG")
set(CMAKE_SHARED_LINKER_FLAGS_MINSIZEREL "${CMAKE_SHARED_LINKER_FLAGS_MINSIZEREL} /LTCG")
set(CMAKE_EXE_LINKER_FLAGS_MINSIZEREL "${CMAKE_EXE_LINKER_FLAGS_MINSIZEREL} /LTCG")

# On Visual C++ -pedantic flag is not used,
# -fPIC is not used on Windows platform (all DLLs are
# relocable), -Wall generates about 30k stupid warnings
Expand Down Expand Up @@ -1001,18 +982,12 @@ macro(CassFindSourceFiles)
endif()

set(CASS_ALL_SOURCE_FILES ${CASS_SRC_FILES} ${CASS_API_HEADER_FILES} ${CASS_INC_FILES})

# Shorten the source file pathing for log messages
foreach(SRC_FILE ${CASS_SRC_FILES})
string(REPLACE "${CASS_ROOT_DIR}/" "" LOG_FILE_ ${SRC_FILE})
set_source_files_properties(${SRC_FILE} PROPERTIES COMPILE_FLAGS -DLOG_FILE_=\\\"${LOG_FILE_}\\\")
endforeach()
endmacro()

#------------------------
# CassConfigure
#
# Generate cassconfig.hpp from cassconfig.hpp.in
# Generate driver_config.hpp from driver_config.hpp.in
#
# Input: CASS_ROOT_DIR, CASS_SRC_DIR
#------------------------
Expand Down Expand Up @@ -1048,6 +1023,6 @@ macro(CassConfigure)
check_cxx_source_compiles("int main() { return __builtin_bswap64(42); }" HAVE_BUILTIN_BSWAP64)
endif()

# Generate the cassconfig.hpp file
configure_file(${CASS_ROOT_DIR}/cassconfig.hpp.in ${CASS_SRC_DIR}/cassconfig.hpp)
# Generate the driver_config.hpp file
configure_file(${CASS_ROOT_DIR}/driver_config.hpp.in ${CASS_SRC_DIR}/driver_config.hpp)
endmacro()
4 changes: 2 additions & 2 deletions cmake/modules/ExternalProject-OpenSSL.cmake
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,8 @@ endif()
# OpenSSL related CMake options
option(OPENSSL_VERSION "OpenSSL version to build and install")
if(NOT OPENSSL_VERSION)
# TODO: Should we default to OpenSSL 1.1 (e.g. 1.1.1b)?
set(OPENSSL_VERSION "1.0.2r")
# TODO: Should we default to OpenSSL 1.1 (e.g. 1.1.1c)?
set(OPENSSL_VERSION "1.0.2s")
endif()
option(OPENSSL_INSTALL_PREFIX "OpenSSL installation prefix location")
if(CASS_USE_ZLIB)
Expand Down
2 changes: 1 addition & 1 deletion cmake/modules/ExternalProject-libssh2.cmake
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ if(NOT LIBSSH2_INSTALL_PREFIX)
endif()
option(LIBSSH2_VERSION "libssh2 version to build and install")
if(NOT LIBSSH2_VERSION)
set(LIBSSH2_VERSION "1.8.2")
set(LIBSSH2_VERSION "1.9.0")
endif()
set(LIBSSH2_VERSION ${LIBSSH2_VERSION} CACHE STRING "libssh2 version to build and install" FORCE)

Expand Down
2 changes: 1 addition & 1 deletion cmake/modules/ExternalProject-libuv.cmake
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ if(NOT LIBUV_INSTALL_PREFIX)
endif()
option(LIBUV_VERSION "libuv version to build and install")
if(NOT LIBUV_VERSION)
set(LIBUV_VERSION "1.28.0")
set(LIBUV_VERSION "1.29.1")
endif()
set(LIBUV_VERSION ${LIBUV_VERSION} CACHE STRING "libuv version to build and install" FORCE)

Expand Down
3 changes: 3 additions & 0 deletions docs.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -52,10 +52,13 @@ rewrites:
- ^examples/(.*): https://github.com/datastax/cpp-driver/blob/master/examples/\1
- http://www.datastax.com/documentation/cql/3.1: https://docs.datastax.com/en/archived/cql/3.1
- http://www.datastax.com/documentation/cassandra/2.: https://docs.datastax.com/en/archived/cassandra/2.
- http://downloads.datastax.com/cpp-driver: https://downloads.datastax.com/cpp-driver/
rules:
use_path_nav_files_only: true

versions:
- name: "2.13"
ref: 2.13.0
- name: "2.12"
ref: 2.12.0
- name: "2.11"
Expand Down
4 changes: 2 additions & 2 deletions cassconfig.hpp.in → driver_config.hpp.in
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
#ifndef __CASSANDRA_CONFIG_HPP_INCLUDED__
#define __CASSANDRA_CONFIG_HPP_INCLUDED__
#ifndef DATASTAX_INTERNAL_DRIVER_CONFIG_HPP
#define DATASTAX_INTERNAL_DRIVER_CONFIG_HPP

#cmakedefine HAVE_OPENSSL
#cmakedefine HAVE_STD_ATOMIC
Expand Down
12 changes: 4 additions & 8 deletions examples/async/async.c
Original file line number Diff line number Diff line change
Expand Up @@ -26,9 +26,9 @@
*/

#include <assert.h>
#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#include "cassandra.h"

Expand All @@ -41,7 +41,6 @@ void print_error(CassFuture* future) {
fprintf(stderr, "Error: %.*s\n", (int)message_length, message);
}


CassCluster* create_cluster(const char* hosts) {
CassCluster* cluster = cass_cluster_new();
cass_cluster_set_contact_points(cluster, hosts);
Expand Down Expand Up @@ -90,7 +89,7 @@ void insert_into_async(CassSession* session, const char* key) {

size_t i;
for (i = 0; i < NUM_CONCURRENT_REQUESTS; ++i) {
char key_buffer[64];
char key_buffer[64];
statement = cass_statement_new(query, 6);

sprintf(key_buffer, "%s%u", key, (unsigned int)i);
Expand Down Expand Up @@ -135,13 +134,10 @@ int main(int argc, char* argv[]) {
return -1;
}

execute_query(session,
"CREATE KEYSPACE examples WITH replication = { \
execute_query(session, "CREATE KEYSPACE examples WITH replication = { \
'class': 'SimpleStrategy', 'replication_factor': '3' };");


execute_query(session,
"CREATE TABLE examples.async (key text, \
execute_query(session, "CREATE TABLE examples.async (key text, \
bln boolean, \
flt float, dbl double,\
i32 int, i64 bigint, \
Expand Down
Loading