| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/server/quorum/ |
| H A D | CommitProcessorTest.java | 145 int cxid; field in CommitProcessorTest.TestClientThread
163 … Request req = new Request(null, sessionId, ++cxid, OpCode.create, bb, new ArrayList<Id>()); in sendWriteRequest()
177 … Request req = new Request(null, sessionId, ++cxid, OpCode.getData, bb, new ArrayList<Id>()); in sendReadRequest()
401 request.cxid, in processRequest()
427 request.cxid, in processRequest()
463 + " write requests while issuing a read request cxid=" + request.cxid in validateReadRequestVariant()
482 sessionCxid = new AtomicInteger(request.cxid + 1); in validateRequest()
486 + request.cxid in validateRequest()
493 if (!sessionCxid.compareAndSet(request.cxid, request.cxid + 1)) { in validateRequest()
494 failTest("Expected_cxid=" + sessionCxid.get() + "; req_cxid=" + request.cxid); in validateRequest()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/test/ |
| H A D | LogChopperTest.java | 94 int cxid = 77; in testChopper() local
103 TxnHeader hdr = new TxnHeader(clientId, cxid, ++zxid, ++time, type); in testChopper()
108 TxnHeader hdr = new TxnHeader(clientId, cxid, zxid + 10, ++time, type); in testChopper()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/ |
| H A D | TraceFormatter.java | 50 int cxid = bb.getInt(); in main() local
74 + cxid in main()
|
| H A D | Request.java | 57 this.cxid = xid; in Request()
65 this.cxid = xid; in Request()
77 public final int cxid; field in Request
391 .append(" cxid:0x").append(Long.toHexString(cxid)) in toString()
|
| H A D | UnimplementedRequestProcessor.java | 35 ReplyHeader rh = new ReplyHeader(request.cxid, request.zxid, ke.code().intValue()); in processRequest()
|
| H A D | ServerCnxn.java | 418 …protected synchronized void updateStatsForResponse(long cxid, long zxid, String op, long start, lo… in updateStatsForResponse() argument
421 if (cxid >= 0) { in updateStatsForResponse()
422 lastCxid = cxid; in updateStatsForResponse()
|
| H A D | SnapshotFormatter.java | 152 … long cxid = printZnode(dataTree, name + (name.equals("/") ? "" : "/") + child, dumpData); in printZnode() local
153 zxid = Math.max(zxid, cxid); in printZnode()
|
| H A D | DataTree.java | 801 public int cxid; field in DataTree.ProcessTxnResult
825 return other.clientId == clientId && other.cxid == cxid; in equals()
838 return (int) ((clientId ^ cxid) % Integer.MAX_VALUE); in hashCode()
860 rc.cxid = header.getCxid(); in processTxn()
|
| H A D | FinalRequestProcessor.java | 604 ReplyHeader hdr = new ReplyHeader(request.cxid, lastZxid, err.intValue()); in processRequest()
693 …request.cnxn.updateStatsForResponse(request.cxid, lastZxid, lastOp, request.createTime, currentTim… in updateStats()
|
| H A D | PrepRequestProcessor.java | 321 request.setHdr(new TxnHeader(request.sessionId, request.cxid, zxid, in pRequest2Txn()
828 …request.setHdr(new TxnHeader(request.sessionId, request.cxid, zks.getNextZxid(), Time.currentWallT… in pRequestHelper()
838 request.setHdr(new TxnHeader(request.sessionId, request.cxid, zxid, in pRequestHelper()
|
| /dports/net-p2p/libbt/libbt-1.06/src/ |
| H A D | udpproto.c | 258 UNSHIFT_INT64( p, b64, dl->cxid); in udp_ready()
259 if (udp_request( ctx->udpsock, dl->cxid, dl->url[dl->tracker], in udp_ready()
356 dl->cxid = 0; in udp_announce()
361 dl->cxid, in udp_announce()
|
| H A D | context.c | 500 if (!dl->cxid) { in btannounce()
511 dl->cxid = 0; in btannounce()
|
| /dports/x11/xpra/xpra-4.3/xpra/x11/models/ |
| H A D | window.py | 190 cxid = self.corral_window.get_xid()
191 log("setup() corral_window=%#x", cxid)
193 X11Window.substructureRedirect(cxid)
210 X11Window.Reparent(self.xid, cxid, 0, 0)
504 cxid = self.corral_window.get_xid()
506 event, cxid, self.xid, self._managed)
511 … geomlog("WindowModel.do_xpra_configure_event: event is on the corral window %#x, ignored", cxid)
532 geomlog.warn("Warning: failed to resize corral window %#x", cxid)
586 cxid = self.corral_window.get_xid()
589 event, self.xid, cxid, configure_bits(event.value_mask), hints)
|
| /dports/net-p2p/libbt/libbt-1.06/include/ |
| H A D | context.h | 50 _int64 cxid; /* UDP connection id */ member
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/ |
| H A D | ReadOnlyRequestProcessor.java | 112 request.cxid, in sendErrorResponse()
|
| H A D | LearnerHandler.java | 668 int cxid; in run() local
696 cxid = bb.getInt(); in run()
701 … si = new LearnerSyncRequest(this, sessionId, cxid, type, bb, qp.getAuthinfo()); in run()
703 si = new Request(null, sessionId, cxid, type, bb, qp.getAuthinfo()); in run()
|
| H A D | CommitProcessor.java | 328 && queuedWriteRequests.peek().cxid == request.cxid) { in run()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-contrib/zookeeper-contrib-loggraph/ |
| H A D | README.md | 54 cxid : number, the cxid of a transaction
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-jute/src/main/resources/ |
| H A D | zookeeper.jute | 297 int cxid;
|
| /dports/security/passivedns/passivedns-1.2.1-22-gd757713/src/ |
| H A D | passivedns.h | 241 uint64_t cxid; /* Connection ID */ member
|
| /dports/databases/postgresql96-server/postgresql-9.6.24/src/backend/storage/ipc/ |
| H A D | procarray.c | 1130 TransactionId cxid = proc->subxids.xids[j]; in TransactionIdIsInProgress() local
1132 if (TransactionIdEquals(cxid, xid)) in TransactionIdIsInProgress()
|
| /dports/databases/postgresql96-pltcl/postgresql-9.6.24/src/backend/storage/ipc/ |
| H A D | procarray.c | 1130 TransactionId cxid = proc->subxids.xids[j]; in TransactionIdIsInProgress() local
1132 if (TransactionIdEquals(cxid, xid)) in TransactionIdIsInProgress()
|
| /dports/databases/postgresql96-plpython/postgresql-9.6.24/src/backend/storage/ipc/ |
| H A D | procarray.c | 1130 TransactionId cxid = proc->subxids.xids[j]; in TransactionIdIsInProgress() local
1132 if (TransactionIdEquals(cxid, xid)) in TransactionIdIsInProgress()
|
| /dports/databases/postgresql10-docs/postgresql-10.19/src/backend/storage/ipc/ |
| H A D | procarray.c | 1126 TransactionId cxid = proc->subxids.xids[j]; in TransactionIdIsInProgress() local
1128 if (TransactionIdEquals(cxid, xid)) in TransactionIdIsInProgress()
|
| /dports/databases/postgresql11-client/postgresql-11.14/src/backend/storage/ipc/ |
| H A D | procarray.c | 1123 TransactionId cxid = proc->subxids.xids[j]; in TransactionIdIsInProgress() local
1125 if (TransactionIdEquals(cxid, xid)) in TransactionIdIsInProgress()
|