List of assignNode() Examples

Examples of assignNode()

com.sun.sgs.service.NodeMappingService.assignNode()
Assigns the identity to a node and adds the assignment to the map. If the identity has no node assignment, or the current assignment is not to a live node, a node is selected for it; otherwise, no action is performed.
Additionally (and atomically), notes that the service considers the identity to be active, as though {@link #setStatus setStatus(service, identity, true)} hadbeen called on the assigned node.
TBD: Perhaps this atomic setService doesn't help. It seems as though each service instance on a node needs to call setStatus anyway, and it complicates the implementation of this service.
TBD: Maybe the first parameter should be Class. The actual service who cares might be very interesting to the load balancer.
This method should not be called while in a transaction, as this method call could entail remote communication.
@param service the class of the caller @param identity the identity to assign to a node @throws IllegalStateException if this method is called while in atransaction

Examples of com.sun.sgs.service.NodeMappingService.assignNode()

            // node3: 3,6,9,12,15,18,21,24,27,30,33
            // Actual round robin policy might assign these differently...
            NodeMappingService nms = node1.getNodeMappingService();
            for (int i = 1; i < 35; i++) {
                idents[i] = new DummyIdentity(String.valueOf(i));
                nms.assignNode(this.getClass(), idents[i]);
            }
            
            // Node 1 uses.
            AffinityGraphBuilder builder1 = driver1.getGraphBuilder();
            AccessedObjectsDetailTest detail = new AccessedObjectsDetailTest();

View Full Code Here

Examples of com.sun.sgs.service.NodeMappingService.assignNode()

            TestListener listener = new TestListener();        
            nodemap.addNodeMappingListener(listener);
            
            // We have NOT called ready yet.
            final Identity id = new IdentityImpl("first");
            nodemap.assignNode(NodeMappingService.class, id);
            
            txnScheduler.runTask(
                new TestAbstractKernelRunnable() {
                    public void run() throws Exception {
                        nodeMappingService.getNode(id);

View Full Code Here

Examples of com.sun.sgs.service.NodeMappingService.assignNode()

                    (NodeMappingServerImpl) mapServer.get(nodeMappingService);
            
            // Create a new identity and assign it to a node
            // Since there is only 1 app node, it will be assigned to that one
            final Identity id = new IdentityImpl(appName + "_identity");
            nodeMappingService.assignNode(NodeMappingService.class, id);
            System.err.println("AppNode id: "+appNode.getNodeId());


            txnScheduler.runTask(new TestAbstractKernelRunnable() {
                public void run() throws Exception {
                    // See if the right node has the identity

View Full Code Here

Examples of com.sun.sgs.service.NodeMappingService.assignNode()

                    (NodeMappingServerImpl) mapServer.get(nodeMappingService);
            
            // Create a new identity and assign it to a node
            // Since there is only 1 app node, it will be assigned to that one
            final Identity id = new IdentityImpl(appName + "_identity");
            nodeMappingService.assignNode(NodeMappingService.class, id);
            System.err.println("AppNode id: "+appNode.getNodeId());


            txnScheduler.runTask(new TestAbstractKernelRunnable() {
                public void run() throws Exception {
                    // See if the right node has the identity

View Full Code Here

TOP

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.