Coverage for /pythoncovmergedfiles/medio/medio/usr/local/lib/python3.11/site-packages/zmq/constants.py: 96%

1"""zmq constants as enums""" 

2 

3from __future__ import annotations 

4 

5import errno 

6import sys 

7from enum import Enum, IntEnum, IntFlag 

8 

9_HAUSNUMERO = 156384712 

10 

11 

12class Errno(IntEnum): 

13 """libzmq error codes 

14 

15 .. versionadded:: 23 

16 """ 

17 

18 EAGAIN = errno.EAGAIN 

19 EFAULT = errno.EFAULT 

20 EINVAL = errno.EINVAL 

21 

22 if sys.platform.startswith("win"): 

23 # Windows: libzmq uses errno.h 

24 # while Python errno prefers WSA* variants 

25 # many of these were introduced to errno.h in vs2010 

26 # ref: https://github.com/python/cpython/blob/3.9/Modules/errnomodule.c#L10-L37 

27 # source: https://docs.microsoft.com/en-us/cpp/c-runtime-library/errno-constants 

28 ENOTSUP = 129 

29 EPROTONOSUPPORT = 135 

30 ENOBUFS = 119 

31 ENETDOWN = 116 

32 EADDRINUSE = 100 

33 EADDRNOTAVAIL = 101 

34 ECONNREFUSED = 107 

35 EINPROGRESS = 112 

36 ENOTSOCK = 128 

37 EMSGSIZE = 115 

38 EAFNOSUPPORT = 102 

39 ENETUNREACH = 118 

40 ECONNABORTED = 106 

41 ECONNRESET = 108 

42 ENOTCONN = 126 

43 ETIMEDOUT = 138 

44 EHOSTUNREACH = 110 

45 ENETRESET = 117 

46 

47 else: 

48 ENOTSUP = getattr(errno, "ENOTSUP", _HAUSNUMERO + 1) 

49 EPROTONOSUPPORT = getattr(errno, "EPROTONOSUPPORT", _HAUSNUMERO + 2) 

50 ENOBUFS = getattr(errno, "ENOBUFS", _HAUSNUMERO + 3) 

51 ENETDOWN = getattr(errno, "ENETDOWN", _HAUSNUMERO + 4) 

52 EADDRINUSE = getattr(errno, "EADDRINUSE", _HAUSNUMERO + 5) 

53 EADDRNOTAVAIL = getattr(errno, "EADDRNOTAVAIL", _HAUSNUMERO + 6) 

54 ECONNREFUSED = getattr(errno, "ECONNREFUSED", _HAUSNUMERO + 7) 

55 EINPROGRESS = getattr(errno, "EINPROGRESS", _HAUSNUMERO + 8) 

56 ENOTSOCK = getattr(errno, "ENOTSOCK", _HAUSNUMERO + 9) 

57 EMSGSIZE = getattr(errno, "EMSGSIZE", _HAUSNUMERO + 10) 

58 EAFNOSUPPORT = getattr(errno, "EAFNOSUPPORT", _HAUSNUMERO + 11) 

59 ENETUNREACH = getattr(errno, "ENETUNREACH", _HAUSNUMERO + 12) 

60 ECONNABORTED = getattr(errno, "ECONNABORTED", _HAUSNUMERO + 13) 

61 ECONNRESET = getattr(errno, "ECONNRESET", _HAUSNUMERO + 14) 

62 ENOTCONN = getattr(errno, "ENOTCONN", _HAUSNUMERO + 15) 

63 ETIMEDOUT = getattr(errno, "ETIMEDOUT", _HAUSNUMERO + 16) 

64 EHOSTUNREACH = getattr(errno, "EHOSTUNREACH", _HAUSNUMERO + 17) 

65 ENETRESET = getattr(errno, "ENETRESET", _HAUSNUMERO + 18) 

66 

67 # Native 0MQ error codes 

68 EFSM = _HAUSNUMERO + 51 

69 ENOCOMPATPROTO = _HAUSNUMERO + 52 

70 ETERM = _HAUSNUMERO + 53 

71 EMTHREAD = _HAUSNUMERO + 54 

72 

73 

74class ContextOption(IntEnum): 

75 """Options for Context.get/set 

76 

77 .. versionadded:: 23 

78 """ 

79 

80 IO_THREADS = 1 

81 MAX_SOCKETS = 2 

82 SOCKET_LIMIT = 3 

83 THREAD_PRIORITY = 3 

84 THREAD_SCHED_POLICY = 4 

85 MAX_MSGSZ = 5 

86 MSG_T_SIZE = 6 

87 THREAD_AFFINITY_CPU_ADD = 7 

88 THREAD_AFFINITY_CPU_REMOVE = 8 

89 THREAD_NAME_PREFIX = 9 

90 

91 

92class SocketType(IntEnum): 

93 """zmq socket types 

94 

95 .. versionadded:: 23 

96 """ 

97 

98 PAIR = 0 

99 PUB = 1 

100 SUB = 2 

101 REQ = 3 

102 REP = 4 

103 DEALER = 5 

104 ROUTER = 6 

105 PULL = 7 

106 PUSH = 8 

107 XPUB = 9 

108 XSUB = 10 

109 STREAM = 11 

110 

111 # deprecated aliases 

112 XREQ = DEALER 

113 XREP = ROUTER 

114 

115 # DRAFT socket types 

116 SERVER = 12 

117 CLIENT = 13 

118 RADIO = 14 

119 DISH = 15 

120 GATHER = 16 

121 SCATTER = 17 

122 DGRAM = 18 

123 PEER = 19 

124 CHANNEL = 20 

125 

126 

127class _OptType(Enum): 

128 int = 'int' 

