summaryrefslogtreecommitdiffstats
path: root/tests/auto/concurrent/qtconcurrentfiltermapgenerated/generator/function_signature.py
blob: d87c8a2e9b52ab796a215f63225351bae738e194 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
# Copyright (C) 2020 The Qt Company Ltd.
# SPDX-License-Identifier: LicenseRef-Qt-Commercial OR GPL-3.0-only WITH Qt-GPL-exception-1.0


from option_management import need_separate_output_sequence


# ["hallo", "welt"] -> "halloWelt"
def build_camel_case(*args):
    assert all(isinstance(x, str) for x in args)
    if len(args) == 0:
        return ""
    if len(args) == 1:
        return args[0]
    return args[0] + "".join(x.capitalize() for x in args[1:])


def build_function_name(options):
    result = []
    for part in ["blocking", "filter", "map", "reduce"]:
        if options[part]:
            result.append(part)

    def make_potentially_passive(verb):
        if verb == "map":
            return "mapped"
        if verb == "blocking":
            return "blocking"

        if verb[-1] == "e":
            verb += "d"
        else:
            verb += "ed"

        return verb

    if not options["inplace"]:
        result = [make_potentially_passive(x) for x in result]

    result = build_camel_case(*result)
    return result


def build_blocking_return_type(options):
    if options["inplace"]:
        if options["filter"] and options["iterators"] and not options["reduce"]:
            return "Iterator"  # have to mark new end
        else:
            return "void"
    else:
        if options["reduce"]:
            return "ResultType"

        if need_separate_output_sequence(options):
            return "OutputSequence"
        else:
            return "Sequence"


def build_return_type(options):
    if options["blocking"]:
        return build_blocking_return_type(options)
    else:
        return f"QFuture<{build_blocking_return_type(options)}>"


def build_template_argument_list(options):
    required_types = []
    if options["reduce"]:
        required_types.append("typename ResultType")

    need_output_sequence = need_separate_output_sequence(options)
    if need_output_sequence:
        required_types.append("OutputSequence")

    if options["iterators"]:
        required_types.append("Iterator")
    else:
        if need_output_sequence:
            required_types.append("InputSequence")
        else:
            required_types.append("Sequence")

    # Functors
    if options["filter"]:
        required_types.append("KeepFunctor")

    if options["map"]:
        required_types.append("MapFunctor")

    if options["reduce"]:
        required_types.append("ReduceFunctor")

    if options["initialvalue"]:
        required_types.append("reductionitemtype")

    return "template<" + ", ".join(["typename "+x for x in required_types]) + ">"


def build_argument_list(options):
    required_arguments = []
    if options["pool"]:
        required_arguments.append("QThreadPool* pool")

    if options["iterators"]:
        required_arguments.append("Iterator begin")
        required_arguments.append("Iterator end")
    else:
        if options["inplace"]:
            required_arguments.append("Sequence & sequence")
        else:
            if need_separate_output_sequence(options):
                required_arguments.append("InputSequence && sequence")
            else:
                required_arguments.append("const Sequence & sequence")

    if options["filter"]:
        required_arguments.append("KeepFunctor filterFunction")

    if options["map"]:
        required_arguments.append("MapFunctor function")

    if options["reduce"]:
        required_arguments.append("ReduceFunctor reduceFunction")
        if options["initialvalue"]:
            required_arguments.append("reductionitemtype && initialValue")

        required_arguments.append("ReduceOptions")

    return "(" + ", ".join(required_arguments) + ")"


def build_function_signature(options):
    return (build_template_argument_list(options) + "\n" +
            build_return_type(
                options) + " " + build_function_name(options) + build_argument_list(options)
            + ";"
            )