Home
last modified time | relevance | path

Searched refs:transID (Results 1 – 25 of 73) sorted by relevance

123

/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/
H A Dslavedbrmnode.cpp374 if (transID) in bulkSetHWM()
375 vbCommit(transID); in bulkSetHWM()
402 if (transID) in bulkSetHWMAndCP()
403 vbCommit(transID); in bulkSetHWMAndCP()
493 if (oldVerID == transID) in writeVBEntry()
495 else if (oldVerID > transID) in writeVBEntry()
556 if (oldVerID == transID) in bulkWriteVBEntry()
604 if (transID < 1) in beginVBCopy()
760 vss.commit(transID); in vbCommit()
780 if (transID < 1) in vbRollback()
[all …]
H A Dslavedbrmnode.h310 EXPORT int bulkSetHWM(const std::vector<BulkSetHWMArg>&, VER_t transID,
316 VER_t transID, bool firstNode) throw();
364 EXPORT int writeVBEntry(VER_t transID, LBID_t lbid, OID_t vbOID,
376 EXPORT int bulkWriteVBEntry(VER_t transID,
398 EXPORT int beginVBCopy(VER_t transID, uint16_t vbOID,
411 EXPORT int endVBCopy(VER_t transID, const LBIDRange_v& ranges)
419 EXPORT int vbCommit(VER_t transID) throw();
430 EXPORT int vbRollback(VER_t transID, const LBIDRange_v& lbidList,
442 EXPORT int vbRollback(VER_t transID, const std::vector<LBID_t>& lbidList,
H A Dslavecomm.cpp1105 VER_t transID; in do_bulkSetHWM() local
1146 VER_t transID; in do_bulkSetHWMAndCP() local
1726 VER_t transID; in do_writeVBEntry() local
1739 transID = tmp; in do_writeVBEntry()
1767 VER_t transID; in do_bulkWriteVBEntry() local
1780 transID = tmp; in do_bulkWriteVBEntry()
1810 VER_t transID; in do_beginVBCopy() local
1856 VER_t transID; in do_endVBCopy() local
1867 transID = tmp; in do_endVBCopy()
1895 VER_t transID; in do_vbRollback1() local
[all …]
H A Ddbrm.h441 EXPORT int bulkSetHWM(const std::vector<BulkSetHWMArg>&, VER_t transID = 0) DBRM_THROW;
454 VER_t transID) DBRM_THROW;
615 EXPORT int writeVBEntry(VER_t transID, LBID_t lbid, OID_t vbOID,
627 EXPORT int bulkWriteVBEntry(VER_t transID,
638 EXPORT int getUncommittedLBIDs(VER_t transID,
646 EXPORT int getDBRootsForRollback(VER_t transID, std::vector<uint16_t>* dbRootList)
675 EXPORT int beginVBCopy(VER_t transID, uint16_t dbRoot, const LBIDRange_v& ranges,
688 EXPORT int endVBCopy(VER_t transID, const LBIDRange_v& ranges)
696 EXPORT int vbCommit(VER_t transID) DBRM_THROW;
706 EXPORT int vbRollback(VER_t transID, const LBIDRange_v& lbidList)
[all …]
H A Ddbrm.cpp1586 command << (uint32_t) transID; in bulkSetHWM()
1620 command << (uint32_t) transID; in bulkSetHWMAndCP()
2204 TRACER_ADDINPUT(transID); in writeVBEntry()
2283 TRACER_ADDINPUT(transID); in getDBRootsForRollback()
2367 TRACER_ADDINPUT(transID); in getUncommittedLBIDs()
2403 TRACER_ADDINPUT(transID); in getUncommittedExtentLBIDs()
2490 TRACER_ADDINPUT(transID); in beginVBCopy()
2536 TRACER_ADDINPUT(transID); in endVBCopy()
2564 TRACER_ADDINPUT(transID); in vbCommit()
2595 TRACER_ADDINPUT(transID); in vbRollback()
[all …]
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/
H A Dslavedbrmnode.cpp374 if (transID) in bulkSetHWM()
375 vbCommit(transID); in bulkSetHWM()
402 if (transID) in bulkSetHWMAndCP()
403 vbCommit(transID); in bulkSetHWMAndCP()
493 if (oldVerID == transID) in writeVBEntry()
495 else if (oldVerID > transID) in writeVBEntry()
556 if (oldVerID == transID) in bulkWriteVBEntry()
604 if (transID < 1) in beginVBCopy()
760 vss.commit(transID); in vbCommit()
780 if (transID < 1) in vbRollback()
[all …]
H A Dslavedbrmnode.h310 EXPORT int bulkSetHWM(const std::vector<BulkSetHWMArg>&, VER_t transID,
316 VER_t transID, bool firstNode) throw();
364 EXPORT int writeVBEntry(VER_t transID, LBID_t lbid, OID_t vbOID,
376 EXPORT int bulkWriteVBEntry(VER_t transID,
398 EXPORT int beginVBCopy(VER_t transID, uint16_t vbOID,
411 EXPORT int endVBCopy(VER_t transID, const LBIDRange_v& ranges)
419 EXPORT int vbCommit(VER_t transID) throw();
430 EXPORT int vbRollback(VER_t transID, const LBIDRange_v& lbidList,
442 EXPORT int vbRollback(VER_t transID, const std::vector<LBID_t>& lbidList,
H A Dslavecomm.cpp1105 VER_t transID; in do_bulkSetHWM() local
1146 VER_t transID; in do_bulkSetHWMAndCP() local
1726 VER_t transID; in do_writeVBEntry() local
1739 transID = tmp; in do_writeVBEntry()
1767 VER_t transID; in do_bulkWriteVBEntry() local
1780 transID = tmp; in do_bulkWriteVBEntry()
1810 VER_t transID; in do_beginVBCopy() local
1856 VER_t transID; in do_endVBCopy() local
1867 transID = tmp; in do_endVBCopy()
1895 VER_t transID; in do_vbRollback1() local
[all …]
H A Ddbrm.h441 EXPORT int bulkSetHWM(const std::vector<BulkSetHWMArg>&, VER_t transID = 0) DBRM_THROW;
454 VER_t transID) DBRM_THROW;
615 EXPORT int writeVBEntry(VER_t transID, LBID_t lbid, OID_t vbOID,
627 EXPORT int bulkWriteVBEntry(VER_t transID,
638 EXPORT int getUncommittedLBIDs(VER_t transID,
646 EXPORT int getDBRootsForRollback(VER_t transID, std::vector<uint16_t>* dbRootList)
675 EXPORT int beginVBCopy(VER_t transID, uint16_t dbRoot, const LBIDRange_v& ranges,
688 EXPORT int endVBCopy(VER_t transID, const LBIDRange_v& ranges)
696 EXPORT int vbCommit(VER_t transID) DBRM_THROW;
706 EXPORT int vbRollback(VER_t transID, const LBIDRange_v& lbidList)
[all …]
H A Ddbrm.cpp1586 command << (uint32_t) transID; in bulkSetHWM()
1620 command << (uint32_t) transID; in bulkSetHWMAndCP()
2204 TRACER_ADDINPUT(transID); in writeVBEntry()
2283 TRACER_ADDINPUT(transID); in getDBRootsForRollback()
2367 TRACER_ADDINPUT(transID); in getUncommittedLBIDs()
2403 TRACER_ADDINPUT(transID); in getUncommittedExtentLBIDs()
2490 TRACER_ADDINPUT(transID); in beginVBCopy()
2536 TRACER_ADDINPUT(transID); in endVBCopy()
2564 TRACER_ADDINPUT(transID); in vbCommit()
2595 TRACER_ADDINPUT(transID); in vbRollback()
[all …]
/dports/multimedia/livego/livego-0.0.15/protocol/rtmp/core/
H A Dconn_client.go34 transID int member
50 transID: 1,
98 if id != connClient.transID {
160 log.Debugf("writeConnectMsg: connClient.transID=%d, event=%v", connClient.transID, event)
161 if err := connClient.writeMsg(cmdConnect, connClient.transID, event); err != nil {
168 connClient.transID++
171 log.Debugf("writeCreateStreamMsg: connClient.transID=%d", connClient.transID)
172 if err := connClient.writeMsg(cmdCreateStream, connClient.transID, nil); err != nil {
191 connClient.transID++
200 connClient.transID++
[all …]
/dports/net/syncthing/syncthing-1.18.1/syncthing/vendor/github.com/ccding/go-stun/stun/
H A Dpacket.go27 transID []byte // 4 bytes magic cookie + 12 bytes transaction id member
33 v.transID = make([]byte, 16)
34 binary.BigEndian.PutUint32(v.transID[:4], magicCookie)
35 _, err := rand.Read(v.transID[4:])
54 pkt.transID = packetBytes[4:20]
81 packetBytes = append(packetBytes, v.transID...)
129 return a.xorAddr(v.transID)
H A Dattribute.go68 func (v *attribute) xorAddr(transID []byte) *Host {
71 xorIP[i] = v.value[i+4] ^ transID[i]
79 x := binary.BigEndian.Uint16(transID[:2])
H A Dnet.go94 if !bytes.Equal(pkt.transID, p.transID) {
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/shared/
H A Dwe_brm.cpp511 int32_t& transID, in getTableLock() argument
798 int BRMWrapper::commit(const VER_t transID) in commit() argument
800 int rc = blockRsltnMgrPtr->vbCommit(transID); in commit()
912 fileOp.setTransId(transID); in rollBack()
923 QueryContext verID(transID); in rollBack()
1119 VER_t verID = (VER_t) transID; in rollBackBlocks()
1175 fileOp.setTransId(transID); in rollBackBlocks()
1191 verID = (VER_t) transID; in rollBackBlocks()
1537 BRM::QueryContext verID(transID); in pruneLBIDList()
1592 cout << "\n\tTransId=" << transID << endl; in writeVB()
[all …]
H A Dwe_brm.h317 BRM::VER_t transID);
343 int32_t& transID,
397 EXPORT int commit( const BRM::VER_t transID );
421 EXPORT int rollBack( const BRM::VER_t transID, int sessionId );
437 const BRM::VER_t transID,
442 const BRM::VER_t transID,
450 void writeVBEnd(const BRM::VER_t transID,
454 void pruneLBIDList(BRM::VER_t transID,
643 BRM::VER_t transID = 0; // n/a in bulkSetHWMAndCP() local
704 BRM::VER_t transID = 0)
[all …]
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/shared/
H A Dwe_brm.cpp511 int32_t& transID, in getTableLock() argument
798 int BRMWrapper::commit(const VER_t transID) in commit() argument
800 int rc = blockRsltnMgrPtr->vbCommit(transID); in commit()
912 fileOp.setTransId(transID); in rollBack()
923 QueryContext verID(transID); in rollBack()
1119 VER_t verID = (VER_t) transID; in rollBackBlocks()
1175 fileOp.setTransId(transID); in rollBackBlocks()
1191 verID = (VER_t) transID; in rollBackBlocks()
1537 BRM::QueryContext verID(transID); in pruneLBIDList()
1592 cout << "\n\tTransId=" << transID << endl; in writeVB()
[all …]
H A Dwe_brm.h317 BRM::VER_t transID);
343 int32_t& transID,
397 EXPORT int commit( const BRM::VER_t transID );
421 EXPORT int rollBack( const BRM::VER_t transID, int sessionId );
437 const BRM::VER_t transID,
442 const BRM::VER_t transID,
450 void writeVBEnd(const BRM::VER_t transID,
454 void pruneLBIDList(BRM::VER_t transID,
643 BRM::VER_t transID = 0; // n/a in bulkSetHWMAndCP() local
704 BRM::VER_t transID = 0)
[all …]
/dports/finance/moneymanagerex/moneymanagerex-1.2.7/src/
H A Dmmreportspanel.cpp51 long transID = -1; in GetFile() local
52 if (sData.ToLong(&transID)) { in GetFile()
53 const Model_Checking::Data* transaction = Model_Checking::instance().get(transID); in GetFile()
59 frame->setGotoAccountID(transaction->ACCOUNTID, transID); in GetFile()
68 long transID = -1; in GetFile() local
69 if (sData.ToLong(&transID)) { in GetFile()
70 const Model_Checking::Data* transaction = Model_Checking::instance().get(transID); in GetFile()
73 mmTransDialog dlg(nullptr, -1, transID); in GetFile()
/dports/sysutils/libdnf/libdnf-0.64.0/libdnf/transaction/
H A DTransactionItem.cpp89 , transID(0) in TransactionItem()
124 TransactionItem::TransactionItem(SQLite3Ptr conn, int64_t transID) in TransactionItem() argument
126 , transID(transID) in TransactionItem()
250 Transaction t(conn, transID); in getInstalledBy()
/dports/misc/glow/glow-f24d960e3cc80db95ac0bc17b1900dbf60ca044a/utils/
H A Dlog_parser.py276 transID: int,
302 (transID, baseNode.get_name(), baseNode.get_kind_name(), fullScopeName),
313 (transID, an.get_name(), an.get_kind_name(), fullScopeName),
325 (transID, rn.get_name(), rn.get_kind_name(), fullScopeName),
424 transID = 0
518 transID,
526 transID += 1
/dports/lang/intel-compute-runtime/compute-runtime-21.52.22081/shared/source/tbx/
H A Dtbx_sockets_imp.cpp89 cmd.hdr.trans_id = transID++; in init()
142 cmd.hdr.trans_id = transID++; in readMMIO()
180 cmd.hdr.trans_id = transID++; in writeMMIO()
194 cmd.hdr.trans_id = transID++; in readMemory()
234 cmd.hdr.trans_id = transID++; in writeMemory()
269 cmd.hdr.trans_id = transID++; in writeGTT()
H A Dtbx_sockets_imp.h41 inline uint32_t getNextTransID() { return transID++; } in getNextTransID()
45 uint32_t transID = 0; variable
/dports/comms/mlan3/mlan3-1.00/common/
H A Dshadebit.c157 user->accountFile.file.transID[0] = 0; in InstallServiceData()
158 user->accountFile.file.transID[0] = 0; in InstallServiceData()
184 user->accountFile.file.transID[0] += 1; in UpdateServiceData()
185 if(user->accountFile.file.transID[0]==0) in UpdateServiceData()
186 user->accountFile.file.transID[1] += 1; in UpdateServiceData()
/dports/net/tcpview/tcpview-1.0/
H A Dprint-atalk.c142 EXTRACT_SHORT(&ap->transID));
165 EXTRACT_SHORT(&ap->transID), ap->bitmap, length);
180 (void)printf(" atp-rel %d", EXTRACT_SHORT(&ap->transID));
209 EXTRACT_SHORT(&ap->transID), length);

123