# $Id: jeventmachine.rb 771 2008-08-28 00:45:23Z francis $
#
# Author:: Francis Cianfrocca (gmail: blackhedd)
# Homepage::  http://rubyeventmachine.com
# Date:: 8 Apr 2006
# 
# See EventMachine and EventMachine::Connection for documentation and
# usage examples.
#
#----------------------------------------------------------------------------
#
# 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.
#
#---------------------------------------------------------------------------
#
# 


# This module provides "glue" for the Java version of the EventMachine reactor core.
# For C++ EventMachines, the analogous functionality is found in ext/rubymain.cpp,
# which is a garden-variety Ruby-extension glue module.


require 'em_reactor'

module EventMachine
	# TODO: These event numbers are defined in way too many places.
	# DRY them up.
	TimerFired = 100
	ConnectionData = 101
	ConnectionUnbound = 102
	ConnectionAccepted = 103
	ConnectionCompleted = 104
	LoopbreakSignalled = 105

	# This thunk class used to be called EM, but that caused conflicts with
	# the alias "EM" for module EventMachine. (FC, 20Jun08)
	class JEM < com.rubyeventmachine.EmReactor
		def eventCallback a1, a2, a3
			s = String.from_java_bytes(a3.array[a3.position...a3.limit])
			EventMachine::event_callback a1, a2, s
		end
	end
	def self.initialize_event_machine
		@em = JEM.new
	end
	def self.release_machine
		@em = nil
	end
	def self.add_oneshot_timer interval
		@em.installOneshotTimer interval
	end
	def self.run_machine
		@em.run
	end
	def self.stop
		@em.stop
	end
	def self.start_tcp_server server, port
		@em.startTcpServer server, port
	end
	def self.stop_tcp_server sig
		@em.stopTcpServer sig
	end
	def self.start_unix_server filename
		# TEMPORARILY unsupported until someone figures out how to do it.
		raise "unsupported on this platform"
	end
	def self.send_data sig, data, length
		@em.sendData sig, data.to_java_bytes
	end
	def self.send_datagram sig, data, length, address, port
		@em.sendDatagram sig, data, length, address, port
	end
	def self.connect_server server, port
		@em.connectTcpServer server, port
	end
	def self.close_connection sig, after_writing
		@em.closeConnection sig, after_writing
	end
	def self.set_comm_inactivity_timeout sig, interval
		@em.setCommInactivityTimeout sig, interval
	end
	def self.start_tls sig
		@em.startTls sig
	end
	def self.signal_loopbreak
		@em.signalLoopbreak
	end
	def self.set_timer_quantum q
		@em.setTimerQuantum q
	end
	def self.epoll
		# Epoll is a no-op for Java.
		# The latest Java versions run epoll when possible in NIO.
	end
	def self.set_rlimit_nofile n_descriptors
		# Currently a no-op for Java.
	end
	def self.open_udp_socket server, port
		@em.openUdpSocket server, port
	end
	def self.invoke_popen cmd
		# TEMPORARILY unsupported until someone figures out how to do it.
		raise "unsupported on this platform"
	end
	def self.read_keyboard
		# TEMPORARILY unsupported until someone figures out how to do it.
		raise "temporarily unsupported on this platform"
	end
	def self.set_max_timer_count num
		# harmless no-op in Java. There's no built-in timer limit.
	end
	def self.library_type
		:java
	end

	class Connection
		def associate_callback_target sig
			# No-op for the time being
		end
	end
end