58 lines
1.6 KiB
C++
58 lines
1.6 KiB
C++
#pragma once
|
|
|
|
#include "kj/async.h"
|
|
#include "Python.h"
|
|
#include "capabilityHelper.h"
|
|
|
|
class PyEventPort: public kj::EventPort {
|
|
public:
|
|
PyEventPort(PyObject * _py_event_port): py_event_port(_py_event_port) {
|
|
// We don't need to incref/decref, since this C++ class will be owned by the Python wrapper class, and we'll make sure the python class doesn't refcount to 0 elsewhere.
|
|
// Py_INCREF(py_event_port);
|
|
}
|
|
virtual bool wait() {
|
|
GILAcquire gil;
|
|
PyObject_CallMethod(py_event_port, const_cast<char *>("wait"), NULL);
|
|
}
|
|
|
|
virtual bool poll() {
|
|
GILAcquire gil;
|
|
PyObject_CallMethod(py_event_port, const_cast<char *>("poll"), NULL);
|
|
}
|
|
|
|
virtual void setRunnable(bool runnable) {
|
|
GILAcquire gil;
|
|
PyObject * arg = Py_False;
|
|
if (runnable)
|
|
arg = Py_True;
|
|
PyObject_CallMethod(py_event_port, const_cast<char *>("set_runnable"), const_cast<char *>("o"), arg);
|
|
}
|
|
|
|
private:
|
|
PyObject * py_event_port;
|
|
};
|
|
|
|
void waitNeverDone(kj::WaitScope & scope) {
|
|
GILRelease gil;
|
|
kj::NEVER_DONE.wait(scope);
|
|
}
|
|
|
|
kj::Timer * getTimer(kj::AsyncIoContext * context) {
|
|
return &context->lowLevelProvider->getTimer();
|
|
}
|
|
|
|
void waitVoidPromise(kj::Promise<void> * promise, kj::WaitScope & scope) {
|
|
GILRelease gil;
|
|
promise->wait(scope);
|
|
}
|
|
|
|
PyObject * waitPyPromise(kj::Promise<PyObject *> * promise, kj::WaitScope & scope) {
|
|
GILRelease gil;
|
|
return promise->wait(scope);
|
|
}
|
|
|
|
capnp::Response< ::capnp::DynamicStruct> * waitRemote(capnp::RemotePromise< ::capnp::DynamicStruct> * promise, kj::WaitScope & scope) {
|
|
GILRelease gil;
|
|
return new capnp::Response< ::capnp::DynamicStruct>(promise->wait(scope));
|
|
}
|