| ... | @@ -141,21 +141,16 @@ fn deinit_thread_inner() !void { | ... | @@ -141,21 +141,16 @@ fn deinit_thread_inner() !void { |
| 141 | { | 141 | { |
| 142 | var client: std.http.Client = .{ .allocator = allocator }; | 142 | var client: std.http.Client = .{ .allocator = allocator }; |
| 143 | defer client.deinit(); | 143 | defer client.deinit(); |
| 144 | var buf: [4096]u8 = @splat(0); | 144 | var req = try client.request(.POST, traces_endpoint, .{ |
| 145 | var req = try client.open(.POST, traces_endpoint, .{ | | |
| 146 | .server_header_buffer = &buf, | | |
| 147 | .headers = .{ | 145 | .headers = .{ |
| 148 | .content_type = .{ .override = "application/x-protobuf" }, | 146 | .content_type = .{ .override = "application/x-protobuf" }, |
| 149 | }, | 147 | }, |
| 150 | .redirect_behavior = .not_allowed, | 148 | .redirect_behavior = .not_allowed, |
| 151 | }); | 149 | }); |
| 152 | defer req.deinit(); | 150 | defer req.deinit(); |
| 153 | req.transfer_encoding = .{ .content_length = export_request.items.len }; | 151 | try req.sendBodyComplete(export_request.items); |
| 154 | try req.send(); | 152 | const resp = try req.receiveHead(&.{}); |
| 155 | try req.writeAll(export_request.items); | 153 | if (resp.head.status != .ok) std.log.scoped(.tracer).warn("otel: {s} {d}", .{ &extras.to_hex(trace_id), resp.head.status }); |
| 156 | try req.finish(); | | |
| 157 | try req.wait(); | | |
| 158 | if (req.response.status != .ok) std.log.scoped(.tracer).warn("otel: {s} {d}", .{ &extras.to_hex(trace_id), req.response.status }); | | |
| 159 | } | 154 | } |
| 160 | } | 155 | } |
| 161 | | 156 | |