51 lines
1.1 KiB
C++
51 lines
1.1 KiB
C++
/**
|
|
* php-asio/strand.cpp
|
|
*
|
|
* @author CismonX<admin@cismon.net>
|
|
*/
|
|
|
|
#include "strand.hpp"
|
|
#include "future.hpp"
|
|
|
|
#ifdef ENABLE_STRAND
|
|
|
|
#define STRAND_DISPATCH_CALLBACK(meth) \
|
|
PHP_ASIO_DISPATCH_CALLBACK(meth) PHP_ASIO_DEC_HANDLER_COUNT(); })
|
|
|
|
namespace asio
|
|
{
|
|
P3_METHOD(strand, dispatch)
|
|
{
|
|
PHP_ASIO_INC_HANDLER_COUNT();
|
|
STRAND_DISPATCH_CALLBACK(strand_.dispatch);
|
|
}
|
|
|
|
P3_METHOD(strand, post)
|
|
{
|
|
PHP_ASIO_INC_HANDLER_COUNT();
|
|
STRAND_DISPATCH_CALLBACK(strand_.post);
|
|
}
|
|
|
|
P3_METHOD(strand, runningInThisThread) const
|
|
{
|
|
RETVAL_BOOL(strand_.running_in_this_thread());
|
|
}
|
|
|
|
P3_METHOD(strand, wrap)
|
|
{
|
|
zval* callback;
|
|
ZEND_PARSE_PARAMETERS_START(1, 1)
|
|
Z_PARAM_ZVAL(callback)
|
|
ZEND_PARSE_PARAMETERS_END();
|
|
PHP_ASIO_INC_HANDLER_COUNT();
|
|
RETVAL_OBJ(p3::alloc_object<wrapped_handler>(wrapped_handler::class_entry,
|
|
[this, callback](wrapped_handler* ptr) {
|
|
new(ptr) wrapped_handler(this, callback);
|
|
}));
|
|
}
|
|
|
|
PHP_ASIO_CE_DEFINE(strand);
|
|
}
|
|
|
|
#endif // ENABLE_STRAND
|