projects
/
oweals
/
gnunet.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Implement a Full Domain Hash (FDH) for RSA signatures and blind signatures
[oweals/gnunet.git]
/
src
/
util
/
server_mst.c
diff --git
a/src/util/server_mst.c
b/src/util/server_mst.c
index 7eac75bedd44b162ce07b687f7cf0c788f766239..0a686a079e6323e44ef949a774fd4c6ef991c21c 100644
(file)
--- a/
src/util/server_mst.c
+++ b/
src/util/server_mst.c
@@
-1,6
+1,6
@@
/*
This file is part of GNUnet.
/*
This file is part of GNUnet.
- (C) 2010 Christian Grothoff (and other contributing authors)
+ Copyright (C) 2010 GNUnet e.V.
GNUnet is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published
GNUnet is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published
@@
-14,8
+14,8
@@
You should have received a copy of the GNU General Public License
along with GNUnet; see the file COPYING. If not, write to the
You should have received a copy of the GNU General Public License
along with GNUnet; see the file COPYING. If not, write to the
- Free Software Foundation, Inc., 5
9 Temple Place - Suite 330
,
- Boston, MA 0211
1-1307
, USA.
+ Free Software Foundation, Inc., 5
1 Franklin Street, Fifth Floor
,
+ Boston, MA 0211
0-1301
, USA.
*/
/**
*/
/**
@@
-25,11
+25,7
@@
*/
#include "platform.h"
*/
#include "platform.h"
-#include "gnunet_common.h"
-#include "gnunet_connection_lib.h"
-#include "gnunet_scheduler_lib.h"
-#include "gnunet_server_lib.h"
-#include "gnunet_time_lib.h"
+#include "gnunet_util_lib.h"
#if HAVE_UNALIGNED_64_ACCESS
#if HAVE_UNALIGNED_64_ACCESS
@@
-85,7
+81,7
@@
struct GNUNET_SERVER_MessageStreamTokenizer
* Create a message stream tokenizer.
*
* @param cb function to call on completed messages
* Create a message stream tokenizer.
*
* @param cb function to call on completed messages
- * @param cb_cls closure for cb
+ * @param cb_cls closure for
@a
cb
* @return handle to tokenizer
*/
struct GNUNET_SERVER_MessageStreamTokenizer *
* @return handle to tokenizer
*/
struct GNUNET_SERVER_MessageStreamTokenizer *
@@
-94,7
+90,7
@@
GNUNET_SERVER_mst_create (GNUNET_SERVER_MessageTokenizerCallback cb,
{
struct GNUNET_SERVER_MessageStreamTokenizer *ret;
{
struct GNUNET_SERVER_MessageStreamTokenizer *ret;
- ret = GNUNET_
malloc (sizeof (struct GNUNET_SERVER_MessageStreamTokenizer)
);
+ ret = GNUNET_
new (struct GNUNET_SERVER_MessageStreamTokenizer
);
ret->hdr = GNUNET_malloc (GNUNET_SERVER_MIN_BUFFER_SIZE);
ret->curr_buf = GNUNET_SERVER_MIN_BUFFER_SIZE;
ret->cb = cb;
ret->hdr = GNUNET_malloc (GNUNET_SERVER_MIN_BUFFER_SIZE);
ret->curr_buf = GNUNET_SERVER_MIN_BUFFER_SIZE;
ret->cb = cb;
@@
-110,17
+106,18
@@
GNUNET_SERVER_mst_create (GNUNET_SERVER_MessageTokenizerCallback cb,
* @param mst tokenizer to use
* @param client_identity ID of client for which this is a buffer
* @param buf input data to add
* @param mst tokenizer to use
* @param client_identity ID of client for which this is a buffer
* @param buf input data to add
- * @param size number of bytes in buf
+ * @param size number of bytes in
@a
buf
* @param purge should any excess bytes in the buffer be discarded
* (i.e. for packet-based services like UDP)
* @param one_shot only call callback once, keep rest of message in buffer
* @param purge should any excess bytes in the buffer be discarded
* (i.e. for packet-based services like UDP)
* @param one_shot only call callback once, keep rest of message in buffer
- * @return GNUNET_OK if we are done processing (need more data)
- *
GNUNET_NO if
one_shot was set and we have another message ready
- * GNUNET_SYSERR if the data stream is corrupt
+ * @return
#
GNUNET_OK if we are done processing (need more data)
+ *
#GNUNET_NO if @a
one_shot was set and we have another message ready
+ *
#
GNUNET_SYSERR if the data stream is corrupt
*/
int
GNUNET_SERVER_mst_receive (struct GNUNET_SERVER_MessageStreamTokenizer *mst,
*/
int
GNUNET_SERVER_mst_receive (struct GNUNET_SERVER_MessageStreamTokenizer *mst,
- void *client_identity, const char *buf, size_t size,
+ void *client_identity,
+ const char *buf, size_t size,
int purge, int one_shot)
{
const struct GNUNET_MessageHeader *hdr;
int purge, int one_shot)
{
const struct GNUNET_MessageHeader *hdr;