USB - CEC Adapter

diff --git a/src/libcec.cpp b/src/libcec.cpp
index 7e6ed69..f25cc48 100644
--- a/src/libcec.cpp
+++ b/src/libcec.cpp
@@ -260,6 +260,10 @@ bool Cec::ping() {
     return cec->PingAdapter();
 }


+void Cec::activate() {
+ //cout << "activate()" << endl;
+ cec->SetActiveSource();
+}


 /**
  * Prints the name of all found adapters
diff --git a/src/libcec.h b/src/libcec.h
index d0678a2..50b27f1 100644
--- a/src/libcec.h
+++ b/src/libcec.h
@@ -68,6 +68,11 @@ class Cec {
                void setTargetAddress(const HDMI::address & address);
                bool ping();


+ /**
+ * Sets the PC as the active source
+ */
+void activate();
+
        // These are just wrapper functions, to map C callbacks to C++
        friend int cecLogMessage (void *cbParam, const CEC::cec_log_message &message);
        friend int cecKeyPress   (void *cbParam, const CEC::cec_keypress &key);
diff --git a/src/main.cpp b/src/main.cpp
index 13de756..3064dfa 100644
--- a/src/main.cpp
+++ b/src/main.cpp
@@ -32,6 +32,14 @@
 #include <log4cplus/logger.h>
 #include <log4cplus/loggingmacros.h>
 #include <log4cplus/configurator.h>
+// Socket stuff
+#include <stdio.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <string.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
:
diff --git a/src/libcec.cpp b/src/libcec.cpp
index 7e6ed69..f25cc48 100644
--- a/src/libcec.cpp
+++ b/src/libcec.cpp
@@ -260,6 +260,10 @@ bool Cec::ping() {
     return cec->PingAdapter();
 }


+void Cec::activate() {
+ //cout << "activate()" << endl;
+ cec->SetActiveSource();
+}


 /**
  * Prints the name of all found adapters
diff --git a/src/libcec.h b/src/libcec.h
index d0678a2..50b27f1 100644
--- a/src/libcec.h
+++ b/src/libcec.h
@@ -68,6 +68,11 @@ class Cec {
                void setTargetAddress(const HDMI::address & address);
                bool ping();


+ /**
+ * Sets the PC as the active source
+ */
+void activate();
+
        // These are just wrapper functions, to map C callbacks to C++
        friend int cecLogMessage (void *cbParam, const CEC::cec_log_message &message);
        friend int cecKeyPress   (void *cbParam, const CEC::cec_keypress &key);
diff --git a/src/main.cpp b/src/main.cpp
index 13de756..3064dfa 100644
--- a/src/main.cpp
+++ b/src/main.cpp
@@ -32,6 +32,14 @@
 #include <log4cplus/logger.h>
 #include <log4cplus/loggingmacros.h>
 #include <log4cplus/configurator.h>
+// Socket stuff
+#include <stdio.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <string.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <netinet/in.h>


 using namespace CEC;
 using namespace log4cplus;
@@ -167,7 +175,53 @@ void Main::loop(const string & device) {
                                running = cec.ping();
                        }
                }
-               while( running );
+               while( running ); {
+ //sleep(1);
+ // Socket
+ int sockfd, newsockfd, portno;
+ socklen_t clilen;
+ char buffer[256];
+ struct sockaddr_in serv_addr, cli_addr;
+ int n;
+
+ sockfd = socket(AF_INET, SOCK_STREAM, 0);
+ if (sockfd < 0)
+ cout << "ERROR opening socket" << endl;
+ bzero((char *) &serv_addr, sizeof(serv_addr));
+ portno = 23456;
+ serv_addr.sin_family = AF_INET;
+ serv_addr.sin_addr.s_addr = INADDR_ANY;
+ serv_addr.sin_port = htons(portno);
+ /*if (bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0)
+ cout << "ERROR on binding" << endl;*/
+ int on = 1;
+ if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)) < 0)
+ cout << "Couldn't set socket params!" << endl;
+ int so = bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr));
+ while(so < 0) {
+ cout << "ERROR on binding" << endl;
+ sleep(1);
+ so = bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr));
+ }
+ listen(sockfd,5);
+ clilen = sizeof(cli_addr);
+ newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen);
+ if (newsockfd < 0)
+ cout << "ERROR on accept" << endl;
+ bzero(buffer,256);
+ //cout << "Socket created!" << endl;
+ n = read(newsockfd,buffer,255);
+ if (n < 0)
+ cout << "Error reading from socket" << endl;
+ /*if (strcmp(buffer, "call\n") == 0) {
+ cout << "call received" << endl;
+ cec.activate();
+ }*/
+ cec.activate();
+ //cout << "message: " << buffer << endl;
+ close(newsockfd);
+ close(sockfd);
+        }


                /* reset signals */
                signal (SIGHUP,  SIG_DFL);
@@ -665,6 +719,43 @@ int main (int argc, char *argv[]) {
         }


                main.loop(device);
+               // Socket
+               /*int sockfd, newsockfd, portno, pid;
+               socklen_t clilen;
+               struct sockaddr_in serv_addr, cli_addr;
+
+               sockfd = socket(AF_INET, SOCK_STREAM, 0);
+               if (sockfd < 0)
+                       cout << "ERROR opening socket" << endl;
+               cout << "Made socket" << endl;
+               bzero((char *) &serv_addr, sizeof(serv_addr));
+               portno = 23456;
+               serv_addr.sin_family = AF_INET;
+               serv_addr.sin_addr.s_addr = INADDR_ANY;
+               serv_addr.sin_port = htons(portno);
+               if (bind(sockfd, (struct sockaddr *) &serv_addr,
+                sizeof(serv_addr)) < 0)
+                cout << "ERROR on binding" << endl;
+               listen(sockfd,5);
+               clilen = sizeof(cli_addr);
+               while (true) {
+                       newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen);
+                       if (newsockfd < 0)
+                               cout << "ERROR on accept" << endl;
+                       pid = fork();
+                       if (pid < 0)
+                               cout << "ERROR on fork" << endl;
+                       if (pid == 0) {
+                               close(sockfd);
+                               //dostuff(newsockfd);
+                               cout << "Socket created!" << endl;
+                               exit(0);
+                       }
+                       else
+                               close(newsockfd);
+               } // end of while
+               close(sockfd);
+               return 0; // we never get here */


        } catch (std::exception & e) {
                cerr << e.what() << endl;