MCPcopy Create free account
hub / github.com/apache/mesos / received

Method received

src/examples/java/V1TestFramework.java:88–147  ·  view source on GitHub ↗
(Mesos mesos, Event event)

Source from the content-addressed store, hash-verified

86 }
87
88 @Override
89 public synchronized void received(Mesos mesos, Event event) {
90 switch (event.getType()) {
91 case SUBSCRIBED: {
92 frameworkId = event.getSubscribed().getFrameworkId();
93 state = State.SUBSCRIBED;
94
95 System.out.println(
96 "Subscribed with ID " + frameworkId + " to master " +
97 event.getSubscribed().getMasterInfo().getId());
98 break;
99 }
100
101 case OFFERS: {
102 System.out.println("Received an OFFERS event");
103
104 offers(mesos, event.getOffers().getOffersList());
105 break;
106 }
107
108 case RESCIND: {
109 System.out.println("Received an RESCIND event");
110 break;
111 }
112
113 case UPDATE: {
114 System.out.println("Received an UPDATE event");
115
116 update(mesos, event.getUpdate().getStatus());
117 break;
118 }
119
120 case MESSAGE: {
121 System.out.println("Received a MESSAGE event");
122 break;
123 }
124
125 case FAILURE: {
126 System.out.println("Received a FAILURE event");
127 break;
128 }
129
130 case ERROR: {
131 System.out.println("Received an ERROR event");
132 System.exit(1);
133 }
134
135 case HEARTBEAT: {
136 // TODO(anand): Force reconnection with the master upon lack
137 // of heartbeats.
138 System.out.println("Received a HEARTBEAT event");
139 break;
140 }
141
142 case UNKNOWN: {
143 System.out.println("Received an UNKNOWN event");
144 break;
145 }

Callers

nothing calls this directly

Calls 5

offersMethod · 0.95
updateMethod · 0.95
getIdMethod · 0.80
getMasterInfoMethod · 0.80
exitMethod · 0.80

Tested by

no test coverage detected