Update answerer.c

Fixing format

test/p2p_c_version/answerer.c

@@ -1,5 +1,5 @@
 
-#include <rtc/rtc.h>
+ #include <rtc/rtc.h>
 
  #include <stdbool.h>
  #include <stdio.h>
@@ -9,15 +9,15 @@
  #include <ctype.h>
 
 typedef struct {
-	rtcState state;
-	rtcGatheringState gatheringState;
-	int pc;
-	int dc;
-	bool connected;
+        rtcState state;
+        rtcGatheringState gatheringState;
+        int pc;
+        int dc;
+        bool connected;
 } Peer;
 
 Peer *peer = NULL;
-static void dataChannelCallback(int dc, void *ptr) ;
+static void dataChannelCallback(int dc, void *ptr);
 static void descriptionCallback(const char *sdp, const char *type, void *ptr);
 
 static void candidateCallback(const char *cand, const char *mid, void *ptr);
@@ -26,7 +26,6 @@ static void stateChangeCallback(rtcState state, void *ptr);
 
 static void gatheringStateCallback(rtcGatheringState state, void *ptr);
 
-// static void openCallback(void *ptr);
 
 static void closedCallback(void *ptr);
 
@@ -39,285 +38,270 @@ char* rtcGatheringState_print(rtcState state);
 
 
 int main(int argc, char **argv) {
-	rtcInitLogger(RTC_LOG_DEBUG);
+        rtcInitLogger(RTC_LOG_DEBUG);
 
-	// Create peer
-	rtcConfiguration config;
-	memset(&config, 0, sizeof(config));
+        // Create peer
+        rtcConfiguration config;
+        memset(&config, 0, sizeof(config));
 
-      Peer *peer = (Peer *)malloc(sizeof(Peer));
-	if (!peer){
+        Peer *peer = (Peer *)malloc(sizeof(Peer));
+        if (!peer) {
 
-            printf("Error allocating memory for peer\n");
-            deletePeer(peer);
+                printf("Error allocating memory for peer\n");
+                deletePeer(peer);
 
-      }
-	memset(peer, 0, sizeof(Peer));
-
-      printf("Peer created\n");
-
-      // Create peer connection
-      peer->pc = rtcCreatePeerConnection(&config);
+        }
+        memset(peer, 0, sizeof(Peer));
 
-	rtcSetUserPointer(peer->pc, peer);
-	rtcSetLocalDescriptionCallback(peer->pc, descriptionCallback);
-	rtcSetLocalCandidateCallback(peer->pc, candidateCallback);
-	rtcSetStateChangeCallback(peer->pc, stateChangeCallback);
-	rtcSetGatheringStateChangeCallback(peer->pc, gatheringStateCallback);
+        printf("Peer created\n");
 
-      rtcSetUserPointer(peer->dc, NULL);
-	rtcSetDataChannelCallback(peer->pc, dataChannelCallback);
+        // Create peer connection
+        peer->pc = rtcCreatePeerConnection(&config);
 
+        rtcSetUserPointer(peer->pc, peer);
+        rtcSetLocalDescriptionCallback(peer->pc, descriptionCallback);
+        rtcSetLocalCandidateCallback(peer->pc, candidateCallback);
+        rtcSetStateChangeCallback(peer->pc, stateChangeCallback);
+        rtcSetGatheringStateChangeCallback(peer->pc, gatheringStateCallback);
 
+        rtcSetUserPointer(peer->dc, NULL);
+        rtcSetDataChannelCallback(peer->pc, dataChannelCallback);
 
 
-	bool exit = false;
 
-	while (!exit) {
 
-		printf("\n");
-		printf("***************************************************************************************\n");
+        bool exit = false;
 
-	     // << endl
-	     printf("* 0: Exit /"
-			" 1: Enter remote description /"
-			" 2: Enter remote candidate /"
-			" 3: Send message /"
-			" 4: Print Connection Info *\n"
-			"[Command]: ");
+        while (!exit) {
 
-		int command = -1;
-            int c;
-		// int check_scan
-		if (scanf("%d", &command)){
+                printf("\n");
+                printf("***************************************************************************************\n");
 
-		}else {
-			break;
-		}
-            while ((c = getchar()) != '\n' && c != EOF) { }
+                // << endl
+                printf("* 0: Exit /"
+                       " 1: Enter remote description /"
+                       " 2: Enter remote candidate /"
+                       " 3: Send message /"
+                       " 4: Print Connection Info *\n"
+                       "[Command]: ");
 
-		fflush(stdin);
-		switch (command) {
-		case 0: {
-			exit = true;
-			break;
-		}
-            case 1: {
-			// Parse Description
-			printf("[Description]: ");
+                int command = -1;
+                int c;
+                // int check_scan
+                if (scanf("%d", &command)) {
 
+                }else {
+                        break;
+                }
+                while ((c = getchar()) != '\n' && c != EOF) { }
 
-                   char *line = NULL;
-                   size_t len = 0;
-                   size_t read = 0;
-                   char *sdp = (char*) malloc(sizeof(char));
-                   while ((read = getline(&line, &len, stdin)) != -1 && !all_space(line)) {
-                        sdp = (char*) realloc (sdp,(strlen(sdp)+1) +strlen(line)+1);
-                        strcat(sdp, line);
-                  // strcat(sdp, "\r\n");
+                fflush(stdin);
+                switch (command) {
+                case 0: {
+                        exit = true;
+                        break;
+                }
+                case 1: {
+                        // Parse Description
+                        printf("[Description]: ");
+
+
+                        char *line = NULL;
+                        size_t len = 0;
+                        size_t read = 0;
+                        char *sdp = (char*) malloc(sizeof(char));
+                        while ((read = getline(&line, &len, stdin)) != -1 && !all_space(line)) {
+                                sdp = (char*) realloc (sdp,(strlen(sdp)+1) +strlen(line)+1);
+                                strcat(sdp, line);
+
+                        }
+                        printf("%s\n",sdp);
+                        rtcSetRemoteDescription(peer->pc, sdp, "offer");
+                        free(sdp);
+                        free(line);
+                        break;
 
-                  }
-                  printf("%s\n",sdp);
-                  rtcSetRemoteDescription(peer->pc, sdp, "offer");
-                  free(sdp);
-                  free(line);
-                  break;
+                }
+                case 2: {
+                        // Parse Candidate
+                        printf("[Candidate]: ");
+                        char* candidate = NULL;
+                        size_t candidate_size = 0;
 
-		}
-		case 2: {
-			// Parse Candidate
-			printf("[Candidate]: ");
-                  char* candidate = NULL;
-			size_t candidate_size = 0;
+                        if(getline(&candidate, &candidate_size, stdin)) {
+                                rtcAddRemoteCandidate(peer->pc, candidate, "0");
+                                free(candidate);
 
-                  if(getline(&candidate, &candidate_size, stdin)){
-                        rtcAddRemoteCandidate(peer->pc, candidate, "0");
-                        free(candidate);
+                        }else {
+                                printf("Error reading line\n");
+                                break;
+                        }
 
-                  }else {
-                        printf("Error reading line\n");
                         break;
-                  }
-
-			break;
-		}
-		case 3: {
-			// Send Message
-                  if(!peer->connected){
-				printf("** Channel is not Open **");
-				break;
-			}
-			printf("[Message]: ");
-                  char* message = NULL;
-			size_t message_size = 0;
-
-                  if(getline(&message, &message_size, stdin)){
-                        rtcSendMessage(peer->dc, message, -1);
-                        free(message);
-                  }else {
-                        printf("Error reading line\n");
+                }
+                case 3: {
+                        // Send Message
+                        if(!peer->connected) {
+                                printf("** Channel is not Open **");
+                                break;
+                        }
+                        printf("[Message]: ");
+                        char* message = NULL;
+                        size_t message_size = 0;
+
+                        if(getline(&message, &message_size, stdin)) {
+                                rtcSendMessage(peer->dc, message, -1);
+                                free(message);
+                        }else {
+                                printf("Error reading line\n");
+                                break;
+                        }
+                        break;
+                }
+                case 4: {
+                        // Connection Info
+                        if(!peer->connected) {
+                                printf("** Channel is not Open **");
+                                break;
+                        }
+                        char buffer[256];
+                        if (rtcGetLocalAddress(peer->pc, buffer, 256) >= 0)
+                                printf("Local address 1:  %s\n", buffer);
+                        if (rtcGetRemoteAddress(peer->pc, buffer, 256) >= 0)
+                                printf("Remote address 1: %s\n", buffer);
+
+                        else
+                                printf("Could not get Candidate Pair Info\n");
                         break;
-                  }
-			break;
-		}
-		case 4: {
-			// Connection Info
-                  if(!peer->connected){
-				printf("** Channel is not Open **");
-				break;
-			}
-                  char buffer[256];
-                  if (rtcGetLocalAddress(peer->pc, buffer, 256) >= 0)
-                        printf("Local address 1:  %s\n", buffer);
-                  if (rtcGetRemoteAddress(peer->pc, buffer, 256) >= 0)
-                        printf("Remote address 1: %s\n", buffer);
-
-			else
-				printf("Could not get Candidate Pair Info\n");
-			break;
-		}
-		default: {
-			printf("** Invalid Command **");
-			break;
-		}
-		}
-	}
-
-
-	deletePeer(peer);
-	return 0;
+                }
+                default: {
+                        printf("** Invalid Command **");
+                        break;
+                }
+                }
+        }
+
+
+        deletePeer(peer);
+        return 0;
 }
 
 
 static void descriptionCallback(const char *sdp, const char *type, void *ptr) {
-	// Peer *peer = (Peer *)ptr;
-	printf("Description %s:\n%s\n", "answerer", sdp);
+        // Peer *peer = (Peer *)ptr;
+        printf("Description %s:\n%s\n", "answerer", sdp);
 }
 
 static void candidateCallback(const char *cand, const char *mid, void *ptr) {
-	// Peer *peer = (Peer *)ptr;
-	printf("Candidate %s: %s\n", "answerer", cand);
+        // Peer *peer = (Peer *)ptr;
+        printf("Candidate %s: %s\n", "answerer", cand);
 
 }
 
 static void stateChangeCallback(rtcState state, void *ptr) {
-	Peer *peer = (Peer *)ptr;
-	peer->state = state;
-	printf("State %s: %s\n", "answerer", state_print(state));
+        Peer *peer = (Peer *)ptr;
+        peer->state = state;
+        printf("State %s: %s\n", "answerer", state_print(state));
 }
 
 static void gatheringStateCallback(rtcGatheringState state, void *ptr) {
-	Peer *peer = (Peer *)ptr;
-	peer->gatheringState = state;
-	printf("Gathering state %s: %s\n", "answerer", rtcGatheringState_print(state));
+        Peer *peer = (Peer *)ptr;
+        peer->gatheringState = state;
+        printf("Gathering state %s: %s\n", "answerer", rtcGatheringState_print(state));
 }
 
 
