#define __MSF_ERROR_H__
#include <stdio.h>
-#include<iostream>
-#include<string>
+#include <iostream>
+#include <string>
using namespace std;
#include <map>
#include <json-glib/json-glib.h>
#include <json-glib/json-parser.h>
-#include"SearchProvider.h"
+#include "SearchProvider.h"
using namespace std;
#include <string>
#include <vector>
-
using namespace std;
class Message
#define __MSF_SEARCH_H__
#include <list>
-#include"SearchProvider.h"
+#include "SearchProvider.h"
#include <list>
#include <pthread.h>
#include <string>
-#include"mDNSSearchProvider.h"
+#include "mDNSSearchProvider.h"
#define NUM_OF_THREADS 3
#define MDNS_THREAD_NUMBER 0
#ifndef __MSF_SEARCH_PROVIDER_H__
#define __MSF_SEARCH_PROVIDER_H__
-#include<iostream>
-#include<list>
-#include<string>
+#include <iostream>
+#include <list>
+#include <string>
#include <map>
//#include "Service.h"
#include <json-glib/json-glib.h>
#include <json-glib/json-parser.h>
-
using namespace std;
class Application;
using namespace std;
-#include"SearchProvider.h"
+#include "SearchProvider.h"
#include <nsd/dns-sd.h>
#include "Service.h"
#include "Result.h"
if (in_result_cb != NULL) {
if (((*in_result_cb) != NULL)) {
(*in_result_cb)->onStart(result);
- } else {
}
}
if (in_result_cb != NULL) {
if (((*in_result_cb) != NULL)) {
(*in_result_cb)->onStart(false);
- } else {
}
}
delete this;
if (in_result_cb != NULL) {
if (((*in_result_cb) != NULL)) {
(*in_result_cb)->onStop(result);
- } else {
}
}
if (in_result_cb != NULL) {
if (((*in_result_cb) != NULL)) {
(*in_result_cb)->onStop(false);
- } else {
}
}
delete this;
webapp = false;
install_listener = NULL;
install_result = false;
+ result = NULL;
+ startArgs = NULL;
}
Application::Application(Service *se, string Uri, string Id)
waitForOnReady = false;
install_listener = NULL;
install_result = false;
- setSecureSupport(se->IsSecureConnectionSupport());
+ if (se != NULL) {
+ setSecureSupport(se->IsSecureConnectionSupport());
+ }
}
Application::Application(Service *se, string Uri, string Id, map<string, string> startargs)
ApplicationInfo::ApplicationInfo()
{
+ running = false;
}
ApplicationInfo::ApplicationInfo(string iD, bool state, string Name, string Version)
pingTimeout = 5000000;
lastPingReceived = 0;
running = false;
+ longestRT = 0;
+ numPings = 0;
+ startTime = 0;
+ pingSent = 0;
+ average = 0;
}
Channel::Channel() {
lws_callback_on_writable(ch_p->wsi_mirror);
}
+ MSF_DBG("write_buf_count:%d", ch_p->write_buf_count);
if (ch_p->write_buf_count) {
if (ch_p->write_buf_last_sent_index == 999) {
ch_p->write_buf_last_sent_index = 1;
ch_p->onPublishListener->onPublished(false, ch_p->publish_user_data[ch_p->write_buf_last_sent_index]);
}
} else {
- MSF_DBG("Writing succeed\n");
+ MSF_DBG("Writing succeed : %d", n);
if (ch_p->onPublishListener) {
ch_p->onPublishListener->onPublished(true, ch_p->publish_user_data[ch_p->write_buf_last_sent_index]);
}
this_ptr->cl_payload[len - 2 - header_size] = 0;
this_ptr->cl_payload_size = len - 2 - header_size;
+/*
MSF_DBG("payload = %s",
&(this_ptr->cl_payload[0]));
-
+*/
this_ptr->connectionHandler->resetLastPingReceived();
if (this_ptr->eventType == CONNECT_EVENT) {
int l = 0;
int header_size = 0;
- int prepare_buf_size = LWS_SEND_BUFFER_PRE_PADDING + 4096 + LWS_SEND_BUFFER_POST_PADDING;
+ int prepare_buf_size = LWS_SEND_BUFFER_PRE_PADDING + payload_size + LWS_SEND_BUFFER_POST_PADDING + 128;
unsigned char *prepare_buf = new unsigned char[prepare_buf_size];
if (payload) {
id = string();
host = false ;
connectTime = 0;
+ m_channel = NULL;
}
void Client::create(Client &client)
Message::Message()
{
+ m_channel = NULL;
+ m_payload = NULL;
+ m_payload_size = 0;
}
Message::Message(const Message& m)