Ticket #11856: 0002-Implement-BMediaRoster-SyncToNode.2.patch

headers/private/media/ServerInterface.h

@@ -89 +89 @@
     NODE_TIME_WARP,
     NODE_PREROLL,
     NODE_ROLL,
+    NODE_SYNC_TO,
     NODE_SET_TIMESOURCE,
     NODE_GET_TIMESOURCE,
     NODE_REQUEST_COMPLETED,
@@ -929 +930 @@
 struct node_final_release_command : command_data {
 };
 
+struct node_sync_to_command : command_data {
+    bigtime_t               performance_time;
+    port_id                 port;
+};
 
 // #pragma mark - time source commands
 

src/kits/media/MediaEventLooper.cpp

@@ -157 +157 @@
                             int32 cookie)
 {
     CALLED();
-    // XXX what do we need to do here?
-    return BMediaNode::AddTimer(at_performance_time,cookie);
+
+    media_timed_event event(at_performance_time,
+        BTimedEventQueue::B_TIMER, NULL,
+        BTimedEventQueue::B_EXPIRE_TIMER);
+    event.data = cookie;
+    return EventQueue()->AddEvent(event);
 }
 
 
@@ -477 +481 @@
             /* nothing */
             break;
 
+        case BTimedEventQueue::B_TIMER:
+            TimerExpired(TimeSource()->Now(), event->data);
+            break;
+
         default:
             break;
     }

src/kits/media/MediaNode.cpp

@@ -1 +1 @@
 /*
  * Copyright (c) 2002, 2003 Marcus Overhagen <Marcus@Overhagen.de>
+ * Copyright (c) 2015, Dario Casalinuovo
  *
  * Permission is hereby granted, free of charge, to any person obtaining
  * a copy of this software and associated documentation files or portions
@@ -327 +328 @@
 }
 
 
+/*
+ * Used with AddTimer
+ * This will, in turn, cause the BMediaRoster::SyncToNode() call
+ * that instigated the timer to return to the caller.
+*/
 void
 BMediaNode::TimerExpired(bigtime_t notifyPoint,
                          int32 cookie,
                          status_t error)
 {
-    UNIMPLEMENTED();
-    // Used with AddTimer
-    // This will, in turn, cause the BMediaRoster::SyncToNode() call
-    // that instigated the timer to return to the caller.
-    // Probably only important to classes derived from BTimeSource.
+    CALLED();
+    port_id port = (port_id) cookie;
+    int32 reply = 1;
+    write_port(port, NODE_SYNC_TO, &reply, sizeof(reply));
 }
 
 
@@ -696 +701 @@
             return B_OK;
         }
 
+        case NODE_SYNC_TO:
+        {
+            const node_sync_to_command *command
+                = static_cast<const node_sync_to_command *>(data);
+
+            TRACE("BMediaNode::HandleMessage NODE_SYNC_TO, node %ld\n",
+                fNodeID);
+
+            if (AddTimer(command->performance_time, command->port) != B_OK) {
+                // When AddTimer return an error we will notify the caller
+                // that the node doesn't support this feature or there was
+                // a problem when adding the time, this will result in
+                // SyncToNode returning immediately to the caller with an error.
+                int32 reply = -1;
+                write_port(command->port, NODE_SYNC_TO, &reply, sizeof(reply));
+            }
+            return B_OK;
+        }
+
     };
     return B_ERROR;
 }
@@ -878 +902 @@
 BMediaNode::AddTimer(bigtime_t at_performance_time,
                      int32 cookie)
 {
-    UNIMPLEMENTED();
-
+    CALLED();
     return B_ERROR;
 }
 

src/kits/media/MediaRoster.cpp

@@ -1 +1 @@
 /*
  * Copyright 2008 Maurice Kalinowski, haiku@kaldience.com
  * Copyright 2009-2012, Axel Dörfler, axeld@pinc-software.de.
+ * Copyright 2015 Dario Casalinuovo, b.vitruvio@gmail.com
  *
  * All rights reserved. Distributed under the terms of the MIT License.
  */
@@ -1364 +1365 @@
 BMediaRoster::SyncToNode(const media_node& node, bigtime_t atTime,
     bigtime_t timeout)
 {
-    UNIMPLEMENTED();
-    return B_OK;
+    TRACE("BMediaRoster::SyncToNode, node %" B_PRId32 ", at real %" B_PRId64
+        ", at timeout %" B_PRId64 "\n", node.node, atTime, timeout);
+    if (IS_INVALID_NODE(node))
+        return B_MEDIA_BAD_NODE;
+
+    port_id wait_port = create_port(1, "SyncToNode wait port");
+    if (wait_port < 0)
+        return wait_port;
+
+    node_sync_to_command command;
+    command.performance_time = atTime;
+    command.port = wait_port;
+    status_t status = write_port(node.port,
+        NODE_SYNC_TO, &command, sizeof(command));
+    if (status == B_OK) {
+        int32 code, reply = 0;
+        ssize_t size = read_port_etc(wait_port, &code, &reply, sizeof(reply),
+            B_TIMEOUT, timeout);
+        if (size < 0)
+            status = size;
+        else if (code != NODE_SYNC_TO || reply != 1)
+            status = B_ERROR;
+    }
+    close_port(wait_port);
+    delete_port(wait_port);
+    return status;
 }