Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Autogenerate java docs #29

Closed
wants to merge 54 commits into from
Closed
Changes from 1 commit
Commits
Show all changes
54 commits
Select commit Hold shift + click to select a range
c18a1aa
Remove license maven plugin
haaawk Jul 30, 2018
61b89b2
Add Host field to Connection
haaawk Apr 19, 2019
d5705ce
Add ShardingInfo class to store details of shards on host
haaawk Jul 30, 2018
6ccd1db
Add ProtocolVersion.isShardingSupported
haaawk Apr 19, 2019
cc66c5f
Add shardingInfo field to Host
haaawk Apr 19, 2019
f9f6dc1
Add shardId field to Connection
haaawk Apr 19, 2019
bc42e31
Fetch sharding info when initializing the connection
haaawk Apr 19, 2019
2bd2e25
Add shard awareness to HostConnectionPool
haaawk Apr 19, 2019
702d5f2
Signal usage of optimized driver
haaawk Apr 19, 2019
1e6338d
Add lastHost field to Statement
haaawk Apr 19, 2019
4106ab1
Add PagingOptimizingLoadBalancingPolicy
haaawk Oct 24, 2018
6511f1a
Use PagingLoadBalancingPolicy in Cluster
haaawk Apr 19, 2019
46d29d2
Add PagingOptimizingLatencyTracker
haaawk Oct 24, 2018
565d4ef
Use PagingOptimizingLatencyTracker
haaawk Apr 19, 2019
972e3f5
Prevent schema.local full scans
haaawk Apr 19, 2019
4e10d5d
Log channel creation exceptions
haaawk Apr 19, 2019
b6507ec
Stop cleaning uninitialized pool
haaawk Apr 19, 2019
5ce83a1
Optional coalscing of schema refresh queries
slivne Aug 6, 2019
934fd94
Limit number of opened connections
haaawk Apr 25, 2019
e411a57
Prepare for publishing to Maven repo
haaawk Aug 7, 2019
2521e74
[maven-release-plugin] prepare release 3.7.1-scylla-0
haaawk Aug 9, 2019
edad52b
[maven-release-plugin] prepare for next development iteration
haaawk Aug 9, 2019
09ecb30
Add metrics for shard awareness
haaawk Aug 20, 2019
9c28fb3
Update sharding info when node restarts
haaawk Aug 20, 2019
354d13d
[maven-release-plugin] prepare release 3.7.1-scylla-1
haaawk Aug 20, 2019
ab9dd27
[maven-release-plugin] prepare for next development iteration
haaawk Aug 20, 2019
d14ef5d
HostConnectionPool: track number of opened connections per shard
haaawk Oct 27, 2019
7354c77
HostConnectionPool: finish initializing after getting first connections
haaawk Oct 27, 2019
ba3443c
HostConnectionPool: use connection for any shard
haaawk Oct 27, 2019
e432c44
HostConnectionPool: share excessive connections between ConnectionTasks
haaawk Oct 28, 2019
b925924
Merge pull request #17 from haaawk/init_async
haaawk Nov 13, 2019
9ab00c4
[maven-release-plugin] prepare release 3.7.1-scylla-2
haaawk Nov 13, 2019
f3ee452
[maven-release-plugin] prepare for next development iteration
haaawk Nov 13, 2019
d8e0010
Added scylladb docs style (#1)
dgarcia360 Aug 7, 2020
2aef9fc
Updated dev docs
dgarcia360 Aug 7, 2020
958ba52
Clean conf.py
dgarcia360 Aug 7, 2020
a018b2c
Merge remote-tracking branch 'upstream/latest' into docs-automation (…
dgarcia360 Aug 14, 2020
478bb85
Fixed link
dgarcia360 Aug 14, 2020
9cd7869
Added ditaa lexer
dgarcia360 Aug 14, 2020
1ea9b03
Fixed merge
dgarcia360 Aug 14, 2020
26ebfee
Clean PR
dgarcia360 Aug 14, 2020
254b124
Replace index before building
dgarcia360 Aug 28, 2020
7d2b859
Overwrite md relative link parser
dgarcia360 Sep 10, 2020
5341cba
Add original markers
dgarcia360 Sep 10, 2020
f192325
Keep original folder structure
dgarcia360 Sep 14, 2020
b15ff8a
Fixed links
dgarcia360 Sep 14, 2020
7fc6f21
Remove index references from toctree
dgarcia360 Sep 14, 2020
9b9b5fb
Rollback index.md to README.md
dgarcia360 Sep 21, 2020
c56731c
Fixed multiversion
dgarcia360 Sep 21, 2020
2883628
Fixed doxygen multiversion
dgarcia360 Sep 21, 2020
ec0148d
Fixed redirection multiversion
Sep 21, 2020
848fe5e
Fixed conf.py
Sep 21, 2020
8d3be89
Fixed multiversion redirects
dgarcia360 Sep 21, 2020
0320099
Fixed spaces
dgarcia360 Sep 21, 2020
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Add Host field to Connection
Part of Connection initialization will be obtaining
info about shards in the host so Connection needs
a reference to the host to be able to set up this info.

Signed-off-by: Piotr Jastrzebski <haaawk@gmail.com>
  • Loading branch information
haaawk committed Aug 7, 2019
commit 61b89b2774fa093f85380606900f783bf1fc0e8b
19 changes: 9 additions & 10 deletions driver-core/src/main/java/com/datastax/driver/core/Connection.java
Original file line number Diff line number Diff line change
@@ -110,6 +110,7 @@ enum State {

volatile long maxIdleTime;

private final Host host;
final InetSocketAddress address;
private final String name;

@@ -144,8 +145,9 @@ enum State {
* @param owner the component owning this connection (may be null). Note that an existing
* connection can also be associated to an owner later with {@link #setOwner(Owner)}.
*/
protected Connection(String name, InetSocketAddress address, Factory factory, Owner owner) {
this.address = address;
protected Connection(String name, Host host, Factory factory, Owner owner) {
this.host = host;
this.address = host.getSocketAddress();
this.factory = factory;
this.dispatcher = new Dispatcher();
this.name = name;
@@ -156,8 +158,8 @@ protected Connection(String name, InetSocketAddress address, Factory factory, Ow
}

/** Create a new connection to a Cassandra node. */
Connection(String name, InetSocketAddress address, Factory factory) {
this(name, address, factory, null);
Connection(String name, Host host, Factory factory) {
this(name, host, factory, null);
}

ListenableFuture<Void> initAsync() {
@@ -955,7 +957,7 @@ Connection open(Host host)
if (isShutdown) throw new ConnectionException(address, "Connection factory is shut down");

host.convictionPolicy.signalConnectionsOpening(1);
Connection connection = new Connection(buildConnectionName(host), address, this);
Connection connection = new Connection(buildConnectionName(host), host, this);
// This method opens the connection synchronously, so wait until it's initialized
try {
connection.initAsync().get();
@@ -970,8 +972,7 @@ Connection open(HostConnectionPool pool)
throws ConnectionException, InterruptedException, UnsupportedProtocolVersionException,
ClusterNameMismatchException {
pool.host.convictionPolicy.signalConnectionsOpening(1);
Connection connection =
new Connection(buildConnectionName(pool.host), pool.host.getSocketAddress(), this, pool);
Connection connection = new Connection(buildConnectionName(pool.host), pool.host, this, pool);
try {
connection.initAsync().get();
return connection;
@@ -988,9 +989,7 @@ List<Connection> newConnections(HostConnectionPool pool, int count) {
pool.host.convictionPolicy.signalConnectionsOpening(count);
List<Connection> connections = Lists.newArrayListWithCapacity(count);
for (int i = 0; i < count; i++)
connections.add(
new Connection(
buildConnectionName(pool.host), pool.host.getSocketAddress(), this, pool));
connections.add(new Connection(buildConnectionName(pool.host), pool.host, this, pool));
return connections;
}