Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
updates
  • Loading branch information
mhanes committed Sep 10, 2009
1 parent da93ca1 commit 31a2b4d
Showing 1 changed file with 8 additions and 1 deletion.
Expand Up @@ -291,12 +291,17 @@ public boolean extract(Node node, IOutgoingTransport targetTransport) throws IOE
routingService.routeData();
}

// possibly here we should do "are there any outgoing batches to send even?"
// to avoid an un-needed reservation & to consolidate the logic
List<OutgoingBatch> batches = outgoingBatchService.getOutgoingBatches(node.getNodeId());
if (batches != null && batches.size() > 0) {

// reserve here....

//

// based on results, filter all AND my local getNodeChannel()!
// if locals aren't ready to send, filter 'em out

// batches.get(0).setStatus(status)
FileOutgoingTransport fileTransport = null;
Expand All @@ -316,6 +321,8 @@ public boolean extract(Node node, IOutgoingTransport targetTransport) throws IOE

networkTransfer(fileTransport, targetTransport);

// sent channels need timestamps updated...

// batch.setStatus(OutgoingBatch.Status.SE); for IGNORED
// outgoingBatchService.updateOutgoingBatch(batch);

Expand Down

0 comments on commit 31a2b4d

Please sign in to comment.