Attachment 945553 Details for Bug 1151416 – Reproducer script

Reproducer script

send_raw_data_dtx_timeout.py (text/plain), 1.94 KB, created by Pavel Moravec on 2014-10-10 11:09:04 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Pavel Moravec

Created: 2014-10-10 11:09:04 UTC

Size: 1.94 KB

patch

obsolete

>import socket
>import struct
>import binascii
>from time import sleep
>import sys
>sys.path.insert(0,'bitstring-3.1.2')
>from bitstring import BitStream, BitArray
>
>#let play with global_id but ensure it has 19 characters inside
>global_id = '74657374007465737400746573740054455354'
>
>client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
>client_socket.connect(('localhost', 5672))
>
>def send_and_receive(hexstream, recv_len):
>    hex = binascii.unhexlify(hexstream)
>    data = BitArray(bytes=hex)
>    client_socket.sendall(data.tobytes())
>    if (recv_len > 0):
>        data = client_socket.recv(recv_len)
>
>send_and_receive('414d51500101000a', 146) #AMQP hello frame
>
>send_and_receive('0f0000ad000000000000000001020f0000000068000000040f717069642e636c69656e745f7069642100002d7f10717069642e636c69656e745f7070696421000007e413717069642e636c69656e745f70726f6365737395000b717069642d74787465737411717069642e73657373696f6e5f666c6f77210000000109414e4f4e594d4f55530000001d616e6f6e796d6f757340706d6f72617665632d6d72672d747261696e3205656e5f5553', 24) # connection.start-ok
>
>send_and_receive('0f0000160000000000000000010607007fffffff00000f00001a0000000000000000010707000000000005f000000000', 25) # connection.tune-ok, connection.start
>
>send_and_receive('0f000036000000010000000002010100002433646230393239332d333635622d343563632d613931332d653034643730373464623434', 82) #session.attach
>send_and_receive('0f000014000000010000000002050100000000000f00001c000000010000000002070300000000000000000000000000', 0) # session.request-timeout, session.command-point
>send_and_receive('0f0100120001000100000000060101000000', 0) #dtx.select
>
>send_and_receive('0f01003c000100010000000006020100010000000026060407004c414e4713'+global_id+'0974782d746573742d31', 0) # dtx.start
>send_and_receive('0f0100400001000100000000060a0100030000000026060407004c414e4713'+global_id+'0974782d746573742d3100000259', 0) # dtx.timeout
>
>sleep(0.1) # just to let broker to react and send us the (malformed) response
>client_socket.close()

Actions: View

Attachments on bug 1151416: 945553