Skip to content

Commit

Permalink
Fix spotlessJavaCheck failures
Browse files Browse the repository at this point in the history
Those are failing CI for a while.
  • Loading branch information
fishy committed Jun 27, 2023
1 parent 9151761 commit 6199224
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -553,6 +553,7 @@ public int getMinSerializedSize(byte type) throws TTransportException {
throw new TTransportException(TTransportException.UNKNOWN, "unrecognized type code");
}
}

// -----------------------------------------------------------------
// Additional methods to improve performance.

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -940,6 +940,7 @@ public int getMinSerializedSize(byte type) throws TTransportException {
throw new TTransportException(TTransportException.UNKNOWN, "unrecognized type code");
}
}

// -----------------------------------------------------------------
// Additional methods to improve performance.

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -65,18 +65,22 @@ public static class Args extends AbstractNonblockingServerArgs<Args> {

/** The number of threads for selecting on already-accepted connections */
public int selectorThreads = 2;

/**
* The size of the executor service (if none is specified) that will handle invocations. This
* may be set to 0, in which case invocations will be handled directly on the selector threads
* (as is in TNonblockingServer)
*/
private int workerThreads = 5;

/** Time to wait for server to stop gracefully */
private int stopTimeoutVal = 60;

private TimeUnit stopTimeoutUnit = TimeUnit.SECONDS;

/** The ExecutorService for handling dispatched requests */
private ExecutorService executorService = null;

/**
* The size of the blocking queue per selector thread for passing accepted connections to the
* selector thread
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,6 +68,7 @@ public TIOStreamTransport(TConfiguration config, InputStream is) throws TTranspo
super(config);
inputStream_ = is;
}

/**
* Input stream constructor, constructs an input only transport.
*
Expand Down

0 comments on commit 6199224

Please sign in to comment.