/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
H A D | slavedbrmnode.cpp | 374 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 D | slavedbrmnode.h | 310 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 D | slavecomm.cpp | 1105 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 D | dbrm.h | 441 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 D | dbrm.cpp | 1586 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 D | slavedbrmnode.cpp | 374 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 D | slavedbrmnode.h | 310 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 D | slavecomm.cpp | 1105 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 D | dbrm.h | 441 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 D | dbrm.cpp | 1586 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 D | conn_client.go | 34 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 D | packet.go | 27 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 D | attribute.go | 68 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 D | net.go | 94 if !bytes.Equal(pkt.transID, p.transID) {
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/shared/ |
H A D | we_brm.cpp | 511 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 D | we_brm.h | 317 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 D | we_brm.cpp | 511 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 D | we_brm.h | 317 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 D | mmreportspanel.cpp | 51 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 D | TransactionItem.cpp | 89 , 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 D | log_parser.py | 276 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 D | tbx_sockets_imp.cpp | 89 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 D | tbx_sockets_imp.h | 41 inline uint32_t getNextTransID() { return transID++; } in getNextTransID() 45 uint32_t transID = 0; variable
|
/dports/comms/mlan3/mlan3-1.00/common/ |
H A D | shadebit.c | 157 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 D | print-atalk.c | 142 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);
|