1.29 00:36:12 increased default buffer and downgraded some messages to info level
2004/10/25 mbalazin Bug fix in datapath... there was a possibility of bug under high data rates.
Jeong-Hyon, I'm not changing the HA stuff because I assume we'll revisit it
anyways and integrate it with connection points, etc.
2004/10/25 mbalazin Making the DataPath slow down if downstream nodes cannot keep up.
2004/10/22 mbalazin - SUnion and SOutput now both inherit from an SControlQBox that holds all
the common stuff for boxes with an output control stream
- ConsistencyMngr now listens for inputs from both types of control streams.
- SOutput signals when reconciliation is completed (instead of SUnion)
- Also bug fix when suspending data path.. cannot suspend it completely
or control messages don't get through
2004/10/22 mbalazin Starting to have Borealis nodes collaborate to handle clients while reconciling their states.
2004/09/27 mbalazin Added a ConsistencyMngr class to the QueryProcessor. This class manages the consistency of the state of the query network in case of failures and network partitions. If you don't care about any of this, you should not see any difference. Nothing happens unless a query network uses an sunion operator.
2004/09/20 mbalazin - Fixed race condition in AuroraNode.
Race was between: unsubscribing and deleting a stream (because
unsubscribe gets scheduled and executed sometime later).
- Modified "subscribe" for consistency between sub/unsub.
- Adjusted DataPath because no workaround needed anymore
2004/08/26 mbalazin Updated stream management:
- One can now subscribe to input streams. Even when no query network uses the stream.
- Moving subsets of boxes that depend on one another works (streams get forwarded correctly). Not all cominations, though.
- Updated our computations of query hunks that depend on streams. Consolidated that in query setup and deletion.
Removed stale concept of streams being "owned"... using their location instead.
Other small clean ups.
2004/08/24 mbalazin Making Anurag happy ;-) ... removed duplicate class Stream.
Most of what used to be in Borealis::Stream is now in Borealis::StreamState
The tuple buffer is now in a new class called queryProcessor/StreamBuffer/
This required updates in QueryProcessor and DataPath
Also, in DataPath, renamed all m_input_streams into m_input_paths
and m_output_streams into m_output_paths. That way, when we talk about
these streams, we will distinguish the inputs and output of query hunks
(or superoperators) and the inputs and outputs of a node. Adjusted
a few method names as well.
2004/08/19 mbalazin - Added a missing include in QOSOptimizer.h (for RPCs)
Bunch of changes mostly for connection points:
- Made CPViewDescriptions be Objects and use Name as unique id (instead of string
so that caused a few method signatures to change)
- Decoupled CPViewDescriptions from Stream
- My class Stream will go away in the meantime, I renamed the files to be MStream.* to avoid confusion in includes
- Connection points are now registered in the catalog.
2004/08/12 yna Fixed box state movement, and internal box movement.
2004/06/25 mbalazin Removing outgoing data paths when removing streams and queries so when we move something back, we don't have duplicate outgoing datapaths anymore
2004/06/03 mbalazin Small things... committing to synch.
2004/06/03 mbalazin last_input_tuples()
and last_output_tuples()
2004/06/02 jhhwang Updates for passive standby. Needs more work yet.
2004/06/02 mbalazin Sending stream events after they were checkpointed
2004/06/02 mbalazin Modifying the we we're going to send history after checkpoints
2004/06/02 mbalazin Parameters for checkpoint messages
2004/06/02 jhhwang changes for passive standby
2004/05/31 mbalazin When starting, the HA module tells the QueryProcessor module:
- the recovery method to use
- the primary status (true/false)... this status can change later
- the list of secondaries
2004/05/31 mbalazin Decoupling such that QueryProcessor/DataPath do not invoke methods directly on the HA module but rather send the HA module a message on its input queue.
I agree that this is extra overhead but this is the current architecture.
Given the tight coupling between DataPath, QueryProcessor, and HA we should probably put all these three classes in a single module under a single BasicComponent.
This code is not tested but it compiles... I'm going to test it now
2004/05/29 jhhwang Not a big deal.
2004/05/29 mbalazin Just a precaution to avoid possible race conditions in the network partitions demo
2004/05/26 mbalazin Got duplicate elimination to work!
2004/05/25 mbalazin - Modified subscriptions so they can specify the first history tuple that a clients desires.
- Adjusted stream buffering accordingly
2004/05/25 mbalazin Upstream backup simple version with ACK0 and ACK1
2004/05/21 mbalazin Allowing clients to subscribe with the option to get the history replay or not
2004/05/21 mbalazin We've got simple Rollback recovery!
- Basic HA demo now shows the simplest form of upstream backup
- Network partitions are handled by hot-swapping upstream node for another replica and by replaying history (no tuple loss unless going too fast for buffer size of course)
2004/05/14 mbalazin - Removed the slow data path completely
- Merged AuroraQueryProcessor with QueryProcessor since the latter was
mainly taking care of the slow data path
- Renamed AuroraGateway to DataPath because it is more accurate
- Got rid of SimpleReader, SimpleWriter, and SimpleAdmin because
they were using the slow datapath
