summaryrefslogtreecommitdiff
path: root/src/Encoder.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/Encoder.cpp')
-rw-r--r--src/Encoder.cpp22
1 files changed, 12 insertions, 10 deletions
diff --git a/src/Encoder.cpp b/src/Encoder.cpp
index 3b59b07..d6f817f 100644
--- a/src/Encoder.cpp
+++ b/src/Encoder.cpp
@@ -14,7 +14,7 @@
#include <string.h>
#include <sys/ioctl.h>
-#include "Utils.h"
+#include "Util.h"
#include "Logger.h"
#include "Encoder.h"
@@ -50,7 +50,7 @@ Encoder::Encoder() throw(trap)
DEBUG("shm-info : fd [%d], name [%s], size [%d], data [%p]", mShmFd, mShmName.c_str(), mShmSize, mShmData);
DEBUG("sem-info : id [%p], name [%s]", mSemId, mSemName.c_str());
- std::vector<int> pidlist = find_process_by_name("transtreamproxy", 0);
+ std::vector<int> pidlist = Util::find_process_by_name("transtreamproxy", 0);
session_dump("before init.");
@@ -66,7 +66,7 @@ Encoder::Encoder() throw(trap)
Post();
int mypid = getpid();
- std::string ipaddr = get_host_addr();
+ std::string ipaddr = Util::host_addr();
if (session_already_exist(ipaddr) > 0) {
encoder_id = session_update(ipaddr, mypid);
}
@@ -92,7 +92,7 @@ Encoder::~Encoder()
bool Encoder::encoder_open()
{
- std::string path = "/dev/bcm_enc" + ultostr(encoder_id);
+ std::string path = "/dev/bcm_enc" + Util::ultostr(encoder_id);
fd = ::open(path.c_str(), O_RDWR, 0);
if (fd >= 0) {
state = ENCODER_STAT_OPENED;
@@ -141,12 +141,14 @@ int Encoder::get_fd()
void Encoder::session_dump(const char* aMessage)
{
- DUMMY(" >> %s", aMessage);
- DUMMY("-------- [ DUMP HOST INFO ] ---------");
- for (int i = 0; i < max_encodr_count; i++) {
- DUMMY("%d : ip [%s], pid [%d]", i, mShmData[i].ip, mShmData[i].pid);
+ if (Logger::instance()->get_level() >= Logger::INFO) {
+ DUMMY(" >> %s", aMessage);
+ DUMMY("-------- [ DUMP HOST INFO ] ---------");
+ for (int i = 0; i < max_encodr_count; i++) {
+ DUMMY("%d : ip [%s], pid [%d]", i, mShmData[i].ip, mShmData[i].pid);
+ }
+ DUMMY("-------------------------------------");
}
- DUMMY("-------------------------------------");
}
//----------------------------------------------------------------------
@@ -220,7 +222,7 @@ int Encoder::session_update(std::string aIpAddr, int aPid)
for (; i < max_encodr_count; i++) {
if (strcmp(mShmData[i].ip, aIpAddr.c_str()) == 0) {
result = true;
- kill_process(mShmData[i].pid);
+ Util::kill_process(mShmData[i].pid);
memset(mShmData[i].ip, 0, 16);
mShmData[i].pid = 0;
break;