| 215 | } |
| 216 | |
| 217 | int startServer(int port) { |
| 218 | std::shared_ptr<Runner> runner(new Runner); |
| 219 | runner->port = port; |
| 220 | runner->processor = processor; |
| 221 | runner->userEventBase = userEventBase_; |
| 222 | |
| 223 | std::unique_ptr<apache::thrift::concurrency::ThreadFactory> threadFactory( |
| 224 | new apache::thrift::concurrency::ThreadFactory(false)); |
| 225 | thread = threadFactory->newThread(runner); |
| 226 | thread->start(); |
| 227 | runner->readyBarrier(); |
| 228 | |
| 229 | server = runner->server; |
| 230 | return runner->port; |
| 231 | } |
| 232 | |
| 233 | bool canCommunicate(int serverPort) { |
| 234 | std::shared_ptr<TSSLSocketFactory> pClientSocketFactory = createClientSocketFactory(); |
nothing calls this directly
no test coverage detected