129 int64 = 'int64' 

130 bytes = 'bytes' 

131 fd = 'fd' 

132 

133 

134class SocketOption(IntEnum): 

135 """Options for Socket.get/set 

136 

137 .. versionadded:: 23 

138 """ 

139 

140 _opt_type: _OptType 

141 

142 def __new__(cls, value: int, opt_type: _OptType = _OptType.int): 

143 """Attach option type as `._opt_type`""" 

144 obj = int.__new__(cls, value) 

145 obj._value_ = value 

146 obj._opt_type = opt_type 

147 return obj 

148 

149 HWM = 1 

150 AFFINITY = 4, _OptType.int64 

151 ROUTING_ID = 5, _OptType.bytes 

152 SUBSCRIBE = 6, _OptType.bytes 

153 UNSUBSCRIBE = 7, _OptType.bytes 

154 RATE = 8 

155 RECOVERY_IVL = 9 

156 SNDBUF = 11 

157 RCVBUF = 12 

158 RCVMORE = 13 

159 FD = 14, _OptType.fd 

160 EVENTS = 15 

161 TYPE = 16 

162 LINGER = 17 

163 RECONNECT_IVL = 18 

164 BACKLOG = 19 

165 RECONNECT_IVL_MAX = 21 

166 MAXMSGSIZE = 22, _OptType.int64 

167 SNDHWM = 23 

168 RCVHWM = 24 

169 MULTICAST_HOPS = 25 

170 RCVTIMEO = 27 

171 SNDTIMEO = 28 

172 LAST_ENDPOINT = 32, _OptType.bytes 

173 ROUTER_MANDATORY = 33 

174 TCP_KEEPALIVE = 34 

175 TCP_KEEPALIVE_CNT = 35 

176 TCP_KEEPALIVE_IDLE = 36 

177 TCP_KEEPALIVE_INTVL = 37 

178 IMMEDIATE = 39 

179 XPUB_VERBOSE = 40 

180 ROUTER_RAW = 41 

181 IPV6 = 42 

182 MECHANISM = 43 

183 PLAIN_SERVER = 44 

184 PLAIN_USERNAME = 45, _OptType.bytes 

185 PLAIN_PASSWORD = 46, _OptType.bytes 

186 CURVE_SERVER = 47 

187 CURVE_PUBLICKEY = 48, _OptType.bytes 

188 CURVE_SECRETKEY = 49, _OptType.bytes 

189 CURVE_SERVERKEY = 50, _OptType.bytes 

190 PROBE_ROUTER = 51 

191 REQ_CORRELATE = 52 

192 REQ_RELAXED = 53 

193 CONFLATE = 54 

194 ZAP_DOMAIN = 55, _OptType.bytes 

195 ROUTER_HANDOVER = 56 

196 TOS = 57 

197 CONNECT_ROUTING_ID = 61, _OptType.bytes 

198 GSSAPI_SERVER = 62 

199 GSSAPI_PRINCIPAL = 63, _OptType.bytes 

200 GSSAPI_SERVICE_PRINCIPAL = 64, _OptType.bytes 

201 GSSAPI_PLAINTEXT = 65 

202 HANDSHAKE_IVL = 66 

203 SOCKS_PROXY = 68, _OptType.bytes 

204 XPUB_NODROP = 69 

205 BLOCKY = 70 

206 XPUB_MANUAL = 71 

207 XPUB_WELCOME_MSG = 72, _OptType.bytes 

208 STREAM_NOTIFY = 73 

209 INVERT_MATCHING = 74 

210 HEARTBEAT_IVL = 75 

211 HEARTBEAT_TTL = 76 

212 HEARTBEAT_TIMEOUT = 77 

213 XPUB_VERBOSER = 78 

214 CONNECT_TIMEOUT = 79 

215 TCP_MAXRT = 80 

216 THREAD_SAFE = 81 

217 MULTICAST_MAXTPDU = 84 

218 VMCI_BUFFER_SIZE = 85, _OptType.int64 

219 VMCI_BUFFER_MIN_SIZE = 86, _OptType.int64 

220 VMCI_BUFFER_MAX_SIZE = 87, _OptType.int64 

221 VMCI_CONNECT_TIMEOUT = 88 

222 USE_FD = 89 

223 GSSAPI_PRINCIPAL_NAMETYPE = 90 

224 GSSAPI_SERVICE_PRINCIPAL_NAMETYPE = 91 

225 BINDTODEVICE = 92, _OptType.bytes 

226 

227 # Deprecated options and aliases 

228 # must not use name-assignment, must have the same value 

229 IDENTITY = ROUTING_ID 

230 CONNECT_RID = CONNECT_ROUTING_ID 

231 TCP_ACCEPT_FILTER = 38, _OptType.bytes 

232 IPC_FILTER_PID = 58 

233 IPC_FILTER_UID = 59 

234 IPC_FILTER_GID = 60 

235 IPV4ONLY = 31 

236 DELAY_ATTACH_ON_CONNECT = IMMEDIATE 

237 FAIL_UNROUTABLE = ROUTER_MANDATORY 

238 ROUTER_BEHAVIOR = ROUTER_MANDATORY 

239 

240 # Draft socket options 

241 ZAP_ENFORCE_DOMAIN = 93 

242 LOOPBACK_FASTPATH = 94 

243 METADATA = 95, _OptType.bytes 

244 MULTICAST_LOOP = 96 

245 ROUTER_NOTIFY = 97 

246 XPUB_MANUAL_LAST_VALUE = 98 

247 SOCKS_USERNAME = 99, _OptType.bytes 

248 SOCKS_PASSWORD = 100, _OptType.bytes 

249 IN_BATCH_SIZE = 101 

