Examples of freenet.io.comm.MessageFilter

freenet.io.comm.MessageFilter
@author ianTo change the template for this generated type comment go to Window - Preferences - Java - Code Generation - Code and Comments

        source.localRejectedOverload("TimedOutAwaitingDataInsert", realTimeFlag);
        
        // Two stage timeout. Don't go fatal unless no response in 60 seconds.
        // Yes it's ugly everywhere but since we have a longish connection timeout it's necessary everywhere. :|
        // FIXME review two stage timeout everywhere with some low level networking guru.
        MessageFilter mf = makeDataInsertFilter(SECONDS.toMillis(60));
        node.usm.addAsyncFilter(mf, new SlowAsyncMessageFilterCallback() {


          @Override
          public void onMatched(Message m) {
            // Okay, great.

View Full Code Here


            byte[] myHash = md.digest(myValue);


            Message m = DMT.createFNPSwapReply(uid, myHash);


            MessageFilter filter =
                MessageFilter.create().setType(DMT.FNPSwapCommit).setField(DMT.UID, uid).setTimeout(TIMEOUT).setSource(pn);


            node.usm.send(pn, m, LocationManager.this);


            Message commit;

View Full Code Here

                // Only 1 ID because we are sending; we won't receive
                item = addForwardedItem(uid, uid, null, pn);


                if(logMINOR) Logger.minor(this, "Sending SwapRequest "+uid+" to "+pn);


                MessageFilter filter1 =
                    MessageFilter.create().setType(DMT.FNPSwapRejected).setField(DMT.UID, uid).setSource(pn).setTimeout(TIMEOUT);
                MessageFilter filter2 =
                    MessageFilter.create().setType(DMT.FNPSwapReply).setField(DMT.UID, uid).setSource(pn).setTimeout(TIMEOUT);
                MessageFilter filter = filter1.or(filter2);


                node.usm.send(pn, m, LocationManager.this);


                if(logMINOR) Logger.minor(this, "Waiting for SwapReply/SwapRejected on "+uid);
                Message reply;
                try {
                    reply = node.usm.waitFor(filter, LocationManager.this);
                } catch (DisconnectedException e) {
                  if(logMINOR) Logger.minor(this, "Disconnected while waiting for SwapReply/SwapRejected for "+uid);
                    return;
                }


                if(reply == null) {
                    if(pn.isRoutable() && (System.currentTimeMillis() - pn.timeLastConnectionCompleted() > TIMEOUT*2)) {
                        // Timed out! Abort...
                        Logger.error(this, "Timed out waiting for SwapRejected/SwapReply on "+uid);
                    }
                    return;
                }


                if(reply.getSpec() == DMT.FNPSwapRejected) {
                    // Failed. Abort.
                  if(logMINOR) Logger.minor(this, "Swap rejected on "+uid);
                    return;
                }


                // We have an FNPSwapReply, yay
                // FNPSwapReply is exactly the same format as FNPSwapRequest
                byte[] hisHash = ((ShortBuffer)reply.getObject(DMT.HASH)).getData();


                Message confirm = DMT.createFNPSwapCommit(uid, myValue);
                //confirm.addSubMessage(DMT.createFNPSwapLocations(extractUIDs(friendLocsAndUIDs)));


                filter1.clearOr();
                MessageFilter filter3 = MessageFilter.create().setField(DMT.UID, uid).setType(DMT.FNPSwapComplete).setTimeout(TIMEOUT).setSource(pn);
                filter = filter1.or(filter3);


                node.usm.send(pn, confirm, LocationManager.this);


                if(logMINOR) Logger.minor(this, "Waiting for SwapComplete: uid = "+uid);

View Full Code Here

    Message m = DMT.createFNPRoutedPing(uid, loc2, maxHTL, initialX, pubKeyHash);
    Logger.normal(this, "Message: "+m);


    dispatcher.handleRouted(m, null);
    // FIXME: might be rejected
    MessageFilter mf1 = MessageFilter.create().setField(DMT.UID, uid).setType(DMT.FNPRoutedPong).setTimeout(5000);
    try {
      //MessageFilter mf2 = MessageFilter.create().setField(DMT.UID, uid).setType(DMT.FNPRoutedRejected).setTimeout(5000);
      // Ignore Rejected - let it be retried on other peers
      m = usm.waitFor(mf1/*.or(mf2)*/, null);
    } catch (DisconnectedException e) {

View Full Code Here

         *   an SVK/SSK/KSK, therefore could be different to what we are
         *   inserting.
         * - FNPDataInsertRejected - the insert was invalid
         */
        
        MessageFilter mfInsertReply = MessageFilter.create().setSource(next).setField(DMT.UID, uid).setTimeout(searchTimeout).setType(DMT.FNPInsertReply);
        MessageFilter mfRejectedOverload = MessageFilter.create().setSource(next).setField(DMT.UID, uid).setTimeout(searchTimeout).setType(DMT.FNPRejectedOverload);
        MessageFilter mfRouteNotFound = MessageFilter.create().setSource(next).setField(DMT.UID, uid).setTimeout(searchTimeout).setType(DMT.FNPRouteNotFound);
        MessageFilter mfDataInsertRejected = MessageFilter.create().setSource(next).setField(DMT.UID, uid).setTimeout(searchTimeout).setType(DMT.FNPDataInsertRejected);
        MessageFilter mfSSKDataFoundHeaders = MessageFilter.create().setSource(next).setField(DMT.UID, uid).setTimeout(searchTimeout).setType(DMT.FNPSSKDataFoundHeaders);
        
        return mfRouteNotFound.or(mfInsertReply.or(mfRejectedOverload.or(mfDataInsertRejected.or(mfSSKDataFoundHeaders))));
  }

View Full Code Here

    final long uid = tag.uid;
    tag.handlingTimeout(next);
    // The node didn't accept the request. So we don't need to send them the data.
    // However, we do need to wait a bit longer to try to postpone the fatalTimeout().
    // Somewhat intricate logic to try to avoid fatalTimeout() if at all possible.
    MessageFilter mf = makeAcceptedRejectedFilter(next, TIMEOUT_AFTER_ACCEPTEDREJECTED_TIMEOUT, tag);
    try {
      node.usm.addAsyncFilter(mf, new SlowAsyncMessageFilterCallback() {


        @Override
        public void onMatched(Message m) {

View Full Code Here

     */
    Logger.normal(this, "Got collision on "+myKey+" ("+uid+") sending to "+next.getPeer());
    
    headers = ((ShortBuffer) msg.getObject(DMT.BLOCK_HEADERS)).getData();
    // Wait for the data
    MessageFilter mfData = MessageFilter.create().setSource(next).setField(DMT.UID, uid).setTimeout(SSKInsertHandler.DATA_INSERT_TIMEOUT).setType(DMT.FNPSSKDataFoundData);
    Message dataMessage;
    try {
      dataMessage = node.usm.waitFor(mfData, this);
    } catch (DisconnectedException e) {
      if(logMINOR)

View Full Code Here

         * Because messages may be re-ordered, it is
         * entirely possible that we get a non-local RejectedOverload,
         * followed by an Accepted. So we must loop here.
         */
        
        MessageFilter mfAccepted = MessageFilter.create().setSource(next).setField(DMT.UID, uid).setTimeout(acceptedTimeout).setType(DMT.FNPSSKAccepted);
        MessageFilter mfRejectedLoop = MessageFilter.create().setSource(next).setField(DMT.UID, uid).setTimeout(acceptedTimeout).setType(DMT.FNPRejectedLoop);
        MessageFilter mfRejectedOverload = MessageFilter.create().setSource(next).setField(DMT.UID, uid).setTimeout(acceptedTimeout).setType(DMT.FNPRejectedOverload);
        return mfAccepted.or(mfRejectedLoop.or(mfRejectedOverload));
  }

View Full Code Here

      }
          
          // Wait for the SSKPubKeyAccepted
          
          // FIXME doubled the timeout because handling it properly would involve forking.
          MessageFilter mf1 = MessageFilter.create().setSource(next).setField(DMT.UID, uid).setTimeout(ACCEPTED_TIMEOUT*2).setType(DMT.FNPSSKPubKeyAccepted);
          
          Message newAck;
      try {
        newAck = node.usm.waitFor(mf1, this);
      } catch (DisconnectedException e) {
        if(logMINOR) Logger.minor(this, "Disconnected from "+next);
        next.noLongerRoutingTo(thisTag, false);
        routeRequests();
        return;
      }
          
          if(newAck == null) {
            handleNoPubkeyAccepted(next, thisTag);
        // Try another peer
          routeRequests();
          return;
          }
        }
        
        // We have sent them the pubkey, and the data.
        // Wait for the response.
        
    MessageFilter mf = makeSearchFilter(next, calculateTimeout(htl));
        
        while (true) {
          Message msg;
      try {
        msg = node.usm.waitFor(mf, this);

View Full Code Here

      return OFFER_STATUS.TRY_ANOTHER;
    }
  }


  private MessageFilter getOfferedKeyReplyFilter(final PeerNode pn, long timeout) {
      MessageFilter mfRO = MessageFilter.create().setSource(pn).setField(DMT.UID, uid).setTimeout(timeout).setType(DMT.FNPRejectedOverload);
      MessageFilter mfGetInvalid = MessageFilter.create().setSource(pn).setField(DMT.UID, uid).setTimeout(timeout).setType(DMT.FNPGetOfferedKeyInvalid);
      if(isSSK) {
        MessageFilter mfAltDF = MessageFilter.create().setSource(pn).setField(DMT.UID, uid).setTimeout(timeout).setType(DMT.FNPSSKDataFoundHeaders);
        return mfAltDF.or(mfRO.or(mfGetInvalid));
      } else {
        MessageFilter mfDF = MessageFilter.create().setSource(pn).setField(DMT.UID, uid).setTimeout(timeout).setType(DMT.FNPCHKDataFound);
        return mfDF.or(mfRO.or(mfGetInvalid));
      }
  }

View Full Code Here

0 1 2

TOP

Related Classes of freenet.io.comm.MessageFilter

freenet.io.xfer.BlockReceiver

freenet.io.xfer.BlockTransmitter

freenet.io.xfer.BulkReceiver

freenet.node.AnnounceSender

freenet.node.BaseSender

freenet.node.CHKInsertHandler

freenet.node.CHKInsertSender

freenet.node.LocationManager$IncomingSwapRequestHandler

freenet.node.LocationManager$OutgoingSwapRequestHandler

freenet.node.Node

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.