socket_rap_server.c File Reference

#include <rz_socket.h>
#include <rz_util.h>

Go to the source code of this file.

Functions
RZ_API RzSocketRapServer *	rz_socket_rap_server_new (bool use_ssl, const char *port)
RZ_API RzSocketRapServer *	rz_socket_rap_server_create (const char *pathname)
RZ_API void	rz_socket_rap_server_free (RzSocketRapServer *s)
RZ_API bool	rz_socket_rap_server_listen (RzSocketRapServer *s, const char *certfile)
RZ_API RzSocket *	rz_socket_rap_server_accept (RzSocketRapServer *s)
RZ_API bool	rz_socket_rap_server_continue (RzSocketRapServer *s)

Function Documentation

rz_socket_rap_server_accept()

RZ_API RzSocket* rz_socket_rap_server_accept

(

RzSocketRapServer *

s

)

Definition at line 48 of file socket_rap_server.c.

                                                                   {
    rz_return_val_if_fail(s && s->fd, NULL);
    return rz_socket_accept(s->fd);
}

References rz_socket_t::fd, NULL, rz_return_val_if_fail, rz_socket_accept(), and s.

rz_socket_rap_server_continue()

RZ_API bool rz_socket_rap_server_continue

(

RzSocketRapServer *

s

)

Definition at line 53 of file socket_rap_server.c.

                                                                {
    rz_return_val_if_fail(s && s->fd, false);
 
    int i;
    char *ptr = NULL;
 
    if (!rz_socket_is_connected(s->fd)) {
        return false;
    }
    rz_socket_read_block(s->fd, s->buf, 1);
    switch (s->buf[0]) {
    case RAP_PACKET_OPEN:
        rz_socket_read_block(s->fd, &s->buf[1], 2);
        rz_socket_read_block(s->fd, &s->buf[3], (int)s->buf[2]);
        {
            int fd = s->open(s->user, (const char *)&s->buf[3], (int)s->buf[1], 0);
            s->buf[0] = RAP_PACKET_OPEN | RAP_PACKET_REPLY;
            eprintf("REPLY BACK %d\n", fd);
            rz_write_be32(s->buf + 1, fd);
        }
        rz_socket_write(s->fd, s->buf, 5);
        rz_socket_flush(s->fd);
        break;
    case RAP_PACKET_READ:
        rz_socket_read_block(s->fd, &s->buf[1], 4);
        i = rz_read_be32(&s->buf[1]);
        if (i > RAP_PACKET_MAX || i < 0) {
            i = RAP_PACKET_MAX;
        }
        s->read(s->user, &s->buf[5], i);
        s->buf[0] = RAP_PACKET_READ | RAP_PACKET_REPLY;
        rz_socket_write(s->fd, s->buf, i + 5);
        rz_socket_flush(s->fd);
        break;
    case RAP_PACKET_WRITE:
        rz_socket_read_block(s->fd, s->buf + 1, 4);
        i = rz_read_be32(s->buf + 1);
        if (i > RAP_PACKET_MAX || i < 0) {
            i = RAP_PACKET_MAX;
        }
        rz_socket_read_block(s->fd, s->buf + 5, i);
        rz_write_be32(s->buf + 1, s->write(s->user, s->buf + 5, i));
        s->buf[0] = RAP_PACKET_WRITE | RAP_PACKET_REPLY;
        rz_socket_write(s->fd, s->buf, 5);
        rz_socket_flush(s->fd);
        break;
    case RAP_PACKET_SEEK: {
        rz_socket_read_block(s->fd, &s->buf[1], 9);
        int whence = s->buf[0];
        ut64 offset = rz_read_be64(s->buf + 1);
        offset = s->seek(s->user, offset, whence);
        /* prepare reply */
        s->buf[0] = RAP_PACKET_SEEK | RAP_PACKET_REPLY;
        rz_write_be64(s->buf + 1, offset);
        rz_socket_write(s->fd, s->buf, 9);
        rz_socket_flush(s->fd);
    } break;
    case RAP_PACKET_CMD:
        rz_socket_read_block(s->fd, &s->buf[1], 4);
        i = rz_read_be32(&s->buf[1]);
        if (rz_socket_read_block(s->fd, &s->buf[5], i) > 0) {
            ptr = s->cmd(s->user, (const char *)s->buf + 5);
            i = (ptr) ? strlen(ptr) + 1 : 0;
            rz_write_be32(&s->buf[1], i);
            s->buf[0] = RAP_PACKET_CMD | RAP_PACKET_REPLY;
            rz_socket_write(s->fd, s->buf, 5);
            if (i) {
                rz_socket_write(s->fd, ptr, i);
            }
            rz_socket_flush(s->fd);
            RZ_FREE(ptr);
        }
        break;
    case RAP_PACKET_CLOSE:
        rz_socket_read_block(s->fd, &s->buf[1], 4);
        i = rz_read_be32(&s->buf[1]);
        s->close(s->user, i);
        s->buf[0] = RAP_PACKET_CLOSE | RAP_PACKET_REPLY;
        rz_socket_write(s->fd, s->buf, 5);
        rz_socket_flush(s->fd);
        break;
    default:
        eprintf("unknown command 0x%02x\n", (ut8)(s->buf[0] & 0xff));
        rz_socket_close(s->fd);
        return false;
    }
    return true;
}