250 OUT_BATCH_SIZE = 102 

251 WSS_KEY_PEM = 103, _OptType.bytes 

252 WSS_CERT_PEM = 104, _OptType.bytes 

253 WSS_TRUST_PEM = 105, _OptType.bytes 

254 WSS_HOSTNAME = 106, _OptType.bytes 

255 WSS_TRUST_SYSTEM = 107 

256 ONLY_FIRST_SUBSCRIBE = 108 

257 RECONNECT_STOP = 109 

258 HELLO_MSG = 110, _OptType.bytes 

259 DISCONNECT_MSG = 111, _OptType.bytes 

260 PRIORITY = 112 

261 # 4.3.5 

262 BUSY_POLL = 113 

263 HICCUP_MSG = 114, _OptType.bytes 

264 XSUB_VERBOSE_UNSUBSCRIBE = 115 

265 TOPICS_COUNT = 116 

266 NORM_MODE = 117 

267 NORM_UNICAST_NACK = 118 

268 NORM_BUFFER_SIZE = 119 

269 NORM_SEGMENT_SIZE = 120 

270 NORM_BLOCK_SIZE = 121 

271 NORM_NUM_PARITY = 122 

272 NORM_NUM_AUTOPARITY = 123 

273 NORM_PUSH = 124 

274 

275 

276class MessageOption(IntEnum): 

277 """Options on zmq.Frame objects 

278 

279 .. versionadded:: 23 

280 """ 

281 

282 MORE = 1 

283 SHARED = 3 

284 # Deprecated message options 

285 SRCFD = 2 

286 

287 

288class Flag(IntFlag): 

289 """Send/recv flags 

290 

291 .. versionadded:: 23 

292 """ 

293 

294 DONTWAIT = 1 

295 SNDMORE = 2 

296 NOBLOCK = DONTWAIT 

297 

298 

299class RouterNotify(IntEnum): 

300 """Values for zmq.ROUTER_NOTIFY socket option 

301 

302 .. versionadded:: 26 

303 .. versionadded:: libzmq-4.3.0 (draft) 

304 """ 

305 

306 @staticmethod 

307 def _global_name(name): 

308 return f"NOTIFY_{name}" 

309 

310 CONNECT = 1 

311 DISCONNECT = 2 

312 

313 

314class NormMode(IntEnum): 

315 """Values for zmq.NORM_MODE socket option 

316 

317 .. versionadded:: 26 

318 .. versionadded:: libzmq-4.3.5 (draft) 

319 """ 

320 

321 @staticmethod 

322 def _global_name(name): 

323 return f"NORM_{name}" 

324 

325 FIXED = 0 

326 CC = 1 

327 CCL = 2 

328 CCE = 3 

329 CCE_ECNONLY = 4 

330 

331 

332class SecurityMechanism(IntEnum): 

333 """Security mechanisms (as returned by ``socket.get(zmq.MECHANISM)``) 

334 

335 .. versionadded:: 23 

336 """ 

337 

338 NULL = 0 

339 PLAIN = 1 

340 CURVE = 2 

341 GSSAPI = 3 

342 

343 

344class ReconnectStop(IntEnum): 

345 """Select behavior for socket.reconnect_stop 

346 

347 .. versionadded:: 25 

348 """ 

349 

350 @staticmethod 

351 def _global_name(name): 

352 return f"RECONNECT_STOP_{name}" 

353 

354 CONN_REFUSED = 0x1 

355 HANDSHAKE_FAILED = 0x2 

356 AFTER_DISCONNECT = 0x4 

357 

358 

359class Event(IntFlag): 

360 """Socket monitoring events 

361 

362 .. versionadded:: 23 

363 """ 

364 

365 @staticmethod 

366 def _global_name(name): 

367 if name.startswith("PROTOCOL_ERROR_"): 

368 return name 

369 else: 

370 # add EVENT_ prefix 

371 return "EVENT_" + name 

372 

373 PROTOCOL_ERROR_WS_UNSPECIFIED = 0x30000000 

374 PROTOCOL_ERROR_ZMTP_UNSPECIFIED = 0x10000000 

375 PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND = 0x10000001 

376 PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE = 0x10000002 

377 PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE = 0x10000003 

378 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED = 0x10000011 

379 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE = 0x10000012 

380 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO = 0x10000013 

381 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE = 0x10000014 

382 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR = 0x10000015 

383 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY = 0x10000016 

384 PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME = 0x10000017 

385 PROTOCOL_ERROR_ZMTP_INVALID_METADATA = 0x10000018 

386 

387 PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC = 0x11000001 

388 PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH = 0x11000002 

389 PROTOCOL_ERROR_ZAP_UNSPECIFIED = 0x20000000 

390 PROTOCOL_ERROR_ZAP_MALFORMED_REPLY = 0x20000001 

391 PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID = 0x20000002 

392 PROTOCOL_ERROR_ZAP_BAD_VERSION = 0x20000003 

393 PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE = 0x20000004 

394 PROTOCOL_ERROR_ZAP_INVALID_METADATA = 0x20000005 

395 

396 # define event types _after_ overlapping protocol error masks 

397 CONNECTED = 0x0001 

398 CONNECT_DELAYED = 0x0002 

399 CONNECT_RETRIED = 0x0004 

400 LISTENING = 0x0008 

401 BIND_FAILED = 0x0010 

402 ACCEPTED = 0x0020 

403 ACCEPT_FAILED = 0x0040 

404 CLOSED = 0x0080 

405 CLOSE_FAILED = 0x0100 

406 DISCONNECTED = 0x0200 

407 MONITOR_STOPPED = 0x0400 

408 

409 HANDSHAKE_FAILED_NO_DETAIL = 0x0800 

