Repository: incubator-ignite Updated Branches: refs/heads/ignite-45-ipc-debug [created] 04ad93108
# DEBUG Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/04ad9310 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/04ad9310 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/04ad9310 Branch: refs/heads/ignite-45-ipc-debug Commit: 04ad931086d4b80fbc301b0bd589594b057ac654 Parents: 27c54ac Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Mon Mar 23 12:17:23 2015 -0700 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Mon Mar 23 12:17:23 2015 -0700 ---------------------------------------------------------------------- .../internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java | 2 ++ .../internal/util/ipc/shmem/IpcSharedMemoryServerEndpoint.java | 2 ++ .../ignite/internal/util/ipc/shmem/IpcSharedMemorySpace.java | 4 ++++ 3 files changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/04ad9310/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java index 27a234f..d76d7a2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java @@ -296,6 +296,8 @@ public class IpcSharedMemoryClientEndpoint implements IpcEndpoint { File tokFile = new File(space.tokenFileName()); + U.dumpStack(log, "Free [tok=" + tokFile + ']'); + // Space is not usable at this point and all local threads // are guaranteed to leave its methods (other party is not alive). // So, we can cleanup resources without additional synchronization. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/04ad9310/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryServerEndpoint.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryServerEndpoint.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryServerEndpoint.java index 8c2fcb0..804b9fe 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryServerEndpoint.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryServerEndpoint.java @@ -671,6 +671,8 @@ public class IpcSharedMemoryServerEndpoint implements IpcServerEndpoint { if (log.isDebugEnabled()) log.debug("Possibly stale token file: " + f0); + U.dumpStack(log, "Free [tok=" + f0.getAbsolutePath() + ']'); + IpcSharedMemoryUtils.freeSystemResources(f0.getAbsolutePath(), size); if (f0.delete()) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/04ad9310/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemorySpace.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemorySpace.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemorySpace.java index 249d995..bbd31da 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemorySpace.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemorySpace.java @@ -87,6 +87,8 @@ public class IpcSharedMemorySpace implements Closeable { opSize = size; + U.dumpStack(log, "Allocate [tok=" + tokFileName + ", size=" + size + ']'); + shmemPtr = IpcSharedMemoryUtils.allocateSystemResources(tokFileName, size, DEBUG && log.isDebugEnabled()); shmemId = IpcSharedMemoryUtils.sharedMemoryId(shmemPtr); @@ -297,6 +299,8 @@ public class IpcSharedMemorySpace implements Closeable { lock.writeLock().lock(); try { + U.dumpStack(log, "Free [tok=" + tokFileName + ", ptr=" + shmemPtr + ", force=" + force + ']'); + IpcSharedMemoryUtils.freeSystemResources(tokFileName, shmemPtr, force); } finally {
