Make Action#bytesize Int64

src/lavinmq/replication/actions.cr

@@ -12,7 +12,7 @@ module LavinMQ
       def initialize(@path : String)
       end
 
-      abstract def bytesize : Int32
+      abstract def bytesize : Int64
       abstract def send(socket : IO) : Int64
 
       protected def filename_bytesize : Int32
@@ -33,12 +33,12 @@ module LavinMQ
       def initialize(@path : String, @mfile : MFile? = nil)
       end
 
-      def bytesize : Int32
+      def bytesize : Int64
         if mfile = @mfile
-          sizeof(Int32) + filename.bytesize +
+          0i64 + sizeof(Int32) + filename.bytesize +
             sizeof(Int64) + mfile.size.to_i64
         else
-          sizeof(Int32) + filename.bytesize +
+          0i64 + sizeof(Int32) + filename.bytesize +
             sizeof(Int64) + File.size(@path).to_i64
         end
       end
@@ -66,7 +66,7 @@ module LavinMQ
       def initialize(@path : String, @obj : Bytes | FileRange | UInt32 | Int32)
       end
 
-      def bytesize : Int32
+      def bytesize : Int64
         datasize = case obj = @obj
                    in Bytes
                      obj.bytesize.to_i64
@@ -75,7 +75,7 @@ module LavinMQ
                    in UInt32, Int32
                      4i64
                    end
-        sizeof(Int32) + filename.bytesize +
+        0i64 + sizeof(Int32) + filename.bytesize +
           sizeof(Int64) + datasize
       end
 
@@ -102,11 +102,11 @@ module LavinMQ
     end
 
     struct DeleteAction < Action
-      def bytesize : Int32
+      def bytesize : Int64
         # Maybe it would be ok to not include delete action in lag, because
         # the follower should have all info necessary to GC the file during
         # startup?
-        sizeof(Int32) + filename.bytesize + sizeof(Int64)
+        (sizeof(Int32) + filename.bytesize + sizeof(Int64)).to_i64
       end
 
       def send(socket) : Int64

src/lavinmq/replication/follower.cr

@@ -129,19 +129,19 @@ module LavinMQ
         end
       end
 
-      def add(path, mfile : MFile? = nil) : Int32
+      def add(path, mfile : MFile? = nil) : Int64
         send_action AddAction.new(path, mfile)
       end
 
-      def append(path, obj) : Int32
+      def append(path, obj) : Int64
         send_action AppendAction.new(path, obj)
       end
 
-      def delete(path) : Int32
+      def delete(path) : Int64
         send_action DeleteAction.new(path)
       end
 
-      private def send_action(action : Action) : Int32
+      private def send_action(action : Action) : Int64
         action_size = action.bytesize
         @sent_bytes += action_size
         @actions.send action