[jira] [Updated] (CASSANDRA-15665) StreamManager should clearly differentiate between "initiator" and "receiver" sessions
[ https://issues.apache.org/jira/browse/CASSANDRA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benjamin Lerer updated CASSANDRA-15665: --- Fix Version/s: (was: 4.0) 4.0-alpha5 Since Version: 4.0-alpha1 Source Control Link: https://github.com/apache/cassandra/commit/ebba613b0b34ea338eed508a3ba6cbb235986fd9 Resolution: Fixed Status: Resolved (was: Ready to Commit) Committed into trunk at ebba613b0b34ea338eed508a3ba6cbb235986fd9 > StreamManager should clearly differentiate between "initiator" and "receiver" > sessions > -- > > Key: CASSANDRA-15665 > URL: https://issues.apache.org/jira/browse/CASSANDRA-15665 > Project: Cassandra > Issue Type: Bug > Components: Legacy/Streaming and Messaging >Reporter: Sergio Bossa >Assignee: ZhaoYang >Priority: Normal > Fix For: 4.0-alpha5 > > > {{StreamManager}} does currently a suboptimal job in differentiating between > stream sessions (in form of {{StreamResultFuture}}) which have been either > initiated or "received", for the following reasons: > 1) Naming is IMO confusing: a "receiver" session could actually both send and > receive files, so technically an initiator is also a receiver. > 2) {{StreamManager#findSession()}} assumes we should first looking into > "initiator" sessions, then into "receiver" ones: this is a dangerous > assumptions, in particular for test environments where the same process could > work as both an initiator and a receiver. > I would recommend the following changes: > 1) Rename "receiver" with "follower" everywhere the former is used. > 2) Introduce a new flag into {{StreamMessageHeader}} to signal if the message > comes from an initiator or follower session, in order to correctly > differentiate and look for sessions in {{StreamManager}}. > While my arguments above might seem trivial, I believe they will improve > clarity and save from potential bugs/headaches at testing time, and doing > such changes now that we're revamping streaming for 4.0 seems the right time. -- This message was sent by Atlassian Jira (v8.3.4#803005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-15665) StreamManager should clearly differentiate between "initiator" and "receiver" sessions
[ https://issues.apache.org/jira/browse/CASSANDRA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benjamin Lerer updated CASSANDRA-15665: --- Reviewers: Benjamin Lerer (was: Benjamin Lerer, Sergio Bossa) > StreamManager should clearly differentiate between "initiator" and "receiver" > sessions > -- > > Key: CASSANDRA-15665 > URL: https://issues.apache.org/jira/browse/CASSANDRA-15665 > Project: Cassandra > Issue Type: Bug > Components: Legacy/Streaming and Messaging >Reporter: Sergio Bossa >Assignee: ZhaoYang >Priority: Normal > Fix For: 4.0 > > > {{StreamManager}} does currently a suboptimal job in differentiating between > stream sessions (in form of {{StreamResultFuture}}) which have been either > initiated or "received", for the following reasons: > 1) Naming is IMO confusing: a "receiver" session could actually both send and > receive files, so technically an initiator is also a receiver. > 2) {{StreamManager#findSession()}} assumes we should first looking into > "initiator" sessions, then into "receiver" ones: this is a dangerous > assumptions, in particular for test environments where the same process could > work as both an initiator and a receiver. > I would recommend the following changes: > 1) Rename "receiver" with "follower" everywhere the former is used. > 2) Introduce a new flag into {{StreamMessageHeader}} to signal if the message > comes from an initiator or follower session, in order to correctly > differentiate and look for sessions in {{StreamManager}}. > While my arguments above might seem trivial, I believe they will improve > clarity and save from potential bugs/headaches at testing time, and doing > such changes now that we're revamping streaming for 4.0 seems the right time. -- This message was sent by Atlassian Jira (v8.3.4#803005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-15665) StreamManager should clearly differentiate between "initiator" and "receiver" sessions
[ https://issues.apache.org/jira/browse/CASSANDRA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benjamin Lerer updated CASSANDRA-15665: --- Status: Ready to Commit (was: Review In Progress) > StreamManager should clearly differentiate between "initiator" and "receiver" > sessions > -- > > Key: CASSANDRA-15665 > URL: https://issues.apache.org/jira/browse/CASSANDRA-15665 > Project: Cassandra > Issue Type: Bug > Components: Legacy/Streaming and Messaging >Reporter: Sergio Bossa >Assignee: ZhaoYang >Priority: Normal > Fix For: 4.0 > > > {{StreamManager}} does currently a suboptimal job in differentiating between > stream sessions (in form of {{StreamResultFuture}}) which have been either > initiated or "received", for the following reasons: > 1) Naming is IMO confusing: a "receiver" session could actually both send and > receive files, so technically an initiator is also a receiver. > 2) {{StreamManager#findSession()}} assumes we should first looking into > "initiator" sessions, then into "receiver" ones: this is a dangerous > assumptions, in particular for test environments where the same process could > work as both an initiator and a receiver. > I would recommend the following changes: > 1) Rename "receiver" with "follower" everywhere the former is used. > 2) Introduce a new flag into {{StreamMessageHeader}} to signal if the message > comes from an initiator or follower session, in order to correctly > differentiate and look for sessions in {{StreamManager}}. > While my arguments above might seem trivial, I believe they will improve > clarity and save from potential bugs/headaches at testing time, and doing > such changes now that we're revamping streaming for 4.0 seems the right time. -- This message was sent by Atlassian Jira (v8.3.4#803005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-15665) StreamManager should clearly differentiate between "initiator" and "receiver" sessions
[ https://issues.apache.org/jira/browse/CASSANDRA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhaoYang updated CASSANDRA-15665: - Test and Documentation Plan: PR: https://github.com/apache/cassandra/pull/586 CI: [https://circleci.com/workflow-run/947320b4-3c52-4113-91ab-36d622a45e23] was: PR: https://github.com/apache/cassandra/pull/586 CI: [https://circleci.com/workflow-run/75c2ae2b-6334-4189-923f-465dc9ace240] > StreamManager should clearly differentiate between "initiator" and "receiver" > sessions > -- > > Key: CASSANDRA-15665 > URL: https://issues.apache.org/jira/browse/CASSANDRA-15665 > Project: Cassandra > Issue Type: Bug > Components: Legacy/Streaming and Messaging >Reporter: Sergio Bossa >Assignee: ZhaoYang >Priority: Normal > Fix For: 4.0 > > > {{StreamManager}} does currently a suboptimal job in differentiating between > stream sessions (in form of {{StreamResultFuture}}) which have been either > initiated or "received", for the following reasons: > 1) Naming is IMO confusing: a "receiver" session could actually both send and > receive files, so technically an initiator is also a receiver. > 2) {{StreamManager#findSession()}} assumes we should first looking into > "initiator" sessions, then into "receiver" ones: this is a dangerous > assumptions, in particular for test environments where the same process could > work as both an initiator and a receiver. > I would recommend the following changes: > 1) Rename "receiver" with "follower" everywhere the former is used. > 2) Introduce a new flag into {{StreamMessageHeader}} to signal if the message > comes from an initiator or follower session, in order to correctly > differentiate and look for sessions in {{StreamManager}}. > While my arguments above might seem trivial, I believe they will improve > clarity and save from potential bugs/headaches at testing time, and doing > such changes now that we're revamping streaming for 4.0 seems the right time. -- This message was sent by Atlassian Jira (v8.3.4#803005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-15665) StreamManager should clearly differentiate between "initiator" and "receiver" sessions
[ https://issues.apache.org/jira/browse/CASSANDRA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benjamin Lerer updated CASSANDRA-15665: --- Reviewers: Benjamin Lerer, Sergio Bossa, Benjamin Lerer (was: Benjamin Lerer, Sergio Bossa) Benjamin Lerer, Sergio Bossa, Benjamin Lerer (was: Benjamin Lerer, Sergio Bossa) Status: Review In Progress (was: Patch Available) > StreamManager should clearly differentiate between "initiator" and "receiver" > sessions > -- > > Key: CASSANDRA-15665 > URL: https://issues.apache.org/jira/browse/CASSANDRA-15665 > Project: Cassandra > Issue Type: Bug > Components: Legacy/Streaming and Messaging >Reporter: Sergio Bossa >Assignee: ZhaoYang >Priority: Normal > Fix For: 4.0 > > > {{StreamManager}} does currently a suboptimal job in differentiating between > stream sessions (in form of {{StreamResultFuture}}) which have been either > initiated or "received", for the following reasons: > 1) Naming is IMO confusing: a "receiver" session could actually both send and > receive files, so technically an initiator is also a receiver. > 2) {{StreamManager#findSession()}} assumes we should first looking into > "initiator" sessions, then into "receiver" ones: this is a dangerous > assumptions, in particular for test environments where the same process could > work as both an initiator and a receiver. > I would recommend the following changes: > 1) Rename "receiver" with "follower" everywhere the former is used. > 2) Introduce a new flag into {{StreamMessageHeader}} to signal if the message > comes from an initiator or follower session, in order to correctly > differentiate and look for sessions in {{StreamManager}}. > While my arguments above might seem trivial, I believe they will improve > clarity and save from potential bugs/headaches at testing time, and doing > such changes now that we're revamping streaming for 4.0 seems the right time. -- This message was sent by Atlassian Jira (v8.3.4#803005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-15665) StreamManager should clearly differentiate between "initiator" and "receiver" sessions
[ https://issues.apache.org/jira/browse/CASSANDRA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhaoYang updated CASSANDRA-15665: - Test and Documentation Plan: PR: https://github.com/apache/cassandra/pull/586 CI: [https://circleci.com/workflow-run/75c2ae2b-6334-4189-923f-465dc9ace240] was: CI: [https://circleci.com/workflow-run/e2e5bf69-58a9-45e7-aed7-a05ebf022c2e] > StreamManager should clearly differentiate between "initiator" and "receiver" > sessions > -- > > Key: CASSANDRA-15665 > URL: https://issues.apache.org/jira/browse/CASSANDRA-15665 > Project: Cassandra > Issue Type: Bug > Components: Legacy/Streaming and Messaging >Reporter: Sergio Bossa >Assignee: ZhaoYang >Priority: Normal > Fix For: 4.0 > > > {{StreamManager}} does currently a suboptimal job in differentiating between > stream sessions (in form of {{StreamResultFuture}}) which have been either > initiated or "received", for the following reasons: > 1) Naming is IMO confusing: a "receiver" session could actually both send and > receive files, so technically an initiator is also a receiver. > 2) {{StreamManager#findSession()}} assumes we should first looking into > "initiator" sessions, then into "receiver" ones: this is a dangerous > assumptions, in particular for test environments where the same process could > work as both an initiator and a receiver. > I would recommend the following changes: > 1) Rename "receiver" with "follower" everywhere the former is used. > 2) Introduce a new flag into {{StreamMessageHeader}} to signal if the message > comes from an initiator or follower session, in order to correctly > differentiate and look for sessions in {{StreamManager}}. > While my arguments above might seem trivial, I believe they will improve > clarity and save from potential bugs/headaches at testing time, and doing > such changes now that we're revamping streaming for 4.0 seems the right time. -- This message was sent by Atlassian Jira (v8.3.4#803005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-15665) StreamManager should clearly differentiate between "initiator" and "receiver" sessions
[ https://issues.apache.org/jira/browse/CASSANDRA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhaoYang updated CASSANDRA-15665: - Test and Documentation Plan: CI: [https://circleci.com/workflow-run/e2e5bf69-58a9-45e7-aed7-a05ebf022c2e] was:CI pending: [https://circleci.com/workflow-run/e2e5bf69-58a9-45e7-aed7-a05ebf022c2e] > StreamManager should clearly differentiate between "initiator" and "receiver" > sessions > -- > > Key: CASSANDRA-15665 > URL: https://issues.apache.org/jira/browse/CASSANDRA-15665 > Project: Cassandra > Issue Type: Bug > Components: Legacy/Streaming and Messaging >Reporter: Sergio Bossa >Assignee: ZhaoYang >Priority: Normal > Fix For: 4.0 > > > {{StreamManager}} does currently a suboptimal job in differentiating between > stream sessions (in form of {{StreamResultFuture}}) which have been either > initiated or "received", for the following reasons: > 1) Naming is IMO confusing: a "receiver" session could actually both send and > receive files, so technically an initiator is also a receiver. > 2) {{StreamManager#findSession()}} assumes we should first looking into > "initiator" sessions, then into "receiver" ones: this is a dangerous > assumptions, in particular for test environments where the same process could > work as both an initiator and a receiver. > I would recommend the following changes: > 1) Rename "receiver" with "follower" everywhere the former is used. > 2) Introduce a new flag into {{StreamMessageHeader}} to signal if the message > comes from an initiator or follower session, in order to correctly > differentiate and look for sessions in {{StreamManager}}. > While my arguments above might seem trivial, I believe they will improve > clarity and save from potential bugs/headaches at testing time, and doing > such changes now that we're revamping streaming for 4.0 seems the right time. -- This message was sent by Atlassian Jira (v8.3.4#803005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-15665) StreamManager should clearly differentiate between "initiator" and "receiver" sessions
[ https://issues.apache.org/jira/browse/CASSANDRA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhaoYang updated CASSANDRA-15665: - Test and Documentation Plan: CI pending: [https://circleci.com/workflow-run/e2e5bf69-58a9-45e7-aed7-a05ebf022c2e] (was: CI pending: [https://circleci.com/workflow-run/bd115daa-88d4-49f6-b710-fe8a38315cc8]) > StreamManager should clearly differentiate between "initiator" and "receiver" > sessions > -- > > Key: CASSANDRA-15665 > URL: https://issues.apache.org/jira/browse/CASSANDRA-15665 > Project: Cassandra > Issue Type: Bug > Components: Legacy/Streaming and Messaging >Reporter: Sergio Bossa >Assignee: ZhaoYang >Priority: Normal > Fix For: 4.0 > > > {{StreamManager}} does currently a suboptimal job in differentiating between > stream sessions (in form of {{StreamResultFuture}}) which have been either > initiated or "received", for the following reasons: > 1) Naming is IMO confusing: a "receiver" session could actually both send and > receive files, so technically an initiator is also a receiver. > 2) {{StreamManager#findSession()}} assumes we should first looking into > "initiator" sessions, then into "receiver" ones: this is a dangerous > assumptions, in particular for test environments where the same process could > work as both an initiator and a receiver. > I would recommend the following changes: > 1) Rename "receiver" with "follower" everywhere the former is used. > 2) Introduce a new flag into {{StreamMessageHeader}} to signal if the message > comes from an initiator or follower session, in order to correctly > differentiate and look for sessions in {{StreamManager}}. > While my arguments above might seem trivial, I believe they will improve > clarity and save from potential bugs/headaches at testing time, and doing > such changes now that we're revamping streaming for 4.0 seems the right time. -- This message was sent by Atlassian Jira (v8.3.4#803005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-15665) StreamManager should clearly differentiate between "initiator" and "receiver" sessions
[ https://issues.apache.org/jira/browse/CASSANDRA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhaoYang updated CASSANDRA-15665: - Test and Documentation Plan: CI pending: [https://circleci.com/workflow-run/bd115daa-88d4-49f6-b710-fe8a38315cc8] (was: CI pending: [https://circleci.com/workflow-run/b8aed041-cb39-4e86-9a8f-189c02a08857]) > StreamManager should clearly differentiate between "initiator" and "receiver" > sessions > -- > > Key: CASSANDRA-15665 > URL: https://issues.apache.org/jira/browse/CASSANDRA-15665 > Project: Cassandra > Issue Type: Bug > Components: Legacy/Streaming and Messaging >Reporter: Sergio Bossa >Assignee: ZhaoYang >Priority: Normal > Fix For: 4.0 > > > {{StreamManager}} does currently a suboptimal job in differentiating between > stream sessions (in form of {{StreamResultFuture}}) which have been either > initiated or "received", for the following reasons: > 1) Naming is IMO confusing: a "receiver" session could actually both send and > receive files, so technically an initiator is also a receiver. > 2) {{StreamManager#findSession()}} assumes we should first looking into > "initiator" sessions, then into "receiver" ones: this is a dangerous > assumptions, in particular for test environments where the same process could > work as both an initiator and a receiver. > I would recommend the following changes: > 1) Rename "receiver" with "follower" everywhere the former is used. > 2) Introduce a new flag into {{StreamMessageHeader}} to signal if the message > comes from an initiator or follower session, in order to correctly > differentiate and look for sessions in {{StreamManager}}. > While my arguments above might seem trivial, I believe they will improve > clarity and save from potential bugs/headaches at testing time, and doing > such changes now that we're revamping streaming for 4.0 seems the right time. -- This message was sent by Atlassian Jira (v8.3.4#803005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-15665) StreamManager should clearly differentiate between "initiator" and "receiver" sessions
[ https://issues.apache.org/jira/browse/CASSANDRA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhaoYang updated CASSANDRA-15665: - Test and Documentation Plan: CI pending: [https://circleci.com/workflow-run/b8aed041-cb39-4e86-9a8f-189c02a08857] (was: CI pending: [https://circleci.com/workflow-run/896f8753-3b8a-47ed-959e-f2806ae3d052]) > StreamManager should clearly differentiate between "initiator" and "receiver" > sessions > -- > > Key: CASSANDRA-15665 > URL: https://issues.apache.org/jira/browse/CASSANDRA-15665 > Project: Cassandra > Issue Type: Bug > Components: Legacy/Streaming and Messaging >Reporter: Sergio Bossa >Assignee: ZhaoYang >Priority: Normal > Fix For: 4.0 > > > {{StreamManager}} does currently a suboptimal job in differentiating between > stream sessions (in form of {{StreamResultFuture}}) which have been either > initiated or "received", for the following reasons: > 1) Naming is IMO confusing: a "receiver" session could actually both send and > receive files, so technically an initiator is also a receiver. > 2) {{StreamManager#findSession()}} assumes we should first looking into > "initiator" sessions, then into "receiver" ones: this is a dangerous > assumptions, in particular for test environments where the same process could > work as both an initiator and a receiver. > I would recommend the following changes: > 1) Rename "receiver" with "follower" everywhere the former is used. > 2) Introduce a new flag into {{StreamMessageHeader}} to signal if the message > comes from an initiator or follower session, in order to correctly > differentiate and look for sessions in {{StreamManager}}. > While my arguments above might seem trivial, I believe they will improve > clarity and save from potential bugs/headaches at testing time, and doing > such changes now that we're revamping streaming for 4.0 seems the right time. -- This message was sent by Atlassian Jira (v8.3.4#803005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-15665) StreamManager should clearly differentiate between "initiator" and "receiver" sessions
[ https://issues.apache.org/jira/browse/CASSANDRA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhaoYang updated CASSANDRA-15665: - Test and Documentation Plan: CI pending: [https://circleci.com/workflow-run/896f8753-3b8a-47ed-959e-f2806ae3d052] Status: Patch Available (was: In Progress) [Patch|https://github.com/jasonstack/cassandra/pull/10] on top of CASSANDRA-15666: * Include {{isFollower}} flag into {{StreamMessageHeader}}. On the receiver side, it will use initiator session if message is sent by a follower or use follower session if message is sent by an initiator. * Added a base method {{getOrCreateSession}} to {{StreamMessage}}: ** it throws unsupported operation by default ** {{StreamInitMessage}} will initialize a follower {{StreamResultFuture}}/{{StreamSession}} ** {{IncomingStreamMessage}} will just return the stream session taken from {{IncomingStreamMessage#serializer#deserialize}} > StreamManager should clearly differentiate between "initiator" and "receiver" > sessions > -- > > Key: CASSANDRA-15665 > URL: https://issues.apache.org/jira/browse/CASSANDRA-15665 > Project: Cassandra > Issue Type: Bug > Components: Legacy/Streaming and Messaging >Reporter: Sergio Bossa >Assignee: ZhaoYang >Priority: Normal > Fix For: 4.0 > > > {{StreamManager}} does currently a suboptimal job in differentiating between > stream sessions (in form of {{StreamResultFuture}}) which have been either > initiated or "received", for the following reasons: > 1) Naming is IMO confusing: a "receiver" session could actually both send and > receive files, so technically an initiator is also a receiver. > 2) {{StreamManager#findSession()}} assumes we should first looking into > "initiator" sessions, then into "receiver" ones: this is a dangerous > assumptions, in particular for test environments where the same process could > work as both an initiator and a receiver. > I would recommend the following changes: > 1) Rename "receiver" with "follower" everywhere the former is used. > 2) Introduce a new flag into {{StreamMessageHeader}} to signal if the message > comes from an initiator or follower session, in order to correctly > differentiate and look for sessions in {{StreamManager}}. > While my arguments above might seem trivial, I believe they will improve > clarity and save from potential bugs/headaches at testing time, and doing > such changes now that we're revamping streaming for 4.0 seems the right time. -- This message was sent by Atlassian Jira (v8.3.4#803005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-15665) StreamManager should clearly differentiate between "initiator" and "receiver" sessions
[ https://issues.apache.org/jira/browse/CASSANDRA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhaoYang updated CASSANDRA-15665: - Bug Category: Parent values: Code(13163) Complexity: Normal Discovered By: Code Inspection Severity: Normal Status: Open (was: Triage Needed) > StreamManager should clearly differentiate between "initiator" and "receiver" > sessions > -- > > Key: CASSANDRA-15665 > URL: https://issues.apache.org/jira/browse/CASSANDRA-15665 > Project: Cassandra > Issue Type: Bug > Components: Legacy/Streaming and Messaging >Reporter: Sergio Bossa >Assignee: ZhaoYang >Priority: Normal > Fix For: 4.0 > > > {{StreamManager}} does currently a suboptimal job in differentiating between > stream sessions (in form of {{StreamResultFuture}}) which have been either > initiated or "received", for the following reasons: > 1) Naming is IMO confusing: a "receiver" session could actually both send and > receive files, so technically an initiator is also a receiver. > 2) {{StreamManager#findSession()}} assumes we should first looking into > "initiator" sessions, then into "receiver" ones: this is a dangerous > assumptions, in particular for test environments where the same process could > work as both an initiator and a receiver. > I would recommend the following changes: > 1) Rename "receiver" with "follower" everywhere the former is used. > 2) Introduce a new flag into {{StreamMessageHeader}} to signal if the message > comes from an initiator or follower session, in order to correctly > differentiate and look for sessions in {{StreamManager}}. > While my arguments above might seem trivial, I believe they will improve > clarity and save from potential bugs/headaches at testing time, and doing > such changes now that we're revamping streaming for 4.0 seems the right time. -- This message was sent by Atlassian Jira (v8.3.4#803005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
[jira] [Updated] (CASSANDRA-15665) StreamManager should clearly differentiate between "initiator" and "receiver" sessions
[ https://issues.apache.org/jira/browse/CASSANDRA-15665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergio Bossa updated CASSANDRA-15665: - Fix Version/s: 4.0 > StreamManager should clearly differentiate between "initiator" and "receiver" > sessions > -- > > Key: CASSANDRA-15665 > URL: https://issues.apache.org/jira/browse/CASSANDRA-15665 > Project: Cassandra > Issue Type: Bug > Components: Legacy/Streaming and Messaging >Reporter: Sergio Bossa >Priority: Normal > Fix For: 4.0 > > > {{StreamManager}} does currently a suboptimal job in differentiating between > stream sessions (in form of {{StreamResultFuture}}) which have been either > initiated or "received", for the following reasons: > 1) Naming is IMO confusing: a "receiver" session could actually both send and > receive files, so technically an initiator is also a receiver. > 2) {{StreamManager#findSession()}} assumes we should first looking into > "initiator" sessions, then into "receiver" ones: this is a dangerous > assumptions, in particular for test environments where the same process could > work as both an initiator and a receiver. > I would recommend the following changes: > 1) Rename "receiver" with "follower" everywhere the former is used. > 2) Introduce a new flag into {{StreamMessageHeader}} to signal if the message > comes from an initiator or follower session, in order to correctly > differentiate and look for sessions in {{StreamManager}}. > While my arguments above might seem trivial, I believe they will improve > clarity and save from potential bugs/headaches at testing time, and doing > such changes now that we're revamping streaming for 4.0 seems the right time. -- This message was sent by Atlassian Jira (v8.3.4#803005) - To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org