Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/PlatformLab/Homa
/ functions
Functions
400 in github.com/PlatformLab/Homa
⨍
Functions
400
◇
Types & classes
130
↓ 2 callers
Method
get
* Return an Iterator to the specified element if the element is in the * list. Otherwise return List::end. * * @param node *
src/Intrusive.h:293
↓ 2 callers
Method
getBandwidth
* See Driver::getBandwidth() */
src/Drivers/Fake/FakeDriver.cc:257
↓ 2 callers
Function
getKeys
src/STLUtil.h:44
↓ 2 callers
Method
getOrAllocPacket
* Return the Packet with the given index. If the Packet does yet exist, * allocate a new Packet. * * @param index * A Packet's index in the
src/Sender.cc:726
↓ 2 callers
Function
getValues
src/STLUtil.h:57
↓ 2 callers
Method
isNull
* @return * True if the MacAddress consists of all zero bytes, false if not. */
src/Drivers/DPDK/MacAddress.cc:73
↓ 2 callers
Function
log
* Unconditionally log the given message to stderr. * This is normally called by LOG(). * @param level * The level of importance of the message
src/Debug.cc:413
↓ 2 callers
Method
release
* @copydoc Homa::OutMessage::release() */
src/Sender.cc:643
↓ 2 callers
Function
runTest
* Runs a particular test and prints a one-line result message. * * @param test * Describes the test to run. */
test/Perf.cc:768
↓ 2 callers
Function
sorted
src/STLUtil.h:33
↓ 2 callers
Method
strip
* @copydoc Homa::InMessage::strip() */
src/Receiver.cc:427
↓ 2 callers
Method
try_lock
* Try to acquire the SpinLock; does not block the thread and returns * immediately. * * @return * True if the lock was succes
src/SpinLock.h:78
↓ 1 callers
Method
alloc
See Homa::Transport::alloc()
src/TransportImpl.h:50
↓ 1 callers
Function
assign
* Pick a unique value to use as the thread identifier for the current * thread. This value is saved in the thread-specific variable #id. */
src/ThreadId.cc:54
↓ 1 callers
Method
baseFileName
* Return the base name of the file (i.e., only the last component of the * file name, omitting any preceding directories). */
src/CodeLocation.cc:58
↓ 1 callers
Function
basic
test/Output.h:75
↓ 1 callers
Function
basicHeader
test/Output.h:69
↓ 1 callers
Function
calculateLengthFilePrefix
* Return the number of characters of __FILE__ that make up the path prefix. * That is, __FILE__ plus this value will be the relative path from the to
src/Debug.cc:227
↓ 1 callers
Method
checkPingTimeouts
* Process any outbound messages in a given bucket that need to be pinged to * ensure the message is kept alive by the receiver. * * Pulled out of c
src/Sender.cc:962
↓ 1 callers
Method
checkResendTimeouts
* Process any inbound messages that may need to issue resends. * * Pulled out of checkTimeouts() for ease of testing. * * @param now * The r
src/Receiver.cc:602
↓ 1 callers
Function
clientMain
* @return * Number of Op that failed. */
test/system_test.cc:103
↓ 1 callers
Function
demangle
* Helper function to call __cxa_demangle. Has internal linkage. * Handles the C-style memory management required. * Returns a std::string with the l
src/Util.cc:40
↓ 1 callers
Method
deregisterNIC
Remove the FakeNIC from the network.
src/Drivers/Fake/FakeDriver.cc:69
↓ 1 callers
Method
dropMessage
* Inform the Receiver that an Message returned by receiveMessage() is not * needed and can be dropped. * * @param message * Message which wil
src/Receiver.cc:495
↓ 1 callers
Method
dumpStats
* Export this object's counter values to a Stats structure. */
src/Perf.h:152
↓ 1 callers
Method
empty
* Check if the TimeoutManager manages no Timeouts. * * @return * True, if there are no Timeouts being managed; false, otherwise.
src/Timeout.h:155
↓ 1 callers
Method
fail
* @copydoc See Homa::InMessage::fail() */
src/Receiver.cc:361
↓ 1 callers
Method
get
* @copydoc Homa::InMessage::get() */
src/Receiver.cc:373
↓ 1 callers
Method
getPacket
* 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/Receiver.cc:451
↓ 1 callers
Method
getResendPriority
* Return the network priority that should be used for resent packets * (i.e. packets that were lost and need to be resent). */
src/Policy.cc:71
↓ 1 callers
Method
getScheduledPolicy
* Returns the highest priority that should be used for scheduled (granted) * messages and the number of messages that should be concurrently granted.
src/Policy.cc:85
↓ 1 callers
Method
getState
* Return the current state of this message. */
src/Receiver.h:177
↓ 1 callers
Method
getX
src/TubTest.cc:40
↓ 1 callers
Function
infoTest
* Print the documentation of a particular test. * * @param test * Describes the test whose documentation should be printed. */
test/Perf.cc:808
↓ 1 callers
Function
length__FILE__Prefix
* Return the number of characters of __FILE__ that make up the path prefix. * That is, __FILE__ plus this value will be the relative path from the to
src/CodeLocation.cc:33
↓ 1 callers
Function
listTest
* Print short listing of a particular test. * * @param test * Describes the test to list. */
test/Perf.cc:795
↓ 1 callers
Method
prepend
* @copydoc Homa::OutMessage::prepend() */
src/Sender.cc:613
↓ 1 callers
Method
processPackets
* Helper method which receives a burst of incoming packets and process them * through the transport protocol. Pulled out of TransportImpl::poll() to
src/TransportImpl.cc:87
↓ 1 callers
Method
receive
See Homa::Transport::receive()
src/TransportImpl.h:57
↓ 1 callers
Method
registerNIC
Register the FakeNIC so it can receive packets. Returns the newly registered FakeNIC's addressId.
src/Drivers/Fake/FakeDriver.cc:59
↓ 1 callers
Method
send
* @copydoc Homa::OutMessage::send() */
src/Sender.cc:691
↓ 1 callers
Method
signalNewMessage
* Record statistics about a new incoming Message that are used to recalculate * this Transport's unscheduled and scheduled policies. * * Called by
src/Policy.cc:149
Method
BadAddress
include/Homa/Driver.h:266
Method
Bar
src/TubTest.cc:50
Method
BusyHeader
BusyHeader constructor.
src/Protocol.h:253
Method
CodeLocation
Called by #HERE only.
src/CodeLocation.h:31
Method
CommonHeader
CommonHeader constructor.
src/Protocol.h:143
Method
Counters
* Default constructor. */
src/Perf.h:80
Method
DataHeader
DataHeader constructor.
src/Protocol.h:170
Method
DebugMessage
See <Homa/Debug.h>
src/Debug.cc:37
Method
DebugTest
src/DebugTest.cc:41
Method
DoneHeader
DoneHeader constructor.
src/Protocol.h:215
Method
DpdkDriver
src/Drivers/DPDK/DpdkDriver.cc:24
Method
DpdkDriver
Disable copy and assign
include/Homa/Drivers/DPDK/DpdkDriver.h:166
Method
DpdkDriverImplTest
src/Drivers/DPDK/DpdkDriverTest.cc:29
Method
DriverInitFailure
include/Homa/Driver.h:248
Method
ErrorHeader
ErrorHeader constructor.
src/Protocol.h:296
Method
Exception
include/Homa/Exception.h:33
Method
FakeDriver
* FakeDriver Constructor. */
src/Drivers/Fake/FakeDriver.cc:165
Method
FakeDriver
Disable copy and assign
include/Homa/Drivers/Fake/FakeDriver.h:136
Method
FakeNIC
* FakeNIC constructor. */
src/Drivers/Fake/FakeDriver.cc:142
Method
FakeNetwork
Constructor.
src/Drivers/Fake/FakeDriver.cc:40
Method
FakePacket
* FakePacket constructor. */
include/Homa/Drivers/Fake/FakeDriver.h:67
Method
FatalError
include/Homa/Exception.h:93
Method
Foo
test/Perf.cc:223
Method
Foo
src/IntrusiveTest.cc:25
Method
Foo
src/TubTest.cc:29
Method
GrantHeader
GrantHeader constructor.
src/Protocol.h:198
Method
HeaderPrefix
HeaderPrefix constructor.
src/Protocol.h:126
Method
Impl
* See DpdkDriver::DpdkDriver() */
src/Drivers/DPDK/DpdkDriverImpl.cc:78
Method
IntrusiveListTest
src/IntrusiveTest.cc:36
Method
Iterator
* Iterator empty constructor. */
src/Intrusive.h:104
Method
List
* List constructor. */
src/Intrusive.h:212
Method
MacAddress
src/Drivers/DPDK/MacAddress.h:31
Method
MacAddress
* Create a new address from 6 bytes. * @param raw * The raw bytes. */
src/Drivers/DPDK/MacAddress.cc:31
Method
Manager
* Construct a Policy::Manager. * * @param transport * The transport that owns this Policy::Manager. */
src/Policy.cc:41
Method
Message
src/Receiver.h:135
Method
Message
* Construct an Message. */
src/Sender.h:135
Method
MessageBucket
* MessageBucket constructor. * * @param messageTimeoutCycles * Number of cycles of inactivity to wait before a Message
src/Receiver.h:282
Method
MessageBucket
* MessageBucket constructor. * * @param messageTimeoutCycles * Number of cycles of inactivity to wait before a Message
src/Sender.h:269
Method
MessageBucketMap
* MessageBucketMap constructor. * * @param messageTimeoutCycles * Number of cycles of inactivity to wait before a Mess
src/Receiver.h:383
Method
MessageBucketMap
* MessageBucketMap constructor. * * @param messageTimeoutCycles * Number of cycles of inactivity to wait before a Mess
src/Sender.h:368
Method
MessageId
MessageId default constructor.
src/Protocol.h:46
Method
MockPolicyManager
src/Mock/MockPolicy.h:32
Method
MockReceiver
src/Mock/MockReceiver.h:34
Method
MockSender
src/Mock/MockSender.h:34
Method
Node
test/system_test.cc:57
Method
Node
* List::Node constructor. * * @param owner * Pointer to the object of which this Node is a member. */
src/Intrusive.h:52
Method
ObjectPool
* Construct a new ObjectPool. The pool begins life with no allocated * memory. Objects are first allocated individually via malloc. Destroyed
src/ObjectPool.h:65
Method
Packet
* Construct a DPDK Packet backed by a DPDK mbuf. * * @param mbuf * Pointer to the DPDK mbuf that holds this packet. * @param data * Mem
src/Drivers/DPDK/DpdkDriverImpl.cc:53
Method
Peer
* Peer constructor. */
src/Receiver.h:423
Method
PingHeader
PingHeader constructor.
src/Protocol.h:267
Method
QueueEstimator
* Construct a QueueEstimator; the NIC is assumed to be idle when this * method is invoked. * * @param bandwidth * Bandwidth o
include/Homa/Drivers/Util/QueueEstimator.h:50
Method
QueueEstimatorTest
src/Drivers/Util/QueueEstimatorTest.cc:49
Method
QueuedMessageInfo
* QueuedMessageInfo constructor. * * @param message * Message to which this metadata is associated. */
src/Sender.h:85
Function
RTE_ETH_FOREACH_DEV
src/Drivers/DPDK/DpdkDriverImpl.cc:590
Method
Receiver
* Receiver constructor. * * @param driver * The driver used to send and receive packets. * @param policyManager * Provides information
src/Receiver.cc:39
Method
ReceiverTest
src/ReceiverTest.cc:49
Method
ResendHeader
DoneHeader constructor.
src/Protocol.h:235
Method
Rx
* Basic Constructor. */
src/Drivers/DPDK/DpdkDriverImpl.h:213
← previous
next →
101–200 of 400, ranked by callers