Documentation ¶
Index ¶
- Constants
- type App
- type Consumer
- func (consumer *Consumer) Close() error
- func (consumer *Consumer) Configure(settings ConsumerSettings) error
- func (consumer *Consumer) ConfigureDemux(demuxI, demuxD, demuxN *iface.InputDemux)
- func (consumer *Consumer) FileInfo(pathname string) (filesize int64, e error)
- func (consumer *Consumer) GetCounters() (cnt Counters)
- func (consumer *Consumer) Launch()
- func (consumer *Consumer) Read(pathname string, buf *C.uint8_t, count int64, offset int64) (nbytes int64, e error)
- func (consumer *Consumer) RequestData(pathname string, count int64, offset int64, pt C.PacketType) int
- func (consumer *Consumer) ResetCounters()
- func (consumer *Consumer) RxQueue() *iface.PktQueue
- func (consumer *Consumer) SetLCores(rxLCore, txLCore eal.LCore)
- func (consumer *Consumer) Stop() error
- type ConsumerSettings
- type Counters
- type InitConfigConsumer
- type Input
- type MessageRx
Constants ¶
View Source
const ( LCoreRole_Input = "RX" LCoreRole_Output = "TX" LCoreRole_ConsumerRx = "ConsumerRx" LCoreRole_ConsumerTx = "ConsumerTx" )
LCoreAlloc roles
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type App ¶
type App struct {
// contains filtered or unexported fields
}
App struct
func (*App) TransferFile ¶
TransferFile over NDN
type Consumer ¶
type Consumer struct { Rx ealthread.Thread Tx ealthread.Thread // contains filtered or unexported fields }
Consumer Instance and threads
func NewConsumer ¶
func NewConsumer(face iface.Face, settings ConsumerSettings) (*Consumer, error)
NewConsumer objet
func (*Consumer) Close ¶
Close the consumer Both RX and TX threads must be stopped before calling this.
func (*Consumer) Configure ¶
func (consumer *Consumer) Configure(settings ConsumerSettings) error
Configure consumer instance
func (*Consumer) ConfigureDemux ¶
func (consumer *Consumer) ConfigureDemux(demuxI, demuxD, demuxN *iface.InputDemux)
ConfigureDemux for Consumer instance
func (*Consumer) GetCounters ¶
GetCounters Get Rx and Tx consumer counters
func (*Consumer) Read ¶
func (consumer *Consumer) Read(pathname string, buf *C.uint8_t, count int64, offset int64) (nbytes int64, e error)
Read from file
func (*Consumer) RequestData ¶
func (consumer *Consumer) RequestData(pathname string, count int64, offset int64, pt C.PacketType) int
RequestData over NDN
func (*Consumer) ResetCounters ¶
func (consumer *Consumer) ResetCounters()
ResetCounters Reset Rx and Tx Consumer thread counters for statistics
type ConsumerSettings ¶
type ConsumerSettings struct { MustBeFresh bool // Whether to set MustBeFresh InterestLifetime time.Duration // InterestLifetime value, zero means default RxQueue iface.PktQueueConfig }
ConsumerSettings config
type Counters ¶
type Counters struct {
// contains filtered or unexported fields
}
Counters for Consumer Rx and Tx threads
type InitConfigConsumer ¶
type InitConfigConsumer struct { Face iface.LocatorWrapper // Face locator for face creation Consumer *ConsumerSettings // If not nil, create a consumer on the face Files []string // List of files to be copied over NDN by this consumer applications }
InitConfigConsumer config
Click to show internal directories.
Click to hide internal directories.