Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Fetching contributors…

Cannot retrieve contributors at this time

203 lines (155 sloc) 4.238 kb
/*****************************************************************************
$Id$
File: cplusplus.cpp
Date: 27Jul07
Copyright (C) 2006-07 by Francis Cianfrocca. All Rights Reserved.
Gmail: blackhedd
This program is free software; you can redistribute it and/or modify
it under the terms of either: 1) 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; or 2) Ruby's License.
See the file COPYING for complete licensing information.
*****************************************************************************/
#include "project.h"
namespace EM {
static map<unsigned long, Eventable*> Eventables;
static map<unsigned long, void(*)()> Timers;
}
/*******
EM::Run
*******/
void EM::Run (void (*start_func)())
{
evma_set_epoll (1);
evma_initialize_library ((EMCallback)EM::Callback);
if (start_func)
AddTimer (0, start_func);
evma_run_machine();
evma_release_library();
}
/************
EM::AddTimer
************/
void EM::AddTimer (int milliseconds, void (*func)())
{
if (func) {
const unsigned long sig = evma_install_oneshot_timer (milliseconds);
#ifndef HAVE_MAKE_PAIR
Timers.insert (map<unsigned long, void(*)()>::value_type (sig, func));
#else
Timers.insert (make_pair (sig, func));
#endif
}
}
/***************
EM::StopReactor
***************/
void EM::StopReactor()
{
evma_stop_machine();
}
/********************
EM::Acceptor::Accept
********************/
void EM::Acceptor::Accept (const unsigned long signature)
{
Connection *c = MakeConnection();
c->Signature = signature;
#ifndef HAVE_MAKE_PAIR
Eventables.insert (std::map<unsigned long,EM::Eventable*>::value_type (c->Signature, c));
#else
Eventables.insert (make_pair (c->Signature, c));
#endif
c->PostInit();
}
/************************
EM::Connection::SendData
************************/
void EM::Connection::SendData (const char *data)
{
if (data)
SendData (data, strlen (data));
}
/************************
EM::Connection::SendData
************************/
void EM::Connection::SendData (const char *data, int length)
{
evma_send_data_to_connection (Signature, data, length);
}
/*********************
EM::Connection::Close
*********************/
void EM::Connection::Close (bool afterWriting)
{
evma_close_connection (Signature, afterWriting);
}
/***************************
EM::Connection::BindConnect
***************************/
void EM::Connection::BindConnect (const char *bind_addr, int bind_port, const char *host, int port)
{
Signature = evma_connect_to_server (bind_addr, bind_port, host, port);
#ifndef HAVE_MAKE_PAIR
Eventables.insert (std::map<unsigned long,EM::Eventable*>::value_type (Signature, this));
#else
Eventables.insert (make_pair (Signature, this));
#endif
}
/***********************
EM::Connection::Connect
***********************/
void EM::Connection::Connect (const char *host, int port)
{
this->BindConnect(NULL, 0, host, port);
}
/*******************
EM::Acceptor::Start
*******************/
void EM::Acceptor::Start (const char *host, int port)
{
Signature = evma_create_tcp_server (host, port);
#ifndef HAVE_MAKE_PAIR
Eventables.insert (std::map<unsigned long,EM::Eventable*>::value_type (Signature, this));
#else
Eventables.insert (make_pair (Signature, this));
#endif
}
/************
EM::Callback
************/
void EM::Callback (const unsigned long sig, int ev, const char *data, const unsigned long length)
{
EM::Eventable *e;
void (*f)();
switch (ev) {
case EM_TIMER_FIRED:
f = Timers [length]; // actually a binding
if (f)
(*f)();
Timers.erase (length);
break;
case EM_CONNECTION_READ:
e = EM::Eventables [sig];
e->ReceiveData (data, length);
break;
case EM_CONNECTION_COMPLETED:
e = EM::Eventables [sig];
e->ConnectionCompleted();
break;
case EM_CONNECTION_ACCEPTED:
e = EM::Eventables [sig];
e->Accept (length); // actually a binding
break;
case EM_CONNECTION_UNBOUND:
e = EM::Eventables [sig];
e->Unbind();
EM::Eventables.erase (sig);
delete e;
break;
case EM_SSL_HANDSHAKE_COMPLETED:
e = EM::Eventables [sig];
e->SslHandshakeCompleted();
break;
}
}
Jump to Line
Something went wrong with that request. Please try again.