DanielThomas

#!/bin/bash -xe

dir=$(mktemp -d)
cd "$dir"

touch manifest-empty.txt
cat << EOF > manifest-guice-all.txt
Class-Path: guice-grapher-5.1.0.jar guice-assistedinject-5.1.0.jar guice-dagger-adapter-5.1.0.jar guice-jmx-5.1.0.jar guice-jndi-5.1.0.jar guice-persist-5.1.0.jar guice-struts2-5.1.0.jar guice-servlet-5.1.0.jar guice-spring-5.1.0.jar guice-throwingproviders-5.1.0.jar guice-5.1.0.jar asm-9.6.jar guava-30.1-jre.jar failureaccess-1.0.1.jar listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar
EOF

DanielThomas

Thread responsible for flushing CountBoundedQueue:

#107 "AsyncReporter{com.netflix.tracing.reporter.UdpBytesMessageSender@7a65e842}"
      java.base/jdk.internal.misc.Unsafe.park(Native Method)
      java.base/java.util.concurrent.locks.LockSupport.park(LockSupport.java:221)
      java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:754)
      java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:1761)
      zipkin2.reporter.internal.CountBoundedQueue.drainTo(CountBoundedQueue.java:81)
      zipkin2.reporter.internal.AsyncReporter$BoundedAsyncReporter.flush(AsyncReporter.java:241)
      zipkin2.reporter.internal.AsyncReporter$Flusher.run(AsyncReporter.java:352)

DanielThomas

import java.time.Duration;
import java.util.List;
import java.util.concurrent.locks.ReentrantLock;
import java.util.stream.IntStream;
import java.util.stream.Stream;

/**
 * Demonstrate potential for deadlock on a {@link ReentrantLock} when there is both a synchronized and
 * non-synchronized path to that lock, which can allow a virtual thread to hold the lock, but
 * other pinned waiters to consume all the available workers. 

DanielThomas

/*
 * Copyright 2024 Netflix Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software

DanielThomas

/*
 * Copyright 2024 Netflix Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software

DanielThomas

vcl 4.1;

import edgestash;
import goto;
import xbody;

backend default none;

sub vcl_init {
    new registry = goto.dns_director("https://registry.npmjs.org");

DanielThomas

docker_setup_vpn () {
        echo "## Previous Configuration"
        sudo pfctl -a com.apple.internet-sharing/shared_v4 -s nat 2> /dev/null | tee /tmp/docker_vpn.conf
        if sudo pfctl -a com.apple.internet-sharing/shared_v4 -s nat 2> /dev/null | grep 192.168.64.0 | grep -q utun2
        then
                echo && echo "Not applying change"
        else
                echo "nat on utun2 inet from 192.168.64.0/24 to any -> (utun2) extfilter ei" >> /tmp/docker_vpn.conf
                sudo pfctl -a com.apple.internet-sharing/shared_v4 -N -f /tmp/docker_vpn.conf 2> /dev/null
                echo && echo "## New Configuration"

DanielThomas

vcl 4.1;

import purge;
import std;
import synthbackend;

sub vcl_recv {
    if (req.method != "GET" && req.method != "PUT" && req.method != "DELETE") {
        return (synth(405));
    }

DanielThomas

package com.netflix.lint.rule.nebula

import com.netflix.nebula.lint.FileMode
import com.netflix.nebula.lint.rule.GradleLintRule
import com.netflix.nebula.lint.rule.GradleModelAware
import org.codehaus.groovy.ast.ClassNode

import java.security.MessageDigest

import static java.nio.file.Files.isSymbolicLink

DanielThomas