Index: ppapi/proxy/media_stream_audio_track_resource.cc |
diff --git a/ppapi/proxy/media_stream_video_track_resource.cc b/ppapi/proxy/media_stream_audio_track_resource.cc |
similarity index 59% |
copy from ppapi/proxy/media_stream_video_track_resource.cc |
copy to ppapi/proxy/media_stream_audio_track_resource.cc |
index e8ab4c577251a44e0e3c54dbede7f2eb2dbe83b3..10956ab30d9c8617000845a750553ffbb4c35e75 100644 |
--- a/ppapi/proxy/media_stream_video_track_resource.cc |
+++ b/ppapi/proxy/media_stream_audio_track_resource.cc |
@@ -2,17 +2,16 @@ |
// Use of this source code is governed by a BSD-style license that can be |
// found in the LICENSE file. |
-#include "ppapi/proxy/media_stream_video_track_resource.h" |
+#include "ppapi/proxy/media_stream_audio_track_resource.h" |
-#include "base/logging.h" |
-#include "ppapi/proxy/video_frame_resource.h" |
+#include "ppapi/proxy/audio_frame_resource.h" |
#include "ppapi/shared_impl/media_stream_frame.h" |
#include "ppapi/shared_impl/var.h" |
namespace ppapi { |
namespace proxy { |
-MediaStreamVideoTrackResource::MediaStreamVideoTrackResource( |
+MediaStreamAudioTrackResource::MediaStreamAudioTrackResource( |
Connection connection, |
PP_Instance instance, |
int pending_renderer_id, |
@@ -22,40 +21,38 @@ MediaStreamVideoTrackResource::MediaStreamVideoTrackResource( |
get_frame_output_(NULL) { |
} |
-MediaStreamVideoTrackResource::~MediaStreamVideoTrackResource() { |
+MediaStreamAudioTrackResource::~MediaStreamAudioTrackResource() { |
Close(); |
} |
-thunk::PPB_MediaStreamVideoTrack_API* |
-MediaStreamVideoTrackResource::AsPPB_MediaStreamVideoTrack_API() { |
+thunk::PPB_MediaStreamAudioTrack_API* |
+MediaStreamAudioTrackResource::AsPPB_MediaStreamAudioTrack_API() { |
return this; |
} |
-PP_Var MediaStreamVideoTrackResource::GetId() { |
+PP_Var MediaStreamAudioTrackResource::GetId() { |
return StringVar::StringToPPVar(id()); |
} |
-PP_Bool MediaStreamVideoTrackResource::HasEnded() { |
+PP_Bool MediaStreamAudioTrackResource::HasEnded() { |
return PP_FromBool(has_ended()); |
} |
- |
-int32_t MediaStreamVideoTrackResource::Configure( |
+int32_t MediaStreamAudioTrackResource::Configure( |
const int32_t attrib_list[], |
scoped_refptr<TrackedCallback> callback) { |
- // TODO(penghuang): redesign and implement Configure() to support format, |
- // size, etc. |
+ // TODO(penghuang): Implement this function. |
return PP_ERROR_NOTSUPPORTED; |
} |
-int32_t MediaStreamVideoTrackResource::GetAttrib( |
- PP_MediaStreamVideoTrack_Attrib attrib, |
+int32_t MediaStreamAudioTrackResource::GetAttrib( |
+ PP_MediaStreamAudioTrack_Attrib attrib, |
int32_t* value) { |
- // TODO(penghuang): implement this function. |
+ // TODO(penghuang): Implement this function. |
return PP_ERROR_NOTSUPPORTED; |
} |
-int32_t MediaStreamVideoTrackResource::GetFrame( |
+int32_t MediaStreamAudioTrackResource::GetFrame( |
PP_Resource* frame, |
scoped_refptr<TrackedCallback> callback) { |
if (has_ended()) |
@@ -64,21 +61,24 @@ int32_t MediaStreamVideoTrackResource::GetFrame( |
if (TrackedCallback::IsPending(get_frame_callback_)) |
return PP_ERROR_INPROGRESS; |
- *frame = GetVideoFrame(); |
+ *frame = GetAudioFrame(); |
if (*frame) |
return PP_OK; |
+ // TODO(penghuang): Use the callback as hints to determine which thread will |
+ // use the resource, so we could deliver frames to the target thread directly |
+ // for better performance. |
get_frame_output_ = frame; |
get_frame_callback_ = callback; |
return PP_OK_COMPLETIONPENDING; |
} |
-int32_t MediaStreamVideoTrackResource::RecycleFrame(PP_Resource frame) { |
+int32_t MediaStreamAudioTrackResource::RecycleFrame(PP_Resource frame) { |
FrameMap::iterator it = frames_.find(frame); |
if (it == frames_.end()) |
return PP_ERROR_BADRESOURCE; |
- scoped_refptr<VideoFrameResource> frame_resource = it->second; |
+ scoped_refptr<AudioFrameResource> frame_resource = it->second; |
frames_.erase(it); |
if (has_ended()) |
@@ -91,7 +91,7 @@ int32_t MediaStreamVideoTrackResource::RecycleFrame(PP_Resource frame) { |
return PP_OK; |
} |
-void MediaStreamVideoTrackResource::Close() { |
+void MediaStreamAudioTrackResource::Close() { |
if (has_ended()) |
return; |
@@ -106,23 +106,27 @@ void MediaStreamVideoTrackResource::Close() { |
MediaStreamTrackResourceBase::CloseInternal(); |
} |
-void MediaStreamVideoTrackResource::OnNewFrameEnqueued() { |
- if (TrackedCallback::IsPending(get_frame_callback_)) { |
- *get_frame_output_ = GetVideoFrame(); |
- get_frame_output_ = NULL; |
- scoped_refptr<TrackedCallback> callback; |
- callback.swap(get_frame_callback_); |
- callback->Run(PP_OK); |
- } |
+void MediaStreamAudioTrackResource::OnNewFrameEnqueued() { |
+ if (!TrackedCallback::IsPending(get_frame_callback_)) |
+ return; |
+ |
+ *get_frame_output_ = GetAudioFrame(); |
+ int32_t result = *get_frame_output_ ? PP_OK : PP_ERROR_FAILED; |
+ get_frame_output_ = NULL; |
+ scoped_refptr<TrackedCallback> callback; |
+ callback.swap(get_frame_callback_); |
+ callback->Run(result); |
} |
-PP_Resource MediaStreamVideoTrackResource::GetVideoFrame() { |
+PP_Resource MediaStreamAudioTrackResource::GetAudioFrame() { |
int32_t index = frame_buffer()->DequeueFrame(); |
if (index < 0) |
- return 0; |
+ return 0; |
+ |
MediaStreamFrame* frame = frame_buffer()->GetFramePointer(index); |
- scoped_refptr<VideoFrameResource> resource = |
- new VideoFrameResource(pp_instance(), index, frame); |
+ DCHECK(frame); |
+ scoped_refptr<AudioFrameResource> resource = |
+ new AudioFrameResource(pp_instance(), index, frame); |
// Add |pp_resource()| and |resource| into |frames_|. |
// |frames_| uses scoped_ptr<> to hold a ref of |resource|. It keeps the |
// resource alive. |
@@ -130,7 +134,7 @@ PP_Resource MediaStreamVideoTrackResource::GetVideoFrame() { |
return resource->GetReference(); |
} |
-void MediaStreamVideoTrackResource::ReleaseFrames() { |
+void MediaStreamAudioTrackResource::ReleaseFrames() { |
FrameMap::iterator it = frames_.begin(); |
while (it != frames_.end()) { |
// Just invalidate and release VideoFrameResorce, but keep PP_Resource. |