mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-29 20:57:00 +00:00
Code Issues Packages Projects Releases Wiki Activity
7,559 Commits 241 Branches 541 Tags
branch-0.13
Commit Graph

21 Commits

Author SHA1 Message Date
Avi Kivity
d5cf0fb2b1 Add license notices 2015-09-20 10:43:39 +03:00
Asias He
1828019d60 streaming: Convert StreamManager.java to C++ 2015-07-14 20:41:14 +08:00
Asias He
85d9204d0e streaming: Drop connection_handler 
stream_session::stream_session(inet_address peer_, inet_address connecting_,
    int index_, bool keep_ss_table_level_)
    : peer(peer_)
    , connecting(connecting_)
    , conn_handler(shared_from_this())

Calling shared_from_this() inside stream_session's constructor is
problematic. I got

   Exiting on unhandled exception of type 'std::bad_weak_ptr': bad_weak_ptr

exceptions, with

   auto session = std::make_shared<stream_session>(peer, connecting, size, _keep_ss_table_level)

Also, the logic in connection_handler is not very useful for us. The
sending and receiving of messages are handled using messaging_service.
There is no need to add another layer.
 2015-07-14 20:41:14 +08:00
Asias He
60449c4b59 streaming: Convert StreamResultFuture to C++ 2015-06-30 16:00:56 +08:00
Asias He
573e96c4c2 streaming: Convert StreamState.java to C++ 2015-06-24 16:13:30 +08:00
Asias He
90b9d6294f streaming: Convert CompressionInfo.java to C++ 2015-06-23 16:06:28 +08:00
Asias He
a794dd28e1 streaming: Convert ConnectionHandler.java to C++ 2015-06-19 15:29:13 +08:00
Asias He
04fa228091 streaming: Convert StreamEventHandler.java to C++ 2015-06-19 15:11:35 +08:00
Asias He
6707c9f8af streaming: Convert StreamEvent.java to C++ 2015-06-19 15:07:22 +08:00
Asias He
b315e6505a streaming: Convert StreamTask to C++ 2015-06-18 14:55:07 +08:00
Asias He
ea0b6931b0 streaming: Convert StreamSession.java to C++ 2015-06-17 16:08:37 +08:00
Asias He
6e83f70954 streaming: Convert SessionFailedMessage.java to C++ 2015-06-17 13:37:52 +08:00
Asias He
e86d3d7712 streaming: Convert RetryMessage.java to C++ 2015-06-17 13:37:52 +08:00
Asias He
a277df83ad streaming: Convert ReceivedMessage.java to C++ 2015-06-17 13:37:52 +08:00
Asias He
61081ce816 streaming: Convert PrepareMessage.java to C++ 2015-06-17 13:37:52 +08:00
Asias He
22346102b7 streaming: Convert FileMessageHeader.java to C++ 2015-06-17 13:37:52 +08:00
Asias He
35ccd02db3 streaming: Convert OutgoingFileMessage.java to C++ 2015-06-17 13:37:52 +08:00
Asias He
edbae6a542 streaming: Convert IncomingFileMessage.java to C++ 2015-06-17 13:37:52 +08:00
Asias He
be31293d61 streaming: Convert CompleteMessage.java to C++ 2015-06-17 13:37:52 +08:00
Asias He
082aeab0a7 streaming: Convert StreamInitMessage.java to C++ 2015-06-17 13:37:52 +08:00
Asias He
15a1d71049 streaming: Convert StreamMessage.java to C++ 2015-06-17 13:37:52 +08:00