410 HANDSHAKE_SUCCEEDED = 0x1000 

411 HANDSHAKE_FAILED_PROTOCOL = 0x2000 

412 HANDSHAKE_FAILED_AUTH = 0x4000 

413 

414 ALL_V1 = 0xFFFF 

415 ALL = ALL_V1 

416 

417 # DRAFT Socket monitoring events 

418 PIPES_STATS = 0x10000 

419 ALL_V2 = ALL_V1 | PIPES_STATS 

420 

421 

422class PollEvent(IntFlag): 

423 """Which events to poll for in poll methods 

424 

425 .. versionadded: 23 

426 """ 

427 

428 POLLIN = 1 

429 POLLOUT = 2 

430 POLLERR = 4 

431 POLLPRI = 8 

432 

433 

434class DeviceType(IntEnum): 

435 """Device type constants for zmq.device 

436 

437 .. versionadded: 23 

438 """ 

439 

440 STREAMER = 1 

441 FORWARDER = 2 

442 QUEUE = 3 

443 

444 

445# AUTOGENERATED_BELOW_HERE 

446 

447 

448IO_THREADS: int = ContextOption.IO_THREADS 

449MAX_SOCKETS: int = ContextOption.MAX_SOCKETS 

450SOCKET_LIMIT: int = ContextOption.SOCKET_LIMIT 

451THREAD_PRIORITY: int = ContextOption.THREAD_PRIORITY 

452THREAD_SCHED_POLICY: int = ContextOption.THREAD_SCHED_POLICY 

453MAX_MSGSZ: int = ContextOption.MAX_MSGSZ 

454MSG_T_SIZE: int = ContextOption.MSG_T_SIZE 

455THREAD_AFFINITY_CPU_ADD: int = ContextOption.THREAD_AFFINITY_CPU_ADD 

456THREAD_AFFINITY_CPU_REMOVE: int = ContextOption.THREAD_AFFINITY_CPU_REMOVE 

457THREAD_NAME_PREFIX: int = ContextOption.THREAD_NAME_PREFIX 

458STREAMER: int = DeviceType.STREAMER 

459FORWARDER: int = DeviceType.FORWARDER 

460QUEUE: int = DeviceType.QUEUE 

461EAGAIN: int = Errno.EAGAIN 

462EFAULT: int = Errno.EFAULT 

463EINVAL: int = Errno.EINVAL 

464ENOTSUP: int = Errno.ENOTSUP 

465EPROTONOSUPPORT: int = Errno.EPROTONOSUPPORT 

466ENOBUFS: int = Errno.ENOBUFS 

467ENETDOWN: int = Errno.ENETDOWN 

468EADDRINUSE: int = Errno.EADDRINUSE 

469EADDRNOTAVAIL: int = Errno.EADDRNOTAVAIL 

470ECONNREFUSED: int = Errno.ECONNREFUSED 

471EINPROGRESS: int = Errno.EINPROGRESS 

472ENOTSOCK: int = Errno.ENOTSOCK 

473EMSGSIZE: int = Errno.EMSGSIZE 

474EAFNOSUPPORT: int = Errno.EAFNOSUPPORT 

475ENETUNREACH: int = Errno.ENETUNREACH 

476ECONNABORTED: int = Errno.ECONNABORTED 

477ECONNRESET: int = Errno.ECONNRESET 

478ENOTCONN: int = Errno.ENOTCONN 

479ETIMEDOUT: int = Errno.ETIMEDOUT 

480EHOSTUNREACH: int = Errno.EHOSTUNREACH 

481ENETRESET: int = Errno.ENETRESET 

482EFSM: int = Errno.EFSM 

483ENOCOMPATPROTO: int = Errno.ENOCOMPATPROTO 

484ETERM: int = Errno.ETERM 

485EMTHREAD: int = Errno.EMTHREAD 

486PROTOCOL_ERROR_WS_UNSPECIFIED: int = Event.PROTOCOL_ERROR_WS_UNSPECIFIED 

487PROTOCOL_ERROR_ZMTP_UNSPECIFIED: int = Event.PROTOCOL_ERROR_ZMTP_UNSPECIFIED 

488PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND: int = ( 

489 Event.PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND 

490) 

491PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE: int = Event.PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE 

492PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE: int = Event.PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE 

493PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED: int = ( 

494 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED 

495) 

496PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE: int = ( 

497 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE 

498) 

499PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO: int = ( 

500 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO 

501) 

502PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE: int = ( 

503 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE 

504) 

505PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR: int = ( 

506 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR 

507) 

508PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY: int = ( 

509 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY 

510) 

511PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME: int = ( 

512 Event.PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME 

513) 

514PROTOCOL_ERROR_ZMTP_INVALID_METADATA: int = Event.PROTOCOL_ERROR_ZMTP_INVALID_METADATA 

515PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC: int = Event.PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC 

516PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH: int = ( 

517 Event.PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH 

518) 

519PROTOCOL_ERROR_ZAP_UNSPECIFIED: int = Event.PROTOCOL_ERROR_ZAP_UNSPECIFIED 

520PROTOCOL_ERROR_ZAP_MALFORMED_REPLY: int = Event.PROTOCOL_ERROR_ZAP_MALFORMED_REPLY 

521PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID: int = Event.PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID 

522PROTOCOL_ERROR_ZAP_BAD_VERSION: int = Event.PROTOCOL_ERROR_ZAP_BAD_VERSION 

523PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE: int = ( 

524 Event.PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE 

525) 

526PROTOCOL_ERROR_ZAP_INVALID_METADATA: int = Event.PROTOCOL_ERROR_ZAP_INVALID_METADATA 

