Commit Graph

  • 8fd8f39d63 streaming: Add more debug info for message exchange Asias He 2015-07-13 10:52:55 +08:00
  • ca7f5ca5c9 streaming: Set proper dst_cpu_id in shard_id for PREPARE_MESSAGE and STREAM_MUTATION Asias He 2015-07-13 11:16:12 +08:00
  • 845de56614 streaming: Fix handler of PREPARE_MESSAGE Asias He 2015-07-13 10:07:20 +08:00
  • 0282d4d6d0 streaming: Start stream_manager on startup Asias He 2015-07-13 08:33:04 +08:00
  • 8734213890 streaming: Lookup session Asias He 2015-07-10 17:39:39 +08:00
  • fd04337e80 streaming: Wire up register_receiving init_receiving_side Asias He 2015-07-10 17:10:08 +08:00
  • d1720ffed1 streaming: Hold a shared_ptr inside stream_plan Asias He 2015-07-10 17:00:58 +08:00
  • 1828019d60 streaming: Convert StreamManager.java to C++ Asias He 2015-07-10 15:59:03 +08:00
  • 692c5b4c40 streaming: Import StreamManager.java Asias He 2015-07-10 15:58:14 +08:00
  • f1cab93212 streaming: Return empty prepare_message for now Asias He 2015-07-10 15:50:30 +08:00
  • 38ee079916 streaming: Add test helper function Asias He 2015-07-10 15:45:53 +08:00
  • 01aa42ddca streaming: Add streaming_debug Asias He 2015-07-10 15:42:37 +08:00
  • 285d1907ef streaming: Fix Assertion _instances.empty() failed Asias He 2015-07-10 14:49:28 +08:00
  • 85d9204d0e streaming: Drop connection_handler Asias He 2015-07-10 11:22:02 +08:00
  • 0f2bc82f82 streaming: Fix stream_init_message destination Asias He 2015-07-09 15:18:01 +08:00
  • 14ae9e66ae streaming: Use shared_ptr to track back to stream_session Asias He 2015-07-09 14:38:55 +08:00
  • 5ffb946dac streaming: futurize stream_session::on_initialization_complete Asias He 2015-07-08 10:46:15 +08:00
  • a0cb90fe67 logger: add API to convert log_level to/from iostream Avi Kivity 2015-07-14 15:19:33 +03:00
  • 6ef552ef34 logger: add registry APIs to manage loggers Avi Kivity 2015-07-14 14:51:41 +03:00
  • c065623da5 logger: add APIs to set and retrieve the log level Avi Kivity 2015-07-14 14:48:53 +03:00
  • 7fbe154a26 token_metadata: add include_min handling in tokens_iterator Gleb Natapov 2015-07-06 16:12:09 +03:00
  • 49fb10d640 improve token printout Gleb Natapov 2015-07-08 17:27:56 +03:00
  • c037666491 stroage_proxy: fix response_id moving in send_to_live_endpoints() Gleb Natapov 2015-07-02 16:53:52 +03:00
  • d36041d654 Merge seastar upstream Avi Kivity 2015-07-14 11:57:55 +03:00
  • 53745dc357 Adding a void_json object to the json_elements Amnon Heiman 2015-07-02 08:33:54 +03:00
  • 4b1fd3d48d Merge "Set currently commented out properties for system tables" from Glauber Avi Kivity 2015-07-14 10:52:22 +03:00
  • 6024e9489a Merge seastar upstream Avi Kivity 2015-07-14 10:52:00 +03:00
  • 7b355a6a02 json-api: Add an assignment operator to the json_list obj Amnon Heiman 2015-07-14 09:40:33 +03:00
  • 62364fcdd7 sstring: add compare method for parts of a sstring Glauber Costa 2015-07-13 22:06:07 -04:00
  • 5ac6ed72f4 system tables: set default ttl according to Origin settings Glauber Costa 2015-07-13 23:47:24 -04:00
  • 7b1b8f0e09 system tables: set gc grace period according to Origin settings Glauber Costa 2015-07-13 22:06:37 -04:00
  • 39ca76fd03 schema: allow for the setting of default time to live Glauber Costa 2015-07-13 23:37:34 -04:00
  • 5165e8b439 schema: allow for the setting of gc grace period Glauber Costa 2015-07-13 21:59:09 -04:00
  • 62babd6b39 Merge seastar upstream Avi Kivity 2015-07-13 19:09:36 +03:00
  • 66451d5a9c tcp: fix assertion failure on connection reset Avi Kivity 2015-07-13 19:05:01 +03:00
  • 0171dfbf81 tests: drop http server from messaging test Avi Kivity 2015-07-13 13:20:56 +03:00
  • f2502ae1ad row_cache: Value-initialize stats Tomasz Grabiec 2015-07-13 11:47:19 +02:00
  • bfe9d21808 Merge "Adding the storage proxy metrics" from Amnon Avi Kivity 2015-07-13 11:55:50 +03:00
  • e03b26ef9b Merge "Cleanup storage_proxy::query_local()" from Tomasz Avi Kivity 2015-07-13 11:35:50 +03:00
  • d4ec9d9566 system_keyspace: Remove the out-of-date comment from query() Tomasz Grabiec 2015-07-13 10:25:40 +02:00
  • 9aed3fdbfc system_keyspace: Simplify query() by using partition_slice_builder Tomasz Grabiec 2015-07-13 10:22:59 +02:00
  • bc0874d299 db: Move storage_proxy::query_local() to db::system_keyspace::query() Tomasz Grabiec 2015-07-13 10:01:27 +02:00
  • f3adc5b729 drop unneeded && qualifier from query::result_merger::get() Gleb Natapov 2015-07-12 13:17:33 +03:00
  • 38cf77b16b transport: use begin() and end() instead of sstring_view::data() Paweł Dziepak 2015-07-13 09:00:53 +02:00
  • 06df13b091 API: Adding an implementation to storage_proxy counters Amnon Heiman 2015-07-12 14:02:48 +03:00
  • dfc7121fd8 API: Add a helper function to sum stat values of a distributed objec Amnon Heiman 2015-07-12 14:11:33 +03:00
  • d0ce45efbb API: Add a reference to storage_proxy into API context Amnon Heiman 2015-07-12 14:10:56 +03:00
  • 0eeef904d7 Storage proxy: Adding a stats object Amnon Heiman 2015-07-12 13:55:26 +03:00
  • b89c54df9d query::range: fix call to internal deserialized_size() template Avi Kivity 2015-07-12 21:05:55 +03:00
  • 1072a960e7 build: avoid false positive warning on gcc 5 Avi Kivity 2015-07-12 20:55:49 +03:00
  • d162922e03 core: simplify do_flush_directory Glauber Costa 2015-07-12 12:57:04 -04:00
  • 8a50b3d9ba main: be more explicit about make directory errors Avi Kivity 2015-07-12 19:38:59 +03:00
  • 322b1c30dd main: make sure data directory exists before proceeding Glauber Costa 2015-07-12 12:12:48 -04:00
  • d9a4645e24 Merge seastar upstream Avi Kivity 2015-07-12 19:13:52 +03:00
  • 2a622304ed file: make files copyable Avi Kivity 2015-07-12 18:11:46 +03:00
  • 50e2f24dfa core: add recursive_touch directory Glauber Costa 2015-07-12 10:54:44 -04:00
  • 8c7bcf52e2 Merge seastar upstream Avi Kivity 2015-07-12 17:06:14 +03:00
  • c84b6a948f Merge "fstream optimizations" Avi Kivity 2015-07-12 16:56:01 +03:00
  • 35f29dcdb4 fstream: add read-until-end tests without knowning the file size beforehand Avi Kivity 2015-07-12 13:24:01 +03:00
  • 7684f2f541 Merge "Add ByteOrderedPartitioner" from Paweł Avi Kivity 2015-07-12 16:20:19 +03:00
  • 83bbd87966 storage_proxy: simplify net::messaging_verb::READ_DATA handler Gleb Natapov 2015-07-12 16:15:19 +03:00
  • 67d494c4ee storage_proxy: fix waiting_for to check for local dataceneter Gleb Natapov 2015-07-12 16:15:18 +03:00
  • 351b113913 dht: allow configuration file to choose partitioner Paweł Dziepak 2015-07-12 15:13:39 +02:00
  • 82b621b857 Merge "Fix insert statement to preperly handle tables without clustering key" from Tomasz Avi Kivity 2015-07-12 16:14:13 +03:00
  • 18c48dbb14 tests: Add test for inserting a row without setting any regular column Tomasz Grabiec 2015-07-12 14:49:34 +02:00
  • 28c1c3eaf1 tests: Use 'update' instead of 'insert' in test_ttl Tomasz Grabiec 2015-07-12 14:45:29 +02:00
  • 05e2e9d5ea cql: Fix 'insert' statement not creating row marker for non-clustered tables Tomasz Grabiec 2015-07-12 14:26:43 +02:00
  • ddc98ac45d Merge "Mutation query interface" Avi Kivity 2015-07-12 15:17:37 +03:00
  • 3dd694b8c6 API: Adding a stub implementation to the storage_proxy Amnon Heiman 2015-07-12 09:57:49 +03:00
  • c82b89a8b0 Adding the metrics definition to the storage_proxy Amnon Heiman 2015-07-12 09:54:31 +03:00
  • 674dfdcf25 tests: Test consistent ordering of partitions in range queries Tomasz Grabiec 2015-07-11 18:48:21 +02:00
  • e35854b33c storage_proxy: Preserve partition order in range queries Tomasz Grabiec 2015-07-11 13:59:38 +02:00
  • ad99e84505 storage_proxy: Take schema_ptr in query() Tomasz Grabiec 2015-07-11 13:24:27 +02:00
  • 5b332c6f7c messaging_service: Add RPC call for mutation queries. Tomasz Grabiec 2015-07-07 14:06:38 +02:00
  • 4931d3fdcd storage_proxy: Implement query_mutations_locally() Tomasz Grabiec 2015-07-11 13:58:04 +02:00
  • 82a61e92fa messaging_service: Use generic serializer adaptor for frozen_mutation Tomasz Grabiec 2015-07-11 13:53:16 +02:00
  • 0573844deb messaging_service: Add adaptors for types having db::serializer<> Tomasz Grabiec 2015-07-11 13:44:42 +02:00
  • e865740abe messaging_service: Extract integral reading logic Tomasz Grabiec 2015-07-07 14:05:53 +02:00
  • 9f789602e8 db/serializer: Implement read() with output parameter variant for frozen_mutation Tomasz Grabiec 2015-07-11 13:55:35 +02:00
  • 2ae6e91956 keys: Make comparators work on views rather than const& Tomasz Grabiec 2015-07-11 13:42:24 +02:00
  • 6f5c00c515 tests: Add test for mutation queries Tomasz Grabiec 2015-07-08 17:15:41 +02:00
  • 9bea6aa0a3 db: Introduce mutation query interface Tomasz Grabiec 2015-07-11 14:12:29 +02:00
  • 8ba0d6729e frozen_mutation: Add copy constructor and assignment operator Tomasz Grabiec 2015-07-11 13:41:30 +02:00
  • 7356024dde mutation_partition: Introduce compact_for_query() Tomasz Grabiec 2015-07-03 17:52:27 +02:00
  • 4a1bf56b48 types: Introduce collection_type_impl::mutation::compact_and_expire() Tomasz Grabiec 2015-07-08 16:42:05 +02:00
  • 9c6dd8b724 Merge "Fix CQL index name case sensitivity" from Pekka Avi Kivity 2015-07-12 12:45:26 +03:00
  • 98c38a7c4b Merge "Query path bug fixes and cleanups" from Tomasz Avi Kivity 2015-07-12 11:41:54 +03:00
  • d3a83aa549 sstables: finish streaming_histogram::update Raphael S. Carvalho 2015-07-10 19:31:45 -03:00
  • 7827d89443 Merge tag 'schema_properties-v2' from git@github.com:glommer/urchin.git schema_properties-v2 Tomasz Grabiec 2015-07-10 19:40:08 +03:00
  • fe370ec848 schema: read_repair_chance Glauber Costa 2015-07-09 18:22:45 -04:00
  • ea17f6d76f schema: max and min index interval Glauber Costa 2015-07-08 16:45:25 -04:00
  • aa270a149f schema: compaction strategy Glauber Costa 2015-07-08 16:26:00 -04:00
  • b75bd9ef53 schema: add local_repair_chance parameter Glauber Costa 2015-07-08 16:20:20 -04:00
  • 8218c819a5 schema: access gc_grace_seconds Glauber Costa 2015-07-08 15:02:14 -04:00
  • f84148c335 schema: support cf type, and is_super Glauber Costa 2015-07-08 14:51:29 -04:00
  • c820078916 cql3/Cql.g: Fix index name case sensitivity Pekka Enberg 2015-07-10 11:01:44 +03:00
  • c73d4cba16 system_keyspaces: update hints dropped Glauber Costa 2015-07-09 18:01:49 -04:00
  • 0bf09f6af8 system_keyspace: implement update_preferred_ip Glauber Costa 2015-07-09 18:01:48 -04:00
  • fe154efffe system_keyspace: implement (remote) update_tokens Glauber Costa 2015-07-09 18:01:47 -04:00
  • 31f4601329 system_keyspace: remove duplication for blocking flush Glauber Costa 2015-07-09 17:21:48 -04:00