本文整理汇总了Java中org.apache.cassandra.net.IAsyncCallback类的典型用法代码示例。如果您正苦于以下问题：Java IAsyncCallback类的具体用法？Java IAsyncCallback怎么用？Java IAsyncCallback使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
IAsyncCallback类属于org.apache.cassandra.net包，在下文中一共展示了IAsyncCallback类的6个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: markAlive
import org.apache.cassandra.net.IAsyncCallback; //导入依赖的package包/类
private void markAlive(final InetAddress addr, final EndpointState localState)
{
if (MessagingService.instance().getVersion(addr) < MessagingService.VERSION_20)
{
realMarkAlive(addr, localState);
return;
}
localState.markDead();
MessageOut<EchoMessage> echoMessage = new MessageOut<EchoMessage>(MessagingService.Verb.ECHO, new EchoMessage(), EchoMessage.serializer);
logger.trace("Sending a EchoMessage to {}", addr);
IAsyncCallback echoHandler = new IAsyncCallback()
{
public boolean isLatencyForSnitch()
{
return false;
}
public void response(MessageIn msg)
{
realMarkAlive(addr, localState);
}
};
MessagingService.instance().sendRR(echoMessage, addr, echoHandler);
}
开发者ID:daidong，项目名称:GraphTrek，代码行数:27，代码来源:Gossiper.java
示例2: runMayThrow
import org.apache.cassandra.net.IAsyncCallback; //导入依赖的package包/类
protected void runMayThrow() throws IOException
{
try
{
resolver.resolve();
}
catch (DigestMismatchException e)
{
if (logger.isDebugEnabled())
logger.debug("Digest mismatch:", e);
ReadCommand readCommand = (ReadCommand) command;
final RowRepairResolver repairResolver = new RowRepairResolver(readCommand.table, readCommand.key);
IAsyncCallback repairHandler = new AsyncRepairCallback(repairResolver, endpoints.size());
for (InetAddress endpoint : endpoints)
MessagingService.instance().sendRR(readCommand, endpoint, repairHandler);
}
}
开发者ID:devdattakulkarni，项目名称:Cassandra-KVPM，代码行数:20，代码来源:ReadCallback.java
示例3: markAlive
import org.apache.cassandra.net.IAsyncCallback; //导入依赖的package包/类
private void markAlive(final InetAddress addr, final EndpointState localState)
{
if (MessagingService.instance().getVersion(addr) < MessagingService.VERSION_20)
{
realMarkAlive(addr, localState);
return;
}
localState.markDead();
MessageOut<EchoMessage> echoMessage = new MessageOut<EchoMessage>(MessagingService.Verb.ECHO, new EchoMessage(), EchoMessage.serializer);
logger.trace("Sending a EchoMessage to {}", addr);
IAsyncCallback echoHandler = new IAsyncCallback()
{
public boolean isLatencyForSnitch()
{
return false;
}
public void response(MessageIn msg)
{
realMarkAlive(addr, localState);
}
};
MessagingService.instance().sendRR(echoMessage, addr, echoHandler);
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:28，代码来源:Gossiper.java
示例4: markAlive
import org.apache.cassandra.net.IAsyncCallback; //导入依赖的package包/类
private void markAlive(final InetAddress addr, final EndpointState localState)
{
MessageOut<EchoMessage> echoMessage = new MessageOut<EchoMessage>(MessagingService.Verb.ECHO, new EchoMessage(), EchoMessage.serializer);
logger.trace("Sending a EchoMessage to {}", addr);
IAsyncCallback echoHandler = new IAsyncCallback()
{
public boolean isLatencyForSnitch()
{
return false;
}
public void response(MessageIn msg)
{
if (logger.isTraceEnabled())
logger.trace("marking as alive {}", addr);
localState.markAlive();
localState.updateTimestamp(); // prevents doStatusCheck from racing us and evicting if it was down > aVeryLongTime
liveEndpoints.add(addr);
unreachableEndpoints.remove(addr);
expireTimeEndpointMap.remove(addr);
logger.debug("removing expire time for endpoint : {}", addr);
logger.info("InetAddress {} is now UP", addr);
for (IEndpointStateChangeSubscriber subscriber : subscribers)
subscriber.onAlive(addr, localState);
if (logger.isTraceEnabled())
logger.trace("Notified " + subscribers);
}
};
MessagingService.instance().sendRR(echoMessage, addr, echoHandler);
}
开发者ID:pgaref，项目名称:ACaZoo，代码行数:31，代码来源:Gossiper.java
示例5: makeSnapshots
import org.apache.cassandra.net.IAsyncCallback; //导入依赖的package包/类
public void makeSnapshots(Collection<InetAddress> endpoints)
{
try
{
snapshotLatch = new CountDownLatch(endpoints.size());
IAsyncCallback callback = new IAsyncCallback()
{
public boolean isLatencyForSnitch()
{
return false;
}
public void response(MessageIn msg)
{
RepairJob.this.snapshotLatch.countDown();
}
};
for (InetAddress endpoint : endpoints)
MessagingService.instance().sendRR(new SnapshotCommand(desc.keyspace, desc.columnFamily, desc.sessionId.toString(), false).createMessage(), endpoint, callback);
snapshotLatch.await();
snapshotLatch = null;
}
catch (InterruptedException e)
{
throw new RuntimeException(e);
}
}
开发者ID:pgaref，项目名称:ACaZoo，代码行数:28，代码来源:RepairJob.java
示例6: markAlive
import org.apache.cassandra.net.IAsyncCallback; //导入依赖的package包/类
private void markAlive(final InetAddress addr, final EndpointState localState)
{
if (MessagingService.instance().getVersion(addr) < MessagingService.VERSION_20)
{
realMarkAlive(addr, localState);
return;
}
localState.markDead();
MessageOut<EchoMessage> echoMessage = new MessageOut<EchoMessage>(MessagingService.Verb.ECHO, EchoMessage.instance, EchoMessage.serializer);
logger.trace("Sending a EchoMessage to {}", addr);
IAsyncCallback echoHandler = new IAsyncCallback()
{
public boolean isLatencyForSnitch()
{
return false;
}
public void response(MessageIn msg)
{
realMarkAlive(addr, localState);
}
};
MessagingService.instance().sendRR(echoMessage, addr, echoHandler);
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:28，代码来源:Gossiper.java
注：本文中的org.apache.cassandra.net.IAsyncCallback类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论