├─ RobotsTxtException
  └─ SitemapsException
```

### Thread-Local Storage

Use `CrawlingParameterUtil` to set/get `CrawlerContext` and `UrlQueue` in worker threads. Always clear in finally block with `CrawlingParameterUtil.clearAll()`.

### Resource Cleanup Pattern

Always use try-with-resources for `ResponseData` - temp files are auto-deleted on close.

## Log Message Guidelines

  fun threadIsInterruptedOnFirstRead() {
    Thread.currentThread().interrupt()
    try {
      val result = publicSuffixDatabase.getEffectiveTldPlusOne("squareup.com")
      assertThat(result).isEqualTo("squareup.com")
    } finally {
      assertThat(Thread.interrupted()).isTrue()
    }
  }

  @Test
  fun secondReadFailsSameAsFirst() {
    val badPublicSuffixDatabase =
      PublicSuffixDatabase(
        ResourcePublicSuffixList(

                        }
                    }
                }
            }
            generateTextReport(versionToIncubating)
            generateHtmlReport(versionToIncubating)
        } finally {
            JavaParserFacade.clearInstances()
        }
    }

    private
    fun generateHtmlReport(versionToIncubating: VersionsToIncubating) {
        val htmlReport = parameters.htmlReportFile.get().asFile

            assertNull(sslSocketFactory);

        } catch (IOException e) {
            fail("Failed to create test certificate file: " + e.getMessage());
        } finally {
            if (invalidCertFile != null && invalidCertFile.exists()) {
                invalidCertFile.delete();
            }
        }
    }

    @Test

     * described.
     */
    static class UnknownRepositoryLayout implements ArtifactRepositoryLayout {

        private final String id;

        private final ArtifactRepositoryLayout fallback;

        UnknownRepositoryLayout(String id, ArtifactRepositoryLayout fallback) {
            this.id = id;
            this.fallback = fallback;
        }

    public void test_poll_concurrentAccessTx() throws Exception {
        final String sessionId = "poll_session4";
        final int numThreads = 5;
        final int itemsPerThread = 10;
        final List<OpenSearchUrlQueue> urlQueueList = new ArrayList<>();

        // Insert items
        for (int i = 1; i <= itemsPerThread * numThreads; i++) {
            final OpenSearchUrlQueue urlQueue = new OpenSearchUrlQueue();

        sendTestRequest(fbRequest)
        Thread.sleep(1000)
        sendTestRequest(twitterRequest)
        Thread.sleep(1000)
        sendTestRequest(googleRequest)
        Thread.sleep(2000)
      }
    } finally {
      client.connectionPool.evictAll()
      client.dispatcher.executorService.shutdownNow()

      if (launch == CommandLine) {
        process?.destroyForcibly()
      }
    }
  }

              nextEvent.subscribers.next().dispatchEvent(nextEvent.event);
            }
          }
        } finally {
          dispatching.remove();
          queue.remove();
        }
      }
    }

    private static final class Event {
      private final Object event;
      private final Iterator<Subscriber> subscribers;

      private Event(Object event, Iterator<Subscriber> subscribers) {

 */
public class DisniRdmaConnection extends RdmaConnection {

    private static final Logger log = LoggerFactory.getLogger(DisniRdmaConnection.class);

    // DiSNI objects - would be actual DiSNI types in real implementation
    private final Object endpoint; // RdmaActiveEndpoint
    private final Object group; // RdmaActiveEndpointGroup<DisniRdmaEndpoint>

    /**
     * Create new DiSNI RDMA connection

    try {
      fallbackResult = doFallback(localFallback, castThrowable);
    } catch (Throwable t) {
      restoreInterruptIfIsInterruptedException(t);
      setException(t);
      return;
    } finally {
      exceptionType = null;
      fallback = null;
    }

    setResult(fallbackResult);
  }

  /** Template method for subtypes to actually run the fallback. */
  @ForOverride