527EVENT_CONNECTED: int = Event.CONNECTED 

528EVENT_CONNECT_DELAYED: int = Event.CONNECT_DELAYED 

529EVENT_CONNECT_RETRIED: int = Event.CONNECT_RETRIED 

530EVENT_LISTENING: int = Event.LISTENING 

531EVENT_BIND_FAILED: int = Event.BIND_FAILED 

532EVENT_ACCEPTED: int = Event.ACCEPTED 

533EVENT_ACCEPT_FAILED: int = Event.ACCEPT_FAILED 

534EVENT_CLOSED: int = Event.CLOSED 

535EVENT_CLOSE_FAILED: int = Event.CLOSE_FAILED 

536EVENT_DISCONNECTED: int = Event.DISCONNECTED 

537EVENT_MONITOR_STOPPED: int = Event.MONITOR_STOPPED 

538EVENT_HANDSHAKE_FAILED_NO_DETAIL: int = Event.HANDSHAKE_FAILED_NO_DETAIL 

539EVENT_HANDSHAKE_SUCCEEDED: int = Event.HANDSHAKE_SUCCEEDED 

540EVENT_HANDSHAKE_FAILED_PROTOCOL: int = Event.HANDSHAKE_FAILED_PROTOCOL 

541EVENT_HANDSHAKE_FAILED_AUTH: int = Event.HANDSHAKE_FAILED_AUTH 

542EVENT_ALL_V1: int = Event.ALL_V1 

543EVENT_ALL: int = Event.ALL 

544EVENT_PIPES_STATS: int = Event.PIPES_STATS 

545EVENT_ALL_V2: int = Event.ALL_V2 

546DONTWAIT: int = Flag.DONTWAIT 

547SNDMORE: int = Flag.SNDMORE 

548NOBLOCK: int = Flag.NOBLOCK 

549MORE: int = MessageOption.MORE 

550SHARED: int = MessageOption.SHARED 

551SRCFD: int = MessageOption.SRCFD 

552NORM_FIXED: int = NormMode.FIXED 

553NORM_CC: int = NormMode.CC 

554NORM_CCL: int = NormMode.CCL 

555NORM_CCE: int = NormMode.CCE 

556NORM_CCE_ECNONLY: int = NormMode.CCE_ECNONLY 

557POLLIN: int = PollEvent.POLLIN 

558POLLOUT: int = PollEvent.POLLOUT 

559POLLERR: int = PollEvent.POLLERR 

560POLLPRI: int = PollEvent.POLLPRI 

561RECONNECT_STOP_CONN_REFUSED: int = ReconnectStop.CONN_REFUSED 

562RECONNECT_STOP_HANDSHAKE_FAILED: int = ReconnectStop.HANDSHAKE_FAILED 

563RECONNECT_STOP_AFTER_DISCONNECT: int = ReconnectStop.AFTER_DISCONNECT 

564NOTIFY_CONNECT: int = RouterNotify.CONNECT 

565NOTIFY_DISCONNECT: int = RouterNotify.DISCONNECT 

566NULL: int = SecurityMechanism.NULL 

567PLAIN: int = SecurityMechanism.PLAIN 

568CURVE: int = SecurityMechanism.CURVE 

569GSSAPI: int = SecurityMechanism.GSSAPI 

570HWM: int = SocketOption.HWM 

571AFFINITY: int = SocketOption.AFFINITY 

572ROUTING_ID: int = SocketOption.ROUTING_ID 

573SUBSCRIBE: int = SocketOption.SUBSCRIBE 

574UNSUBSCRIBE: int = SocketOption.UNSUBSCRIBE 

575RATE: int = SocketOption.RATE 

576RECOVERY_IVL: int = SocketOption.RECOVERY_IVL 

577SNDBUF: int = SocketOption.SNDBUF 

578RCVBUF: int = SocketOption.RCVBUF 

579RCVMORE: int = SocketOption.RCVMORE 

580FD: int = SocketOption.FD 

581EVENTS: int = SocketOption.EVENTS 

582TYPE: int = SocketOption.TYPE 

583LINGER: int = SocketOption.LINGER 

584RECONNECT_IVL: int = SocketOption.RECONNECT_IVL 

585BACKLOG: int = SocketOption.BACKLOG 

586RECONNECT_IVL_MAX: int = SocketOption.RECONNECT_IVL_MAX 

587MAXMSGSIZE: int = SocketOption.MAXMSGSIZE 

588SNDHWM: int = SocketOption.SNDHWM 

589RCVHWM: int = SocketOption.RCVHWM 

590MULTICAST_HOPS: int = SocketOption.MULTICAST_HOPS 

591RCVTIMEO: int = SocketOption.RCVTIMEO 

592SNDTIMEO: int = SocketOption.SNDTIMEO 

593LAST_ENDPOINT: int = SocketOption.LAST_ENDPOINT 

594ROUTER_MANDATORY: int = SocketOption.ROUTER_MANDATORY 

595TCP_KEEPALIVE: int = SocketOption.TCP_KEEPALIVE 

596TCP_KEEPALIVE_CNT: int = SocketOption.TCP_KEEPALIVE_CNT 

597TCP_KEEPALIVE_IDLE: int = SocketOption.TCP_KEEPALIVE_IDLE 

598TCP_KEEPALIVE_INTVL: int = SocketOption.TCP_KEEPALIVE_INTVL 

599IMMEDIATE: int = SocketOption.IMMEDIATE 

600XPUB_VERBOSE: int = SocketOption.XPUB_VERBOSE 

601ROUTER_RAW: int = SocketOption.ROUTER_RAW 

602IPV6: int = SocketOption.IPV6 

603MECHANISM: int = SocketOption.MECHANISM 

