+++ /dev/null
-/*
- * Copyright (c) 2000-2001 Apple Computer, Inc. All Rights Reserved.
- *
- * The contents of this file constitute Original Code as defined in and are
- * subject to the Apple Public Source License Version 1.2 (the 'License').
- * You may not use this file except in compliance with the License. Please obtain
- * a copy of the License at http://www.apple.com/publicsource and read it before
- * using this file.
- *
- * This Original Code and all software distributed under the License are
- * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESS
- * OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES, INCLUDING WITHOUT
- * LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
- * PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT. Please see the License for the
- * specific language governing rights and limitations under the License.
- */
-
-
-//
-// socks++int - internal Socks implementation
-//
-#include "socks++4.h"
-#include "hosts.h"
-#include <set>
-
-
-namespace Security {
-namespace IPPlusPlus {
-namespace Socks4 {
-
-
-
-//
-// Socks4 Protocol implementation
-//
-void Server::connect(SocksClientSocket &me, const IPSockAddress &peer)
-{
- me.Socket::open(SOCK_STREAM);
- me.Socket::connect(mServerAddress);
- Message request(socksConnect, peer);
- request.send(me, "nobody");
- (Message(me)); // read and check reply message
- me.mPeerAddress = peer; // best guess, Mr. Sulu
- secdebug("socks", "%d socks4 connected to %s", me.fd(), string(peer).c_str());
-}
-
-void Server::connect(SocksClientSocket &me, const Host &host, IPPort port)
-{
- // Socks4 has no name resolution support. Do it here
- //@@@ error reporting sucks here
- set<IPAddress> addrs = host.addresses();
- for (set<IPAddress>::const_iterator it = addrs.begin(); it != addrs.end(); it++) {
- try {
- IPSockAddress addr(*it, port);
- connect(me, addr);
- return;
- } catch (const UnixError &err) {
- errno = err.error;
- }
- }
- // exhausted
- UnixError::throwMe();
-}
-
-
-void Server::bind(SocksServerSocket &me, const IPAddress &peer, IPPort port)
-{
- me.Socket::open(SOCK_STREAM);
- me.Socket::connect(mServerAddress);
- Message request(socksBind, IPSockAddress(peer, port));
- request.send(me, "nobody");
- Message reply(me);
- me.mLocalAddress = reply.address().defaults(mServerAddress.address());
- secdebug("socks", "%d socks4 bound to %s", me.fd(), string(me.mLocalAddress).c_str());
-}
-
-void Server::receive(SocksServerSocket &me, SocksClientSocket &receiver)
-{
- Message reply(me);
- receiver.setFd(me.fd(), me.mLocalAddress, reply.address());
- me.clear(); // clear our own (don't close on destruction)
- secdebug("socks", "%d socks4 inbound connect", receiver.fd());
-}
-
-
-//
-// Message properties
-//
-Message::Message(Command cmd, const IPSockAddress &address)
- : version(4), message(cmd), port(htons(address.port())), addr(address.address())
-{
-}
-
-
-void Message::send(Socket &s, const char *userid)
-{
- if (s.write(this, sizeof(*this)) != sizeof(*this))
- UnixError::throwMe();
- // now append zero-terminated userid (what a crock)
- size_t length = strlen(userid) + 1;
- if (s.write(userid, length) != length) {
- s.close();
- UnixError::throwMe();
- }
-}
-
-Message::Message(Socket &s)
-{
- if (s.read(this, sizeof(*this)) != sizeof(*this)) {
- s.close();
- UnixError::throwMe();
- }
- if (version != 0) {
- s.close();
- UnixError::throwMe(EPROTONOSUPPORT);
- }
- switch (message) {
- case requestAccepted:
- return;
- default:
- UnixError::throwMe(ECONNREFUSED); //@@@ hardly any diagnostics here
- }
-}
-
-
-} // end namespace Socks
-} // end namespace IPPlusPlus
-} // end namespace Security