ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [27/50] ignite git commit: IGNITE-2629: ODBC: GridNioAsyncNotifyFilter should process onSessionOpened synchronously
Date Wed, 14 Sep 2016 11:10:43 GMT
IGNITE-2629: ODBC: GridNioAsyncNotifyFilter should process onSessionOpened synchronously


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b5121adf
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b5121adf
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b5121adf

Branch: refs/heads/ignite-3661
Commit: b5121adff860d96e5954d3466137854f8fae4c27
Parents: 224cae1
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Sep 7 12:44:24 2016 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed Sep 7 12:44:24 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/b5121adf/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)
                         };
 


Mime
View raw message