==== TMockDiscovery server started on port 37729
==== TMockDiscovery add endpoints, firstNodeId 9999, nodeCount 2, port 0
====TYdbPqTestRetryPolicy()
====ExpectBreakDown
=== Create write session
==== ListEndpoints request: database: "local"
==== ListEndpoints response: operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "localhost" node_id: 9999 } endpoints { address: "ip6-localhost" node_id: 10000 } } } }
2025-12-12T11:55:12.542532Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session: try to update token
2025-12-12T11:55:12.542797Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 0.000000s
=== Wait for retries
2025-12-12T11:55:12.542828Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:12.544579Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got PartitionLocation response. Status TRANSPORT_UNAVAILABLE, proto:
====CreateRetryState
====CreateRetryState Initialized
Test retry state: get retry delay
2025-12-12T11:55:12.544620Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got error. Status: TRANSPORT_UNAVAILABLE, Description: <main>: Error: Failed to get partition location     <main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.0.1:0: Failed to connect to remote host: Connection refused     <main>: Error: Grpc error response on endpoint localhost:0 
2025-12-12T11:55:12.544625Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session will restart in 2.000000s
2025-12-12T11:55:12.544631Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 2.000000s
2025-12-12T11:55:14.545434Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:14.547568Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got PartitionLocation response. Status TRANSPORT_UNAVAILABLE, proto:
Test retry state: get retry delay
2025-12-12T11:55:14.547615Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got error. Status: TRANSPORT_UNAVAILABLE, Description: <main>: Error: Failed to get partition location     <main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv6:%5B::1%5D:0: Failed to connect to remote host: Connection refused     <main>: Error: Grpc error response on endpoint ip6-localhost:0 
2025-12-12T11:55:14.547619Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session will restart in 2.000000s
2025-12-12T11:55:14.547626Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 2.000000s
E1212 11:55:16.296857580 2876211 chttp2_transport.cc:1143]             ipv4:0.0.0.0:37729: Received a GOAWAY with error code ENHANCE_YOUR_CALM and debug data equal to "too_many_pings". Current keepalive time (before throttling): 1250ms
2025-12-12T11:55:16.548373Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:16.550319Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got PartitionLocation response. Status TRANSPORT_UNAVAILABLE, proto:
Test retry state: get retry delay
2025-12-12T11:55:16.550373Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got error. Status: TRANSPORT_UNAVAILABLE, Description: <main>: Error: Failed to get partition location     <main>: Error: GRpc error: (14): connections to all backends failing; last error: UNKNOWN: ipv4:127.0.0.1:0: Failed to connect to remote host: Connection refused     <main>: Error: Grpc error response on endpoint ip6-localhost:0 
2025-12-12T11:55:16.550378Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Write session will restart in 2.000000s
==== TMockDiscovery set good endpoint nodes 
2025-12-12T11:55:16.550384Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Get partition location async, partition 0, delay 2.000000s
==== TMockDiscovery add endpoints, firstNodeId 1, nodeCount 1, port 1665
=== Wait for repair
==== ListEndpoints request: database: "local"
==== ListEndpoints response: operation { ready: true status: SUCCESS result { [type.googleapis.com/Ydb.Discovery.ListEndpointsResult] { endpoints { address: "localhost" port: 1665 node_id: 1 } } } }
2025-12-12T11:55:18.551579Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0]  Getting partition location, partition 0
2025-12-12T11:55:18.554604Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] Got PartitionLocation response. Status SUCCESS, proto:
partition {
  active: true
  partition_location {
    node_id: 1
    generation: 1
  }
}
2025-12-12T11:55:18.554623Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [0] GetPreferredEndpoint: partitionId 0, partitionNodeId 1 exists in the endpoint pool.
2025-12-12T11:55:18.554630Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Start write session. Will connect to nodeId: 1
2025-12-12T11:55:18.554885Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: direct write to partition: 0, generation 1
2025-12-12T11:55:18.554925Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: send init request: init_request { path: "sdk_tests/LocalPartition-DirectRead_DiscoveryServiceBadPort/test-topic" producer_id: "test-producer" partition_with_generation { generation: 1 } }
2025-12-12T11:55:18.555065Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnWriteDone gRpcStatusCode: 0
2025-12-12T11:55:18.562769Z :DEBUG: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session: OnReadDone gRpcStatusCode: 0
2025-12-12T11:55:18.562801Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Counters: { Errors: 3 CurrentSessionLifetimeMs: 1765540518562 BytesWritten: 0 MessagesWritten: 0 BytesWrittenCompressed: 0 BytesInflightUncompressed: 0 BytesInflightCompressed: 0 BytesInflightTotal: 0 MessagesInflight: 0 }
2025-12-12T11:55:18.562836Z :INFO: [local]  TraceId []  SessionId []  PartitionId [0]  Generation [1] Write session established. Init response: session_id: "test-producer|d5969563-4e3eebb1-cb630183-d9d03ff1_0"
====StateDestroyed
=== Close write session
2025-12-12T11:55:18.562921Z :INFO: [local]  TraceId []  SessionId [test-producer|d5969563-4e3eebb1-cb630183-d9d03ff1_0]  PartitionId [0]  Generation [1] Write session: close. Timeout 18446744073709.551615s
2025-12-12T11:55:18.562935Z :INFO: [local]  TraceId []  SessionId [test-producer|d5969563-4e3eebb1-cb630183-d9d03ff1_0]  PartitionId [0]  Generation [1] Write session will now close
2025-12-12T11:55:18.562942Z :DEBUG: [local]  TraceId []  SessionId [test-producer|d5969563-4e3eebb1-cb630183-d9d03ff1_0]  PartitionId [0]  Generation [1] Write session: aborting
2025-12-12T11:55:18.563049Z :INFO: [local]  TraceId []  SessionId [test-producer|d5969563-4e3eebb1-cb630183-d9d03ff1_0]  PartitionId [0]  Generation [1] Write session: gracefully shut down, all writes complete
2025-12-12T11:55:18.563067Z :DEBUG: [local]  TraceId []  SessionId [test-producer|d5969563-4e3eebb1-cb630183-d9d03ff1_0]  PartitionId [0]  Generation [1] Write session: destroy
