Find Usages Diff Raw Download HTML Widget
Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions 
1
  /*-
2
   * See the file LICENSE for redistribution information.
3
   *
4
   * Copyright (c) 2002, 2013 Oracle and/or its affiliates.  All rights reserved.
5
   *
6
   */
7
  
8
  package com.sleepycat.je.rep.impl;
9
  
10
 import static com.sleepycat.je.rep.impl.RepParams.GROUP_NAME;
11
 
18
 import java.util.Set;
21
 
42
 
43
 public class GroupService extends ExecutingService {
44
 
45
     /* The replication node */
46
     final RepNode repNode;
47
     final RepGroupProtocol protocol;

    
List of sockets for in-flight requests. The socket is in this collection while the request is being processed, and must be removed before sending any response.

See also:
cancel()
unregisterSocket(java.nio.channels.SocketChannel)
56
 
57
     private final Collection<SocketChannel> activeChannels =
58
         new ArrayList<SocketChannel>();
59
 
60
     private final Logger logger;
61
 
62
     /* Identifies the Group Service. */
63
     public static final String SERVICE_NAME = "Group";
64
 
65
     public GroupService(ServiceDispatcher dispatcher, RepNode repNode) {
66
         super(, dispatcher);
67
         this. = repNode;
68
 
69
         final DbConfigManager configManager =
70
             repNode.getRepImpl().getConfigManager();
71
         String groupName = configManager.get();
72
          = new RepGroupProtocol(groupName,
73
                                         repNode.getNameIdPair(),
74
                                         repNode.getRepImpl());
75
          = LoggerUtils.getLogger(getClass());
76
     }
77
     
78
     @Override
79
     protected void cancel() {
80
         Collection<SocketChannel> channels;
81
         synchronized (this) {
82
             channels = new ArrayList<SocketChannel>();
83
             .clear();
84
         }
85
         if (!channels.isEmpty()) {
86
             LoggerUtils.warning
87
                 (, .getRepImpl(),
88
                  "In-flight GroupService request(s) canceled: node shutdown");
89
         }
90
         for (SocketChannel channel : channels) {
91
             try {
92
                 PrintWriter out =
93
                     new PrintWriter(channel.socket().getOutputStream(), true);
94
                 ResponseMessage rm =
95
                     .new Fail(., "shutting down");
96
                 out.println(rm.wireFormat());
97
             } catch (IOException e) {
98
                 LoggerUtils.warning
99
                     (, .getRepImpl(),
100
                     "IO error on socket: " + e.getMessage());
101
            } finally {
102
                if (channel.isOpen()) {
103
                    try {
104
                        channel.close();
105
                    }
106
                    catch (IOException e) {
107
                        LoggerUtils.warning
108
                            (, .getRepImpl(),
109
                             "IO error on socket close: " + e.getMessage());
110
                    }
111
                }
112
            }
113
        }
114
    }
116
    /* Dynamically invoked process methods */

    
Wraps the replication group as currently cached on this node in a Response message and returns it. 
122
    @SuppressWarnings("unused")
123
    public ResponseMessage process(GroupRequest groupRequest) {
124
        RepGroupImpl group = .getGroup();
125
        if (group == null) {
126
            return .new Fail(., "no group info yet");
127
        }
128
        return .new GroupResponse(group);
129
    }

    
Ensures that the Monitor node, as described in the request, is a member of the group.

Parameters:
ensureNode the request message describing the monitor node
Returns:
EnsureOK message if the monitor node is already part of the rep group, or was just made a part of the replication group. It returns a Fail message if it could not be made part of the group. The message associated with the response provides further details.
142
    public ResponseMessage process(EnsureNode ensureNode) {
143
        RepNodeImpl node = ensureNode.getNode();
144
        try {
145
            ensureMaster();
146
            .getRepGroupDB().ensureMember(node);
147
            RepNodeImpl enode =
148
                .getGroup().getMember(node.getName());
149
            return .new EnsureOK(enode.getNameIdPair());
150
        } catch (ReplicaStateException e) {
151
            return .new Fail(., e.getMessage());
152
        } catch (DatabaseException e) {
153
            return .new Fail(., e.getMessage());
154
        }
155
    }

    
Removes a current member from the group.

Parameters:
removeMember the request identifying the member to be removed.
Returns:
OK message if the member was removed from the group.
164
    public ResponseMessage process(RemoveMember removeMember) {
165
        final String nodeName = removeMember.getNodeName();
166
        try {
167
            ensureMaster();
168
            .removeMember(nodeName);
169
            return .new OK();
170
        } catch (MemberNotFoundException e) {
171
            return .new Fail(.,
172
                                     e.getMessage());
173
        } catch (MasterStateException e) {
174
            return .new Fail(., e.getMessage());
175
        } catch (ReplicaStateException e) {
176
            return .new Fail(., e.getMessage());
177
        }  catch (DatabaseException e) {
178
            return .new Fail(., e.getMessage());
179
        }
180
    }

    
Update the network address for a dead replica.

Parameters:
updateAddress the request identifying the new network address for the node.
Returns:
OK message if the address is successfully updated.
190
    public ResponseMessage process(UpdateAddress updateAddress) {
191
        try {
192
            ensureMaster();
193
            .updateAddress(updateAddress.getNodeName(),
194
                                  updateAddress.getNewHostName(),
195
                                  updateAddress.getNewPort());
196
            return .new OK();
197
        } catch (MemberNotFoundException e) {
198
            return .new Fail(.,
199
                                     e.getMessage());
200
        } catch (MasterStateException e) {
201
            return .new Fail(., e.getMessage());
202
        } catch (ReplicaStateException e) {
203
            return .new Fail(., e.getMessage());
204
        } catch (DatabaseException e) {
205
            return .new Fail(., e.getMessage());
206
        }
207
    }

    
Transfer the master role from the current master to one of the specified replicas.

Parameters:
transferMaster the request identifying nodes to be considered for the role of new master
Returns:
null
217
    public ResponseMessage process(TransferMaster transferMaster) {
218
        try {
219
            ensureMaster();
220
            final String nodeList = transferMaster.getNodeNameList();
221
            final Set<String> replicas = parseNodeList(nodeList);
222
            final long timeout = transferMaster.getTimeout();
223
            final boolean force = transferMaster.getForceFlag();
224
            String winner = .transferMaster(replicas, timeout, force);
225
            return .new TransferOK(winner);
226
        } catch (ReplicaStateException e) {
227
            return .new Fail(., e.getMessage());
228
        } catch (MasterTransferFailureException e) {
229
            return .new Fail(., e.getMessage());
230
        } catch (DatabaseException e) {
231
            return .new Fail(., e.getMessage());
232
        } catch (IllegalArgumentException e) {
233
            return .new Fail(., e.toString());
234
        } catch (IllegalStateException e) {
235
            return .new Fail(., e.toString());
236
        }
237
    }
238
    
239
    private Set<String> parseNodeList(String list) {
240
        Set<String> set = new HashSet<String>();
241
        StringTokenizer st = new StringTokenizer(list, ",");
242
        while (st.hasMoreTokens()) {
243
            set.add(st.nextToken());
244
        }
245
        return set;
246
    }
248
    private void ensureMaster() throws ReplicaStateException {
249
        if (!.isMaster()) {
250
            throw new ReplicaStateException
251
                ("GroupService operation can only be performed at master");
252
        }
253
    }
255
    synchronized private void registerSocket(SocketChannel sc) {
256
        .add(sc);
257
    }

    
Removes the given SocketChannel from our list of active sockets.

Before sending any response on the socket, this method must be invoked to claim ownership of it. This avoids a potential race between the request processing thread in the normal case, and a thread calling cancel() at env shutdown time.

Returns:
true, if the socket is still active (usual case); false otherwise, presumably because the service was shut down.
271
    synchronized private boolean unregisterSocket(SocketChannel sc) {
272
        return .remove(sc);
273
    }
275
    @Override
276
    public Runnable getRunnable(SocketChannel socketChannel) {
277
        return new GroupServiceRunnable(socketChannel, );
278
    }
280
    class GroupServiceRunnable extends ExecutingRunnable {
281
        GroupServiceRunnable(SocketChannel socketChannel, 
282
                             RepGroupProtocol protocol) {
283
            super(socketChannel, protocol, true);
284
            registerSocket(socketChannel);
285
        }
287
        @Override
288
        protected ResponseMessage getResponse(RequestMessage request)  
289
            throws IOException {
291
            ResponseMessage rm = .process(GroupService.this, request);
293
            /*
294
             * If the socket has already been closed, before we got a chance to
295
             * produce the response, then just discard the tardy response and
296
             * return null.
297
             */
298
            return unregisterSocket() ? rm : null;
299
        }
301
        @Override
302
        protected void logMessage(String message) {
303
            LoggerUtils.warning(, .getRepImpl(), message);
304
        }
305
    }
New to GrepCode? Check out our FAQ X