blob: 75ab95198822b8af617936a181243f81ab6c7a8d [file] [log] [blame]
package com.gemstone.org.jgroups.stack;
import java.net.DatagramSocket;
import java.net.SocketAddress;
import java.util.List;
import java.util.Properties;
import java.util.Set;
import java.util.Timer;
import com.gemstone.org.jgroups.Address;
import com.gemstone.org.jgroups.spi.GFPeerAdapter;
import com.gemstone.org.jgroups.util.GFLogWriter;
import com.gemstone.org.jgroups.util.StringId;
public class GFPeerAdapterImpl implements GFPeerAdapter {
@Override
public DatagramSocket getMembershipSocketForUDP() {
return null;
}
@Override
public boolean getDisableAutoReconnect() {
return true;
}
@Override
public boolean isReconnectingDS() {
return false;
}
@Override
public Timer getConnectionTimeoutTimer() {
return null;
}
@Override
public void setCacheTimeOffset(Address src, long timeOffs, boolean b) {
}
@Override
public boolean getDisableTcp() {
return true;
}
@Override
public boolean isShunnedMemberNoSync(IpAddress mbr) {
return false;
}
@Override
public int getAckWaitThreshold() {
return 15;
}
@Override
public int getAckSevereAlertThreshold() {
return 0;
}
@Override
public int getSerialQueueThrottleTime(Address src) {
return 0;
}
@Override
public void pongReceived(SocketAddress socketAddress) {
}
@Override
public void quorumLost(Set failures, List remaining) {
}
@Override
public boolean isShuttingDown(IpAddress addr) {
return false;
}
@Override
public int getMcastPort() {
return 0;
}
@Override
public void enableNetworkPartitionDetection() {
}
@Override
public long getShunnedMemberTimeout() {
return 60000;
}
@Override
public long getMemberTimeout() {
return 5000;
}
@Override
public Properties getCredentials(String authInitMethod, Properties secProps,
Address createDistributedMember, boolean b, GFLogWriter logWriter,
GFLogWriter securityLogWriter) {
return null;
}
@Override
public void verifyCredentials(String authenticator, Properties credentials,
Properties securityProperties, GFLogWriter logWriter,
GFLogWriter securityLogWriter, Address src) {
}
@Override
public void logStartup(StringId msgId, Object...params) {
}
@Override
public void incUcastReadBytes(int len) {
}
@Override
public void incjChannelUpTime(long l) {
}
@Override
public void incjgChannelDownTime(long l) {
}
@Override
public void setJgUNICASTreceivedMessagesSize(long rm) {
}
@Override
public void incJgUNICASTdataReceived(long l) {
}
@Override
public void setJgUNICASTsentHighPriorityMessagesSize(long hm) {
}
@Override
public void setJgUNICASTsentMessagesSize(long sm) {
}
@Override
public void incUcastRetransmits() {
}
@Override
public void incJgFragmentsCreated(int num_frags) {
}
@Override
public void incJgFragmentationsPerformed() {
}
@Override
public void incMcastReadBytes(int len) {
}
@Override
public long startMcastWrite() {
return 0;
}
@Override
public void endMcastWrite(long start, int length) {
}
@Override
public long startUcastWrite() {
return 0;
}
@Override
public void endUcastWrite(long start, int length) {
}
@Override
public void incFlowControlResponses() {
}
@Override
public void incJgFCsendBlocks(int i) {
}
@Override
public long startFlowControlWait() {
return 0;
}
@Override
public void incJgFCautoRequests(int i) {
}
@Override
public void endFlowControlWait(long blockStartTime) {
}
@Override
public long startFlowControlThrottleWait() {
return 0;
}
@Override
public void endFlowControlThrottleWait(long blockStartTime) {
}
@Override
public void incJgFCreplenish(int i) {
}
@Override
public void incJgFCresumes(int i) {
}
@Override
public void setJgQueuedMessagesSize(int size) {
}
@Override
public void incJgFCsentThrottleRequests(int i) {
}
@Override
public void incJgFCsentCredits(int i) {
}
@Override
public void incFlowControlRequests() {
}
@Override
public void incjgUpTime(long l) {
}
@Override
public void incBatchSendTime(long gsstart) {
}
@Override
public void incBatchCopyTime(long start) {
}
@Override
public void incBatchFlushTime(long start) {
}
@Override
public void incMcastRetransmitRequests() {
}
@Override
public void setJgSTABLEreceivedMessagesSize(long received_msgs_size) {
}
@Override
public void setJgSTABLEsentMessagesSize(int size) {
}
@Override
public void incJgNAKACKwaits(int i) {
}
@Override
public void incMcastRetransmits() {
}
@Override
public void incJgSTABLEmessagesSent(int i) {
}
@Override
public void incJgSTABLEmessages(int i) {
}
@Override
public void incJgSTABLEsuspendTime(long l) {
}
@Override
public void incJgSTABILITYmessages(int i) {
}
@Override
public void beforeChannelClosing(String string,
RuntimeException closeException) {
}
@Override
public void beforeSendingPayload(Object gfmsg) {
}
@Override
public boolean shutdownHookIsAlive() {
return false;
}
@Override
public boolean isAdminOnlyMember() {
return false;
}
@Override
public boolean hasLocator() {
return false;
}
@Override
public boolean isDisconnecting() {
return false;
}
}