604PLAIN_SERVER: int = SocketOption.PLAIN_SERVER 

605PLAIN_USERNAME: int = SocketOption.PLAIN_USERNAME 

606PLAIN_PASSWORD: int = SocketOption.PLAIN_PASSWORD 

607CURVE_SERVER: int = SocketOption.CURVE_SERVER 

608CURVE_PUBLICKEY: int = SocketOption.CURVE_PUBLICKEY 

609CURVE_SECRETKEY: int = SocketOption.CURVE_SECRETKEY 

610CURVE_SERVERKEY: int = SocketOption.CURVE_SERVERKEY 

611PROBE_ROUTER: int = SocketOption.PROBE_ROUTER 

612REQ_CORRELATE: int = SocketOption.REQ_CORRELATE 

613REQ_RELAXED: int = SocketOption.REQ_RELAXED 

614CONFLATE: int = SocketOption.CONFLATE 

615ZAP_DOMAIN: int = SocketOption.ZAP_DOMAIN 

616ROUTER_HANDOVER: int = SocketOption.ROUTER_HANDOVER 

617TOS: int = SocketOption.TOS 

618CONNECT_ROUTING_ID: int = SocketOption.CONNECT_ROUTING_ID 

619GSSAPI_SERVER: int = SocketOption.GSSAPI_SERVER 

620GSSAPI_PRINCIPAL: int = SocketOption.GSSAPI_PRINCIPAL 

621GSSAPI_SERVICE_PRINCIPAL: int = SocketOption.GSSAPI_SERVICE_PRINCIPAL 

622GSSAPI_PLAINTEXT: int = SocketOption.GSSAPI_PLAINTEXT 

623HANDSHAKE_IVL: int = SocketOption.HANDSHAKE_IVL 

624SOCKS_PROXY: int = SocketOption.SOCKS_PROXY 

625XPUB_NODROP: int = SocketOption.XPUB_NODROP 

626BLOCKY: int = SocketOption.BLOCKY 

627XPUB_MANUAL: int = SocketOption.XPUB_MANUAL 

628XPUB_WELCOME_MSG: int = SocketOption.XPUB_WELCOME_MSG 

629STREAM_NOTIFY: int = SocketOption.STREAM_NOTIFY 

630INVERT_MATCHING: int = SocketOption.INVERT_MATCHING 

631HEARTBEAT_IVL: int = SocketOption.HEARTBEAT_IVL 

632HEARTBEAT_TTL: int = SocketOption.HEARTBEAT_TTL 

633HEARTBEAT_TIMEOUT: int = SocketOption.HEARTBEAT_TIMEOUT 

634XPUB_VERBOSER: int = SocketOption.XPUB_VERBOSER 

635CONNECT_TIMEOUT: int = SocketOption.CONNECT_TIMEOUT 

636TCP_MAXRT: int = SocketOption.TCP_MAXRT 

637THREAD_SAFE: int = SocketOption.THREAD_SAFE 

638MULTICAST_MAXTPDU: int = SocketOption.MULTICAST_MAXTPDU 

639VMCI_BUFFER_SIZE: int = SocketOption.VMCI_BUFFER_SIZE 

640VMCI_BUFFER_MIN_SIZE: int = SocketOption.VMCI_BUFFER_MIN_SIZE 

641VMCI_BUFFER_MAX_SIZE: int = SocketOption.VMCI_BUFFER_MAX_SIZE 

642VMCI_CONNECT_TIMEOUT: int = SocketOption.VMCI_CONNECT_TIMEOUT 

643USE_FD: int = SocketOption.USE_FD 

644GSSAPI_PRINCIPAL_NAMETYPE: int = SocketOption.GSSAPI_PRINCIPAL_NAMETYPE 

645GSSAPI_SERVICE_PRINCIPAL_NAMETYPE: int = SocketOption.GSSAPI_SERVICE_PRINCIPAL_NAMETYPE 

646BINDTODEVICE: int = SocketOption.BINDTODEVICE 

647IDENTITY: int = SocketOption.IDENTITY 

648CONNECT_RID: int = SocketOption.CONNECT_RID 

649TCP_ACCEPT_FILTER: int = SocketOption.TCP_ACCEPT_FILTER 

650IPC_FILTER_PID: int = SocketOption.IPC_FILTER_PID 

651IPC_FILTER_UID: int = SocketOption.IPC_FILTER_UID 

652IPC_FILTER_GID: int = SocketOption.IPC_FILTER_GID 

653IPV4ONLY: int = SocketOption.IPV4ONLY 

654DELAY_ATTACH_ON_CONNECT: int = SocketOption.DELAY_ATTACH_ON_CONNECT 

655FAIL_UNROUTABLE: int = SocketOption.FAIL_UNROUTABLE 

656ROUTER_BEHAVIOR: int = SocketOption.ROUTER_BEHAVIOR 

657ZAP_ENFORCE_DOMAIN: int = SocketOption.ZAP_ENFORCE_DOMAIN 

658LOOPBACK_FASTPATH: int = SocketOption.LOOPBACK_FASTPATH 

659METADATA: int = SocketOption.METADATA 

660MULTICAST_LOOP: int = SocketOption.MULTICAST_LOOP 

661ROUTER_NOTIFY: int = SocketOption.ROUTER_NOTIFY 

662XPUB_MANUAL_LAST_VALUE: int = SocketOption.XPUB_MANUAL_LAST_VALUE 

663SOCKS_USERNAME: int = SocketOption.SOCKS_USERNAME 

664SOCKS_PASSWORD: int = SocketOption.SOCKS_PASSWORD 

665IN_BATCH_SIZE: int = SocketOption.IN_BATCH_SIZE 

