henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 1 | /* |
| 2 | * libjingle |
jlmiller@webrtc.org | 5f93d0a | 2015-01-20 21:36:13 +0000 | [diff] [blame] | 3 | * Copyright 2012 Google Inc. |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 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 <gtk/gtk.h> |
| 29 | |
| 30 | #include "talk/examples/peerconnection/client/conductor.h" |
| 31 | #include "talk/examples/peerconnection/client/flagdefs.h" |
| 32 | #include "talk/examples/peerconnection/client/linux/main_wnd.h" |
| 33 | #include "talk/examples/peerconnection/client/peer_connection_client.h" |
| 34 | |
buildbot@webrtc.org | d4e598d | 2014-07-29 17:36:52 +0000 | [diff] [blame] | 35 | #include "webrtc/base/ssladapter.h" |
| 36 | #include "webrtc/base/thread.h" |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 37 | |
buildbot@webrtc.org | d4e598d | 2014-07-29 17:36:52 +0000 | [diff] [blame] | 38 | class CustomSocketServer : public rtc::PhysicalSocketServer { |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 39 | public: |
buildbot@webrtc.org | d4e598d | 2014-07-29 17:36:52 +0000 | [diff] [blame] | 40 | CustomSocketServer(rtc::Thread* thread, GtkMainWnd* wnd) |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 41 | : thread_(thread), wnd_(wnd), conductor_(NULL), client_(NULL) {} |
| 42 | virtual ~CustomSocketServer() {} |
| 43 | |
| 44 | void set_client(PeerConnectionClient* client) { client_ = client; } |
| 45 | void set_conductor(Conductor* conductor) { conductor_ = conductor; } |
| 46 | |
| 47 | // Override so that we can also pump the GTK message loop. |
| 48 | virtual bool Wait(int cms, bool process_io) { |
| 49 | // Pump GTK events. |
| 50 | // TODO: We really should move either the socket server or UI to a |
| 51 | // different thread. Alternatively we could look at merging the two loops |
| 52 | // by implementing a dispatcher for the socket server and/or use |
| 53 | // g_main_context_set_poll_func. |
| 54 | while (gtk_events_pending()) |
| 55 | gtk_main_iteration(); |
| 56 | |
| 57 | if (!wnd_->IsWindow() && !conductor_->connection_active() && |
| 58 | client_ != NULL && !client_->is_connected()) { |
| 59 | thread_->Quit(); |
| 60 | } |
buildbot@webrtc.org | d4e598d | 2014-07-29 17:36:52 +0000 | [diff] [blame] | 61 | return rtc::PhysicalSocketServer::Wait(0/*cms == -1 ? 1 : cms*/, |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 62 | process_io); |
| 63 | } |
| 64 | |
| 65 | protected: |
buildbot@webrtc.org | d4e598d | 2014-07-29 17:36:52 +0000 | [diff] [blame] | 66 | rtc::Thread* thread_; |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 67 | GtkMainWnd* wnd_; |
| 68 | Conductor* conductor_; |
| 69 | PeerConnectionClient* client_; |
| 70 | }; |
| 71 | |
| 72 | int main(int argc, char* argv[]) { |
| 73 | gtk_init(&argc, &argv); |
| 74 | g_type_init(); |
decurtis@webrtc.org | bfa3c72 | 2015-02-17 21:22:48 +0000 | [diff] [blame^] | 75 | // g_thread_init API is deprecated since glib 2.31.0, see release note: |
| 76 | // http://mail.gnome.org/archives/gnome-announce-list/2011-October/msg00041.html |
| 77 | #if !GLIB_CHECK_VERSION(2, 31, 0) |
| 78 | g_thread_init(NULL); |
| 79 | #endif |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 80 | |
buildbot@webrtc.org | d4e598d | 2014-07-29 17:36:52 +0000 | [diff] [blame] | 81 | rtc::FlagList::SetFlagsFromCommandLine(&argc, argv, true); |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 82 | if (FLAG_help) { |
buildbot@webrtc.org | d4e598d | 2014-07-29 17:36:52 +0000 | [diff] [blame] | 83 | rtc::FlagList::Print(NULL, false); |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 84 | return 0; |
| 85 | } |
| 86 | |
| 87 | // Abort if the user specifies a port that is outside the allowed |
| 88 | // range [1, 65535]. |
| 89 | if ((FLAG_port < 1) || (FLAG_port > 65535)) { |
| 90 | printf("Error: %i is not a valid port.\n", FLAG_port); |
| 91 | return -1; |
| 92 | } |
| 93 | |
| 94 | GtkMainWnd wnd(FLAG_server, FLAG_port, FLAG_autoconnect, FLAG_autocall); |
| 95 | wnd.Create(); |
| 96 | |
buildbot@webrtc.org | d4e598d | 2014-07-29 17:36:52 +0000 | [diff] [blame] | 97 | rtc::AutoThread auto_thread; |
| 98 | rtc::Thread* thread = rtc::Thread::Current(); |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 99 | CustomSocketServer socket_server(thread, &wnd); |
| 100 | thread->set_socketserver(&socket_server); |
| 101 | |
buildbot@webrtc.org | d4e598d | 2014-07-29 17:36:52 +0000 | [diff] [blame] | 102 | rtc::InitializeSSL(); |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 103 | // Must be constructed after we set the socketserver. |
| 104 | PeerConnectionClient client; |
buildbot@webrtc.org | d4e598d | 2014-07-29 17:36:52 +0000 | [diff] [blame] | 105 | rtc::scoped_refptr<Conductor> conductor( |
| 106 | new rtc::RefCountedObject<Conductor>(&client, &wnd)); |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 107 | socket_server.set_client(&client); |
| 108 | socket_server.set_conductor(conductor); |
| 109 | |
| 110 | thread->Run(); |
| 111 | |
| 112 | // gtk_main(); |
| 113 | wnd.Destroy(); |
| 114 | |
| 115 | thread->set_socketserver(NULL); |
| 116 | // TODO: Run the Gtk main loop to tear down the connection. |
| 117 | //while (gtk_events_pending()) { |
| 118 | // gtk_main_iteration(); |
| 119 | //} |
buildbot@webrtc.org | d4e598d | 2014-07-29 17:36:52 +0000 | [diff] [blame] | 120 | rtc::CleanupSSL(); |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 121 | return 0; |
| 122 | } |