|
@@ -92,7 +92,8 @@ def gen_block(self, format: str) -> str:
|
|
|
|
|
|
|
|
|
|
# Match wrappers declared with a co_wrapper mark
|
|
# Match wrappers declared with a co_wrapper mark
|
|
-func_decl_re = re.compile(r'^int\s*co_wrapper'
|
|
|
|
|
|
+func_decl_re = re.compile(r'^(?P<return_type>[a-zA-Z][a-zA-Z0-9_]* [\*]?)'
|
|
|
|
+ r'\s*co_wrapper'
|
|
r'(?P<variant>(_[a-z][a-z0-9_]*)?)\s*'
|
|
r'(?P<variant>(_[a-z][a-z0-9_]*)?)\s*'
|
|
r'(?P<wrapper_name>[a-z][a-z0-9_]*)'
|
|
r'(?P<wrapper_name>[a-z][a-z0-9_]*)'
|
|
r'\((?P<args>[^)]*)\);$', re.MULTILINE)
|
|
r'\((?P<args>[^)]*)\);$', re.MULTILINE)
|
|
@@ -100,7 +101,7 @@ def gen_block(self, format: str) -> str:
|
|
|
|
|
|
def func_decl_iter(text: str) -> Iterator:
|
|
def func_decl_iter(text: str) -> Iterator:
|
|
for m in func_decl_re.finditer(text):
|
|
for m in func_decl_re.finditer(text):
|
|
- yield FuncDecl(return_type='int',
|
|
|
|
|
|
+ yield FuncDecl(return_type=m.group('return_type'),
|
|
name=m.group('wrapper_name'),
|
|
name=m.group('wrapper_name'),
|
|
args=m.group('args'),
|
|
args=m.group('args'),
|
|
variant=m.group('variant'))
|
|
variant=m.group('variant'))
|
|
@@ -123,7 +124,7 @@ def create_mixed_wrapper(func: FuncDecl) -> str:
|
|
name = func.co_name
|
|
name = func.co_name
|
|
struct_name = func.struct_name
|
|
struct_name = func.struct_name
|
|
return f"""\
|
|
return f"""\
|
|
-int {func.name}({ func.gen_list('{decl}') })
|
|
|
|
|
|
+{func.return_type} {func.name}({ func.gen_list('{decl}') })
|
|
{{
|
|
{{
|
|
if (qemu_in_coroutine()) {{
|
|
if (qemu_in_coroutine()) {{
|
|
return {name}({ func.gen_list('{name}') });
|
|
return {name}({ func.gen_list('{name}') });
|
|
@@ -137,7 +138,8 @@ def create_mixed_wrapper(func: FuncDecl) -> str:
|
|
|
|
|
|
s.poll_state.co = qemu_coroutine_create({name}_entry, &s);
|
|
s.poll_state.co = qemu_coroutine_create({name}_entry, &s);
|
|
|
|
|
|
- return bdrv_poll_co(&s.poll_state);
|
|
|
|
|
|
+ bdrv_poll_co(&s.poll_state);
|
|
|
|
+ return s.ret;
|
|
}}
|
|
}}
|
|
}}"""
|
|
}}"""
|
|
|
|
|
|
@@ -149,7 +151,7 @@ def create_co_wrapper(func: FuncDecl) -> str:
|
|
name = func.co_name
|
|
name = func.co_name
|
|
struct_name = func.struct_name
|
|
struct_name = func.struct_name
|
|
return f"""\
|
|
return f"""\
|
|
-int {func.name}({ func.gen_list('{decl}') })
|
|
|
|
|
|
+{func.return_type} {func.name}({ func.gen_list('{decl}') })
|
|
{{
|
|
{{
|
|
{struct_name} s = {{
|
|
{struct_name} s = {{
|
|
.poll_state.ctx = {func.ctx},
|
|
.poll_state.ctx = {func.ctx},
|
|
@@ -161,13 +163,13 @@ def create_co_wrapper(func: FuncDecl) -> str:
|
|
|
|
|
|
s.poll_state.co = qemu_coroutine_create({name}_entry, &s);
|
|
s.poll_state.co = qemu_coroutine_create({name}_entry, &s);
|
|
|
|
|
|
- return bdrv_poll_co(&s.poll_state);
|
|
|
|
|
|
+ bdrv_poll_co(&s.poll_state);
|
|
|
|
+ return s.ret;
|
|
}}"""
|
|
}}"""
|
|
|
|
|
|
|
|
|
|
def gen_wrapper(func: FuncDecl) -> str:
|
|
def gen_wrapper(func: FuncDecl) -> str:
|
|
assert not '_co_' in func.name
|
|
assert not '_co_' in func.name
|
|
- assert func.return_type == 'int'
|
|
|
|
|
|
|
|
name = func.co_name
|
|
name = func.co_name
|
|
struct_name = func.struct_name
|
|
struct_name = func.struct_name
|
|
@@ -183,6 +185,7 @@ def gen_wrapper(func: FuncDecl) -> str:
|
|
|
|
|
|
typedef struct {struct_name} {{
|
|
typedef struct {struct_name} {{
|
|
BdrvPollCo poll_state;
|
|
BdrvPollCo poll_state;
|
|
|
|
+ {func.return_type} ret;
|
|
{ func.gen_block(' {decl};') }
|
|
{ func.gen_block(' {decl};') }
|
|
}} {struct_name};
|
|
}} {struct_name};
|
|
|
|
|
|
@@ -190,7 +193,7 @@ def gen_wrapper(func: FuncDecl) -> str:
|
|
{{
|
|
{{
|
|
{struct_name} *s = opaque;
|
|
{struct_name} *s = opaque;
|
|
|
|
|
|
- s->poll_state.ret = {name}({ func.gen_list('s->{name}') });
|
|
|
|
|
|
+ s->ret = {name}({ func.gen_list('s->{name}') });
|
|
s->poll_state.in_progress = false;
|
|
s->poll_state.in_progress = false;
|
|
|
|
|
|
aio_wait_kick();
|
|
aio_wait_kick();
|