wrench::XRootD::ContinueSearchMessage

class ContinueSearchMessage : public wrench::XRootD::Message

A message sent to a XRootD Node to continue an ongoing search for a file.

Subclassed by wrench::XRootD::AdvancedContinueSearchMessage

Public Functions

ContinueSearchMessage(ContinueSearchMessage *toCopy)

Copy Constructor.

Parameters

other – The message to copy. timeToLive is decremented

ContinueSearchMessage(simgrid::s4u::Mailbox *answer_mailbox, std::shared_ptr<StorageServiceFileReadRequestMessage> original, std::shared_ptr<DataFile> file, Node *node, double payload, std::shared_ptr<bool> answered, int timeToLive)

Constructor.

Parameters

  • answer_mailbox – The mailbox the final answer should be sent to

  • original – The original file read request being responded too. If this is a file locate search, this should be null

  • file – The file to search for

  • node – The node where the search was initiated

  • payload – The message size in bytes

  • answered – A shared boolean for if the answer has been sent to the client. This should be the same for all messages searching for this request. Used to prevent the multiple response problem

  • timeToLive – The max number of hops this message can take

Public Members

simgrid::s4u::Mailbox *answer_mailbox

Mailbox to which the FINAL answer message should be sent.

std::shared_ptr<bool> answered

Whether or not the calling client has been answered yet. Used to prevent answer_mailbox spamming for multiple file hits.

std::shared_ptr<DataFile> file

The file being searched for.

Node *node

The node that originally received the FileLookupRequest or FileReadRequest

std::shared_ptr<StorageServiceFileReadRequestMessage> original

The original file read request that kicked off the search (if null this was a lookup request)

int timeToLive

How many more hops this message can live for, to prevent messages living forever in improper configurations with loops.