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
|
/* -*- mode: C++; tab-width: 4 -*- */
/* ===================================================================== *\
Copyright (c) 2000-2001 Palm, Inc. or its subsidiaries.
All rights reserved.
This file is part of the Palm OS Emulator.
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.
\* ===================================================================== */
#ifndef EmTransportSocket_h
#define EmTransportSocket_h
#include "EmTransport.h"
#include "SocketMessaging.h"
#include <deque>
#include <map>
#include <vector>
#include <string>
#include "omnithread.h" // omni_mutex
class EmTransportSocket;
class CTCPClientSocket : public CTCPSocket
{
public:
CTCPClientSocket (EventCallback fn, string targetHost, int targetPort, EmTransportSocket* transport);
virtual ~CTCPClientSocket (void);
sockaddr* FillAddress (sockaddr* addr);
virtual ErrCode Open (void);
ErrCode OpenInServerMode (void);
EmTransportSocket* GetOwner (void);
sockaddr* FillLocalAddress (sockaddr* addr);
private:
string fTargetHost;
EmTransportSocket* fTransport; // Owner
};
class EmTransportSocket : public EmTransport
{
public:
typedef string PortName;
typedef vector<PortName> PortNameList;
struct ConfigSocket : public EmTransport::Config
{
ConfigSocket (void);
virtual ~ConfigSocket (void);
virtual EmTransport* NewTransport (void);
virtual EmTransport* GetTransport (void);
bool operator==(const ConfigSocket& other) const;
string fTargetHost;
string fTargetPort;
};
typedef map<PortName, EmTransportSocket*> OpenPortList;
public:
EmTransportSocket (void);
EmTransportSocket (const EmTransportDescriptor&);
EmTransportSocket (const ConfigSocket&);
virtual ~EmTransportSocket (void);
virtual ErrCode Open (void);
virtual ErrCode Close (void);
virtual ErrCode Read (long&, void*);
virtual ErrCode Write (long&, const void*);
virtual Bool CanRead (void);
virtual Bool CanWrite (void);
virtual long BytesInBuffer (long minBytes);
virtual string GetSpecificName (void);
static EmTransportSocket* GetTransport (const ConfigSocket&);
static void GetDescriptorList (EmTransportDescriptorList&);
// ErrCode OpenCommPort (const EmTransportSocket::ConfigSocket&);
ErrCode OpenCommPortListen (const EmTransportSocket::ConfigSocket&);
ErrCode OpenCommPortConnect (const EmTransportSocket::ConfigSocket&);
ErrCode CloseCommPort (void);
ErrCode CloseCommPortConnect (void);
ErrCode CloseCommPortListen (void);
// Manage data coming in the host socket.
void PutIncomingData (const void*, long&);
void GetIncomingData (void*, long&);
long IncomingDataSize (void);
// Manage data going out the host socket.
ErrCode PutOutgoingData (const void*, long&);
long OutgoingDataSize (void);
static void EventCallBack (CSocket* s, int event);
public:
omni_mutex fReadMutex;
deque<char> fReadBuffer;
// CTCPClientSocket* fDataSocket;
CTCPClientSocket* fDataConnectSocket;
CTCPClientSocket* fDataListenSocket;
private:
ConfigSocket fConfig;
Bool fCommEstablished;
static OpenPortList fgOpenPorts;
};
#endif /* EmTransportSocket_h */
|
