Election.ice

Go to the documentation of this file.

// **********************************************************************
//
// Copyright (c) 2003-2017 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************
 
#pragma once
 
[["ice-prefix", "cpp:header-ext:h"]]
 
#include <Ice/Identity.ice>
#include <Ice/BuiltinSequences.ice>
#include <IceStorm/SubscriberRecord.ice>
#include <IceStorm/LLURecord.ice>
 
module IceStormElection
{
 
struct TopicContent
{
    Ice::Identity id;
    IceStorm::SubscriberRecordSeq records;
}
 
sequence<TopicContent> TopicContentSeq;
 
exception ObserverInconsistencyException
{
    string reason;
}
 
interface ReplicaObserver
{
    void init(LogUpdate llu, TopicContentSeq content)
        throws ObserverInconsistencyException;
 
    void createTopic(LogUpdate llu, string name)
        throws ObserverInconsistencyException;
 
    void destroyTopic(LogUpdate llu, string name)
        throws ObserverInconsistencyException;
 
    void addSubscriber(LogUpdate llu, string topic, IceStorm::SubscriberRecord record)
        throws ObserverInconsistencyException;
 
    void removeSubscriber(LogUpdate llu, string topic, Ice::IdentitySeq subscribers)
        throws ObserverInconsistencyException;
}
 
interface TopicManagerSync
{
    void getContent(out LogUpdate llu, out TopicContentSeq content);
}
 
enum NodeState
{
    NodeStateInactive,
    NodeStateElection,
    NodeStateReorganization,
    NodeStateNormal
}
 
interface Node;
 
struct NodeInfo
{
    int id;
    Node* n;
}
 
sequence<NodeInfo> NodeInfoSeq;
 
struct GroupInfo
{
    int id;
    LogUpdate llu;
}
sequence<GroupInfo> GroupInfoSeq;
 
struct QueryInfo
{
    int id;
 
    int coord;
 
    string group;
 
    Object* replica;
 
    NodeState state;
 
    GroupInfoSeq up;
 
    int max;
}
 
interface Node
{
    void invitation(int j, string gn);
 
    void ready(int j, string gn, Object* coordinator, int max, long generation);
 
    void accept(int j, string gn, Ice::IntSeq forwardedInvites, Object* observer, LogUpdate llu, int max);
 
    ["cpp:const"] idempotent bool areYouCoordinator();
 
    ["cpp:const"] idempotent bool areYouThere(string gn, int j);
 
    ["cpp:const"] idempotent Object* sync();
 
    ["cpp:const"] idempotent NodeInfoSeq nodes();
 
    ["cpp:const"] idempotent QueryInfo query();
}
 
}