Skip to content

Commit f6ad59b

Browse files
marius311stevengj
authored andcommitted
make work with ipc transport (#868)
1 parent 92b01a2 commit f6ad59b

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

src/init.jl

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -84,11 +84,12 @@ function init(args)
8484
requests[] = Socket(ROUTER)
8585
control[] = Socket(ROUTER)
8686
heartbeat[] = Socket(ROUTER)
87-
bind(publish[], "$(profile["transport"])://$(profile["ip"]):$(profile["iopub_port"])")
88-
bind(requests[], "$(profile["transport"])://$(profile["ip"]):$(profile["shell_port"])")
89-
bind(control[], "$(profile["transport"])://$(profile["ip"]):$(profile["control_port"])")
90-
bind(raw_input[], "$(profile["transport"])://$(profile["ip"]):$(profile["stdin_port"])")
91-
bind(heartbeat[], "$(profile["transport"])://$(profile["ip"]):$(profile["hb_port"])")
87+
sep = profile["transport"]=="ipc" ? "-" : ":"
88+
bind(publish[], "$(profile["transport"])://$(profile["ip"])$(sep)$(profile["iopub_port"])")
89+
bind(requests[], "$(profile["transport"])://$(profile["ip"])$(sep)$(profile["shell_port"])")
90+
bind(control[], "$(profile["transport"])://$(profile["ip"])$(sep)$(profile["control_port"])")
91+
bind(raw_input[], "$(profile["transport"])://$(profile["ip"])$(sep)$(profile["stdin_port"])")
92+
bind(heartbeat[], "$(profile["transport"])://$(profile["ip"])$(sep)$(profile["hb_port"])")
9293

9394
# associate a lock with each socket so that multi-part messages
9495
# on a given socket don't get inter-mingled between tasks.

0 commit comments

Comments
 (0)