tokkee.org

Merged branch 'master' of git://git.tokkee.org/sysdb.

store_test: Added a test for tojson().

store: tojson(): Comma-separate multiple hosts.

Run all tests using TZ=UTC.

This will ensure consistent time formatting.

t/core/store_test: Added initial tests for the object store.

For now, testing basic insertion operations.

store: Don't try to update non-existent attributes.

object_test: Added test for sdb_object_cmp_by_name().

object_test: Added tests for wrapped object and memory management.

Updated various copyright notices to 2012-2013.

sysdbd: Changed -d option to -D and default to daemonizing the process.

It doesn't really matter much what the default is but -d should be reserved
for debugging.

sysdbd: Fixed a typo.

sysdb: Added a initial client implementation.

For now, this is basically a placeholder.

client: Let client_recv() read a full response.

… and block if necessary. There is no reason that a client should handle
partial responses.

client: Let client_recv() not pass unparsed status,len to the caller.

strbuf_test: Added skip() tests using various offsets.

util strbuf: Let skip() support an offset.

That is, add support for removing bytes from the middle of the buffer.

Added version functions to libsysdbclient.

This is basically the same as the sdb_version() functions but to be used only
in the client lib.

Link proto and strbuf utilities into libsysdbclient.

Added initial client library implementation.

For now, this includes a network client only.

utils proto: Added sdb_proto_get_int().

This function “recieves” a 32bit integer from a string buffer and converts it
from network to host byte order.

utils proto: Added utility functions for protocol handling.

So far, added functions to send data to an open file descriptor and use that
in the frontend code.

Merged branch 'master' of git://git.tokkee.org/sysdb.

Conflicts:
t/Makefile.am
t/libsysdb_test.c
t/libsysdb_test.h

.gitignore: Added check test logs.

t/: Added initial tests for core/object.

object: Be more specific about requirements for the 'destroy' callback.

object: Ensure that a type's destroy callback is called if init fails.

Else, failed init may leak memory.

frontend: Unified error reporting to the client.

Keep track of the latest error in a connection object and report that back to
the client in case a command handler failed.

store: Let tojson() embed errors into JSON rather than aborting.

Renamed sdb_session_start() to sdb_fe_session_start().

frontend: Added a simple 'LIST' command.

This command sends a JSON representation of the whole store to the client.

store: Replaced store_dump() with store_tojson().

The new function serializes the store as JSON and writes the result to a
string buffer.

strbuf test: Further extended the incremental append test.

utils strbuf: Handle nul-byte correctly.

A corner-case was not handled correctly before: when writing just enough
characters to the buffer that it would then be full, a resize was attempted
without changing the size of the buffer, leading to an endless loop in
vappend(). This was caused by not taking into account the space required for
the trailing nul-byte.

A test-case which exposes this problem has also been added.

src/Makefile: Install all public header files.

frontend: Moved all connection handling operations into connection.c.

connection_obj_t was merged into sdb_conn_t which now inherits from
sdb_object_t. The connection object is now private to the library and defined
in the new header file connection-private.h.

frontend: Report back invalid commands.

frontend: Handle STARTUP and PING commands.

Implemented an initial, trivial "framework" for session handling /
authentication. Simply send back OK status for now.

Fixed preconditions for initialization and handling of commands.

frontend: Moved connection init/close to connection.c.

frontend/sock: Fixed an info message.

;-)

frontend/connection: Reset state after handling a command.

frontend/connection: Try to handle as much as possible in read().

Else, we might have to wait for more data before being able to process a
command.

frontend: Added module for generic connection handling.

Merged branch 'master' of git://git.tokkee.org/sysdb.

socket frontend: Notify about incomplete commands before closing connections.

utils strbuf: Advance buffer position in sdb_strbuf_read().

socket frontend: Read incoming commands into a buffer.

Handle commands once all of them has been read. Give preference to reading
data over handling a command in order not to block clients or exhaust
operating system buffers.

strbuf_test: Added some NULL tests.

These are mainly to check that the functions do no segfault but report an
error.

strbuf_test: Added tests for len / nil-termination after skip().

utils strbuf: Added sdb_strbuf_skip().

This function may be used to remove bytes and the beginning of the buffer.

socket frontend: Merged connection_obj_t and connection_t.

There's no reason for two separate structs.

utils strbuf: Added sdb_strbuf_read().

This function may be used to read from an open file into the buffer.

