Package org.jgroups.upgrade_server

Class UpgradeService

java.lang.Object

org.jgroups.upgrade_server.UpgradeServiceGrpc.UpgradeServiceImplBase

org.jgroups.upgrade_server.UpgradeService

All Implemented Interfaces:

io.grpc.BindableService

public class UpgradeService
extends org.jgroups.upgrade_server.UpgradeServiceGrpc.UpgradeServiceImplBase

Since:

1.0.0 todo: Add logging instead of System.err.printf

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	UpgradeService.SynchronizedMap

Field Summary

Fields

Modifier and Type	Field	Description
protected ConcurrentMap<String,UpgradeService.SynchronizedMap>	members
protected long	view_id

Constructor Summary

Constructors

Constructor	Description
UpgradeService()

Method Summary

Modifier and Type	Method	Description
io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Request>	connect(io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Response> responseObserver)
void	dump(org.jgroups.upgrade_server.Void request, io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.DumpResponse> responseObserver)
protected String	dumpDiagnostics()
protected void	dumpViews(StringBuilder sb)
protected long	getNewViewId()
protected void	handleJoinRequest(org.jgroups.upgrade_server.JoinRequest join_req, io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Response> responseObserver)
protected void	handleLeaveRequest(org.jgroups.upgrade_server.LeaveRequest leave_req, io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Response> responseObserver)
protected void	handleMessage(org.jgroups.upgrade_server.Message msg)
void	leave(org.jgroups.upgrade_server.LeaveRequest req, io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Void> responseObserver)
protected void	postView(Map<org.jgroups.upgrade_server.Address,io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Response>> map)
protected void	relayTo(org.jgroups.upgrade_server.Message msg, UpgradeService.SynchronizedMap m)
protected void	relayToAll(org.jgroups.upgrade_server.Message msg, UpgradeService.SynchronizedMap m)
protected void	remove(io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Response> observer)

Methods inherited from class org.jgroups.upgrade_server.UpgradeServiceGrpc.UpgradeServiceImplBase

bindService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

members

protected final ConcurrentMap<String,UpgradeService.SynchronizedMap> members

view_id

protected long view_id

Constructor Detail

UpgradeService

public UpgradeService()

Method Detail

connect

public io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Request> connect(io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Response> responseObserver)

Overrides:

connect in class org.jgroups.upgrade_server.UpgradeServiceGrpc.UpgradeServiceImplBase

leave

public void leave(org.jgroups.upgrade_server.LeaveRequest req,
                  io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Void> responseObserver)

Overrides:

leave in class org.jgroups.upgrade_server.UpgradeServiceGrpc.UpgradeServiceImplBase

dump

public void dump(org.jgroups.upgrade_server.Void request,
                 io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.DumpResponse> responseObserver)

Overrides:

dump in class org.jgroups.upgrade_server.UpgradeServiceGrpc.UpgradeServiceImplBase

remove

protected void remove(io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Response> observer)

handleJoinRequest

protected void handleJoinRequest(org.jgroups.upgrade_server.JoinRequest join_req,
                                 io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Response> responseObserver)

handleLeaveRequest

protected void handleLeaveRequest(org.jgroups.upgrade_server.LeaveRequest leave_req,
                                  io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Response> responseObserver)

handleMessage

protected void handleMessage(org.jgroups.upgrade_server.Message msg)

relayToAll

protected void relayToAll(org.jgroups.upgrade_server.Message msg,
                          UpgradeService.SynchronizedMap m)

relayTo

protected void relayTo(org.jgroups.upgrade_server.Message msg,
                       UpgradeService.SynchronizedMap m)

postView

protected void postView(Map<org.jgroups.upgrade_server.Address,io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Response>> map)

dumpDiagnostics

protected String dumpDiagnostics()

dumpViews

protected void dumpViews(StringBuilder sb)

getNewViewId

protected long getNewViewId()