socket_proc.c File Reference

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

Go to the source code of this file.

Macros
#define	BUFFER_SIZE   4096

Functions
RZ_API struct rz_socket_proc_t *	rz_socket_proc_open (char *const argv[])
RZ_API int	rz_socket_proc_close (struct rz_socket_proc_t *sp)
RZ_API int	rz_socket_proc_read (RzSocketProc *sp, unsigned char *buf, int len)
RZ_API int	rz_socket_proc_gets (RzSocketProc *sp, char *buf, int size)
RZ_API int	rz_socket_proc_write (RzSocketProc *sp, void *buf, int len)
RZ_API void	rz_socket_proc_printf (RzSocketProc *sp, const char *fmt,...)
RZ_API int	rz_socket_proc_ready (RzSocketProc *sp, int secs, int usecs)

Macro Definition Documentation

BUFFER_SIZE

#define BUFFER_SIZE   4096

Definition at line 15 of file socket_proc.c.

Function Documentation

rz_socket_proc_close()

RZ_API int rz_socket_proc_close

(

struct rz_socket_proc_t *

sp

)

Definition at line 60 of file socket_proc.c.

                                                             {
#if __UNIX__
    /* this is wrong */
    kill(sp->pid, SIGKILL);
    waitpid(sp->pid, NULL, 0); // WNOHANG);
    close(sp->fd0[0]);
    close(sp->fd0[1]);
    // close(sp->fd1[0]);
    close(sp->fd1[1]);
    // sp->fd[0] = -1;
    // sp->fd[1] = -1;
#endif
    return 0;
}

References close, kill, NULL, SIGKILL, and sp.

Referenced by rz_socket_proc_open().

rz_socket_proc_gets()

RZ_API int rz_socket_proc_gets	(	RzSocketProc *	sp,
		char *	buf,
		int	size
	)

Definition at line 82 of file socket_proc.c.

                                                                      {
    RzSocket s;
    s.is_ssl = false;
    s.fd = sp->fd1[0];
    return rz_socket_gets(&s, buf, size);
}

References rz_socket_t::fd, rz_socket_t::is_ssl, rz_socket_gets(), s, and sp.

rz_socket_proc_open()

RZ_API struct rz_socket_proc_t* rz_socket_proc_open

(

char *const

argv[]

)

Definition at line 17 of file socket_proc.c.

                                                                        {
#if __UNIX__ && HAVE_FORK
    RzSocketProc *sp = RZ_NEW(RzSocketProc);
 
    if (!sp) {
        return NULL;
    }
 
    if (rz_sys_pipe(sp->fd0, true) == -1) {
        perror("pipe");
        goto error;
    }
 
    if (rz_sys_pipe(sp->fd1, true) == -1) {
        perror("pipe");
        goto error;
    }
 
    sp->pid = rz_sys_fork();
    switch (sp->pid) {
    case 0:
        close(0);
        dup2(sp->fd0[0], 0);
        close(1);
        dup2(sp->fd1[1], 1);
        rz_sys_execv(argv[0], argv);
        exit(1);
        break;
    case -1:
        perror("fork");
        rz_socket_proc_close(sp);
        goto error;
        // rz_socket_block_time (sp, false, 0);
    }
    return sp;
error:
    free(sp);
    return NULL;
#else
    return NULL;
#endif
}

References argv, close, dup2, error(), test-lz4-list::exit, free(), NULL, RZ_NEW, rz_socket_proc_close(), rz_sys_execv(), rz_sys_fork(), rz_sys_pipe(), and sp.

rz_socket_proc_printf()

RZ_API void rz_socket_proc_printf	(	RzSocketProc *	sp,
		const char *	fmt,
			...
	)

Definition at line 96 of file socket_proc.c.

                                                                          {
    RzSocket s;
    char buf[BUFFER_SIZE];
    va_list ap;
    s.is_ssl = false;
    s.fd = sp->fd0[1];
    if (s.fd != RZ_INVALID_SOCKET) {
        va_start(ap, fmt);
        vsnprintf(buf, BUFFER_SIZE, fmt, ap);
        rz_socket_write(&s, buf, strlen(buf));
        va_end(ap);
    }
}

References BUFFER_SIZE, rz_socket_t::fd, rz_socket_t::is_ssl, RZ_INVALID_SOCKET, rz_socket_write(), s, sp, and vsnprintf.

rz_socket_proc_read()

RZ_API int rz_socket_proc_read	(	RzSocketProc *	sp,
		unsigned char *	buf,
		int	len
	)

Definition at line 75 of file socket_proc.c.

                                                                              {
    RzSocket s;
    s.is_ssl = false;
    s.fd = sp->fd1[0];
    return rz_socket_read(&s, buf, len);
}

References rz_socket_t::fd, rz_socket_t::is_ssl, len, rz_socket_read(), s, and sp.

rz_socket_proc_ready()

RZ_API int rz_socket_proc_ready	(	RzSocketProc *	sp,
		int	secs,
		int	usecs
	)

Definition at line 110 of file socket_proc.c.

                                                                       {
    RzSocket s;
    s.is_ssl = false;
    s.fd = sp->fd1[0];
    return rz_socket_ready(&s, secs, usecs);
}

References rz_socket_t::fd, rz_socket_t::is_ssl, rz_socket_ready(), s, and sp.

rz_socket_proc_write()

RZ_API int rz_socket_proc_write	(	RzSocketProc *	sp,
		void *	buf,
		int	len
	)

Definition at line 89 of file socket_proc.c.

                                                                      {
    RzSocket s;
    s.is_ssl = false;
    s.fd = sp->fd0[1];
    return rz_socket_write(&s, buf, len);
}

References rz_socket_t::fd, rz_socket_t::is_ssl, len, rz_socket_write(), s, and sp.