packet.h File Reference

#include <stdint.h>
#include <string.h>
#include <stdlib.h>
#include "libqnxr.h"
#include <stdio.h>
#include <unistd.h>

Go to the source code of this file.

Functions
int	qnxr_send_nak (libqnxr_t *instance)
int	qnxr_send_ch_reset (libqnxr_t *instance)
int	qnxr_send_ch_debug (libqnxr_t *instance)
int	qnxr_send_ch_text (libqnxr_t *instance)
int	qnxr_send_packet (libqnxr_t *instance)
	sends a packet sends a packet to the established connection More...
int	qnxr_read_packet (libqnxr_t *instance)
	Function reads data from the established connection. More...

Function Documentation

qnxr_read_packet()

int qnxr_read_packet

(

libqnxr_t *

instance

)

Function reads data from the established connection.

Parameters

instance

the "instance" of the current libqnxr session

Returns

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

Definition at line 65 of file packet.c.

                                   {
    int ret;
 
    if (!g) {
        eprintf("Initialize libqnxr_t first\n");
        return -1;
    }
    g->data_len = 0;
 
    // read from network if we've exhausted our buffer
    // or the buffer is empty
    if (g->read_len == 0 || g->read_ptr == g->read_len) {
        while (true) {
            int ret = rz_socket_ready(g->sock, 0, READ_TIMEOUT);
            if (ret < 0) {
                if (errno == EINTR)
                    continue;
                else
                    return -1;
            }
 
            g->read_ptr = 0;
            g->read_len = rz_socket_read(g->sock, (void *)g->read_buff,
 
                DS_DATA_MAX_SIZE * 2);
            if (g->read_len <= 0) {
                g->read_len = 0;
                eprintf("%s: read failed\n", __func__);
                return -1;
            }
 
            break;
        }
    }
 
    ret = unpack(g);
    if (ret < 0) {
        eprintf("%s: unpack failed\n", __func__);
        return -1;
    }
 
    if (g->data_len >= sizeof(struct DShdr)) {
        if (g->recv.pkt.hdr.channel)
            g->channelrd = g->recv.pkt.hdr.channel;
    } else if (g->data_len >= 1) {
        if (g->recv.data[0] == SET_CHANNEL_NAK) {
            eprintf("%s: NAK received\n", __func__);
            g->channelrd = SET_CHANNEL_NAK;
            return -1;
        }
        if (g->recv.data[0] <= SET_CHANNEL_TEXT)
            g->channelrd = g->recv.data[0];
    }
 
    if (!ret) {
        // Skip the checksum
        return g->data_len - 1;
    }
 
    return -1;
}

References DS_DATA_MAX_SIZE, EINTR, eprintf, g, READ_TIMEOUT, rz_socket_read(), rz_socket_ready(), SET_CHANNEL_NAK, SET_CHANNEL_TEXT, and unpack().

Referenced by nto_send(), and qnxr_wait().

qnxr_send_ch_debug()

int qnxr_send_ch_debug

(

libqnxr_t *

instance

)

Definition at line 135 of file packet.c.

                                     {
    return rz_socket_write(g->sock, ch_debug_packet, sizeof(ch_debug_packet));
}

References ch_debug_packet, g, and rz_socket_write().

Referenced by qnxr_send_packet(), and qnxr_wait().

qnxr_send_ch_reset()

int qnxr_send_ch_reset

(

libqnxr_t *

instance

)

Definition at line 131 of file packet.c.

                                     {
    return rz_socket_write(g->sock, ch_reset_packet, sizeof(ch_reset_packet));
}

References ch_reset_packet, g, and rz_socket_write().

Referenced by qnxr_connect().

qnxr_send_ch_text()

int qnxr_send_ch_text

(

libqnxr_t *

instance

)

Definition at line 139 of file packet.c.

                                    {
    return rz_socket_write(g->sock, ch_text_packet, sizeof(ch_text_packet));
}

References ch_text_packet, g, and rz_socket_write().

Referenced by qnxr_send_packet().

qnxr_send_nak()

int qnxr_send_nak

(

libqnxr_t *

instance

)

Definition at line 127 of file packet.c.

                                {
    return rz_socket_write(g->sock, nak_packet, sizeof(nak_packet));
}

References g, nak_packet, and rz_socket_write().

qnxr_send_packet()

int qnxr_send_packet

(

libqnxr_t *

instance

)

sends a packet sends a packet to the established connection

Parameters

instance

the "instance" of the current libqnxr session

Returns

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

Definition at line 143 of file packet.c.

                                   {
    if (!g) {
        eprintf("Initialize libqnxr_t first\n");
        return -1;
    }
 
    int i;
    ut8 csum = 0;
    char *p;
 
    p = g->send_buff;
    *p++ = FRAME_CHAR;
 
    for (i = 0; i < g->send_len; i++) {
        ut8 c = g->tran.data[i];
        csum += c;
 
        switch (c) {
        case FRAME_CHAR:
        case ESC_CHAR:
            *p++ = ESC_CHAR;
            c ^= 0x20;
            break;
        }
        *p++ = c;
    }
 
    csum ^= 0xff;
    switch (csum) {
    case FRAME_CHAR:
    case ESC_CHAR:
        *p++ = ESC_CHAR;
        csum ^= 0x20;
        break;
    }
    *p++ = csum;
    *p++ = FRAME_CHAR;
 
    if (g->channelwr != g->tran.pkt.hdr.channel) {
        switch (g->tran.pkt.hdr.channel) {
        case SET_CHANNEL_TEXT:
            qnxr_send_ch_text(g);
            break;
        case SET_CHANNEL_DEBUG:
            qnxr_send_ch_debug(g);
            break;
        }
        g->channelwr = g->tran.pkt.hdr.channel;
    }
 
    return rz_socket_write(g->sock, g->send_buff, p - g->send_buff);
}

References c, eprintf, ESC_CHAR, FRAME_CHAR, g, i, p, qnxr_send_ch_debug(), qnxr_send_ch_text(), rz_socket_write(), SET_CHANNEL_DEBUG, and SET_CHANNEL_TEXT.

Referenced by nto_send(), qnxr_stop(), and qnxr_wait().