Skip to content

Commit 82d6cc3

Browse files
knopers8teo
authored andcommitted
[O2-2818][core] Disable autoBind in FairMQ
This makes FairMQ produce an error when failing to bind a port instead of selecting a random one in the range 22000-23000, which is useless in our case. Probably not related to OCTRL-773, but should fix O2-2818, where we obliviously run a QC proxy which could not bind a port due to a leftover task on the same machine.
1 parent 54ac191 commit 82d6cc3

1 file changed

Lines changed: 9 additions & 8 deletions

File tree

core/task/channel/inbound.go

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -152,19 +152,20 @@ func (inbound *Inbound) buildFMQMap(address string, transport TransportType) (pm
152152
prefix := strings.Join([]string{chans, chName, "0"}, ".")
153153

154154
chanProps := controlcommands.PropertyMap{
155-
"address": address,
156-
"method": "bind",
157-
"rateLogging": inbound.RateLogging,
158-
"rcvBufSize": strconv.Itoa(inbound.RcvBufSize),
155+
"address": address,
156+
"method": "bind",
157+
"autoBind": "false",
158+
"rateLogging": inbound.RateLogging,
159+
"rcvBufSize": strconv.Itoa(inbound.RcvBufSize),
159160
"rcvKernelSize": "0", //NOTE: hardcoded
160-
"sndBufSize": strconv.Itoa(inbound.SndBufSize),
161+
"sndBufSize": strconv.Itoa(inbound.SndBufSize),
161162
"sndKernelSize": "0", //NOTE: hardcoded
162-
"transport": transport.String(),
163-
"type": inbound.Type.String(),
163+
"transport": transport.String(),
164+
"type": inbound.Type.String(),
164165
}
165166

166167
for k, v := range chanProps {
167-
pm[prefix + "." + k] = v
168+
pm[prefix+"."+k] = v
168169
}
169170
return
170171
}

0 commit comments

Comments
 (0)