main.c File Reference

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <uv.h>

Go to the source code of this file.

Classes
struct	write_req_t

Macros
#define	PIPENAME   "/tmp/echo.sock"

Functions
void	free_write_req (uv_write_t *req)
void	alloc_buffer (uv_handle_t *handle, size_t suggested_size, uv_buf_t *buf)
void	echo_write (uv_write_t *req, int status)
void	echo_read (uv_stream_t *client, ssize_t nread, const uv_buf_t *buf)
void	on_new_connection (uv_stream_t *server, int status)
void	remove_sock (int sig)
int	main ()

Variables
uv_loop_t *	loop

Macro Definition Documentation

PIPENAME

#define PIPENAME   "/tmp/echo.sock"

Definition at line 9 of file main.c.

Function Documentation

alloc_buffer()

void alloc_buffer	(	uv_handle_t *	handle,
		size_t	suggested_size,
		uv_buf_t *	buf
	)

Definition at line 25 of file main.c.

                                                                             {
  buf->base = malloc(suggested_size);
  buf->len = suggested_size;
}

References malloc().

echo_read()

void echo_read	(	uv_stream_t *	client,
		ssize_t	nread,
		const uv_buf_t *	buf
	)

Definition at line 37 of file main.c.

                                                                        {
    if (nread > 0) {
        write_req_t *req = (write_req_t*) malloc(sizeof(write_req_t));
        req->buf = uv_buf_init(buf->base, nread);
        uv_write((uv_write_t*) req, client, &req->buf, 1, echo_write);
        return;
    }
 
    if (nread < 0) {
        if (nread != UV_EOF)
            fprintf(stderr, "Read error %s\n", uv_err_name(nread));
        uv_close((uv_handle_t*) client, NULL);
    }
 
    free(buf->base);
}

References echo_write(), free(), malloc(), NULL, req, uv_buf_init(), uv_close(), uv_err_name(), and uv_write().

Referenced by on_new_connection().

echo_write()

void echo_write	(	uv_write_t *	req,
		int	status
	)

Definition at line 30 of file main.c.

                                             {
    if (status < 0) {
        fprintf(stderr, "Write error %s\n", uv_err_name(status));
    }
    free_write_req(req);
}

References free_write_req(), req, status, and uv_err_name().

Referenced by echo_read().

free_write_req()

void free_write_req

(

uv_write_t *

req

)

Definition at line 19 of file main.c.

                                     {
    write_req_t *wr = (write_req_t*) req;
    free(wr->buf.base);
    free(wr);
}

References uv_buf_t::base, write_req_t::buf, free(), and req.

Referenced by echo_write(), on_file_write(), and on_stdout_write().

main()

int main

(

void

)

Definition at line 76 of file main.c.

           {
    loop = uv_default_loop();
 
    uv_pipe_t server;
    uv_pipe_init(loop, &server, 0);
 
    signal(SIGINT, remove_sock);
 
    int r;
    if ((r = uv_pipe_bind(&server, PIPENAME))) {
        fprintf(stderr, "Bind error %s\n", uv_err_name(r));
        return 1;
    }
    if ((r = uv_listen((uv_stream_t*) &server, 128, on_new_connection))) {
        fprintf(stderr, "Listen error %s\n", uv_err_name(r));
        return 2;
    }
    return uv_run(loop, UV_RUN_DEFAULT);
}

References loop, on_new_connection(), PIPENAME, r, remove_sock(), signal, uv_default_loop(), uv_err_name(), uv_listen(), uv_pipe_bind(), uv_pipe_init(), uv_run(), and UV_RUN_DEFAULT.

on_new_connection()

void on_new_connection	(	uv_stream_t *	server,
		int	status
	)

Definition at line 54 of file main.c.

                                                        {
    if (status == -1) {
        // error!
        return;
    }
 
    uv_pipe_t *client = (uv_pipe_t*) malloc(sizeof(uv_pipe_t));
    uv_pipe_init(loop, client, 0);
    if (uv_accept(server, (uv_stream_t*) client) == 0) {
        uv_read_start((uv_stream_t*) client, alloc_buffer, echo_read);
    }
    else {
        uv_close((uv_handle_t*) client, NULL);
    }
}

References alloc_buffer(), echo_read(), loop, malloc(), NULL, status, uv_accept(), uv_close(), uv_pipe_init(), and uv_read_start().

remove_sock()

void remove_sock

(

int

sig

)

Definition at line 70 of file main.c.

                          {
    uv_fs_t req;
    uv_fs_unlink(loop, &req, PIPENAME, NULL);
    exit(0);
}

References test-lz4-list::exit, loop, NULL, PIPENAME, req, and uv_fs_unlink().

Referenced by main().

Variable Documentation

loop

uv_loop_t* loop

Definition at line 12 of file main.c.