Method IOCompletion

isapi/src/PyExtensionObjects.cpp:801–828

@pymethod int|EXTENSION_CONTROL_BLOCK|IOCompletion|Set a callback that will be used for handling asynchronous I/O operations. @comm If you call this multiple times, the previous callback will be discarded. @comm A reference to the callback and args are held until is called. If the callback function fails, DoneWithSession(HSE_STATUS_ERROR) will automatic

// function fails, DoneWithSession(HSE_STATUS_ERROR) will automatically be
// called and no further callbacks for the ECB will be made.
PyObject * PyECB::IOCompletion(PyObject *self, PyObject *args)
{
	PyECB * pecb = (PyECB *) self;
	if (!pecb || !pecb->Check()) return NULL;
	EXTENSION_CONTROL_BLOCK *ecb = pecb->m_pcb->GetECB();

	PyObject *obCallback;
	PyObject *obArg = NULL;
	if (!PyArg_ParseTuple(args, "O|O:IOCompletion",
	                      &obCallback, // @pyparm callable|func||The function to call, as described by the <om EXTENSION_CONTROL_BLOCK.IOCallback> method.
	                      &obArg)) // @pyparm object|arg|None|Any object which will be supplied as an argument to the callback function.
		return NULL;

	if (!PyCallable_Check(obCallback))
		return PyErr_Format(PyExc_TypeError, "first param must be callable");
	// now we have checked the params just ignore them!  Stick args itself
	// in our map.
	if (!SetupIOCallback(ecb, args))
		return NULL;

	BOOL bRes;
	Py_BEGIN_ALLOW_THREADS
	bRes = ecb->ServerSupportFunction(ecb->ConnID, HSE_REQ_IO_COMPLETION, DoIOCallback, NULL, NULL);
	Py_END_ALLOW_THREADS
	if (!bRes)
		return SetPyECBError("ServerSupportFunction(HSE_REQ_IO_COMPLETION)");
	Py_RETURN_NONE;
}

// @pymethod int|EXTENSION_CONTROL_BLOCK|ReportUnhealthy|Calls ServerSupportFunction with HSE_REQ_REPORT_UNHEALTHY
PyObject * PyECB::ReportUnhealthy(PyObject *self, PyObject *args)