666OUT_BATCH_SIZE: int = SocketOption.OUT_BATCH_SIZE 

667WSS_KEY_PEM: int = SocketOption.WSS_KEY_PEM 

668WSS_CERT_PEM: int = SocketOption.WSS_CERT_PEM 

669WSS_TRUST_PEM: int = SocketOption.WSS_TRUST_PEM 

670WSS_HOSTNAME: int = SocketOption.WSS_HOSTNAME 

671WSS_TRUST_SYSTEM: int = SocketOption.WSS_TRUST_SYSTEM 

672ONLY_FIRST_SUBSCRIBE: int = SocketOption.ONLY_FIRST_SUBSCRIBE 

673RECONNECT_STOP: int = SocketOption.RECONNECT_STOP 

674HELLO_MSG: int = SocketOption.HELLO_MSG 

675DISCONNECT_MSG: int = SocketOption.DISCONNECT_MSG 

676PRIORITY: int = SocketOption.PRIORITY 

677BUSY_POLL: int = SocketOption.BUSY_POLL 

678HICCUP_MSG: int = SocketOption.HICCUP_MSG 

679XSUB_VERBOSE_UNSUBSCRIBE: int = SocketOption.XSUB_VERBOSE_UNSUBSCRIBE 

680TOPICS_COUNT: int = SocketOption.TOPICS_COUNT 

681NORM_MODE: int = SocketOption.NORM_MODE 

682NORM_UNICAST_NACK: int = SocketOption.NORM_UNICAST_NACK 

683NORM_BUFFER_SIZE: int = SocketOption.NORM_BUFFER_SIZE 

684NORM_SEGMENT_SIZE: int = SocketOption.NORM_SEGMENT_SIZE 

685NORM_BLOCK_SIZE: int = SocketOption.NORM_BLOCK_SIZE 

686NORM_NUM_PARITY: int = SocketOption.NORM_NUM_PARITY 

687NORM_NUM_AUTOPARITY: int = SocketOption.NORM_NUM_AUTOPARITY 

688NORM_PUSH: int = SocketOption.NORM_PUSH 

689PAIR: int = SocketType.PAIR 

690PUB: int = SocketType.PUB 

691SUB: int = SocketType.SUB 

692REQ: int = SocketType.REQ 

693REP: int = SocketType.REP 

694DEALER: int = SocketType.DEALER 

695ROUTER: int = SocketType.ROUTER 

696PULL: int = SocketType.PULL 

697PUSH: int = SocketType.PUSH 

698XPUB: int = SocketType.XPUB 

699XSUB: int = SocketType.XSUB 

700STREAM: int = SocketType.STREAM 

701XREQ: int = SocketType.XREQ 

702XREP: int = SocketType.XREP 

703SERVER: int = SocketType.SERVER 

704CLIENT: int = SocketType.CLIENT 

705RADIO: int = SocketType.RADIO 

706DISH: int = SocketType.DISH 

707GATHER: int = SocketType.GATHER 

708SCATTER: int = SocketType.SCATTER 

709DGRAM: int = SocketType.DGRAM 

710PEER: int = SocketType.PEER 

711CHANNEL: int = SocketType.CHANNEL 

712 

