| 346 | } |
| 347 | |
| 348 | static bool is_urgent(enum peer_wire type) |
| 349 | { |
| 350 | switch (type) { |
| 351 | case WIRE_INIT: |
| 352 | case WIRE_ERROR: |
| 353 | case WIRE_WARNING: |
| 354 | case WIRE_TX_ADD_INPUT: |
| 355 | case WIRE_TX_ADD_OUTPUT: |
| 356 | case WIRE_TX_REMOVE_INPUT: |
| 357 | case WIRE_TX_REMOVE_OUTPUT: |
| 358 | case WIRE_TX_COMPLETE: |
| 359 | case WIRE_TX_SIGNATURES: |
| 360 | case WIRE_OPEN_CHANNEL: |
| 361 | case WIRE_ACCEPT_CHANNEL: |
| 362 | case WIRE_FUNDING_CREATED: |
| 363 | case WIRE_FUNDING_SIGNED: |
| 364 | case WIRE_CHANNEL_READY: |
| 365 | case WIRE_OPEN_CHANNEL2: |
| 366 | case WIRE_ACCEPT_CHANNEL2: |
| 367 | case WIRE_INIT_RBF: |
| 368 | case WIRE_ACK_RBF: |
| 369 | case WIRE_SHUTDOWN: |
| 370 | case WIRE_CLOSING_SIGNED: |
| 371 | case WIRE_UPDATE_ADD_HTLC: |
| 372 | case WIRE_UPDATE_FULFILL_HTLC: |
| 373 | case WIRE_UPDATE_FAIL_HTLC: |
| 374 | case WIRE_UPDATE_FAIL_MALFORMED_HTLC: |
| 375 | case WIRE_UPDATE_FEE: |
| 376 | case WIRE_UPDATE_BLOCKHEIGHT: |
| 377 | case WIRE_CHANNEL_REESTABLISH: |
| 378 | case WIRE_ANNOUNCEMENT_SIGNATURES: |
| 379 | case WIRE_CHANNEL_ANNOUNCEMENT: |
| 380 | case WIRE_NODE_ANNOUNCEMENT: |
| 381 | case WIRE_CHANNEL_UPDATE: |
| 382 | case WIRE_QUERY_SHORT_CHANNEL_IDS: |
| 383 | case WIRE_REPLY_SHORT_CHANNEL_IDS_END: |
| 384 | case WIRE_QUERY_CHANNEL_RANGE: |
| 385 | case WIRE_REPLY_CHANNEL_RANGE: |
| 386 | case WIRE_GOSSIP_TIMESTAMP_FILTER: |
| 387 | case WIRE_ONION_MESSAGE: |
| 388 | #if EXPERIMENTAL_FEATURES |
| 389 | case WIRE_STFU: |
| 390 | #endif |
| 391 | return false; |
| 392 | |
| 393 | /* These are time-sensitive, and so send without delay. */ |
| 394 | case WIRE_PING: |
| 395 | case WIRE_PONG: |
| 396 | case WIRE_COMMITMENT_SIGNED: |
| 397 | case WIRE_REVOKE_AND_ACK: |
| 398 | return true; |
| 399 | }; |
| 400 | |
| 401 | /* plugins can inject other messages; assume not urgent. */ |
| 402 | return false; |
| 403 | } |
| 404 | |
| 405 | /* io_sock_shutdown, but in format suitable for an io_plan callback */ |