From ca3fdddf033adb594a025a5565310746522a969d Mon Sep 17 00:00:00 2001 From: "A.J. Beamon" Date: Fri, 26 May 2017 13:59:10 -0700 Subject: [PATCH] Flow bindings no longer support API versions prior to 500. Remove DB name argument. --- bindings/bindingtester/known_testers.py | 2 +- bindings/flow/fdb_flow.actor.cpp | 13 +++++++------ bindings/flow/fdb_flow.h | 2 +- bindings/flow/tester/Tester.actor.cpp | 6 +++--- 4 files changed, 12 insertions(+), 11 deletions(-) diff --git a/bindings/bindingtester/known_testers.py b/bindings/bindingtester/known_testers.py index 09d0a9b786..deae3f496b 100644 --- a/bindings/bindingtester/known_testers.py +++ b/bindings/bindingtester/known_testers.py @@ -64,5 +64,5 @@ testers = { 'java_completable' : Tester('java', _java_completable_cmd + 'StackTester', 2040, 500, MAX_API_VERSION), 'java_completable_async' : Tester('java', _java_completable_cmd + 'AsyncStackTester', 2040, 500, MAX_API_VERSION), 'go' : Tester('go', _absolute_path('go/bin/_stacktester'), 63, 200, MAX_API_VERSION), - 'flow' : Tester('flow', _absolute_path('flow/bin/fdb_flow_tester'), 63, 200, MAX_API_VERSION), + 'flow' : Tester('flow', _absolute_path('flow/bin/fdb_flow_tester'), 63, 500, MAX_API_VERSION), } diff --git a/bindings/flow/fdb_flow.actor.cpp b/bindings/flow/fdb_flow.actor.cpp index 678fa4a8cb..1d4ac67365 100644 --- a/bindings/flow/fdb_flow.actor.cpp +++ b/bindings/flow/fdb_flow.actor.cpp @@ -33,9 +33,9 @@ THREAD_FUNC networkThread(void* fdb) { } ACTOR Future _test() { - API *fdb = FDB::API::selectAPIVersion(400); + API *fdb = FDB::API::selectAPIVersion(500); auto c = fdb->createCluster( std::string() ); - auto db = c->createDatabase( LiteralStringRef("DB") ); + auto db = c->createDatabase(); state Reference tr( new Transaction(db) ); // tr->setVersion(1); @@ -77,7 +77,7 @@ ACTOR Future _test() { } void fdb_flow_test() { - API *fdb = FDB::API::selectAPIVersion(400); + API *fdb = FDB::API::selectAPIVersion(500); fdb->setupNetwork(); startThread(networkThread, fdb); @@ -144,7 +144,7 @@ namespace FDB { throw api_version_already_set(); } - if(apiVersion < 200 || apiVersion > FDB_API_VERSION) { + if(apiVersion < 500 || apiVersion > FDB_API_VERSION) { throw api_version_not_supported(); } @@ -183,8 +183,9 @@ namespace FDB { return Reference( new Cluster(c) ); } - Reference Cluster::createDatabase( Standalone dbName ) { - CFuture f( fdb_cluster_create_database( c, dbName.begin(), dbName.size() ) ); + Reference Cluster::createDatabase() { + const char *dbName = "DB"; + CFuture f( fdb_cluster_create_database( c, (uint8_t*)dbName, (int)strlen(dbName) ) ); f.blockUntilReady(); FDBDatabase* db; diff --git a/bindings/flow/fdb_flow.h b/bindings/flow/fdb_flow.h index 013c0f0826..cc138878c2 100644 --- a/bindings/flow/fdb_flow.h +++ b/bindings/flow/fdb_flow.h @@ -52,7 +52,7 @@ namespace FDB { fdb_cluster_destroy( c ); } - Reference createDatabase( Standalone dbName ); + Reference createDatabase(); private: explicit Cluster( FDBCluster* c ) : c(c) {} diff --git a/bindings/flow/tester/Tester.actor.cpp b/bindings/flow/tester/Tester.actor.cpp index 192989d36d..80e4a57429 100644 --- a/bindings/flow/tester/Tester.actor.cpp +++ b/bindings/flow/tester/Tester.actor.cpp @@ -1661,7 +1661,7 @@ ACTOR void startTest(std::string clusterFilename, StringRef prefix, int apiVersi // Connect to the default cluster/database, and create a transaction auto cluster = fdb->createCluster(clusterFilename); - Reference db = cluster->createDatabase(LiteralStringRef("DB")); + Reference db = cluster->createDatabase(); Reference data = Reference(new FlowTesterData(fdb)); Void _ = wait(runTest(data, db, prefix)); @@ -1685,13 +1685,13 @@ ACTOR void _test_versionstamp() { try { g_network = newNet2(NetworkAddress(), false); - API *fdb = FDB::API::selectAPIVersion(410); + API *fdb = FDB::API::selectAPIVersion(500); fdb->setupNetwork(); startThread(networkThread, fdb); auto c = fdb->createCluster(std::string()); - auto db = c->createDatabase(LiteralStringRef("DB")); + auto db = c->createDatabase(); state Reference tr(new Transaction(db)); state Future> ftrVersion = tr->getVersionstamp();