(Mesos mesos, Event event)
| 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 | } |
nothing calls this directly
no test coverage detected