feat: Add Seqpacket support

CHANGELOG.md

@@ -23,6 +23,9 @@ and this project adheres to
 
 ### Changed
 
+- [#5595](https://github.com/firecracker-microvm/firecracker/pull/5595): Added
+  `vsock_type` field to the vsock device API to denote the type of the
+  underlying socket. Can be `stream` or `seqpacket`
 - [#5564](https://github.com/firecracker-microvm/firecracker/pull/5564): which
   added support for VMClock, uses one extra GSI for the VMClock device itself
   which reduces the available GSIs for VirtIO devices. New maximum values is 92

Cargo.toml

@@ -33,6 +33,7 @@ or_fun_call = "warn"
 
 [profile.dev]
 panic = "abort"
+incremental = true
 
 [profile.release]
 panic = "abort"

src/firecracker/src/api_server/parsed_request.rs

@@ -939,7 +939,7 @@ pub mod tests {
     fn test_try_from_put_vsock() {
         let (mut sender, receiver) = UnixStream::pair().unwrap();
         let mut connection = HttpConnection::new(receiver);
-        let body = "{ \"vsock_id\": \"string\", \"guest_cid\": 0, \"uds_path\": \"string\" }";
+        let body = "{ \"vsock_id\": \"string\", \"guest_cid\": 0, \"uds_path\": \"string\", \"vsock_type\": \"stream\" }";
         sender
             .write_all(http_request("PUT", "/vsock", Some(body)).as_bytes())
             .unwrap();

src/firecracker/src/api_server/request/vsock.rs

@@ -41,7 +41,8 @@ mod tests {
     fn test_parse_put_vsock_request() {
         let body = r#"{
             "guest_cid": 42,
-            "uds_path": "vsock.sock"
+            "uds_path": "vsock.sock",
+            "vsock_type": "stream"
         }"#;
         parse_put_vsock(&Body::new(body)).unwrap();
 
@@ -57,7 +58,8 @@ mod tests {
         let body = r#"{
             "vsock_id": "foo",
             "guest_cid": 42,
-            "uds_path": "vsock.sock"
+            "uds_path": "vsock.sock",
+            "vsock_type": "stream"
         }"#;
         depr_action_from_req(
             parse_put_vsock(&Body::new(body)).unwrap(),
@@ -66,7 +68,8 @@ mod tests {
 
         let body = r#"{
             "guest_cid": 42,
-            "uds_path": "vsock.sock"
+            "uds_path": "vsock.sock",
+            "vsock_type": "stream"
         }"#;
         let (_, mut parsing_info) = parse_put_vsock(&Body::new(body)).unwrap().into_parts();
         assert!(parsing_info.take_deprecation_message().is_none());

src/firecracker/swagger/firecracker.yaml

@@ -1779,6 +1779,13 @@ definitions:
       uds_path:
         type: string
         description: Path to UNIX domain socket, used to proxy vsock connections.
+      vsock_type:
+        description: Enumeration indicating the type of the underlying socket (stream or seqpacket)
+        type: string
+        enum:
+          - stream
+          - seqpacket
+        default: stream
       vsock_id:
         type: string
         description:

src/vmm/Cargo.toml

@@ -46,6 +46,7 @@ serde = { version = "1.0.228", features = ["derive", "rc"] }
 serde_json = "1.0.149"
 slab = "0.4.11"
 thiserror = "2.0.17"
+uds = "0.4.2"
 userfaultfd = "0.9.0"
 utils = { path = "../utils" }
 uuid = "1.19.0"

src/vmm/src/builder.rs

@@ -941,7 +941,7 @@ pub(crate) mod tests {
         vsock_config: VsockDeviceConfig,
     ) {
         let vsock_dev_id = VSOCK_DEV_ID.to_owned();
-        let vsock = VsockBuilder::create_unixsock_vsock(vsock_config).unwrap();
+        let vsock = VsockBuilder::create_unixsock_vsock(&vsock_config).unwrap();
         let vsock = Arc::new(Mutex::new(vsock));
 
         attach_unixsock_vsock_device(

src/vmm/src/device_manager/pci_mngr.rs

@@ -665,7 +665,7 @@ mod tests {
     use crate::vmm_config::memory_hotplug::MemoryHotplugConfig;
     use crate::vmm_config::net::NetworkInterfaceConfig;
     use crate::vmm_config::pmem::PmemConfig;
-    use crate::vmm_config::vsock::VsockDeviceConfig;
+    use crate::vmm_config::vsock::{VsockDeviceConfig, VsockType};
 
     #[test]
     fn test_device_manager_persistence() {
@@ -723,6 +723,7 @@ mod tests {
                 vsock_id: Some(vsock_dev_id.to_string()),
                 guest_cid: 3,
                 uds_path: tmp_sock_file.as_path().to_str().unwrap().to_string(),
+                vsock_type: VsockType::Stream,
             };
             insert_vsock_device(&mut vmm, &mut cmdline, &mut event_manager, vsock_config);
             // Add an entropy device.
@@ -835,7 +836,8 @@ mod tests {
   ],
   "vsock": {{
     "guest_cid": 3,
-    "uds_path": "{}"
+    "uds_path": "{}",
+    "vsock_type": "stream"
   }},
   "entropy": {{
     "rate_limiter": null

src/vmm/src/device_manager/persist.rs

@@ -637,7 +637,7 @@ mod tests {
     use crate::vmm_config::memory_hotplug::MemoryHotplugConfig;
     use crate::vmm_config::net::NetworkInterfaceConfig;
     use crate::vmm_config::pmem::PmemConfig;
-    use crate::vmm_config::vsock::VsockDeviceConfig;
+    use crate::vmm_config::vsock::{VsockDeviceConfig, VsockType};
 
     impl<T> PartialEq for VirtioDeviceState<T> {
         fn eq(&self, other: &VirtioDeviceState<T>) -> bool {
@@ -735,6 +735,7 @@ mod tests {
                 vsock_id: Some(vsock_dev_id.to_string()),
                 guest_cid: 3,
                 uds_path: tmp_sock_file.as_path().to_str().unwrap().to_string(),
+                vsock_type: VsockType::Stream,
             };
             insert_vsock_device(&mut vmm, &mut cmdline, &mut event_manager, vsock_config);
             // Add an entropy device.
@@ -843,7 +844,8 @@ mod tests {
   ],
   "vsock": {{
     "guest_cid": 3,
-    "uds_path": "{}"
+    "uds_path": "{}",
+    "vsock_type": "stream"
   }},
   "entropy": {{
     "rate_limiter": null

src/vmm/src/devices/virtio/persist.rs

@@ -269,6 +269,7 @@ mod tests {
     use crate::devices::virtio::transport::mmio::tests::DummyDevice;
     use crate::devices::virtio::vsock::{Vsock, VsockUnixBackend};
     use crate::snapshot::Snapshot;
+    use crate::vmm_config::vsock::VsockType;
 
     const DEFAULT_QUEUE_MAX_SIZE: u16 = 256;
     impl Default for QueueState {
@@ -500,7 +501,7 @@ mod tests {
         // Remove the file so the path can be used by the socket.
         temp_uds_path.remove().unwrap();
         let uds_path = String::from(temp_uds_path.as_path().to_str().unwrap());
-        let backend = VsockUnixBackend::new(guest_cid, uds_path).unwrap();
+        let backend = VsockUnixBackend::new(guest_cid, uds_path, VsockType::Stream).unwrap();
         let vsock = Vsock::new(guest_cid, backend).unwrap();
         let vsock = Arc::new(Mutex::new(vsock));
         let mmio_transport =