713__all__: list[str] = [ 

714 "ContextOption", 

715 "IO_THREADS", 

716 "MAX_SOCKETS", 

717 "SOCKET_LIMIT", 

718 "THREAD_PRIORITY", 

719 "THREAD_SCHED_POLICY", 

720 "MAX_MSGSZ", 

721 "MSG_T_SIZE", 

722 "THREAD_AFFINITY_CPU_ADD", 

723 "THREAD_AFFINITY_CPU_REMOVE", 

724 "THREAD_NAME_PREFIX", 

725 "DeviceType", 

726 "STREAMER", 

727 "FORWARDER", 

728 "QUEUE", 

729 "Enum", 

730 "Errno", 

731 "EAGAIN", 

732 "EFAULT", 

733 "EINVAL", 

734 "ENOTSUP", 

735 "EPROTONOSUPPORT", 

736 "ENOBUFS", 

737 "ENETDOWN", 

738 "EADDRINUSE", 

739 "EADDRNOTAVAIL", 

740 "ECONNREFUSED", 

741 "EINPROGRESS", 

742 "ENOTSOCK", 

743 "EMSGSIZE", 

744 "EAFNOSUPPORT", 

745 "ENETUNREACH", 

746 "ECONNABORTED", 

747 "ECONNRESET", 

748 "ENOTCONN", 

749 "ETIMEDOUT", 

750 "EHOSTUNREACH", 

751 "ENETRESET", 

752 "EFSM", 

753 "ENOCOMPATPROTO", 

754 "ETERM", 

755 "EMTHREAD", 

756 "Event", 

757 "PROTOCOL_ERROR_WS_UNSPECIFIED", 

758 "PROTOCOL_ERROR_ZMTP_UNSPECIFIED", 

759 "PROTOCOL_ERROR_ZMTP_UNEXPECTED_COMMAND", 

760 "PROTOCOL_ERROR_ZMTP_INVALID_SEQUENCE", 

761 "PROTOCOL_ERROR_ZMTP_KEY_EXCHANGE", 

762 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_UNSPECIFIED", 

763 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_MESSAGE", 

764 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_HELLO", 

765 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_INITIATE", 

766 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_ERROR", 

767 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_READY", 

768 "PROTOCOL_ERROR_ZMTP_MALFORMED_COMMAND_WELCOME", 

769 "PROTOCOL_ERROR_ZMTP_INVALID_METADATA", 

770 "PROTOCOL_ERROR_ZMTP_CRYPTOGRAPHIC", 

771 "PROTOCOL_ERROR_ZMTP_MECHANISM_MISMATCH", 

772 "PROTOCOL_ERROR_ZAP_UNSPECIFIED", 

773 "PROTOCOL_ERROR_ZAP_MALFORMED_REPLY", 

774 "PROTOCOL_ERROR_ZAP_BAD_REQUEST_ID", 

775 "PROTOCOL_ERROR_ZAP_BAD_VERSION", 

776 "PROTOCOL_ERROR_ZAP_INVALID_STATUS_CODE", 

777 "PROTOCOL_ERROR_ZAP_INVALID_METADATA", 

778 "EVENT_CONNECTED", 

779 "EVENT_CONNECT_DELAYED", 

780 "EVENT_CONNECT_RETRIED", 

781 "EVENT_LISTENING", 

782 "EVENT_BIND_FAILED", 

783 "EVENT_ACCEPTED", 

784 "EVENT_ACCEPT_FAILED", 

785 "EVENT_CLOSED", 

786 "EVENT_CLOSE_FAILED", 

787 "EVENT_DISCONNECTED", 

788 "EVENT_MONITOR_STOPPED", 

789 "EVENT_HANDSHAKE_FAILED_NO_DETAIL", 

790 "EVENT_HANDSHAKE_SUCCEEDED", 

791 "EVENT_HANDSHAKE_FAILED_PROTOCOL", 

792 "EVENT_HANDSHAKE_FAILED_AUTH", 

793 "EVENT_ALL_V1", 

794 "EVENT_ALL", 

795 "EVENT_PIPES_STATS", 

796 "EVENT_ALL_V2", 

797 "Flag", 

798 "DONTWAIT", 

799 "SNDMORE", 

800 "NOBLOCK", 

801 "IntEnum", 

802 "IntFlag", 

803 "MessageOption", 

804 "MORE", 

805 "SHARED", 

806 "SRCFD", 

807 "NormMode", 

808 "NORM_FIXED", 

809 "NORM_CC", 

810 "NORM_CCL", 

811 "NORM_CCE", 

812 "NORM_CCE_ECNONLY", 

813 "PollEvent", 

814 "POLLIN", 

815 "POLLOUT", 

816 "POLLERR", 

817 "POLLPRI", 

818 "ReconnectStop", 

819 "RECONNECT_STOP_CONN_REFUSED", 

820 "RECONNECT_STOP_HANDSHAKE_FAILED", 

821 "RECONNECT_STOP_AFTER_DISCONNECT", 

822 "RouterNotify", 

823 "NOTIFY_CONNECT", 

824 "NOTIFY_DISCONNECT", 

825 "SecurityMechanism", 

826 "NULL", 

827 "PLAIN", 

828 "CURVE", 

829 "GSSAPI", 

830 "SocketOption", 

831 "HWM", 

832 "AFFINITY", 

833 "ROUTING_ID", 

834 "SUBSCRIBE", 

835 "UNSUBSCRIBE", 

836 "RATE", 

837 "RECOVERY_IVL", 

838 "SNDBUF", 

839 "RCVBUF", 

840 "RCVMORE", 

841 "FD", 

842 "EVENTS", 

843 "TYPE", 

844 "LINGER", 

845 "RECONNECT_IVL", 

846 "BACKLOG", 

847 "RECONNECT_IVL_MAX", 

848 "MAXMSGSIZE", 

849 "SNDHWM", 

850 "RCVHWM", 

851 "MULTICAST_HOPS", 

852 "RCVTIMEO", 

853 "SNDTIMEO", 

854 "LAST_ENDPOINT", 

855 "ROUTER_MANDATORY", 

856 "TCP_KEEPALIVE", 

857 "TCP_KEEPALIVE_CNT", 

858 "TCP_KEEPALIVE_IDLE", 

859 "TCP_KEEPALIVE_INTVL", 

860 "IMMEDIATE", 

861 "XPUB_VERBOSE", 

862 "ROUTER_RAW", 

863 "IPV6", 

864 "MECHANISM", 

865 "PLAIN_SERVER", 

866 "PLAIN_USERNAME", 

867 "PLAIN_PASSWORD", 

868 "CURVE_SERVER", 

869 "CURVE_PUBLICKEY", 

870 "CURVE_SECRETKEY", 

871 "CURVE_SERVERKEY", 

872 "PROBE_ROUTER", 

873 "REQ_CORRELATE", 

874 "REQ_RELAXED", 

875 "CONFLATE", 

876 "ZAP_DOMAIN", 

877 "ROUTER_HANDOVER", 

878 "TOS", 

879 "CONNECT_ROUTING_ID", 

880 "GSSAPI_SERVER", 

881 "GSSAPI_PRINCIPAL", 

882 "GSSAPI_SERVICE_PRINCIPAL", 

883 "GSSAPI_PLAINTEXT", 

884 "HANDSHAKE_IVL", 

885 "SOCKS_PROXY", 

886 "XPUB_NODROP", 

887 "BLOCKY", 

888 "XPUB_MANUAL", 

889 "XPUB_WELCOME_MSG", 

890 "STREAM_NOTIFY", 

891 "INVERT_MATCHING", 

892 "HEARTBEAT_IVL", 

893 "HEARTBEAT_TTL", 

894 "HEARTBEAT_TIMEOUT", 

895 "XPUB_VERBOSER", 

896 "CONNECT_TIMEOUT", 

897 "TCP_MAXRT", 

898 "THREAD_SAFE", 

899 "MULTICAST_MAXTPDU", 

900 "VMCI_BUFFER_SIZE", 

901 "VMCI_BUFFER_MIN_SIZE", 

902 "VMCI_BUFFER_MAX_SIZE",