xrootdlib.streams.XrdXrootdMon.trace module¶

class Close(client: Union[xrootdlib.streams.XrdXrootdMon.map.UserInfo, xrootdlib.streams.XrdXrootdMon.map.PathAccessInfo], lfn: bytes, rtot: int, wtot: int)¶

Bases: object

A client closed a file

client¶

classmethod from_record(record_struct: xrootdlib.structs.XrdXrootdMon.trace.Close, stod: int, map_store: xrootdlib.streams.XrdXrootdMon.map.MapInfoStore)¶

lfn¶

rtot¶

wtot¶

class Disconnect(client: xrootdlib.streams.XrdXrootdMon.map.UserInfo, duration: int, forced: bool)¶

Bases: object

A client disconnected from the server

client¶

duration¶

forced¶

classmethod from_record(record_struct: xrootdlib.structs.XrdXrootdMon.trace.Disc, stod: int, map_store: xrootdlib.streams.XrdXrootdMon.map.MapInfoStore)¶

class Open(client: Union[xrootdlib.streams.XrdXrootdMon.map.UserInfo, xrootdlib.streams.XrdXrootdMon.map.PathAccessInfo], lfn: bytes, filesize: int)¶

Bases: object

A client opened a file

client¶

filesize¶

classmethod from_record(record_struct: xrootdlib.structs.XrdXrootdMon.trace.Open, stod: int, map_store: xrootdlib.streams.XrdXrootdMon.map.MapInfoStore)¶

lfn¶

class ReadVector(client: Union[xrootdlib.streams.XrdXrootdMon.map.UserInfo, xrootdlib.streams.XrdXrootdMon.map.PathAccessInfo], lfn: bytes, reads: List[int])¶

Bases: object

client¶

lfn¶

reads¶

class ReadWrite(client: Union[xrootdlib.streams.XrdXrootdMon.map.UserInfo, xrootdlib.streams.XrdXrootdMon.map.PathAccessInfo], lfn: bytes, offset: int, read: int, write: int)¶

Bases: object

A client read from or wrote to a file

client¶

classmethod from_record(record_struct: xrootdlib.structs.XrdXrootdMon.trace.ReadWrite, stod: int, map_store: xrootdlib.streams.XrdXrootdMon.map.MapInfoStore)¶

lfn¶

offset¶

read¶

write¶

class TraceWindow(server_info: xrootdlib.streams.XrdXrootdMon.map.ServerInfo, start: int, end: int, records: List[T])¶

Bases: object

Sequence of events in a time window

end¶

records¶

server_info¶

start¶

digest_packet(stod: int, buff_struct: xrootdlib.structs.XrdXrootdMon.Buff, map_store: xrootdlib.streams.XrdXrootdMon.map.MapInfoStore)¶: Digest a packet containing trace data

ignore_not_implemented(record_struct, stod, map_store)¶: Skip structs that are currently not implemented