|
/********************************************************************
File : ChannelFactory.h
Creation date : 2010/6/27
License : Copyright 2010 Ahmed Charfeddine, http://www.pushframework.com
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*********************************************************************/
#ifndef ChannelFactory__INCLUDED
#define ChannelFactory__INCLUDED
#pragma once
#include "Channel.h"
namespace PushFramework{
class ServerImpl;
class Listener;
typedef struct IPRange
{
IN_ADDR startIP;
IN_ADDR endIP;
} IPRange;
class ChannelFactory
{
public:
ChannelFactory(ServerImpl* pServerImpl);
~ChannelFactory(void);
void setMaxAllowedConnections(unsigned int nMaxConnections);
bool SetupClientConnection(SOCKET hSocket, SOCKADDR_IN address, Listener* pListener);
bool SetupDashboardConnection(SOCKET hSocket, SOCKADDR_IN address, Listener* pListener);
void setLoginExpiryDuration(unsigned int uLoginExpireDuration);
CChannel* getObject(CChannel::Key key);
void disposeObject(CChannel::Key key);
void closeNonLogged();
void BroadcastToMonitors(OutgoingPacket* pPacket);
void ProcessPendingObserversPackets();
void ProcessPendingClientPackets(std::string broadcastChannel);
void addIPRangeAccess(const char* ipStart, const char* ipStop, bool bPermit);
private:
ServerImpl* pServerImpl;
//
void addObject(CChannel* pChannel);
void removeObject(CChannel::Key key);
private:
typedef std::map<CChannel::Key, CChannel*> channelMapT;
channelMapT channelMap;
channelMapT observersChannelMap;
//
CRITICAL_SECTION csChannelMap;
void disposeChannel(CChannel* pChannel);
//
unsigned int uLoginExpireDuration;
private:
unsigned int nMaxConnections;
bool SetupPhysicalConnection(SOCKET hSocket, ListenerOptions* pListenerOptions, SOCKADDR_IN address, bool isObserver);
bool isNotBlockedAddress(IN_ADDR SockAddr);
typedef std::vector<IPRange> ipRangeListT;
ipRangeListT blockedIPs;
ipRangeListT permittedIPs;
//
bool isPermitOnly;
};
}
#endif // ChannelFactory__INCLUDED
|
By viewing downloads associated with this article you agree to the Terms of Service and the article's licence.
If a file you wish to view isn't highlighted, and is a text file (not binary), please
let us know and we'll add colourisation support for it.