Functions — github.com/PlatformLab/Homa

CodeHub MCPcopy Create free account

hub / github.com/PlatformLab/Homa / functions

Functions400 in github.com/PlatformLab/Homa

⨍ Functions 400◇ Types & classes 130

↓ 125 callersMethodsize

* Return the number of elements in the List. */

src/Intrusive.h:316

↓ 68 callersMethodpush_back

* Append an element to the end of the List. * * No Iterators are invalidated. * * @node * Node element to be appended.

src/Intrusive.h:396

↓ 53 callersMethodconstruct

↓ 46 callersMethodempty

* Check if the List contains no elements. * * @return * True, if there are no elements in this List; false, otherwise. */

src/Intrusive.h:308

↓ 43 callersMethodadd

* Add the values in other to the corresponding counters in this object. */

↓ 42 callersMethodbegin

* Return an Iterator to the first element in the List. */

src/Intrusive.h:270

↓ 41 callersMethodallocMessage

* Allocate an OutMessage that can be sent with this Sender. */

src/Sender.cc:70

↓ 39 callersMethodcontains

* Check if the given element is in the List. * * @param node * Node element being checked. * @return * True, if the

src/Intrusive.h:450

↓ 37 callersMethodgetBucket

* Return the MessageBucket that should hold a Message with the given * MessageId. */

src/Sender.h:388

↓ 34 callersMethodend

* Return an Iterator following the last element in the List. */

src/Intrusive.h:278

↓ 33 callersMethodsetTimeout

* Schedule the Timeout to elapse one timeout interval from this point. If * the Timeout was previously scheduled, this call will reschedule it.

src/Timeout.h:104

↓ 32 callersMethodcancelTimeout

* Cancel the Timeout if it was previously scheduled. * * @param timeout * The Timeout that should be canceled. */

src/Timeout.h:120

↓ 30 callersFunctionsetLogHandler

See <Homa/Debug.h>

src/Debug.cc:273

↓ 29 callersFunctionformat

* A safe version of sprintf. */ This comes from the RAMCloud project.

src/StringUtil.cc:80

↓ 28 callersMethodget

* Return the stat value. * * This method is thread-safe. */

↓ 27 callersMethodreleasePackets

* See Driver::releasePackets() */

src/Drivers/Fake/FakeDriver.cc:228

↓ 20 callersMethoddestroy

* Destroy the object, leaving the Tub in the same state * as after the no-argument constructor. * If the object was not initialized, this wi

↓ 20 callersMethodfindMessage

* Return the Message with the given MessageId. * * @param msgId * MessageId of the Message to be found. * @pa

src/Sender.h:288

↓ 18 callersMethodremove

* Removes the node element at pos. * * Iterators referring to the removed element are invalidated. * * @param pos * Iter

src/Intrusive.h:364

↓ 16 callersMethodget

* Return a pointer to the object. * @pre * The object is initialized. */

↓ 16 callersFunctionsetLogPolicy

See <Homa/Debug.h>

src/Debug.cc:291

↓ 15 callersMethodclear

* Remove all linked Node from the List. * * Invalidates any Iterators referring to elements in this List. */

src/Intrusive.h:326

↓ 15 callersMethodlength

* @copydoc Homa::OutMessage::length() */

src/Sender.cc:604

↓ 13 callersMethodinsert

* Insert an element before pos. * * No Iterators are invalidated. * * @param pos * Iterator before which the node will b

src/Intrusive.h:346

↓ 12 callersMethodgetPacket

* Return the Packet with the given index. * * @param index * A Packet's index in the array of packets that form the message. * "packet i

src/Sender.cc:707

↓ 12 callersMethodpop_front

* Remove the first element of the List; * * Iterators referring to the first element in the List are invalidated. * * Calling pop_

src/Intrusive.h:436

↓ 10 callersMethodpush_front

* Prepend an element to the beginning of the List. * * No Iterators are invalidated. * * @node * Node element to be prep

src/Intrusive.h:423

↓ 10 callersMethodschedule

* Add a Message to the schedule. * * Helper function separated mostly for ease of testing. * * @param message * Message to be added. * @par

src/Receiver.cc:787

↓ 10 callersMethodsetPacket

* Store the given packet as the Packet of the given index if one does not * already exist. * * Responsibly for releasing the given Packet is passed

src/Receiver.cc:476

↓ 9 callersFunctionformat

test/Output.h:35

↓ 9 callersMethodhasElapsed

* Return true if this Timeout has elapsed; false otherwise. * * @param now * Optionally provided "current" timestamp cycle time. U

src/Timeout.h:60

↓ 9 callersMethodsendPacket

* See Driver::sendPacket() */

src/Drivers/Fake/FakeDriver.cc:194

↓ 8 callersFunctiongetLogLevel

* From the policy, calculate the most verbose log level that should be * displayed for this file. * This is slow, so isLogging() caches the results

src/Debug.cc:208

↓ 8 callersMethodgetStatus

* @copydoc Homa::OutMessage::getStatus() */

