#include <u.h>#include <libc.h>#include <thread.h> enum{ STACK = 32768,}; voidusage(void){ fprint(2, "usage: dial [-e] addr\n"); threadexitsall("usage");} int waitforeof;voidtxproc(void *v){ int fd; char buf[8192]; int n; fd = (int)v; while((n = read(0, buf, sizeof buf)) > 0) if(write(fd, buf, n) < 0) break; if(!waitforeof) threadexitsall(nil);} voidthreadmain(int argc, char **argv){ int fd; char buf[8192]; int n; ARGBEGIN{ case 'e': waitforeof = 1; break; default: usage(); }ARGEND if(argc != 1) usage(); if((fd = dial(argv[0], nil, nil, nil)) < 0) sysfatal("dial: %r"); proccreate(txproc, (void*)fd, STACK); while((n = read(fd, buf, sizeof buf)) > 0) if(write(1, buf, n) < 0) break; threadexitsall(nil);}
#include <u.h>
#include <libc.h>
#include <thread.h>
enum
{
STACK = 32768,
};
void
usage(void)
{
fprint(2, "usage: dial [-e] addr\n");
threadexitsall("usage");
}
int waitforeof;
void
txproc(void *v)
{
int fd;
char buf[8192];
int n;
fd = (int)v;
while((n = read(0, buf, sizeof buf)) > 0)
if(write(fd, buf, n) < 0)
break;
if(!waitforeof)
threadexitsall(nil);
}
void
threadmain(int argc, char **argv)
{
int fd;
char buf[8192];
int n;
ARGBEGIN{
case 'e':
waitforeof = 1;
break;
default:
usage();
}ARGEND
if(argc != 1)
usage();
if((fd = dial(argv[0], nil, nil, nil)) < 0)
sysfatal("dial: %r");
proccreate(txproc, (void*)fd, STACK);
while((n = read(fd, buf, sizeof buf)) > 0)
if(write(1, buf, n) < 0)
break;
threadexitsall(nil);
}