HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.  2.0.0-chaika
Hierarchical Cluster Engine Python language binding
ftests.ftest_DCC.ConnectionStub Class Reference
Inheritance diagram for ftests.ftest_DCC.ConnectionStub:
Collaboration diagram for ftests.ftest_DCC.ConnectionStub:

Public Member Functions

def __init__ (self)
 
def send (self, event)
 
def poll (self, timeout)
 
def recv (self)
 

Public Attributes

 eventType
 
 id
 
 event
 

Detailed Description

Definition at line 28 of file ftest_DCC.py.

Constructor & Destructor Documentation

◆ __init__()

def ftests.ftest_DCC.ConnectionStub.__init__ (   self)

Definition at line 31 of file ftest_DCC.py.

31  def __init__(self):
32  self.eventType = None
33  self.id = 0
34  self.event = None
35 
36 
def __init__(self)
constructor
Definition: UIDGenerator.py:19

Member Function Documentation

◆ poll()

def ftests.ftest_DCC.ConnectionStub.poll (   self,
  timeout 
)

Definition at line 55 of file ftest_DCC.py.

55  def poll(self, timeout):
56  return 1
57 
58 

◆ recv()

def ftests.ftest_DCC.ConnectionStub.recv (   self)

Definition at line 59 of file ftest_DCC.py.

59  def recv(self):
60  eventObj = None
61  retEventType = None
62  eventBulder = transport.Event.EventBuilder()
63  if self.eventType >= EVENT_TYPES.SITE_NEW and self.eventType <= EVENT_TYPES.URL_PURGE:
64  retEventType = self.eventType + (EVENT_TYPES.SITE_NEW_RESPONSE - EVENT_TYPES.SITE_NEW)
65  eventObj = dc.EventObjects.ClientResponse([])
66  eventObj.itemsList.append(dc.EventObjects.ClientResponseItem(None))
67  eventObj.itemsList.append(dc.EventObjects.ClientResponseItem(None))
68  eventObj.itemsList[0].host = "host1"
69  eventObj.itemsList[1].host = "host2"
70  return eventBulder.build(retEventType, eventObj)
71 
72 

◆ send()

def ftests.ftest_DCC.ConnectionStub.send (   self,
  event 
)

Definition at line 37 of file ftest_DCC.py.

37  def send(self, event):
38  global fName
39  self.eventType = event.eventType
40  self.event = event
41  if hasattr(event.eventObj, "id"):
42  self.id = event.eventObj.id
43  else:
44  self.id = None
45  if fName != None:
46  drceSave = dc.Constants.DRCESyncTasksCover(self.eventType, event.eventObj)
47  pickleStr = pickle.dumps(drceSave)
48  f = open(fName, "w")
49  f.write(pickleStr)
50  f.close()
51  if event.cookie != None:
52  print(">>> Event.cookie = %s" % event.cookie)
53 
54 

Member Data Documentation

◆ event

ftests.ftest_DCC.ConnectionStub.event

Definition at line 34 of file ftest_DCC.py.

◆ eventType

ftests.ftest_DCC.ConnectionStub.eventType

Definition at line 32 of file ftest_DCC.py.

◆ id

ftests.ftest_DCC.ConnectionStub.id

Definition at line 33 of file ftest_DCC.py.


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