Examples of trackerData()

Examples of net.tomp2p.message.Message.trackerData()

84
85
86
87
88
89
90
91
92
93
94
    if (peerAddressToAnnounce == null) {
      peerAddressToAnnounce = peerBean().serverPeerAddress();
    }
    trackerData.put(new PeerStatistic(peerAddressToAnnounce), builder.attachement());
    trackerData = UtilsTracker.limit(trackerData, TrackerRPC.MAX_MSG_SIZE_UDP);
    message.trackerData(trackerData);

    if (builder.isForceTCP()) {
      return requestHandler.sendTCP(channelCreator);
    } else {
      return requestHandler.sendUDP(channelCreator);
View Full Code Here

Examples of net.tomp2p.message.Message.trackerData()

130
131
132
133
134
135
136
137
138
139
140
        if (future.isSuccess()) {
          // Since I might become a tracker as well, we keep this
          // information
          // about those trackers.
          Message message = future.responseMessage();
          TrackerData tmp = message.trackerData(0);
          // no data found
          if (tmp == null || tmp.size() == 0) {
            return;
          }
View Full Code Here

Examples of net.tomp2p.message.Message.trackerData()

180
181
182
183
184
185
186
187
188
189
190
      }
      int size = meshPeers.size();

      meshPeers = UtilsTracker.limit(meshPeers, TrackerRPC.MAX_MSG_SIZE_UDP);
      couldProvideMoreData = size > meshPeers.size();
      responseMessage.trackerData(meshPeers);
    }

    if (couldProvideMoreData) {
      responseMessage.type(Message.Type.PARTIALLY_OK);
    }
View Full Code Here

Examples of net.tomp2p.message.Message.trackerData()

98
99
100
101
102
103
104
105
106
107
108
        message.key(key.locationKey());
        message.key(key.domainKey());
       
    LOG.debug("sent ({}) to {} / {}", message.sender().peerId(), remotePeer.peerId(), peers.size());
    message.trackerData(peers);
    FutureResponse futureResponse = new FutureResponse(message);
    final RequestHandler<FutureResponse> requestHandler = new RequestHandler<FutureResponse>(futureResponse,
            peerBean(), connectionBean(), connectionConfiguration);
    if (!connectionConfiguration.isForceTCP()) {
      return requestHandler.fireAndForgetUDP(channelCreator);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.