Package com.hazelcast.spi

Examples of com.hazelcast.spi.DefaultObjectNamespace

45
46
47
48
49
50
51
        super(key);
        this.name = name;
    }

    protected ObjectNamespace getNamespace() {
        return new DefaultObjectNamespace(MultiMapService.SERVICE_NAME, name);
    }
View Full Code Here
60
61
62
63
64
65
66
67
68
69
        this.service = service;
        this.nodeEngine = service.getNodeEngine();
        this.partitionId = partitionId;
        this.config = nodeEngine.getConfig().findMultiMapConfig(name);

        this.lockNamespace = new DefaultObjectNamespace(MultiMapService.SERVICE_NAME, name);
        final LockService lockService = nodeEngine.getSharedService(LockService.SERVICE_NAME);
        this.lockStore = lockService == null ? null : lockService.createLockStore(partitionId, lockNamespace);
        creationTime = Clock.currentTimeMillis();
    }
View Full Code Here
57
58
59
60
61
62
63
        super.readInternal(in);
        threadId = in.readLong();
    }

    public WaitNotifyKey getWaitKey() {
        return new LockWaitNotifyKey(new DefaultObjectNamespace(MultiMapService.SERVICE_NAME, name), dataKey);
    }
View Full Code Here
76
77
78
79
80
81
82
        return true;
    }

    @Override
    public WaitNotifyKey getNotifiedKey() {
        return new LockWaitNotifyKey(new DefaultObjectNamespace(MapService.SERVICE_NAME, name), dataKey);
    }
View Full Code Here
49
50
51
52
53
54
55
        super(key, threadId, force);
        this.name = name;
    }

    protected ObjectNamespace getNamespace() {
        return new DefaultObjectNamespace(MultiMapService.SERVICE_NAME, name);
    }
View Full Code Here
73
74
75
76
77
78
79
80
81
    private void clearLockStore(String name) {
        final NodeEngine nodeEngine = mapService.getNodeEngine();
        final LockService lockService = nodeEngine.getSharedService(LockService.SERVICE_NAME);
        if (lockService != null) {
            final DefaultObjectNamespace namespace = new DefaultObjectNamespace(MapService.SERVICE_NAME, name);
            lockService.clearLockStore(partitionId, namespace);
        }
    }
View Full Code Here
61
62
63
64
65
66
67
        multiMapResponse.setTxVersion(wrapper.incrementAndGetVersion());
        response = multiMapResponse;
    }

    public WaitNotifyKey getWaitKey() {
        return new LockWaitNotifyKey(new DefaultObjectNamespace(MultiMapService.SERVICE_NAME, name), dataKey);
    }
View Full Code Here
72
73
74
75
76
77
78
79
80
81
        this.service = service;
        this.nodeEngine = service.getNodeEngine();
        this.partitionId = partitionId;
        this.config = nodeEngine.getConfig().findMultiMapConfig(name);

        this.lockNamespace = new DefaultObjectNamespace(MultiMapService.SERVICE_NAME, name);
        final LockService lockService = nodeEngine.getSharedService(LockService.SERVICE_NAME);
        this.lockStore = lockService == null ? null : lockService.createLockStore(partitionId, lockNamespace);
        this.creationTime = Clock.currentTimeMillis();
    }
View Full Code Here
60
61
62
63
64
65
66
        multiMapResponse.setTxVersion(wrapper.incrementAndGetVersion());
        response = multiMapResponse;
    }

    public WaitNotifyKey getWaitKey() {
        return new LockWaitNotifyKey(new DefaultObjectNamespace(MultiMapService.SERVICE_NAME, name), dataKey);
    }
View Full Code Here
46
47
48
49
50
51
52
        super(key, threadId, ttl, timeout);
        this.name = name;
    }

    protected ObjectNamespace getNamespace() {
        return new DefaultObjectNamespace(MultiMapService.SERVICE_NAME, name);
    }
View Full Code Here
TOP

Related Classes of com.hazelcast.spi.DefaultObjectNamespace

  • com.hazelcast.client.spi.ProxyManager
  • com.hazelcast.map.AbstractRecordStore
  • com.hazelcast.map.client.MapIsLockedRequest
  • com.hazelcast.map.client.MapLockRequest
  • com.hazelcast.map.client.MapUnlockRequest
  • com.hazelcast.map.DefaultRecordStore
  • com.hazelcast.map.impl.AbstractRecordStore
  • com.hazelcast.map.impl.client.MapIsLockedRequest
  • com.hazelcast.map.impl.client.MapLockRequest
  • com.hazelcast.map.impl.client.MapUnlockRequest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.