Is there any reason to have both isDarknet() and isOpennet()? I suppose seed
nodes would return false for both?
On Wednesday 09 January 2008 00:53, zothar at freenetproject.org wrote:
> Author: zothar
> Date: 2008-01-09 00:53:07 +0000 (Wed, 09 Jan 2008)
> New Revision: 16974
>
> Modified:
> trunk/freenet/src/freenet/node/DarknetPeerNode.java
> trunk/freenet/src/freenet/node/OpennetPeerNode.java
> trunk/freenet/src/freenet/node/PeerNode.java
> trunk/freenet/src/freenet/node/SeedClientPeerNode.java
> trunk/freenet/src/freenet/node/SeedServerPeerNode.java
> Log:
> Implement isDarknet(). Move sendNodeToNodeMessage() to PeerNode and queue
on not connected only if the peer is a darknet peer.
>
> Modified: trunk/freenet/src/freenet/node/DarknetPeerNode.java
> ===================================================================
> --- trunk/freenet/src/freenet/node/DarknetPeerNode.java 2008-01-09
> 00:00:39
UTC (rev 16973)
> +++ trunk/freenet/src/freenet/node/DarknetPeerNode.java 2008-01-09
> 00:53:07
UTC (rev 16974)
> @@ -1257,28 +1257,6 @@
> }
> }
>
> - public void sendNodeToNodeMessage(SimpleFieldSet fs, int n2nType,
> boolean
includeSentTime, long now) {
> - fs.put("n2nType", n2nType);
> - if(includeSentTime) {
> - fs.put("sentTime", now);
> - }
> - try {
> - Message n2nm;
> - n2nm = DMT.createNodeToNodeMessage(
> - n2nType,
> fs.toString().getBytes("UTF-8"));
> - try {
> - sendAsync(n2nm, null, 0, null);
> - } catch (NotConnectedException e) {
> - if(includeSentTime) {
> - fs.removeValue("sentTime");
> - }
> - queueN2NM(fs);
> - }
> - } catch (UnsupportedEncodingException e) {
> - throw new Error("Impossible: "+e, e);
> - }
> - }
> -
> public int sendFileOfferAccepted(long uid) {
> storeOffers();
> long now = System.currentTimeMillis();
> @@ -1509,6 +1487,10 @@
> return new DarknetPeerNodeStatus(this, noHeavy);
> }
>
> + public boolean isDarknet() {
> + return true;
> + }
> +
> public boolean isOpennet() {
> return false;
> }
>
> Modified: trunk/freenet/src/freenet/node/OpennetPeerNode.java
> ===================================================================
> --- trunk/freenet/src/freenet/node/OpennetPeerNode.java 2008-01-09
> 00:00:39
UTC (rev 16973)
> +++ trunk/freenet/src/freenet/node/OpennetPeerNode.java 2008-01-09
> 00:53:07
UTC (rev 16974)
> @@ -23,6 +23,10 @@
> return super.isRoutingCompatible();
> }
>
> + public boolean isDarknet() {
> + return false;
> + }
> +
> public boolean isOpennet() {
> return true;
> }
>
> Modified: trunk/freenet/src/freenet/node/PeerNode.java
> ===================================================================
> --- trunk/freenet/src/freenet/node/PeerNode.java 2008-01-09 00:00:39 UTC
(rev 16973)
> +++ trunk/freenet/src/freenet/node/PeerNode.java 2008-01-09 00:53:07 UTC
(rev 16974)
> @@ -2367,6 +2367,8 @@
> return fs;
> }
>
> + public abstract boolean isDarknet();
> +
> public abstract boolean isOpennet();
>
> /**
> @@ -3498,4 +3500,35 @@
> }
>
> private int handshakeIPAlternator;
> +
> + public void sendNodeToNodeMessage(SimpleFieldSet fs, int n2nType,
> boolean
includeSentTime, long now) {
> + fs.put("n2nType", n2nType);
> + if(includeSentTime) {
> + fs.put("sentTime", now);
> + }
> + try {
> + Message n2nm;
> + n2nm = DMT.createNodeToNodeMessage(
> + n2nType,
> fs.toString().getBytes("UTF-8"));
> + try {
> + sendAsync(n2nm, null, 0, null);
> + } catch (NotConnectedException e) {
> + if(includeSentTime) {
> + fs.removeValue("sentTime");
> + }
> + if(isDarknet()) {
> + queueN2NM(fs);
> + }
> + }
> + } catch (UnsupportedEncodingException e) {
> + throw new Error("Impossible: "+e, e);
> + }
> + }
> +
> + /**
> + * A method to be to queue an N2NM in a extra peer data file, only
implemented by DarknetPeerNode
> + */
> + public void queueN2NM(SimpleFieldSet fs) {
> + // Do nothing in the default impl
> + }
> }
>
> Modified: trunk/freenet/src/freenet/node/SeedClientPeerNode.java
> ===================================================================
> --- trunk/freenet/src/freenet/node/SeedClientPeerNode.java 2008-01-09
00:00:39 UTC (rev 16973)
> +++ trunk/freenet/src/freenet/node/SeedClientPeerNode.java 2008-01-09
00:53:07 UTC (rev 16974)
> @@ -21,6 +21,10 @@
> return new PeerNodeStatus(this, noHeavy);
> }
>
> + public boolean isDarknet() {
> + return false;
> + }
> +
> public boolean isOpennet() {
> return false; // Not exactly
> }
>
> Modified: trunk/freenet/src/freenet/node/SeedServerPeerNode.java
> ===================================================================
> --- trunk/freenet/src/freenet/node/SeedServerPeerNode.java 2008-01-09
00:00:39 UTC (rev 16973)
> +++ trunk/freenet/src/freenet/node/SeedServerPeerNode.java 2008-01-09
00:53:07 UTC (rev 16974)
> @@ -26,6 +26,10 @@
> return new PeerNodeStatus(this, noHeavy);
> }
>
> + public boolean isDarknet() {
> + return false;
> + }
> +
> public boolean isOpennet() {
> return false;
> }
>
> _______________________________________________
> cvs mailing list
> cvs at freenetproject.org
> http://emu.freenetproject.org/cgi-bin/mailman/listinfo/cvs
>
>
-------------- next part --------------
A non-text attachment was scrubbed...
Name: not available
Type: application/pgp-signature
Size: 189 bytes
Desc: not available
URL:
<https://emu.freenetproject.org/pipermail/devl/attachments/20080111/5bb30078/attachment.pgp>