intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 32 insertions, 0 deletions

diff --git a/library/cpp/actors/interconnect/packet.cpp b/library/cpp/actors/interconnect/packet.cpp
new file mode 100644
index 0000000000..e2c289ed59
--- /dev/null
+++ b/library/cpp/actors/interconnect/packet.cpp
@@ -0,0 +1,32 @@
+#include "packet.h"
+
+#include <library/cpp/actors/core/probes.h>
+
+#include <util/system/datetime.h>
+
+LWTRACE_USING(ACTORLIB_PROVIDER);
+
+ui32 TEventHolder::Fill(IEventHandle& ev) {
+    Serial = 0;
+    Descr.Type = ev.Type;
+    Descr.Flags = ev.Flags;
+    Descr.Recipient = ev.Recipient;
+    Descr.Sender = ev.Sender;
+    Descr.Cookie = ev.Cookie;
+    ev.TraceId.Serialize(&Descr.TraceId);
+    ForwardRecipient = ev.GetForwardOnNondeliveryRecipient();
+    EventActuallySerialized = 0;
+    Descr.Checksum = 0;
+
+    if (ev.HasBuffer()) {
+        Buffer = ev.ReleaseChainBuffer();
+        EventSerializedSize = Buffer->GetSize();
+    } else if (ev.HasEvent()) {
+        Event.Reset(ev.ReleaseBase());
+        EventSerializedSize = Event->CalculateSerializedSize();
+    } else {
+        EventSerializedSize = 0;
+    }
+
+    return EventSerializedSize;
+}