X-Git-Url: http://git.cinelerra-gg.org/git/?a=blobdiff_plain;f=cinelerra-5.0%2Fdb%2Fs.C;fp=cinelerra-5.0%2Fdb%2Fs.C;h=0000000000000000000000000000000000000000;hb=f9d0d999e813ae19965e07ae2f7da690b4e6fe45;hp=efe22a3ee039bc963173b2b688251dcb751d1501;hpb=15359610833cd03c44fe47f5d002e643103610ec;p=goodguy%2Fhistory.git diff --git a/cinelerra-5.0/db/s.C b/cinelerra-5.0/db/s.C deleted file mode 100644 index efe22a3e..00000000 --- a/cinelerra-5.0/db/s.C +++ /dev/null @@ -1,731 +0,0 @@ -#include "s.h" - - -int Video_frameLoc::ikey_Frame_weight:: -cmpr(char *a, char *b) -{ - ikey_Frame_weight *kp = (ikey_Frame_weight *)a; - int v = *(int*)b; - if( kp->v_id == v ) return 0; - Video_frameLoc vloc(kp->loc.entity); - if( vloc.FindId(v) ) - vloc.err_(Db::errCorrupt); - v = cmpr_double( kp->v_Frame_mean.addr(), kp->v_Frame_mean.size(), - vloc._Frame_mean(), vloc->v_Frame_mean.size()); - if( v != 0 ) return v; - if( kp->v_id >= 0 ) { - v = cmpr_int(&kp->v_id, sizeof(kp->v_id), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - } - return 0; -} - -int Video_frameLoc::rkey_Frame_weight:: -cmpr(char *a, char *b) -{ - rkey_Frame_weight *kp = (rkey_Frame_weight *)a; - Video_frameLoc &kloc = (Video_frameLoc&)kp->loc; - int v = kloc->id, b_id = *(int*)b; - if( v == b_id ) return 0; - Video_frameLoc vloc(kloc.entity); - if( vloc.FindId(b_id) ) - kloc.err_(Db::errCorrupt); - v = cmpr_double( kloc._Frame_mean(), kloc->v_Frame_mean.size(), - vloc._Frame_mean(), vloc->v_Frame_mean.size()); - if( v != 0 ) return v; - v = cmpr_int(kloc._id(), kloc._id_size(), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - return 0; -} - -int Video_frameLoc::ikey_Frame_center:: -cmpr(char *a, char *b) -{ - ikey_Frame_center *kp = (ikey_Frame_center *)a; - int v = *(int*)b; - if( kp->v_id == v ) return 0; - Video_frameLoc vloc(kp->loc.entity); - if( vloc.FindId(v) ) - vloc.err_(Db::errCorrupt); - v = cmpr_double( kp->v_Frame_moment.addr(), kp->v_Frame_moment.size(), - vloc._Frame_moment(), vloc->v_Frame_moment.size()); - if( v != 0 ) return v; - if( kp->v_id >= 0 ) { - v = cmpr_int(&kp->v_id, sizeof(kp->v_id), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - } - return 0; -} - -int Video_frameLoc::rkey_Frame_center:: -cmpr(char *a, char *b) -{ - rkey_Frame_center *kp = (rkey_Frame_center *)a; - Video_frameLoc &kloc = (Video_frameLoc&)kp->loc; - int v = kloc->id, b_id = *(int*)b; - if( v == b_id ) return 0; - Video_frameLoc vloc(kloc.entity); - if( vloc.FindId(b_id) ) - kloc.err_(Db::errCorrupt); - v = cmpr_double( kloc._Frame_moment(), kloc->v_Frame_moment.size(), - vloc._Frame_moment(), vloc->v_Frame_moment.size()); - if( v != 0 ) return v; - v = cmpr_int(kloc._id(), kloc._id_size(), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - return 0; -} - -int Video_frameLoc::Allocate() -{ - if_err( allocate() ); - if( !addr_wr() ) return err_(Db::errNoMemory); - v_init(); - return 0; -} - -int Video_frameLoc::Construct() -{ - if_err( insertProhibit() ); - if_err( construct() ); - int id = this->id(); - { rkey_Frame_weight rkey(*this); - if_err( entity->index("Frame_weight")->Insert(rkey,&id) ); } - { rkey_Frame_center rkey(*this); - if_err( entity->index("Frame_center")->Insert(rkey,&id) ); } - if_err( insertCascade() ); - return 0; -} - -int Video_frameLoc::Destruct() -{ - if_err( deleteProhibit() ); - { rkey_Frame_weight rkey(*this); - if_err( entity->index("Frame_weight")->Delete(rkey) ); } - { rkey_Frame_center rkey(*this); - if_err( entity->index("Frame_center")->Delete(rkey) ); } - if_err( destruct() ); - if_err( deleteCascade() ); - return 0; -} - -void Video_frameLoc::Deallocate() -{ - v_del(); - deallocate(); -} - - -int TimelineLoc::ikey_Timelines:: -cmpr(char *a, char *b) -{ - ikey_Timelines *kp = (ikey_Timelines *)a; - int v = *(int*)b; - if( kp->v_id == v ) return 0; - TimelineLoc vloc(kp->loc.entity); - if( vloc.FindId(v) ) - vloc.err_(Db::errCorrupt); - v = cmpr_uint( kp->v_Frame_id.addr(), kp->v_Frame_id.size(), - vloc._Frame_id(), vloc->v_Frame_id.size()); - if( v != 0 ) return v; - if( kp->v_id >= 0 ) { - v = cmpr_int(&kp->v_id, sizeof(kp->v_id), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - } - return 0; -} - -int TimelineLoc::rkey_Timelines:: -cmpr(char *a, char *b) -{ - rkey_Timelines *kp = (rkey_Timelines *)a; - TimelineLoc &kloc = (TimelineLoc&)kp->loc; - int v = kloc->id, b_id = *(int*)b; - if( v == b_id ) return 0; - TimelineLoc vloc(kloc.entity); - if( vloc.FindId(b_id) ) - kloc.err_(Db::errCorrupt); - v = cmpr_uint( kloc._Frame_id(), kloc->v_Frame_id.size(), - vloc._Frame_id(), vloc->v_Frame_id.size()); - if( v != 0 ) return v; - v = cmpr_int(kloc._id(), kloc._id_size(), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - return 0; -} - -int TimelineLoc::ikey_Sequences:: -cmpr(char *a, char *b) -{ - ikey_Sequences *kp = (ikey_Sequences *)a; - int v = *(int*)b; - TimelineLoc vloc(kp->loc.entity); - if( vloc.FindId(v) ) - vloc.err_(Db::errCorrupt); - v = cmpr_uint( kp->v_Clip_id.addr(), kp->v_Clip_id.size(), - vloc._Clip_id(), vloc->v_Clip_id.size()); - if( v != 0 ) return v; - v = cmpr_uint( kp->v_Sequence_no.addr(), kp->v_Sequence_no.size(), - vloc._Sequence_no(), vloc->v_Sequence_no.size()); - if( v != 0 ) return v; - return 0; -} - -int TimelineLoc::rkey_Sequences:: -cmpr(char *a, char *b) -{ - rkey_Sequences *kp = (rkey_Sequences *)a; - TimelineLoc &kloc = (TimelineLoc&)kp->loc; - int v = kloc->id, b_id = *(int*)b; - if( v == b_id ) return 0; - TimelineLoc vloc(kloc.entity); - if( vloc.FindId(b_id) ) - kloc.err_(Db::errCorrupt); - v = cmpr_uint( kloc._Clip_id(), kloc->v_Clip_id.size(), - vloc._Clip_id(), vloc->v_Clip_id.size()); - if( v != 0 ) return v; - v = cmpr_uint( kloc._Sequence_no(), kloc->v_Sequence_no.size(), - vloc._Sequence_no(), vloc->v_Sequence_no.size()); - if( v != 0 ) return v; - return 0; -} - -int TimelineLoc::Allocate() -{ - if_err( allocate() ); - if( !addr_wr() ) return err_(Db::errNoMemory); - return 0; -} - -int TimelineLoc::Construct() -{ - if_err( insertProhibit() ); - if_err( construct() ); - int id = this->id(); - { rkey_Timelines rkey(*this); - if_err( entity->index("Timelines")->Insert(rkey,&id) ); } - { rkey_Sequences rkey(*this); - if_err( entity->index("Sequences")->Insert(rkey,&id) ); } - if_err( insertCascade() ); - return 0; -} - -int TimelineLoc::Destruct() -{ - if_err( deleteProhibit() ); - { rkey_Timelines rkey(*this); - if_err( entity->index("Timelines")->Delete(rkey) ); } - { rkey_Sequences rkey(*this); - if_err( entity->index("Sequences")->Delete(rkey) ); } - if_err( destruct() ); - if_err( deleteCascade() ); - return 0; -} - -void TimelineLoc::Deallocate() -{ - deallocate(); -} - - -int Clip_setLoc::ikey_Clip_title:: -cmpr(char *a, char *b) -{ - ikey_Clip_title *kp = (ikey_Clip_title *)a; - int v = *(int*)b; - if( kp->v_id == v ) return 0; - Clip_setLoc vloc(kp->loc.entity); - if( vloc.FindId(v) ) - vloc.err_(Db::errCorrupt); - v = cmpr_char( kp->v_Title.addr(), kp->v_Title.size(), - vloc._Title(), vloc->v_Title.size()); - if( v != 0 ) return v; - if( kp->v_id >= 0 ) { - v = cmpr_int(&kp->v_id, sizeof(kp->v_id), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - } - return 0; -} - -int Clip_setLoc::rkey_Clip_title:: -cmpr(char *a, char *b) -{ - rkey_Clip_title *kp = (rkey_Clip_title *)a; - Clip_setLoc &kloc = (Clip_setLoc&)kp->loc; - int v = kloc->id, b_id = *(int*)b; - if( v == b_id ) return 0; - Clip_setLoc vloc(kloc.entity); - if( vloc.FindId(b_id) ) - kloc.err_(Db::errCorrupt); - v = cmpr_char( kloc._Title(), kloc->v_Title.size(), - vloc._Title(), vloc->v_Title.size()); - if( v != 0 ) return v; - v = cmpr_int(kloc._id(), kloc._id_size(), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - return 0; -} - -int Clip_setLoc::ikey_Clip_system_time:: -cmpr(char *a, char *b) -{ - ikey_Clip_system_time *kp = (ikey_Clip_system_time *)a; - int v = *(int*)b; - if( kp->v_id == v ) return 0; - Clip_setLoc vloc(kp->loc.entity); - if( vloc.FindId(v) ) - vloc.err_(Db::errCorrupt); - v = cmpr_long( kp->v_System_time.addr(), kp->v_System_time.size(), - vloc._System_time(), vloc->v_System_time.size()); - if( v != 0 ) return v; - if( kp->v_id >= 0 ) { - v = cmpr_int(&kp->v_id, sizeof(kp->v_id), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - } - return 0; -} - -int Clip_setLoc::rkey_Clip_system_time:: -cmpr(char *a, char *b) -{ - rkey_Clip_system_time *kp = (rkey_Clip_system_time *)a; - Clip_setLoc &kloc = (Clip_setLoc&)kp->loc; - int v = kloc->id, b_id = *(int*)b; - if( v == b_id ) return 0; - Clip_setLoc vloc(kloc.entity); - if( vloc.FindId(b_id) ) - kloc.err_(Db::errCorrupt); - v = cmpr_long( kloc._System_time(), kloc->v_System_time.size(), - vloc._System_time(), vloc->v_System_time.size()); - if( v != 0 ) return v; - v = cmpr_int(kloc._id(), kloc._id_size(), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - return 0; -} - -int Clip_setLoc::ikey_Clip_creation_time:: -cmpr(char *a, char *b) -{ - ikey_Clip_creation_time *kp = (ikey_Clip_creation_time *)a; - int v = *(int*)b; - if( kp->v_id == v ) return 0; - Clip_setLoc vloc(kp->loc.entity); - if( vloc.FindId(v) ) - vloc.err_(Db::errCorrupt); - v = cmpr_long( kp->v_Creation_time.addr(), kp->v_Creation_time.size(), - vloc._Creation_time(), vloc->v_Creation_time.size()); - if( v != 0 ) return v; - if( kp->v_id >= 0 ) { - v = cmpr_int(&kp->v_id, sizeof(kp->v_id), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - } - return 0; -} - -int Clip_setLoc::rkey_Clip_creation_time:: -cmpr(char *a, char *b) -{ - rkey_Clip_creation_time *kp = (rkey_Clip_creation_time *)a; - Clip_setLoc &kloc = (Clip_setLoc&)kp->loc; - int v = kloc->id, b_id = *(int*)b; - if( v == b_id ) return 0; - Clip_setLoc vloc(kloc.entity); - if( vloc.FindId(b_id) ) - kloc.err_(Db::errCorrupt); - v = cmpr_long( kloc._Creation_time(), kloc->v_Creation_time.size(), - vloc._Creation_time(), vloc->v_Creation_time.size()); - if( v != 0 ) return v; - v = cmpr_int(kloc._id(), kloc._id_size(), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - return 0; -} - -int Clip_setLoc::ikey_Clip_path_pos:: -cmpr(char *a, char *b) -{ - ikey_Clip_path_pos *kp = (ikey_Clip_path_pos *)a; - int v = *(int*)b; - if( kp->v_id == v ) return 0; - Clip_setLoc vloc(kp->loc.entity); - if( vloc.FindId(v) ) - vloc.err_(Db::errCorrupt); - v = cmpr_char( kp->v_Asset_path.addr(), kp->v_Asset_path.size(), - vloc._Asset_path(), vloc->v_Asset_path.size()); - if( v != 0 ) return v; - v = cmpr_double( kp->v_Position.addr(), kp->v_Position.size(), - vloc._Position(), vloc->v_Position.size()); - if( v != 0 ) return v; - if( kp->v_id >= 0 ) { - v = cmpr_int(&kp->v_id, sizeof(kp->v_id), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - } - return 0; -} - -int Clip_setLoc::rkey_Clip_path_pos:: -cmpr(char *a, char *b) -{ - rkey_Clip_path_pos *kp = (rkey_Clip_path_pos *)a; - Clip_setLoc &kloc = (Clip_setLoc&)kp->loc; - int v = kloc->id, b_id = *(int*)b; - if( v == b_id ) return 0; - Clip_setLoc vloc(kloc.entity); - if( vloc.FindId(b_id) ) - kloc.err_(Db::errCorrupt); - v = cmpr_char( kloc._Asset_path(), kloc->v_Asset_path.size(), - vloc._Asset_path(), vloc->v_Asset_path.size()); - if( v != 0 ) return v; - v = cmpr_double( kloc._Position(), kloc->v_Position.size(), - vloc._Position(), vloc->v_Position.size()); - if( v != 0 ) return v; - v = cmpr_int(kloc._id(), kloc._id_size(), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - return 0; -} - -int Clip_setLoc::Allocate() -{ - if_err( allocate() ); - if( !addr_wr() ) return err_(Db::errNoMemory); - v_init(); - Title((char *)"",0); - Asset_path((char *)"",0); - return 0; -} - -int Clip_setLoc::Construct() -{ - if_err( insertProhibit() ); - if_err( construct() ); - int id = this->id(); - { rkey_Clip_title rkey(*this); - if_err( entity->index("Clip_title")->Insert(rkey,&id) ); } - { rkey_Clip_system_time rkey(*this); - if_err( entity->index("Clip_system_time")->Insert(rkey,&id) ); } - { rkey_Clip_creation_time rkey(*this); - if_err( entity->index("Clip_creation_time")->Insert(rkey,&id) ); } - { rkey_Clip_path_pos rkey(*this); - if_err( entity->index("Clip_path_pos")->Insert(rkey,&id) ); } - if_err( insertCascade() ); - return 0; -} - -int Clip_setLoc::Destruct() -{ - if_err( deleteProhibit() ); - { rkey_Clip_title rkey(*this); - if_err( entity->index("Clip_title")->Delete(rkey) ); } - { rkey_Clip_system_time rkey(*this); - if_err( entity->index("Clip_system_time")->Delete(rkey) ); } - { rkey_Clip_creation_time rkey(*this); - if_err( entity->index("Clip_creation_time")->Delete(rkey) ); } - { rkey_Clip_path_pos rkey(*this); - if_err( entity->index("Clip_path_pos")->Delete(rkey) ); } - if_err( destruct() ); - if_err( deleteCascade() ); - return 0; -} - -void Clip_setLoc::Deallocate() -{ - v_del(); - deallocate(); -} - - -int Clip_viewsLoc::ikey_Clip_access:: -cmpr(char *a, char *b) -{ - ikey_Clip_access *kp = (ikey_Clip_access *)a; - int v = *(int*)b; - Clip_viewsLoc vloc(kp->loc.entity); - if( vloc.FindId(v) ) - vloc.err_(Db::errCorrupt); - v = cmpr_uint( kp->v_Access_clip_id.addr(), kp->v_Access_clip_id.size(), - vloc._Access_clip_id(), vloc->v_Access_clip_id.size()); - if( v != 0 ) return v; - return 0; -} - -int Clip_viewsLoc::rkey_Clip_access:: -cmpr(char *a, char *b) -{ - rkey_Clip_access *kp = (rkey_Clip_access *)a; - Clip_viewsLoc &kloc = (Clip_viewsLoc&)kp->loc; - int v = kloc->id, b_id = *(int*)b; - if( v == b_id ) return 0; - Clip_viewsLoc vloc(kloc.entity); - if( vloc.FindId(b_id) ) - kloc.err_(Db::errCorrupt); - v = cmpr_uint( kloc._Access_clip_id(), kloc->v_Access_clip_id.size(), - vloc._Access_clip_id(), vloc->v_Access_clip_id.size()); - if( v != 0 ) return v; - return 0; -} - -int Clip_viewsLoc::ikey_Last_view:: -cmpr(char *a, char *b) -{ - ikey_Last_view *kp = (ikey_Last_view *)a; - int v = *(int*)b; - if( kp->v_id == v ) return 0; - Clip_viewsLoc vloc(kp->loc.entity); - if( vloc.FindId(v) ) - vloc.err_(Db::errCorrupt); - v = cmpr_long( kp->v_Access_time.addr(), kp->v_Access_time.size(), - vloc._Access_time(), vloc->v_Access_time.size()); - if( v != 0 ) return v; - if( kp->v_id >= 0 ) { - v = cmpr_int(&kp->v_id, sizeof(kp->v_id), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - } - return 0; -} - -int Clip_viewsLoc::rkey_Last_view:: -cmpr(char *a, char *b) -{ - rkey_Last_view *kp = (rkey_Last_view *)a; - Clip_viewsLoc &kloc = (Clip_viewsLoc&)kp->loc; - int v = kloc->id, b_id = *(int*)b; - if( v == b_id ) return 0; - Clip_viewsLoc vloc(kloc.entity); - if( vloc.FindId(b_id) ) - kloc.err_(Db::errCorrupt); - v = cmpr_long( kloc._Access_time(), kloc->v_Access_time.size(), - vloc._Access_time(), vloc->v_Access_time.size()); - if( v != 0 ) return v; - v = cmpr_int(kloc._id(), kloc._id_size(), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - return 0; -} - -int Clip_viewsLoc::ikey_Total_views:: -cmpr(char *a, char *b) -{ - ikey_Total_views *kp = (ikey_Total_views *)a; - int v = *(int*)b; - if( kp->v_id == v ) return 0; - Clip_viewsLoc vloc(kp->loc.entity); - if( vloc.FindId(v) ) - vloc.err_(Db::errCorrupt); - v = cmpr_uint( kp->v_Access_count.addr(), kp->v_Access_count.size(), - vloc._Access_count(), vloc->v_Access_count.size()); - if( v != 0 ) return v; - v = cmpr_uint( kp->v_Access_clip_id.addr(), kp->v_Access_clip_id.size(), - vloc._Access_clip_id(), vloc->v_Access_clip_id.size()); - if( v != 0 ) return v; - if( kp->v_id >= 0 ) { - v = cmpr_int(&kp->v_id, sizeof(kp->v_id), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - } - return 0; -} - -int Clip_viewsLoc::rkey_Total_views:: -cmpr(char *a, char *b) -{ - rkey_Total_views *kp = (rkey_Total_views *)a; - Clip_viewsLoc &kloc = (Clip_viewsLoc&)kp->loc; - int v = kloc->id, b_id = *(int*)b; - if( v == b_id ) return 0; - Clip_viewsLoc vloc(kloc.entity); - if( vloc.FindId(b_id) ) - kloc.err_(Db::errCorrupt); - v = cmpr_uint( kloc._Access_count(), kloc->v_Access_count.size(), - vloc._Access_count(), vloc->v_Access_count.size()); - if( v != 0 ) return v; - v = cmpr_uint( kloc._Access_clip_id(), kloc->v_Access_clip_id.size(), - vloc._Access_clip_id(), vloc->v_Access_clip_id.size()); - if( v != 0 ) return v; - v = cmpr_int(kloc._id(), kloc._id_size(), - vloc._id(), vloc._id_size()); - if( v != 0 ) return v; - return 0; -} - -int Clip_viewsLoc::Allocate() -{ - if_err( allocate() ); - if( !addr_wr() ) return err_(Db::errNoMemory); - return 0; -} - -int Clip_viewsLoc::Construct() -{ - if_err( insertProhibit() ); - if_err( construct() ); - int id = this->id(); - { rkey_Clip_access rkey(*this); - if_err( entity->index("Clip_access")->Insert(rkey,&id) ); } - { rkey_Last_view rkey(*this); - if_err( entity->index("Last_view")->Insert(rkey,&id) ); } - { rkey_Total_views rkey(*this); - if_err( entity->index("Total_views")->Insert(rkey,&id) ); } - if_err( insertCascade() ); - return 0; -} - -int Clip_viewsLoc::Destruct() -{ - if_err( deleteProhibit() ); - { rkey_Clip_access rkey(*this); - if_err( entity->index("Clip_access")->Delete(rkey) ); } - { rkey_Last_view rkey(*this); - if_err( entity->index("Last_view")->Delete(rkey) ); } - { rkey_Total_views rkey(*this); - if_err( entity->index("Total_views")->Delete(rkey) ); } - if_err( destruct() ); - if_err( deleteCascade() ); - return 0; -} - -void Clip_viewsLoc::Deallocate() -{ - deallocate(); -} - - -int theDb:: -create(const char *dfn) -{ - dfd = ::open(dfn,O_RDWR+O_CREAT+O_TRUNC+no_atime,0666); - if( dfd < 0 ) { perror(dfn); return -1; } - int ret = db_create(); - close(); - return ret; -} - -int theDb:: -db_create() -{ - if_ret( Db::make(dfd) ); - if_ret( Video_frame.new_entity("Video_frame", sizeof(Video_frameObj)) ); - if_ret( Video_frame.add_kindex("Frame_weight") ); - if_ret( Video_frame.add_kindex("Frame_center") ); - - if_ret( Timeline.new_entity("Timeline", sizeof(TimelineObj)) ); - if_ret( Timeline.add_kindex("Timelines") ); - if_ret( Timeline.add_kindex("Sequences") ); - - if_ret( Clip_set.new_entity("Clip_set", sizeof(Clip_setObj)) ); - if_ret( Clip_set.add_kindex("Clip_title") ); - if_ret( Clip_set.add_kindex("Clip_system_time") ); - if_ret( Clip_set.add_kindex("Clip_creation_time") ); - if_ret( Clip_set.add_kindex("Clip_path_pos") ); - - if_ret( Clip_views.new_entity("Clip_views", sizeof(Clip_viewsObj)) ); - if_ret( Clip_views.add_kindex("Clip_access") ); - if_ret( Clip_views.add_kindex("Last_view") ); - if_ret( Clip_views.add_kindex("Total_views") ); - - if_ret( Db::commit(1) ); - return 0; -} - -theDb:: -theDb() - : dfd(-1), dkey(-1), no_atime(getuid()?0:O_NOATIME), objects(0), - Video_frame(this), video_frame(Video_frame), - Timeline(this), timeline(Timeline), - Clip_set(this), clip_set(Clip_set), - Clip_views(this), clip_views(Clip_views) -{ - objects = new ObjectList(objects, video_frame); - objects = new ObjectList(objects, timeline); - objects = new ObjectList(objects, clip_set); - objects = new ObjectList(objects, clip_views); - Video_frame.add_vref((vRef)&Video_frameObj::v_Frame_data); - Clip_set.add_vref((vRef)&Clip_setObj::v_Title); - Clip_set.add_vref((vRef)&Clip_setObj::v_Asset_path); - Clip_set.add_vref((vRef)&Clip_setObj::v_Weights); -} - -int theDb:: -open(const char *dfn, int key) -{ - dfd = ::open(dfn,O_RDWR+no_atime); - if( dfd < 0 ) { perror(dfn); return errNotFound; } - if( (dkey=key) >= 0 ) Db::use_shm(1); - int ret = Db::open(dfd, dkey); - if( !ret ) ret = db_open(); - if( ret ) close(); - return ret; -} - -int theDb:: -db_open() -{ - if_ret( Video_frame.get_entity("Video_frame") ); - if_ret( Video_frame.key_index("Frame_weight") ); - if_ret( Video_frame.key_index("Frame_center") ); - - if_ret( Timeline.get_entity("Timeline") ); - if_ret( Timeline.key_index("Timelines") ); - if_ret( Timeline.key_index("Sequences") ); - - if_ret( Clip_set.get_entity("Clip_set") ); - if_ret( Clip_set.key_index("Clip_title") ); - if_ret( Clip_set.key_index("Clip_system_time") ); - if_ret( Clip_set.key_index("Clip_creation_time") ); - if_ret( Clip_set.key_index("Clip_path_pos") ); - - if_ret( Clip_views.get_entity("Clip_views") ); - if_ret( Clip_views.key_index("Clip_access") ); - if_ret( Clip_views.key_index("Last_view") ); - if_ret( Clip_views.key_index("Total_views") ); - - if_ret( Db::start_transaction() ); - return 0; -} - -void theDb:: -close() -{ - Db::close(); - if( dfd >= 0 ) { ::close(dfd); dfd = -1; } -} - -int theDb:: -access(const char *dfn, int key, int rw) -{ - if( key < 0 ) return Db::errInvalid; - dfd = ::open(dfn,O_RDWR+no_atime); - if( dfd < 0 ) { perror(dfn); return Db::errNotFound; } - dkey = key; Db::use_shm(1); - int ret = Db::attach(dfd, dkey, rw); - if( !ret ) ret = db_access(); - else if( ret == errNotFound ) { - ret = Db::open(dfd, dkey); - if( !ret ) ret = db_open(); - if( !ret ) ret = Db::attach(rw); - } - if( ret ) close(); - return ret; -} - -int theDb:: -db_access() -{ - if_ret( Video_frame.get_entity("Video_frame") ); - if_ret( Timeline.get_entity("Timeline") ); - if_ret( Clip_set.get_entity("Clip_set") ); - if_ret( Clip_views.get_entity("Clip_views") ); - return 0; -} - -