641 lines
22 KiB
C++
641 lines
22 KiB
C++
//
|
|
// ZoneMinder Event Class Implementation, $Date$, $Revision$
|
|
// Copyright (C) 2001-2008 Philip Coombes
|
|
//
|
|
// This program is free software; you can redistribute it and/or
|
|
// modify it under the terms of the GNU General Public License
|
|
// as published by the Free Software Foundation; either version 2
|
|
// of the License, or (at your option) any later version.
|
|
//
|
|
// This program is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU General Public License
|
|
// along with this program; if not, write to the Free Software
|
|
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
|
|
//
|
|
|
|
#include <fcntl.h>
|
|
#include <sys/socket.h>
|
|
#include <arpa/inet.h>
|
|
#include <sys/un.h>
|
|
#include <sys/uio.h>
|
|
#include <sys/ipc.h>
|
|
#include <sys/msg.h>
|
|
#include <getopt.h>
|
|
#include <arpa/inet.h>
|
|
#include <glob.h>
|
|
#include <cinttypes>
|
|
|
|
#include "zm.h"
|
|
#include "zm_db.h"
|
|
#include "zm_time.h"
|
|
#include "zm_signal.h"
|
|
#include "zm_event.h"
|
|
#include "zm_monitor.h"
|
|
|
|
//#define USE_PREPARED_SQL 1
|
|
|
|
const char * Event::frame_type_names[3] = { "Normal", "Bulk", "Alarm" };
|
|
|
|
int Event::pre_alarm_count = 0;
|
|
|
|
Event::PreAlarmData Event::pre_alarm_data[MAX_PRE_ALARM_FRAMES] = { { 0 } };
|
|
|
|
Event::Event(
|
|
Monitor *p_monitor,
|
|
struct timeval p_start_time,
|
|
const std::string &p_cause,
|
|
const StringSetMap &p_noteSetMap,
|
|
bool p_videoEvent ) :
|
|
monitor(p_monitor),
|
|
start_time(p_start_time),
|
|
cause(p_cause),
|
|
noteSetMap(p_noteSetMap),
|
|
videoEvent(p_videoEvent),
|
|
videowriter(NULL)
|
|
{
|
|
|
|
std::string notes;
|
|
createNotes(notes);
|
|
|
|
struct timeval now;
|
|
gettimeofday(&now, 0);
|
|
|
|
bool untimedEvent = false;
|
|
if ( !start_time.tv_sec ) {
|
|
untimedEvent = true;
|
|
start_time = now;
|
|
} else if ( start_time.tv_sec > now.tv_sec ) {
|
|
Error(
|
|
"StartTime in the future %u.%u > %u.%u",
|
|
start_time.tv_sec, start_time.tv_usec, now.tv_sec, now.tv_usec
|
|
);
|
|
start_time = now;
|
|
}
|
|
|
|
Storage * storage = monitor->getStorage();
|
|
scheme = storage->Scheme();
|
|
|
|
unsigned int state_id = 0;
|
|
zmDbRow dbrow;
|
|
if ( dbrow.fetch("SELECT Id FROM States WHERE IsActive=1") ) {
|
|
state_id = atoi(dbrow[0]);
|
|
}
|
|
|
|
char sql[ZM_SQL_MED_BUFSIZ];
|
|
struct tm *stime = localtime(&start_time.tv_sec);
|
|
snprintf( sql, sizeof(sql), "INSERT INTO Events ( MonitorId, StorageId, Name, StartTime, Width, Height, Cause, Notes, StateId, Orientation, Videoed, DefaultVideo, SaveJPEGs, Scheme ) values ( %d, %d, 'New Event', from_unixtime( %ld ), %d, %d, '%s', '%s', %d, %d, %d, '', %d, '%s' )",
|
|
monitor->Id(),
|
|
storage->Id(),
|
|
start_time.tv_sec,
|
|
monitor->Width(),
|
|
monitor->Height(),
|
|
cause.c_str(),
|
|
notes.c_str(),
|
|
state_id,
|
|
monitor->getOrientation(),
|
|
videoEvent,
|
|
monitor->GetOptSaveJPEGs(),
|
|
storage->SchemeString().c_str()
|
|
);
|
|
db_mutex.lock();
|
|
if ( mysql_query(&dbconn, sql) ) {
|
|
Error("Can't insert event: %s. sql was (%s)", mysql_error(&dbconn), sql);
|
|
db_mutex.unlock();
|
|
return;
|
|
}
|
|
id = mysql_insert_id(&dbconn);
|
|
db_mutex.unlock();
|
|
if ( untimedEvent ) {
|
|
Warning("Event %d has zero time, setting to current", id);
|
|
}
|
|
end_time.tv_sec = 0;
|
|
frames = 0;
|
|
alarm_frames = 0;
|
|
tot_score = 0;
|
|
max_score = 0;
|
|
|
|
char id_file[PATH_MAX];
|
|
|
|
char *path_ptr = path;
|
|
path_ptr += snprintf(path_ptr, sizeof(path), "%s/%d", storage->Path(), monitor->Id());
|
|
// Try to make the Monitor Dir. Normally this would exist, but in odd cases might not.
|
|
if ( mkdir(path, 0755) ) {
|
|
if ( errno != EEXIST )
|
|
Error("Can't mkdir %s: %s", path, strerror(errno));
|
|
}
|
|
|
|
if ( storage->Scheme() == Storage::DEEP ) {
|
|
|
|
int dt_parts[6];
|
|
dt_parts[0] = stime->tm_year-100;
|
|
dt_parts[1] = stime->tm_mon+1;
|
|
dt_parts[2] = stime->tm_mday;
|
|
dt_parts[3] = stime->tm_hour;
|
|
dt_parts[4] = stime->tm_min;
|
|
dt_parts[5] = stime->tm_sec;
|
|
|
|
char date_path[PATH_MAX] = "";
|
|
char time_path[PATH_MAX] = "";
|
|
char *time_path_ptr = time_path;
|
|
for ( unsigned int i = 0; i < sizeof(dt_parts)/sizeof(*dt_parts); i++ ) {
|
|
path_ptr += snprintf(path_ptr, sizeof(path)-(path_ptr-path), "/%02d", dt_parts[i]);
|
|
|
|
errno = 0;
|
|
if ( mkdir(path, 0755) ) {
|
|
// FIXME This should not be fatal. Should probably move to a different storage area.
|
|
if ( errno != EEXIST )
|
|
Error("Can't mkdir %s: %s", path, strerror(errno));
|
|
}
|
|
if ( i == 2 )
|
|
strncpy(date_path, path, sizeof(date_path));
|
|
else if ( i >= 3 )
|
|
time_path_ptr += snprintf(time_path_ptr, sizeof(time_path)-(time_path_ptr-time_path), "%s%02d", i>3?"/":"", dt_parts[i]);
|
|
}
|
|
// Create event id symlink
|
|
snprintf(id_file, sizeof(id_file), "%s/.%" PRIu64, date_path, id);
|
|
if ( symlink(time_path, id_file) < 0 )
|
|
Error("Can't symlink %s -> %s: %s", id_file, path, strerror(errno));
|
|
} else if ( storage->Scheme() == Storage::MEDIUM ) {
|
|
path_ptr += snprintf(
|
|
path_ptr, sizeof(path), "/%04d-%02d-%02d",
|
|
stime->tm_year+1900, stime->tm_mon+1, stime->tm_mday
|
|
);
|
|
if ( mkdir(path, 0755) ) {
|
|
if ( errno != EEXIST )
|
|
Error("Can't mkdir %s: %s", path, strerror(errno));
|
|
}
|
|
path_ptr += snprintf(path_ptr, sizeof(path), "/%" PRIu64, id);
|
|
if ( mkdir(path, 0755) ) {
|
|
if ( errno != EEXIST )
|
|
Error("Can't mkdir %s: %s", path, strerror(errno));
|
|
}
|
|
} else {
|
|
path_ptr += snprintf(path, sizeof(path), "/%" PRIu64, id);
|
|
if ( mkdir(path, 0755) ) {
|
|
if ( errno != EEXIST )
|
|
Error("Can't mkdir %s: %s", path, strerror(errno));
|
|
}
|
|
|
|
// Create empty id tag file
|
|
snprintf(id_file, sizeof(id_file), "%s/.%" PRIu64, path, id);
|
|
if ( FILE *id_fp = fopen(id_file, "w") )
|
|
fclose(id_fp);
|
|
else
|
|
Error("Can't fopen %s: %s", id_file, strerror(errno));
|
|
} // deep storage or not
|
|
|
|
last_db_frame = 0;
|
|
|
|
video_name[0] = 0;
|
|
|
|
/* Save as video */
|
|
|
|
if ( monitor->GetOptVideoWriter() != 0 ) {
|
|
snprintf(video_name, sizeof(video_name), "%" PRIu64 "-%s", id, "video.mp4");
|
|
snprintf(video_file, sizeof(video_file), staticConfig.video_file_format, path, video_name);
|
|
Debug(1,"Writing video file to %s", video_file );
|
|
|
|
/* X264 MP4 video writer */
|
|
if ( monitor->GetOptVideoWriter() == Monitor::X264ENCODE ) {
|
|
#if ZM_HAVE_VIDEOWRITER_X264MP4
|
|
videowriter = new X264MP4Writer(video_file, monitor->Width(), monitor->Height(), monitor->Colours(), monitor->SubpixelOrder(), monitor->GetOptEncoderParams());
|
|
#else
|
|
Error("ZoneMinder was not compiled with the X264 MP4 video writer, check dependencies (x264 and mp4v2)");
|
|
#endif
|
|
}
|
|
|
|
if ( videowriter != NULL ) {
|
|
/* Open the video stream */
|
|
int nRet = videowriter->Open();
|
|
if ( nRet != 0 ) {
|
|
Error("Failed opening video stream");
|
|
delete videowriter;
|
|
videowriter = NULL;
|
|
}
|
|
}
|
|
} else {
|
|
/* No video object */
|
|
videowriter = NULL;
|
|
}
|
|
|
|
} // Event::Event( Monitor *p_monitor, struct timeval p_start_time, const std::string &p_cause, const StringSetMap &p_noteSetMap, bool p_videoEvent )
|
|
|
|
Event::~Event() {
|
|
|
|
// We close the videowriter first, because if we finish the event, we might try to view the file, but we aren't done writing it yet.
|
|
|
|
/* Close the video file */
|
|
if ( videowriter != NULL ) {
|
|
int nRet = videowriter->Close();
|
|
if ( nRet != 0 ) {
|
|
Error("Failed closing video stream");
|
|
}
|
|
delete videowriter;
|
|
videowriter = NULL;
|
|
}
|
|
|
|
// Should not be static because we are multi-threaded
|
|
char sql[ZM_SQL_MED_BUFSIZ];
|
|
struct DeltaTimeval delta_time;
|
|
DELTA_TIMEVAL(delta_time, end_time, start_time, DT_PREC_2);
|
|
Debug(2, "start_time:%d.%d end_time%d.%d", start_time.tv_sec, start_time.tv_usec, end_time.tv_sec, end_time.tv_usec);
|
|
|
|
if ( frames > last_db_frame ) {
|
|
Debug(1, "Adding closing frame %d to DB", frames);
|
|
snprintf(sql, sizeof(sql),
|
|
"INSERT INTO Frames ( EventId, FrameId, TimeStamp, Delta ) VALUES ( %" PRIu64 ", %d, from_unixtime( %ld ), %s%ld.%02ld )",
|
|
id, frames, end_time.tv_sec, delta_time.positive?"":"-", delta_time.sec, delta_time.fsec);
|
|
db_mutex.lock();
|
|
if ( mysql_query(&dbconn, sql) ) {
|
|
Error("Can't insert frame: %s", mysql_error(&dbconn));
|
|
} else {
|
|
Debug(1,"Success writing last frame");
|
|
}
|
|
db_mutex.unlock();
|
|
}
|
|
|
|
snprintf(sql, sizeof(sql),
|
|
"UPDATE Events SET Name='%s %" PRIu64 "', EndTime = from_unixtime( %ld ), Length = %s%ld.%02ld, Frames = %d, AlarmFrames = %d, TotScore = %d, AvgScore = %d, MaxScore = %d, DefaultVideo = '%s' WHERE Id = %" PRIu64,
|
|
monitor->EventPrefix(), id, end_time.tv_sec, delta_time.positive?"":"-", delta_time.sec, delta_time.fsec, frames, alarm_frames, tot_score, (int)(alarm_frames?(tot_score/alarm_frames):0), max_score, video_name, id );
|
|
db_mutex.lock();
|
|
while ( mysql_query(&dbconn, sql) && !zm_terminate ) {
|
|
Error("Can't update event: %s reason: %s", sql, mysql_error(&dbconn));
|
|
db_mutex.unlock();
|
|
sleep(1);
|
|
db_mutex.lock();
|
|
}
|
|
db_mutex.unlock();
|
|
|
|
} // Event::~Event()
|
|
|
|
void Event::createNotes(std::string ¬es) {
|
|
notes.clear();
|
|
for ( StringSetMap::const_iterator mapIter = noteSetMap.begin(); mapIter != noteSetMap.end(); ++mapIter ) {
|
|
notes += mapIter->first;
|
|
notes += ": ";
|
|
const StringSet &stringSet = mapIter->second;
|
|
for ( StringSet::const_iterator setIter = stringSet.begin(); setIter != stringSet.end(); ++setIter ) {
|
|
if ( setIter != stringSet.begin() )
|
|
notes += ", ";
|
|
notes += *setIter;
|
|
}
|
|
}
|
|
}
|
|
|
|
bool Event::WriteFrameImage(Image *image, struct timeval timestamp, const char *event_file, bool alarm_frame) {
|
|
|
|
int thisquality = ( alarm_frame && (config.jpeg_alarm_file_quality > config.jpeg_file_quality) ) ? config.jpeg_alarm_file_quality : 0 ; // quality to use, zero is default
|
|
bool rc;
|
|
Debug(3, "Writing image to %s", event_file);
|
|
|
|
if ( !config.timestamp_on_capture ) {
|
|
// stash the image we plan to use in another pointer regardless if timestamped.
|
|
Image *ts_image = new Image(*image);
|
|
monitor->TimestampImage(ts_image, ×tamp);
|
|
rc = ts_image->WriteJpeg(event_file, thisquality, (monitor->Exif() ? timestamp : (timeval){0,0})); // exif is only timestamp at present this switches on or off for write
|
|
delete(ts_image);
|
|
} else {
|
|
rc = image->WriteJpeg(event_file, thisquality, (monitor->Exif() ? timestamp : (timeval){0,0})); // exif is only timestamp at present this switches on or off for write
|
|
}
|
|
|
|
return rc;
|
|
}
|
|
|
|
bool Event::WriteFrameVideo( const Image *image, const struct timeval timestamp, VideoWriter* videow ) {
|
|
const Image* frameimg = image;
|
|
Image ts_image;
|
|
|
|
/* Checking for invalid parameters */
|
|
if ( videow == NULL ) {
|
|
Error("NULL Video object");
|
|
return false;
|
|
}
|
|
|
|
/* If the image does not contain a timestamp, add the timestamp */
|
|
if ( !config.timestamp_on_capture ) {
|
|
ts_image = *image;
|
|
monitor->TimestampImage( &ts_image, ×tamp );
|
|
frameimg = &ts_image;
|
|
}
|
|
|
|
/* Calculate delta time */
|
|
struct DeltaTimeval delta_time3;
|
|
DELTA_TIMEVAL( delta_time3, timestamp, start_time, DT_PREC_3 );
|
|
unsigned int timeMS = (delta_time3.sec * delta_time3.prec) + delta_time3.fsec;
|
|
|
|
/* Encode and write the frame */
|
|
if ( videowriter->Encode(frameimg, timeMS) != 0 ) {
|
|
Error("Failed encoding video frame");
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
void Event::updateNotes( const StringSetMap &newNoteSetMap ) {
|
|
bool update = false;
|
|
|
|
//Info( "Checking notes, %d <> %d", noteSetMap.size(), newNoteSetMap.size() );
|
|
if ( newNoteSetMap.size() > 0 ) {
|
|
if ( noteSetMap.size() == 0 ) {
|
|
noteSetMap = newNoteSetMap;
|
|
update = true;
|
|
} else {
|
|
for ( StringSetMap::const_iterator newNoteSetMapIter = newNoteSetMap.begin(); newNoteSetMapIter != newNoteSetMap.end(); ++newNoteSetMapIter ) {
|
|
const std::string &newNoteGroup = newNoteSetMapIter->first;
|
|
const StringSet &newNoteSet = newNoteSetMapIter->second;
|
|
//Info( "Got %d new strings", newNoteSet.size() );
|
|
if ( newNoteSet.size() > 0 ) {
|
|
StringSetMap::iterator noteSetMapIter = noteSetMap.find( newNoteGroup );
|
|
if ( noteSetMapIter == noteSetMap.end() ) {
|
|
//Info( "Can't find note group %s, copying %d strings", newNoteGroup.c_str(), newNoteSet.size() );
|
|
noteSetMap.insert( StringSetMap::value_type( newNoteGroup, newNoteSet ) );
|
|
update = true;
|
|
} else {
|
|
StringSet ¬eSet = noteSetMapIter->second;
|
|
//Info( "Found note group %s, got %d strings", newNoteGroup.c_str(), newNoteSet.size() );
|
|
for ( StringSet::const_iterator newNoteSetIter = newNoteSet.begin(); newNoteSetIter != newNoteSet.end(); ++newNoteSetIter ) {
|
|
const std::string &newNote = *newNoteSetIter;
|
|
StringSet::iterator noteSetIter = noteSet.find( newNote );
|
|
if ( noteSetIter == noteSet.end() ) {
|
|
noteSet.insert( newNote );
|
|
update = true;
|
|
}
|
|
} // end for
|
|
} // end if ( noteSetMap.size() == 0
|
|
} // end if newNoteSetupMap.size() > 0
|
|
} // end foreach newNoteSetMap
|
|
} // end if have old notes
|
|
} // end if have new notes
|
|
|
|
if ( update ) {
|
|
std::string notes;
|
|
createNotes( notes );
|
|
|
|
Debug( 2, "Updating notes for event %d, '%s'", id, notes.c_str() );
|
|
static char sql[ZM_SQL_MED_BUFSIZ];
|
|
#if USE_PREPARED_SQL
|
|
static MYSQL_STMT *stmt = 0;
|
|
|
|
char notesStr[ZM_SQL_MED_BUFSIZ] = "";
|
|
unsigned long notesLen = 0;
|
|
|
|
if ( !stmt ) {
|
|
const char *sql = "update Events set Notes = ? where Id = ?";
|
|
|
|
stmt = mysql_stmt_init( &dbconn );
|
|
if ( mysql_stmt_prepare( stmt, sql, strlen(sql) ) ) {
|
|
Fatal( "Unable to prepare sql '%s': %s", sql, mysql_stmt_error(stmt) );
|
|
}
|
|
|
|
/* Get the parameter count from the statement */
|
|
if ( mysql_stmt_param_count( stmt ) != 2 ) {
|
|
Fatal( "Unexpected parameter count %ld in sql '%s'", mysql_stmt_param_count( stmt ), sql );
|
|
}
|
|
|
|
MYSQL_BIND bind[2];
|
|
memset(bind, 0, sizeof(bind));
|
|
|
|
/* STRING PARAM */
|
|
bind[0].buffer_type = MYSQL_TYPE_STRING;
|
|
bind[0].buffer = (char *)notesStr;
|
|
bind[0].buffer_length = sizeof(notesStr);
|
|
bind[0].is_null = 0;
|
|
bind[0].length = ¬esLen;
|
|
|
|
bind[1].buffer_type= MYSQL_TYPE_LONG;
|
|
bind[1].buffer= (char *)&id;
|
|
bind[1].is_null= 0;
|
|
bind[1].length= 0;
|
|
|
|
/* Bind the buffers */
|
|
if ( mysql_stmt_bind_param( stmt, bind ) ) {
|
|
Fatal( "Unable to bind sql '%s': %s", sql, mysql_stmt_error(stmt) );
|
|
}
|
|
}
|
|
|
|
strncpy( notesStr, notes.c_str(), sizeof(notesStr) );
|
|
|
|
if ( mysql_stmt_execute( stmt ) ) {
|
|
Fatal( "Unable to execute sql '%s': %s", sql, mysql_stmt_error(stmt) );
|
|
}
|
|
#else
|
|
static char escapedNotes[ZM_SQL_MED_BUFSIZ];
|
|
|
|
mysql_real_escape_string(&dbconn, escapedNotes, notes.c_str(), notes.length());
|
|
|
|
snprintf(sql, sizeof(sql), "UPDATE Events SET Notes = '%s' WHERE Id = %" PRIu64, escapedNotes, id);
|
|
db_mutex.lock();
|
|
if ( mysql_query(&dbconn, sql) ) {
|
|
Error("Can't insert event: %s", mysql_error(&dbconn));
|
|
}
|
|
db_mutex.unlock();
|
|
#endif
|
|
} // end if update
|
|
}
|
|
|
|
void Event::AddFrames( int n_frames, Image **images, struct timeval **timestamps ) {
|
|
for (int i = 0; i < n_frames; i += ZM_SQL_BATCH_SIZE) {
|
|
AddFramesInternal(n_frames, i, images, timestamps);
|
|
}
|
|
}
|
|
|
|
void Event::AddFramesInternal( int n_frames, int start_frame, Image **images, struct timeval **timestamps ) {
|
|
static char sql[ZM_SQL_LGE_BUFSIZ];
|
|
strncpy(sql, "insert into Frames ( EventId, FrameId, TimeStamp, Delta ) values ", sizeof(sql));
|
|
int frameCount = 0;
|
|
for ( int i = start_frame; i < n_frames && i - start_frame < ZM_SQL_BATCH_SIZE; i++ ) {
|
|
if ( timestamps[i]->tv_sec <= 0 ) {
|
|
Debug(1, "Not adding pre-capture frame %d, zero or less than 0 timestamp", i);
|
|
continue;
|
|
}
|
|
|
|
frames++;
|
|
|
|
static char event_file[PATH_MAX];
|
|
snprintf(event_file, sizeof(event_file), staticConfig.capture_file_format, path, frames);
|
|
if ( monitor->GetOptSaveJPEGs() & 1 ) {
|
|
Debug(1, "Writing pre-capture frame %d", frames);
|
|
WriteFrameImage(images[i], *(timestamps[i]), event_file);
|
|
} else {
|
|
//If this is the first frame, we should add a thumbnail to the event directory
|
|
// ICON: We are working through the pre-event frames so this snapshot won't
|
|
// neccessarily be of the motion. But some events are less than 10 frames,
|
|
// so I am changing this to 1, but we should overwrite it later with a better snapshot.
|
|
if ( frames == 1 ) {
|
|
char snapshot_file[PATH_MAX];
|
|
snprintf(snapshot_file, sizeof(snapshot_file), "%s/snapshot.jpg", path);
|
|
WriteFrameImage(images[i], *(timestamps[i]), snapshot_file);
|
|
}
|
|
}
|
|
if ( videowriter != NULL ) {
|
|
WriteFrameVideo(images[i], *(timestamps[i]), videowriter);
|
|
}
|
|
|
|
struct DeltaTimeval delta_time;
|
|
DELTA_TIMEVAL( delta_time, *(timestamps[i]), start_time, DT_PREC_2 );
|
|
// Delta is Decimal(8,2) so 6 integer digits and 2 decimal digits
|
|
if ( delta_time.sec > 999999 ) {
|
|
Warning("Invalid delta_time from_unixtime(%ld), %s%ld.%02ld",
|
|
timestamps[i]->tv_sec, delta_time.positive?"":"-", delta_time.sec, delta_time.fsec );
|
|
delta_time.sec = 0;
|
|
}
|
|
|
|
int sql_len = strlen(sql);
|
|
snprintf(sql+sql_len, sizeof(sql)-sql_len, "( %" PRIu64 ", %d, from_unixtime(%ld), %s%ld.%02ld ), ", id, frames, timestamps[i]->tv_sec, delta_time.positive?"":"-", delta_time.sec, delta_time.fsec);
|
|
|
|
frameCount++;
|
|
} // end foreach frame
|
|
|
|
if ( frameCount ) {
|
|
Debug(1, "Adding %d/%d frames to DB", frameCount, n_frames);
|
|
*(sql+strlen(sql)-2) = '\0';
|
|
db_mutex.lock();
|
|
if ( mysql_query( &dbconn, sql ) ) {
|
|
Error("Can't insert frames: %s, sql was (%s)", mysql_error(&dbconn), sql);
|
|
}
|
|
db_mutex.unlock();
|
|
last_db_frame = frames;
|
|
} else {
|
|
Debug(1, "No valid pre-capture frames to add");
|
|
}
|
|
}
|
|
|
|
void Event::AddFrame(Image *image, struct timeval timestamp, int score, Image *alarm_image) {
|
|
if ( !timestamp.tv_sec ) {
|
|
Debug(1, "Not adding new frame, zero timestamp");
|
|
return;
|
|
}
|
|
|
|
frames++;
|
|
|
|
static char event_file[PATH_MAX];
|
|
snprintf(event_file, sizeof(event_file), staticConfig.capture_file_format, path, frames);
|
|
|
|
if ( monitor->GetOptSaveJPEGs() & 1 ) {
|
|
Debug(1, "Writing capture frame %d to %s", frames, event_file);
|
|
if ( ! WriteFrameImage(image, timestamp, event_file) ) {
|
|
Error("Failed to write frame image");
|
|
}
|
|
} else {
|
|
//If this is the first frame, we should add a thumbnail to the event directory
|
|
if ( frames == 1 || score > (int)max_score ) {
|
|
char snapshot_file[PATH_MAX];
|
|
snprintf(snapshot_file, sizeof(snapshot_file), "%s/snapshot.jpg", path);
|
|
WriteFrameImage(image, timestamp, snapshot_file);
|
|
}
|
|
}
|
|
if ( videowriter != NULL ) {
|
|
Debug(3, "Writing video");
|
|
WriteFrameVideo(image, timestamp, videowriter);
|
|
}
|
|
|
|
struct DeltaTimeval delta_time;
|
|
DELTA_TIMEVAL(delta_time, timestamp, start_time, DT_PREC_2);
|
|
|
|
FrameType frame_type = score>0?ALARM:(score<0?BULK:NORMAL);
|
|
// < 0 means no motion detection is being done.
|
|
if ( score < 0 )
|
|
score = 0;
|
|
|
|
bool db_frame = ( frame_type != BULK ) || (!frames) || ((frames%config.bulk_frame_interval)==0) ;
|
|
if ( db_frame ) {
|
|
|
|
Debug( 1, "Adding frame %d of type \"%s\" to DB", frames, Event::frame_type_names[frame_type] );
|
|
static char sql[ZM_SQL_MED_BUFSIZ];
|
|
snprintf(sql, sizeof(sql),
|
|
"INSERT INTO Frames ( EventId, FrameId, Type, TimeStamp, Delta, Score )"
|
|
" VALUES ( %" PRIu64 ", %d, '%s', from_unixtime( %ld ), %s%ld.%02ld, %d )",
|
|
id, frames, frame_type_names[frame_type], timestamp.tv_sec, delta_time.positive?"":"-", delta_time.sec, delta_time.fsec, score);
|
|
db_mutex.lock();
|
|
if ( mysql_query(&dbconn, sql) ) {
|
|
Error("Can't insert frame: %s", mysql_error(&dbconn));
|
|
Error("SQL was %s", sql);
|
|
db_mutex.unlock();
|
|
return;
|
|
}
|
|
db_mutex.unlock();
|
|
last_db_frame = frames;
|
|
|
|
// We are writing a Bulk frame
|
|
if ( frame_type == BULK ) {
|
|
snprintf(sql, sizeof(sql),
|
|
"UPDATE Events SET Length = %s%ld.%02ld, Frames = %d, AlarmFrames = %d, TotScore = %d, AvgScore = %d, MaxScore = %d where Id = %" PRIu64,
|
|
( delta_time.positive?"":"-" ),
|
|
delta_time.sec, delta_time.fsec,
|
|
frames,
|
|
alarm_frames,
|
|
tot_score,
|
|
(int)(alarm_frames?(tot_score/alarm_frames):0),
|
|
max_score,
|
|
id
|
|
);
|
|
db_mutex.lock();
|
|
while ( mysql_query(&dbconn, sql) && !zm_terminate ) {
|
|
Error("Can't update event: %s", mysql_error(&dbconn));
|
|
db_mutex.unlock();
|
|
sleep(1);
|
|
db_mutex.lock();
|
|
}
|
|
db_mutex.unlock();
|
|
}
|
|
} // end if db_frame
|
|
|
|
end_time = timestamp;
|
|
|
|
// We are writing an Alarm frame
|
|
if ( frame_type == ALARM ) {
|
|
alarm_frames++;
|
|
|
|
tot_score += score;
|
|
if ( score > (int)max_score )
|
|
max_score = score;
|
|
|
|
if ( alarm_image ) {
|
|
if ( monitor->GetOptSaveJPEGs() & 2 ) {
|
|
snprintf(event_file, sizeof(event_file), staticConfig.analyse_file_format, path, frames);
|
|
Debug(1, "Writing analysis frame %d", frames);
|
|
if ( ! WriteFrameImage(alarm_image, timestamp, event_file, true) ) {
|
|
Error("Failed to write analysis frame image");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/* This makes viewing the diagnostic images impossible because it keeps deleting them
|
|
if ( config.record_diag_images ) {
|
|
char diag_glob[PATH_MAX] = "";
|
|
|
|
snprintf( diag_glob, sizeof(diag_glob), "%s/%d/diag-*.jpg", staticConfig.DIR_EVENTS.c_str(), monitor->Id() );
|
|
glob_t pglob;
|
|
int glob_status = glob( diag_glob, 0, 0, &pglob );
|
|
if ( glob_status != 0 ) {
|
|
if ( glob_status < 0 ) {
|
|
Error( "Can't glob '%s': %s", diag_glob, strerror(errno) );
|
|
} else {
|
|
Debug( 1, "Can't glob '%s': %d", diag_glob, glob_status );
|
|
}
|
|
} else {
|
|
char new_diag_path[PATH_MAX] = "";
|
|
for ( int i = 0; i < pglob.gl_pathc; i++ ) {
|
|
char *diag_path = pglob.gl_pathv[i];
|
|
|
|
char *diag_file = strstr( diag_path, "diag-" );
|
|
|
|
if ( diag_file ) {
|
|
snprintf( new_diag_path, sizeof(new_diag_path), general_file_format, path, frames, diag_file );
|
|
|
|
if ( rename( diag_path, new_diag_path ) < 0 ) {
|
|
Error( "Can't rename '%s' to '%s': %s", diag_path, new_diag_path, strerror(errno) );
|
|
}
|
|
}
|
|
}
|
|
}
|
|
globfree( &pglob );
|
|
}
|
|
*/
|
|
}
|