TransporterCallbackKernel Class Reference

Inheritance diagram for TransporterCallbackKernel:

Collaboration diagram for TransporterCallbackKernel:

Public Member Functions
void	deliver_signal (SignalHeader *const header, Uint8 prio, Uint32 *const signalData, LinearSectionPtr ptr[3])
void	reportReceiveLen (NodeId nodeId, Uint32 count, Uint64 bytes)
void	reportConnect (NodeId nodeId)
void	reportDisconnect (NodeId nodeId, Uint32 errNo)
void	reportError (NodeId nodeId, TransporterError errorCode, const char *info=0)
void	transporter_recv_from (NodeId node)
Public Member Functions inherited from TransporterCallback
virtual int	checkJobBuffer ()=0
virtual void	reportSendLen (NodeId nodeId, Uint32 count, Uint64 bytes)=0
virtual void	lock_transporter (NodeId node)
virtual void	unlock_transporter (NodeId node)
virtual Uint32	get_bytes_to_send_iovec (NodeId, struct iovec *dst, Uint32)=0
virtual Uint32	bytes_sent (NodeId node, Uint32 bytes)=0
virtual bool	has_data_to_send (NodeId node)=0
virtual void	reset_send_buffer (NodeId node, bool should_be_empty=false)=0

Detailed Description

Definition at line 16 of file TransporterCallbackKernel.hpp.

Member Function Documentation

void TransporterCallbackKernel::deliver_signal ( SignalHeader *const  header, Uint8  prio, Uint32 *const  signalData, LinearSectionPtr  ptr[3]  )

virtual

This method is called to deliver a signal to the upper layer.

The method may either execute the signal immediately (NDB API), or queue it for later execution (kernel).

Check that we haven't received a too long signal

Normal path

Out of memory

Implements TransporterCallback.

Definition at line 126 of file TransporterCallback.cpp.

Here is the call graph for this function:

void TransporterCallbackKernel::reportConnect ( NodeId  nodeId )

virtual

Report connection established

Implements TransporterCallback.

Definition at line 368 of file TransporterCallback.cpp.

void TransporterCallbackKernel::reportDisconnect ( NodeId  nodeId, Uint32  errNo  )

virtual

Report connection broken

Implements TransporterCallback.

Definition at line 395 of file TransporterCallback.cpp.

Here is the caller graph for this function:

void TransporterCallbackKernel::reportError ( NodeId  nodeId, TransporterError  errorCode, const char *  info = 0  )

virtual

Called by transporter code to report error

This is called from TransporterRegistry::update_connections(), which only runs from the receive thread.

Implements TransporterCallback.

Definition at line 232 of file TransporterCallback.cpp.

Here is the call graph for this function:

void TransporterCallbackKernel::reportReceiveLen ( NodeId  nodeId, Uint32  count, Uint64  bytes  )

virtual

Report average receive length in bytes (4096 last receives)

Implements TransporterCallback.

Definition at line 338 of file TransporterCallback.cpp.

void TransporterCallbackKernel::transporter_recv_from ( NodeId  node )

virtual

Called from transporter code after a successful receive from a node.

Used for heartbeat detection by upper layer.

Implements TransporterCallback.

Definition at line 451 of file TransporterCallback.cpp.

---

The documentation for this class was generated from the following files:

• storage/ndb/src/kernel/vm/TransporterCallbackKernel.hpp
• storage/ndb/src/kernel/vm/TransporterCallback.cpp