/dports/net/nsq/nsq-1.2.1/nsqd/ |
H A D | client_v2.go | 41 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 D | channel_test.go | 67 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 D | options.go | 47 MsgTimeout time.Duration `flag:"msg-timeout"` member 128 MsgTimeout: 60 * time.Second,
|
H A D | protocol_v2.go | 221 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 D | dispycos.py | 40 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 D | netpycos.py | 48 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 D | dispycos.py | 40 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 D | netpycos.py | 48 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 D | dispycos.py | 40 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 D | netpycos.py | 48 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 D | dispy.py | 54 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__.py | 54 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 D | dispynetrelay.py | 107 sock.settimeout(dispy.MsgTimeout) 199 conn.settimeout(dispy.MsgTimeout) 234 sock.settimeout(dispy.MsgTimeout)
|
H A D | dispyscheduler.py | 45 _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 D | dispynode.py | 104 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__.py | 54 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 D | dispynetrelay.py | 107 sock.settimeout(dispy.MsgTimeout) 199 conn.settimeout(dispy.MsgTimeout) 234 sock.settimeout(dispy.MsgTimeout)
|
H A D | dispynode.py | 104 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 D | dispyscheduler.py | 45 _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 D | dispy.py | 54 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 D | dispy.py | 54 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__.py | 54 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 D | dispynetrelay.py | 103 sock.settimeout(dispy.MsgTimeout) 195 conn.settimeout(dispy.MsgTimeout) 230 sock.settimeout(dispy.MsgTimeout)
|
H A D | dispyscheduler.py | 44 _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 D | dispynode.py | 100 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 …]
|