You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2016/09/07 09:25:56 UTC
[28/28] ignite git commit: test
test
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/8a5378f5
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8a5378f5
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8a5378f5
Branch: refs/heads/ignite-1.6.7-test
Commit: 8a5378f5a32c6c5bd59babb8bc92cd07e9ad4da6
Parents: 224cae1
Author: sboikov <sb...@gridgain.com>
Authored: Wed Sep 7 12:25:07 2016 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Wed Sep 7 12:25:07 2016 +0300
----------------------------------------------------------------------
.../apache/ignite/internal/processors/odbc/OdbcProcessor.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/8a5378f5/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcProcessor.java
index a672d7c..9388a8e 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcProcessor.java
@@ -29,6 +29,7 @@ import org.apache.ignite.internal.util.nio.GridNioAsyncNotifyFilter;
import org.apache.ignite.internal.util.nio.GridNioCodecFilter;
import org.apache.ignite.internal.util.nio.GridNioFilter;
import org.apache.ignite.internal.util.nio.GridNioServer;
+import org.apache.ignite.internal.util.nio.GridNioSession;
import org.apache.ignite.internal.util.typedef.F;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.marshaller.Marshaller;
@@ -123,7 +124,11 @@ public class OdbcProcessor extends GridProcessorAdapter {
for (int port = hostPort.portFrom(); port <= hostPort.portTo(); port++) {
try {
GridNioFilter[] filters = new GridNioFilter[] {
- new GridNioAsyncNotifyFilter(ctx.gridName(), odbcExecSvc, log),
+ new GridNioAsyncNotifyFilter(ctx.gridName(), odbcExecSvc, log) {
+ @Override public void onSessionOpened(GridNioSession ses) throws IgniteCheckedException {
+ proceedSessionOpened(ses);
+ }
+ },
new GridNioCodecFilter(new OdbcBufferedParser(), log, false)
};