transport.c File Reference

#include <rz_th.h>
#include "transport.h"

Go to the source code of this file.

Functions
io_desc_t *	io_desc_new (io_backend_t *iob, void *fp)
int	iob_write (io_desc_t *desc, const uint8_t *buf, const uint32_t buf_len)
int	iob_read (io_desc_t *desc, uint8_t *buf, const uint32_t buf_len)

Function Documentation

io_desc_new()

io_desc_t* io_desc_new	(	io_backend_t *	iob,
		void *	fp
	)

Definition at line 7 of file transport.c.

                                                    {
    io_desc_t *desc = RZ_NEW0(io_desc_t);
    if (desc) {
        desc->iob = iob;
        desc->fp = fp;
    }
    return desc;
}

References desc, and RZ_NEW0.

Referenced by __open().

iob_read()

int iob_read	(	io_desc_t *	desc,
		uint8_t *	buf,
		const uint32_t	buf_len
	)

Definition at line 37 of file transport.c.

                                                                    {
    uint32_t done;
    static RzThreadLock *lock = NULL;
    if (!lock) {
        lock = rz_th_lock_new(true);
    }
    if (!desc || !desc->iob || !desc->fp) {
        return E_NOIF;
    }
    rz_th_lock_enter(lock);
    for (done = 0; done < buf_len;) {
        int ret = desc->iob->read(desc->fp, buf + done, buf_len - done, 100);
        if (ret < 0) {
            break;
        }
        done += ret;
    }
    rz_th_lock_leave(lock);
    return done;
}

References buf_len, desc, done, E_NOIF, lock(), NULL, rz_th_lock_enter(), rz_th_lock_leave(), and rz_th_lock_new().

Referenced by kd_read_packet().

iob_write()

int iob_write	(	io_desc_t *	desc,
		const uint8_t *	buf,
		const uint32_t	buf_len
	)

Definition at line 16 of file transport.c.

                                                                           {
    uint32_t done;
    static RzThreadLock *lock = NULL;
    if (!lock) {
        lock = rz_th_lock_new(true);
    }
    if (!desc || !desc->iob || !desc->fp) {
        return E_NOIF;
    }
    rz_th_lock_enter(lock);
    for (done = 0; done < buf_len;) {
        int ret = desc->iob->write(desc->fp, buf + done, buf_len - done, 100);
        if (ret < 1) {
            break;
        }
        done += ret;
    }
    rz_th_lock_leave(lock);
    return done;
}

References buf_len, desc, done, E_NOIF, lock(), NULL, rz_th_lock_enter(), rz_th_lock_leave(), and rz_th_lock_new().

Referenced by kd_send_ctrl_packet(), kd_send_data_packet(), winkd_break(), and winkd_sync().