39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
|
kiostream in;
// text can be read from this stream
kiostream out;
// text can be written to this stream
} kiochan;
typedef enum kiocond {
kiocond_ok,
// success
kiocond_fail,
// action failed
} kiocond;
kiocond kiosend(kiochan, ksraw, sz*); // send data to a channel
kiocond kiorecv(kiochan, ksraw*); // receive data from a channel
kmptr kiorecvall(kiochan, kmcell*, kmkind); // automatically allocate a bufer for a channel
// kmkind is only used if kmcell* is NULL
kiocond kiocon(kiochan, kiochan); // connect one channel to another
#endif
|
|
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
|
kiostream in;
// text can be read from this stream
kiostream out;
// text can be written to this stream
} kiochan;
typedef enum kiocond {
/* to check if a call failed, perform (x >= kiocond_fail) where x
* is that call's return value. more typically however you should
* select explicitly against kiocond_ok or kiocond_partial, since
* those situations will usually need to be handled differently. */
kiocond_ok, // success
kiocond_partial, // partial read or write
kiocond_fail, // action failed - unspecified reason
kiocond_fail_closed_stream, // action failed because stream is closed
} kiocond;
kiocond kiosend(kiochan, ksraw, sz*); // send data to a channel
kiocond kiorecv(kiochan, ksraw*); // receive data from a channel
kmptr kiorecvall(kiochan, kmcell*, kmkind); // automatically allocate a bufer for a channel
// kmkind is only used if kmcell* is NULL
kiocond kiocon(kiochan, kiochan); // connect one channel to another
#endif
|