src/Sender.cc:595

↓ 8 callersMethodhandleDonePacket

* Process an incoming DONE packet. * * @param packet * Incoming DONE packet to be processed. */

src/Sender.cc:84

↓ 8 callersMethodhandleErrorPacket

* Process an incoming ERROR packet. * * @param packet * Incoming ERROR packet to be processed. */

src/Sender.cc:445

↓ 8 callersFunctionisPrintable

* Determine whether a null-terminated string is printable. * @param str * A null-terminated string. * @return * True if all the bytes of

src/StringUtil.cc:118

↓ 8 callersFunctionlogLevelToString

* Convert a log level to a (static) string. * PANICs if the string is not a valid log level (case insensitive). */

src/Debug.cc:153

↓ 8 callersFunctionlogPolicyFromString

See <Homa/Debug.h>

src/Debug.cc:308

↓ 8 callersMethodqualifiedFunction

* Return the name of the function, qualified by its surrounding classes and * namespaces. * * Beware: the original version of this method imported

src/CodeLocation.cc:89

↓ 7 callersFunctiongetLogPolicy

See <Homa/Debug.h>

src/Debug.cc:283

↓ 7 callersMethodhandleDataPacket

* Process an incoming DATA packet. * * @param packet * The incoming packet to be processed. * @param sourceIp * Source IP address of th

src/Receiver.cc:88

↓ 7 callersMethodhandleUnknownPacket

* Process an incoming UNKNOWN packet. * * @param packet * Incoming UNKNOWN packet to be processed. */

src/Sender.cc:306

↓ 7 callersFunctionlogLevelFromString

* Convert a string to a log level. * PANICs if the string is not a valid log level (case insensitive). */

src/Debug.cc:179

↓ 7 callersMethodpoll

* Allow the Sender to make progress toward sending outgoing messages. * * This method must be called eagerly to ensure messages are sent. */

src/Sender.cc:513

↓ 7 callersMethodreceivePackets

* See Driver::receivePackets() */

src/Drivers/Fake/FakeDriver.cc:207

↓ 7 callersMethodtrySend

* Send out packets for any messages with unscheduled/granted bytes. * * Pulled out of poll() for ease of testing. */

src/Sender.cc:1017

↓ 7 callersMethodunlink

* Remove this Node from the List to which it is linked (if any). */

src/Intrusive.h:73

↓ 6 callersMethodallocPacket

* See Driver::allocPacket() */

src/Drivers/Fake/FakeDriver.cc:184

↓ 6 callersFunctioncontainer_of

include/Homa/Util.h:26

↓ 6 callersFunctionendsWith

Return true if haystack ends with needle.

src/StringUtil.cc:208

↓ 6 callersMethodgetLocalAddress

* See Driver::getLocalAddress() */

src/Drivers/Fake/FakeDriver.cc:267

↓ 6 callersMethodgetMaxPayloadSize

* See Driver::getMaxPayloadSize() */

src/Drivers/Fake/FakeDriver.cc:248

↓ 6 callersFunctiongetName

* Get the friendly name for the current thread. * This is useful in messages to users. * * You should arrange for setName() to be called when the t

src/ThreadId.cc:104

↓ 6 callersMethodhandleResendPacket

* Process an incoming RESEND packet. * * @param packet * Incoming RESEND packet to be processed. */

src/Sender.cc:155

↓ 6 callersFunctionjoin

src/StringUtil.cc:141

↓ 6 callersMethodlock

* Acquire the SpinLock; blocks the thread (by continuously polling the * lock) until the lock has been acquired. */

src/SpinLock.h:62

↓ 6 callersFunctionnormalize

src/DebugTest.cc:143

↓ 6 callersMethodsendMessage

* Queue a message to be sent. * * @param message * Sender::Message to be sent. * @param destination * Destination address for this mess

src/Sender.cc:752

↓ 6 callersFunctionstartsWith

Return true if haystack begins with needle.

src/StringUtil.cc:201

↓ 5 callersFunctionformatTime

test/Output.h:49

↓ 5 callersFunctiongetId

* Return a unique identifier associated with this thread. The * return value has two properties: * - It will never be zero. * - It will be unique

src/ThreadId.cc:71

↓ 5 callersMethodgetUnscheduledPolicy

* Get the unscheduled byte limit and network priority for a message of a * particular size bound for a particular peer. * * Used by the Sender to d

src/Policy.cc:106

↓ 5 callersMethodhandleGrantPacket

* Process an incoming GRANT packet. * * @param packet * Incoming GRANT packet to be processed. */

src/Sender.cc:245

↓ 5 callersFunctionlogPolicyToString

See <Homa/Debug.h>

src/Debug.cc:331

↓ 5 callersMethodpop_back

* Remove the last element in the List. * * Iterators referring to the last element in the List are invalidated. * * Calling pop_ba

src/Intrusive.h:409

↓ 5 callersFunctionrelativeFileName

* Strip out the common prefix of a filename to get a path from the project's * root directory. * @param fileName * An absolute or relative fil

