@@ -1701,23 +1701,8 @@ class SequentialSpanSubmitter final: public SpanSubmitter {
17011701 public:
17021702 SequentialSpanSubmitter (kj::Own<WorkerTracer> workerTracer): workerTracer(kj::mv(workerTracer)) {}
17031703 void submitSpan (tracing::SpanId spanId, tracing::SpanId parentSpanId, const Span& span) override {
1704- // This code path is workerd-only, we can safely decompose this span into its components and
1705- // call submitSpanOpen/submitSpanEnd instead of reimplementing them here.
1704+ // This code path is workerd-only, we can safely utilize submitSpanOpen here.
17061705 submitSpanOpen (spanId, parentSpanId, span.operationName .clone (), span.startTime );
1707- submitSpanEnd (spanId, span);
1708- }
1709-
1710- void submitSpanOpen (tracing::SpanId spanId,
1711- tracing::SpanId parentSpanId,
1712- kj::ConstString operationName,
1713- kj::Date startTime) override {
1714- if (isPredictableModeForTest ()) {
1715- startTime = kj::UNIX_EPOCH;
1716- }
1717- workerTracer->addSpanOpen (spanId, parentSpanId, kj::mv (operationName), startTime);
1718- }
1719-
1720- void submitSpanEnd (tracing::SpanId spanId, const Span& span) override {
17211706 tracing::SpanEndData span2 (spanId, span.startTime , span.endTime );
17221707 span2.tags .reserve (span.tags .size ());
17231708 for (auto & tag: span.tags ) {
@@ -1730,6 +1715,16 @@ class SequentialSpanSubmitter final: public SpanSubmitter {
17301715 workerTracer->addSpanEnd (kj::mv (span2));
17311716 }
17321717
1718+ void submitSpanOpen (tracing::SpanId spanId,
1719+ tracing::SpanId parentSpanId,
1720+ kj::ConstString operationName,
1721+ kj::Date startTime) override {
1722+ if (isPredictableModeForTest ()) {
1723+ startTime = kj::UNIX_EPOCH;
1724+ }
1725+ workerTracer->addSpanOpen (spanId, parentSpanId, kj::mv (operationName), startTime);
1726+ }
1727+
17331728 tracing::SpanId makeSpanId () override {
17341729 return tracing::SpanId (nextSpanId++);
17351730 }
0 commit comments