本文整理了Java中net.i2p.data.Hash.equals()方法的一些代码示例，展示了Hash.equals()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Hash.equals()方法的具体详情如下：
包路径：net.i2p.data.Hash
类名称：Hash
方法名：equals
暂无
代码示例来源：origin: i2p/i2p.i2p
public boolean equals(Object o) {
if (o == null || !(o instanceof HashPair))
return false;
HashPair hp = (HashPair) o;
return sh.equals(hp.sh) && dh.equals(hp.dh);
}
}代码示例来源：origin: i2p/i2p.i2p
@Override
public boolean equals(Object obj) {
if (obj == null ||
!(obj instanceof PeerProfile))
return false;
PeerProfile prof = (PeerProfile)obj;
return _peer.equals(prof._peer);
}代码示例来源：origin: i2p/i2p.i2p
/**
* Called by the message handler
* on reception of DestReplyMessage
* @param h non-null
*/
void destLookupFailed(Hash h) {
for (LookupWaiter w : _pendingLookups) {
if (h.equals(w.hash)) {
synchronized (w) {
w.notifyAll();
}
}
}
}代码示例来源：origin: i2p/i2p.i2p
public boolean isMatch(I2NPMessage message) {
if (message instanceof DatabaseStoreMessage) {
DatabaseStoreMessage dsm = (DatabaseStoreMessage)message;
return _key.equals(dsm.getKey());
} else if (message instanceof DatabaseSearchReplyMessage) {
DatabaseSearchReplyMessage dsrm = (DatabaseSearchReplyMessage)message;
return _key.equals(dsrm.getSearchKey());
}
return false;
}
}代码示例来源：origin: i2p/i2p.i2p
@Override
public boolean equals(Object o) {
try {
NodeInfo ni = (NodeInfo) o;
// assume dest matches, ignore it
return this.hash.equals(ni.hash) && nID.equals(ni.nID) && port == ni.port;
} catch (RuntimeException e) {
return false;
}
}代码示例来源：origin: i2p/i2p.i2p
@Override
public boolean equals(Object obj) {
if (obj == null || !(obj instanceof ReplyTunnel))
return false;
return this.h.equals(((ReplyTunnel)obj).h) &&
this.id.equals(((ReplyTunnel)obj).id);
}代码示例来源：origin: i2p/i2p.i2p
/**
* This can come in later but the hash must match.
* @throws IllegalArgumentException if hash of dest doesn't match previous hash
*/
public void setDestination(Destination dest) throws IllegalArgumentException {
if (this.dest != null)
return;
if (!dest.calculateHash().equals(this.hash))
throw new IllegalArgumentException("Hash mismatch, was: " + this.hash + " new: " + dest.calculateHash());
this.dest = dest;
}代码示例来源：origin: i2p/i2p.i2p
public void tunnelDataPushed1m(Hash peer, int size) {
if (_context.routerHash().equals(peer))
return;
PeerProfile data = getProfile(peer);
//if (data != null)
data.dataPushed1m(size);
}代码示例来源：origin: i2p/i2p.i2p
public void tunnelLifetimePushed(Hash peer, long lifetime, long size) {
if (_context.routerHash().equals(peer))
return;
PeerProfile data = getProfile(peer);
//if (data != null)
data.tunnelDataTransferred(size);
}代码示例来源：origin: i2p/i2p.i2p
public void tunnelDataPushed(Hash peer, long rtt, int size) {
if (_context.routerHash().equals(peer))
return;
PeerProfile data = getProfile(peer);
//if (data != null)
data.dataPushed(size); // ignore rtt, as we are averaging over a minute
}代码示例来源：origin: i2p/i2p.i2p
/**
* Retrieve the profile for the given peer, if one exists (else null).
* Blocking if a reorganize is happening.
*/
public PeerProfile getProfile(Hash peer) {
if (peer.equals(_us)) {
if (_log.shouldWarn())
_log.warn("Who wanted our own profile?", new Exception("I did"));
return null;
}
getReadLock();
try {
return locked_getProfile(peer);
} finally { releaseReadLock(); }
}代码示例来源：origin: i2p/i2p.i2p
/**
* @throws IllegalStateException if not in RouterContext
*/
public boolean validateRoutingKey() {
I2PAppContext ctx = I2PAppContext.getGlobalContext();
if (!ctx.isRouterContext())
throw new IllegalStateException("Not in router context");
RoutingKeyGenerator gen = ctx.routingKeyGenerator();
Hash destKey = getHash();
Hash rk = gen.getRoutingKey(destKey);
return rk.equals(getRoutingKey());
}代码示例来源：origin: i2p/i2p.i2p
/**
* Retrieve the profile for the given peer, if one exists (else null).
* Non-blocking. Returns null if a reorganize is happening.
* @since 0.8.12
*/
public PeerProfile getProfileNonblocking(Hash peer) {
if (peer.equals(_us)) {
if (_log.shouldWarn())
_log.warn("Who wanted our own profile?", new Exception("I did"));
return null;
}
if (tryReadLock()) {
try {
return locked_getProfile(peer);
} finally { releaseReadLock(); }
}
return null;
}代码示例来源：origin: i2p/i2p.i2p
/**
* So LocalClientMessageEventListener can lookup other local dests
*/
public Destination localLookup(Hash h) {
for (Destination d : _manager.getRunnerDestinations()) {
if (d.calculateHash().equals(h))
return d;
}
return null;
}
}代码示例来源：origin: i2p/i2p.i2p
/**
* Fail all (outbound) tunnels with this peer as first hop (not counting us)
*
* @since 0.8.13
*/
private void failTunnelsWithFirstHop(TunnelPool pool, Hash peer) {
for (TunnelInfo tun : pool.listTunnels()) {
int len = tun.getLength();
if (len > 1 && tun.getPeer(1).equals(peer)) {
if (_log.shouldLog(Log.WARN))
_log.warn("Removing OB tunnel, first hop banlisted: " + tun);
pool.tunnelFailed(tun, peer);
}
}
}代码示例来源：origin: i2p/i2p.i2p
@Override
public boolean equals(Object o) {
if (o == null) return false;
if (o.getClass() != Tunnel.class) return false;
Tunnel t = (Tunnel)o;
return (getTunnel() == t.getTunnel()) &&
getGateway().equals(t.getGateway());
}
}代码示例来源：origin: i2p/i2p.i2p
/**
* Fail all (inbound) tunnels with this peer as last hop (not counting us)
*
* @since 0.8.13
*/
private void failTunnelsWithLastHop(TunnelPool pool, Hash peer) {
for (TunnelInfo tun : pool.listTunnels()) {
int len = tun.getLength();
if (len > 1 && tun.getPeer(len - 2).equals(peer)) {
if (_log.shouldLog(Log.WARN))
_log.warn("Removing IB tunnel, prev. hop banlisted: " + tun);
pool.tunnelFailed(tun, peer);
}
}
}
}代码示例来源：origin: i2p/i2p.i2p
private void addRandom(int count) {
for (int i = 0; i < count; i++) {
byte val[] = new byte[Hash.HASH_LENGTH];
context.random().nextBytes(val);
Hash h = new Hash(val);
// in the highly unlikely chance we randomly generate a hash equal to us
assertTrue(set.add(h) || h.equals(usHash));
}
}代码示例来源：origin: i2p/i2p.i2p
public void runJob() {
Hash from = _dsrm.getFromHash();
int limit = Math.min(_dsrm.getNumReplies(), MAX_TO_FOLLOW);
for (int i = 0; i < limit; i++) {
Hash peer = _dsrm.getReply(i);
if (peer.equals(getContext().routerHash())) // us
continue;
if (peer.equals(from)) // unusual?
continue;
RouterInfo ri = getContext().netDb().lookupRouterInfoLocally(peer);
if (ri == null)
getContext().jobQueue().addJob(new SingleSearchJob(getContext(), peer, from));
else if (ri.getPublished() < getContext().clock().now() - 60*60*1000 ||
!FloodfillNetworkDatabaseFacade.isFloodfill(ri))
getContext().jobQueue().addJob(new SingleSearchJob(getContext(), peer, peer));
}
}代码示例来源：origin: i2p/i2p.i2p
private void sendData(Hash key, DatabaseEntry data, Hash toPeer, TunnelId replyTunnel) {
if (!key.equals(data.getHash())) {
_log.error("Hash mismatch HDLMJ");
return;
}
if (_log.shouldLog(Log.DEBUG))
_log.debug("Sending data matching key " + key + " to peer " + toPeer
+ " tunnel " + replyTunnel);
DatabaseStoreMessage msg = new DatabaseStoreMessage(getContext());
if (data.isLeaseSet()) {
getContext().statManager().addRateData("netDb.lookupsMatchedLeaseSet", 1);
}
msg.setEntry(data);
getContext().statManager().addRateData("netDb.lookupsMatched", 1);
getContext().statManager().addRateData("netDb.lookupsHandled", 1);
sendMessage(msg, toPeer, replyTunnel);
}内容来源于网络，如有侵权，请联系作者删除！