utils strbuf: Added memcpy and memappend functions.

These functions may be used to write arbitrary data to a string buffer.

socket frontend: Cleaned up main handler loop a bit.

socket frontend: Try to reopen a connection if it has been closed.

socket frontend: Close sockets on error as well.

socket frontend: Close listening sockets before returning.

Also, cleaned up listener handling a bit.

socket frontend: Disallow duplicate listen_and_serve() calls.

… and fixed a memory leak.

socket frontend: Don't use UTF-8 in comments ;-)

socket frontend: Let handler read from open connection.

Close the connection on EOF and pass back the connection to the main loop in
case no data is currently available (read() would block).

socket frontend: Pass socket object to handler threads.

This will allow them to pass back connections to the main loop.

socket frontend: Renamed accept_connection → connection_accept.

socket frontend: Use nonblocking I/O for open connections.

socket frontend: Split connection accepting into its own function.

socket frontend: Manage open connections in listen_and_serve().

For that purpose, added a new object data type wrapping a connection. All open
connections are managed in a linked-link in the socket object. The main loop
now also waits data to be available on an open connection and then passed on
the connection object to the connection handler thread which is then supposed
to handle requests (not implemented yet).

channel_test: Updated timeout check according to latest changes.

I.e. check errno rather than the return value.

utils llist: Added sdb_llist_iter_remove_current().

This function may be used to remove the current (the one returned by the last
sdb_llist_iter_get_next() call) iterator value from the list.

Note, that this function is not safe if another iterator is used in parallel
at the same time.

Made log prefixes slightly more generic.

Changed "plugin" to "core" and "sock" to "frontend". Those names better
identify the context in which the error happened.

daemon: Terminate backend thread after frontends have stopped.

daemon: Exit if adding a listener fails.

socket frontend: Improved error reporting.

daemon: Added "Listen" config option.

The main thread listens on all configured addresses and serves requests
through the frontend socket module. The backend collector loop now runs in its
own background thread.

frontend: Use channel shutdown to synchronize handler thread shutdown.

This allows the handler to fully control the shutdown procedure.
pthread_cancel did not play well with pthread_cond_*wait in multiple threads
and the respective locked mutex.

utils channel: Added sdb_channel_shutdown().

This function initiates a shutdown of the channel, forbidding any subsequent
writes. However, readers are still able to empty the buffer. Then, EBADF will
be returned through errno. This allows for graceful shutdowns.

utils channel: Normalize time before passing it to phtread_cond_timedwait.

utils channel: Unlock mutex before returning on error.

utils channel: Update timeout in channel_select when needed.

utils channel: Let channel_select() set errno.

utils channel: Changed abstime argument to a timeout.

frontend/sock: Added loop control to the socket handler.

Added framework for frontend connection handling.

frontend/sock supports UNIX domain sockets for now. It doesn't do much expect
for managing listening sockets and accepting connections on them which are
then handled in the background. So far, each connection is closed right away.

t/utils/channel_test: Added a test-case for sdb_channel_select().

utils channel: Added sdb_channel_select().

This function behaves similar to select(2) providing to passively block on a
channel operation until it becomes ready for reading and / or writing.
Optionally, a deadline may be specified.

utils/channel: Use a mutex instead of a rwlock.

All access to the channel needs to be fully synchronized.

t/utils/channel_test: Added some more write/read tests.

t/: Added tests for the channel implementation.

utils/channel: Added an asynchronous I/O multiplexer.

A channel is a buffered pipe supporting multiple parallel readers and writers.

configure: Don't fail if CHECK is not available.

strbuf.h: Include unistd.h.

Required for ssize_t on GCC 4.4.

store: Make sure not to store duplicate host entries.

daemon: Treat parser errors different from daemon/libsysdb errors.

plugin: Unregister all callbacks if module/plugin init failed.

utils llist: Fixed a segfault in functions doing lookups.

utils llist: Made lookup's user-data a constant pointer.

utils llist: Added sdb_llist_remove().

utils llist: Updated documentation.

utils llist: Added lookup callback type to be used for llist_search.

Lookups should be more flexible than comparing two objects.

utils llist: Added sdb_llist_cmp_cb type.

This is to make sure that comparators always use the same signature.

plugin: Removed sdb_ prefix from private functions.

plugin: Store real plugin name and filename in the context.

plugin: Store plugin info attributes in the plugin context.