()
| 178 | } |
| 179 | |
| 180 | @Override |
| 181 | public void close() { |
| 182 | if (closed.compareAndSet(false, true)) { |
| 183 | joinThread(hydrateMetadataThread, true); |
| 184 | joinThread(compileViewsThread, true); |
| 185 | System.err.println("QuestDB is shutting down..."); |
| 186 | System.out.println("QuestDB is shutting down..."); |
| 187 | if (bootstrap != null && bootstrap.getLog() != null) { |
| 188 | // Still useful in case of custom logger |
| 189 | bootstrap.getLog().info().$("QuestDB is shutting down...").$(); |
| 190 | } |
| 191 | // Signal long-running task to exit ASAP |
| 192 | engine.signalClose(); |
| 193 | if (initialized) { |
| 194 | workerPoolManager.halt(); |
| 195 | } |
| 196 | freeOnExit.close(); |
| 197 | } |
| 198 | } |
| 199 | |
| 200 | public long getActiveConnectionCount(String processorName) { |
| 201 | if (httpServer == null) { |
no test coverage detected