-// static void openCallback(void *ptr) {
-// 	Peer *peer = (Peer *)ptr;
-// 	peer->connected = true;
-//       printf("Reached this openCallback\n");
-//       // char buffer[256];
-// 	// if (rtcGetDataChannelLabel(peer->dc, buffer, 256) >= 0)
-// 	// 	printf("DataChannel %s: Received with label \"%s\"\n","answerer", buffer);
-//       //
-//
-// }
 
 static void closedCallback(void *ptr) {
-	Peer *peer = (Peer *)ptr;
-	peer->connected = false;
+        Peer *peer = (Peer *)ptr;
+        peer->connected = false;
 
-      // char buffer[256];
 
-      // if (rtcGetDataChannelLabel(peer->dc, buffer, 256) >= 0)
-      //       printf("DataChannel %s: Received with label \"%s\"\n","answerer", buffer);
-      //
 }
 static void messageCallback(const char *message, int size, void *ptr) {
-	// Peer *peer = (Peer *)ptr;
-	if (size < 0) { // negative size indicates a null-terminated string
-		printf("Message %s: %s\n", "answerer", message);
-	} else {
-		printf("Message %s: [binary of size %d]\n", "answerer", size);
-	}
+        // Peer *peer = (Peer *)ptr;
+        if (size < 0) { // negative size indicates a null-terminated string
+                printf("Message %s: %s\n", "answerer", message);
+        } else {
+                printf("Message %s: [binary of size %d]\n", "answerer", size);
+        }
 }
 static void deletePeer(Peer *peer) {
-	if (peer) {
-		if (peer->dc)
-			rtcDeleteDataChannel(peer->dc);
-		if (peer->pc)
-			rtcDeletePeerConnection(peer->pc);
-		free(peer);
-	}
+        if (peer) {
+                if (peer->dc)
+                        rtcDeleteDataChannel(peer->dc);
+                if (peer->pc)
+                        rtcDeletePeerConnection(peer->pc);
+                free(peer);
+        }
 }
 
 static void dataChannelCallback(int dc, void *ptr) {
-	Peer *peer = (Peer *)ptr;
-	peer->dc = dc;
-	peer->connected = true;
-      rtcSetClosedCallback(dc, closedCallback);
-	rtcSetMessageCallback(dc, messageCallback);
-	char buffer[256];
-	if (rtcGetDataChannelLabel(dc, buffer, 256) >= 0)
-		printf("DataChannel %s: Received with label \"%s\"\n", "answerer", buffer);
+        Peer *peer = (Peer *)ptr;
+        peer->dc = dc;
+        peer->connected = true;
+        rtcSetClosedCallback(dc, closedCallback);
+        rtcSetMessageCallback(dc, messageCallback);
+        char buffer[256];
+        if (rtcGetDataChannelLabel(dc, buffer, 256) >= 0)
+                printf("DataChannel %s: Received with label \"%s\"\n", "answerer", buffer);
 
 
 }
 int all_space(const char *str) {
-    while (*str) {
-        if (!isspace(*str++)) {
-            return 0;
+        while (*str) {
+                if (!isspace(*str++)) {
+                        return 0;
+                }
         }
-    }
-    return 1;
+        return 1;
 }
 
 char* state_print(rtcState state) {
-	char *str = NULL;
-	switch (state) {
-		case RTC_NEW:
-			str = "RTC_NEW";
-			break;
-		case RTC_CONNECTING:
-			str = "RTC_CONNECTING";
-			break;
-		case RTC_CONNECTED:
-			str = "RTC_CONNECTED";
-			break;
-		case RTC_DISCONNECTED:
-			str = "RTC_DISCONNECTED";
-			break;
-		case RTC_FAILED:
-			str = "RTC_FAILED";
-			break;
-		case RTC_CLOSED:
-			str = "RTC_CLOSED";
-			break;
-		default:
-			break;
-		}
-
-		return str;
+        char *str = NULL;
+        switch (state) {
+        case RTC_NEW:
+                str = "RTC_NEW";
+                break;
+        case RTC_CONNECTING:
+                str = "RTC_CONNECTING";
+                break;
+        case RTC_CONNECTED:
+                str = "RTC_CONNECTED";
+                break;
+        case RTC_DISCONNECTED:
+                str = "RTC_DISCONNECTED";
+                break;
+        case RTC_FAILED:
+                str = "RTC_FAILED";
+                break;
+        case RTC_CLOSED:
+                str = "RTC_CLOSED";
+                break;
+        default:
+                break;
+        }
+
+        return str;
 
 }
 
 char* rtcGatheringState_print(rtcState state) {
-	char* str = NULL;
-	switch (state) {
-		case RTC_GATHERING_NEW:
-			str = "RTC_GATHERING_NEW";
-			break;
-		case RTC_GATHERING_INPROGRESS:
-			str = "RTC_GATHERING_INPROGRESS";
-			break;
-		case RTC_GATHERING_COMPLETE:
-			str = "RTC_GATHERING_COMPLETE";
-			break;
-		default:
-			break;
-		}
-
-		return str;
+        char* str = NULL;
+        switch (state) {
+        case RTC_GATHERING_NEW:
+                str = "RTC_GATHERING_NEW";
+                break;
+        case RTC_GATHERING_INPROGRESS:
+                str = "RTC_GATHERING_INPROGRESS";
+                break;
+        case RTC_GATHERING_COMPLETE:
+                str = "RTC_GATHERING_COMPLETE";
+                break;
+        default:
+                break;
+        }
+
+        return str;
 
 }