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

Method reregistered

src/python/executor/src/mesos/executor/proxy_executor.cpp:84–115  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

82
83
84void ProxyExecutor::reregistered(ExecutorDriver* driver,
85 const SlaveInfo& slaveInfo)
86{
87 InterpreterLock lock;
88
89 PyObject* slaveInfoObj = nullptr;
90 PyObject* res = nullptr;
91
92 slaveInfoObj = createPythonProtobuf(slaveInfo, "SlaveInfo");
93
94 if (slaveInfoObj == nullptr) {
95 goto cleanup; // createPythonProtobuf will have set an exception.
96 }
97
98 res = PyObject_CallMethod(impl->pythonExecutor,
99 (char*) "reregistered",
100 (char*) "OO",
101 impl,
102 slaveInfoObj);
103 if (res == nullptr) {
104 cerr << "Failed to call executor reregistered" << endl;
105 goto cleanup;
106 }
107
108cleanup:
109 if (PyErr_Occurred()) {
110 PyErr_Print();
111 driver->abort();
112 }
113 Py_XDECREF(slaveInfoObj);
114 Py_XDECREF(res);
115}
116
117
118void ProxyExecutor::disconnected(ExecutorDriver* driver)

Callers

nothing calls this directly

Calls 2

createPythonProtobufFunction · 0.85
abortMethod · 0.65

Tested by

no test coverage detected