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
|
/*
* The Unix Channel
*
* by Michel Beaudouin-Lafon
*
* Copyright 1990-1993
* Laboratoire de Recherche en Informatique (LRI)
*
* Text streams
*
* $Id$
* $CurLog$
*/
#ifndef TextStream_H_
#define TextStream_H_
#include "cplus_bugs.h"
#include "Stream.h"
#include "MsgBuffer.h"
#include "MsgStream.h"
#include "ccu/String.h"
class UchTextLine;
class UchTextStream : public UchBufStream {
public:
enum cmd_res {
isCmdSyntax, // syntax error when parsing command
isCmdUnknown, // unknown command
isCmdOk, // request executed
isCmdError, // problem while executing request
isCmdClose, // close connection
isCmdQuit, // quit server
isCmdTerminate, // terminate multiplexer
isCmdAbort, // abort multiplexer
isCmdExit // call exit
};
protected:
void Closing (bool);
void HandleRead ();
void Process (UchMsgBuffer&);
void Flush ();
void ProcessCmdResult (cmd_res, const UchTextLine&);
cmd_res TryPredefined (const UchTextLine&);
virtual cmd_res Execute (const UchTextLine&) = 0;
void Emit (lword);
void Emit (sword);
void Emit (byte);
void Emit (char);
void Emit (const char*);
void Receive (lword&);
void Receive (sword&);
void Receive (byte&);
void Receive (char&);
void Receive (char*);
void Receive (CcuString&);
public:
UchTextStream ();
~UchTextStream ();
// UchTextStream (const UchTextStream&);
// UchChannel* Copy () const;
virtual void Close (); // 'close' request
virtual void Quit (); // 'quit' request
void Send (const char*, bool = false);
void Send (const UchTextLine&, bool = false);
};
class UchTextService : public UchTextStream {
friend class UchServiceStarter;
public:
enum status {
isUnavailable, // address not found in port server
isError, // could not init connection
isRunning, // connection established
isLost // no connection (auto-starting)
};
protected:
status StatusFlag;
UchServiceStarter* Starter;
bool Closed;
CcuString User;
CcuString Service;
CcuString Host;
void Closing (bool);
void Flush ();
status Restart ();
void AutoStart (int = -1, int = -1);
virtual void LostServer ();
virtual void GotServer ();
virtual void AbandonRestart ();
cmd_res Execute (const UchTextLine&);
public:
UchTextService (UchBaseMultiplexer&, const char*, const char* = 0);
UchTextService ();
~UchTextService ();
void Init (UchBaseMultiplexer&, const char*, const char* = 0);
status GetStatus () { return StatusFlag; }
int GetRetryTime ();
int GetMaxRetries ();
void Close (); // close after output buffer emptied
void CloseNow (); // close now
};
// the simplest interface to a server.
extern bool TellServer (const char*, const char*, const char*);
class UchTextWord {
protected:
const char* Sval;
int Ival;
public:
inline UchTextWord () : Sval (0), Ival (0) {}
inline UchTextWord (const char* s) { SetVal (s); }
inline UchTextWord (int i) { SetVal (i); }
void SetVal (const char*);
inline void SetVal (int i) { Sval = 0; Ival = i; }
inline bool IsInt () const { return (Sval == 0) ? true : false; }
inline bool IsString () const { return (Sval != 0) ? true : false; }
const char* GetQuotes () const;
inline operator int () const { return Ival; }
inline operator const char* () const { return Sval; }
};
class UchTextLine {
protected:
int Num;
int Max;
UchTextWord* Words;
void NewWord (const char* s, int i);
public:
UchTextLine ();
~UchTextLine ();
inline UchTextWord& operator [] (int i) const { return Words [i]; }
inline int NumWords () const { return Num; }
inline void AddWord (const char* s) { NewWord (s, 0); }
inline void AddWord (int i) { NewWord (0, i); }
void AddTrailer (const UchTextLine&, int);
inline UchTextLine& operator << (int i) { AddWord (i); return *this; }
inline UchTextLine& operator << (const char* s) { AddWord (s); return *this; }
inline UchTextLine& operator << (const UchTextLine& l) { AddTrailer (l, 0); return *this; }
bool Parse (char*);
char* Unparse (char* dest, int len) const;
char* Unparse (UchMsgBuffer*) const;
bool Match (const char*, const char* = 0) const;
int Index (const char*) const;
int Index (int) const;
inline bool Contains (const char* w) const { return (Index (w) == -1) ? false : true; }
inline bool Contains (int i) const { return (Index (i) == -1) ? false : true; }
inline void Reset () { Num = 0; }
};
#endif /* TextStream_H_ */
|
