| OLD | NEW |
| (Empty) |
| 1 /* | |
| 2 * libjingle | |
| 3 * Copyright 2012 Google Inc. | |
| 4 * | |
| 5 * Redistribution and use in source and binary forms, with or without | |
| 6 * modification, are permitted provided that the following conditions are met: | |
| 7 * | |
| 8 * 1. Redistributions of source code must retain the above copyright notice, | |
| 9 * this list of conditions and the following disclaimer. | |
| 10 * 2. Redistributions in binary form must reproduce the above copyright notice, | |
| 11 * this list of conditions and the following disclaimer in the documentation | |
| 12 * and/or other materials provided with the distribution. | |
| 13 * 3. The name of the author may not be used to endorse or promote products | |
| 14 * derived from this software without specific prior written permission. | |
| 15 * | |
| 16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED | |
| 17 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF | |
| 18 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO | |
| 19 * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | |
| 20 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, | |
| 21 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; | |
| 22 * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, | |
| 23 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR | |
| 24 * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF | |
| 25 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | |
| 26 */ | |
| 27 | |
| 28 #include "talk/examples/peerconnection/client/linux/main_wnd.h" | |
| 29 | |
| 30 #include <gdk/gdkkeysyms.h> | |
| 31 #include <gtk/gtk.h> | |
| 32 #include <stddef.h> | |
| 33 | |
| 34 #include "talk/examples/peerconnection/client/defaults.h" | |
| 35 #include "webrtc/base/common.h" | |
| 36 #include "webrtc/base/logging.h" | |
| 37 #include "webrtc/base/stringutils.h" | |
| 38 | |
| 39 using rtc::sprintfn; | |
| 40 | |
| 41 namespace { | |
| 42 | |
| 43 // | |
| 44 // Simple static functions that simply forward the callback to the | |
| 45 // GtkMainWnd instance. | |
| 46 // | |
| 47 | |
| 48 gboolean OnDestroyedCallback(GtkWidget* widget, GdkEvent* event, | |
| 49 gpointer data) { | |
| 50 reinterpret_cast<GtkMainWnd*>(data)->OnDestroyed(widget, event); | |
| 51 return FALSE; | |
| 52 } | |
| 53 | |
| 54 void OnClickedCallback(GtkWidget* widget, gpointer data) { | |
| 55 reinterpret_cast<GtkMainWnd*>(data)->OnClicked(widget); | |
| 56 } | |
| 57 | |
| 58 gboolean SimulateButtonClick(gpointer button) { | |
| 59 g_signal_emit_by_name(button, "clicked"); | |
| 60 return false; | |
| 61 } | |
| 62 | |
| 63 gboolean OnKeyPressCallback(GtkWidget* widget, GdkEventKey* key, | |
| 64 gpointer data) { | |
| 65 reinterpret_cast<GtkMainWnd*>(data)->OnKeyPress(widget, key); | |
| 66 return false; | |
| 67 } | |
| 68 | |
| 69 void OnRowActivatedCallback(GtkTreeView* tree_view, GtkTreePath* path, | |
| 70 GtkTreeViewColumn* column, gpointer data) { | |
| 71 reinterpret_cast<GtkMainWnd*>(data)->OnRowActivated(tree_view, path, column); | |
| 72 } | |
| 73 | |
| 74 gboolean SimulateLastRowActivated(gpointer data) { | |
| 75 GtkTreeView* tree_view = reinterpret_cast<GtkTreeView*>(data); | |
| 76 GtkTreeModel* model = gtk_tree_view_get_model(tree_view); | |
| 77 | |
| 78 // "if iter is NULL, then the number of toplevel nodes is returned." | |
| 79 int rows = gtk_tree_model_iter_n_children(model, NULL); | |
| 80 GtkTreePath* lastpath = gtk_tree_path_new_from_indices(rows - 1, -1); | |
| 81 | |
| 82 // Select the last item in the list | |
| 83 GtkTreeSelection* selection = gtk_tree_view_get_selection(tree_view); | |
| 84 gtk_tree_selection_select_path(selection, lastpath); | |
| 85 | |
| 86 // Our TreeView only has one column, so it is column 0. | |
| 87 GtkTreeViewColumn* column = gtk_tree_view_get_column(tree_view, 0); | |
| 88 | |
| 89 gtk_tree_view_row_activated(tree_view, lastpath, column); | |
| 90 | |
| 91 gtk_tree_path_free(lastpath); | |
| 92 return false; | |
| 93 } | |
| 94 | |
| 95 // Creates a tree view, that we use to display the list of peers. | |
| 96 void InitializeList(GtkWidget* list) { | |
| 97 GtkCellRenderer* renderer = gtk_cell_renderer_text_new(); | |
| 98 GtkTreeViewColumn* column = gtk_tree_view_column_new_with_attributes( | |
| 99 "List Items", renderer, "text", 0, NULL); | |
| 100 gtk_tree_view_append_column(GTK_TREE_VIEW(list), column); | |
| 101 GtkListStore* store = gtk_list_store_new(2, G_TYPE_STRING, G_TYPE_INT); | |
| 102 gtk_tree_view_set_model(GTK_TREE_VIEW(list), GTK_TREE_MODEL(store)); | |
| 103 g_object_unref(store); | |
| 104 } | |
| 105 | |
| 106 // Adds an entry to a tree view. | |
| 107 void AddToList(GtkWidget* list, const gchar* str, int value) { | |
| 108 GtkListStore* store = GTK_LIST_STORE( | |
| 109 gtk_tree_view_get_model(GTK_TREE_VIEW(list))); | |
| 110 | |
| 111 GtkTreeIter iter; | |
| 112 gtk_list_store_append(store, &iter); | |
| 113 gtk_list_store_set(store, &iter, 0, str, 1, value, -1); | |
| 114 } | |
| 115 | |
| 116 struct UIThreadCallbackData { | |
| 117 explicit UIThreadCallbackData(MainWndCallback* cb, int id, void* d) | |
| 118 : callback(cb), msg_id(id), data(d) {} | |
| 119 MainWndCallback* callback; | |
| 120 int msg_id; | |
| 121 void* data; | |
| 122 }; | |
| 123 | |
| 124 gboolean HandleUIThreadCallback(gpointer data) { | |
| 125 UIThreadCallbackData* cb_data = reinterpret_cast<UIThreadCallbackData*>(data); | |
| 126 cb_data->callback->UIThreadCallback(cb_data->msg_id, cb_data->data); | |
| 127 delete cb_data; | |
| 128 return false; | |
| 129 } | |
| 130 | |
| 131 gboolean Redraw(gpointer data) { | |
| 132 GtkMainWnd* wnd = reinterpret_cast<GtkMainWnd*>(data); | |
| 133 wnd->OnRedraw(); | |
| 134 return false; | |
| 135 } | |
| 136 } // end anonymous | |
| 137 | |
| 138 // | |
| 139 // GtkMainWnd implementation. | |
| 140 // | |
| 141 | |
| 142 GtkMainWnd::GtkMainWnd(const char* server, int port, bool autoconnect, | |
| 143 bool autocall) | |
| 144 : window_(NULL), draw_area_(NULL), vbox_(NULL), server_edit_(NULL), | |
| 145 port_edit_(NULL), peer_list_(NULL), callback_(NULL), | |
| 146 server_(server), autoconnect_(autoconnect), autocall_(autocall) { | |
| 147 char buffer[10]; | |
| 148 sprintfn(buffer, sizeof(buffer), "%i", port); | |
| 149 port_ = buffer; | |
| 150 } | |
| 151 | |
| 152 GtkMainWnd::~GtkMainWnd() { | |
| 153 ASSERT(!IsWindow()); | |
| 154 } | |
| 155 | |
| 156 void GtkMainWnd::RegisterObserver(MainWndCallback* callback) { | |
| 157 callback_ = callback; | |
| 158 } | |
| 159 | |
| 160 bool GtkMainWnd::IsWindow() { | |
| 161 return window_ != NULL && GTK_IS_WINDOW(window_); | |
| 162 } | |
| 163 | |
| 164 void GtkMainWnd::MessageBox(const char* caption, const char* text, | |
| 165 bool is_error) { | |
| 166 GtkWidget* dialog = gtk_message_dialog_new(GTK_WINDOW(window_), | |
| 167 GTK_DIALOG_DESTROY_WITH_PARENT, | |
| 168 is_error ? GTK_MESSAGE_ERROR : GTK_MESSAGE_INFO, | |
| 169 GTK_BUTTONS_CLOSE, "%s", text); | |
| 170 gtk_window_set_title(GTK_WINDOW(dialog), caption); | |
| 171 gtk_dialog_run(GTK_DIALOG(dialog)); | |
| 172 gtk_widget_destroy(dialog); | |
| 173 } | |
| 174 | |
| 175 MainWindow::UI GtkMainWnd::current_ui() { | |
| 176 if (vbox_) | |
| 177 return CONNECT_TO_SERVER; | |
| 178 | |
| 179 if (peer_list_) | |
| 180 return LIST_PEERS; | |
| 181 | |
| 182 return STREAMING; | |
| 183 } | |
| 184 | |
| 185 | |
| 186 void GtkMainWnd::StartLocalRenderer(webrtc::VideoTrackInterface* local_video) { | |
| 187 local_renderer_.reset(new VideoRenderer(this, local_video)); | |
| 188 } | |
| 189 | |
| 190 void GtkMainWnd::StopLocalRenderer() { | |
| 191 local_renderer_.reset(); | |
| 192 } | |
| 193 | |
| 194 void GtkMainWnd::StartRemoteRenderer(webrtc::VideoTrackInterface* remote_video)
{ | |
| 195 remote_renderer_.reset(new VideoRenderer(this, remote_video)); | |
| 196 } | |
| 197 | |
| 198 void GtkMainWnd::StopRemoteRenderer() { | |
| 199 remote_renderer_.reset(); | |
| 200 } | |
| 201 | |
| 202 void GtkMainWnd::QueueUIThreadCallback(int msg_id, void* data) { | |
| 203 g_idle_add(HandleUIThreadCallback, | |
| 204 new UIThreadCallbackData(callback_, msg_id, data)); | |
| 205 } | |
| 206 | |
| 207 bool GtkMainWnd::Create() { | |
| 208 ASSERT(window_ == NULL); | |
| 209 | |
| 210 window_ = gtk_window_new(GTK_WINDOW_TOPLEVEL); | |
| 211 if (window_) { | |
| 212 gtk_window_set_position(GTK_WINDOW(window_), GTK_WIN_POS_CENTER); | |
| 213 gtk_window_set_default_size(GTK_WINDOW(window_), 640, 480); | |
| 214 gtk_window_set_title(GTK_WINDOW(window_), "PeerConnection client"); | |
| 215 g_signal_connect(G_OBJECT(window_), "delete-event", | |
| 216 G_CALLBACK(&OnDestroyedCallback), this); | |
| 217 g_signal_connect(window_, "key-press-event", G_CALLBACK(OnKeyPressCallback), | |
| 218 this); | |
| 219 | |
| 220 SwitchToConnectUI(); | |
| 221 } | |
| 222 | |
| 223 return window_ != NULL; | |
| 224 } | |
| 225 | |
| 226 bool GtkMainWnd::Destroy() { | |
| 227 if (!IsWindow()) | |
| 228 return false; | |
| 229 | |
| 230 gtk_widget_destroy(window_); | |
| 231 window_ = NULL; | |
| 232 | |
| 233 return true; | |
| 234 } | |
| 235 | |
| 236 void GtkMainWnd::SwitchToConnectUI() { | |
| 237 LOG(INFO) << __FUNCTION__; | |
| 238 | |
| 239 ASSERT(IsWindow()); | |
| 240 ASSERT(vbox_ == NULL); | |
| 241 | |
| 242 gtk_container_set_border_width(GTK_CONTAINER(window_), 10); | |
| 243 | |
| 244 if (peer_list_) { | |
| 245 gtk_widget_destroy(peer_list_); | |
| 246 peer_list_ = NULL; | |
| 247 } | |
| 248 | |
| 249 vbox_ = gtk_vbox_new(FALSE, 5); | |
| 250 GtkWidget* valign = gtk_alignment_new(0, 1, 0, 0); | |
| 251 gtk_container_add(GTK_CONTAINER(vbox_), valign); | |
| 252 gtk_container_add(GTK_CONTAINER(window_), vbox_); | |
| 253 | |
| 254 GtkWidget* hbox = gtk_hbox_new(FALSE, 5); | |
| 255 | |
| 256 GtkWidget* label = gtk_label_new("Server"); | |
| 257 gtk_container_add(GTK_CONTAINER(hbox), label); | |
| 258 | |
| 259 server_edit_ = gtk_entry_new(); | |
| 260 gtk_entry_set_text(GTK_ENTRY(server_edit_), server_.c_str()); | |
| 261 gtk_widget_set_size_request(server_edit_, 400, 30); | |
| 262 gtk_container_add(GTK_CONTAINER(hbox), server_edit_); | |
| 263 | |
| 264 port_edit_ = gtk_entry_new(); | |
| 265 gtk_entry_set_text(GTK_ENTRY(port_edit_), port_.c_str()); | |
| 266 gtk_widget_set_size_request(port_edit_, 70, 30); | |
| 267 gtk_container_add(GTK_CONTAINER(hbox), port_edit_); | |
| 268 | |
| 269 GtkWidget* button = gtk_button_new_with_label("Connect"); | |
| 270 gtk_widget_set_size_request(button, 70, 30); | |
| 271 g_signal_connect(button, "clicked", G_CALLBACK(OnClickedCallback), this); | |
| 272 gtk_container_add(GTK_CONTAINER(hbox), button); | |
| 273 | |
| 274 GtkWidget* halign = gtk_alignment_new(1, 0, 0, 0); | |
| 275 gtk_container_add(GTK_CONTAINER(halign), hbox); | |
| 276 gtk_box_pack_start(GTK_BOX(vbox_), halign, FALSE, FALSE, 0); | |
| 277 | |
| 278 gtk_widget_show_all(window_); | |
| 279 | |
| 280 if (autoconnect_) | |
| 281 g_idle_add(SimulateButtonClick, button); | |
| 282 } | |
| 283 | |
| 284 void GtkMainWnd::SwitchToPeerList(const Peers& peers) { | |
| 285 LOG(INFO) << __FUNCTION__; | |
| 286 | |
| 287 if (!peer_list_) { | |
| 288 gtk_container_set_border_width(GTK_CONTAINER(window_), 0); | |
| 289 if (vbox_) { | |
| 290 gtk_widget_destroy(vbox_); | |
| 291 vbox_ = NULL; | |
| 292 server_edit_ = NULL; | |
| 293 port_edit_ = NULL; | |
| 294 } else if (draw_area_) { | |
| 295 gtk_widget_destroy(draw_area_); | |
| 296 draw_area_ = NULL; | |
| 297 draw_buffer_.reset(); | |
| 298 } | |
| 299 | |
| 300 peer_list_ = gtk_tree_view_new(); | |
| 301 g_signal_connect(peer_list_, "row-activated", | |
| 302 G_CALLBACK(OnRowActivatedCallback), this); | |
| 303 gtk_tree_view_set_headers_visible(GTK_TREE_VIEW(peer_list_), FALSE); | |
| 304 InitializeList(peer_list_); | |
| 305 gtk_container_add(GTK_CONTAINER(window_), peer_list_); | |
| 306 gtk_widget_show_all(window_); | |
| 307 } else { | |
| 308 GtkListStore* store = | |
| 309 GTK_LIST_STORE(gtk_tree_view_get_model(GTK_TREE_VIEW(peer_list_))); | |
| 310 gtk_list_store_clear(store); | |
| 311 } | |
| 312 | |
| 313 AddToList(peer_list_, "List of currently connected peers:", -1); | |
| 314 for (Peers::const_iterator i = peers.begin(); i != peers.end(); ++i) | |
| 315 AddToList(peer_list_, i->second.c_str(), i->first); | |
| 316 | |
| 317 if (autocall_ && peers.begin() != peers.end()) | |
| 318 g_idle_add(SimulateLastRowActivated, peer_list_); | |
| 319 } | |
| 320 | |
| 321 void GtkMainWnd::SwitchToStreamingUI() { | |
| 322 LOG(INFO) << __FUNCTION__; | |
| 323 | |
| 324 ASSERT(draw_area_ == NULL); | |
| 325 | |
| 326 gtk_container_set_border_width(GTK_CONTAINER(window_), 0); | |
| 327 if (peer_list_) { | |
| 328 gtk_widget_destroy(peer_list_); | |
| 329 peer_list_ = NULL; | |
| 330 } | |
| 331 | |
| 332 draw_area_ = gtk_drawing_area_new(); | |
| 333 gtk_container_add(GTK_CONTAINER(window_), draw_area_); | |
| 334 | |
| 335 gtk_widget_show_all(window_); | |
| 336 } | |
| 337 | |
| 338 void GtkMainWnd::OnDestroyed(GtkWidget* widget, GdkEvent* event) { | |
| 339 callback_->Close(); | |
| 340 window_ = NULL; | |
| 341 draw_area_ = NULL; | |
| 342 vbox_ = NULL; | |
| 343 server_edit_ = NULL; | |
| 344 port_edit_ = NULL; | |
| 345 peer_list_ = NULL; | |
| 346 } | |
| 347 | |
| 348 void GtkMainWnd::OnClicked(GtkWidget* widget) { | |
| 349 // Make the connect button insensitive, so that it cannot be clicked more than | |
| 350 // once. Now that the connection includes auto-retry, it should not be | |
| 351 // necessary to click it more than once. | |
| 352 gtk_widget_set_sensitive(widget, false); | |
| 353 server_ = gtk_entry_get_text(GTK_ENTRY(server_edit_)); | |
| 354 port_ = gtk_entry_get_text(GTK_ENTRY(port_edit_)); | |
| 355 int port = port_.length() ? atoi(port_.c_str()) : 0; | |
| 356 callback_->StartLogin(server_, port); | |
| 357 } | |
| 358 | |
| 359 void GtkMainWnd::OnKeyPress(GtkWidget* widget, GdkEventKey* key) { | |
| 360 if (key->type == GDK_KEY_PRESS) { | |
| 361 switch (key->keyval) { | |
| 362 case GDK_Escape: | |
| 363 if (draw_area_) { | |
| 364 callback_->DisconnectFromCurrentPeer(); | |
| 365 } else if (peer_list_) { | |
| 366 callback_->DisconnectFromServer(); | |
| 367 } | |
| 368 break; | |
| 369 | |
| 370 case GDK_KP_Enter: | |
| 371 case GDK_Return: | |
| 372 if (vbox_) { | |
| 373 OnClicked(NULL); | |
| 374 } else if (peer_list_) { | |
| 375 // OnRowActivated will be called automatically when the user | |
| 376 // presses enter. | |
| 377 } | |
| 378 break; | |
| 379 | |
| 380 default: | |
| 381 break; | |
| 382 } | |
| 383 } | |
| 384 } | |
| 385 | |
| 386 void GtkMainWnd::OnRowActivated(GtkTreeView* tree_view, GtkTreePath* path, | |
| 387 GtkTreeViewColumn* column) { | |
| 388 ASSERT(peer_list_ != NULL); | |
| 389 GtkTreeIter iter; | |
| 390 GtkTreeModel* model; | |
| 391 GtkTreeSelection* selection = | |
| 392 gtk_tree_view_get_selection(GTK_TREE_VIEW(tree_view)); | |
| 393 if (gtk_tree_selection_get_selected(selection, &model, &iter)) { | |
| 394 char* text; | |
| 395 int id = -1; | |
| 396 gtk_tree_model_get(model, &iter, 0, &text, 1, &id, -1); | |
| 397 if (id != -1) | |
| 398 callback_->ConnectToPeer(id); | |
| 399 g_free(text); | |
| 400 } | |
| 401 } | |
| 402 | |
| 403 void GtkMainWnd::OnRedraw() { | |
| 404 gdk_threads_enter(); | |
| 405 | |
| 406 VideoRenderer* remote_renderer = remote_renderer_.get(); | |
| 407 if (remote_renderer && remote_renderer->image() != NULL && | |
| 408 draw_area_ != NULL) { | |
| 409 int width = remote_renderer->width(); | |
| 410 int height = remote_renderer->height(); | |
| 411 | |
| 412 if (!draw_buffer_.get()) { | |
| 413 draw_buffer_size_ = (width * height * 4) * 4; | |
| 414 draw_buffer_.reset(new uint8[draw_buffer_size_]); | |
| 415 gtk_widget_set_size_request(draw_area_, width * 2, height * 2); | |
| 416 } | |
| 417 | |
| 418 const uint32* image = reinterpret_cast<const uint32*>( | |
| 419 remote_renderer->image()); | |
| 420 uint32* scaled = reinterpret_cast<uint32*>(draw_buffer_.get()); | |
| 421 for (int r = 0; r < height; ++r) { | |
| 422 for (int c = 0; c < width; ++c) { | |
| 423 int x = c * 2; | |
| 424 scaled[x] = scaled[x + 1] = image[c]; | |
| 425 } | |
| 426 | |
| 427 uint32* prev_line = scaled; | |
| 428 scaled += width * 2; | |
| 429 memcpy(scaled, prev_line, (width * 2) * 4); | |
| 430 | |
| 431 image += width; | |
| 432 scaled += width * 2; | |
| 433 } | |
| 434 | |
| 435 VideoRenderer* local_renderer = local_renderer_.get(); | |
| 436 if (local_renderer && local_renderer->image()) { | |
| 437 image = reinterpret_cast<const uint32*>(local_renderer->image()); | |
| 438 scaled = reinterpret_cast<uint32*>(draw_buffer_.get()); | |
| 439 // Position the local preview on the right side. | |
| 440 scaled += (width * 2) - (local_renderer->width() / 2); | |
| 441 // right margin... | |
| 442 scaled -= 10; | |
| 443 // ... towards the bottom. | |
| 444 scaled += (height * width * 4) - | |
| 445 ((local_renderer->height() / 2) * | |
| 446 (local_renderer->width() / 2) * 4); | |
| 447 // bottom margin... | |
| 448 scaled -= (width * 2) * 5; | |
| 449 for (int r = 0; r < local_renderer->height(); r += 2) { | |
| 450 for (int c = 0; c < local_renderer->width(); c += 2) { | |
| 451 scaled[c / 2] = image[c + r * local_renderer->width()]; | |
| 452 } | |
| 453 scaled += width * 2; | |
| 454 } | |
| 455 } | |
| 456 | |
| 457 gdk_draw_rgb_32_image(draw_area_->window, | |
| 458 draw_area_->style->fg_gc[GTK_STATE_NORMAL], | |
| 459 0, | |
| 460 0, | |
| 461 width * 2, | |
| 462 height * 2, | |
| 463 GDK_RGB_DITHER_MAX, | |
| 464 draw_buffer_.get(), | |
| 465 (width * 2) * 4); | |
| 466 } | |
| 467 | |
| 468 gdk_threads_leave(); | |
| 469 } | |
| 470 | |
| 471 GtkMainWnd::VideoRenderer::VideoRenderer( | |
| 472 GtkMainWnd* main_wnd, | |
| 473 webrtc::VideoTrackInterface* track_to_render) | |
| 474 : width_(0), | |
| 475 height_(0), | |
| 476 main_wnd_(main_wnd), | |
| 477 rendered_track_(track_to_render) { | |
| 478 rendered_track_->AddRenderer(this); | |
| 479 } | |
| 480 | |
| 481 GtkMainWnd::VideoRenderer::~VideoRenderer() { | |
| 482 rendered_track_->RemoveRenderer(this); | |
| 483 } | |
| 484 | |
| 485 void GtkMainWnd::VideoRenderer::SetSize(int width, int height) { | |
| 486 gdk_threads_enter(); | |
| 487 | |
| 488 if (width_ == width && height_ == height) { | |
| 489 return; | |
| 490 } | |
| 491 | |
| 492 width_ = width; | |
| 493 height_ = height; | |
| 494 image_.reset(new uint8[width * height * 4]); | |
| 495 gdk_threads_leave(); | |
| 496 } | |
| 497 | |
| 498 void GtkMainWnd::VideoRenderer::RenderFrame( | |
| 499 const cricket::VideoFrame* video_frame) { | |
| 500 gdk_threads_enter(); | |
| 501 | |
| 502 const cricket::VideoFrame* frame = video_frame->GetCopyWithRotationApplied(); | |
| 503 | |
| 504 SetSize(static_cast<int>(frame->GetWidth()), | |
| 505 static_cast<int>(frame->GetHeight())); | |
| 506 | |
| 507 int size = width_ * height_ * 4; | |
| 508 // TODO: Convert directly to RGBA | |
| 509 frame->ConvertToRgbBuffer(cricket::FOURCC_ARGB, | |
| 510 image_.get(), | |
| 511 size, | |
| 512 width_ * 4); | |
| 513 // Convert the B,G,R,A frame to R,G,B,A, which is accepted by GTK. | |
| 514 // The 'A' is just padding for GTK, so we can use it as temp. | |
| 515 uint8* pix = image_.get(); | |
| 516 uint8* end = image_.get() + size; | |
| 517 while (pix < end) { | |
| 518 pix[3] = pix[0]; // Save B to A. | |
| 519 pix[0] = pix[2]; // Set Red. | |
| 520 pix[2] = pix[3]; // Set Blue. | |
| 521 pix[3] = 0xFF; // Fixed Alpha. | |
| 522 pix += 4; | |
| 523 } | |
| 524 | |
| 525 gdk_threads_leave(); | |
| 526 | |
| 527 g_idle_add(Redraw, main_wnd_); | |
| 528 } | |
| 529 | |
| 530 | |
| OLD | NEW |