eungju

import com.google.gson.Gson
import com.google.gson.GsonBuilder
import io.jaegertracing.zipkin.internal.V2SpanConverter
import java.lang.reflect.Field
import java.lang.reflect.Modifier
import java.lang.invoke.MethodHandles
import java.lang.invoke.VarHandle

class FixZipkinV2Reporter(gson: Gson = PRIVACY_RESPECTING_GSON) {
    init {

eungju

import Control.Applicative
import Control.Monad
import System.Directory
import System.FilePath
import System.Exit
import System.Process
import Text.Printf

type URL = String

eungju

import com.athaydes.rawhttp.core.EagerBodyReader;
import com.athaydes.rawhttp.core.EagerHttpResponse;
import com.athaydes.rawhttp.core.MethodLine;
import com.athaydes.rawhttp.core.RawHttp;
import com.athaydes.rawhttp.core.RawHttpHeaders;
import com.athaydes.rawhttp.core.RawHttpRequest;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

eungju

interface CircuitBreakerMetrics {
    fun executionCompleted(name: String, latency: Double) = Unit
}

eungju

class KyotoTycoon(object):
    ...
    def get(self, key):
        with self.pool.context() as c:
            return c.get(key, db=self.db)


class ConnectionPool(object):
    ...
    def context(self):

eungju

    @Test
    fun simple() {
        val observable = Observable.create<Int> { emitter ->
            emitter.onNext(1)
            emitter.onError(IOException("Timeout"))
        }
        observable
                .take(1)
                .subscribe({ assertEquals(1, it) }, { assertTrue(it is UndeliverableException) })
    }

eungju

    override fun connectDevice(userDeviceRef: UserDeviceRef, deviceAttributes: DeviceAttributes, nodeRef: PilsnerRef): Completable
            = Completable.fromRunnable {
        rwLock.write {
            devicePresences[userDeviceRef.deviceId] = Presence(userDeviceRef, deviceAttributes, nodeRef)
            userDevices.put(userDeviceRef.userId, userDeviceRef.deviceId)
        }
    }

    override fun getPresencesOfUser(userId: UserId): Single<List<Presence>>
            = Single.fromCallable {

eungju

class Http {
    data class HeaderName(val name: String) : Comparable<HeaderName> {
        override fun compareTo(other: HeaderName): Int = name.compareTo(other.name, true)

        fun get(headers: MultiMap): String? = headers.get(name)
        fun set(headers: MultiMap, value: String): Unit { headers.set(name, value) }

        fun copyIfExist(from: MultiMap, to: MultiMap) {
            get(from)?.let { set(to, it) }
        }

eungju

    @Test
    fun withLatestFromCausesNoSuchElementException() {
        val state = Observable.just(42).cacheWithInitialCapacity(1)
        var error = 0
        val threads = (0..4 - 1)
                .map {
                    Thread {
                        Observable.just(Unit)
                                .withLatestFrom(state, BiFunction { _: Unit, state: Int -> state })
                                .firstOrError()

eungju

데드락이 걸렸는데 코드를 봐도 어디인지 모를 때가 있다. 자바는 JVM이 쓰레드 덤프 기능을 제공해서 어떤 쓰레드가 어디서 멈춰 있는지 확인하기 쉬웠는데 파이썬은 쓰레드 덤프를 얻으려면 약간의 코딩이 필요하다.

아래와 같이 모든 쓰레드의 스택 트레이스를 볼 수 있다.

for ident, stack in sys._current_frames().items():
    logger.info(("%d" % ident) + "".join(traceback.format_list(traceback.extract_stack(stack))))

어떤 쓰레드가 멈춰 있는지 안다면 그 쓰레드의 스택 트레이스만 볼 수 있다.