Home | History | Annotate | Download | only in linux 
      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 <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 
     35 #include "talk/base/thread.h"
     36 
     37 class CustomSocketServer : public talk_base::PhysicalSocketServer {
     38  public:
     39   CustomSocketServer(talk_base::Thread* thread, GtkMainWnd* wnd)
     40       : thread_(thread), wnd_(wnd), conductor_(NULL), client_(NULL) {}
     41   virtual ~CustomSocketServer() {}
     42 
     43   void set_client(PeerConnectionClient* client) { client_ = client; }
     44   void set_conductor(Conductor* conductor) { conductor_ = conductor; }
     45 
     46   // Override so that we can also pump the GTK message loop.
     47   virtual bool Wait(int cms, bool process_io) {
     48     // Pump GTK events.
     49     // TODO: We really should move either the socket server or UI to a
     50     // different thread.  Alternatively we could look at merging the two loops
     51     // by implementing a dispatcher for the socket server and/or use
     52     // g_main_context_set_poll_func.
     53       while (gtk_events_pending())
     54         gtk_main_iteration();
     55 
     56     if (!wnd_->IsWindow() && !conductor_->connection_active() &&
     57         client_ != NULL && !client_->is_connected()) {
     58       thread_->Quit();
     59     }
     60     return talk_base::PhysicalSocketServer::Wait(0/*cms == -1 ? 1 : cms*/,
     61                                                  process_io);
     62   }
     63 
     64  protected:
     65   talk_base::Thread* thread_;
     66   GtkMainWnd* wnd_;
     67   Conductor* conductor_;
     68   PeerConnectionClient* client_;
     69 };
     70 
     71 int main(int argc, char* argv[]) {
     72   gtk_init(&argc, &argv);
     73   g_type_init();
     74   g_thread_init(NULL);
     75 
     76   FlagList::SetFlagsFromCommandLine(&argc, argv, true);
     77   if (FLAG_help) {
     78     FlagList::Print(NULL, false);
     79     return 0;
     80   }
     81 
     82   // Abort if the user specifies a port that is outside the allowed
     83   // range [1, 65535].
     84   if ((FLAG_port < 1) || (FLAG_port > 65535)) {
     85     printf("Error: %i is not a valid port.\n", FLAG_port);
     86     return -1;
     87   }
     88 
     89   GtkMainWnd wnd(FLAG_server, FLAG_port, FLAG_autoconnect, FLAG_autocall);
     90   wnd.Create();
     91 
     92   talk_base::AutoThread auto_thread;
     93   talk_base::Thread* thread = talk_base::Thread::Current();
     94   CustomSocketServer socket_server(thread, &wnd);
     95   thread->set_socketserver(&socket_server);
     96 
     97   // Must be constructed after we set the socketserver.
     98   PeerConnectionClient client;
     99   talk_base::scoped_refptr<Conductor> conductor(
    100       new talk_base::RefCountedObject<Conductor>(&client, &wnd));
    101   socket_server.set_client(&client);
    102   socket_server.set_conductor(conductor);
    103 
    104   thread->Run();
    105 
    106   // gtk_main();
    107   wnd.Destroy();
    108 
    109   thread->set_socketserver(NULL);
    110   // TODO: Run the Gtk main loop to tear down the connection.
    111   //while (gtk_events_pending()) {
    112   //  gtk_main_iteration();
    113   //}
    114 
    115   return 0;
    116 }
    117 
    118