Skip to content

ZOOKEEPER-3600:[WIP]support the complete Linearizability Read - #1137

Open
maoling wants to merge 2 commits into
apache:masterfrom
maoling:ZOOKEEPER-3600
Open

ZOOKEEPER-3600:[WIP]support the complete Linearizability Read#1137
maoling wants to merge 2 commits into
apache:masterfrom
maoling:ZOOKEEPER-3600

Conversation

@maoling

@maoling maoling commented Nov 7, 2019

Copy link
Copy Markdown
Member
  • this is still a work in the progress,Plz don't review before removing the WIP tag
  • more details in the ZOOKEEPER-3600

@eolivelli eolivelli left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

this work is interesting.
I missed any discussions on the mailing list

int sync = 9;

// sync
int syncedRead = 10;

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

why using 10 ? isn't it better to use 109 ?

* @throws InterruptedException
* @since
*/
public CompletableFuture<ZNode> getData(ReadConsistencyMode readMode, final String path, Watcher watcher) throws KeeperException, InterruptedException {

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CompletableFuture is tricky, because there is no control over the thread that execute any callback/listener

it is appealing but I won't use it here, all the API is based on callbacks that are guaranteed to be executed in the ZK thread

ORDERED_SEQUENTIAL_READ("Ordered Sequential Read"),
LINEARIZABLE_READ("Linearizable Read"),
LEASE_READ("Lease Read"),
DUMMY_READ("Dummy Read Used For Testing");

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

we should remove this DUMMY_READ mode

&& (maxReadBatchSize < 0 || readsProcessed <= maxReadBatchSize)
&& (request = queuedRequests.poll()) != null) {
requestsToProcess--;
//System.out.println("fuck__CommitProcessor_needCommit(request):" + needCommit(request) + ",pendingRequests.containsKey(request.sessionId):"+

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

please do not commit this lines or put them in PRs
they are sent over the mailing lists and tracked in the archives

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants