pyRT.apps.feeds.MemoirDump Namespace Reference

Functions
def	DateTimeMs
	Return string-ified time as YYYY-MM-DD HH:MM:SS.mmm. More...
def	MapFile
	Open / Map in file. More...
def	TimeMs
	Return string-ified time as HH:MM:SS.mmm. More...

Variables
tuple	argc = len( sys.argv )
	# main() # # More...
tuple	bDmp = ( argc > 3 )
list	DDB = []
	Message Count by Message Type. More...
list	dmp = [ '%-20s : %8d' % ( pm, MDB[pm] ) for pm in MDB ]
tuple	dst = ph.Dst()
	eid = sec._SecID
int	eSeq = 1
	Number of Packets Processed. More...
tuple	fh = pcap.FileHdr( map[:32] )
string	fmt = '\n[%s] SEQ=%d; nPkt=%d; nPktDrop=%d; nMsgDrop=%d; PctDrop=%.3f%%'
list	fp = kv[0]
tuple	iMB = sz/( 1024 * 1024 )
	iSeq = udp._SeqNum
tuple	kv = MapFile( pf )
list	map = kv[1]
dictionary	MDB = {}
	Expected SeqNum. More...
tuple	mdb = seq.Messages()
tuple	mLen = rh._oLen-ph.Size()
	mt = sbe._MsgType
int	nc = 0
tuple	nd = len( DDB )
int	nDrp = 0
	Drop Message List. More...
tuple	nm = seq.MsgCount()
int	nPkt = 0
tuple	off = fh.Size()
tuple	oMB = sz/( 1024 * 1024 )
float	pct = 100.0
list	pf = sys.argv[1]
tuple	ph = pcap.PktHdr( map[off:off+42] )
tuple	pm = DataDict.GetMsgName( sbe )
list	raw = map[off:off+mLen]
tuple	rh = pcap.RecHdr( map[off:off+20] )
	rOff = off
string	s = '%dMb mapped in; '
tuple	sbe = SBE.Header( raw )
tuple	sec = SBE.Security( raw )
	for-raw More...
tuple	seq = UDP.SeqPkt( raw, False )
	print( '[%04d.H] %-14s->%-18s : seq=d' % ( nPkt, src, dst, iSeq ) ) More...
tuple	src = ph.Src()
tuple	sSz = seq.Size()
tuple	sz = len( map )
tuple	udp = UDP.Header( raw )
tuple	zap = gzip.decompress( map )

Function Documentation

def pyRT.apps.feeds.MemoirDump.DateTimeMs

(

)

Return string-ified time as YYYY-MM-DD HH:MM:SS.mmm.

Returns

string-ified time as YYYY-MM-DD HH:MM:SS.mmm

def pyRT.apps.feeds.MemoirDump.MapFile

(

filename

)

Open / Map in file.

Parameters

filename

- File to mmap()

Returns

[ fp, map, fSz ] on success; None on error

def pyRT.apps.feeds.MemoirDump.TimeMs

(

)

Return string-ified time as HH:MM:SS.mmm.

Returns

string-ified time as HH:MM:SS.mmm

Variable Documentation

tuple pyRT.apps.feeds.MemoirDump.argc = len( sys.argv )

               #

main() # #

tuple pyRT.apps.feeds.MemoirDump.bDmp = ( argc > 3 )

list pyRT.apps.feeds.MemoirDump.DDB = []

Message Count by Message Type.

list pyRT.apps.feeds.MemoirDump.dmp = [ '%-20s : %8d' % ( pm, MDB[pm] ) for pm in MDB ]

tuple pyRT.apps.feeds.MemoirDump.dst = ph.Dst()

pyRT.apps.feeds.MemoirDump.eid = sec._SecID

pyRT.apps.feeds.MemoirDump.eSeq = 1

Number of Packets Processed.

for-raw

for-raw for-raw for-raw for-raw

Last Sale : Not supported here

tuple pyRT.apps.feeds.MemoirDump.fh = pcap.FileHdr( map[:32] )

string pyRT.apps.feeds.MemoirDump.fmt = '\n[%s] SEQ=%d; nPkt=%d; nPktDrop=%d; nMsgDrop=%d; PctDrop=%.3f%%'

list pyRT.apps.feeds.MemoirDump.fp = kv[0]

pyRT.apps.feeds.MemoirDump.iMB = sz/( 1024 * 1024 )

pyRT.apps.feeds.MemoirDump.iSeq = udp._SeqNum

tuple pyRT.apps.feeds.MemoirDump.kv = MapFile( pf )

pyRT.apps.feeds.MemoirDump.map = kv[1]

dictionary pyRT.apps.feeds.MemoirDump.MDB = {}

Expected SeqNum.

tuple pyRT.apps.feeds.MemoirDump.mdb = seq.Messages()

tuple pyRT.apps.feeds.MemoirDump.mLen = rh._oLen-ph.Size()

pyRT.apps.feeds.MemoirDump.mt = sbe._MsgType

int pyRT.apps.feeds.MemoirDump.nc = 0

tuple pyRT.apps.feeds.MemoirDump.nd = len( DDB )

int pyRT.apps.feeds.MemoirDump.nDrp = 0

Drop Message List.

tuple pyRT.apps.feeds.MemoirDump.nm = seq.MsgCount()

int pyRT.apps.feeds.MemoirDump.nPkt = 0

pyRT.apps.feeds.MemoirDump.off = fh.Size()

tuple pyRT.apps.feeds.MemoirDump.oMB = sz/( 1024 * 1024 )

float pyRT.apps.feeds.MemoirDump.pct = 100.0

list pyRT.apps.feeds.MemoirDump.pf = sys.argv[1]

tuple pyRT.apps.feeds.MemoirDump.ph = pcap.PktHdr( map[off:off+42] )

tuple pyRT.apps.feeds.MemoirDump.pm = DataDict.GetMsgName( sbe )

list pyRT.apps.feeds.MemoirDump.raw = map[off:off+mLen]

tuple pyRT.apps.feeds.MemoirDump.rh = pcap.RecHdr( map[off:off+20] )

pyRT.apps.feeds.MemoirDump.rOff = off

string pyRT.apps.feeds.MemoirDump.s = '%dMb mapped in; '

tuple pyRT.apps.feeds.MemoirDump.sbe = SBE.Header( raw )

tuple pyRT.apps.feeds.MemoirDump.sec = SBE.Security( raw )

for-raw

Different between Depth and Top for-raw for-raw for-raw for-raw

Depth Messages : SBE.Security

Different between Depth and Top for-raw for-raw for-raw for-raw

Top of Book Messages : SBE.Security

tuple pyRT.apps.feeds.MemoirDump.seq = UDP.SeqPkt( raw, False )

print( '[%04d.H] %-14s->%-18s : seq=d' % ( nPkt, src, dst, iSeq ) )

print( '[%04d.X] %-14s->%-18s : seq=d' % ( nPkt, src, dst, iSeq ) )

tuple pyRT.apps.feeds.MemoirDump.src = ph.Src()

tuple pyRT.apps.feeds.MemoirDump.sSz = seq.Size()

tuple pyRT.apps.feeds.MemoirDump.sz = len( map )

tuple pyRT.apps.feeds.MemoirDump.udp = UDP.Header( raw )

tuple pyRT.apps.feeds.MemoirDump.zap = gzip.decompress( map )