Changeset 347

Timestamp:

06/01/07 12:35:49 (2 years ago)

Author:

blackhedd

Message:

added EventMachine::Connection#get_outbound_data_size

Files:

• version_0/ChangeLog (modified) (1 diff)
• version_0/ext/cmain.cpp (modified) (1 diff)
• version_0/ext/eventmachine.h (modified) (1 diff)
• version_0/ext/rubymain.cpp (modified) (5 diffs)

version_0/ChangeLog

@@ -30 +30 @@
-01Jun07: Added EM, a "pseudo-alias" for EventMachine.
-01Jun07: Added EM#next_tick.
+01Jun07: Added EM::Connection#get_outbound_data_size

version_0/ext/cmain.cpp

@@ -304 +304 @@
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+

version_0/ext/eventmachine.h

@@ -49 +49 @@
-        int evma_get_comm_inactivity_timeout (const char *binding, /*out*/int *value);
-        int evma_set_comm_inactivity_timeout (const char *binding, /*in,out*/int *value);
+        int evma_get_outbound_data_size (const char *binding);
+
-        void evma_close_connection (const char *binding, int after_writing);
-        void evma_signal_loopbreak();

version_0/ext/rubymain.cpp

@@ -29 +29 @@
-
-static VALUE EmModule;
+static VALUE EmConnection;
+
+static VALUE Intern_at_signature;
-
-
@@ -324 +327 @@
-
-
+
+/***************************
+conn_get_outbound_data_size
+***************************/
+
+static VALUE conn_get_outbound_data_size (VALUE self)
+{
+        VALUE sig = rb_ivar_get (self, Intern_at_signature);
+        return INT2NUM (evma_get_outbound_data_size (StringValuePtr(sig)));
+}
+
+
+
-/*********************
-Init_rubyeventmachine
@@ -330 +346 @@
-extern "C" void Init_rubyeventmachine()
-{
+        // Tuck away some symbol values so we don't have to look 'em up every time we need 'em.
+        Intern_at_signature = rb_intern ("@signature");
+
-        // INCOMPLETE, we need to define class Connections inside module EventMachine
-        // run_machine and run_machine_without_threads are now identical.
-        // Must deprecate the without_threads variant.
-        EmModule = rb_define_module ("EventMachine");
+        EmConnection = rb_define_class_under (EmModule, "Connection", rb_cObject);
+
+        rb_define_class_under (EmModule, "ConnectionNotBound", rb_eException);
+        rb_define_class_under (EmModule, "NoHandlerForAcceptedConnection", rb_eException);
+        rb_define_class_under (EmModule, "UnknownTimerFired", rb_eException);
+
-        rb_define_module_function (EmModule, "initialize_event_machine", (VALUE(*)(...))t_initialize_event_machine, 0);
-        rb_define_module_function (EmModule, "run_machine", (VALUE(*)(...))t_run_machine_without_threads, 0);
@@ -355 +380 @@
-        rb_define_module_function (EmModule, "invoke_popen", (VALUE(*)(...))t_invoke_popen, 2);
-
-  
+       
-        rb_define_module_function (EmModule, "_write_file", (VALUE(*)(...))t__write_file, 1);
-
@@ -362 +387 @@
-        rb_define_module_function (EmModule, "set_comm_inactivity_timeout", (VALUE(*)(...))t_set_comm_inactivity_timeout, 2);
-
-
-
-
+
-
-        rb_define_const (EmModule, "TimerFired", INT2NUM(100));