Lines Matching refs:message
102 def base_class(message):
103 return arguments_type(message.parameters, function_parameter_type)
106 def reply_type(message):
107 return arguments_type(message.reply_parameters, reply_parameter_type)
110 def decode_type(message):
111 if message.has_attribute(VARIADIC_ATTRIBUTE):
112 return arguments_type(message.parameters[:-1], reply_parameter_type)
113 return base_class(message)
116 def delayed_reply_type(message):
117 return arguments_type(message.reply_parameters, function_parameter_type)
120 def message_to_struct_declaration(message):
122 function_parameters = [(function_parameter_type(x.type), x.name) for x in message.parameters]
123 result.append('struct %s : %s' % (message.name, base_class(message)))
126 result.append(' static CoreIPC::StringReference name() { return CoreIPC::StringReference("%s"); }\n' % message.name)
127 result.append(' static const bool isSync = %s;\n' % ('false', 'true')[message.reply_parameters != None])
129 if message.reply_parameters != None:
130 if message.has_attribute(DELAYED_ATTRIBUTE):
131 send_parameters = [(function_parameter_type(x.type), x.name) for x in message.reply_parameters]
143 result.append(' typedef %s Reply;\n' % reply_type(message))
145 result.append(' typedef %s DecodeType;\n' % decode_type(message))
147 result.append(' %s%s(%s)' % (len(function_parameters) == 1 and 'explicit ' or '', message.name, ', '.join([' '.join(x) for x in function_parameters])))
148 result.append('\n : %s(%s)\n' % (base_class(message), ', '.join([x[1] for x in function_parameters])))
152 return surround_in_condition(''.join(result), message.condition)
230 for message in receiver.messages:
231 if message.reply_parameters != None and message.has_attribute(DELAYED_ATTRIBUTE):
300 def handler_function(receiver, message):
301 if message.name.find('URL') == 0:
302 return '%s::%s' % (receiver.name, 'url' + message.name[3:])
303 return '%s::%s' % (receiver.name, message.name[0].lower() + message.name[1:])
306 def async_message_statement(receiver, message):
307 dispatch_function_args = ['decoder', 'this', '&%s' % handler_function(receiver, message)]
310 if message.has_attribute(VARIADIC_ATTRIBUTE):
313 if message.has_attribute(WANTS_CONNECTION_ATTRIBUTE):
317 result.append(' if (decoder.messageName() == Messages::%s::%s::name()) {\n' % (receiver.name, message.name))
318 result.append(' CoreIPC::%s<Messages::%s::%s>(%s);\n' % (dispatch_function, receiver.name, message.name, ', '.join(dispatch_function_args)))
321 return surround_in_condition(''.join(result), message.condition)
324 def sync_message_statement(receiver, message):
326 if message.has_attribute(DELAYED_ATTRIBUTE):
328 if message.has_attribute(VARIADIC_ATTRIBUTE):
331 wants_connection = message.has_attribute(DELAYED_ATTRIBUTE) or message.has_attribute(WANTS_CONNECTION_ATTRIBUTE)
334 result.append(' if (decoder.messageName() == Messages::%s::%s::name()) {\n' % (receiver.name, message.name))
335 result.append(' CoreIPC::%s<Messages::%s::%s>(%sdecoder, %sreplyEncoder, this, &%s);\n' % (dispatch_function, receiver.name, message.name, 'connection, ' if wants_connection else '', '' if message.has_attribute(DELAYED_ATTRIBUTE) else '*', handler_function(receiver, message)))
338 return surround_in_condition(''.join(result), message.condition)
474 for message in receiver.messages:
475 if message.reply_parameters is not None:
476 for reply_parameter in message.reply_parameters:
483 headers[header].append(message.condition)
489 headers[header].append(message.condition)
512 for message in receiver.messages:
513 if message.reply_parameters != None and message.has_attribute(DELAYED_ATTRIBUTE):
514 sync_delayed_messages.append(message)
519 for message in sync_delayed_messages:
520 send_parameters = [(function_parameter_type(x.type), x.name) for x in message.reply_parameters]
522 if message.condition:
523 result.append('#if %s\n\n' % message.condition)
525 result.append('%s::DelayedReply::DelayedReply(PassRefPtr<CoreIPC::Connection> connection, PassOwnPtr<CoreIPC::MessageEncoder> encoder)\n' % message.name)
531 result.append('%s::DelayedReply::~DelayedReply()\n' % message.name)
536 result.append('bool %s::DelayedReply::send(%s)\n' % (message.name, ', '.join([' '.join(x) for x in send_parameters])))
539 result += [' *m_encoder << %s;\n' % x.name for x in message.reply_parameters]
546 if message.condition:
555 for message in receiver.messages:
556 if message.reply_parameters is not None:
557 sync_messages.append(message)
559 async_messages.append(message)
568 result += [async_message_statement(receiver, message) for message in async_messages]
581 result += [sync_message_statement(receiver, message) for message in sync_messages]