@Test public void testIsThreadBound() throws Exception { Command command = helpGetCommand("SELECT intkey FROM bqt1.smalla", EXAMPLE_BQT); AtomicRequestMessage arm = createNewAtomicRequestMessage(1, 1); TransactionContext tc = new TransactionContext(); tc.setTransactionType(Scope.LOCAL); tc.setIsolationLevel(Connection.TRANSACTION_REPEATABLE_READ); arm.setTransactionContext(tc); arm.setCommand(command); final FakeConnector c = new FakeConnector() { public boolean supportsMultipleOpenExecutions() { return false; } }; ConnectorManager cm = new ConnectorManager("FakeConnector","FakeConnector") { public ExecutionFactory getExecutionFactory() { return c; } public Object getConnectionFactory(){ return c; } }; cm.start(); ConnectorWorkItem cwi = new ConnectorWorkItem(arm, cm); assertTrue(cwi.isThreadBound()); cwi = new ConnectorWorkItem(arm, TestConnectorManager.getConnectorManager()); assertFalse(cwi.isThreadBound()); }
@Override public boolean isThreadBound() { return this.connector.isThreadBound() || (!isForkable() && !this.connector.supportsMultipleOpenExecutions()); }
ConnectorWorkItem implements ConnectorWork { @Override public boolean isThreadBound() { return this.connector.isThreadBound() || (!isForkable() && !this.connector.supportsMultipleOpenExecutions()); } }
ConnectorWorkItem implements ConnectorWork { @Override public boolean isThreadBound() { return this.connector.isThreadBound() || (!isForkable() && !this.connector.supportsMultipleOpenExecutions()); } ConnectorWorkItem(AtomicRequestMessage message, ConnectorManager manager); }
ConnectorWorkItem implements ConnectorWork { @Override public boolean isThreadBound() { return this.connector.isThreadBound() || (!isForkable() && !this.connector.supportsMultipleOpenExecutions()); } ConnectorWorkItem(AtomicRequestMessage message, ConnectorManager manager); static void initLanguageBridgeFactory(LanguageBridgeFactory factory,
            CommandContext context, SourceCapabilities capabilities); @Override AtomicRequestID getId(); @Override void cancel(boolean abnormal); synchronized AtomicResultsMessage more(); synchronized void close(); synchronized void execute(); static AtomicResultsMessage createResultsMessage(List<?>[] batch); @Override String toString(); @Override boolean isDataAvailable(); @Override CacheDirective getCacheDirective(); @Override boolean isForkable(); @Override boolean isThreadBound(); @Override int hashCode(); @Override boolean equals(Object obj); void logCommand(Object... command); void setTracingSpan(Span span); Span getTracingSpan(); }
ConnectorWorkItem implements ConnectorWork { @Override public boolean isThreadBound() { return this.connector.isThreadBound() || (!isForkable() && !this.connector.supportsMultipleOpenExecutions()); } ConnectorWorkItem(AtomicRequestMessage message, ConnectorManager manager); static void initLanguageBridgeFactory(LanguageBridgeFactory factory,
            CommandContext context, SourceCapabilities capabilities); @Override AtomicRequestID getId(); @Override void cancel(boolean abnormal); synchronized AtomicResultsMessage more(); synchronized void close(); synchronized void execute(); static AtomicResultsMessage createResultsMessage(List<?>[] batch); @Override String toString(); @Override boolean isDataAvailable(); @Override CacheDirective getCacheDirective(); @Override boolean isForkable(); @Override boolean isThreadBound(); @Override int hashCode(); @Override boolean equals(Object obj); void logCommand(Object... command); void setTracingSpan(Span span); Span getTracingSpan();  }