Skip to content

enm goes into infinite loop with pipeline tcp connection - when tcp service is not running. #7

Open
@harishdeshmukh

Description

@harishdeshmukh

enm goes into infinite loop with pipeline tcp connection - when tcp service is not running.

start() ->
    enm:start_link(),
    Url = "tcp://localhost:8789",
    {ok,Push} = enm:push([{connect,Url},list]),
    Send1 = "Hello, World!",
    io:format("pushing message \"~s\"~n", [Send1]),
    ok = enm:send(Push, Send1),
    Send2 = "Goodbye.",
    io:format("pushing message \"~s\"~n", [Send2]),
    ok = enm:send(Push, Send2),
    enm:close(Push),
    enm:stop().

Scenario:
a. Connect Url is tcp
b. The tcp service is not running
c. Run the following code. I just did

$ erl -pa ebin deps/*/ebin
1> c("src/pipeline.erl").
{ok,pipeline}
3> pipeline:start().
pushing message "Hello, World!"
pushing message "Goodbye."

d. Look at top - the erlang process is taking 100% CPU.
e. CentOS - Linux version 3.10.0-123.20.1.el7.x86_64 ([email protected])
f. gcc version 4.8.2 20140120

Is it a known issue? Please let me know if its a user error.

Thanks.

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions