Changeset 424

Show
Ignore:
Timestamp:
07/16/07 21:22:03 (1 year ago)
Author:
blackhedd
Message:

start_tls

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • experiments/jruby-1/src/com/rubyeventmachine/EM.java

    r423 r424  
    3535import java.net.*; 
    3636import java.util.concurrent.atomic.*; 
     37import javax.net.ssl.*; 
    3738 
    3839public class EM { 
    …… 
    113114                                                        EventableChannel ec = new EventableChannel (sn, b, mySelector); 
    114115                                                        Connections.put(b, ec); 
    115                                                         //eventCallback ((String)k.attachment(), EM_CONNECTION_ACCEPTED, b, b.length()); 
    116116                                                        eventCallback ((String)k.attachment(), EM_CONNECTION_ACCEPTED, ByteBuffer.wrap(b.getBytes())); 
    117117                                                } 
    …… 
    124124                                                if (r > 0) { 
    125125                                                        bb.flip(); 
    126                                                         //eventCallback (((EventableChannel)k.attachment()).getBinding(), EM_CONNECTION_READ, new String(bb.array(), 0, bb.limit()), bb.limit()); 
    127126                                                        eventCallback (((EventableChannel)k.attachment()).getBinding(), EM_CONNECTION_READ, bb); 
    128127                                                } 
    129128                                                else { 
    130129                                                        String b = ((EventableChannel)k.attachment()).getBinding(); 
    131                                                         //eventCallback (b, EM_CONNECTION_UNBOUND, "", 0); 
    132                                                         eventCallback (b, EM_CONNECTION_UNBOUND, EmptyByteBuffer); // TODO, have this BB around somewhere, don't generate garbage. 
     130                                                        eventCallback (b, EM_CONNECTION_UNBOUND, EmptyByteBuffer); 
    133131                                                        Connections.remove(b); 
    134132                                                        sn.close(); 
    …… 
    148146                                                EventableChannel ec = (EventableChannel)k.attachment(); 
    149147                                                if (ec.finishConnecting()) { 
    150                                                         //eventCallback (ec.getBinding(), EM_CONNECTION_COMPLETED, "", 0); 
    151148                                                        eventCallback (ec.getBinding(), EM_CONNECTION_COMPLETED, EmptyByteBuffer); 
    152149                                                } 
    …… 
    154151                                                        Connections.remove (ec.getBinding()); 
    155152                                                        k.channel().close(); 
    156                                                         //eventCallback (ec.getBinding(), EM_CONNECTION_UNBOUND, "", 0); 
    157153                                                        eventCallback (ec.getBinding(), EM_CONNECTION_UNBOUND, EmptyByteBuffer); 
    158154                                                } 
    …… 
    184180                bRunReactor = false; 
    185181                signalLoopbreak(); 
    186                 // TODO, signal the loopbreaker. 
    187182        } 
    188183         
    …… 
    194189                                break; 
    195190                        String s = Timers.remove(k); 
    196                         //eventCallback ("", 100, s, s.length()); 
    197191                        eventCallback ("", EM_TIMER_FIRED, ByteBuffer.wrap(s.getBytes())); 
    198192                } 

  • version_0/lib/jeventmachine.rb

    r420 r424  
    7070                @em.closeConnection sig, after_writing 
    7171        end 
     72        def self.start_tls sig 
     73                @em.startTls sig 
     74        end 
    7275end 
    7376