From b3f81a786e586c61cb4cc1fff9dd2adf93ffefbc Mon Sep 17 00:00:00 2001 From: Alexander Vdolainen Date: Sun, 14 Feb 2016 23:39:47 +0200 Subject: [PATCH] just added stream.c skel - stream implementation; --- lib/Makefile.am | 3 +- lib/stream.c | 114 ++++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 116 insertions(+), 1 deletion(-) create mode 100644 lib/stream.c diff --git a/lib/Makefile.am b/lib/Makefile.am index d9f4688..c0d2b0c 100644 --- a/lib/Makefile.am +++ b/lib/Makefile.am @@ -14,7 +14,8 @@ lib_LTLIBRARIES = libsxmp.la libsxmp_la_SOURCES = \ - sxmplv2.c link.c channel.c message.c rpc.c uuid.c + sxmplv2.c link.c channel.c message.c rpc.c \ + uuid.c stream.c libsxmp_la_LDFLAGS = diff --git a/lib/stream.c b/lib/stream.c new file mode 100644 index 0000000..b308ef0 --- /dev/null +++ b/lib/stream.c @@ -0,0 +1,114 @@ +/* + * Secure X Message Passing Library v2 implementation. + * (sxmplv2) it superseed all versions before due to the: + * - memory consumption + * - new features such as pulse emitting + * - performance optimization + * + * (c) Askele Group 2013-2015 + * (c) Alexander Vdolainen 2013-2015,2016 + * + * libsxmp is free software: you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as published + * by the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * libsxmp 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 Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public License + * along with this program. If not, see ."; + * + */ + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#include +#include +#include + +#include +#include +#include + +#include +#include + +#include "internal.h" + +/* + * NOTE: sxstream operations (except opening process i.e. few threads + * can open different streams) are NOT _thread-safe_, please + * care about that in your own application. + */ +sxstream_t *sxstream_open(sxlink_t *link, const char *opt, int stid, int flags) +{ + return NULL; +} + +sxstream_t *sxstream_openwch(sxlink_t *link, sxchnl_t *channel, const char *opt, + int stid, int flags) +{ + return NULL; +} + +int sxstream_close(sxstream_t *stream) +{ + return SXE_SUCCESS; +} + +/* binary stream operations */ +/* + * NOTE: it will be done with with a copy paste, + * there are todo - implement it with oilite style. + */ +size_t sxstream_bread(sxstream_t *stream, void *buf, size_t buf_len) +{ + return -1; +} + +size_t sxstream_breadat(sxstream_t *stream, void *buf, size_t buf_len, off_t off) +{ + return -1; +} + +size_t sxstream_bwriteat(sxstream_t *stream, const void *buf, + size_t buf_len, off_t off) +{ + return -1; +} + +size_t sxstream_bsyncat(sxstream_t *stream, void *buf, size_t buf_len, off_t off) +{ + return -1; +} + +/* + * NOTE: returning value for reading from entry streams + * shouldn't be managed, it's done by close operation. + * That means you should care about ridden values, since + * it might be freed on the next read operation. + */ +/* entry nonamed stream ops */ +list_head_t *sxstream_read(sxstream_t *stream) +{ + return NULL; +} + +/* entry named stream ops */ +list_head_t *sxstream_readnamed(sxstream_t *stream) +{ + return NULL; +} +