File: streaminfo.c

package info (click to toggle)
yap 6.2.2-2
  • links: PTS, VCS
  • area: main
  • in suites: jessie, jessie-kfreebsd
  • size: 33,460 kB
  • ctags: 27,764
  • sloc: ansic: 227,316; perl: 100,861; sh: 6,714; java: 5,165; makefile: 3,502; cpp: 1,401; python: 1,163; tcl: 352; xml: 77; awk: 9
file content (109 lines) | stat: -rw-r--r-- 2,651 bytes parent folder | download | duplicates (4)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
/*  $Id$

    Part of SWI-Prolog

    Author:        Jan Wielemaker
    E-mail:        J.Wielemaker@uva.nl
    WWW:           http://www.swi-prolog.org
    Copyright (C): 2009, University of Amsterdam

    This library 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.

    This library 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 library; if not, write to the Free Software
    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
*/

#include <SWI-Stream.h>
#include <SWI-Prolog.h>
#include "error.h"
#include <ctype.h>

static int
print_byte(int value)
{ if ( isgraph(value) || isspace(value) )
  { Sdprintf("%c", value);
  } else
  { Sdprintf("\\\\%02x", value);
  }

  return 0;
}

static int
print_buffer(const char *data, size_t len)
{ size_t i;

  Sdprintf("----------------\n");
  for(i=0; i<len; i++)
  { if ( data[i] == 0 )
    { size_t zeros;

      for(zeros = 0; i+zeros < len && data[i+zeros] == 0; zeros++)
	;
      if ( zeros > 10 )
      { Sdprintf("<%d 0-bytes>", zeros);
      }
      i += zeros;
    } else
    { print_byte(data[i]&0xff);
    }
  }
  if ( data[len-1] != '\n' )
    Sdprintf("\n");
  Sdprintf("----------------\n");

  return 0;
}


static foreign_t
stream_info(term_t stream)
{ IOSTREAM *s;

  if ( !PL_get_stream_handle(stream, &s) )
  { return pl_error("stream_info", 2, NULL, ERR_ARGTYPE, 1,
		    stream, "stream");
  }

  if ( (s->flags & SIO_INPUT) )
  { if ( s->buffer )
    { if ( s->bufp > s->buffer )
      { Sdprintf("Processed input:\n");
	print_buffer(s->buffer, s->bufp-s->buffer);
      }

      if ( s->bufp < s->limitp )
      { Sdprintf("Unprocessed input:\n");
	print_buffer(s->bufp, s->limitp-s->bufp);
      }
    }
  } else if ( (s->flags & SIO_OUTPUT) )
  { if ( s->buffer )
    { if ( s->bufp > s->buffer )
      { Sdprintf("Buffered output:\n");
	print_buffer(s->buffer, s->bufp-s->buffer);
      }

      if ( s->bufp < s->limitp )
      { Sdprintf("Possibly sent output (or junk):\n");
	print_buffer(s->bufp, s->limitp-s->bufp);
      }
    }
  }

  return PL_release_stream(s);
}

install_t
install_streaminfo()
{ PL_register_foreign("$stream_info", 1, stream_info, 0);
}