# GG-9613 free resources on remote nodes
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/44ea204e Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/44ea204e Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/44ea204e Branch: refs/heads/ignite-gg-9702 Commit: 44ea204ece2d1436b4136c088d60f484a1a97dc3 Parents: d817a5c Author: ptupitsyn <ptupit...@gridgain.com> Authored: Wed Apr 15 17:25:02 2015 +0300 Committer: ptupitsyn <ptupit...@gridgain.com> Committed: Wed Apr 15 17:25:02 2015 +0300 ---------------------------------------------------------------------- .../GridCloseableMessageFilter.java | 30 ++++++++++++++++++++ .../managers/communication/GridIoManager.java | 4 +-- .../GridMessageCloseableFilter.java | 30 -------------------- 3 files changed, 32 insertions(+), 32 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/44ea204e/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridCloseableMessageFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridCloseableMessageFilter.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridCloseableMessageFilter.java new file mode 100644 index 0000000..e3888ab --- /dev/null +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridCloseableMessageFilter.java @@ -0,0 +1,30 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.ignite.internal.managers.communication; + +import org.apache.ignite.lang.*; + +/** + * Special version of bi-predicate for messaging with close callback. + */ +public interface GridCloseableMessageFilter<K, V> extends IgniteBiPredicate<K, V> { + /** + * Callback invoked when predicate is no longer needed. + */ + public void onClose(); +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/44ea204e/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java index 1ffad15..2607665 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java @@ -1486,8 +1486,8 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa private void closeListener(GridMessageListener lsnr) { if (lsnr instanceof GridUserMessageListener) { GridUserMessageListener userLsnr = (GridUserMessageListener)lsnr; - if (userLsnr.predLsnr instanceof GridMessageCloseableFilter) - ((GridMessageCloseableFilter)userLsnr.predLsnr).onClose(); + if (userLsnr.predLsnr instanceof GridCloseableMessageFilter) + ((GridCloseableMessageFilter)userLsnr.predLsnr).onClose(); } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/44ea204e/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridMessageCloseableFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridMessageCloseableFilter.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridMessageCloseableFilter.java deleted file mode 100644 index 4f84ebf..0000000 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridMessageCloseableFilter.java +++ /dev/null @@ -1,30 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.ignite.internal.managers.communication; - -import org.apache.ignite.lang.*; - -/** - * Special version of bi-predicate for messaging with close callback. - */ -public interface GridMessageCloseableFilter<K, V> extends IgniteBiPredicate<K, V> { - /** - * Callback invoked when predicate is no longer needed. - */ - public void onClose(); -}
