worker.c File Reference

#include <stdarg.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <string.h>
#include <stdio.h>
#include <search.h>
#include "class.h"
#include "stream.h"
#include "hash.h"
#include "queue.h"
#include "http/worker.h"
#include "http/parser.h"
#include "http/writer.h"
#include "utils/memory.h"
#include "interface/subject.h"
#include "interface/observer.h"

Include dependency graph for worker.c:

Go to the source code of this file.

Macros
#define	_GNU_SOURCE

Functions
static int	httpWorkerCtor (void *_this, va_list *params)
static void	httpWorkerDtor (void *_this)
static void	httpWorkerClone (void *_this, void *_base)
ssize_t	httpWorkerProcess (void *, Stream)
ssize_t	httpWorkerWrite (void *, Stream)
static void	httpWorkerDetach (void *_this, void *adapter)
static void	httpWorkerAttach (void *_this, void *adapter)
static void	httpWorkerNotify (void *_this)
	INIT_IFACE (Class, httpWorkerCtor, httpWorkerDtor, httpWorkerClone)
	INIT_IFACE (StreamReader, httpWorkerProcess)
	INIT_IFACE (StreamWriter, httpWorkerWrite)
	INIT_IFACE (Subject, httpWorkerAttach, httpWorkerDetach, httpWorkerNotify)
	CREATE_CLASS (HttpWorker, NULL, IFACE(Class), IFACE(StreamReader), IFACE(StreamWriter), IFACE(Subject))

Detailed Description

Author

Georg Hopp

Copyright

Copyright © 2012 Georg Hopp

This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.

You should have received a copy of the GNU General Public License along with this program. If not, see http://www.gnu.org/licenses/.

Definition in file worker.c.

Macro Definition Documentation

#define _GNU_SOURCE

Definition at line 23 of file worker.c.

Function Documentation

CREATE_CLASS	(	HttpWorker	,
		NULL	,
		IFACE(Class)	,
		IFACE(StreamReader)	,
		IFACE(StreamWriter)	,
		IFACE(Subject)
	)

static void httpWorkerAttach ( void *  _this, void *  adapter  )

static

Definition at line 139 of file worker.c.

References httpWorkerDetach().

{
    HttpWorker this = (HttpWorker)_this;

    /*
     * right now only one adapter is allowed and the last
     * added will be used....all others will be deleted in
     * assumption that no other handle does exist anymore
     * (because it was added as an adapter and thus is good
     * for nothing else.)
     */
    httpWorkerDetach(_this, adapter);

    this->application_adapter = adapter;
}

Here is the call graph for this function:

static void httpWorkerClone ( void *  _this, void *  _base  )

static

Definition at line 90 of file worker.c.

References asset_pool.

{
    HttpWorker this = _this;
    HttpWorker base = _base;

    this->asset_pool          = base->asset_pool;
    this->application_adapter = base->application_adapter;

    this->additional_headers = new(Queue);

    this->parser = new(HttpParser, base->pbuf);
    /*
     * I am pretty sure that it is not neccessary to have a
     * separeate writer for each connection...
     * Right now I leave it that way.
     * TODO check this.
     * OK some facts:
     * - the stream as well as the worker are associated
     *   to the filehandle within the server.
     * - the response queue is located within the writer.
     *   (this might be wrong...the response queue should
     *   be part of the worker. That way I could give it
     *   into the writer when writing. That way only one
     *   instance of the writer might be possible...)
     *   NO, the previous statement is wrong...this would
     *   involve much more organization overhead within
     *   the writer...queue change and such...
     *   At the end I think it might be best to leave it as
     *   it is.
     */
    this->writer = new(HttpWriter);
}

static int httpWorkerCtor ( void *  _this, va_list *  params  )

static

Definition at line 47 of file worker.c.

References asset_pool, memMalloc(), and PARSER_MAX_BUF.

{
    HttpWorker this = _this;
    char *     id   = va_arg(*params, char *);
    char       cbuf_id[100];

    this->id  = memMalloc(strlen(id) + 1);
    strcpy(this->id, id);

    this->asset_pool = new(Hash);

    sprintf(cbuf_id, "%s_%s", "parser", id);
    this->pbuf   = new(Cbuf, cbuf_id, PARSER_MAX_BUF);

    this->additional_headers = new(Queue);

    this->parser = new(HttpParser, this->pbuf);
    this->writer = new(HttpWriter);

    return 0;
}

Here is the call graph for this function:

static void httpWorkerDetach ( void *  _this, void *  adapter  )

static

Definition at line 128 of file worker.c.

Referenced by httpWorkerAttach().

{
    HttpWorker this = (HttpWorker)_this;

    if (NULL != this->application_adapter) {
        delete(this->application_adapter);
    }
}

Here is the caller graph for this function:

static void httpWorkerDtor ( void *  _this )

static

< cloned workers have NULL, so delete won't do anything

Definition at line 71 of file worker.c.

References asset_pool, and MEM_FREE.

{
    HttpWorker this = _this;

    MEM_FREE(this->id);

    delete(this->additional_headers);

    delete(this->parser);
    delete(this->writer);

    if (NULL != this->pbuf) {
        delete(this->asset_pool);
        delete(this->pbuf); //!< cloned workers have NULL, so delete won't do anything
    }
}

static void httpWorkerNotify ( void *  _this )

static

Definition at line 157 of file worker.c.

References observerUpdate().

{
    HttpWorker this = (HttpWorker)_this;

    observerUpdate(this->application_adapter, _this);
}

Here is the call graph for this function:

ssize_t httpWorkerProcess	(	void *	,
		Stream
	)

ssize_t httpWorkerWrite	(	void *	,
		Stream
	)

INIT_IFACE	(	Class	,
		httpWorkerCtor	,
		httpWorkerDtor	,
		httpWorkerClone
	)

INIT_IFACE	(	StreamReader	,
		httpWorkerProcess
	)

INIT_IFACE	(	StreamWriter	,
		httpWorkerWrite
	)

INIT_IFACE	(	Subject	,
		httpWorkerAttach	,
		httpWorkerDetach	,
		httpWorkerNotify
	)