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
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
|
/* stdout -- write messages to standard output.
Copyright 2008 Miller Puckette
BSD license; see README.txt in this distribution for details.
*/
#include "m_pd.h"
#include "s_stuff.h"
#include <stdio.h>
#include <string.h>
#ifdef _WIN32
#include <fcntl.h>
#endif
static t_class *stdout_class;
#define MODE_DEFAULT 0 /* default, FUDI style */
#define MODE_CR 1 /* newline-terminate messages and omit semicolons */
#define MODE_BIN 2 /* binary messages supplied bytewise from patch */
#define MODE_PDTILDE 3 /* binary atoms for subprocess of pd~ object */
typedef struct _stdout
{
t_object x_obj;
int x_mode; /* 0=FUDI; 1=printf (no terminating semicolon); -1=binary */
int x_flush; /* fflush() stdout after each message */
#ifdef _WIN32
int x_setiobin; /* we've set stdin and out to binary on MSW */
#endif
} t_stdout;
static void *stdout_new(t_symbol*s, int argc, t_atom*argv)
{
t_stdout *x = (t_stdout *)pd_new(stdout_class);
/* for some reason in MS windows we have to flush standard out here -
otherwise these outputs get out of order from the ones from pdsched.c
over in ../pd~. I'm guessing mingw (with its different C runtime
support) will handle this correctly and so am only ifdeffing this on
Microsoft C compiler. It's an efficiency hit, possibly a serious
one. */
#ifdef _MSC_VER
x->x_flush = 1;
#endif
while(argc--)
{
s = atom_getsymbol(argv++);
if (gensym("-cr") == s)
{
/* No-semicolon mode */
x->x_mode = MODE_CR;
}
else if ((gensym("-b") == s) || (gensym("-binary") == s))
{
/* Binary mode:
no extra characters (semicolons, CR,...) is appended
*/
x->x_mode = MODE_BIN;
}
else if ((gensym("-f") == s) || (gensym("-flush") == s))
{
x->x_flush = 1;
}
else if ((gensym("-nf") == s) || (gensym("-noflush") == s))
{
x->x_flush = 0;
}
else if (gensym("") != s)
{
/* unknown mode; ignore it */
}
}
#ifdef _WIN32
x->x_setiobin = 0;
#endif
return (x);
}
static void stdout_binary(t_stdout *x, int argc, t_atom *argv)
{
#define BUFSIZE 65535
char buf[BUFSIZE];
int i;
if (argc>BUFSIZE)
argc = BUFSIZE;
for (i=0; i<argc; i++)
((unsigned char *)buf)[i] = atom_getfloatarg(i, argc, argv);
buf[i>=BUFSIZE?(BUFSIZE-1):i] = 0;
fwrite(buf, 1, argc, stdout);
if (x->x_flush || !argc)
fflush(stdout);
}
static void pd_tilde_putfloat(float f, FILE *fd)
{
putc(A_FLOAT, fd);
fwrite(&f, sizeof(f), 1, fd);
}
static void pd_tilde_putsymbol(t_symbol *s, FILE *fd)
{
const char *sp = s->s_name;
putc(A_SYMBOL, fd);
do
putc(*sp, fd);
while (*sp++);
}
static void stdout_anything(t_stdout *x, t_symbol *s, int argc, t_atom *argv)
{
char msgbuf[MAXPDSTRING], *sp, *ep = msgbuf+MAXPDSTRING;
if (pd_extraflags && *pd_extraflags == 'b')
{
/* On Windows, set stdin and out to "binary" mode */
#ifdef _WIN32
if (!x->x_setiobin)
{
setmode(fileno(stdout), O_BINARY);
setmode(fileno(stdin), O_BINARY);
x->x_setiobin = 1;
}
#endif
pd_tilde_putsymbol(s, stdout);
for (; argc--; argv++)
{
if (argv->a_type == A_FLOAT)
pd_tilde_putfloat(argv->a_w.w_float, stdout);
else if (argv->a_type == A_SYMBOL)
pd_tilde_putsymbol(argv->a_w.w_symbol, stdout);
}
putc(A_SEMI, stdout);
if (x->x_flush)
fflush(stdout);
return;
}
else if (x->x_mode == MODE_BIN)
{
#ifdef _WIN32
if (!x->x_setiobin)
{
setmode(fileno(stdout), O_BINARY);
setmode(fileno(stdin), O_BINARY);
x->x_setiobin = 1;
}
#endif
if ((gensym("list") == s) || (gensym("float") == s) ||
(gensym("bang") == s))
stdout_binary(x, argc, argv);
else
pd_error(x,
"stdout: only 'list' messages allowed in binary mode (got '%s')",
s->s_name);
return;
}
msgbuf[0] = 0;
strncpy(msgbuf, s->s_name, MAXPDSTRING);
msgbuf[MAXPDSTRING-1] = 0;
sp = msgbuf + strlen(msgbuf);
while (argc--)
{
if (sp < ep-1)
sp[0] = ' ', sp[1] = 0, sp++;
atom_string(argv++, sp, (unsigned int)(ep-sp));
sp += strlen(sp);
}
switch(x->x_mode) {
case MODE_CR:
printf("%s\n", msgbuf);
break;
default:
printf("%s;\n", msgbuf);
}
if (x->x_flush)
fflush(stdout);
}
static void stdout_free(t_stdout *x)
{
fflush(stdout);
}
void stdout_setup(void)
{
stdout_class = class_new(gensym("stdout"), (t_newmethod)stdout_new,
(t_method)stdout_free, sizeof(t_stdout), 0, A_GIMME, 0);
class_addanything(stdout_class, stdout_anything);
}
|
