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_DTMC.ConnectionStub Class Reference
Inheritance diagram for ftests.ftest_DTMC.ConnectionStub:
Collaboration diagram for ftests.ftest_DTMC.ConnectionStub:

Public Member Functions

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

Public Attributes

 eventType
 
 id
 

Detailed Description

Definition at line 22 of file ftest_DTMC.py.

Constructor & Destructor Documentation

◆ __init__()

def ftests.ftest_DTMC.ConnectionStub.__init__ (   self)

Definition at line 25 of file ftest_DTMC.py.

25  def __init__(self):
26  self.eventType = None
27 
28 
def __init__(self)
constructor
Definition: UIDGenerator.py:19

Member Function Documentation

◆ poll()

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

Definition at line 37 of file ftest_DTMC.py.

37  def poll(self, timeout):
38  return 1
39 
40 

◆ recv()

def ftests.ftest_DTMC.ConnectionStub.recv (   self)

Definition at line 41 of file ftest_DTMC.py.

41  def recv(self):
42  eventObj = None
43  retEventType = None
44  retEvent = None
45  eventBulder = transport.Event.EventBuilder()
46  if self.eventType == EVENT_TYPES.NEW_TASK:
47  retEventType = EVENT_TYPES.GENERAL_RESPONSE
49  eventObj.statuses.append("was_new")
50  elif self.eventType == EVENT_TYPES.CHECK_TASK_STATE:
51  retEventType = EVENT_TYPES.FETCH_EE_DATA_RESPONSE
52  eventObj = dtm.EventObjects.EEResponseData(self.id)
53  elif self.eventType == EVENT_TYPES.DELETE_TASK:
54  retEventType = EVENT_TYPES.GENERAL_RESPONSE
56  eventObj.statuses.append("was_delete")
57  elif self.eventType == EVENT_TYPES.FETCH_TASK_RESULTS:
58  retEventType = EVENT_TYPES.FETCH_EE_DATA_RESPONSE
59  eventObj = dtm.EventObjects.EEResponseData(self.id)
60  retEvent = eventBulder.build(retEventType, eventObj)
61  return retEvent
62 
63 
GeneralResponse event object, represents general state response for multipurpose usage.
EEResponseData event object, store task results data, returned from EE.

◆ send()

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

Definition at line 29 of file ftest_DTMC.py.

29  def send(self, event):
30  self.eventType = event.eventType
31  if hasattr(event.eventObj, "id"):
32  self.id = event.eventObj.id
33  else:
34  self.id = None
35 
36 

Member Data Documentation

◆ eventType

ftests.ftest_DTMC.ConnectionStub.eventType

Definition at line 26 of file ftest_DTMC.py.

◆ id

ftests.ftest_DTMC.ConnectionStub.id

Definition at line 32 of file ftest_DTMC.py.


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