Displaying 20 results from an estimated 1000 matches similar to: "broadcast"
2007 Nov 15
3
0-length datagram
There appears to be a problem with sending 0-length (UDP) datagrams. I
have a little UDP server running on port 1392, and when I execute the
following client code the server does not receive anything. However if I
change it to data="x", the server receives it just fine.
EM::run {
conn = EM::open_datagram_socket( "", 0 )
data = ""
puts
2008 Jan 06
5
Having very odd problems with UDP.
I am using eventmachine 0.8.1 on windows XP and am having very odd problems.
This snippet of code gives the error that follows it.
class EchoServer
def receive_data data
puts data
send_data ">>>you sent: #{data}"
if data =~ /quit/i
puts "quitting"
close_connection
EventMachine::stop_event_loop
end
end
end
2008 Aug 22
6
EventMachine website down?
Hi all
Is the EventMachine website (www.rubyeventmachine.com) down? I can''t access
it from South Africa, and have tried using tor as well with no luck.
I''m kinda new to EventMachine, so I first have a lot of examples to work
through and reading to do before I start pestering the mailing list with
questions.
Thanks to everyone who partook in creating the library, so far
2008 Apr 23
2
Status of EventMachine.fork
Hi All,
I''m currently looking into doing a bit of evented network programming
in ruby and i''m currently looking into packet, eventmachine and rev.
The problem is that I need to be able to fork and start a new reactor
within the forked child (it also should open a socket and write
status information back to the main process). I have not been able to
do this with EventMachine.
2007 Feb 25
6
Crash occurs where EventMachine.connect is
Hi everyone,
If you subclass EventMachine::Connection and call it outside an
EventMachine::run
event loop, EventMachine crashes! Example:
class Put < EventMachine::Connection
include EventMachine::Deferrable
HOST="localhost"
PORT=8080
def self.request(data)
EventMachine.connect(HOST, PORT, self) {|c|
c.instance_eval { @data = data }
}
end
#
2009 Mar 15
2
How can I add TimeoutHandler to EvenmentMachine
Hi, list
Now I am coding for one non-blocking httpclient based on event-machine, and
it seems the client will hang for 50 seconds if the destination is
unreachable. My questions are
1. How can I short the timeout? I had tried
conn.set_comm_inactivity_timeout(5), but it didn''t work
2. How can I add TimeoutHandler to the connection?
Thanks!
/Jack
--
Jack Tang
Software
2007 Nov 09
1
EventMachine::run - How can I ensure that this
Friends,
I am writing an event system which has an interface on a web site which can create events.
The creation of events opens up EventMachine::run and connects to the event server, and sends messages.
The problem comes if this is run inside of say, event driven mongrel, where it will crash fatally, the same as:
EventMachine::run { EventMachine::run { } }
The only solution that
2006 Nov 03
6
How to send data,
Hello,
First of all I''m new to working with sockets,
so the problems I''m having are probably because of my lack of understanding.
What I''m trying to accomplish is to create a mac os x client gui to ruby-debug.
When a application that includes ruby-debug is started,
it starts listening for 2 connections; 8989, 8990
The connection is made by calling the connectToApp
2006 Aug 08
11
Core dump using sample DumbHttpClient
I''m using the current release branch from the repository (version_0)
on freebsd 6.1 with ruby 1.8.4. This is the error that is generated
when running the code below at the bottom of the message, plus a gdb
bt. Sorry no debugging symbols built into ruby but maybe the bt will
help anyways.
terminate called after throwing an instance of ''std::runtime_error''
what():
2007 Feb 26
9
libevent
Francis,
I read in the list archives back that a future EventMachine release
will support epoll on Linux (i.e., it''s in the trunk).
Better still, is there a possibility that EM will rely on libevent so
that it will be architecture independent (i.e. epoll on Linux, kqueue
on FreeBSD/Mac OS X, /dev/poll on Solaris)? This is how memcached is
implemented, and it would be helpful to be able
2008 Jan 14
10
Using EventMachine to listen from non-network
I''ve actually found a way to make EventMachine listen to events from a
serial port, but only by using the pure Ruby version, using Guilliame
Pierronnet''s Ruby/SerialPort library. It turned out to be simpler
than I thought it would be:
require ''serialport''
$eventmachine_library = :pure_ruby
require ''eventmachine''
module EventMachine
class
2008 Feb 01
6
epoll increasing latency big time
Sorry this is going to be a bit vague, but I''ve noticed something rather odd
going on with EventMachine on Linux.
I''ve written something uses EventMachine to proxy HTTP to other processes.
On OS X, it works great, adding only about 20% extra latency into the
connection when proxying versus connecting to the original backend process
directly, so a 5ms connection might now take
2007 Nov 07
4
Gracefully stopping EventMachine?
Hello all,
I''ve been learning Ruby and playing with a chat server I built using
GServer. After into an issue I found with GServer, that no one else seemed
to notice (actually, similar to this question, GServer is hard to kill
nicely, especially when you want to.), I found references to EventMachine,
and rebuilt my server using it. I much prefer EventMachine''s model.
The
2006 Jul 11
32
Database Concurrency Without a Web Server?
My Rails application requires a very busy worker process running in the
background at all times. I am launching this non-interactive process
using script/runner. This process is very busy and is communicating
with the MySQL server constantly. As I started putting some load on the
system to test, I started running into performance issues.
I have since discovered that Rails is only using 1
2007 Dec 09
38
libevent
Hello,
I have been looking at the Ruby/EventMachine. First let me say it look very
good. Reactor model with no threads makes for fast reliable server, and I
have read about marvelous Twisted framework for Python and am glad to see
something similar for Ruby.
I am writing network app with Ruby threads now and it very slow, and I try
new Ruby 1.9 with native threads that make it much slower.
2007 May 24
4
Multiple EM connections on separate threads
Hi EM Gurus,
I''m hoping someone can shed some light on the following...
I''m using a 3rd party (legacy) server that can accept up to 8
simultaneous connections on one port.
I''ve been able to make multiple connections to this server from within
one call to EventMachine::run {...}.
Specificaly, I can access each connection separately using:
em_thread = Thread.new do
2008 Apr 30
5
get_peername - start_server vs. connect
Hi,
On windows, get_peername works both with connections obtained
via start_server, and connections obtained via connect.
On linux, get_peername seems to only work with connections
obtained via start_server.
(I''m using svn HEAD.)
I''m wondering which is the intended behavior?
(I realize get_peername is less useful for connections obtained
via connect, since one should already
2007 Sep 14
3
epoll appears to break
The following program is a minor variant on the sample given in the README
with eventmachine-0.8.1. I am running under CentOS 4.5 (kernel
2.6.9-55.0.2.plus.c4) with a ruby-1.8.5 RPM from the CentOS testing
repository.
When I run it, I find that set_comm_inactivity_timeout doesn''t do anything.
That is, if I client opens a connection, it stays open indefinitely.
However, if I comment out
2011 Sep 26
2
undefined method `options' for #<EventMachine::HttpClien
Hi , I am writing a rake task to consume twitter stream API. The task
contains the following code:
consumer = OAuth::Consumer.new(CONSUMER_KEY, CONSUMER_SECRET, :site =>
''http://twitter.com'')
access_token =
OAuth::AccessToken.new(consumer,ACCESS_TOKEN,ACCESS_TOKEN_SECRET)
oauth_params = {:consumer => consumer, :token => access_token}
EventMachine.run do
# now,
2006 Dec 15
5
Testing event driven Socket classes
Ok, here is the class, I want to Unit Test, its part of a large app
and is based on EventMachine library.
I want to mock the class TickServer ( i.e not stub it) . Since in
actual scenario, you can''t do this on this class:
@server = TickServer.new # will toss an exception at your face
you must initialize the server like this:
EventMachine.run {