Skip to content

DRILL-4841: Use server event loop for web clients #565

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.

Sign up for GitHub

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

Open
sudheeshkatkam wants to merge 3 commits into
base: master
Choose a base branch
from
Open

DRILL-4841: Use server event loop for web clients #565

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
0889aa6
DRILL-4606: HYGIENE
Mar 9, 2016
8cc6bc9
DRILL-4606: CORE
Apr 15, 2016
b5ee0fb
DRILL-4841: Use server event loop for web clients
Aug 10, 2016
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
27 changes: 26 additions & 1 deletion common/src/main/java/org/apache/drill/common/AutoCloseables.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ public static void close(AutoCloseable... autoCloseables) throws Exception {

/**
* Closes all autoCloseables if not null and suppresses subsequent exceptions if more than one
* @param autoCloseables the closeables to close
* @param ac the closeables to close
*/
public static void close(Iterable<? extends AutoCloseable> ac) throws Exception {
Exception topLevelException = null;
Expand All @@ -87,4 +87,29 @@ public static void close(Iterable<? extends AutoCloseable> ac) throws Exception
throw topLevelException;
}
}

/**
* close() an {@see java.lang.AutoCloseable} without throwing a (checked)
* {@see java.lang.Exception}. This wraps the close() call with a
* try-catch that will rethrow an Exception wrapped with a
* {@see java.lang.RuntimeException}, providing a way to call close()
* without having to do the try-catch everywhere or propagate the Exception.
*
* @param autoCloseable the AutoCloseable to close; may be null
* @throws RuntimeException if an Exception occurs; the Exception is
* wrapped by the RuntimeException
*/
public static void closeNoChecked(final AutoCloseable autoCloseable) {
Copy link
Copy Markdown
Contributor

@paul-rogers paul-rogers Oct 6, 2016

Choose a reason for hiding this comment

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

closeUnchecked ?

But, we are "checking", the "checked" has to do with the Exception type.

Maybe cleanClose( ) for this function. Then, add a "closeSilently" to catch and ignore close exceptions. (The closeSilently is handy in the case when, say, a file is full, a write failed, and the close will also fail because it still can't flush pending buffers.) There are other functions to the to silent close, but might be handy to have them in one place.

if (autoCloseable != null) {
try {
autoCloseable.close();
} catch(final Exception e) {
throw new RuntimeException("Exception while closing", e);
}
}
}

// prevents instantiation
private AutoCloseables() {
}
}
50 changes: 0 additions & 50 deletions common/src/main/java/org/apache/drill/common/DrillAutoCloseables.java
View file
Open in desktop

This file was deleted.

5 changes: 4 additions & 1 deletion contrib/storage-hbase/src/test/java/org/apache/drill/hbase/TestHBaseCFAsJSONString.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,10 @@ public class TestHBaseCFAsJSONString extends BaseHBaseTest {
@BeforeClass
public static void openMyClient() throws Exception {
parent_client = client;
client = new DrillClient(config, serviceSet.getCoordinator());
client = DrillClient.newBuilder()
.setConfig(config)
.setClusterCoordinator(serviceSet.getCoordinator())
.build();
client.setSupportComplexTypes(false);
client.connect();
}
Expand Down
Loading