Home
last modified time | relevance | path

Searched refs:serial_consistency (Results 1 – 25 of 36) sorted by relevance

12

/dports/databases/pecl-cassandra/php-driver-61faee0/ext/util/
H A Dconsistency.c45 int php_driver_get_serial_consistency(zval *serial_consistency, long *result TSRMLS_DC) in php_driver_get_serial_consistency() argument
47 if (serial_consistency && Z_TYPE_P(serial_consistency) == IS_LONG) { in php_driver_get_serial_consistency()
48 switch (Z_LVAL_P(serial_consistency)) { in php_driver_get_serial_consistency()
51 *result = Z_LVAL_P(serial_consistency); in php_driver_get_serial_consistency()
54 …INVALID_ARGUMENT_VALUE(serial_consistency, "either " PHP_DRIVER_NAMESPACE "::CONSISTENCY_SERIAL or… in php_driver_get_serial_consistency()
57 …INVALID_ARGUMENT_VALUE(serial_consistency, "either " PHP_DRIVER_NAMESPACE "::CONSISTENCY_SERIAL or… in php_driver_get_serial_consistency()
H A Dconsistency.h21 int php_driver_get_serial_consistency(zval *serial_consistency, long *result TSRMLS_DC);
/dports/databases/cassandra-cpp-driver/cpp-driver-2.16.0/src/
H A Drequest.hpp65 , serial_consistency(CASS_CONSISTENCY_UNKNOWN) in RequestSettings()
69 CassConsistency serial_consistency; member
116 CassConsistency serial_consistency() const { return settings_.serial_consistency; } in serial_consistency() function in datastax::internal::core::Request
118 void set_serial_consistency(CassConsistency serial_consistency) { in set_serial_consistency() argument
119 settings_.serial_consistency = serial_consistency; in set_serial_consistency()
H A Drequest_callback.hpp79 CassConsistency serial_consistency() const { in serial_consistency() function in datastax::internal::core::RequestWrapper
80 if (request()->serial_consistency() != CASS_CONSISTENCY_UNKNOWN) { in serial_consistency()
81 return request()->serial_consistency(); in serial_consistency()
173 CassConsistency serial_consistency() { return wrapper_.serial_consistency(); } in serial_consistency() function in datastax::internal::core::RequestCallback
H A Dbatch_request.cpp55 CassError cass_batch_set_serial_consistency(CassBatch* batch, CassConsistency serial_consistency) { in cass_batch_set_serial_consistency() argument
56 batch->set_serial_consistency(serial_consistency); in cass_batch_set_serial_consistency()
165 if (callback->serial_consistency() != 0) { in encode()
189 if (callback->serial_consistency() != 0) { in encode()
190 pos = buf.encode_uint16(pos, callback->serial_consistency()); in encode()
H A Dconfig.cpp24 if (it->second.serial_consistency() == CASS_CONSISTENCY_UNKNOWN) { in init_profiles()
25 it->second.set_serial_consistency(default_profile_.serial_consistency()); in init_profiles()
H A Dexecution_profile.hpp57 CassConsistency serial_consistency() const { return serial_consistency_; } in serial_consistency() function in datastax::internal::core::ExecutionProfile
59 void set_serial_consistency(CassConsistency serial_consistency) { in set_serial_consistency() argument
60 serial_consistency_ = serial_consistency; in set_serial_consistency()
H A Dstatement.cpp85 CassConsistency serial_consistency) { in cass_statement_set_serial_consistency() argument
86 statement->set_serial_consistency(serial_consistency); in cass_statement_set_serial_consistency()
398 if (callback->serial_consistency() != 0) { in encode_begin()
476 if (callback->serial_consistency() != 0) { in encode_end()
503 if (callback->serial_consistency() != 0) { in encode_end()
504 pos = buf.encode_uint16(pos, callback->serial_consistency()); in encode_end()
H A Dconfig.hpp103 CassConsistency serial_consistency() { return default_profile_.serial_consistency(); } in serial_consistency() function in datastax::internal::core::Config
104 void set_serial_consistency(CassConsistency serial_consistency) { in set_serial_consistency() argument
105 default_profile_.set_serial_consistency(serial_consistency); in set_serial_consistency()
H A Dexecution_profile.cpp44 CassConsistency serial_consistency) { in cass_execution_profile_set_serial_consistency() argument
45 profile->set_serial_consistency(serial_consistency); in cass_execution_profile_set_serial_consistency()
H A Dtesting.cpp102 return statement->from()->serial_consistency(); in get_serial_consistency()
H A Drequest_callback.cpp40 serial_consistency_ = profile.serial_consistency(); in init()
/dports/databases/pecl-cassandra/php-driver-61faee0/ext/src/
H A DExecutionOptions.c27 self->serial_consistency = -1; in init_execution_options()
40 php5to7_zval *serial_consistency = NULL; in build_from_array() local
54 …IND(Z_ARRVAL_P(options), "serial_consistency", sizeof("serial_consistency"), serial_consistency)) { in build_from_array()
55 …iver_get_serial_consistency(PHP5TO7_ZVAL_MAYBE_DEREF(serial_consistency), &self->serial_consistenc… in build_from_array()
189 if (self->serial_consistency == -1) { in PHP_METHOD()
192 RETURN_LONG(self->serial_consistency); in PHP_METHOD()
H A DDefaultSession.c506 CassConsistency consistency, long serial_consistency, argument
518 if (rc == CASS_OK && serial_consistency >= 0)
519 rc = cass_statement_set_serial_consistency(stmt, serial_consistency);
559 long serial_consistency = -1; local
621 if (opts->serial_consistency >= 0)
622 serial_consistency = opts->serial_consistency;
634 serial_consistency, page_size,
713 long serial_consistency = -1; local
771 if (opts->serial_consistency >= 0)
772 serial_consistency = opts->serial_consistency;
[all …]
H A DSession.yaml21 …| serial_consistency | int | Either Dse::CONSISTENCY_SERIAL or Dse::CONSISTENCY_LOCAL_…
/dports/databases/cassandra-cpp-driver/cpp-driver-2.16.0/tests/src/integration/objects/
H A Dstatement.hpp139 CassConsistency serial_consistency() { in serial_consistency() function in test::driver::Statement
221 void set_serial_consistency(CassConsistency serial_consistency) { in set_serial_consistency() argument
222 ASSERT_EQ(CASS_OK, cass_statement_set_serial_consistency(get(), serial_consistency)); in set_serial_consistency()
392 void set_serial_consistency(CassConsistency serial_consistency) { in set_serial_consistency() argument
393 ASSERT_EQ(CASS_OK, cass_batch_set_serial_consistency(get(), serial_consistency)); in set_serial_consistency()
H A Dexecution_profile.hpp212 ExecutionProfile& with_serial_consistency(CassConsistency serial_consistency) { in with_serial_consistency() argument
213 EXPECT_EQ(CASS_OK, cass_execution_profile_set_serial_consistency(get(), serial_consistency)); in with_serial_consistency()
/dports/net/kea/kea-2.0.1/src/lib/yang/
H A Dtranslator_database.cc120 ConstElementPtr serial_consistency = getItem(xpath + "/serial-consistency"); in getDatabaseKea() local
121 if (serial_consistency) { in getDatabaseKea()
122 result->set("serial-consistency", serial_consistency); in getDatabaseKea()
238 ConstElementPtr serial_consistency = elem->get("serial-consistency"); in setDatabaseKea() local
239 if (serial_consistency) { in setDatabaseKea()
240 setItem(xpath + "/serial-consistency", serial_consistency, SR_STRING_T); in setDatabaseKea()
/dports/net/kea/kea-2.0.1/src/lib/cql/
H A Dcql_connection.cc171 const char* serial_consistency = NULL; in openDatabase() local
175 serial_consistency = sserial_consistency.c_str(); in openDatabase()
254 if (serial_consistency) { in openDatabase()
420 CassConsistency serial_consistency) { in setConsistency() argument
423 serial_consistency_ = serial_consistency; in setConsistency()
H A Dcql_connection.h180 CassConsistency serial_consistency);
/dports/databases/cassandra-cpp-driver/cpp-driver-2.16.0/tests/src/integration/tests/
H A Dtest_prepared.cpp142 EXPECT_EQ(bound_statement.serial_consistency(), CASS_CONSISTENCY_SERIAL); in CASSANDRA_INTEGRATION_TEST_F()
187 EXPECT_EQ(bound_statement2.serial_consistency(), CASS_CONSISTENCY_SERIAL); in CASSANDRA_INTEGRATION_TEST_F()
/dports/databases/cassandra-cpp-driver/cpp-driver-2.16.0/tests/src/unit/tests/
H A Dtest_exec_profile.cpp50 ASSERT_EQ(CASS_CONSISTENCY_UNKNOWN, profile.serial_consistency()); in TEST()
58 ASSERT_EQ(CASS_DEFAULT_SERIAL_CONSISTENCY, profile_lookup.serial_consistency()); in TEST()
59 ASSERT_EQ(CASS_DEFAULT_SERIAL_CONSISTENCY, copy_config.default_profile().serial_consistency()); in TEST()
H A Dtest_client_insights.cpp201 CassConsistency serial_consistency = CASS_CONSISTENCY_ONE; in TEST_F() local
211 config_.set_serial_consistency(serial_consistency); in TEST_F()
320 ASSERT_STREQ(cass_consistency_string(serial_consistency), in TEST_F()
588 ASSERT_STREQ(cass_consistency_string(config_.serial_consistency()), in TEST_F()
/dports/databases/p5-Protocol-CassandraCQL/Protocol-CassandraCQL-0.11/t/
H A D05frames.t133 serial_consistency => 8,
/dports/databases/p5-Protocol-CassandraCQL/Protocol-CassandraCQL-0.11/lib/Protocol/CassandraCQL/
H A DFrames.pm178 my $ser_cons = $params{serial_consistency};

12