Home
last modified time | relevance | path

Searched refs:MsgTimeout (Results 1 – 25 of 36) sorted by relevance

12

/dports/net/nsq/nsq-1.2.1/nsqd/
H A Dclient_v2.go41 MsgTimeout int `json:"msg_timeout"` member
48 MsgTimeout time.Duration member
156 MsgTimeout time.Duration member
202 MsgTimeout: nsqd.getOpts().MsgTimeout,
264 err = c.SetMsgTimeout(data.MsgTimeout)
273 MsgTimeout: c.MsgTimeout,
553 c.MsgTimeout = time.Duration(msgTimeout) * time.Millisecond
H A Dchannel_test.go67 opts.MsgTimeout = 100 * time.Millisecond
79 channel.StartInFlightTimeout(msg, 0, opts.MsgTimeout)
94 time.Sleep(4 * opts.MsgTimeout)
121 channel.StartInFlightTimeout(msg, 0, opts.MsgTimeout)
160 channel.StartInFlightTimeout(msg, 0, opts.MsgTimeout)
H A Doptions.go47 MsgTimeout time.Duration `flag:"msg-timeout"` member
128 MsgTimeout: 60 * time.Second,
H A Dprotocol_v2.go221 msgTimeout := client.MsgTimeout
299 msgTimeout = identifyData.MsgTimeout
417 MsgTimeout int64 `json:"msg_timeout"`
431 MsgTimeout: int64(client.MsgTimeout / time.Millisecond),
950 msgTimeout := client.MsgTimeout
/dports/devel/pycos/pycos-4.8.11/py2/pycos/
H A Ddispycos.py40 MsgTimeout = pycos.MsgTimeout variable
283 self._auth = yield task.receive(timeout=MsgTimeout)
323 yield task.receive(MsgTimeout)
337 yield task.receive(MsgTimeout)
728 rtask = yield task.receive(timeout=MsgTimeout)
1083 reply = yield task.recv(timeout=MsgTimeout)
1100 node_info = yield task.receive(timeout=MsgTimeout)
1137 cpus = yield task.receive(timeout=MsgTimeout)
1176 cpus = yield task.receive(timeout=MsgTimeout)
1209 timeout=MsgTimeout)
[all …]
H A Dnetpycos.py48 MsgTimeout = pycos.MsgTimeout variable
505 def close_peer(self, location, timeout=MsgTimeout):
525 def send_file(self, location, file, dir=None, overwrite=False, timeout=MsgTimeout):
843 sock.settimeout(MsgTimeout)
1430 def monitor(self, task, timeout=MsgTimeout):
1450 def close(self, timeout=MsgTimeout):
1475 dst=self._location, timeout=MsgTimeout)
1748 def shutdown(timeout=MsgTimeout):
/dports/devel/pycos/pycos-4.8.11/py3/pycos/
H A Ddispycos.py40 MsgTimeout = pycos.MsgTimeout variable
293 self._auth = yield task.receive(timeout=MsgTimeout)
333 yield task.receive(MsgTimeout)
347 yield task.receive(MsgTimeout)
736 rtask = yield task.receive(timeout=MsgTimeout)
1091 reply = yield task.recv(timeout=MsgTimeout)
1108 node_info = yield task.receive(timeout=MsgTimeout)
1145 cpus = yield task.receive(timeout=MsgTimeout)
1184 cpus = yield task.receive(timeout=MsgTimeout)
1217 timeout=MsgTimeout)
[all …]
H A Dnetpycos.py48 MsgTimeout = pycos.MsgTimeout variable
498 def close_peer(self, location, timeout=MsgTimeout):
518 def send_file(self, location, file, dir=None, overwrite=False, timeout=MsgTimeout):
836 sock.settimeout(MsgTimeout)
1423 def monitor(self, task, timeout=MsgTimeout):
1443 def close(self, timeout=MsgTimeout):
1468 dst=self._location, timeout=MsgTimeout)
1741 def shutdown(timeout=MsgTimeout):
/dports/devel/pycos/pycos-4.8.11/py3.7/pycos/
H A Ddispycos.py40 MsgTimeout = pycos.MsgTimeout variable
293 self._auth = yield task.receive(timeout=MsgTimeout)
333 yield task.receive(MsgTimeout)
347 yield task.receive(MsgTimeout)
736 rtask = yield task.receive(timeout=MsgTimeout)
1091 reply = yield task.recv(timeout=MsgTimeout)
1108 node_info = yield task.receive(timeout=MsgTimeout)
1145 cpus = yield task.receive(timeout=MsgTimeout)
1184 cpus = yield task.receive(timeout=MsgTimeout)
1217 timeout=MsgTimeout)
[all …]
H A Dnetpycos.py48 MsgTimeout = pycos.MsgTimeout variable
498 def close_peer(self, location, timeout=MsgTimeout):
518 def send_file(self, location, file, dir=None, overwrite=False, timeout=MsgTimeout):
836 sock.settimeout(MsgTimeout)
1423 def monitor(self, task, timeout=MsgTimeout):
1443 def close(self, timeout=MsgTimeout):
1468 dst=self._location, timeout=MsgTimeout)
1741 def shutdown(timeout=MsgTimeout):
/dports/devel/dispy/dispy-4.10.6/py3/
H A Ddispy.py54 MsgTimeout = 10 variable
632 sock.settimeout(MsgTimeout)
1048 conn.settimeout(MsgTimeout)
3043 sock.settimeout(MsgTimeout)
3094 sock.settimeout(MsgTimeout)
3227 sock.settimeout(MsgTimeout)
3253 sock.settimeout(MsgTimeout)
3280 sock.settimeout(MsgTimeout)
3306 sock.settimeout(MsgTimeout)
3333 sock.settimeout(MsgTimeout)
[all …]
/dports/devel/dispy/dispy-4.10.6/py3.7/dispy/
H A D__init__.py54 MsgTimeout = 10 variable
632 sock.settimeout(MsgTimeout)
1048 conn.settimeout(MsgTimeout)
3043 sock.settimeout(MsgTimeout)
3094 sock.settimeout(MsgTimeout)
3227 sock.settimeout(MsgTimeout)
3253 sock.settimeout(MsgTimeout)
3280 sock.settimeout(MsgTimeout)
3306 sock.settimeout(MsgTimeout)
3333 sock.settimeout(MsgTimeout)
[all …]
H A Ddispynetrelay.py107 sock.settimeout(dispy.MsgTimeout)
199 conn.settimeout(dispy.MsgTimeout)
234 sock.settimeout(dispy.MsgTimeout)
H A Ddispyscheduler.py45 _same_file, MsgTimeout, _node_ipaddr
338 sock.settimeout(MsgTimeout)
381 conn.settimeout(MsgTimeout)
449 sock.settimeout(MsgTimeout)
818 conn.settimeout(MsgTimeout)
1227 tcp_sock.settimeout(MsgTimeout)
1463 sock.settimeout(MsgTimeout)
1523 sock.settimeout(MsgTimeout)
1541 sock.settimeout(MsgTimeout)
1996 sock.settimeout(MsgTimeout)
[all …]
H A Ddispynode.py104 def dispy_send_file(path, timeout=MsgTimeout):
833 sock.settimeout(MsgTimeout)
855 sock.settimeout(MsgTimeout)
868 sock.settimeout(MsgTimeout)
917 sock.settimeout(MsgTimeout)
1920 sock.settimeout(MsgTimeout)
2125 sock.settimeout(MsgTimeout)
2280 sock.settimeout(MsgTimeout)
2390 sock.settimeout(MsgTimeout)
2437 sock.settimeout(MsgTimeout)
[all …]
/dports/devel/dispy/dispy-4.10.6/py3/dispy/
H A D__init__.py54 MsgTimeout = 10 variable
632 sock.settimeout(MsgTimeout)
1048 conn.settimeout(MsgTimeout)
3043 sock.settimeout(MsgTimeout)
3094 sock.settimeout(MsgTimeout)
3227 sock.settimeout(MsgTimeout)
3253 sock.settimeout(MsgTimeout)
3280 sock.settimeout(MsgTimeout)
3306 sock.settimeout(MsgTimeout)
3333 sock.settimeout(MsgTimeout)
[all …]
H A Ddispynetrelay.py107 sock.settimeout(dispy.MsgTimeout)
199 conn.settimeout(dispy.MsgTimeout)
234 sock.settimeout(dispy.MsgTimeout)
H A Ddispynode.py104 def dispy_send_file(path, timeout=MsgTimeout):
833 sock.settimeout(MsgTimeout)
855 sock.settimeout(MsgTimeout)
868 sock.settimeout(MsgTimeout)
917 sock.settimeout(MsgTimeout)
1920 sock.settimeout(MsgTimeout)
2125 sock.settimeout(MsgTimeout)
2280 sock.settimeout(MsgTimeout)
2390 sock.settimeout(MsgTimeout)
2437 sock.settimeout(MsgTimeout)
[all …]
H A Ddispyscheduler.py45 _same_file, MsgTimeout, _node_ipaddr
338 sock.settimeout(MsgTimeout)
381 conn.settimeout(MsgTimeout)
449 sock.settimeout(MsgTimeout)
818 conn.settimeout(MsgTimeout)
1227 tcp_sock.settimeout(MsgTimeout)
1463 sock.settimeout(MsgTimeout)
1523 sock.settimeout(MsgTimeout)
1541 sock.settimeout(MsgTimeout)
1996 sock.settimeout(MsgTimeout)
[all …]
/dports/devel/dispy/dispy-4.10.6/py3.7/
H A Ddispy.py54 MsgTimeout = 10 variable
632 sock.settimeout(MsgTimeout)
1048 conn.settimeout(MsgTimeout)
3043 sock.settimeout(MsgTimeout)
3094 sock.settimeout(MsgTimeout)
3227 sock.settimeout(MsgTimeout)
3253 sock.settimeout(MsgTimeout)
3280 sock.settimeout(MsgTimeout)
3306 sock.settimeout(MsgTimeout)
3333 sock.settimeout(MsgTimeout)
[all …]
/dports/devel/dispy/dispy-4.10.6/py2/
H A Ddispy.py54 MsgTimeout = 10 variable
626 sock.settimeout(MsgTimeout)
1041 conn.settimeout(MsgTimeout)
3036 sock.settimeout(MsgTimeout)
3087 sock.settimeout(MsgTimeout)
3220 sock.settimeout(MsgTimeout)
3246 sock.settimeout(MsgTimeout)
3273 sock.settimeout(MsgTimeout)
3299 sock.settimeout(MsgTimeout)
3326 sock.settimeout(MsgTimeout)
[all …]
/dports/devel/dispy/dispy-4.10.6/py2/dispy/
H A D__init__.py54 MsgTimeout = 10 variable
626 sock.settimeout(MsgTimeout)
1041 conn.settimeout(MsgTimeout)
3036 sock.settimeout(MsgTimeout)
3087 sock.settimeout(MsgTimeout)
3220 sock.settimeout(MsgTimeout)
3246 sock.settimeout(MsgTimeout)
3273 sock.settimeout(MsgTimeout)
3299 sock.settimeout(MsgTimeout)
3326 sock.settimeout(MsgTimeout)
[all …]
H A Ddispynetrelay.py103 sock.settimeout(dispy.MsgTimeout)
195 conn.settimeout(dispy.MsgTimeout)
230 sock.settimeout(dispy.MsgTimeout)
H A Ddispyscheduler.py44 _same_file, MsgTimeout, _node_ipaddr
334 sock.settimeout(MsgTimeout)
377 conn.settimeout(MsgTimeout)
445 sock.settimeout(MsgTimeout)
814 conn.settimeout(MsgTimeout)
1223 tcp_sock.settimeout(MsgTimeout)
1459 sock.settimeout(MsgTimeout)
1519 sock.settimeout(MsgTimeout)
1537 sock.settimeout(MsgTimeout)
1992 sock.settimeout(MsgTimeout)
[all …]
H A Ddispynode.py100 def dispy_send_file(path, timeout=MsgTimeout):
827 sock.settimeout(MsgTimeout)
849 sock.settimeout(MsgTimeout)
862 sock.settimeout(MsgTimeout)
911 sock.settimeout(MsgTimeout)
1914 sock.settimeout(MsgTimeout)
2119 sock.settimeout(MsgTimeout)
2274 sock.settimeout(MsgTimeout)
2392 sock.settimeout(MsgTimeout)
2439 sock.settimeout(MsgTimeout)
[all …]

12