Commit Graph

  • 4a7ef682ab streaming: Use stream_session_state Asias He 2015-06-24 11:44:25 +08:00
  • 5c7aac3da9 streaming: Add stream_session_state Asias He 2015-06-24 11:42:53 +08:00
  • 8b3d5b2da0 streaming: Reduce dependency to stream_session in connection_handler Asias He 2015-06-24 11:40:49 +08:00
  • 827b332a31 streaming: Move has_active_sessions to source file Asias He 2015-06-24 10:56:23 +08:00
  • 189b2515e0 streaming: Add is_empty to stream_plan Asias He 2015-06-24 10:50:42 +08:00
  • ed27012503 streaming: Add has_active_sessions to stream_coordinator Asias He 2015-06-24 10:50:08 +08:00
  • 934c17fa6b streaming: Add set_state and get_state to stream_session() Asias He 2015-06-24 10:47:28 +08:00
  • 6619122b35 streaming: Add _coordinator to stream_plan Asias He 2015-06-24 10:31:09 +08:00
  • 573e96c4c2 streaming: Convert StreamState.java to C++ Asias He 2015-06-24 09:44:38 +08:00
  • 15da955766 streaming: Import StreamState.java Asias He 2015-06-24 09:44:04 +08:00
  • bb40fed991 streaming: Add add_transfer_file to stream_transfer_task Asias He 2015-06-23 17:22:29 +08:00
  • 27b0200912 tests: don't mix up stdout and the xml log Avi Kivity 2015-06-24 07:21:05 +03:00
  • 5d4f533e14 streaming: Add constructor for outgoing_file_message Asias He 2015-06-23 17:23:38 +08:00
  • 8ecacca2a9 streaming: Add keep_ss_table_level to stream_session Asias He 2015-06-23 17:23:07 +08:00
  • fd6ec4a7ca database: fix sstables exception Glauber Costa 2015-06-23 20:57:53 -04:00
  • d6b14c967f db: flush system tables to disk Glauber Costa 2015-06-17 16:32:32 -04:00
  • a6ef9815e9 database: futurize seal_active_memtables Glauber Costa 2015-06-23 14:58:01 -04:00
  • b35d1412c4 Merge "Compaction metadata" from Raphael Avi Kivity 2015-06-23 21:22:54 +03:00
  • 83d4a47a21 stop using get() / get0() arbitrarily Glauber Costa 2015-06-23 14:13:06 -04:00
  • 1a515ca807 Merge "CQL3 validation: keyspace and table creation" from Paweł Avi Kivity 2015-06-23 21:07:56 +03:00
  • 0f95066be4 sstables: fix a bug which invalidated generated sstables Raphael S. Carvalho 2015-06-22 12:53:52 -03:00
  • f831d1bce9 sstables: add support to generate compaction metadata Raphael S. Carvalho 2015-06-22 12:09:23 -03:00
  • 954688b327 hyperloglog: modify it according to our needs Raphael S. Carvalho 2015-06-23 12:01:50 -03:00
  • 2c95fdd7b6 sstables: import hyperloglog implementation Raphael S. Carvalho 2015-06-23 11:25:23 -03:00
  • 0d345dfd32 sstables: extend metadata collector to add ancestors Raphael S. Carvalho 2015-06-17 14:53:54 -03:00
  • 3addb285cd tests/cql: test validation of keyspace and table creation requests Paweł Dziepak 2015-06-22 09:58:42 +02:00
  • 26ff34060d tests/cql: add assert_that_failed() Paweł Dziepak 2015-06-22 09:58:18 +02:00
  • 67551832c0 cql3: implement displayRecogintionError for lexer and parser Paweł Dziepak 2015-06-23 15:26:18 +02:00
  • 0369d169cc cql3: validate name and columns of the created table Paweł Dziepak 2015-06-22 09:57:44 +02:00
  • 3e760454d5 cql3: validate properties of newly created tables Paweł Dziepak 2015-06-22 09:57:01 +02:00
  • 3806f0e268 cql3: validate the name of the created keyspace Paweł Dziepak 2015-06-22 09:56:09 +02:00
  • c5e617ea78 schema: add NAME_LENGTH constant Paweł Dziepak 2015-06-22 09:54:44 +02:00
  • 7de8f2cda8 cql3: validate properties at keyspace creation Paweł Dziepak 2015-06-22 09:54:10 +02:00
  • cb8f8f84be cql3: make property_definitions::validate() take const references Paweł Dziepak 2015-06-22 09:53:20 +02:00
  • de23b54764 types: Implement to_string()/from_string() for boolean_type Tomasz Grabiec 2015-06-23 16:05:28 +02:00
  • efe1696410 cql_test_env: Start the global snitch before storage service Vlad Zolotarov 2015-06-23 16:32:41 +03:00
  • 20b86ea839 Merge seastar upstream Avi Kivity 2015-06-23 15:57:09 +03:00
  • 12f3d53372 storage_proxy: cleanup leftovers from timer consolidation Gleb Natapov 2015-06-23 15:25:11 +03:00
  • 2be9dfc242 storage_proxy: use fb_utilities::get_broadcast_address() Gleb Natapov 2015-06-23 15:25:10 +03:00
  • 67ea1b0ec8 Revert "db: hold onto write response handler until timeout handler is executed" Gleb Natapov 2015-06-23 15:25:09 +03:00
  • 20e7e3576e Merge "Introduce simple cache" from Tomasz Avi Kivity 2015-06-23 15:30:21 +03:00
  • d4e0e5957b db: Integrate cache with the read path Tomasz Grabiec 2015-06-20 22:04:48 +02:00
  • d11773bc14 tests: Introduce row cache test Tomasz Grabiec 2015-06-23 11:46:42 +02:00
  • 2b5d9a917f tests: Convert mutation_reader_test to use seastar threads Tomasz Grabiec 2015-06-23 11:43:54 +02:00
  • e40638823e db: Introduce mutation cache Tomasz Grabiec 2015-06-20 20:31:18 +02:00
  • b9288d9fa7 db: Make column_family managed by lw_shared_ptr<> Tomasz Grabiec 2015-06-20 10:44:10 +02:00
  • 8fd466338d mutation_reader: Introduce helper for consuming all mutations Tomasz Grabiec 2015-06-20 17:38:49 +02:00
  • 83e7a21dfb mutation: Add apply() helper which works on mutation_opt Tomasz Grabiec 2015-06-19 12:13:52 +02:00
  • bdd3fd5019 tests: Add missing blank line Tomasz Grabiec 2015-06-19 15:17:13 +02:00
  • c9909dd183 cluster: consolidate mutation clustering timers Gleb Natapov 2015-06-23 14:40:03 +03:00
  • 14a8110d1f future: Avoid copying of the result in get0() Tomasz Grabiec 2015-06-23 12:02:23 +02:00
  • 5e1348e741 storage_service: Use get_local_snitch_ptr in gossip_snitch_info Asias He 2015-06-23 16:51:58 +08:00
  • 51eb220c49 Merge "stream reader and writer" from Asias Avi Kivity 2015-06-23 11:31:10 +03:00
  • 0f8c35a2fe streaming: Convert StreamReader.java to C++ Asias He 2015-06-23 14:53:31 +08:00
  • 9456fb3935 streaming: Import StreamReader.java Asias He 2015-06-23 14:52:57 +08:00
  • 4f8a1041ce streaming: Convert StreamWriter.java to C++ Asias He 2015-06-23 14:53:54 +08:00
  • 5f4293b379 streaming: Import StreamWriter.java Asias He 2015-06-23 14:52:18 +08:00
  • fe61c0d8d4 streaming: Convert more of file_message_header.hh Asias He 2015-06-23 14:00:10 +08:00
  • 90b9d6294f streaming: Convert CompressionInfo.java to C++ Asias He 2015-06-23 14:01:06 +08:00
  • b3b2d26305 streaming: Import CompressionInfo.java Asias He 2015-06-23 14:00:30 +08:00
  • 792a19d40d Merge "global snitch" from Vlad Avi Kivity 2015-06-23 10:49:30 +03:00
  • cbd0be5a68 Merge seastar upstream Avi Kivity 2015-06-23 10:46:39 +03:00
  • f458d6c54a tests: generate seperate boost xml output files Shlomi Livne 2015-06-23 10:16:12 +03:00
  • c214b3bff9 Merge "initial compaction support" from Nadav Avi Kivity 2015-06-23 09:49:08 +03:00
  • 9f7794752f sstables: basic compaction test Nadav Har'El 2015-06-23 00:36:35 +03:00
  • f26dae3bf9 sstable: basic compaction function Nadav Har'El 2015-06-23 00:36:34 +03:00
  • 6063d4502f sstable: method for estimating number of partitions in sstable Nadav Har'El 2015-06-23 00:36:33 +03:00
  • 319491dad7 gossiping_property_file_snitch_test: check that the distribution Vlad Zolotarov 2015-06-17 21:45:23 +03:00
  • 67bb1ba132 gossiping_property_file_snitch: Register creators for all parameters set options. Vlad Zolotarov 2015-06-17 20:57:36 +03:00
  • 3520d4de10 locator: introduce a global distributed<snitch_ptr> i_endpoint_snitch::snitch_instance() Vlad Zolotarov 2015-06-21 13:00:30 +03:00
  • 6ce39d8399 tests: move a semaphore test from futures_test to semaphore_test Avi Kivity 2015-06-22 19:14:05 +03:00
  • a7d612f196 schema tables: add missing columns Glauber Costa 2015-06-22 12:05:00 -04:00
  • 0eb8d7384a Reduce partitioner's dependencies on sstables/*.hh Avi Kivity 2015-06-22 18:56:44 +03:00
  • 04a25474e4 tombstone: make its print operator nicer Avi Kivity 2015-06-22 17:48:13 +03:00
  • 78add789c3 Merge "Fix bug with old sstable" from Glauber Avi Kivity 2015-06-22 18:23:16 +03:00
  • b008f8cf06 sstables: test table with wrong marker Glauber Costa 2015-06-19 07:51:00 -04:00
  • 6336c02cab sstables: fix bug with old sstable Glauber Costa 2015-06-19 12:33:16 -04:00
  • 118e4fc8be sstable: make do_write_components more pleasant to read Raphael S. Carvalho 2015-06-22 10:21:28 -03:00
  • b8db713b81 service: Increase write timeout to 2 seconds Tomasz Grabiec 2015-06-22 14:43:21 +02:00
  • acb56b580f abstract_replication_strategy: work around missing _snitch in cql_query_test Avi Kivity 2015-06-22 15:28:22 +03:00
  • ddc84f3459 Merge "Adding the stroage_proxy API" from Amnon Avi Kivity 2015-06-22 14:54:17 +03:00
  • de26b3a75c Merge "Update system keyspace rs to local_strategy" from Shlomi Avi Kivity 2015-06-22 14:27:57 +03:00
  • b3e4094e11 Updating setting of system keyspace strategy to be local_strategy Shlomi Livne 2015-06-22 00:25:48 +03:00
  • 36ab6c1a5a Changing order of database and storage_service initialization Shlomi Livne 2015-06-22 13:18:14 +03:00
  • 0ce374a853 Add support for setting keyspace replication_strategy Shlomi Livne 2015-06-22 00:23:03 +03:00
  • afe0f7dc85 Add support for local_strategy Shlomi Livne 2015-06-22 00:21:12 +03:00
  • ab7be2890f core: rename distributed<Service> to seastar::sharded<Service> Avi Kivity 2015-06-22 00:14:37 +03:00
  • 9ea9626bdf Merge seastar upstream Avi Kivity 2015-06-22 12:51:01 +03:00
  • b879fabf36 reactor: block SIGALRM while we're still not ready to handle it Avi Kivity 2015-06-22 12:48:50 +03:00
  • 7859f5a421 Merge seastar upstream Avi Kivity 2015-06-22 10:45:06 +03:00
  • 6d09819d1d Merge "repeat" from Tomasz Avi Kivity 2015-06-22 10:38:55 +03:00
  • ea274a0eda locator: Fix a typo in a token_metadata constructor Vlad Zolotarov 2015-06-21 18:54:17 +03:00
  • e5e7348f76 core: Reimplement keep_doing() using repeat() Tomasz Grabiec 2015-06-20 19:03:21 +02:00
  • 61992f84c5 core: Introduce repeat() Tomasz Grabiec 2015-06-20 11:24:51 +02:00
  • 00e9f9e06a sstables: don't use size_t for on-disk sizes Nadav Har'El 2015-06-22 02:01:14 +03:00
  • bd3044a38d do_with: doc: mark cherry_pick_tuple as internal Avi Kivity 2015-06-21 23:36:42 +03:00
  • 646c31e596 sstables: take generic mutation_reader instead of memtable Nadav Har'El 2015-06-21 23:16:38 +03:00
  • 5367a0fb8b doc: unhide static functions Avi Kivity 2015-06-21 23:27:33 +03:00
  • 6975be8e12 Merge seastar upstream Avi Kivity 2015-06-21 21:16:48 +03:00
  • 9679075b30 shared_mutex: reinstate FIFO ordering Avi Kivity 2015-06-21 20:54:53 +03:00