References eprintf, fd, rz_socket_t::fd, i, NULL, RAP_PACKET_CLOSE, RAP_PACKET_CMD, RAP_PACKET_MAX, RAP_PACKET_OPEN, RAP_PACKET_READ, RAP_PACKET_REPLY, RAP_PACKET_SEEK, RAP_PACKET_WRITE, RZ_FREE, rz_read_be32(), rz_read_be64(), rz_return_val_if_fail, rz_socket_close(), rz_socket_flush(), rz_socket_is_connected(), rz_socket_read_block(), rz_socket_write(), rz_write_be32(), rz_write_be64(), s, and ut64().

rz_socket_rap_server_create()

RZ_API RzSocketRapServer* rz_socket_rap_server_create

(

const char *

pathname

)

Definition at line 23 of file socket_rap_server.c.

                                                                            {
    rz_return_val_if_fail(pathname, NULL);
    if (strlen(pathname) < 11) {
        return NULL;
    }
    if (strncmp(pathname, "rap", 3)) {
        return NULL;
    }
    bool is_ssl = (pathname[3] == 's');
    const char *port = &pathname[7 + is_ssl];
    return rz_socket_rap_server_new(is_ssl, port);
}

References NULL, pathname, rz_return_val_if_fail, and rz_socket_rap_server_new().

rz_socket_rap_server_free()

RZ_API void rz_socket_rap_server_free

(

RzSocketRapServer *

s

)

Definition at line 36 of file socket_rap_server.c.

                                                            {
    if (s) {
        rz_socket_free(s->fd);
        free(s);
    }
}

References rz_socket_t::fd, free(), rz_socket_free(), and s.

rz_socket_rap_server_listen()

RZ_API bool rz_socket_rap_server_listen	(	RzSocketRapServer *	s,
		const char *	certfile
	)

Definition at line 43 of file socket_rap_server.c.

                                                                                    {
    rz_return_val_if_fail(s && s->port && *s->port, false);
    return rz_socket_listen(s->fd, s->port, certfile);
}

References rz_socket_t::fd, rz_socket_t::port, rz_return_val_if_fail, rz_socket_listen(), and s.

rz_socket_rap_server_new()

RZ_API RzSocketRapServer* rz_socket_rap_server_new	(	bool	use_ssl,
		const char *	port
	)

Definition at line 8 of file socket_rap_server.c.

                                                                                   {
    rz_return_val_if_fail(port, NULL);
    RzSocketRapServer *s = RZ_NEW0(RzSocketRapServer);
    if (s) {
        s->port = strdup(port);
        s->fd = rz_socket_new(use_ssl);
        if (s->fd) {
            return s;
        }
        rz_socket_free(s->fd);
        free(s);
    }
    return NULL;
}

References rz_socket_t::fd, free(), NULL, rz_socket_t::port, RZ_NEW0, rz_return_val_if_fail, rz_socket_free(), rz_socket_new(), s, and strdup().

Referenced by rz_socket_rap_server_create().