lib/eggdrop/linemode.c File Reference

#include <eggdrop/eggdrop.h>
#include <unistd.h>

Go to the source code of this file.

Data Structures
struct	linemode_t
Defines
#define	LINEMODE_LEVEL   SOCKBUF_LEVEL_TEXT_BUFFER
Functions
static int	linemode_on_read (void *client_data, int idx, char *data, int len)
static int	linemode_on_eof (void *client_data, int idx, int err, const char *errmsg)
static int	linemode_on_delete (void *client_data, int idx)
int	linemode_on (int idx)
	Turns linebuffering on an index on.
int	linemode_off (int idx)
	Turns linebuffering on an index off.
int	linemode_check (int idx)
	Checks if an index is in linebuffered mode.
Variables
static const char	rcsid [] = "$Id: linemode.c,v 1.9 2006-11-14 14:51:23 sven Exp $"
static sockbuf_filter_t	linemode_filter

---

Define Documentation

#define LINEMODE_LEVEL   SOCKBUF_LEVEL_TEXT_BUFFER

Definition at line 27 of file linemode.c.

Referenced by linemode_off(), linemode_on_eof(), and linemode_on_read().

---

Function Documentation

int linemode_check

(

int

idx

)

Checks if an index is in linebuffered mode.

Parameters:

idx

the index to check

Returns:

1 if linebuffered, 0 if not linebuffered, -1 on error

Definition at line 180 of file linemode.c.

References sockbuf_get_filter_data(), and sockbuf_isvalid().

Referenced by linemode_on(), and script_net_linemode().

{
  if (!sockbuf_isvalid(idx)) return -1;
  return !sockbuf_get_filter_data(idx, &linemode_filter, 0);
}

int linemode_off

(

int

idx

)

Turns linebuffering on an index off.

If there if a line currently buffered it's send of immidiatly.

Parameters:

idx

the index to turn off linebuffering for

Returns:

0 on success, -1 on error

Definition at line 152 of file linemode.c.

References linemode_t::data, linemode_t::len, LINEMODE_LEVEL, sockbuf_detach_filter(), and sockbuf_on_read().

Referenced by script_net_linemode().

{
  int ret;
  linemode_t *old_data;

  ret = sockbuf_detach_filter(idx, &linemode_filter, &old_data);
  if (ret) return ret;
  if (old_data) {
    if (old_data->data) {
      if (old_data->len) {
        old_data->data[old_data->len] = 0;
        sockbuf_on_read(idx, LINEMODE_LEVEL, old_data->data, old_data->len);
        old_data->len = 0;
      }
      free(old_data->data);
    }
    free(old_data);
  }
  return(0);
}

int linemode_on

(

int

idx

)

Turns linebuffering on an index on.

Parameters:

idx

the index to turn on linebuffering for

Returns:

0 on success, -1 on error

Definition at line 133 of file linemode.c.

References linemode_check(), and sockbuf_attach_filter().

Referenced by do_link(), got_chat_request(), http_reconnect(), irc_on_newclient(), script_net_linemode(), server_on_connect(), telnet_on_newclient(), and terminal_init().

{
  linemode_t *old_data;

  if (linemode_check(idx)) return -1;
  old_data = calloc(1, sizeof(*old_data));
  sockbuf_attach_filter(idx, &linemode_filter, old_data);
  return(0);
}

static int linemode_on_delete	(	void *	client_data,
		int	idx
	)			[static]

Definition at line 109 of file linemode.c.

References linemode_t::data.

{
  linemode_t *old_data = client_data;
  /* When the sockbuf is deleted, just kill the associated data. */
  if (old_data->data) free(old_data->data);
  free(old_data);
  return(0);
}

static int linemode_on_eof	(	void *	client_data,
		int	idx,
		int	err,
		const char *	errmsg
	)			[static]

Definition at line 95 of file linemode.c.

References linemode_t::data, linemode_t::len, LINEMODE_LEVEL, sockbuf_on_eof(), and sockbuf_on_read().

{
  linemode_t *old_data = client_data;
  /* If there is any buffered data, do one more on->read callback. */
  if (old_data->len) {
    old_data->data[old_data->len] = 0;
    sockbuf_on_read(idx, LINEMODE_LEVEL, old_data->data, old_data->len);
    old_data->len = 0;
  }

  /* And now continue the eof event chain. */
  return sockbuf_on_eof(idx, LINEMODE_LEVEL, err, errmsg);
}

static int linemode_on_read	(	void *	client_data,
		int	idx,
		char *	data,
		int	len
	)			[static]

Definition at line 34 of file linemode.c.

References linemode_t::data, linemode_t::len, LINEMODE_LEVEL, sockbuf_isvalid(), and sockbuf_on_read().

{
  linemode_t *old_data = client_data;
  char *line, *stop, *save;
  int linelen, savelen;

  while (1) {
    /* If there's a cr or lf, we have a line. */
    stop = memchr(data, '\n', len);
    if (!stop) {
      stop = memchr(data, '\r', len);
      if (!stop) {
        /* No line, save the whole thing. */
        save = data;
        savelen = len;
        break;
      }
    }

    /* Save the cursor position for the next iteration. */
    save = stop+1;
    savelen = len - (save - data);

    if (stop > data && *(stop-1) == '\r') stop--;
    linelen = stop - data;
    *stop = 0;

    /* If there is buffered data, concat it all. */
    if (old_data->len) {
      /* Expand the buffer. */
      old_data->data = realloc(old_data->data, old_data->len + linelen + 1);
      memcpy(old_data->data+old_data->len, data, linelen + 1);

      line = old_data->data;
      linelen += old_data->len;

      /* All the old data is used. */
      old_data->len = 0;
    }
    else {
      line = data;
    }

    sockbuf_on_read(idx, LINEMODE_LEVEL, line, linelen);

    if (!sockbuf_isvalid(idx)) return 0; /* We've been deleted */

    /* If we're out of data, we're done. */
    if (savelen <= 0) return(0);
    /* Otherwise, do this again to check for another line. */
    data = save;
    len = savelen;
  }

  /* No cr/lf, so we save the remaining data for next time. */
  old_data->data = realloc(old_data->data, savelen + old_data->len + 1);
  memcpy(old_data->data + old_data->len, save, savelen);
  old_data->len += savelen;
  return(0);
}

---

Variable Documentation

sockbuf_filter_t linemode_filter [static]

Initial value:

 {
  "linemode",
  LINEMODE_LEVEL,
  NULL, linemode_on_eof, NULL,
  linemode_on_read, NULL, NULL,
  NULL, linemode_on_delete
}

Definition at line 118 of file linemode.c.

const char rcsid[] = "$Id: linemode.c,v 1.9 2006-11-14 14:51:23 sven Exp $" [static]

Definition at line 21 of file linemode.c.