File Coverage

amqp_framing.c
Criterion Covered Total %
statement 632 1635 38.6
branch 243 736 33.0
condition n/a
subroutine n/a
pod n/a
total 875 2371 36.9


line stmt bran cond sub pod time code
1             /* Generated code. Do not edit. Edit and re-run codegen.py instead.
2             *
3             * ***** BEGIN LICENSE BLOCK *****
4             * Version: MIT
5             *
6             * Portions created by Alan Antonuk are Copyright (c) 2012-2013
7             * Alan Antonuk. All Rights Reserved.
8             *
9             * Portions created by VMware are Copyright (c) 2007-2012 VMware, Inc.
10             * All Rights Reserved.
11             *
12             * Portions created by Tony Garnock-Jones are Copyright (c) 2009-2010
13             * VMware, Inc. and Tony Garnock-Jones. All Rights Reserved.
14             *
15             * Permission is hereby granted, free of charge, to any person
16             * obtaining a copy of this software and associated documentation
17             * files (the "Software"), to deal in the Software without
18             * restriction, including without limitation the rights to use, copy,
19             * modify, merge, publish, distribute, sublicense, and/or sell copies
20             * of the Software, and to permit persons to whom the Software is
21             * furnished to do so, subject to the following conditions:
22             *
23             * The above copyright notice and this permission notice shall be
24             * included in all copies or substantial portions of the Software.
25             *
26             * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
27             * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
28             * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
29             * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
30             * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
31             * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
32             * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
33             * SOFTWARE.
34             * ***** END LICENSE BLOCK *****
35             */
36              
37             #ifdef HAVE_CONFIG_H
38             #include "config.h"
39             #endif
40              
41             #include "amqp_private.h"
42             #include
43             #include
44             #include
45             #include
46              
47 0           char const *amqp_constant_name(int constantNumber) {
48 0           switch (constantNumber) {
49             case AMQP_FRAME_METHOD:
50 0           return "AMQP_FRAME_METHOD";
51             case AMQP_FRAME_HEADER:
52 0           return "AMQP_FRAME_HEADER";
53             case AMQP_FRAME_BODY:
54 0           return "AMQP_FRAME_BODY";
55             case AMQP_FRAME_HEARTBEAT:
56 0           return "AMQP_FRAME_HEARTBEAT";
57             case AMQP_FRAME_MIN_SIZE:
58 0           return "AMQP_FRAME_MIN_SIZE";
59             case AMQP_FRAME_END:
60 0           return "AMQP_FRAME_END";
61             case AMQP_REPLY_SUCCESS:
62 0           return "AMQP_REPLY_SUCCESS";
63             case AMQP_CONTENT_TOO_LARGE:
64 0           return "AMQP_CONTENT_TOO_LARGE";
65             case AMQP_NO_ROUTE:
66 0           return "AMQP_NO_ROUTE";
67             case AMQP_NO_CONSUMERS:
68 0           return "AMQP_NO_CONSUMERS";
69             case AMQP_ACCESS_REFUSED:
70 0           return "AMQP_ACCESS_REFUSED";
71             case AMQP_NOT_FOUND:
72 0           return "AMQP_NOT_FOUND";
73             case AMQP_RESOURCE_LOCKED:
74 0           return "AMQP_RESOURCE_LOCKED";
75             case AMQP_PRECONDITION_FAILED:
76 0           return "AMQP_PRECONDITION_FAILED";
77             case AMQP_CONNECTION_FORCED:
78 0           return "AMQP_CONNECTION_FORCED";
79             case AMQP_INVALID_PATH:
80 0           return "AMQP_INVALID_PATH";
81             case AMQP_FRAME_ERROR:
82 0           return "AMQP_FRAME_ERROR";
83             case AMQP_SYNTAX_ERROR:
84 0           return "AMQP_SYNTAX_ERROR";
85             case AMQP_COMMAND_INVALID:
86 0           return "AMQP_COMMAND_INVALID";
87             case AMQP_CHANNEL_ERROR:
88 0           return "AMQP_CHANNEL_ERROR";
89             case AMQP_UNEXPECTED_FRAME:
90 0           return "AMQP_UNEXPECTED_FRAME";
91             case AMQP_RESOURCE_ERROR:
92 0           return "AMQP_RESOURCE_ERROR";
93             case AMQP_NOT_ALLOWED:
94 0           return "AMQP_NOT_ALLOWED";
95             case AMQP_NOT_IMPLEMENTED:
96 0           return "AMQP_NOT_IMPLEMENTED";
97             case AMQP_INTERNAL_ERROR:
98 0           return "AMQP_INTERNAL_ERROR";
99             default:
100 0           return "(unknown)";
101             }
102             }
103              
104 0           amqp_boolean_t amqp_constant_is_hard_error(int constantNumber) {
105 0           switch (constantNumber) {
106             case AMQP_CONNECTION_FORCED:
107 0           return 1;
108             case AMQP_INVALID_PATH:
109 0           return 1;
110             case AMQP_FRAME_ERROR:
111 0           return 1;
112             case AMQP_SYNTAX_ERROR:
113 0           return 1;
114             case AMQP_COMMAND_INVALID:
115 0           return 1;
116             case AMQP_CHANNEL_ERROR:
117 0           return 1;
118             case AMQP_UNEXPECTED_FRAME:
119 0           return 1;
120             case AMQP_RESOURCE_ERROR:
121 0           return 1;
122             case AMQP_NOT_ALLOWED:
123 0           return 1;
124             case AMQP_NOT_IMPLEMENTED:
125 0           return 1;
126             case AMQP_INTERNAL_ERROR:
127 0           return 1;
128             default:
129 0           return 0;
130             }
131             }
132              
133 0           char const *amqp_method_name(amqp_method_number_t methodNumber) {
134 0           switch (methodNumber) {
135             case AMQP_CONNECTION_START_METHOD:
136 0           return "AMQP_CONNECTION_START_METHOD";
137             case AMQP_CONNECTION_START_OK_METHOD:
138 0           return "AMQP_CONNECTION_START_OK_METHOD";
139             case AMQP_CONNECTION_SECURE_METHOD:
140 0           return "AMQP_CONNECTION_SECURE_METHOD";
141             case AMQP_CONNECTION_SECURE_OK_METHOD:
142 0           return "AMQP_CONNECTION_SECURE_OK_METHOD";
143             case AMQP_CONNECTION_TUNE_METHOD:
144 0           return "AMQP_CONNECTION_TUNE_METHOD";
145             case AMQP_CONNECTION_TUNE_OK_METHOD:
146 0           return "AMQP_CONNECTION_TUNE_OK_METHOD";
147             case AMQP_CONNECTION_OPEN_METHOD:
148 0           return "AMQP_CONNECTION_OPEN_METHOD";
149             case AMQP_CONNECTION_OPEN_OK_METHOD:
150 0           return "AMQP_CONNECTION_OPEN_OK_METHOD";
151             case AMQP_CONNECTION_CLOSE_METHOD:
152 0           return "AMQP_CONNECTION_CLOSE_METHOD";
153             case AMQP_CONNECTION_CLOSE_OK_METHOD:
154 0           return "AMQP_CONNECTION_CLOSE_OK_METHOD";
155             case AMQP_CONNECTION_BLOCKED_METHOD:
156 0           return "AMQP_CONNECTION_BLOCKED_METHOD";
157             case AMQP_CONNECTION_UNBLOCKED_METHOD:
158 0           return "AMQP_CONNECTION_UNBLOCKED_METHOD";
159             case AMQP_CHANNEL_OPEN_METHOD:
160 0           return "AMQP_CHANNEL_OPEN_METHOD";
161             case AMQP_CHANNEL_OPEN_OK_METHOD:
162 0           return "AMQP_CHANNEL_OPEN_OK_METHOD";
163             case AMQP_CHANNEL_FLOW_METHOD:
164 0           return "AMQP_CHANNEL_FLOW_METHOD";
165             case AMQP_CHANNEL_FLOW_OK_METHOD:
166 0           return "AMQP_CHANNEL_FLOW_OK_METHOD";
167             case AMQP_CHANNEL_CLOSE_METHOD:
168 0           return "AMQP_CHANNEL_CLOSE_METHOD";
169             case AMQP_CHANNEL_CLOSE_OK_METHOD:
170 0           return "AMQP_CHANNEL_CLOSE_OK_METHOD";
171             case AMQP_ACCESS_REQUEST_METHOD:
172 0           return "AMQP_ACCESS_REQUEST_METHOD";
173             case AMQP_ACCESS_REQUEST_OK_METHOD:
174 0           return "AMQP_ACCESS_REQUEST_OK_METHOD";
175             case AMQP_EXCHANGE_DECLARE_METHOD:
176 0           return "AMQP_EXCHANGE_DECLARE_METHOD";
177             case AMQP_EXCHANGE_DECLARE_OK_METHOD:
178 0           return "AMQP_EXCHANGE_DECLARE_OK_METHOD";
179             case AMQP_EXCHANGE_DELETE_METHOD:
180 0           return "AMQP_EXCHANGE_DELETE_METHOD";
181             case AMQP_EXCHANGE_DELETE_OK_METHOD:
182 0           return "AMQP_EXCHANGE_DELETE_OK_METHOD";
183             case AMQP_EXCHANGE_BIND_METHOD:
184 0           return "AMQP_EXCHANGE_BIND_METHOD";
185             case AMQP_EXCHANGE_BIND_OK_METHOD:
186 0           return "AMQP_EXCHANGE_BIND_OK_METHOD";
187             case AMQP_EXCHANGE_UNBIND_METHOD:
188 0           return "AMQP_EXCHANGE_UNBIND_METHOD";
189             case AMQP_EXCHANGE_UNBIND_OK_METHOD:
190 0           return "AMQP_EXCHANGE_UNBIND_OK_METHOD";
191             case AMQP_QUEUE_DECLARE_METHOD:
192 0           return "AMQP_QUEUE_DECLARE_METHOD";
193             case AMQP_QUEUE_DECLARE_OK_METHOD:
194 0           return "AMQP_QUEUE_DECLARE_OK_METHOD";
195             case AMQP_QUEUE_BIND_METHOD:
196 0           return "AMQP_QUEUE_BIND_METHOD";
197             case AMQP_QUEUE_BIND_OK_METHOD:
198 0           return "AMQP_QUEUE_BIND_OK_METHOD";
199             case AMQP_QUEUE_PURGE_METHOD:
200 0           return "AMQP_QUEUE_PURGE_METHOD";
201             case AMQP_QUEUE_PURGE_OK_METHOD:
202 0           return "AMQP_QUEUE_PURGE_OK_METHOD";
203             case AMQP_QUEUE_DELETE_METHOD:
204 0           return "AMQP_QUEUE_DELETE_METHOD";
205             case AMQP_QUEUE_DELETE_OK_METHOD:
206 0           return "AMQP_QUEUE_DELETE_OK_METHOD";
207             case AMQP_QUEUE_UNBIND_METHOD:
208 0           return "AMQP_QUEUE_UNBIND_METHOD";
209             case AMQP_QUEUE_UNBIND_OK_METHOD:
210 0           return "AMQP_QUEUE_UNBIND_OK_METHOD";
211             case AMQP_BASIC_QOS_METHOD:
212 0           return "AMQP_BASIC_QOS_METHOD";
213             case AMQP_BASIC_QOS_OK_METHOD:
214 0           return "AMQP_BASIC_QOS_OK_METHOD";
215             case AMQP_BASIC_CONSUME_METHOD:
216 0           return "AMQP_BASIC_CONSUME_METHOD";
217             case AMQP_BASIC_CONSUME_OK_METHOD:
218 0           return "AMQP_BASIC_CONSUME_OK_METHOD";
219             case AMQP_BASIC_CANCEL_METHOD:
220 0           return "AMQP_BASIC_CANCEL_METHOD";
221             case AMQP_BASIC_CANCEL_OK_METHOD:
222 0           return "AMQP_BASIC_CANCEL_OK_METHOD";
223             case AMQP_BASIC_PUBLISH_METHOD:
224 0           return "AMQP_BASIC_PUBLISH_METHOD";
225             case AMQP_BASIC_RETURN_METHOD:
226 0           return "AMQP_BASIC_RETURN_METHOD";
227             case AMQP_BASIC_DELIVER_METHOD:
228 0           return "AMQP_BASIC_DELIVER_METHOD";
229             case AMQP_BASIC_GET_METHOD:
230 0           return "AMQP_BASIC_GET_METHOD";
231             case AMQP_BASIC_GET_OK_METHOD:
232 0           return "AMQP_BASIC_GET_OK_METHOD";
233             case AMQP_BASIC_GET_EMPTY_METHOD:
234 0           return "AMQP_BASIC_GET_EMPTY_METHOD";
235             case AMQP_BASIC_ACK_METHOD:
236 0           return "AMQP_BASIC_ACK_METHOD";
237             case AMQP_BASIC_REJECT_METHOD:
238 0           return "AMQP_BASIC_REJECT_METHOD";
239             case AMQP_BASIC_RECOVER_ASYNC_METHOD:
240 0           return "AMQP_BASIC_RECOVER_ASYNC_METHOD";
241             case AMQP_BASIC_RECOVER_METHOD:
242 0           return "AMQP_BASIC_RECOVER_METHOD";
243             case AMQP_BASIC_RECOVER_OK_METHOD:
244 0           return "AMQP_BASIC_RECOVER_OK_METHOD";
245             case AMQP_BASIC_NACK_METHOD:
246 0           return "AMQP_BASIC_NACK_METHOD";
247             case AMQP_TX_SELECT_METHOD:
248 0           return "AMQP_TX_SELECT_METHOD";
249             case AMQP_TX_SELECT_OK_METHOD:
250 0           return "AMQP_TX_SELECT_OK_METHOD";
251             case AMQP_TX_COMMIT_METHOD:
252 0           return "AMQP_TX_COMMIT_METHOD";
253             case AMQP_TX_COMMIT_OK_METHOD:
254 0           return "AMQP_TX_COMMIT_OK_METHOD";
255             case AMQP_TX_ROLLBACK_METHOD:
256 0           return "AMQP_TX_ROLLBACK_METHOD";
257             case AMQP_TX_ROLLBACK_OK_METHOD:
258 0           return "AMQP_TX_ROLLBACK_OK_METHOD";
259             case AMQP_CONFIRM_SELECT_METHOD:
260 0           return "AMQP_CONFIRM_SELECT_METHOD";
261             case AMQP_CONFIRM_SELECT_OK_METHOD:
262 0           return "AMQP_CONFIRM_SELECT_OK_METHOD";
263             default:
264 0           return NULL;
265             }
266             }
267              
268 0           amqp_boolean_t amqp_method_has_content(amqp_method_number_t methodNumber) {
269 0           switch (methodNumber) {
270             case AMQP_BASIC_PUBLISH_METHOD:
271 0           return 1;
272             case AMQP_BASIC_RETURN_METHOD:
273 0           return 1;
274             case AMQP_BASIC_DELIVER_METHOD:
275 0           return 1;
276             case AMQP_BASIC_GET_OK_METHOD:
277 0           return 1;
278             default:
279 0           return 0;
280             }
281             }
282              
283 396           int amqp_decode_method(amqp_method_number_t methodNumber, amqp_pool_t *pool,
284             amqp_bytes_t encoded, void **decoded) {
285 396           size_t offset = 0;
286             uint8_t bit_buffer;
287              
288 396           switch (methodNumber) {
289             case AMQP_CONNECTION_START_METHOD: {
290 37           amqp_connection_start_t *m = (amqp_connection_start_t *)amqp_pool_alloc(
291             pool, sizeof(amqp_connection_start_t));
292 37 50         if (m == NULL) {
293 0           return AMQP_STATUS_NO_MEMORY;
294             }
295 37 50         if (!amqp_decode_8(encoded, &offset, &m->version_major))
296 0           return AMQP_STATUS_BAD_AMQP_DATA;
297 37 50         if (!amqp_decode_8(encoded, &offset, &m->version_minor))
298 0           return AMQP_STATUS_BAD_AMQP_DATA;
299             {
300 37           int res =
301 37           amqp_decode_table(encoded, pool, &(m->server_properties), &offset);
302 37 50         if (res < 0) return res;
303             }
304             {
305             uint32_t len;
306 74           if (!amqp_decode_32(encoded, &offset, &len) ||
307 37           !amqp_decode_bytes(encoded, &offset, &m->mechanisms, len))
308 0           return AMQP_STATUS_BAD_AMQP_DATA;
309             }
310             {
311             uint32_t len;
312 74           if (!amqp_decode_32(encoded, &offset, &len) ||
313 37           !amqp_decode_bytes(encoded, &offset, &m->locales, len))
314 0           return AMQP_STATUS_BAD_AMQP_DATA;
315             }
316 37           *decoded = m;
317 37           return 0;
318             }
319             case AMQP_CONNECTION_START_OK_METHOD: {
320 0           amqp_connection_start_ok_t *m =
321             (amqp_connection_start_ok_t *)amqp_pool_alloc(
322             pool, sizeof(amqp_connection_start_ok_t));
323 0 0         if (m == NULL) {
324 0           return AMQP_STATUS_NO_MEMORY;
325             }
326             {
327 0           int res =
328 0           amqp_decode_table(encoded, pool, &(m->client_properties), &offset);
329 0 0         if (res < 0) return res;
330             }
331             {
332             uint8_t len;
333 0           if (!amqp_decode_8(encoded, &offset, &len) ||
334 0           !amqp_decode_bytes(encoded, &offset, &m->mechanism, len))
335 0           return AMQP_STATUS_BAD_AMQP_DATA;
336             }
337             {
338             uint32_t len;
339 0           if (!amqp_decode_32(encoded, &offset, &len) ||
340 0           !amqp_decode_bytes(encoded, &offset, &m->response, len))
341 0           return AMQP_STATUS_BAD_AMQP_DATA;
342             }
343             {
344             uint8_t len;
345 0           if (!amqp_decode_8(encoded, &offset, &len) ||
346 0           !amqp_decode_bytes(encoded, &offset, &m->locale, len))
347 0           return AMQP_STATUS_BAD_AMQP_DATA;
348             }
349 0           *decoded = m;
350 0           return 0;
351             }
352             case AMQP_CONNECTION_SECURE_METHOD: {
353 0           amqp_connection_secure_t *m = (amqp_connection_secure_t *)amqp_pool_alloc(
354             pool, sizeof(amqp_connection_secure_t));
355 0 0         if (m == NULL) {
356 0           return AMQP_STATUS_NO_MEMORY;
357             }
358             {
359             uint32_t len;
360 0           if (!amqp_decode_32(encoded, &offset, &len) ||
361 0           !amqp_decode_bytes(encoded, &offset, &m->challenge, len))
362 0           return AMQP_STATUS_BAD_AMQP_DATA;
363             }
364 0           *decoded = m;
365 0           return 0;
366             }
367             case AMQP_CONNECTION_SECURE_OK_METHOD: {
368 0           amqp_connection_secure_ok_t *m =
369             (amqp_connection_secure_ok_t *)amqp_pool_alloc(
370             pool, sizeof(amqp_connection_secure_ok_t));
371 0 0         if (m == NULL) {
372 0           return AMQP_STATUS_NO_MEMORY;
373             }
374             {
375             uint32_t len;
376 0           if (!amqp_decode_32(encoded, &offset, &len) ||
377 0           !amqp_decode_bytes(encoded, &offset, &m->response, len))
378 0           return AMQP_STATUS_BAD_AMQP_DATA;
379             }
380 0           *decoded = m;
381 0           return 0;
382             }
383             case AMQP_CONNECTION_TUNE_METHOD: {
384 37           amqp_connection_tune_t *m = (amqp_connection_tune_t *)amqp_pool_alloc(
385             pool, sizeof(amqp_connection_tune_t));
386 37 50         if (m == NULL) {
387 0           return AMQP_STATUS_NO_MEMORY;
388             }
389 37 50         if (!amqp_decode_16(encoded, &offset, &m->channel_max))
390 0           return AMQP_STATUS_BAD_AMQP_DATA;
391 37 50         if (!amqp_decode_32(encoded, &offset, &m->frame_max))
392 0           return AMQP_STATUS_BAD_AMQP_DATA;
393 37 50         if (!amqp_decode_16(encoded, &offset, &m->heartbeat))
394 0           return AMQP_STATUS_BAD_AMQP_DATA;
395 37           *decoded = m;
396 37           return 0;
397             }
398             case AMQP_CONNECTION_TUNE_OK_METHOD: {
399 0           amqp_connection_tune_ok_t *m =
400             (amqp_connection_tune_ok_t *)amqp_pool_alloc(
401             pool, sizeof(amqp_connection_tune_ok_t));
402 0 0         if (m == NULL) {
403 0           return AMQP_STATUS_NO_MEMORY;
404             }
405 0 0         if (!amqp_decode_16(encoded, &offset, &m->channel_max))
406 0           return AMQP_STATUS_BAD_AMQP_DATA;
407 0 0         if (!amqp_decode_32(encoded, &offset, &m->frame_max))
408 0           return AMQP_STATUS_BAD_AMQP_DATA;
409 0 0         if (!amqp_decode_16(encoded, &offset, &m->heartbeat))
410 0           return AMQP_STATUS_BAD_AMQP_DATA;
411 0           *decoded = m;
412 0           return 0;
413             }
414             case AMQP_CONNECTION_OPEN_METHOD: {
415 0           amqp_connection_open_t *m = (amqp_connection_open_t *)amqp_pool_alloc(
416             pool, sizeof(amqp_connection_open_t));
417 0 0         if (m == NULL) {
418 0           return AMQP_STATUS_NO_MEMORY;
419             }
420             {
421             uint8_t len;
422 0           if (!amqp_decode_8(encoded, &offset, &len) ||
423 0           !amqp_decode_bytes(encoded, &offset, &m->virtual_host, len))
424 0           return AMQP_STATUS_BAD_AMQP_DATA;
425             }
426             {
427             uint8_t len;
428 0           if (!amqp_decode_8(encoded, &offset, &len) ||
429 0           !amqp_decode_bytes(encoded, &offset, &m->capabilities, len))
430 0           return AMQP_STATUS_BAD_AMQP_DATA;
431             }
432 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
433 0           return AMQP_STATUS_BAD_AMQP_DATA;
434 0           m->insist = (bit_buffer & (1 << 0)) ? 1 : 0;
435 0           *decoded = m;
436 0           return 0;
437             }
438             case AMQP_CONNECTION_OPEN_OK_METHOD: {
439 37           amqp_connection_open_ok_t *m =
440             (amqp_connection_open_ok_t *)amqp_pool_alloc(
441             pool, sizeof(amqp_connection_open_ok_t));
442 37 50         if (m == NULL) {
443 0           return AMQP_STATUS_NO_MEMORY;
444             }
445             {
446             uint8_t len;
447 74           if (!amqp_decode_8(encoded, &offset, &len) ||
448 37           !amqp_decode_bytes(encoded, &offset, &m->known_hosts, len))
449 0           return AMQP_STATUS_BAD_AMQP_DATA;
450             }
451 37           *decoded = m;
452 37           return 0;
453             }
454             case AMQP_CONNECTION_CLOSE_METHOD: {
455 0           amqp_connection_close_t *m = (amqp_connection_close_t *)amqp_pool_alloc(
456             pool, sizeof(amqp_connection_close_t));
457 0 0         if (m == NULL) {
458 0           return AMQP_STATUS_NO_MEMORY;
459             }
460 0 0         if (!amqp_decode_16(encoded, &offset, &m->reply_code))
461 0           return AMQP_STATUS_BAD_AMQP_DATA;
462             {
463             uint8_t len;
464 0           if (!amqp_decode_8(encoded, &offset, &len) ||
465 0           !amqp_decode_bytes(encoded, &offset, &m->reply_text, len))
466 0           return AMQP_STATUS_BAD_AMQP_DATA;
467             }
468 0 0         if (!amqp_decode_16(encoded, &offset, &m->class_id))
469 0           return AMQP_STATUS_BAD_AMQP_DATA;
470 0 0         if (!amqp_decode_16(encoded, &offset, &m->method_id))
471 0           return AMQP_STATUS_BAD_AMQP_DATA;
472 0           *decoded = m;
473 0           return 0;
474             }
475             case AMQP_CONNECTION_CLOSE_OK_METHOD: {
476 29           amqp_connection_close_ok_t *m =
477             (amqp_connection_close_ok_t *)amqp_pool_alloc(
478             pool, sizeof(amqp_connection_close_ok_t));
479 29 50         if (m == NULL) {
480 0           return AMQP_STATUS_NO_MEMORY;
481             }
482 29           *decoded = m;
483 29           return 0;
484             }
485             case AMQP_CONNECTION_BLOCKED_METHOD: {
486 0           amqp_connection_blocked_t *m =
487             (amqp_connection_blocked_t *)amqp_pool_alloc(
488             pool, sizeof(amqp_connection_blocked_t));
489 0 0         if (m == NULL) {
490 0           return AMQP_STATUS_NO_MEMORY;
491             }
492             {
493             uint8_t len;
494 0           if (!amqp_decode_8(encoded, &offset, &len) ||
495 0           !amqp_decode_bytes(encoded, &offset, &m->reason, len))
496 0           return AMQP_STATUS_BAD_AMQP_DATA;
497             }
498 0           *decoded = m;
499 0           return 0;
500             }
501             case AMQP_CONNECTION_UNBLOCKED_METHOD: {
502 0           amqp_connection_unblocked_t *m =
503             (amqp_connection_unblocked_t *)amqp_pool_alloc(
504             pool, sizeof(amqp_connection_unblocked_t));
505 0 0         if (m == NULL) {
506 0           return AMQP_STATUS_NO_MEMORY;
507             }
508 0           *decoded = m;
509 0           return 0;
510             }
511             case AMQP_CHANNEL_OPEN_METHOD: {
512 0           amqp_channel_open_t *m = (amqp_channel_open_t *)amqp_pool_alloc(
513             pool, sizeof(amqp_channel_open_t));
514 0 0         if (m == NULL) {
515 0           return AMQP_STATUS_NO_MEMORY;
516             }
517             {
518             uint8_t len;
519 0           if (!amqp_decode_8(encoded, &offset, &len) ||
520 0           !amqp_decode_bytes(encoded, &offset, &m->out_of_band, len))
521 0           return AMQP_STATUS_BAD_AMQP_DATA;
522             }
523 0           *decoded = m;
524 0           return 0;
525             }
526             case AMQP_CHANNEL_OPEN_OK_METHOD: {
527 36           amqp_channel_open_ok_t *m = (amqp_channel_open_ok_t *)amqp_pool_alloc(
528             pool, sizeof(amqp_channel_open_ok_t));
529 36 50         if (m == NULL) {
530 0           return AMQP_STATUS_NO_MEMORY;
531             }
532             {
533             uint32_t len;
534 72           if (!amqp_decode_32(encoded, &offset, &len) ||
535 36           !amqp_decode_bytes(encoded, &offset, &m->channel_id, len))
536 0           return AMQP_STATUS_BAD_AMQP_DATA;
537             }
538 36           *decoded = m;
539 36           return 0;
540             }
541             case AMQP_CHANNEL_FLOW_METHOD: {
542 0           amqp_channel_flow_t *m = (amqp_channel_flow_t *)amqp_pool_alloc(
543             pool, sizeof(amqp_channel_flow_t));
544 0 0         if (m == NULL) {
545 0           return AMQP_STATUS_NO_MEMORY;
546             }
547 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
548 0           return AMQP_STATUS_BAD_AMQP_DATA;
549 0           m->active = (bit_buffer & (1 << 0)) ? 1 : 0;
550 0           *decoded = m;
551 0           return 0;
552             }
553             case AMQP_CHANNEL_FLOW_OK_METHOD: {
554 0           amqp_channel_flow_ok_t *m = (amqp_channel_flow_ok_t *)amqp_pool_alloc(
555             pool, sizeof(amqp_channel_flow_ok_t));
556 0 0         if (m == NULL) {
557 0           return AMQP_STATUS_NO_MEMORY;
558             }
559 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
560 0           return AMQP_STATUS_BAD_AMQP_DATA;
561 0           m->active = (bit_buffer & (1 << 0)) ? 1 : 0;
562 0           *decoded = m;
563 0           return 0;
564             }
565             case AMQP_CHANNEL_CLOSE_METHOD: {
566 6           amqp_channel_close_t *m = (amqp_channel_close_t *)amqp_pool_alloc(
567             pool, sizeof(amqp_channel_close_t));
568 6 50         if (m == NULL) {
569 0           return AMQP_STATUS_NO_MEMORY;
570             }
571 6 50         if (!amqp_decode_16(encoded, &offset, &m->reply_code))
572 0           return AMQP_STATUS_BAD_AMQP_DATA;
573             {
574             uint8_t len;
575 12           if (!amqp_decode_8(encoded, &offset, &len) ||
576 6           !amqp_decode_bytes(encoded, &offset, &m->reply_text, len))
577 0           return AMQP_STATUS_BAD_AMQP_DATA;
578             }
579 6 50         if (!amqp_decode_16(encoded, &offset, &m->class_id))
580 0           return AMQP_STATUS_BAD_AMQP_DATA;
581 6 50         if (!amqp_decode_16(encoded, &offset, &m->method_id))
582 0           return AMQP_STATUS_BAD_AMQP_DATA;
583 6           *decoded = m;
584 6           return 0;
585             }
586             case AMQP_CHANNEL_CLOSE_OK_METHOD: {
587 1           amqp_channel_close_ok_t *m = (amqp_channel_close_ok_t *)amqp_pool_alloc(
588             pool, sizeof(amqp_channel_close_ok_t));
589 1 50         if (m == NULL) {
590 0           return AMQP_STATUS_NO_MEMORY;
591             }
592 1           *decoded = m;
593 1           return 0;
594             }
595             case AMQP_ACCESS_REQUEST_METHOD: {
596 0           amqp_access_request_t *m = (amqp_access_request_t *)amqp_pool_alloc(
597             pool, sizeof(amqp_access_request_t));
598 0 0         if (m == NULL) {
599 0           return AMQP_STATUS_NO_MEMORY;
600             }
601             {
602             uint8_t len;
603 0           if (!amqp_decode_8(encoded, &offset, &len) ||
604 0           !amqp_decode_bytes(encoded, &offset, &m->realm, len))
605 0           return AMQP_STATUS_BAD_AMQP_DATA;
606             }
607 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
608 0           return AMQP_STATUS_BAD_AMQP_DATA;
609 0           m->exclusive = (bit_buffer & (1 << 0)) ? 1 : 0;
610 0           m->passive = (bit_buffer & (1 << 1)) ? 1 : 0;
611 0           m->active = (bit_buffer & (1 << 2)) ? 1 : 0;
612 0           m->write = (bit_buffer & (1 << 3)) ? 1 : 0;
613 0           m->read = (bit_buffer & (1 << 4)) ? 1 : 0;
614 0           *decoded = m;
615 0           return 0;
616             }
617             case AMQP_ACCESS_REQUEST_OK_METHOD: {
618 0           amqp_access_request_ok_t *m = (amqp_access_request_ok_t *)amqp_pool_alloc(
619             pool, sizeof(amqp_access_request_ok_t));
620 0 0         if (m == NULL) {
621 0           return AMQP_STATUS_NO_MEMORY;
622             }
623 0 0         if (!amqp_decode_16(encoded, &offset, &m->ticket))
624 0           return AMQP_STATUS_BAD_AMQP_DATA;
625 0           *decoded = m;
626 0           return 0;
627             }
628             case AMQP_EXCHANGE_DECLARE_METHOD: {
629 0           amqp_exchange_declare_t *m = (amqp_exchange_declare_t *)amqp_pool_alloc(
630             pool, sizeof(amqp_exchange_declare_t));
631 0 0         if (m == NULL) {
632 0           return AMQP_STATUS_NO_MEMORY;
633             }
634 0 0         if (!amqp_decode_16(encoded, &offset, &m->ticket))
635 0           return AMQP_STATUS_BAD_AMQP_DATA;
636             {
637             uint8_t len;
638 0           if (!amqp_decode_8(encoded, &offset, &len) ||
639 0           !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
640 0           return AMQP_STATUS_BAD_AMQP_DATA;
641             }
642             {
643             uint8_t len;
644 0           if (!amqp_decode_8(encoded, &offset, &len) ||
645 0           !amqp_decode_bytes(encoded, &offset, &m->type, len))
646 0           return AMQP_STATUS_BAD_AMQP_DATA;
647             }
648 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
649 0           return AMQP_STATUS_BAD_AMQP_DATA;
650 0           m->passive = (bit_buffer & (1 << 0)) ? 1 : 0;
651 0           m->durable = (bit_buffer & (1 << 1)) ? 1 : 0;
652 0           m->auto_delete = (bit_buffer & (1 << 2)) ? 1 : 0;
653 0           m->internal = (bit_buffer & (1 << 3)) ? 1 : 0;
654 0           m->nowait = (bit_buffer & (1 << 4)) ? 1 : 0;
655             {
656 0           int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
657 0 0         if (res < 0) return res;
658             }
659 0           *decoded = m;
660 0           return 0;
661             }
662             case AMQP_EXCHANGE_DECLARE_OK_METHOD: {
663 26           amqp_exchange_declare_ok_t *m =
664             (amqp_exchange_declare_ok_t *)amqp_pool_alloc(
665             pool, sizeof(amqp_exchange_declare_ok_t));
666 26 50         if (m == NULL) {
667 0           return AMQP_STATUS_NO_MEMORY;
668             }
669 26           *decoded = m;
670 26           return 0;
671             }
672             case AMQP_EXCHANGE_DELETE_METHOD: {
673 0           amqp_exchange_delete_t *m = (amqp_exchange_delete_t *)amqp_pool_alloc(
674             pool, sizeof(amqp_exchange_delete_t));
675 0 0         if (m == NULL) {
676 0           return AMQP_STATUS_NO_MEMORY;
677             }
678 0 0         if (!amqp_decode_16(encoded, &offset, &m->ticket))
679 0           return AMQP_STATUS_BAD_AMQP_DATA;
680             {
681             uint8_t len;
682 0           if (!amqp_decode_8(encoded, &offset, &len) ||
683 0           !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
684 0           return AMQP_STATUS_BAD_AMQP_DATA;
685             }
686 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
687 0           return AMQP_STATUS_BAD_AMQP_DATA;
688 0           m->if_unused = (bit_buffer & (1 << 0)) ? 1 : 0;
689 0           m->nowait = (bit_buffer & (1 << 1)) ? 1 : 0;
690 0           *decoded = m;
691 0           return 0;
692             }
693             case AMQP_EXCHANGE_DELETE_OK_METHOD: {
694 27           amqp_exchange_delete_ok_t *m =
695             (amqp_exchange_delete_ok_t *)amqp_pool_alloc(
696             pool, sizeof(amqp_exchange_delete_ok_t));
697 27 50         if (m == NULL) {
698 0           return AMQP_STATUS_NO_MEMORY;
699             }
700 27           *decoded = m;
701 27           return 0;
702             }
703             case AMQP_EXCHANGE_BIND_METHOD: {
704 0           amqp_exchange_bind_t *m = (amqp_exchange_bind_t *)amqp_pool_alloc(
705             pool, sizeof(amqp_exchange_bind_t));
706 0 0         if (m == NULL) {
707 0           return AMQP_STATUS_NO_MEMORY;
708             }
709 0 0         if (!amqp_decode_16(encoded, &offset, &m->ticket))
710 0           return AMQP_STATUS_BAD_AMQP_DATA;
711             {
712             uint8_t len;
713 0           if (!amqp_decode_8(encoded, &offset, &len) ||
714 0           !amqp_decode_bytes(encoded, &offset, &m->destination, len))
715 0           return AMQP_STATUS_BAD_AMQP_DATA;
716             }
717             {
718             uint8_t len;
719 0           if (!amqp_decode_8(encoded, &offset, &len) ||
720 0           !amqp_decode_bytes(encoded, &offset, &m->source, len))
721 0           return AMQP_STATUS_BAD_AMQP_DATA;
722             }
723             {
724             uint8_t len;
725 0           if (!amqp_decode_8(encoded, &offset, &len) ||
726 0           !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
727 0           return AMQP_STATUS_BAD_AMQP_DATA;
728             }
729 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
730 0           return AMQP_STATUS_BAD_AMQP_DATA;
731 0           m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0;
732             {
733 0           int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
734 0 0         if (res < 0) return res;
735             }
736 0           *decoded = m;
737 0           return 0;
738             }
739             case AMQP_EXCHANGE_BIND_OK_METHOD: {
740 1           amqp_exchange_bind_ok_t *m = (amqp_exchange_bind_ok_t *)amqp_pool_alloc(
741             pool, sizeof(amqp_exchange_bind_ok_t));
742 1 50         if (m == NULL) {
743 0           return AMQP_STATUS_NO_MEMORY;
744             }
745 1           *decoded = m;
746 1           return 0;
747             }
748             case AMQP_EXCHANGE_UNBIND_METHOD: {
749 0           amqp_exchange_unbind_t *m = (amqp_exchange_unbind_t *)amqp_pool_alloc(
750             pool, sizeof(amqp_exchange_unbind_t));
751 0 0         if (m == NULL) {
752 0           return AMQP_STATUS_NO_MEMORY;
753             }
754 0 0         if (!amqp_decode_16(encoded, &offset, &m->ticket))
755 0           return AMQP_STATUS_BAD_AMQP_DATA;
756             {
757             uint8_t len;
758 0           if (!amqp_decode_8(encoded, &offset, &len) ||
759 0           !amqp_decode_bytes(encoded, &offset, &m->destination, len))
760 0           return AMQP_STATUS_BAD_AMQP_DATA;
761             }
762             {
763             uint8_t len;
764 0           if (!amqp_decode_8(encoded, &offset, &len) ||
765 0           !amqp_decode_bytes(encoded, &offset, &m->source, len))
766 0           return AMQP_STATUS_BAD_AMQP_DATA;
767             }
768             {
769             uint8_t len;
770 0           if (!amqp_decode_8(encoded, &offset, &len) ||
771 0           !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
772 0           return AMQP_STATUS_BAD_AMQP_DATA;
773             }
774 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
775 0           return AMQP_STATUS_BAD_AMQP_DATA;
776 0           m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0;
777             {
778 0           int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
779 0 0         if (res < 0) return res;
780             }
781 0           *decoded = m;
782 0           return 0;
783             }
784             case AMQP_EXCHANGE_UNBIND_OK_METHOD: {
785 1           amqp_exchange_unbind_ok_t *m =
786             (amqp_exchange_unbind_ok_t *)amqp_pool_alloc(
787             pool, sizeof(amqp_exchange_unbind_ok_t));
788 1 50         if (m == NULL) {
789 0           return AMQP_STATUS_NO_MEMORY;
790             }
791 1           *decoded = m;
792 1           return 0;
793             }
794             case AMQP_QUEUE_DECLARE_METHOD: {
795 0           amqp_queue_declare_t *m = (amqp_queue_declare_t *)amqp_pool_alloc(
796             pool, sizeof(amqp_queue_declare_t));
797 0 0         if (m == NULL) {
798 0           return AMQP_STATUS_NO_MEMORY;
799             }
800 0 0         if (!amqp_decode_16(encoded, &offset, &m->ticket))
801 0           return AMQP_STATUS_BAD_AMQP_DATA;
802             {
803             uint8_t len;
804 0           if (!amqp_decode_8(encoded, &offset, &len) ||
805 0           !amqp_decode_bytes(encoded, &offset, &m->queue, len))
806 0           return AMQP_STATUS_BAD_AMQP_DATA;
807             }
808 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
809 0           return AMQP_STATUS_BAD_AMQP_DATA;
810 0           m->passive = (bit_buffer & (1 << 0)) ? 1 : 0;
811 0           m->durable = (bit_buffer & (1 << 1)) ? 1 : 0;
812 0           m->exclusive = (bit_buffer & (1 << 2)) ? 1 : 0;
813 0           m->auto_delete = (bit_buffer & (1 << 3)) ? 1 : 0;
814 0           m->nowait = (bit_buffer & (1 << 4)) ? 1 : 0;
815             {
816 0           int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
817 0 0         if (res < 0) return res;
818             }
819 0           *decoded = m;
820 0           return 0;
821             }
822             case AMQP_QUEUE_DECLARE_OK_METHOD: {
823 19           amqp_queue_declare_ok_t *m = (amqp_queue_declare_ok_t *)amqp_pool_alloc(
824             pool, sizeof(amqp_queue_declare_ok_t));
825 19 50         if (m == NULL) {
826 0           return AMQP_STATUS_NO_MEMORY;
827             }
828             {
829             uint8_t len;
830 38           if (!amqp_decode_8(encoded, &offset, &len) ||
831 19           !amqp_decode_bytes(encoded, &offset, &m->queue, len))
832 0           return AMQP_STATUS_BAD_AMQP_DATA;
833             }
834 19 50         if (!amqp_decode_32(encoded, &offset, &m->message_count))
835 0           return AMQP_STATUS_BAD_AMQP_DATA;
836 19 50         if (!amqp_decode_32(encoded, &offset, &m->consumer_count))
837 0           return AMQP_STATUS_BAD_AMQP_DATA;
838 19           *decoded = m;
839 19           return 0;
840             }
841             case AMQP_QUEUE_BIND_METHOD: {
842 0           amqp_queue_bind_t *m =
843             (amqp_queue_bind_t *)amqp_pool_alloc(pool, sizeof(amqp_queue_bind_t));
844 0 0         if (m == NULL) {
845 0           return AMQP_STATUS_NO_MEMORY;
846             }
847 0 0         if (!amqp_decode_16(encoded, &offset, &m->ticket))
848 0           return AMQP_STATUS_BAD_AMQP_DATA;
849             {
850             uint8_t len;
851 0           if (!amqp_decode_8(encoded, &offset, &len) ||
852 0           !amqp_decode_bytes(encoded, &offset, &m->queue, len))
853 0           return AMQP_STATUS_BAD_AMQP_DATA;
854             }
855             {
856             uint8_t len;
857 0           if (!amqp_decode_8(encoded, &offset, &len) ||
858 0           !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
859 0           return AMQP_STATUS_BAD_AMQP_DATA;
860             }
861             {
862             uint8_t len;
863 0           if (!amqp_decode_8(encoded, &offset, &len) ||
864 0           !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
865 0           return AMQP_STATUS_BAD_AMQP_DATA;
866             }
867 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
868 0           return AMQP_STATUS_BAD_AMQP_DATA;
869 0           m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0;
870             {
871 0           int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
872 0 0         if (res < 0) return res;
873             }
874 0           *decoded = m;
875 0           return 0;
876             }
877             case AMQP_QUEUE_BIND_OK_METHOD: {
878 17           amqp_queue_bind_ok_t *m = (amqp_queue_bind_ok_t *)amqp_pool_alloc(
879             pool, sizeof(amqp_queue_bind_ok_t));
880 17 50         if (m == NULL) {
881 0           return AMQP_STATUS_NO_MEMORY;
882             }
883 17           *decoded = m;
884 17           return 0;
885             }
886             case AMQP_QUEUE_PURGE_METHOD: {
887 0           amqp_queue_purge_t *m = (amqp_queue_purge_t *)amqp_pool_alloc(
888             pool, sizeof(amqp_queue_purge_t));
889 0 0         if (m == NULL) {
890 0           return AMQP_STATUS_NO_MEMORY;
891             }
892 0 0         if (!amqp_decode_16(encoded, &offset, &m->ticket))
893 0           return AMQP_STATUS_BAD_AMQP_DATA;
894             {
895             uint8_t len;
896 0           if (!amqp_decode_8(encoded, &offset, &len) ||
897 0           !amqp_decode_bytes(encoded, &offset, &m->queue, len))
898 0           return AMQP_STATUS_BAD_AMQP_DATA;
899             }
900 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
901 0           return AMQP_STATUS_BAD_AMQP_DATA;
902 0           m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0;
903 0           *decoded = m;
904 0           return 0;
905             }
906             case AMQP_QUEUE_PURGE_OK_METHOD: {
907 17           amqp_queue_purge_ok_t *m = (amqp_queue_purge_ok_t *)amqp_pool_alloc(
908             pool, sizeof(amqp_queue_purge_ok_t));
909 17 50         if (m == NULL) {
910 0           return AMQP_STATUS_NO_MEMORY;
911             }
912 17 50         if (!amqp_decode_32(encoded, &offset, &m->message_count))
913 0           return AMQP_STATUS_BAD_AMQP_DATA;
914 17           *decoded = m;
915 17           return 0;
916             }
917             case AMQP_QUEUE_DELETE_METHOD: {
918 0           amqp_queue_delete_t *m = (amqp_queue_delete_t *)amqp_pool_alloc(
919             pool, sizeof(amqp_queue_delete_t));
920 0 0         if (m == NULL) {
921 0           return AMQP_STATUS_NO_MEMORY;
922             }
923 0 0         if (!amqp_decode_16(encoded, &offset, &m->ticket))
924 0           return AMQP_STATUS_BAD_AMQP_DATA;
925             {
926             uint8_t len;
927 0           if (!amqp_decode_8(encoded, &offset, &len) ||
928 0           !amqp_decode_bytes(encoded, &offset, &m->queue, len))
929 0           return AMQP_STATUS_BAD_AMQP_DATA;
930             }
931 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
932 0           return AMQP_STATUS_BAD_AMQP_DATA;
933 0           m->if_unused = (bit_buffer & (1 << 0)) ? 1 : 0;
934 0           m->if_empty = (bit_buffer & (1 << 1)) ? 1 : 0;
935 0           m->nowait = (bit_buffer & (1 << 2)) ? 1 : 0;
936 0           *decoded = m;
937 0           return 0;
938             }
939             case AMQP_QUEUE_DELETE_OK_METHOD: {
940 20           amqp_queue_delete_ok_t *m = (amqp_queue_delete_ok_t *)amqp_pool_alloc(
941             pool, sizeof(amqp_queue_delete_ok_t));
942 20 50         if (m == NULL) {
943 0           return AMQP_STATUS_NO_MEMORY;
944             }
945 20 50         if (!amqp_decode_32(encoded, &offset, &m->message_count))
946 0           return AMQP_STATUS_BAD_AMQP_DATA;
947 20           *decoded = m;
948 20           return 0;
949             }
950             case AMQP_QUEUE_UNBIND_METHOD: {
951 0           amqp_queue_unbind_t *m = (amqp_queue_unbind_t *)amqp_pool_alloc(
952             pool, sizeof(amqp_queue_unbind_t));
953 0 0         if (m == NULL) {
954 0           return AMQP_STATUS_NO_MEMORY;
955             }
956 0 0         if (!amqp_decode_16(encoded, &offset, &m->ticket))
957 0           return AMQP_STATUS_BAD_AMQP_DATA;
958             {
959             uint8_t len;
960 0           if (!amqp_decode_8(encoded, &offset, &len) ||
961 0           !amqp_decode_bytes(encoded, &offset, &m->queue, len))
962 0           return AMQP_STATUS_BAD_AMQP_DATA;
963             }
964             {
965             uint8_t len;
966 0           if (!amqp_decode_8(encoded, &offset, &len) ||
967 0           !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
968 0           return AMQP_STATUS_BAD_AMQP_DATA;
969             }
970             {
971             uint8_t len;
972 0           if (!amqp_decode_8(encoded, &offset, &len) ||
973 0           !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
974 0           return AMQP_STATUS_BAD_AMQP_DATA;
975             }
976             {
977 0           int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
978 0 0         if (res < 0) return res;
979             }
980 0           *decoded = m;
981 0           return 0;
982             }
983             case AMQP_QUEUE_UNBIND_OK_METHOD: {
984 21           amqp_queue_unbind_ok_t *m = (amqp_queue_unbind_ok_t *)amqp_pool_alloc(
985             pool, sizeof(amqp_queue_unbind_ok_t));
986 21 50         if (m == NULL) {
987 0           return AMQP_STATUS_NO_MEMORY;
988             }
989 21           *decoded = m;
990 21           return 0;
991             }
992             case AMQP_BASIC_QOS_METHOD: {
993 0           amqp_basic_qos_t *m =
994             (amqp_basic_qos_t *)amqp_pool_alloc(pool, sizeof(amqp_basic_qos_t));
995 0 0         if (m == NULL) {
996 0           return AMQP_STATUS_NO_MEMORY;
997             }
998 0 0         if (!amqp_decode_32(encoded, &offset, &m->prefetch_size))
999 0           return AMQP_STATUS_BAD_AMQP_DATA;
1000 0 0         if (!amqp_decode_16(encoded, &offset, &m->prefetch_count))
1001 0           return AMQP_STATUS_BAD_AMQP_DATA;
1002 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
1003 0           return AMQP_STATUS_BAD_AMQP_DATA;
1004 0           m->global = (bit_buffer & (1 << 0)) ? 1 : 0;
1005 0           *decoded = m;
1006 0           return 0;
1007             }
1008             case AMQP_BASIC_QOS_OK_METHOD: {
1009 1           amqp_basic_qos_ok_t *m = (amqp_basic_qos_ok_t *)amqp_pool_alloc(
1010             pool, sizeof(amqp_basic_qos_ok_t));
1011 1 50         if (m == NULL) {
1012 0           return AMQP_STATUS_NO_MEMORY;
1013             }
1014 1           *decoded = m;
1015 1           return 0;
1016             }
1017             case AMQP_BASIC_CONSUME_METHOD: {
1018 0           amqp_basic_consume_t *m = (amqp_basic_consume_t *)amqp_pool_alloc(
1019             pool, sizeof(amqp_basic_consume_t));
1020 0 0         if (m == NULL) {
1021 0           return AMQP_STATUS_NO_MEMORY;
1022             }
1023 0 0         if (!amqp_decode_16(encoded, &offset, &m->ticket))
1024 0           return AMQP_STATUS_BAD_AMQP_DATA;
1025             {
1026             uint8_t len;
1027 0           if (!amqp_decode_8(encoded, &offset, &len) ||
1028 0           !amqp_decode_bytes(encoded, &offset, &m->queue, len))
1029 0           return AMQP_STATUS_BAD_AMQP_DATA;
1030             }
1031             {
1032             uint8_t len;
1033 0           if (!amqp_decode_8(encoded, &offset, &len) ||
1034 0           !amqp_decode_bytes(encoded, &offset, &m->consumer_tag, len))
1035 0           return AMQP_STATUS_BAD_AMQP_DATA;
1036             }
1037 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
1038 0           return AMQP_STATUS_BAD_AMQP_DATA;
1039 0           m->no_local = (bit_buffer & (1 << 0)) ? 1 : 0;
1040 0           m->no_ack = (bit_buffer & (1 << 1)) ? 1 : 0;
1041 0           m->exclusive = (bit_buffer & (1 << 2)) ? 1 : 0;
1042 0           m->nowait = (bit_buffer & (1 << 3)) ? 1 : 0;
1043             {
1044 0           int res = amqp_decode_table(encoded, pool, &(m->arguments), &offset);
1045 0 0         if (res < 0) return res;
1046             }
1047 0           *decoded = m;
1048 0           return 0;
1049             }
1050             case AMQP_BASIC_CONSUME_OK_METHOD: {
1051 16           amqp_basic_consume_ok_t *m = (amqp_basic_consume_ok_t *)amqp_pool_alloc(
1052             pool, sizeof(amqp_basic_consume_ok_t));
1053 16 50         if (m == NULL) {
1054 0           return AMQP_STATUS_NO_MEMORY;
1055             }
1056             {
1057             uint8_t len;
1058 32           if (!amqp_decode_8(encoded, &offset, &len) ||
1059 16           !amqp_decode_bytes(encoded, &offset, &m->consumer_tag, len))
1060 0           return AMQP_STATUS_BAD_AMQP_DATA;
1061             }
1062 16           *decoded = m;
1063 16           return 0;
1064             }
1065             case AMQP_BASIC_CANCEL_METHOD: {
1066 0           amqp_basic_cancel_t *m = (amqp_basic_cancel_t *)amqp_pool_alloc(
1067             pool, sizeof(amqp_basic_cancel_t));
1068 0 0         if (m == NULL) {
1069 0           return AMQP_STATUS_NO_MEMORY;
1070             }
1071             {
1072             uint8_t len;
1073 0           if (!amqp_decode_8(encoded, &offset, &len) ||
1074 0           !amqp_decode_bytes(encoded, &offset, &m->consumer_tag, len))
1075 0           return AMQP_STATUS_BAD_AMQP_DATA;
1076             }
1077 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
1078 0           return AMQP_STATUS_BAD_AMQP_DATA;
1079 0           m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0;
1080 0           *decoded = m;
1081 0           return 0;
1082             }
1083             case AMQP_BASIC_CANCEL_OK_METHOD: {
1084 1           amqp_basic_cancel_ok_t *m = (amqp_basic_cancel_ok_t *)amqp_pool_alloc(
1085             pool, sizeof(amqp_basic_cancel_ok_t));
1086 1 50         if (m == NULL) {
1087 0           return AMQP_STATUS_NO_MEMORY;
1088             }
1089             {
1090             uint8_t len;
1091 2           if (!amqp_decode_8(encoded, &offset, &len) ||
1092 1           !amqp_decode_bytes(encoded, &offset, &m->consumer_tag, len))
1093 0           return AMQP_STATUS_BAD_AMQP_DATA;
1094             }
1095 1           *decoded = m;
1096 1           return 0;
1097             }
1098             case AMQP_BASIC_PUBLISH_METHOD: {
1099 0           amqp_basic_publish_t *m = (amqp_basic_publish_t *)amqp_pool_alloc(
1100             pool, sizeof(amqp_basic_publish_t));
1101 0 0         if (m == NULL) {
1102 0           return AMQP_STATUS_NO_MEMORY;
1103             }
1104 0 0         if (!amqp_decode_16(encoded, &offset, &m->ticket))
1105 0           return AMQP_STATUS_BAD_AMQP_DATA;
1106             {
1107             uint8_t len;
1108 0           if (!amqp_decode_8(encoded, &offset, &len) ||
1109 0           !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
1110 0           return AMQP_STATUS_BAD_AMQP_DATA;
1111             }
1112             {
1113             uint8_t len;
1114 0           if (!amqp_decode_8(encoded, &offset, &len) ||
1115 0           !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
1116 0           return AMQP_STATUS_BAD_AMQP_DATA;
1117             }
1118 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
1119 0           return AMQP_STATUS_BAD_AMQP_DATA;
1120 0           m->mandatory = (bit_buffer & (1 << 0)) ? 1 : 0;
1121 0           m->immediate = (bit_buffer & (1 << 1)) ? 1 : 0;
1122 0           *decoded = m;
1123 0           return 0;
1124             }
1125             case AMQP_BASIC_RETURN_METHOD: {
1126 0           amqp_basic_return_t *m = (amqp_basic_return_t *)amqp_pool_alloc(
1127             pool, sizeof(amqp_basic_return_t));
1128 0 0         if (m == NULL) {
1129 0           return AMQP_STATUS_NO_MEMORY;
1130             }
1131 0 0         if (!amqp_decode_16(encoded, &offset, &m->reply_code))
1132 0           return AMQP_STATUS_BAD_AMQP_DATA;
1133             {
1134             uint8_t len;
1135 0           if (!amqp_decode_8(encoded, &offset, &len) ||
1136 0           !amqp_decode_bytes(encoded, &offset, &m->reply_text, len))
1137 0           return AMQP_STATUS_BAD_AMQP_DATA;
1138             }
1139             {
1140             uint8_t len;
1141 0           if (!amqp_decode_8(encoded, &offset, &len) ||
1142 0           !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
1143 0           return AMQP_STATUS_BAD_AMQP_DATA;
1144             }
1145             {
1146             uint8_t len;
1147 0           if (!amqp_decode_8(encoded, &offset, &len) ||
1148 0           !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
1149 0           return AMQP_STATUS_BAD_AMQP_DATA;
1150             }
1151 0           *decoded = m;
1152 0           return 0;
1153             }
1154             case AMQP_BASIC_DELIVER_METHOD: {
1155 21           amqp_basic_deliver_t *m = (amqp_basic_deliver_t *)amqp_pool_alloc(
1156             pool, sizeof(amqp_basic_deliver_t));
1157 21 50         if (m == NULL) {
1158 0           return AMQP_STATUS_NO_MEMORY;
1159             }
1160             {
1161             uint8_t len;
1162 42           if (!amqp_decode_8(encoded, &offset, &len) ||
1163 21           !amqp_decode_bytes(encoded, &offset, &m->consumer_tag, len))
1164 0           return AMQP_STATUS_BAD_AMQP_DATA;
1165             }
1166 21 50         if (!amqp_decode_64(encoded, &offset, &m->delivery_tag))
1167 0           return AMQP_STATUS_BAD_AMQP_DATA;
1168 21 50         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
1169 0           return AMQP_STATUS_BAD_AMQP_DATA;
1170 21           m->redelivered = (bit_buffer & (1 << 0)) ? 1 : 0;
1171             {
1172             uint8_t len;
1173 42           if (!amqp_decode_8(encoded, &offset, &len) ||
1174 21           !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
1175 0           return AMQP_STATUS_BAD_AMQP_DATA;
1176             }
1177             {
1178             uint8_t len;
1179 42           if (!amqp_decode_8(encoded, &offset, &len) ||
1180 21           !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
1181 0           return AMQP_STATUS_BAD_AMQP_DATA;
1182             }
1183 21           *decoded = m;
1184 21           return 0;
1185             }
1186             case AMQP_BASIC_GET_METHOD: {
1187 0           amqp_basic_get_t *m =
1188             (amqp_basic_get_t *)amqp_pool_alloc(pool, sizeof(amqp_basic_get_t));
1189 0 0         if (m == NULL) {
1190 0           return AMQP_STATUS_NO_MEMORY;
1191             }
1192 0 0         if (!amqp_decode_16(encoded, &offset, &m->ticket))
1193 0           return AMQP_STATUS_BAD_AMQP_DATA;
1194             {
1195             uint8_t len;
1196 0           if (!amqp_decode_8(encoded, &offset, &len) ||
1197 0           !amqp_decode_bytes(encoded, &offset, &m->queue, len))
1198 0           return AMQP_STATUS_BAD_AMQP_DATA;
1199             }
1200 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
1201 0           return AMQP_STATUS_BAD_AMQP_DATA;
1202 0           m->no_ack = (bit_buffer & (1 << 0)) ? 1 : 0;
1203 0           *decoded = m;
1204 0           return 0;
1205             }
1206             case AMQP_BASIC_GET_OK_METHOD: {
1207 4           amqp_basic_get_ok_t *m = (amqp_basic_get_ok_t *)amqp_pool_alloc(
1208             pool, sizeof(amqp_basic_get_ok_t));
1209 4 50         if (m == NULL) {
1210 0           return AMQP_STATUS_NO_MEMORY;
1211             }
1212 4 50         if (!amqp_decode_64(encoded, &offset, &m->delivery_tag))
1213 0           return AMQP_STATUS_BAD_AMQP_DATA;
1214 4 50         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
1215 0           return AMQP_STATUS_BAD_AMQP_DATA;
1216 4           m->redelivered = (bit_buffer & (1 << 0)) ? 1 : 0;
1217             {
1218             uint8_t len;
1219 8           if (!amqp_decode_8(encoded, &offset, &len) ||
1220 4           !amqp_decode_bytes(encoded, &offset, &m->exchange, len))
1221 0           return AMQP_STATUS_BAD_AMQP_DATA;
1222             }
1223             {
1224             uint8_t len;
1225 8           if (!amqp_decode_8(encoded, &offset, &len) ||
1226 4           !amqp_decode_bytes(encoded, &offset, &m->routing_key, len))
1227 0           return AMQP_STATUS_BAD_AMQP_DATA;
1228             }
1229 4 50         if (!amqp_decode_32(encoded, &offset, &m->message_count))
1230 0           return AMQP_STATUS_BAD_AMQP_DATA;
1231 4           *decoded = m;
1232 4           return 0;
1233             }
1234             case AMQP_BASIC_GET_EMPTY_METHOD: {
1235 18           amqp_basic_get_empty_t *m = (amqp_basic_get_empty_t *)amqp_pool_alloc(
1236             pool, sizeof(amqp_basic_get_empty_t));
1237 18 50         if (m == NULL) {
1238 0           return AMQP_STATUS_NO_MEMORY;
1239             }
1240             {
1241             uint8_t len;
1242 36           if (!amqp_decode_8(encoded, &offset, &len) ||
1243 18           !amqp_decode_bytes(encoded, &offset, &m->cluster_id, len))
1244 0           return AMQP_STATUS_BAD_AMQP_DATA;
1245             }
1246 18           *decoded = m;
1247 18           return 0;
1248             }
1249             case AMQP_BASIC_ACK_METHOD: {
1250 0           amqp_basic_ack_t *m =
1251             (amqp_basic_ack_t *)amqp_pool_alloc(pool, sizeof(amqp_basic_ack_t));
1252 0 0         if (m == NULL) {
1253 0           return AMQP_STATUS_NO_MEMORY;
1254             }
1255 0 0         if (!amqp_decode_64(encoded, &offset, &m->delivery_tag))
1256 0           return AMQP_STATUS_BAD_AMQP_DATA;
1257 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
1258 0           return AMQP_STATUS_BAD_AMQP_DATA;
1259 0           m->multiple = (bit_buffer & (1 << 0)) ? 1 : 0;
1260 0           *decoded = m;
1261 0           return 0;
1262             }
1263             case AMQP_BASIC_REJECT_METHOD: {
1264 0           amqp_basic_reject_t *m = (amqp_basic_reject_t *)amqp_pool_alloc(
1265             pool, sizeof(amqp_basic_reject_t));
1266 0 0         if (m == NULL) {
1267 0           return AMQP_STATUS_NO_MEMORY;
1268             }
1269 0 0         if (!amqp_decode_64(encoded, &offset, &m->delivery_tag))
1270 0           return AMQP_STATUS_BAD_AMQP_DATA;
1271 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
1272 0           return AMQP_STATUS_BAD_AMQP_DATA;
1273 0           m->requeue = (bit_buffer & (1 << 0)) ? 1 : 0;
1274 0           *decoded = m;
1275 0           return 0;
1276             }
1277             case AMQP_BASIC_RECOVER_ASYNC_METHOD: {
1278 0           amqp_basic_recover_async_t *m =
1279             (amqp_basic_recover_async_t *)amqp_pool_alloc(
1280             pool, sizeof(amqp_basic_recover_async_t));
1281 0 0         if (m == NULL) {
1282 0           return AMQP_STATUS_NO_MEMORY;
1283             }
1284 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
1285 0           return AMQP_STATUS_BAD_AMQP_DATA;
1286 0           m->requeue = (bit_buffer & (1 << 0)) ? 1 : 0;
1287 0           *decoded = m;
1288 0           return 0;
1289             }
1290             case AMQP_BASIC_RECOVER_METHOD: {
1291 0           amqp_basic_recover_t *m = (amqp_basic_recover_t *)amqp_pool_alloc(
1292             pool, sizeof(amqp_basic_recover_t));
1293 0 0         if (m == NULL) {
1294 0           return AMQP_STATUS_NO_MEMORY;
1295             }
1296 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
1297 0           return AMQP_STATUS_BAD_AMQP_DATA;
1298 0           m->requeue = (bit_buffer & (1 << 0)) ? 1 : 0;
1299 0           *decoded = m;
1300 0           return 0;
1301             }
1302             case AMQP_BASIC_RECOVER_OK_METHOD: {
1303 0           amqp_basic_recover_ok_t *m = (amqp_basic_recover_ok_t *)amqp_pool_alloc(
1304             pool, sizeof(amqp_basic_recover_ok_t));
1305 0 0         if (m == NULL) {
1306 0           return AMQP_STATUS_NO_MEMORY;
1307             }
1308 0           *decoded = m;
1309 0           return 0;
1310             }
1311             case AMQP_BASIC_NACK_METHOD: {
1312 0           amqp_basic_nack_t *m =
1313             (amqp_basic_nack_t *)amqp_pool_alloc(pool, sizeof(amqp_basic_nack_t));
1314 0 0         if (m == NULL) {
1315 0           return AMQP_STATUS_NO_MEMORY;
1316             }
1317 0 0         if (!amqp_decode_64(encoded, &offset, &m->delivery_tag))
1318 0           return AMQP_STATUS_BAD_AMQP_DATA;
1319 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
1320 0           return AMQP_STATUS_BAD_AMQP_DATA;
1321 0           m->multiple = (bit_buffer & (1 << 0)) ? 1 : 0;
1322 0           m->requeue = (bit_buffer & (1 << 1)) ? 1 : 0;
1323 0           *decoded = m;
1324 0           return 0;
1325             }
1326             case AMQP_TX_SELECT_METHOD: {
1327 0           amqp_tx_select_t *m =
1328             (amqp_tx_select_t *)amqp_pool_alloc(pool, sizeof(amqp_tx_select_t));
1329 0 0         if (m == NULL) {
1330 0           return AMQP_STATUS_NO_MEMORY;
1331             }
1332 0           *decoded = m;
1333 0           return 0;
1334             }
1335             case AMQP_TX_SELECT_OK_METHOD: {
1336 1           amqp_tx_select_ok_t *m = (amqp_tx_select_ok_t *)amqp_pool_alloc(
1337             pool, sizeof(amqp_tx_select_ok_t));
1338 1 50         if (m == NULL) {
1339 0           return AMQP_STATUS_NO_MEMORY;
1340             }
1341 1           *decoded = m;
1342 1           return 0;
1343             }
1344             case AMQP_TX_COMMIT_METHOD: {
1345 0           amqp_tx_commit_t *m =
1346             (amqp_tx_commit_t *)amqp_pool_alloc(pool, sizeof(amqp_tx_commit_t));
1347 0 0         if (m == NULL) {
1348 0           return AMQP_STATUS_NO_MEMORY;
1349             }
1350 0           *decoded = m;
1351 0           return 0;
1352             }
1353             case AMQP_TX_COMMIT_OK_METHOD: {
1354 1           amqp_tx_commit_ok_t *m = (amqp_tx_commit_ok_t *)amqp_pool_alloc(
1355             pool, sizeof(amqp_tx_commit_ok_t));
1356 1 50         if (m == NULL) {
1357 0           return AMQP_STATUS_NO_MEMORY;
1358             }
1359 1           *decoded = m;
1360 1           return 0;
1361             }
1362             case AMQP_TX_ROLLBACK_METHOD: {
1363 0           amqp_tx_rollback_t *m = (amqp_tx_rollback_t *)amqp_pool_alloc(
1364             pool, sizeof(amqp_tx_rollback_t));
1365 0 0         if (m == NULL) {
1366 0           return AMQP_STATUS_NO_MEMORY;
1367             }
1368 0           *decoded = m;
1369 0           return 0;
1370             }
1371             case AMQP_TX_ROLLBACK_OK_METHOD: {
1372 1           amqp_tx_rollback_ok_t *m = (amqp_tx_rollback_ok_t *)amqp_pool_alloc(
1373             pool, sizeof(amqp_tx_rollback_ok_t));
1374 1 50         if (m == NULL) {
1375 0           return AMQP_STATUS_NO_MEMORY;
1376             }
1377 1           *decoded = m;
1378 1           return 0;
1379             }
1380             case AMQP_CONFIRM_SELECT_METHOD: {
1381 0           amqp_confirm_select_t *m = (amqp_confirm_select_t *)amqp_pool_alloc(
1382             pool, sizeof(amqp_confirm_select_t));
1383 0 0         if (m == NULL) {
1384 0           return AMQP_STATUS_NO_MEMORY;
1385             }
1386 0 0         if (!amqp_decode_8(encoded, &offset, &bit_buffer))
1387 0           return AMQP_STATUS_BAD_AMQP_DATA;
1388 0           m->nowait = (bit_buffer & (1 << 0)) ? 1 : 0;
1389 0           *decoded = m;
1390 0           return 0;
1391             }
1392             case AMQP_CONFIRM_SELECT_OK_METHOD: {
1393 0           amqp_confirm_select_ok_t *m = (amqp_confirm_select_ok_t *)amqp_pool_alloc(
1394             pool, sizeof(amqp_confirm_select_ok_t));
1395 0 0         if (m == NULL) {
1396 0           return AMQP_STATUS_NO_MEMORY;
1397             }
1398 0           *decoded = m;
1399 0           return 0;
1400             }
1401             default:
1402 396           return AMQP_STATUS_UNKNOWN_METHOD;
1403             }
1404             }
1405              
1406 25           int amqp_decode_properties(uint16_t class_id, amqp_pool_t *pool,
1407             amqp_bytes_t encoded, void **decoded) {
1408 25           size_t offset = 0;
1409              
1410 25           amqp_flags_t flags = 0;
1411 25           int flagword_index = 0;
1412             uint16_t partial_flags;
1413              
1414             do {
1415 25 50         if (!amqp_decode_16(encoded, &offset, &partial_flags))
1416 0           return AMQP_STATUS_BAD_AMQP_DATA;
1417 25           flags |= (partial_flags << (flagword_index * 16));
1418 25           flagword_index++;
1419 25 50         } while (partial_flags & 1);
1420              
1421 25           switch (class_id) {
1422             case 10: {
1423 0           amqp_connection_properties_t *p =
1424             (amqp_connection_properties_t *)amqp_pool_alloc(
1425             pool, sizeof(amqp_connection_properties_t));
1426 0 0         if (p == NULL) {
1427 0           return AMQP_STATUS_NO_MEMORY;
1428             }
1429 0           p->_flags = flags;
1430 0           *decoded = p;
1431 0           return 0;
1432             }
1433             case 20: {
1434 0           amqp_channel_properties_t *p =
1435             (amqp_channel_properties_t *)amqp_pool_alloc(
1436             pool, sizeof(amqp_channel_properties_t));
1437 0 0         if (p == NULL) {
1438 0           return AMQP_STATUS_NO_MEMORY;
1439             }
1440 0           p->_flags = flags;
1441 0           *decoded = p;
1442 0           return 0;
1443             }
1444             case 30: {
1445 0           amqp_access_properties_t *p = (amqp_access_properties_t *)amqp_pool_alloc(
1446             pool, sizeof(amqp_access_properties_t));
1447 0 0         if (p == NULL) {
1448 0           return AMQP_STATUS_NO_MEMORY;
1449             }
1450 0           p->_flags = flags;
1451 0           *decoded = p;
1452 0           return 0;
1453             }
1454             case 40: {
1455 0           amqp_exchange_properties_t *p =
1456             (amqp_exchange_properties_t *)amqp_pool_alloc(
1457             pool, sizeof(amqp_exchange_properties_t));
1458 0 0         if (p == NULL) {
1459 0           return AMQP_STATUS_NO_MEMORY;
1460             }
1461 0           p->_flags = flags;
1462 0           *decoded = p;
1463 0           return 0;
1464             }
1465             case 50: {
1466 0           amqp_queue_properties_t *p = (amqp_queue_properties_t *)amqp_pool_alloc(
1467             pool, sizeof(amqp_queue_properties_t));
1468 0 0         if (p == NULL) {
1469 0           return AMQP_STATUS_NO_MEMORY;
1470             }
1471 0           p->_flags = flags;
1472 0           *decoded = p;
1473 0           return 0;
1474             }
1475             case 60: {
1476 25           amqp_basic_properties_t *p = (amqp_basic_properties_t *)amqp_pool_alloc(
1477             pool, sizeof(amqp_basic_properties_t));
1478 25 50         if (p == NULL) {
1479 0           return AMQP_STATUS_NO_MEMORY;
1480             }
1481 25           p->_flags = flags;
1482 25 100         if (flags & AMQP_BASIC_CONTENT_TYPE_FLAG) {
1483             {
1484             uint8_t len;
1485 8           if (!amqp_decode_8(encoded, &offset, &len) ||
1486 4           !amqp_decode_bytes(encoded, &offset, &p->content_type, len))
1487 4           return AMQP_STATUS_BAD_AMQP_DATA;
1488             }
1489             }
1490 25 100         if (flags & AMQP_BASIC_CONTENT_ENCODING_FLAG) {
1491             {
1492             uint8_t len;
1493 14           if (!amqp_decode_8(encoded, &offset, &len) ||
1494 7           !amqp_decode_bytes(encoded, &offset, &p->content_encoding, len))
1495 7           return AMQP_STATUS_BAD_AMQP_DATA;
1496             }
1497             }
1498 25 100         if (flags & AMQP_BASIC_HEADERS_FLAG) {
1499             {
1500 9           int res = amqp_decode_table(encoded, pool, &(p->headers), &offset);
1501 9 50         if (res < 0) return res;
1502             }
1503             }
1504 25 100         if (flags & AMQP_BASIC_DELIVERY_MODE_FLAG) {
1505 4 50         if (!amqp_decode_8(encoded, &offset, &p->delivery_mode))
1506 0           return AMQP_STATUS_BAD_AMQP_DATA;
1507             }
1508 25 100         if (flags & AMQP_BASIC_PRIORITY_FLAG) {
1509 4 50         if (!amqp_decode_8(encoded, &offset, &p->priority))
1510 0           return AMQP_STATUS_BAD_AMQP_DATA;
1511             }
1512 25 100         if (flags & AMQP_BASIC_CORRELATION_ID_FLAG) {
1513             {
1514             uint8_t len;
1515 8           if (!amqp_decode_8(encoded, &offset, &len) ||
1516 4           !amqp_decode_bytes(encoded, &offset, &p->correlation_id, len))
1517 4           return AMQP_STATUS_BAD_AMQP_DATA;
1518             }
1519             }
1520 25 100         if (flags & AMQP_BASIC_REPLY_TO_FLAG) {
1521             {
1522             uint8_t len;
1523 8           if (!amqp_decode_8(encoded, &offset, &len) ||
1524 4           !amqp_decode_bytes(encoded, &offset, &p->reply_to, len))
1525 4           return AMQP_STATUS_BAD_AMQP_DATA;
1526             }
1527             }
1528 25 100         if (flags & AMQP_BASIC_EXPIRATION_FLAG) {
1529             {
1530             uint8_t len;
1531 8           if (!amqp_decode_8(encoded, &offset, &len) ||
1532 4           !amqp_decode_bytes(encoded, &offset, &p->expiration, len))
1533 4           return AMQP_STATUS_BAD_AMQP_DATA;
1534             }
1535             }
1536 25 100         if (flags & AMQP_BASIC_MESSAGE_ID_FLAG) {
1537             {
1538             uint8_t len;
1539 8           if (!amqp_decode_8(encoded, &offset, &len) ||
1540 4           !amqp_decode_bytes(encoded, &offset, &p->message_id, len))
1541 4           return AMQP_STATUS_BAD_AMQP_DATA;
1542             }
1543             }
1544 25 100         if (flags & AMQP_BASIC_TIMESTAMP_FLAG) {
1545 4 50         if (!amqp_decode_64(encoded, &offset, &p->timestamp))
1546 0           return AMQP_STATUS_BAD_AMQP_DATA;
1547             }
1548 25 100         if (flags & AMQP_BASIC_TYPE_FLAG) {
1549             {
1550             uint8_t len;
1551 8           if (!amqp_decode_8(encoded, &offset, &len) ||
1552 4           !amqp_decode_bytes(encoded, &offset, &p->type, len))
1553 4           return AMQP_STATUS_BAD_AMQP_DATA;
1554             }
1555             }
1556 25 100         if (flags & AMQP_BASIC_USER_ID_FLAG) {
1557             {
1558             uint8_t len;
1559 8           if (!amqp_decode_8(encoded, &offset, &len) ||
1560 4           !amqp_decode_bytes(encoded, &offset, &p->user_id, len))
1561 4           return AMQP_STATUS_BAD_AMQP_DATA;
1562             }
1563             }
1564 25 100         if (flags & AMQP_BASIC_APP_ID_FLAG) {
1565             {
1566             uint8_t len;
1567 8           if (!amqp_decode_8(encoded, &offset, &len) ||
1568 4           !amqp_decode_bytes(encoded, &offset, &p->app_id, len))
1569 4           return AMQP_STATUS_BAD_AMQP_DATA;
1570             }
1571             }
1572 25 50         if (flags & AMQP_BASIC_CLUSTER_ID_FLAG) {
1573             {
1574             uint8_t len;
1575 0           if (!amqp_decode_8(encoded, &offset, &len) ||
1576 0           !amqp_decode_bytes(encoded, &offset, &p->cluster_id, len))
1577 0           return AMQP_STATUS_BAD_AMQP_DATA;
1578             }
1579             }
1580 25           *decoded = p;
1581 25           return 0;
1582             }
1583             case 90: {
1584 0           amqp_tx_properties_t *p = (amqp_tx_properties_t *)amqp_pool_alloc(
1585             pool, sizeof(amqp_tx_properties_t));
1586 0 0         if (p == NULL) {
1587 0           return AMQP_STATUS_NO_MEMORY;
1588             }
1589 0           p->_flags = flags;
1590 0           *decoded = p;
1591 0           return 0;
1592             }
1593             case 85: {
1594 0           amqp_confirm_properties_t *p =
1595             (amqp_confirm_properties_t *)amqp_pool_alloc(
1596             pool, sizeof(amqp_confirm_properties_t));
1597 0 0         if (p == NULL) {
1598 0           return AMQP_STATUS_NO_MEMORY;
1599             }
1600 0           p->_flags = flags;
1601 0           *decoded = p;
1602 0           return 0;
1603             }
1604             default:
1605 25           return AMQP_STATUS_UNKNOWN_CLASS;
1606             }
1607             }
1608              
1609 409           int amqp_encode_method(amqp_method_number_t methodNumber, void *decoded,
1610             amqp_bytes_t encoded) {
1611 409           size_t offset = 0;
1612             uint8_t bit_buffer;
1613              
1614 409           switch (methodNumber) {
1615             case AMQP_CONNECTION_START_METHOD: {
1616 0           amqp_connection_start_t *m = (amqp_connection_start_t *)decoded;
1617 0 0         if (!amqp_encode_8(encoded, &offset, m->version_major))
1618 0           return AMQP_STATUS_BAD_AMQP_DATA;
1619 0 0         if (!amqp_encode_8(encoded, &offset, m->version_minor))
1620 0           return AMQP_STATUS_BAD_AMQP_DATA;
1621             {
1622 0           int res = amqp_encode_table(encoded, &(m->server_properties), &offset);
1623 0 0         if (res < 0) return res;
1624             }
1625 0           if (UINT32_MAX < m->mechanisms.len ||
1626 0 0         !amqp_encode_32(encoded, &offset, (uint32_t)m->mechanisms.len) ||
1627 0           !amqp_encode_bytes(encoded, &offset, m->mechanisms))
1628 0           return AMQP_STATUS_BAD_AMQP_DATA;
1629 0           if (UINT32_MAX < m->locales.len ||
1630 0 0         !amqp_encode_32(encoded, &offset, (uint32_t)m->locales.len) ||
1631 0           !amqp_encode_bytes(encoded, &offset, m->locales))
1632 0           return AMQP_STATUS_BAD_AMQP_DATA;
1633 0           return (int)offset;
1634             }
1635             case AMQP_CONNECTION_START_OK_METHOD: {
1636 37           amqp_connection_start_ok_t *m = (amqp_connection_start_ok_t *)decoded;
1637             {
1638 37           int res = amqp_encode_table(encoded, &(m->client_properties), &offset);
1639 37 50         if (res < 0) return res;
1640             }
1641 74           if (UINT8_MAX < m->mechanism.len ||
1642 74 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->mechanism.len) ||
1643 37           !amqp_encode_bytes(encoded, &offset, m->mechanism))
1644 0           return AMQP_STATUS_BAD_AMQP_DATA;
1645 74           if (UINT32_MAX < m->response.len ||
1646 74 50         !amqp_encode_32(encoded, &offset, (uint32_t)m->response.len) ||
1647 37           !amqp_encode_bytes(encoded, &offset, m->response))
1648 0           return AMQP_STATUS_BAD_AMQP_DATA;
1649 74           if (UINT8_MAX < m->locale.len ||
1650 74 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->locale.len) ||
1651 37           !amqp_encode_bytes(encoded, &offset, m->locale))
1652 0           return AMQP_STATUS_BAD_AMQP_DATA;
1653 37           return (int)offset;
1654             }
1655             case AMQP_CONNECTION_SECURE_METHOD: {
1656 0           amqp_connection_secure_t *m = (amqp_connection_secure_t *)decoded;
1657 0           if (UINT32_MAX < m->challenge.len ||
1658 0 0         !amqp_encode_32(encoded, &offset, (uint32_t)m->challenge.len) ||
1659 0           !amqp_encode_bytes(encoded, &offset, m->challenge))
1660 0           return AMQP_STATUS_BAD_AMQP_DATA;
1661 0           return (int)offset;
1662             }
1663             case AMQP_CONNECTION_SECURE_OK_METHOD: {
1664 0           amqp_connection_secure_ok_t *m = (amqp_connection_secure_ok_t *)decoded;
1665 0           if (UINT32_MAX < m->response.len ||
1666 0 0         !amqp_encode_32(encoded, &offset, (uint32_t)m->response.len) ||
1667 0           !amqp_encode_bytes(encoded, &offset, m->response))
1668 0           return AMQP_STATUS_BAD_AMQP_DATA;
1669 0           return (int)offset;
1670             }
1671             case AMQP_CONNECTION_TUNE_METHOD: {
1672 0           amqp_connection_tune_t *m = (amqp_connection_tune_t *)decoded;
1673 0 0         if (!amqp_encode_16(encoded, &offset, m->channel_max))
1674 0           return AMQP_STATUS_BAD_AMQP_DATA;
1675 0 0         if (!amqp_encode_32(encoded, &offset, m->frame_max))
1676 0           return AMQP_STATUS_BAD_AMQP_DATA;
1677 0 0         if (!amqp_encode_16(encoded, &offset, m->heartbeat))
1678 0           return AMQP_STATUS_BAD_AMQP_DATA;
1679 0           return (int)offset;
1680             }
1681             case AMQP_CONNECTION_TUNE_OK_METHOD: {
1682 37           amqp_connection_tune_ok_t *m = (amqp_connection_tune_ok_t *)decoded;
1683 37 50         if (!amqp_encode_16(encoded, &offset, m->channel_max))
1684 0           return AMQP_STATUS_BAD_AMQP_DATA;
1685 37 50         if (!amqp_encode_32(encoded, &offset, m->frame_max))
1686 0           return AMQP_STATUS_BAD_AMQP_DATA;
1687 37 50         if (!amqp_encode_16(encoded, &offset, m->heartbeat))
1688 0           return AMQP_STATUS_BAD_AMQP_DATA;
1689 37           return (int)offset;
1690             }
1691             case AMQP_CONNECTION_OPEN_METHOD: {
1692 37           amqp_connection_open_t *m = (amqp_connection_open_t *)decoded;
1693 74           if (UINT8_MAX < m->virtual_host.len ||
1694 74 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->virtual_host.len) ||
1695 37           !amqp_encode_bytes(encoded, &offset, m->virtual_host))
1696 0           return AMQP_STATUS_BAD_AMQP_DATA;
1697 74           if (UINT8_MAX < m->capabilities.len ||
1698 74 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->capabilities.len) ||
1699 37           !amqp_encode_bytes(encoded, &offset, m->capabilities))
1700 0           return AMQP_STATUS_BAD_AMQP_DATA;
1701 37           bit_buffer = 0;
1702 37 50         if (m->insist) bit_buffer |= (1 << 0);
1703 37 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
1704 0           return AMQP_STATUS_BAD_AMQP_DATA;
1705 37           return (int)offset;
1706             }
1707             case AMQP_CONNECTION_OPEN_OK_METHOD: {
1708 0           amqp_connection_open_ok_t *m = (amqp_connection_open_ok_t *)decoded;
1709 0           if (UINT8_MAX < m->known_hosts.len ||
1710 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->known_hosts.len) ||
1711 0           !amqp_encode_bytes(encoded, &offset, m->known_hosts))
1712 0           return AMQP_STATUS_BAD_AMQP_DATA;
1713 0           return (int)offset;
1714             }
1715             case AMQP_CONNECTION_CLOSE_METHOD: {
1716 31           amqp_connection_close_t *m = (amqp_connection_close_t *)decoded;
1717 31 50         if (!amqp_encode_16(encoded, &offset, m->reply_code))
1718 0           return AMQP_STATUS_BAD_AMQP_DATA;
1719 62           if (UINT8_MAX < m->reply_text.len ||
1720 62 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->reply_text.len) ||
1721 31           !amqp_encode_bytes(encoded, &offset, m->reply_text))
1722 0           return AMQP_STATUS_BAD_AMQP_DATA;
1723 31 50         if (!amqp_encode_16(encoded, &offset, m->class_id))
1724 0           return AMQP_STATUS_BAD_AMQP_DATA;
1725 31 50         if (!amqp_encode_16(encoded, &offset, m->method_id))
1726 0           return AMQP_STATUS_BAD_AMQP_DATA;
1727 31           return (int)offset;
1728             }
1729             case AMQP_CONNECTION_CLOSE_OK_METHOD: {
1730 0           return (int)offset;
1731             }
1732             case AMQP_CONNECTION_BLOCKED_METHOD: {
1733 0           amqp_connection_blocked_t *m = (amqp_connection_blocked_t *)decoded;
1734 0           if (UINT8_MAX < m->reason.len ||
1735 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->reason.len) ||
1736 0           !amqp_encode_bytes(encoded, &offset, m->reason))
1737 0           return AMQP_STATUS_BAD_AMQP_DATA;
1738 0           return (int)offset;
1739             }
1740             case AMQP_CONNECTION_UNBLOCKED_METHOD: {
1741 0           return (int)offset;
1742             }
1743             case AMQP_CHANNEL_OPEN_METHOD: {
1744 36           amqp_channel_open_t *m = (amqp_channel_open_t *)decoded;
1745 72           if (UINT8_MAX < m->out_of_band.len ||
1746 72 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->out_of_band.len) ||
1747 36           !amqp_encode_bytes(encoded, &offset, m->out_of_band))
1748 0           return AMQP_STATUS_BAD_AMQP_DATA;
1749 36           return (int)offset;
1750             }
1751             case AMQP_CHANNEL_OPEN_OK_METHOD: {
1752 0           amqp_channel_open_ok_t *m = (amqp_channel_open_ok_t *)decoded;
1753 0           if (UINT32_MAX < m->channel_id.len ||
1754 0 0         !amqp_encode_32(encoded, &offset, (uint32_t)m->channel_id.len) ||
1755 0           !amqp_encode_bytes(encoded, &offset, m->channel_id))
1756 0           return AMQP_STATUS_BAD_AMQP_DATA;
1757 0           return (int)offset;
1758             }
1759             case AMQP_CHANNEL_FLOW_METHOD: {
1760 0           amqp_channel_flow_t *m = (amqp_channel_flow_t *)decoded;
1761 0           bit_buffer = 0;
1762 0 0         if (m->active) bit_buffer |= (1 << 0);
1763 0 0         if (!amqp_encode_8(encoded, &offset, bit_buffer))
1764 0           return AMQP_STATUS_BAD_AMQP_DATA;
1765 0           return (int)offset;
1766             }
1767             case AMQP_CHANNEL_FLOW_OK_METHOD: {
1768 0           amqp_channel_flow_ok_t *m = (amqp_channel_flow_ok_t *)decoded;
1769 0           bit_buffer = 0;
1770 0 0         if (m->active) bit_buffer |= (1 << 0);
1771 0 0         if (!amqp_encode_8(encoded, &offset, bit_buffer))
1772 0           return AMQP_STATUS_BAD_AMQP_DATA;
1773 0           return (int)offset;
1774             }
1775             case AMQP_CHANNEL_CLOSE_METHOD: {
1776 1           amqp_channel_close_t *m = (amqp_channel_close_t *)decoded;
1777 1 50         if (!amqp_encode_16(encoded, &offset, m->reply_code))
1778 0           return AMQP_STATUS_BAD_AMQP_DATA;
1779 2           if (UINT8_MAX < m->reply_text.len ||
1780 2 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->reply_text.len) ||
1781 1           !amqp_encode_bytes(encoded, &offset, m->reply_text))
1782 0           return AMQP_STATUS_BAD_AMQP_DATA;
1783 1 50         if (!amqp_encode_16(encoded, &offset, m->class_id))
1784 0           return AMQP_STATUS_BAD_AMQP_DATA;
1785 1 50         if (!amqp_encode_16(encoded, &offset, m->method_id))
1786 0           return AMQP_STATUS_BAD_AMQP_DATA;
1787 1           return (int)offset;
1788             }
1789             case AMQP_CHANNEL_CLOSE_OK_METHOD: {
1790 0           return (int)offset;
1791             }
1792             case AMQP_ACCESS_REQUEST_METHOD: {
1793 0           amqp_access_request_t *m = (amqp_access_request_t *)decoded;
1794 0           if (UINT8_MAX < m->realm.len ||
1795 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->realm.len) ||
1796 0           !amqp_encode_bytes(encoded, &offset, m->realm))
1797 0           return AMQP_STATUS_BAD_AMQP_DATA;
1798 0           bit_buffer = 0;
1799 0 0         if (m->exclusive) bit_buffer |= (1 << 0);
1800 0 0         if (m->passive) bit_buffer |= (1 << 1);
1801 0 0         if (m->active) bit_buffer |= (1 << 2);
1802 0 0         if (m->write) bit_buffer |= (1 << 3);
1803 0 0         if (m->read) bit_buffer |= (1 << 4);
1804 0 0         if (!amqp_encode_8(encoded, &offset, bit_buffer))
1805 0           return AMQP_STATUS_BAD_AMQP_DATA;
1806 0           return (int)offset;
1807             }
1808             case AMQP_ACCESS_REQUEST_OK_METHOD: {
1809 0           amqp_access_request_ok_t *m = (amqp_access_request_ok_t *)decoded;
1810 0 0         if (!amqp_encode_16(encoded, &offset, m->ticket))
1811 0           return AMQP_STATUS_BAD_AMQP_DATA;
1812 0           return (int)offset;
1813             }
1814             case AMQP_EXCHANGE_DECLARE_METHOD: {
1815 26           amqp_exchange_declare_t *m = (amqp_exchange_declare_t *)decoded;
1816 26 50         if (!amqp_encode_16(encoded, &offset, m->ticket))
1817 0           return AMQP_STATUS_BAD_AMQP_DATA;
1818 52           if (UINT8_MAX < m->exchange.len ||
1819 52 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) ||
1820 26           !amqp_encode_bytes(encoded, &offset, m->exchange))
1821 0           return AMQP_STATUS_BAD_AMQP_DATA;
1822 52           if (UINT8_MAX < m->type.len ||
1823 52 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->type.len) ||
1824 26           !amqp_encode_bytes(encoded, &offset, m->type))
1825 0           return AMQP_STATUS_BAD_AMQP_DATA;
1826 26           bit_buffer = 0;
1827 26 50         if (m->passive) bit_buffer |= (1 << 0);
1828 26 100         if (m->durable) bit_buffer |= (1 << 1);
1829 26 100         if (m->auto_delete) bit_buffer |= (1 << 2);
1830 26 100         if (m->internal) bit_buffer |= (1 << 3);
1831 26 50         if (m->nowait) bit_buffer |= (1 << 4);
1832 26 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
1833 0           return AMQP_STATUS_BAD_AMQP_DATA;
1834             {
1835 26           int res = amqp_encode_table(encoded, &(m->arguments), &offset);
1836 26 50         if (res < 0) return res;
1837             }
1838 26           return (int)offset;
1839             }
1840             case AMQP_EXCHANGE_DECLARE_OK_METHOD: {
1841 0           return (int)offset;
1842             }
1843             case AMQP_EXCHANGE_DELETE_METHOD: {
1844 27           amqp_exchange_delete_t *m = (amqp_exchange_delete_t *)decoded;
1845 27 50         if (!amqp_encode_16(encoded, &offset, m->ticket))
1846 0           return AMQP_STATUS_BAD_AMQP_DATA;
1847 54           if (UINT8_MAX < m->exchange.len ||
1848 54 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) ||
1849 27           !amqp_encode_bytes(encoded, &offset, m->exchange))
1850 0           return AMQP_STATUS_BAD_AMQP_DATA;
1851 27           bit_buffer = 0;
1852 27 50         if (m->if_unused) bit_buffer |= (1 << 0);
1853 27 50         if (m->nowait) bit_buffer |= (1 << 1);
1854 27 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
1855 0           return AMQP_STATUS_BAD_AMQP_DATA;
1856 27           return (int)offset;
1857             }
1858             case AMQP_EXCHANGE_DELETE_OK_METHOD: {
1859 0           return (int)offset;
1860             }
1861             case AMQP_EXCHANGE_BIND_METHOD: {
1862 1           amqp_exchange_bind_t *m = (amqp_exchange_bind_t *)decoded;
1863 1 50         if (!amqp_encode_16(encoded, &offset, m->ticket))
1864 0           return AMQP_STATUS_BAD_AMQP_DATA;
1865 2           if (UINT8_MAX < m->destination.len ||
1866 2 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->destination.len) ||
1867 1           !amqp_encode_bytes(encoded, &offset, m->destination))
1868 0           return AMQP_STATUS_BAD_AMQP_DATA;
1869 2           if (UINT8_MAX < m->source.len ||
1870 2 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->source.len) ||
1871 1           !amqp_encode_bytes(encoded, &offset, m->source))
1872 0           return AMQP_STATUS_BAD_AMQP_DATA;
1873 2           if (UINT8_MAX < m->routing_key.len ||
1874 2 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) ||
1875 1           !amqp_encode_bytes(encoded, &offset, m->routing_key))
1876 0           return AMQP_STATUS_BAD_AMQP_DATA;
1877 1           bit_buffer = 0;
1878 1 50         if (m->nowait) bit_buffer |= (1 << 0);
1879 1 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
1880 0           return AMQP_STATUS_BAD_AMQP_DATA;
1881             {
1882 1           int res = amqp_encode_table(encoded, &(m->arguments), &offset);
1883 1 50         if (res < 0) return res;
1884             }
1885 1           return (int)offset;
1886             }
1887             case AMQP_EXCHANGE_BIND_OK_METHOD: {
1888 0           return (int)offset;
1889             }
1890             case AMQP_EXCHANGE_UNBIND_METHOD: {
1891 1           amqp_exchange_unbind_t *m = (amqp_exchange_unbind_t *)decoded;
1892 1 50         if (!amqp_encode_16(encoded, &offset, m->ticket))
1893 0           return AMQP_STATUS_BAD_AMQP_DATA;
1894 2           if (UINT8_MAX < m->destination.len ||
1895 2 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->destination.len) ||
1896 1           !amqp_encode_bytes(encoded, &offset, m->destination))
1897 0           return AMQP_STATUS_BAD_AMQP_DATA;
1898 2           if (UINT8_MAX < m->source.len ||
1899 2 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->source.len) ||
1900 1           !amqp_encode_bytes(encoded, &offset, m->source))
1901 0           return AMQP_STATUS_BAD_AMQP_DATA;
1902 2           if (UINT8_MAX < m->routing_key.len ||
1903 2 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) ||
1904 1           !amqp_encode_bytes(encoded, &offset, m->routing_key))
1905 0           return AMQP_STATUS_BAD_AMQP_DATA;
1906 1           bit_buffer = 0;
1907 1 50         if (m->nowait) bit_buffer |= (1 << 0);
1908 1 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
1909 0           return AMQP_STATUS_BAD_AMQP_DATA;
1910             {
1911 1           int res = amqp_encode_table(encoded, &(m->arguments), &offset);
1912 1 50         if (res < 0) return res;
1913             }
1914 1           return (int)offset;
1915             }
1916             case AMQP_EXCHANGE_UNBIND_OK_METHOD: {
1917 0           return (int)offset;
1918             }
1919             case AMQP_QUEUE_DECLARE_METHOD: {
1920 20           amqp_queue_declare_t *m = (amqp_queue_declare_t *)decoded;
1921 20 50         if (!amqp_encode_16(encoded, &offset, m->ticket))
1922 0           return AMQP_STATUS_BAD_AMQP_DATA;
1923 40           if (UINT8_MAX < m->queue.len ||
1924 40 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) ||
1925 20           !amqp_encode_bytes(encoded, &offset, m->queue))
1926 0           return AMQP_STATUS_BAD_AMQP_DATA;
1927 20           bit_buffer = 0;
1928 20 50         if (m->passive) bit_buffer |= (1 << 0);
1929 20 100         if (m->durable) bit_buffer |= (1 << 1);
1930 20 50         if (m->exclusive) bit_buffer |= (1 << 2);
1931 20 100         if (m->auto_delete) bit_buffer |= (1 << 3);
1932 20 50         if (m->nowait) bit_buffer |= (1 << 4);
1933 20 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
1934 0           return AMQP_STATUS_BAD_AMQP_DATA;
1935             {
1936 20           int res = amqp_encode_table(encoded, &(m->arguments), &offset);
1937 20 50         if (res < 0) return res;
1938             }
1939 20           return (int)offset;
1940             }
1941             case AMQP_QUEUE_DECLARE_OK_METHOD: {
1942 0           amqp_queue_declare_ok_t *m = (amqp_queue_declare_ok_t *)decoded;
1943 0           if (UINT8_MAX < m->queue.len ||
1944 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) ||
1945 0           !amqp_encode_bytes(encoded, &offset, m->queue))
1946 0           return AMQP_STATUS_BAD_AMQP_DATA;
1947 0 0         if (!amqp_encode_32(encoded, &offset, m->message_count))
1948 0           return AMQP_STATUS_BAD_AMQP_DATA;
1949 0 0         if (!amqp_encode_32(encoded, &offset, m->consumer_count))
1950 0           return AMQP_STATUS_BAD_AMQP_DATA;
1951 0           return (int)offset;
1952             }
1953             case AMQP_QUEUE_BIND_METHOD: {
1954 18           amqp_queue_bind_t *m = (amqp_queue_bind_t *)decoded;
1955 18 50         if (!amqp_encode_16(encoded, &offset, m->ticket))
1956 0           return AMQP_STATUS_BAD_AMQP_DATA;
1957 36           if (UINT8_MAX < m->queue.len ||
1958 36 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) ||
1959 18           !amqp_encode_bytes(encoded, &offset, m->queue))
1960 0           return AMQP_STATUS_BAD_AMQP_DATA;
1961 36           if (UINT8_MAX < m->exchange.len ||
1962 36 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) ||
1963 18           !amqp_encode_bytes(encoded, &offset, m->exchange))
1964 0           return AMQP_STATUS_BAD_AMQP_DATA;
1965 36           if (UINT8_MAX < m->routing_key.len ||
1966 36 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) ||
1967 18           !amqp_encode_bytes(encoded, &offset, m->routing_key))
1968 0           return AMQP_STATUS_BAD_AMQP_DATA;
1969 18           bit_buffer = 0;
1970 18 50         if (m->nowait) bit_buffer |= (1 << 0);
1971 18 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
1972 0           return AMQP_STATUS_BAD_AMQP_DATA;
1973             {
1974 18           int res = amqp_encode_table(encoded, &(m->arguments), &offset);
1975 18 50         if (res < 0) return res;
1976             }
1977 18           return (int)offset;
1978             }
1979             case AMQP_QUEUE_BIND_OK_METHOD: {
1980 0           return (int)offset;
1981             }
1982             case AMQP_QUEUE_PURGE_METHOD: {
1983 19           amqp_queue_purge_t *m = (amqp_queue_purge_t *)decoded;
1984 19 50         if (!amqp_encode_16(encoded, &offset, m->ticket))
1985 0           return AMQP_STATUS_BAD_AMQP_DATA;
1986 38           if (UINT8_MAX < m->queue.len ||
1987 38 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) ||
1988 19           !amqp_encode_bytes(encoded, &offset, m->queue))
1989 0           return AMQP_STATUS_BAD_AMQP_DATA;
1990 19           bit_buffer = 0;
1991 19 50         if (m->nowait) bit_buffer |= (1 << 0);
1992 19 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
1993 0           return AMQP_STATUS_BAD_AMQP_DATA;
1994 19           return (int)offset;
1995             }
1996             case AMQP_QUEUE_PURGE_OK_METHOD: {
1997 0           amqp_queue_purge_ok_t *m = (amqp_queue_purge_ok_t *)decoded;
1998 0 0         if (!amqp_encode_32(encoded, &offset, m->message_count))
1999 0           return AMQP_STATUS_BAD_AMQP_DATA;
2000 0           return (int)offset;
2001             }
2002             case AMQP_QUEUE_DELETE_METHOD: {
2003 20           amqp_queue_delete_t *m = (amqp_queue_delete_t *)decoded;
2004 20 50         if (!amqp_encode_16(encoded, &offset, m->ticket))
2005 0           return AMQP_STATUS_BAD_AMQP_DATA;
2006 40           if (UINT8_MAX < m->queue.len ||
2007 40 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) ||
2008 20           !amqp_encode_bytes(encoded, &offset, m->queue))
2009 0           return AMQP_STATUS_BAD_AMQP_DATA;
2010 20           bit_buffer = 0;
2011 20 50         if (m->if_unused) bit_buffer |= (1 << 0);
2012 20 50         if (m->if_empty) bit_buffer |= (1 << 1);
2013 20 50         if (m->nowait) bit_buffer |= (1 << 2);
2014 20 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2015 0           return AMQP_STATUS_BAD_AMQP_DATA;
2016 20           return (int)offset;
2017             }
2018             case AMQP_QUEUE_DELETE_OK_METHOD: {
2019 0           amqp_queue_delete_ok_t *m = (amqp_queue_delete_ok_t *)decoded;
2020 0 0         if (!amqp_encode_32(encoded, &offset, m->message_count))
2021 0           return AMQP_STATUS_BAD_AMQP_DATA;
2022 0           return (int)offset;
2023             }
2024             case AMQP_QUEUE_UNBIND_METHOD: {
2025 21           amqp_queue_unbind_t *m = (amqp_queue_unbind_t *)decoded;
2026 21 50         if (!amqp_encode_16(encoded, &offset, m->ticket))
2027 0           return AMQP_STATUS_BAD_AMQP_DATA;
2028 42           if (UINT8_MAX < m->queue.len ||
2029 42 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) ||
2030 21           !amqp_encode_bytes(encoded, &offset, m->queue))
2031 0           return AMQP_STATUS_BAD_AMQP_DATA;
2032 42           if (UINT8_MAX < m->exchange.len ||
2033 42 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) ||
2034 21           !amqp_encode_bytes(encoded, &offset, m->exchange))
2035 0           return AMQP_STATUS_BAD_AMQP_DATA;
2036 42           if (UINT8_MAX < m->routing_key.len ||
2037 42 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) ||
2038 21           !amqp_encode_bytes(encoded, &offset, m->routing_key))
2039 0           return AMQP_STATUS_BAD_AMQP_DATA;
2040             {
2041 21           int res = amqp_encode_table(encoded, &(m->arguments), &offset);
2042 21 50         if (res < 0) return res;
2043             }
2044 21           return (int)offset;
2045             }
2046             case AMQP_QUEUE_UNBIND_OK_METHOD: {
2047 0           return (int)offset;
2048             }
2049             case AMQP_BASIC_QOS_METHOD: {
2050 1           amqp_basic_qos_t *m = (amqp_basic_qos_t *)decoded;
2051 1 50         if (!amqp_encode_32(encoded, &offset, m->prefetch_size))
2052 0           return AMQP_STATUS_BAD_AMQP_DATA;
2053 1 50         if (!amqp_encode_16(encoded, &offset, m->prefetch_count))
2054 0           return AMQP_STATUS_BAD_AMQP_DATA;
2055 1           bit_buffer = 0;
2056 1 50         if (m->global) bit_buffer |= (1 << 0);
2057 1 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2058 0           return AMQP_STATUS_BAD_AMQP_DATA;
2059 1           return (int)offset;
2060             }
2061             case AMQP_BASIC_QOS_OK_METHOD: {
2062 0           return (int)offset;
2063             }
2064             case AMQP_BASIC_CONSUME_METHOD: {
2065 16           amqp_basic_consume_t *m = (amqp_basic_consume_t *)decoded;
2066 16 50         if (!amqp_encode_16(encoded, &offset, m->ticket))
2067 0           return AMQP_STATUS_BAD_AMQP_DATA;
2068 32           if (UINT8_MAX < m->queue.len ||
2069 32 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) ||
2070 16           !amqp_encode_bytes(encoded, &offset, m->queue))
2071 0           return AMQP_STATUS_BAD_AMQP_DATA;
2072 32           if (UINT8_MAX < m->consumer_tag.len ||
2073 32 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) ||
2074 16           !amqp_encode_bytes(encoded, &offset, m->consumer_tag))
2075 0           return AMQP_STATUS_BAD_AMQP_DATA;
2076 16           bit_buffer = 0;
2077 16 50         if (m->no_local) bit_buffer |= (1 << 0);
2078 16 100         if (m->no_ack) bit_buffer |= (1 << 1);
2079 16 50         if (m->exclusive) bit_buffer |= (1 << 2);
2080 16 50         if (m->nowait) bit_buffer |= (1 << 3);
2081 16 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2082 0           return AMQP_STATUS_BAD_AMQP_DATA;
2083             {
2084 16           int res = amqp_encode_table(encoded, &(m->arguments), &offset);
2085 16 50         if (res < 0) return res;
2086             }
2087 16           return (int)offset;
2088             }
2089             case AMQP_BASIC_CONSUME_OK_METHOD: {
2090 0           amqp_basic_consume_ok_t *m = (amqp_basic_consume_ok_t *)decoded;
2091 0           if (UINT8_MAX < m->consumer_tag.len ||
2092 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) ||
2093 0           !amqp_encode_bytes(encoded, &offset, m->consumer_tag))
2094 0           return AMQP_STATUS_BAD_AMQP_DATA;
2095 0           return (int)offset;
2096             }
2097             case AMQP_BASIC_CANCEL_METHOD: {
2098 2           amqp_basic_cancel_t *m = (amqp_basic_cancel_t *)decoded;
2099 4           if (UINT8_MAX < m->consumer_tag.len ||
2100 4 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) ||
2101 2           !amqp_encode_bytes(encoded, &offset, m->consumer_tag))
2102 0           return AMQP_STATUS_BAD_AMQP_DATA;
2103 2           bit_buffer = 0;
2104 2 50         if (m->nowait) bit_buffer |= (1 << 0);
2105 2 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2106 0           return AMQP_STATUS_BAD_AMQP_DATA;
2107 2           return (int)offset;
2108             }
2109             case AMQP_BASIC_CANCEL_OK_METHOD: {
2110 0           amqp_basic_cancel_ok_t *m = (amqp_basic_cancel_ok_t *)decoded;
2111 0           if (UINT8_MAX < m->consumer_tag.len ||
2112 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) ||
2113 0           !amqp_encode_bytes(encoded, &offset, m->consumer_tag))
2114 0           return AMQP_STATUS_BAD_AMQP_DATA;
2115 0           return (int)offset;
2116             }
2117             case AMQP_BASIC_PUBLISH_METHOD: {
2118 29           amqp_basic_publish_t *m = (amqp_basic_publish_t *)decoded;
2119 29 50         if (!amqp_encode_16(encoded, &offset, m->ticket))
2120 0           return AMQP_STATUS_BAD_AMQP_DATA;
2121 58           if (UINT8_MAX < m->exchange.len ||
2122 58 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) ||
2123 29           !amqp_encode_bytes(encoded, &offset, m->exchange))
2124 0           return AMQP_STATUS_BAD_AMQP_DATA;
2125 58           if (UINT8_MAX < m->routing_key.len ||
2126 58 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) ||
2127 29           !amqp_encode_bytes(encoded, &offset, m->routing_key))
2128 0           return AMQP_STATUS_BAD_AMQP_DATA;
2129 29           bit_buffer = 0;
2130 29 50         if (m->mandatory) bit_buffer |= (1 << 0);
2131 29 50         if (m->immediate) bit_buffer |= (1 << 1);
2132 29 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2133 0           return AMQP_STATUS_BAD_AMQP_DATA;
2134 29           return (int)offset;
2135             }
2136             case AMQP_BASIC_RETURN_METHOD: {
2137 0           amqp_basic_return_t *m = (amqp_basic_return_t *)decoded;
2138 0 0         if (!amqp_encode_16(encoded, &offset, m->reply_code))
2139 0           return AMQP_STATUS_BAD_AMQP_DATA;
2140 0           if (UINT8_MAX < m->reply_text.len ||
2141 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->reply_text.len) ||
2142 0           !amqp_encode_bytes(encoded, &offset, m->reply_text))
2143 0           return AMQP_STATUS_BAD_AMQP_DATA;
2144 0           if (UINT8_MAX < m->exchange.len ||
2145 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) ||
2146 0           !amqp_encode_bytes(encoded, &offset, m->exchange))
2147 0           return AMQP_STATUS_BAD_AMQP_DATA;
2148 0           if (UINT8_MAX < m->routing_key.len ||
2149 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) ||
2150 0           !amqp_encode_bytes(encoded, &offset, m->routing_key))
2151 0           return AMQP_STATUS_BAD_AMQP_DATA;
2152 0           return (int)offset;
2153             }
2154             case AMQP_BASIC_DELIVER_METHOD: {
2155 0           amqp_basic_deliver_t *m = (amqp_basic_deliver_t *)decoded;
2156 0           if (UINT8_MAX < m->consumer_tag.len ||
2157 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->consumer_tag.len) ||
2158 0           !amqp_encode_bytes(encoded, &offset, m->consumer_tag))
2159 0           return AMQP_STATUS_BAD_AMQP_DATA;
2160 0 0         if (!amqp_encode_64(encoded, &offset, m->delivery_tag))
2161 0           return AMQP_STATUS_BAD_AMQP_DATA;
2162 0           bit_buffer = 0;
2163 0 0         if (m->redelivered) bit_buffer |= (1 << 0);
2164 0 0         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2165 0           return AMQP_STATUS_BAD_AMQP_DATA;
2166 0           if (UINT8_MAX < m->exchange.len ||
2167 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) ||
2168 0           !amqp_encode_bytes(encoded, &offset, m->exchange))
2169 0           return AMQP_STATUS_BAD_AMQP_DATA;
2170 0           if (UINT8_MAX < m->routing_key.len ||
2171 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) ||
2172 0           !amqp_encode_bytes(encoded, &offset, m->routing_key))
2173 0           return AMQP_STATUS_BAD_AMQP_DATA;
2174 0           return (int)offset;
2175             }
2176             case AMQP_BASIC_GET_METHOD: {
2177 22           amqp_basic_get_t *m = (amqp_basic_get_t *)decoded;
2178 22 50         if (!amqp_encode_16(encoded, &offset, m->ticket))
2179 0           return AMQP_STATUS_BAD_AMQP_DATA;
2180 44           if (UINT8_MAX < m->queue.len ||
2181 44 50         !amqp_encode_8(encoded, &offset, (uint8_t)m->queue.len) ||
2182 22           !amqp_encode_bytes(encoded, &offset, m->queue))
2183 0           return AMQP_STATUS_BAD_AMQP_DATA;
2184 22           bit_buffer = 0;
2185 22 100         if (m->no_ack) bit_buffer |= (1 << 0);
2186 22 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2187 0           return AMQP_STATUS_BAD_AMQP_DATA;
2188 22           return (int)offset;
2189             }
2190             case AMQP_BASIC_GET_OK_METHOD: {
2191 0           amqp_basic_get_ok_t *m = (amqp_basic_get_ok_t *)decoded;
2192 0 0         if (!amqp_encode_64(encoded, &offset, m->delivery_tag))
2193 0           return AMQP_STATUS_BAD_AMQP_DATA;
2194 0           bit_buffer = 0;
2195 0 0         if (m->redelivered) bit_buffer |= (1 << 0);
2196 0 0         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2197 0           return AMQP_STATUS_BAD_AMQP_DATA;
2198 0           if (UINT8_MAX < m->exchange.len ||
2199 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->exchange.len) ||
2200 0           !amqp_encode_bytes(encoded, &offset, m->exchange))
2201 0           return AMQP_STATUS_BAD_AMQP_DATA;
2202 0           if (UINT8_MAX < m->routing_key.len ||
2203 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->routing_key.len) ||
2204 0           !amqp_encode_bytes(encoded, &offset, m->routing_key))
2205 0           return AMQP_STATUS_BAD_AMQP_DATA;
2206 0 0         if (!amqp_encode_32(encoded, &offset, m->message_count))
2207 0           return AMQP_STATUS_BAD_AMQP_DATA;
2208 0           return (int)offset;
2209             }
2210             case AMQP_BASIC_GET_EMPTY_METHOD: {
2211 0           amqp_basic_get_empty_t *m = (amqp_basic_get_empty_t *)decoded;
2212 0           if (UINT8_MAX < m->cluster_id.len ||
2213 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)m->cluster_id.len) ||
2214 0           !amqp_encode_bytes(encoded, &offset, m->cluster_id))
2215 0           return AMQP_STATUS_BAD_AMQP_DATA;
2216 0           return (int)offset;
2217             }
2218             case AMQP_BASIC_ACK_METHOD: {
2219 2           amqp_basic_ack_t *m = (amqp_basic_ack_t *)decoded;
2220 2 50         if (!amqp_encode_64(encoded, &offset, m->delivery_tag))
2221 0           return AMQP_STATUS_BAD_AMQP_DATA;
2222 2           bit_buffer = 0;
2223 2 50         if (m->multiple) bit_buffer |= (1 << 0);
2224 2 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2225 0           return AMQP_STATUS_BAD_AMQP_DATA;
2226 2           return (int)offset;
2227             }
2228             case AMQP_BASIC_REJECT_METHOD: {
2229 1           amqp_basic_reject_t *m = (amqp_basic_reject_t *)decoded;
2230 1 50         if (!amqp_encode_64(encoded, &offset, m->delivery_tag))
2231 0           return AMQP_STATUS_BAD_AMQP_DATA;
2232 1           bit_buffer = 0;
2233 1 50         if (m->requeue) bit_buffer |= (1 << 0);
2234 1 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2235 0           return AMQP_STATUS_BAD_AMQP_DATA;
2236 1           return (int)offset;
2237             }
2238             case AMQP_BASIC_RECOVER_ASYNC_METHOD: {
2239 0           amqp_basic_recover_async_t *m = (amqp_basic_recover_async_t *)decoded;
2240 0           bit_buffer = 0;
2241 0 0         if (m->requeue) bit_buffer |= (1 << 0);
2242 0 0         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2243 0           return AMQP_STATUS_BAD_AMQP_DATA;
2244 0           return (int)offset;
2245             }
2246             case AMQP_BASIC_RECOVER_METHOD: {
2247 0           amqp_basic_recover_t *m = (amqp_basic_recover_t *)decoded;
2248 0           bit_buffer = 0;
2249 0 0         if (m->requeue) bit_buffer |= (1 << 0);
2250 0 0         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2251 0           return AMQP_STATUS_BAD_AMQP_DATA;
2252 0           return (int)offset;
2253             }
2254             case AMQP_BASIC_RECOVER_OK_METHOD: {
2255 0           return (int)offset;
2256             }
2257             case AMQP_BASIC_NACK_METHOD: {
2258 1           amqp_basic_nack_t *m = (amqp_basic_nack_t *)decoded;
2259 1 50         if (!amqp_encode_64(encoded, &offset, m->delivery_tag))
2260 0           return AMQP_STATUS_BAD_AMQP_DATA;
2261 1           bit_buffer = 0;
2262 1 50         if (m->multiple) bit_buffer |= (1 << 0);
2263 1 50         if (m->requeue) bit_buffer |= (1 << 1);
2264 1 50         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2265 0           return AMQP_STATUS_BAD_AMQP_DATA;
2266 1           return (int)offset;
2267             }
2268             case AMQP_TX_SELECT_METHOD: {
2269 1           return (int)offset;
2270             }
2271             case AMQP_TX_SELECT_OK_METHOD: {
2272 0           return (int)offset;
2273             }
2274             case AMQP_TX_COMMIT_METHOD: {
2275 1           return (int)offset;
2276             }
2277             case AMQP_TX_COMMIT_OK_METHOD: {
2278 0           return (int)offset;
2279             }
2280             case AMQP_TX_ROLLBACK_METHOD: {
2281 1           return (int)offset;
2282             }
2283             case AMQP_TX_ROLLBACK_OK_METHOD: {
2284 0           return (int)offset;
2285             }
2286             case AMQP_CONFIRM_SELECT_METHOD: {
2287 0           amqp_confirm_select_t *m = (amqp_confirm_select_t *)decoded;
2288 0           bit_buffer = 0;
2289 0 0         if (m->nowait) bit_buffer |= (1 << 0);
2290 0 0         if (!amqp_encode_8(encoded, &offset, bit_buffer))
2291 0           return AMQP_STATUS_BAD_AMQP_DATA;
2292 0           return (int)offset;
2293             }
2294             case AMQP_CONFIRM_SELECT_OK_METHOD: {
2295 0           return (int)offset;
2296             }
2297             default:
2298 409           return AMQP_STATUS_UNKNOWN_METHOD;
2299             }
2300             }
2301              
2302 28           int amqp_encode_properties(uint16_t class_id, void *decoded,
2303             amqp_bytes_t encoded) {
2304 28           size_t offset = 0;
2305              
2306             /* Cheat, and get the flags out generically, relying on the
2307             similarity of structure between classes */
2308 28           amqp_flags_t flags = *(amqp_flags_t *)decoded; /* cheating! */
2309              
2310             {
2311             /* We take a copy of flags to avoid destroying it, as it is used
2312             in the autogenerated code below. */
2313 28           amqp_flags_t remaining_flags = flags;
2314             do {
2315 28           amqp_flags_t remainder = remaining_flags >> 16;
2316 28           uint16_t partial_flags = remaining_flags & 0xFFFE;
2317 28 50         if (remainder != 0) {
2318 0           partial_flags |= 1;
2319             }
2320 28 50         if (!amqp_encode_16(encoded, &offset, partial_flags))
2321 0           return AMQP_STATUS_BAD_AMQP_DATA;
2322 28           remaining_flags = remainder;
2323 28 50         } while (remaining_flags != 0);
2324             }
2325              
2326 28           switch (class_id) {
2327             case 10: {
2328 0           return (int)offset;
2329             }
2330             case 20: {
2331 0           return (int)offset;
2332             }
2333             case 30: {
2334 0           return (int)offset;
2335             }
2336             case 40: {
2337 0           return (int)offset;
2338             }
2339             case 50: {
2340 0           return (int)offset;
2341             }
2342             case 60: {
2343 28           amqp_basic_properties_t *p = (amqp_basic_properties_t *)decoded;
2344 28 100         if (flags & AMQP_BASIC_CONTENT_TYPE_FLAG) {
2345 10           if (UINT8_MAX < p->content_type.len ||
2346 10 50         !amqp_encode_8(encoded, &offset, (uint8_t)p->content_type.len) ||
2347 5           !amqp_encode_bytes(encoded, &offset, p->content_type))
2348 0           return AMQP_STATUS_BAD_AMQP_DATA;
2349             }
2350 28 100         if (flags & AMQP_BASIC_CONTENT_ENCODING_FLAG) {
2351 16           if (UINT8_MAX < p->content_encoding.len ||
2352 8           !amqp_encode_8(encoded, &offset,
2353 8 50         (uint8_t)p->content_encoding.len) ||
2354 8           !amqp_encode_bytes(encoded, &offset, p->content_encoding))
2355 0           return AMQP_STATUS_BAD_AMQP_DATA;
2356             }
2357 28 100         if (flags & AMQP_BASIC_HEADERS_FLAG) {
2358             {
2359 9           int res = amqp_encode_table(encoded, &(p->headers), &offset);
2360 9 50         if (res < 0) return res;
2361             }
2362             }
2363 28 100         if (flags & AMQP_BASIC_DELIVERY_MODE_FLAG) {
2364 5 50         if (!amqp_encode_8(encoded, &offset, p->delivery_mode))
2365 0           return AMQP_STATUS_BAD_AMQP_DATA;
2366             }
2367 28 100         if (flags & AMQP_BASIC_PRIORITY_FLAG) {
2368 5 50         if (!amqp_encode_8(encoded, &offset, p->priority))
2369 0           return AMQP_STATUS_BAD_AMQP_DATA;
2370             }
2371 28 100         if (flags & AMQP_BASIC_CORRELATION_ID_FLAG) {
2372 10           if (UINT8_MAX < p->correlation_id.len ||
2373 10 50         !amqp_encode_8(encoded, &offset, (uint8_t)p->correlation_id.len) ||
2374 5           !amqp_encode_bytes(encoded, &offset, p->correlation_id))
2375 0           return AMQP_STATUS_BAD_AMQP_DATA;
2376             }
2377 28 100         if (flags & AMQP_BASIC_REPLY_TO_FLAG) {
2378 10           if (UINT8_MAX < p->reply_to.len ||
2379 10 50         !amqp_encode_8(encoded, &offset, (uint8_t)p->reply_to.len) ||
2380 5           !amqp_encode_bytes(encoded, &offset, p->reply_to))
2381 0           return AMQP_STATUS_BAD_AMQP_DATA;
2382             }
2383 28 100         if (flags & AMQP_BASIC_EXPIRATION_FLAG) {
2384 10           if (UINT8_MAX < p->expiration.len ||
2385 10 50         !amqp_encode_8(encoded, &offset, (uint8_t)p->expiration.len) ||
2386 5           !amqp_encode_bytes(encoded, &offset, p->expiration))
2387 0           return AMQP_STATUS_BAD_AMQP_DATA;
2388             }
2389 28 100         if (flags & AMQP_BASIC_MESSAGE_ID_FLAG) {
2390 10           if (UINT8_MAX < p->message_id.len ||
2391 10 50         !amqp_encode_8(encoded, &offset, (uint8_t)p->message_id.len) ||
2392 5           !amqp_encode_bytes(encoded, &offset, p->message_id))
2393 0           return AMQP_STATUS_BAD_AMQP_DATA;
2394             }
2395 28 100         if (flags & AMQP_BASIC_TIMESTAMP_FLAG) {
2396 5 50         if (!amqp_encode_64(encoded, &offset, p->timestamp))
2397 0           return AMQP_STATUS_BAD_AMQP_DATA;
2398             }
2399 28 100         if (flags & AMQP_BASIC_TYPE_FLAG) {
2400 10           if (UINT8_MAX < p->type.len ||
2401 10 50         !amqp_encode_8(encoded, &offset, (uint8_t)p->type.len) ||
2402 5           !amqp_encode_bytes(encoded, &offset, p->type))
2403 0           return AMQP_STATUS_BAD_AMQP_DATA;
2404             }
2405 28 100         if (flags & AMQP_BASIC_USER_ID_FLAG) {
2406 10           if (UINT8_MAX < p->user_id.len ||
2407 10 50         !amqp_encode_8(encoded, &offset, (uint8_t)p->user_id.len) ||
2408 5           !amqp_encode_bytes(encoded, &offset, p->user_id))
2409 0           return AMQP_STATUS_BAD_AMQP_DATA;
2410             }
2411 28 100         if (flags & AMQP_BASIC_APP_ID_FLAG) {
2412 10           if (UINT8_MAX < p->app_id.len ||
2413 10 50         !amqp_encode_8(encoded, &offset, (uint8_t)p->app_id.len) ||
2414 5           !amqp_encode_bytes(encoded, &offset, p->app_id))
2415 0           return AMQP_STATUS_BAD_AMQP_DATA;
2416             }
2417 28 50         if (flags & AMQP_BASIC_CLUSTER_ID_FLAG) {
2418 0           if (UINT8_MAX < p->cluster_id.len ||
2419 0 0         !amqp_encode_8(encoded, &offset, (uint8_t)p->cluster_id.len) ||
2420 0           !amqp_encode_bytes(encoded, &offset, p->cluster_id))
2421 0           return AMQP_STATUS_BAD_AMQP_DATA;
2422             }
2423 28           return (int)offset;
2424             }
2425             case 90: {
2426 0           return (int)offset;
2427             }
2428             case 85: {
2429 0           return (int)offset;
2430             }
2431             default:
2432 28           return AMQP_STATUS_UNKNOWN_CLASS;
2433             }
2434             }
2435              
2436             /**
2437             * amqp_channel_open
2438             *
2439             * @param [in] state connection state
2440             * @param [in] channel the channel to do the RPC on
2441             * @returns amqp_channel_open_ok_t
2442             */
2443             AMQP_PUBLIC_FUNCTION
2444             amqp_channel_open_ok_t *AMQP_CALL
2445 36           amqp_channel_open(amqp_connection_state_t state, amqp_channel_t channel) {
2446             amqp_channel_open_t req;
2447 36           req.out_of_band = amqp_empty_bytes;
2448              
2449 36           return amqp_simple_rpc_decoded(state, channel, AMQP_CHANNEL_OPEN_METHOD,
2450             AMQP_CHANNEL_OPEN_OK_METHOD, &req);
2451             }
2452              
2453             /**
2454             * amqp_channel_flow
2455             *
2456             * @param [in] state connection state
2457             * @param [in] channel the channel to do the RPC on
2458             * @param [in] active active
2459             * @returns amqp_channel_flow_ok_t
2460             */
2461             AMQP_PUBLIC_FUNCTION
2462             amqp_channel_flow_ok_t *AMQP_CALL
2463 0           amqp_channel_flow(amqp_connection_state_t state, amqp_channel_t channel,
2464             amqp_boolean_t active) {
2465             amqp_channel_flow_t req;
2466 0           req.active = active;
2467              
2468 0           return amqp_simple_rpc_decoded(state, channel, AMQP_CHANNEL_FLOW_METHOD,
2469             AMQP_CHANNEL_FLOW_OK_METHOD, &req);
2470             }
2471              
2472             /**
2473             * amqp_exchange_declare
2474             *
2475             * @param [in] state connection state
2476             * @param [in] channel the channel to do the RPC on
2477             * @param [in] exchange exchange
2478             * @param [in] type type
2479             * @param [in] passive passive
2480             * @param [in] durable durable
2481             * @param [in] auto_delete auto_delete
2482             * @param [in] internal internal
2483             * @param [in] arguments arguments
2484             * @returns amqp_exchange_declare_ok_t
2485             */
2486             AMQP_PUBLIC_FUNCTION
2487 26           amqp_exchange_declare_ok_t *AMQP_CALL amqp_exchange_declare(
2488             amqp_connection_state_t state, amqp_channel_t channel,
2489             amqp_bytes_t exchange, amqp_bytes_t type, amqp_boolean_t passive,
2490             amqp_boolean_t durable, amqp_boolean_t auto_delete, amqp_boolean_t internal,
2491             amqp_table_t arguments) {
2492             amqp_exchange_declare_t req;
2493 26           req.ticket = 0;
2494 26           req.exchange = exchange;
2495 26           req.type = type;
2496 26           req.passive = passive;
2497 26           req.durable = durable;
2498 26           req.auto_delete = auto_delete;
2499 26           req.internal = internal;
2500 26           req.nowait = 0;
2501 26           req.arguments = arguments;
2502              
2503 26           return amqp_simple_rpc_decoded(state, channel, AMQP_EXCHANGE_DECLARE_METHOD,
2504             AMQP_EXCHANGE_DECLARE_OK_METHOD, &req);
2505             }
2506              
2507             /**
2508             * amqp_exchange_delete
2509             *
2510             * @param [in] state connection state
2511             * @param [in] channel the channel to do the RPC on
2512             * @param [in] exchange exchange
2513             * @param [in] if_unused if_unused
2514             * @returns amqp_exchange_delete_ok_t
2515             */
2516             AMQP_PUBLIC_FUNCTION
2517             amqp_exchange_delete_ok_t *AMQP_CALL
2518 27           amqp_exchange_delete(amqp_connection_state_t state, amqp_channel_t channel,
2519             amqp_bytes_t exchange, amqp_boolean_t if_unused) {
2520             amqp_exchange_delete_t req;
2521 27           req.ticket = 0;
2522 27           req.exchange = exchange;
2523 27           req.if_unused = if_unused;
2524 27           req.nowait = 0;
2525              
2526 27           return amqp_simple_rpc_decoded(state, channel, AMQP_EXCHANGE_DELETE_METHOD,
2527             AMQP_EXCHANGE_DELETE_OK_METHOD, &req);
2528             }
2529              
2530             /**
2531             * amqp_exchange_bind
2532             *
2533             * @param [in] state connection state
2534             * @param [in] channel the channel to do the RPC on
2535             * @param [in] destination destination
2536             * @param [in] source source
2537             * @param [in] routing_key routing_key
2538             * @param [in] arguments arguments
2539             * @returns amqp_exchange_bind_ok_t
2540             */
2541             AMQP_PUBLIC_FUNCTION
2542             amqp_exchange_bind_ok_t *AMQP_CALL
2543 1           amqp_exchange_bind(amqp_connection_state_t state, amqp_channel_t channel,
2544             amqp_bytes_t destination, amqp_bytes_t source,
2545             amqp_bytes_t routing_key, amqp_table_t arguments) {
2546             amqp_exchange_bind_t req;
2547 1           req.ticket = 0;
2548 1           req.destination = destination;
2549 1           req.source = source;
2550 1           req.routing_key = routing_key;
2551 1           req.nowait = 0;
2552 1           req.arguments = arguments;
2553              
2554 1           return amqp_simple_rpc_decoded(state, channel, AMQP_EXCHANGE_BIND_METHOD,
2555             AMQP_EXCHANGE_BIND_OK_METHOD, &req);
2556             }
2557              
2558             /**
2559             * amqp_exchange_unbind
2560             *
2561             * @param [in] state connection state
2562             * @param [in] channel the channel to do the RPC on
2563             * @param [in] destination destination
2564             * @param [in] source source
2565             * @param [in] routing_key routing_key
2566             * @param [in] arguments arguments
2567             * @returns amqp_exchange_unbind_ok_t
2568             */
2569             AMQP_PUBLIC_FUNCTION
2570             amqp_exchange_unbind_ok_t *AMQP_CALL
2571 1           amqp_exchange_unbind(amqp_connection_state_t state, amqp_channel_t channel,
2572             amqp_bytes_t destination, amqp_bytes_t source,
2573             amqp_bytes_t routing_key, amqp_table_t arguments) {
2574             amqp_exchange_unbind_t req;
2575 1           req.ticket = 0;
2576 1           req.destination = destination;
2577 1           req.source = source;
2578 1           req.routing_key = routing_key;
2579 1           req.nowait = 0;
2580 1           req.arguments = arguments;
2581              
2582 1           return amqp_simple_rpc_decoded(state, channel, AMQP_EXCHANGE_UNBIND_METHOD,
2583             AMQP_EXCHANGE_UNBIND_OK_METHOD, &req);
2584             }
2585              
2586             /**
2587             * amqp_queue_declare
2588             *
2589             * @param [in] state connection state
2590             * @param [in] channel the channel to do the RPC on
2591             * @param [in] queue queue
2592             * @param [in] passive passive
2593             * @param [in] durable durable
2594             * @param [in] exclusive exclusive
2595             * @param [in] auto_delete auto_delete
2596             * @param [in] arguments arguments
2597             * @returns amqp_queue_declare_ok_t
2598             */
2599             AMQP_PUBLIC_FUNCTION
2600 20           amqp_queue_declare_ok_t *AMQP_CALL amqp_queue_declare(
2601             amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue,
2602             amqp_boolean_t passive, amqp_boolean_t durable, amqp_boolean_t exclusive,
2603             amqp_boolean_t auto_delete, amqp_table_t arguments) {
2604             amqp_queue_declare_t req;
2605 20           req.ticket = 0;
2606 20           req.queue = queue;
2607 20           req.passive = passive;
2608 20           req.durable = durable;
2609 20           req.exclusive = exclusive;
2610 20           req.auto_delete = auto_delete;
2611 20           req.nowait = 0;
2612 20           req.arguments = arguments;
2613              
2614 20           return amqp_simple_rpc_decoded(state, channel, AMQP_QUEUE_DECLARE_METHOD,
2615             AMQP_QUEUE_DECLARE_OK_METHOD, &req);
2616             }
2617              
2618             /**
2619             * amqp_queue_bind
2620             *
2621             * @param [in] state connection state
2622             * @param [in] channel the channel to do the RPC on
2623             * @param [in] queue queue
2624             * @param [in] exchange exchange
2625             * @param [in] routing_key routing_key
2626             * @param [in] arguments arguments
2627             * @returns amqp_queue_bind_ok_t
2628             */
2629             AMQP_PUBLIC_FUNCTION
2630 18           amqp_queue_bind_ok_t *AMQP_CALL amqp_queue_bind(
2631             amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue,
2632             amqp_bytes_t exchange, amqp_bytes_t routing_key, amqp_table_t arguments) {
2633             amqp_queue_bind_t req;
2634 18           req.ticket = 0;
2635 18           req.queue = queue;
2636 18           req.exchange = exchange;
2637 18           req.routing_key = routing_key;
2638 18           req.nowait = 0;
2639 18           req.arguments = arguments;
2640              
2641 18           return amqp_simple_rpc_decoded(state, channel, AMQP_QUEUE_BIND_METHOD,
2642             AMQP_QUEUE_BIND_OK_METHOD, &req);
2643             }
2644              
2645             /**
2646             * amqp_queue_purge
2647             *
2648             * @param [in] state connection state
2649             * @param [in] channel the channel to do the RPC on
2650             * @param [in] queue queue
2651             * @returns amqp_queue_purge_ok_t
2652             */
2653             AMQP_PUBLIC_FUNCTION
2654 19           amqp_queue_purge_ok_t *AMQP_CALL amqp_queue_purge(amqp_connection_state_t state,
2655             amqp_channel_t channel,
2656             amqp_bytes_t queue) {
2657             amqp_queue_purge_t req;
2658 19           req.ticket = 0;
2659 19           req.queue = queue;
2660 19           req.nowait = 0;
2661              
2662 19           return amqp_simple_rpc_decoded(state, channel, AMQP_QUEUE_PURGE_METHOD,
2663             AMQP_QUEUE_PURGE_OK_METHOD, &req);
2664             }
2665              
2666             /**
2667             * amqp_queue_delete
2668             *
2669             * @param [in] state connection state
2670             * @param [in] channel the channel to do the RPC on
2671             * @param [in] queue queue
2672             * @param [in] if_unused if_unused
2673             * @param [in] if_empty if_empty
2674             * @returns amqp_queue_delete_ok_t
2675             */
2676             AMQP_PUBLIC_FUNCTION
2677 20           amqp_queue_delete_ok_t *AMQP_CALL amqp_queue_delete(
2678             amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue,
2679             amqp_boolean_t if_unused, amqp_boolean_t if_empty) {
2680             amqp_queue_delete_t req;
2681 20           req.ticket = 0;
2682 20           req.queue = queue;
2683 20           req.if_unused = if_unused;
2684 20           req.if_empty = if_empty;
2685 20           req.nowait = 0;
2686              
2687 20           return amqp_simple_rpc_decoded(state, channel, AMQP_QUEUE_DELETE_METHOD,
2688             AMQP_QUEUE_DELETE_OK_METHOD, &req);
2689             }
2690              
2691             /**
2692             * amqp_queue_unbind
2693             *
2694             * @param [in] state connection state
2695             * @param [in] channel the channel to do the RPC on
2696             * @param [in] queue queue
2697             * @param [in] exchange exchange
2698             * @param [in] routing_key routing_key
2699             * @param [in] arguments arguments
2700             * @returns amqp_queue_unbind_ok_t
2701             */
2702             AMQP_PUBLIC_FUNCTION
2703 21           amqp_queue_unbind_ok_t *AMQP_CALL amqp_queue_unbind(
2704             amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue,
2705             amqp_bytes_t exchange, amqp_bytes_t routing_key, amqp_table_t arguments) {
2706             amqp_queue_unbind_t req;
2707 21           req.ticket = 0;
2708 21           req.queue = queue;
2709 21           req.exchange = exchange;
2710 21           req.routing_key = routing_key;
2711 21           req.arguments = arguments;
2712              
2713 21           return amqp_simple_rpc_decoded(state, channel, AMQP_QUEUE_UNBIND_METHOD,
2714             AMQP_QUEUE_UNBIND_OK_METHOD, &req);
2715             }
2716              
2717             /**
2718             * amqp_basic_qos
2719             *
2720             * @param [in] state connection state
2721             * @param [in] channel the channel to do the RPC on
2722             * @param [in] prefetch_size prefetch_size
2723             * @param [in] prefetch_count prefetch_count
2724             * @param [in] global global
2725             * @returns amqp_basic_qos_ok_t
2726             */
2727             AMQP_PUBLIC_FUNCTION
2728 1           amqp_basic_qos_ok_t *AMQP_CALL amqp_basic_qos(amqp_connection_state_t state,
2729             amqp_channel_t channel,
2730             uint32_t prefetch_size,
2731             uint16_t prefetch_count,
2732             amqp_boolean_t global) {
2733             amqp_basic_qos_t req;
2734 1           req.prefetch_size = prefetch_size;
2735 1           req.prefetch_count = prefetch_count;
2736 1           req.global = global;
2737              
2738 1           return amqp_simple_rpc_decoded(state, channel, AMQP_BASIC_QOS_METHOD,
2739             AMQP_BASIC_QOS_OK_METHOD, &req);
2740             }
2741              
2742             /**
2743             * amqp_basic_consume
2744             *
2745             * @param [in] state connection state
2746             * @param [in] channel the channel to do the RPC on
2747             * @param [in] queue queue
2748             * @param [in] consumer_tag consumer_tag
2749             * @param [in] no_local no_local
2750             * @param [in] no_ack no_ack
2751             * @param [in] exclusive exclusive
2752             * @param [in] arguments arguments
2753             * @returns amqp_basic_consume_ok_t
2754             */
2755             AMQP_PUBLIC_FUNCTION
2756 16           amqp_basic_consume_ok_t *AMQP_CALL amqp_basic_consume(
2757             amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue,
2758             amqp_bytes_t consumer_tag, amqp_boolean_t no_local, amqp_boolean_t no_ack,
2759             amqp_boolean_t exclusive, amqp_table_t arguments) {
2760             amqp_basic_consume_t req;
2761 16           req.ticket = 0;
2762 16           req.queue = queue;
2763 16           req.consumer_tag = consumer_tag;
2764 16           req.no_local = no_local;
2765 16           req.no_ack = no_ack;
2766 16           req.exclusive = exclusive;
2767 16           req.nowait = 0;
2768 16           req.arguments = arguments;
2769              
2770 16           return amqp_simple_rpc_decoded(state, channel, AMQP_BASIC_CONSUME_METHOD,
2771             AMQP_BASIC_CONSUME_OK_METHOD, &req);
2772             }
2773              
2774             /**
2775             * amqp_basic_cancel
2776             *
2777             * @param [in] state connection state
2778             * @param [in] channel the channel to do the RPC on
2779             * @param [in] consumer_tag consumer_tag
2780             * @returns amqp_basic_cancel_ok_t
2781             */
2782             AMQP_PUBLIC_FUNCTION
2783             amqp_basic_cancel_ok_t *AMQP_CALL
2784 2           amqp_basic_cancel(amqp_connection_state_t state, amqp_channel_t channel,
2785             amqp_bytes_t consumer_tag) {
2786             amqp_basic_cancel_t req;
2787 2           req.consumer_tag = consumer_tag;
2788 2           req.nowait = 0;
2789              
2790 2           return amqp_simple_rpc_decoded(state, channel, AMQP_BASIC_CANCEL_METHOD,
2791             AMQP_BASIC_CANCEL_OK_METHOD, &req);
2792             }
2793              
2794             /**
2795             * amqp_basic_recover
2796             *
2797             * @param [in] state connection state
2798             * @param [in] channel the channel to do the RPC on
2799             * @param [in] requeue requeue
2800             * @returns amqp_basic_recover_ok_t
2801             */
2802             AMQP_PUBLIC_FUNCTION
2803             amqp_basic_recover_ok_t *AMQP_CALL
2804 0           amqp_basic_recover(amqp_connection_state_t state, amqp_channel_t channel,
2805             amqp_boolean_t requeue) {
2806             amqp_basic_recover_t req;
2807 0           req.requeue = requeue;
2808              
2809 0           return amqp_simple_rpc_decoded(state, channel, AMQP_BASIC_RECOVER_METHOD,
2810             AMQP_BASIC_RECOVER_OK_METHOD, &req);
2811             }
2812              
2813             /**
2814             * amqp_tx_select
2815             *
2816             * @param [in] state connection state
2817             * @param [in] channel the channel to do the RPC on
2818             * @returns amqp_tx_select_ok_t
2819             */
2820             AMQP_PUBLIC_FUNCTION
2821 1           amqp_tx_select_ok_t *AMQP_CALL amqp_tx_select(amqp_connection_state_t state,
2822             amqp_channel_t channel) {
2823             amqp_tx_select_t req;
2824              
2825 1           return amqp_simple_rpc_decoded(state, channel, AMQP_TX_SELECT_METHOD,
2826             AMQP_TX_SELECT_OK_METHOD, &req);
2827             }
2828              
2829             /**
2830             * amqp_tx_commit
2831             *
2832             * @param [in] state connection state
2833             * @param [in] channel the channel to do the RPC on
2834             * @returns amqp_tx_commit_ok_t
2835             */
2836             AMQP_PUBLIC_FUNCTION
2837 1           amqp_tx_commit_ok_t *AMQP_CALL amqp_tx_commit(amqp_connection_state_t state,
2838             amqp_channel_t channel) {
2839             amqp_tx_commit_t req;
2840              
2841 1           return amqp_simple_rpc_decoded(state, channel, AMQP_TX_COMMIT_METHOD,
2842             AMQP_TX_COMMIT_OK_METHOD, &req);
2843             }
2844              
2845             /**
2846             * amqp_tx_rollback
2847             *
2848             * @param [in] state connection state
2849             * @param [in] channel the channel to do the RPC on
2850             * @returns amqp_tx_rollback_ok_t
2851             */
2852             AMQP_PUBLIC_FUNCTION
2853 1           amqp_tx_rollback_ok_t *AMQP_CALL amqp_tx_rollback(amqp_connection_state_t state,
2854             amqp_channel_t channel) {
2855             amqp_tx_rollback_t req;
2856              
2857 1           return amqp_simple_rpc_decoded(state, channel, AMQP_TX_ROLLBACK_METHOD,
2858             AMQP_TX_ROLLBACK_OK_METHOD, &req);
2859             }
2860              
2861             /**
2862             * amqp_confirm_select
2863             *
2864             * @param [in] state connection state
2865             * @param [in] channel the channel to do the RPC on
2866             * @returns amqp_confirm_select_ok_t
2867             */
2868             AMQP_PUBLIC_FUNCTION
2869             amqp_confirm_select_ok_t *AMQP_CALL
2870 0           amqp_confirm_select(amqp_connection_state_t state, amqp_channel_t channel) {
2871             amqp_confirm_select_t req;
2872 0           req.nowait = 0;
2873              
2874 0           return amqp_simple_rpc_decoded(state, channel, AMQP_CONFIRM_SELECT_METHOD,
2875             AMQP_CONFIRM_SELECT_OK_METHOD, &req);
2876             }