src/Debug.cc:248

↓ 5 callersMethodreserve

* @copydoc Homa::OutMessage::reserve() */

src/Sender.cc:652

↓ 5 callersMethodsignalBytesSent

* Called when more bytes have been added to the NIC queue so that this * QueueEstimator can update it's estimate. * * @param sentBytes

include/Homa/Drivers/Util/QueueEstimator.h:73

↓ 5 callersMethodsplit

* Return the number of cycles since the last time split was called. */

↓ 5 callersMethodtoString

* Return the string representation of this address. */

src/Drivers/DPDK/MacAddress.cc:60

↓ 4 callersMethodanyElapsed

* Check if any managed Timeouts have elapsed. * * This method is thread-safe but may race with the other * non-thread-safe methods of t

src/Timeout.h:144

↓ 4 callersMethodappend

* @copydoc Homa::OutMessage::append() */

src/Sender.cc:548

↓ 4 callersMethoddropMessage

* Inform the Sender that a Message is no longer needed. * * @param message * The Sender::Message that is no longer needed. */

src/Sender.cc:881

↓ 4 callersFunctionflags

* Format an ORed group of flags as a string. * @param value * The ORed options. * @param flags * Maps option identifiers to their string

src/StringUtil.cc:59

↓ 4 callersMethodgetQueuedBytes

* See Driver::getQueuedBytes() */

src/Drivers/Fake/FakeDriver.cc:276

↓ 4 callersFunctionisPowerOfTwo

include/Homa/Util.h:67

↓ 4 callersMethodreceiveMessage

* Return a handle to a new received Message. * * The Transport should regularly call this method to insure incoming messages * are processed. * *

src/Receiver.cc:264

↓ 4 callersFunctionsetLogFile

See <Homa/Debug.h>

src/Debug.cc:263

↓ 4 callersFunctionsplit

* Split a string into multiple components by a character. * @param subject * The string to split. * @param delimiter * The character to

src/StringUtil.cc:189

↓ 4 callersMethodstr

* Return a string representation of the current location in the code. */

src/CodeLocation.cc:47

↓ 4 callersFunctiontrim

* Return a copy of the given string except with no leading or trailing * whitespace. */

src/StringUtil.cc:221

↓ 4 callersMethodtrySendGrants

* Send GRANTs to incoming Message according to the Receiver's policy. */

src/Receiver.cc:698

↓ 4 callersMethodunschedule

* Remove a Message from the schedule. * * Helper function separated mostly for ease of testing. * * @param message * Message to be removed.

src/Receiver.cc:827

↓ 3 callersFunctionarrayLength

include/Homa/Util.h:38

↓ 3 callersMethodgetHighestPacketPriority

* See Driver::getHighestPacketPriority() */

src/Drivers/Fake/FakeDriver.cc:239

↓ 3 callersFunctiongetItems

src/STLUtil.h:70

↓ 3 callersMethodhandleBusyPacket

* Process an incoming BUSY packet. * * @param packet * The incoming BUSY packet to be processed. */

src/Receiver.cc:178

↓ 3 callersMethodhandlePingPacket

* Process an incoming PING packet. * * @param packet * The incoming PING packet to be processed. * @param sourceIp * Source IP address

src/Receiver.cc:207

↓ 3 callersFunctionisLogging

* Return whether the current logging configuration includes messages of * the given level for the given filename. * This is normally called by LOG()

src/Debug.cc:383

↓ 3 callersMethodrelativeFile

src/CodeLocation.cc:68

↓ 3 callersFunctionsetName

* Set the friendly name for the current thread. * This can be later retrieved with getName(). * Calling setName with an empty string will reset the

src/ThreadId.cc:85

↓ 3 callersFunctiontoString

src/StringUtil.h:46

↓ 3 callersMethodunlock

* Release the SpinLock. The caller must previously have acquired the * SpinLock with a call to lock() or try_lock(). */

src/SpinLock.h:89

↓ 3 callersMethodupdateSchedule

* Update Message's position in the schedule. * * Called when new data has arrived for the Message. * * Helper function separated mostly for ease o

src/Receiver.cc:871

↓ 2 callersMethodacknowledge

* @copydoc Homa::InMessage::acknowledge() */

src/Receiver.cc:340

↓ 2 callersMethodcancelMessage

* Inform the Sender that a Message no longer needs to be sent. * * @param message * The Sender::Message that is no longer needs to be sent. *

src/Sender.cc:851

↓ 2 callersMethodcheckMessageTimeouts

* Process any outbound messages in a given bucket that have timed out due to * lack of activity from the Receiver. * * Pulled out of checkTimeouts(

src/Sender.cc:914

↓ 2 callersMethodcheckTimeouts

* Make incremental progress processing expired Sender timeouts. * * Pulled out of poll() for ease of testing. */

src/Sender.cc:525

↓ 2 callersMethoddropped

* @copydoc Homa::InMessage::dropped() */

src/Receiver.cc:352

next →1–100 of 400, ranked by callers