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
|
/*-----------------------------------------------------------------------
File : cio_multiplexer.h
Author: Stephan Schulz (schulz@eprover.org)
Contents
Code for handling several communication channels.
Copyright 2011 by the author.
This code is released under the GNU General Public Licence.
See the file COPYING in the main CLIB directory for details.
Run "eprover -h" for contact information.
Changes
<1> Fri Mar 11 21:00:09 CET 2011
New
-----------------------------------------------------------------------*/
#ifndef CIO_MULTIPLEXER
#define CIO_MULTIPLEXER
#include <cio_network.h>
/*---------------------------------------------------------------------*/
/* Data type declarations */
/*---------------------------------------------------------------------*/
typedef struct tcp_channel_cell
{
int sock;
PQueue_p in;
PQueue_p out;
}TCPChannelCell, *TCPChannel_p;
/*---------------------------------------------------------------------*/
/* Exported Functions and Variables */
/*---------------------------------------------------------------------*/
/*
#define XXXCellAlloc() (XXXCell*)SizeMalloc(sizeof(XXXCell))
#define XXXCellFree(junk) SizeFree(junk, sizeof(XXXCell))
XXX_p XXXAlloc();
void XXXFree(XXX_p junk);
*/
#define TCPChannelCellAlloc() (TCPChannelCell*)SizeMalloc(sizeof(TCPChannelCell))
#define TCPChannelCellFree(junk) SizeFree(junk, sizeof(TCPChannelCell))
TCPChannel_p TCPChannelAlloc(int sock);
void TCPChannelFree(TCPChannel_p junk);
void TCPChannelClose(TCPChannel_p channel);
#define TCPChannelHasOutMsg(channel) (!PQueueEmpty(channel->out))
bool TCPChannelHasInMsg(TCPChannel_p channel);
#define TCPChannelGetInMsg(channel) (PQueueGetNextP((channel)->in))
void TCPChannelSendMsg(TCPChannel_p channel, TCPMsg_p msg);
void TCPChannelSendStr(TCPChannel_p channel, char* str);
MsgStatus TCPChannelRead(TCPChannel_p channel);
MsgStatus TCPChannelWrite(TCPChannel_p channel);
#endif
/*---------------------------------------------------------------------*/
/* End of File */
/*---------------------------------------------------------------------*/
|
