1 files changed, 125 insertions, 0 deletions
diff --git a/SrcShared/EmTransportSocket.h b/SrcShared/EmTransportSocket.h
new file mode 100644
index 0000000..10f0ed3
--- /dev/null
+++ b/SrcShared/EmTransportSocket.h
@@ -0,0 +1,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 */