packet.h File Reference

#include <stdint.h>
#include <string.h>
#include <stdlib.h>
#include "libgdbr.h"
#include <stdio.h>

Go to the source code of this file.

Functions
int	send_packet (libgdbr_t *g)
	sends a packet sends a packet to the established connection More...
int	read_packet (libgdbr_t *g, bool vcont)
	Function reads data from the established connection. More...
int	pack (libgdbr_t *g, const char *msg)

Function Documentation

pack()

int pack	(	libgdbr_t *	g,
		const char *	msg
	)

Definition at line 206 of file packet.c.

                                        {
    int run_len;
    size_t msg_len;
    const char *src;
    char prev;
    if (!g || !msg) {
        return -1;
    }
    msg_len = strlen(msg);
    if (msg_len > g->send_max + 5) {
        eprintf("%s: message too long: %s", __func__, msg);
        return -1;
    }
    if (!g->send_buff) {
        return -1;
    }
    g->send_buff[0] = '$';
    g->send_len = 1;
    src = msg;
    while (*src) {
        if (*src == '#' || *src == '$' || *src == '}') {
            msg_len += 1;
            if (msg_len > g->send_max + 5) {
                eprintf("%s: message too long: %s", __func__, msg);
                return -1;
            }
            g->send_buff[g->send_len++] = '}';
            g->send_buff[g->send_len++] = *src++ ^ 0x20;
            continue;
        }
        g->send_buff[g->send_len++] = *src++;
        if (!g->is_server) {
            continue;
        }
        prev = *(src - 1);
        run_len = 0;
        while (src[run_len] == prev) {
            run_len++;
        }
        if (run_len < 3) { // 3 specified in RSP documentation
            while (run_len--) {
                g->send_buff[g->send_len++] = *src++;
            }
            continue;
        }
        run_len += 29; // Encode as printable character
        if (run_len == 35 || run_len == 36) { // Cannot use '$' or '#'
            run_len = 34;
        } else if (run_len > 126) { // Max printable ascii value
            run_len = 126;
        }
        g->send_buff[g->send_len++] = '*';
        g->send_buff[g->send_len++] = run_len;
        msg_len -= run_len - 27; // 2 chars to encode run length
        src += run_len - 29;
    }
    g->send_buff[g->send_len] = '\0';
    snprintf(g->send_buff + g->send_len, 4, "#%.2x", cmd_checksum(g->send_buff + 1));
    g->send_len += 3;
    return g->send_len;
}

References cmd_checksum(), eprintf, g, msg, snprintf, and src.

Referenced by send_msg(), xprint::to_x(), and xprint::to_x_32().

read_packet()

int read_packet	(	libgdbr_t *	g,
		bool	vcont
	)

Function reads data from the established connection.

Parameters

g	the "instance" of the current libgdbr session
vcont	whether it's called to receive reply to a vcont packet

Returns

a failure code (currently -1) or 0 if call successfully

Definition at line 143 of file packet.c.

                                          {
    struct parse_ctx ctx = { 0 };
    int ret, i;
    if (!g) {
        eprintf("Initialize libgdbr_t first\n");
        return -1;
    }
    g->data_len = 0;
    if (g->read_len > 0) {
        if (unpack(g, &ctx, g->read_len) == 0) {
            // TODO: Evaluate if partial packets are clubbed
            g->data[g->data_len] = '\0';
            if (g->server_debug) {
                eprintf("getpkt (\"%s\");  %s\n", g->data,
                    g->no_ack ? "[no ack sent]" : "[sending ack]");
            }
            return 0;
        }
    }
    g->data_len = 0;
    for (i = 0; i < g->num_retries && !g->isbreaked; vcont ? 0 : i++) {
        ret = rz_socket_ready(g->sock, 0, READ_TIMEOUT);
        if (ret == 0 && !vcont) {
            continue;
        }
        if (ret <= 0) {
            return -1;
        }
        int sz = rz_socket_read(g->sock, (void *)g->read_buff, g->read_max - 1);
        if (sz <= 0) {
            eprintf("%s: read failed\n", __func__);
            return -1;
        }
        ret = unpack(g, &ctx, sz);
        if (ret < 0) {
            eprintf("%s: unpack failed\n", __func__);
            return -1;
        }
        if (!ret) {
            g->data[g->data_len] = '\0';
            if (g->server_debug) {
                eprintf("getpkt (\"%s\");  %s\n", g->data,
                    g->no_ack ? "[no ack sent]" : "[sending ack]");
            }
            return 0;
        }
    }
    return -1;
}

send_packet()

int send_packet

(

libgdbr_t *

g

)

sends a packet sends a packet to the established connection

Parameters

g	the "instance" of the current libgdbr session

Returns

a failure code (currently -1) or 0 if call successfully

Definition at line 193 of file packet.c.

                              {
    if (!g) {
        eprintf("Initialize libgdbr_t first\n");
        return -1;
    }
    if (g->server_debug) {
        g->send_buff[g->send_len] = '\0';
        eprintf("putpkt (\"%s\");  %s\n", g->send_buff,
            g->no_ack ? "[noack mode]" : "[looking for ack]");
    }
    return rz_socket_write(g->sock, g->send_buff, g->send_len);
}

References eprintf, g, and rz_socket_write().

Referenced by send_msg().