Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- # From: https://github.com/freenet/fred/blob/cbfae4ae632608f82e5eeaf9a115588b32014c3a/src/freenet/node/NewPacketFormat.java#L608
- addOldLoop: for(Map<Integer, MessageWrapper> started : startedByPrio) {
- //Try to finish messages that have been started
- Iterator<MessageWrapper> it = started.values().iterator();
- while(it.hasNext() && packet.getLength() < maxPacketSize) {
- MessageWrapper wrapper = it.next();
- while(packet.getLength() < maxPacketSize) {
- MessageFragment frag = wrapper.getMessageFragment(maxPacketSize - packet.getLength());
- if(frag == null) break;
- mustSend = true;
- addedFragments = true;
- packet.addMessageFragment(frag);
- sentPacket.addFragment(frag);
- if(wrapper.allSent()) {
- if((haveAddedStatsBulk == null) && wrapper.getItem().sendLoadBulk) {
- addStatsBulk = true;
- // Add the lossy message outside the lock.
- break addOldLoop;
- }
- if((haveAddedStatsRT == null) && wrapper.getItem().sendLoadRT) {
- addStatsRT = true;
- // Add the lossy message outside the lock.
- break addOldLoop;
- }
- }
- }
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment