2001-11-06 15:42:37 +00:00
|
|
|
|
/* assuan-buffer.c - read and send data
|
2002-07-30 17:38:54 +00:00
|
|
|
|
* Copyright (C) 2001, 2002 Free Software Foundation, Inc.
|
2001-11-06 15:42:37 +00:00
|
|
|
|
*
|
2002-07-30 17:38:54 +00:00
|
|
|
|
* This file is part of Assuan.
|
2001-11-06 15:42:37 +00:00
|
|
|
|
*
|
2002-07-30 17:38:54 +00:00
|
|
|
|
* Assuan 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 2.1 of
|
|
|
|
|
* the License, or (at your option) any later version.
|
2001-11-06 15:42:37 +00:00
|
|
|
|
*
|
2002-07-30 17:38:54 +00:00
|
|
|
|
* Assuan 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.
|
2001-11-06 15:42:37 +00:00
|
|
|
|
*
|
2002-07-30 17:38:54 +00:00
|
|
|
|
* You should have received a copy of the GNU Lesser General Public
|
|
|
|
|
* License along with this program; if not, write to the Free Software
|
|
|
|
|
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA
|
2001-11-06 15:42:37 +00:00
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
#include <config.h>
|
|
|
|
|
#include <stdlib.h>
|
2002-01-19 18:20:15 +00:00
|
|
|
|
#include <string.h>
|
2001-11-06 15:42:37 +00:00
|
|
|
|
#include <stdio.h>
|
2001-11-07 17:43:05 +00:00
|
|
|
|
#include <errno.h>
|
|
|
|
|
#include <unistd.h>
|
|
|
|
|
#include <assert.h>
|
2001-11-06 15:42:37 +00:00
|
|
|
|
#include "assuan-defs.h"
|
|
|
|
|
|
2002-04-09 18:36:20 +00:00
|
|
|
|
#ifdef HAVE_JNLIB_LOGGING
|
|
|
|
|
#include "../jnlib/logging.h"
|
|
|
|
|
#endif
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
static const char *
|
|
|
|
|
my_log_prefix (void)
|
|
|
|
|
{
|
|
|
|
|
#ifdef HAVE_JNLIB_LOGGING
|
|
|
|
|
return log_get_prefix (NULL);
|
|
|
|
|
#else
|
|
|
|
|
return "";
|
|
|
|
|
#endif
|
|
|
|
|
}
|
|
|
|
|
|
2001-11-06 15:42:37 +00:00
|
|
|
|
|
2001-11-07 17:43:05 +00:00
|
|
|
|
static int
|
|
|
|
|
writen ( int fd, const char *buffer, size_t length )
|
|
|
|
|
{
|
|
|
|
|
while (length)
|
|
|
|
|
{
|
2002-05-23 09:07:12 +00:00
|
|
|
|
int nwritten = _assuan_write_wrapper?
|
|
|
|
|
_assuan_write_wrapper (fd, buffer, length):
|
|
|
|
|
write (fd, buffer, length);
|
2001-11-07 17:43:05 +00:00
|
|
|
|
|
|
|
|
|
if (nwritten < 0)
|
|
|
|
|
{
|
|
|
|
|
if (errno == EINTR)
|
|
|
|
|
continue;
|
|
|
|
|
return -1; /* write error */
|
|
|
|
|
}
|
|
|
|
|
length -= nwritten;
|
|
|
|
|
buffer += nwritten;
|
|
|
|
|
}
|
|
|
|
|
return 0; /* okay */
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/* read an entire line */
|
|
|
|
|
static int
|
|
|
|
|
readline (int fd, char *buf, size_t buflen, int *r_nread, int *eof)
|
|
|
|
|
{
|
|
|
|
|
size_t nleft = buflen;
|
|
|
|
|
char *p;
|
|
|
|
|
|
|
|
|
|
*eof = 0;
|
|
|
|
|
*r_nread = 0;
|
|
|
|
|
while (nleft > 0)
|
|
|
|
|
{
|
2002-05-23 09:07:12 +00:00
|
|
|
|
int n = _assuan_read_wrapper?
|
|
|
|
|
_assuan_read_wrapper (fd, buf, nleft):
|
|
|
|
|
read (fd, buf, nleft);
|
|
|
|
|
|
2001-11-07 17:43:05 +00:00
|
|
|
|
if (n < 0)
|
|
|
|
|
{
|
|
|
|
|
if (errno == EINTR)
|
|
|
|
|
continue;
|
|
|
|
|
return -1; /* read error */
|
|
|
|
|
}
|
|
|
|
|
else if (!n)
|
|
|
|
|
{
|
|
|
|
|
*eof = 1;
|
|
|
|
|
break; /* allow incomplete lines */
|
|
|
|
|
}
|
|
|
|
|
p = buf;
|
|
|
|
|
nleft -= n;
|
|
|
|
|
buf += n;
|
|
|
|
|
*r_nread += n;
|
|
|
|
|
|
|
|
|
|
for (; n && *p != '\n'; n--, p++)
|
|
|
|
|
;
|
|
|
|
|
if (n)
|
2001-11-24 21:10:22 +00:00
|
|
|
|
break; /* at least one full line available - that's enough for now */
|
2001-11-07 17:43:05 +00:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
2001-11-06 15:42:37 +00:00
|
|
|
|
int
|
|
|
|
|
_assuan_read_line (ASSUAN_CONTEXT ctx)
|
|
|
|
|
{
|
2001-11-07 17:43:05 +00:00
|
|
|
|
char *line = ctx->inbound.line;
|
2001-12-14 01:23:07 +00:00
|
|
|
|
int n, nread, atticlen;
|
2001-11-07 17:43:05 +00:00
|
|
|
|
int rc;
|
2001-12-14 01:23:07 +00:00
|
|
|
|
|
2001-11-07 17:43:05 +00:00
|
|
|
|
if (ctx->inbound.eof)
|
|
|
|
|
return -1;
|
|
|
|
|
|
2001-12-14 01:23:07 +00:00
|
|
|
|
atticlen = ctx->inbound.attic.linelen;
|
|
|
|
|
if (atticlen)
|
2001-11-24 21:10:22 +00:00
|
|
|
|
{
|
2001-12-14 01:23:07 +00:00
|
|
|
|
memcpy (line, ctx->inbound.attic.line, atticlen);
|
2001-11-24 21:10:22 +00:00
|
|
|
|
ctx->inbound.attic.linelen = 0;
|
2001-12-14 01:23:07 +00:00
|
|
|
|
for (n=0; n < atticlen && line[n] != '\n'; n++)
|
2001-11-24 21:10:22 +00:00
|
|
|
|
;
|
2001-12-14 01:23:07 +00:00
|
|
|
|
if (n < atticlen)
|
|
|
|
|
{
|
|
|
|
|
rc = 0; /* found another line in the attic */
|
|
|
|
|
nread = atticlen;
|
|
|
|
|
atticlen = 0;
|
|
|
|
|
}
|
2001-11-24 21:10:22 +00:00
|
|
|
|
else
|
|
|
|
|
{ /* read the rest */
|
2001-12-14 01:23:07 +00:00
|
|
|
|
assert (atticlen < LINELENGTH);
|
|
|
|
|
rc = readline (ctx->inbound.fd, line + atticlen,
|
|
|
|
|
LINELENGTH - atticlen, &nread, &ctx->inbound.eof);
|
2001-11-24 21:10:22 +00:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
rc = readline (ctx->inbound.fd, line, LINELENGTH,
|
|
|
|
|
&nread, &ctx->inbound.eof);
|
2001-11-07 17:43:05 +00:00
|
|
|
|
if (rc)
|
2002-01-19 18:20:15 +00:00
|
|
|
|
{
|
|
|
|
|
if (ctx->log_fp)
|
2002-04-09 18:36:20 +00:00
|
|
|
|
fprintf (ctx->log_fp, "%s[%p] <- [Error: %s]\n",
|
|
|
|
|
my_log_prefix (), ctx, strerror (errno));
|
2002-01-19 18:20:15 +00:00
|
|
|
|
return ASSUAN_Read_Error;
|
|
|
|
|
}
|
2001-11-07 17:43:05 +00:00
|
|
|
|
if (!nread)
|
|
|
|
|
{
|
|
|
|
|
assert (ctx->inbound.eof);
|
2002-01-19 18:20:15 +00:00
|
|
|
|
if (ctx->log_fp)
|
2002-04-09 18:36:20 +00:00
|
|
|
|
fprintf (ctx->log_fp, "%s[%p] <- [EOF]\n", my_log_prefix (),ctx);
|
2001-11-07 17:43:05 +00:00
|
|
|
|
return -1;
|
|
|
|
|
}
|
2001-11-06 15:42:37 +00:00
|
|
|
|
|
2001-12-12 09:17:23 +00:00
|
|
|
|
ctx->inbound.attic.pending = 0;
|
2001-12-14 01:23:07 +00:00
|
|
|
|
nread += atticlen;
|
2001-11-24 21:10:22 +00:00
|
|
|
|
for (n=0; n < nread; n++)
|
2001-11-07 17:43:05 +00:00
|
|
|
|
{
|
|
|
|
|
if (line[n] == '\n')
|
|
|
|
|
{
|
2001-11-24 21:10:22 +00:00
|
|
|
|
if (n+1 < nread)
|
2001-11-07 17:43:05 +00:00
|
|
|
|
{
|
2001-12-12 09:17:23 +00:00
|
|
|
|
char *s, *d;
|
|
|
|
|
int i;
|
|
|
|
|
|
2001-11-24 21:10:22 +00:00
|
|
|
|
n++;
|
|
|
|
|
/* we have to copy the rest because the handlers are
|
|
|
|
|
allowed to modify the passed buffer */
|
2001-12-12 09:17:23 +00:00
|
|
|
|
for (d=ctx->inbound.attic.line, s=line+n, i=nread-n; i; i--)
|
|
|
|
|
{
|
|
|
|
|
if (*s=='\n')
|
|
|
|
|
ctx->inbound.attic.pending = 1;
|
|
|
|
|
*d++ = *s++;
|
|
|
|
|
}
|
2001-11-24 21:10:22 +00:00
|
|
|
|
ctx->inbound.attic.linelen = nread-n;
|
|
|
|
|
n--;
|
2001-11-07 17:43:05 +00:00
|
|
|
|
}
|
|
|
|
|
if (n && line[n-1] == '\r')
|
|
|
|
|
n--;
|
|
|
|
|
line[n] = 0;
|
|
|
|
|
ctx->inbound.linelen = n;
|
2002-01-19 18:20:15 +00:00
|
|
|
|
if (ctx->log_fp)
|
|
|
|
|
{
|
2002-04-09 18:36:20 +00:00
|
|
|
|
fprintf (ctx->log_fp, "%s[%p] <- ", my_log_prefix (), ctx);
|
2002-01-19 18:20:15 +00:00
|
|
|
|
if (ctx->confidential)
|
|
|
|
|
fputs ("[Confidential data not shown]", ctx->log_fp);
|
|
|
|
|
else
|
|
|
|
|
_assuan_log_print_buffer (ctx->log_fp,
|
|
|
|
|
ctx->inbound.line,
|
|
|
|
|
ctx->inbound.linelen);
|
|
|
|
|
putc ('\n', ctx->log_fp);
|
|
|
|
|
}
|
2001-11-07 17:43:05 +00:00
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2002-01-19 18:20:15 +00:00
|
|
|
|
if (ctx->log_fp)
|
2002-04-09 18:36:20 +00:00
|
|
|
|
fprintf (ctx->log_fp, "%s[%p] <- [Invalid line]\n", my_log_prefix (), ctx);
|
2001-11-07 17:43:05 +00:00
|
|
|
|
*line = 0;
|
|
|
|
|
ctx->inbound.linelen = 0;
|
|
|
|
|
return ctx->inbound.eof? ASSUAN_Line_Not_Terminated : ASSUAN_Line_Too_Long;
|
2001-11-06 15:42:37 +00:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
2001-12-12 09:17:23 +00:00
|
|
|
|
/* Read the next line from the client or server and return a pointer
|
|
|
|
|
to a buffer with holding that line. linelen returns the length of
|
|
|
|
|
the line. This buffer is valid until another read operation is
|
|
|
|
|
done on this buffer. The caller is allowed to modify this buffer.
|
|
|
|
|
He should only use the buffer if the function returns without an
|
|
|
|
|
error.
|
|
|
|
|
|
|
|
|
|
Returns: 0 on success or an assuan error code
|
|
|
|
|
See also: assuan_pending_line().
|
|
|
|
|
*/
|
|
|
|
|
AssuanError
|
|
|
|
|
assuan_read_line (ASSUAN_CONTEXT ctx, char **line, size_t *linelen)
|
|
|
|
|
{
|
2001-12-13 20:16:21 +00:00
|
|
|
|
AssuanError err;
|
|
|
|
|
|
2001-12-12 09:17:23 +00:00
|
|
|
|
if (!ctx)
|
|
|
|
|
return ASSUAN_Invalid_Value;
|
2001-12-13 20:16:21 +00:00
|
|
|
|
|
|
|
|
|
err = _assuan_read_line (ctx);
|
2001-12-12 09:17:23 +00:00
|
|
|
|
*line = ctx->inbound.line;
|
|
|
|
|
*linelen = ctx->inbound.linelen;
|
2001-12-13 20:16:21 +00:00
|
|
|
|
return err;
|
2001-12-12 09:17:23 +00:00
|
|
|
|
}
|
2001-11-06 15:42:37 +00:00
|
|
|
|
|
|
|
|
|
|
2001-12-12 09:17:23 +00:00
|
|
|
|
/* Return true when a full line is pending for a read, without the need
|
|
|
|
|
for actual IO */
|
|
|
|
|
int
|
|
|
|
|
assuan_pending_line (ASSUAN_CONTEXT ctx)
|
|
|
|
|
{
|
|
|
|
|
return ctx && ctx->inbound.attic.pending;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
AssuanError
|
|
|
|
|
assuan_write_line (ASSUAN_CONTEXT ctx, const char *line )
|
2001-11-06 15:42:37 +00:00
|
|
|
|
{
|
2001-11-07 17:43:05 +00:00
|
|
|
|
int rc;
|
2002-06-26 12:51:15 +00:00
|
|
|
|
size_t len;
|
|
|
|
|
const char *s;
|
|
|
|
|
|
2001-12-12 09:17:23 +00:00
|
|
|
|
if (!ctx)
|
|
|
|
|
return ASSUAN_Invalid_Value;
|
2001-11-07 17:43:05 +00:00
|
|
|
|
|
2002-06-26 12:51:15 +00:00
|
|
|
|
/* Make sure that we never take a LF from the user - this might
|
|
|
|
|
violate the protocol. */
|
|
|
|
|
s = strchr (line, '\n');
|
|
|
|
|
len = s? (s-line) : strlen (line);
|
|
|
|
|
|
|
|
|
|
/* fixme: we should do some kind of line buffering. */
|
2002-01-19 18:20:15 +00:00
|
|
|
|
if (ctx->log_fp)
|
|
|
|
|
{
|
2002-04-09 18:36:20 +00:00
|
|
|
|
fprintf (ctx->log_fp, "%s[%p] -> ", my_log_prefix (), ctx);
|
2002-06-26 12:51:15 +00:00
|
|
|
|
if (s)
|
|
|
|
|
fputs ("[supplied line contained a LF]", ctx->log_fp);
|
2002-01-19 18:20:15 +00:00
|
|
|
|
if (ctx->confidential)
|
|
|
|
|
fputs ("[Confidential data not shown]", ctx->log_fp);
|
|
|
|
|
else
|
2002-06-26 12:51:15 +00:00
|
|
|
|
_assuan_log_print_buffer (ctx->log_fp, line, len);
|
2002-01-19 18:20:15 +00:00
|
|
|
|
putc ('\n', ctx->log_fp);
|
|
|
|
|
}
|
|
|
|
|
|
2002-06-26 12:51:15 +00:00
|
|
|
|
rc = writen (ctx->outbound.fd, line, len);
|
2001-11-07 17:43:05 +00:00
|
|
|
|
if (rc)
|
|
|
|
|
rc = ASSUAN_Write_Error;
|
|
|
|
|
if (!rc)
|
|
|
|
|
{
|
|
|
|
|
rc = writen (ctx->outbound.fd, "\n", 1);
|
|
|
|
|
if (rc)
|
|
|
|
|
rc = ASSUAN_Write_Error;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return rc;
|
2001-11-06 15:42:37 +00:00
|
|
|
|
}
|
|
|
|
|
|
2001-11-19 16:15:43 +00:00
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/* Write out the data in buffer as datalines with line wrapping and
|
|
|
|
|
percent escaping. This fucntion is used for GNU's custom streams */
|
|
|
|
|
int
|
|
|
|
|
_assuan_cookie_write_data (void *cookie, const char *buffer, size_t size)
|
|
|
|
|
{
|
|
|
|
|
ASSUAN_CONTEXT ctx = cookie;
|
|
|
|
|
char *line;
|
|
|
|
|
size_t linelen;
|
|
|
|
|
|
|
|
|
|
if (ctx->outbound.data.error)
|
|
|
|
|
return 0;
|
|
|
|
|
|
|
|
|
|
line = ctx->outbound.data.line;
|
|
|
|
|
linelen = ctx->outbound.data.linelen;
|
|
|
|
|
line += linelen;
|
|
|
|
|
while (size)
|
|
|
|
|
{
|
|
|
|
|
/* insert data line header */
|
|
|
|
|
if (!linelen)
|
|
|
|
|
{
|
|
|
|
|
*line++ = 'D';
|
|
|
|
|
*line++ = ' ';
|
|
|
|
|
linelen += 2;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/* copy data, keep some space for the CRLF and to escape one character */
|
|
|
|
|
while (size && linelen < LINELENGTH-2-2)
|
|
|
|
|
{
|
|
|
|
|
if (*buffer == '%' || *buffer == '\r' || *buffer == '\n')
|
|
|
|
|
{
|
|
|
|
|
sprintf (line, "%%%02X", *(unsigned char*)buffer);
|
|
|
|
|
line += 3;
|
|
|
|
|
linelen += 3;
|
|
|
|
|
buffer++;
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
*line++ = *buffer++;
|
|
|
|
|
linelen++;
|
|
|
|
|
}
|
|
|
|
|
size--;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (linelen >= LINELENGTH-2-2)
|
|
|
|
|
{
|
2002-01-19 18:20:15 +00:00
|
|
|
|
if (ctx->log_fp)
|
|
|
|
|
{
|
2002-04-09 18:36:20 +00:00
|
|
|
|
fprintf (ctx->log_fp, "%s[%p] -> ", my_log_prefix (), ctx);
|
2002-01-19 18:20:15 +00:00
|
|
|
|
if (ctx->confidential)
|
|
|
|
|
fputs ("[Confidential data not shown]", ctx->log_fp);
|
|
|
|
|
else
|
|
|
|
|
_assuan_log_print_buffer (ctx->log_fp,
|
|
|
|
|
ctx->outbound.data.line,
|
|
|
|
|
linelen);
|
|
|
|
|
putc ('\n', ctx->log_fp);
|
|
|
|
|
}
|
2001-11-19 16:15:43 +00:00
|
|
|
|
*line++ = '\n';
|
|
|
|
|
linelen++;
|
|
|
|
|
if (writen (ctx->outbound.fd, ctx->outbound.data.line, linelen))
|
|
|
|
|
{
|
|
|
|
|
ctx->outbound.data.error = ASSUAN_Write_Error;
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
line = ctx->outbound.data.line;
|
|
|
|
|
linelen = 0;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
ctx->outbound.data.linelen = linelen;
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/* Write out any buffered data
|
|
|
|
|
This fucntion is used for GNU's custom streams */
|
|
|
|
|
int
|
|
|
|
|
_assuan_cookie_write_flush (void *cookie)
|
|
|
|
|
{
|
|
|
|
|
ASSUAN_CONTEXT ctx = cookie;
|
|
|
|
|
char *line;
|
|
|
|
|
size_t linelen;
|
|
|
|
|
|
|
|
|
|
if (ctx->outbound.data.error)
|
|
|
|
|
return 0;
|
|
|
|
|
|
|
|
|
|
line = ctx->outbound.data.line;
|
|
|
|
|
linelen = ctx->outbound.data.linelen;
|
|
|
|
|
line += linelen;
|
|
|
|
|
if (linelen)
|
|
|
|
|
{
|
2002-01-19 18:20:15 +00:00
|
|
|
|
if (ctx->log_fp)
|
|
|
|
|
{
|
2002-04-09 18:36:20 +00:00
|
|
|
|
fprintf (ctx->log_fp, "%s[%p] -> ", my_log_prefix (), ctx);
|
2002-01-19 18:20:15 +00:00
|
|
|
|
if (ctx->confidential)
|
|
|
|
|
fputs ("[Confidential data not shown]", ctx->log_fp);
|
|
|
|
|
else
|
|
|
|
|
_assuan_log_print_buffer (ctx->log_fp,
|
|
|
|
|
ctx->outbound.data.line,
|
|
|
|
|
linelen);
|
|
|
|
|
putc ('\n', ctx->log_fp);
|
|
|
|
|
}
|
2001-11-19 16:15:43 +00:00
|
|
|
|
*line++ = '\n';
|
|
|
|
|
linelen++;
|
|
|
|
|
if (writen (ctx->outbound.fd, ctx->outbound.data.line, linelen))
|
|
|
|
|
{
|
|
|
|
|
ctx->outbound.data.error = ASSUAN_Write_Error;
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
ctx->outbound.data.linelen = 0;
|
|
|
|
|
}
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
2001-12-05 23:45:01 +00:00
|
|
|
|
/**
|
|
|
|
|
* assuan_send_data:
|
|
|
|
|
* @ctx: An assuan context
|
|
|
|
|
* @buffer: Data to send or NULL to flush
|
|
|
|
|
* @length: length of the data to send/
|
|
|
|
|
*
|
|
|
|
|
* This function may be used by the server or the client to send data
|
|
|
|
|
* lines. The data will be escaped as required by the Assuan protocol
|
|
|
|
|
* and may get buffered until a line is full. To force sending the
|
|
|
|
|
* data out @buffer may be passed as NULL (in which case @length must
|
|
|
|
|
* also be 0); however when used by a client this flush operation does
|
|
|
|
|
* also send the terminating "END" command to terminate the reponse on
|
|
|
|
|
* a INQUIRE response. However, when assuan_transact() is used, this
|
|
|
|
|
* function takes care of sending END itself.
|
|
|
|
|
*
|
|
|
|
|
* Return value: 0 on success or an error code
|
|
|
|
|
**/
|
|
|
|
|
|
|
|
|
|
AssuanError
|
|
|
|
|
assuan_send_data (ASSUAN_CONTEXT ctx, const void *buffer, size_t length)
|
|
|
|
|
{
|
|
|
|
|
if (!ctx)
|
|
|
|
|
return ASSUAN_Invalid_Value;
|
|
|
|
|
if (!buffer && length)
|
|
|
|
|
return ASSUAN_Invalid_Value;
|
|
|
|
|
|
|
|
|
|
if (!buffer)
|
|
|
|
|
{ /* flush what we have */
|
|
|
|
|
_assuan_cookie_write_flush (ctx);
|
|
|
|
|
if (ctx->outbound.data.error)
|
|
|
|
|
return ctx->outbound.data.error;
|
|
|
|
|
if (!ctx->is_server)
|
2001-12-12 09:17:23 +00:00
|
|
|
|
return assuan_write_line (ctx, "END");
|
2001-12-05 23:45:01 +00:00
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
_assuan_cookie_write_data (ctx, buffer, length);
|
|
|
|
|
if (ctx->outbound.data.error)
|
|
|
|
|
return ctx->outbound.data.error;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
2001-11-19 16:15:43 +00:00
|
|
|
|
|
|
|
|
|
|