/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/command/ |
H A D | CommandExecutor.java | 33 PrintWriter pwriter, in execute() argument 51 PrintWriter pwriter, in getCommand() argument 55 command = new RuokCommand(pwriter, serverCnxn); in getCommand() 59 command = new EnvCommand(pwriter, serverCnxn); in getCommand() 61 command = new ConfCommand(pwriter, serverCnxn); in getCommand() 67 command = new DirsCommand(pwriter, serverCnxn); in getCommand() 69 command = new DumpCommand(pwriter, serverCnxn); in getCommand() 73 command = new ConsCommand(pwriter, serverCnxn); in getCommand() 79 command = new MonitorCommand(pwriter, serverCnxn); in getCommand() 81 command = new IsroCommand(pwriter, serverCnxn); in getCommand() [all …]
|
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/ |
H A D | ServerCnxn.java | 497 pwriter.flush(); in toString() 498 pwriter.close(); in toString() 513 pwriter.print(" "); in dumpConnectionInfo() 515 pwriter.print("["); in dumpConnectionInfo() 518 pwriter.print("](queued="); in dumpConnectionInfo() 520 pwriter.print(",recved="); in dumpConnectionInfo() 522 pwriter.print(",sent="); in dumpConnectionInfo() 555 pwriter.print(")"); in dumpConnectionInfo() 590 if (pwriter != null) { in cleanupWriterSocket() 591 pwriter.flush(); in cleanupWriterSocket() [all …]
|
H A D | ExpiryQueue.java | 155 public void dump(PrintWriter pwriter) { in dump() argument 156 pwriter.print("Sets ("); in dump() 157 pwriter.print(expiryMap.size()); in dump() 158 pwriter.print(")/("); in dump() 159 pwriter.print(elemMap.size()); in dump() 160 pwriter.println("):"); in dump() 166 pwriter.print(set.size()); in dump() 167 pwriter.print(" expire at "); in dump() 169 pwriter.println(":"); in dump() 171 pwriter.print("\t"); in dump() [all …]
|
H A D | SessionTrackerImpl.java | 124 public void dumpSessions(PrintWriter pwriter) { in dumpSessions() argument 125 pwriter.print("Session "); in dumpSessions() 126 sessionExpiryQueue.dump(pwriter); in dumpSessions() 149 PrintWriter pwriter = new PrintWriter(sw); in toString() local 150 dumpSessions(pwriter); in toString() 151 pwriter.flush(); in toString() 152 pwriter.close(); in toString()
|
/dports/science/liggghts/LIGGGHTS-PUBLIC-3.8.0-26-g6e873439/src/ |
H A D | dump_vtk.cpp | 165 pwriter->SetFileName(filename); in write_vtp() 170 pwriter->SetInput(data); in write_vtp() 172 pwriter->SetInputData(data); in write_vtp() 178 pwriter->Write(); in write_vtp() 204 pwriter->SetFileName(filename); in write_vtu() 209 pwriter->SetInput(data); in write_vtu() 211 pwriter->SetInputData(data); in write_vtu() 217 pwriter->Write(); in write_vtu() 253 pwriter->Write(); in write_vti() 282 pwriter->SetInputData(data); in write_vtr() [all …]
|
/dports/math/vtk6/VTK-6.2.0/IO/XML/Testing/Tcl/ |
H A D | TestEmptyXML.tcl | 46 vtkXMLP${type}Writer pwriter 48 pwriter SetNumberOfPieces 1 50 catch {pwriter Write} 52 pwriter SetInputData input 53 pwriter Write 79 pwriter Delete 99 pwriter SetNumberOfPieces 1 101 catch {pwriter Write} 103 pwriter SetInputData input 104 pwriter Write [all …]
|
/dports/math/vtk8/VTK-8.2.0/IO/XML/Testing/Python/ |
H A D | TestEmptyXML.py | 50 pwriter = eval('vtk.vtkXMLP' + type + 'Writer()') variable 53 pwriter.Write() 55 pwriter.SetInputData(input) 56 pwriter.Write() 82 del pwriter 90 pwriter = vtk.vtkXMLPDataSetWriter() variable 102 pwriter.SetNumberOfPieces(1) 103 pwriter.Write() 105 pwriter.SetInputData(input) 106 pwriter.Write() [all …]
|
/dports/math/vtk6/VTK-6.2.0/IO/XML/Testing/Python/ |
H A D | TestEmptyXML.py | 50 pwriter = eval('vtk.vtkXMLP' + type + 'Writer()') variable 53 pwriter.Write() 55 pwriter.SetInputData(input) 56 pwriter.Write() 82 del pwriter 90 pwriter = vtk.vtkXMLPDataSetWriter() variable 102 pwriter.SetNumberOfPieces(1) 103 pwriter.Write() 105 pwriter.SetInputData(input) 106 pwriter.Write() [all …]
|
/dports/math/vtk9/VTK-9.1.0/IO/XML/Testing/Python/ |
H A D | TestEmptyXML.py | 53 pwriter = eval('vtk.vtkXMLP' + type + 'Writer()') variable 56 pwriter.Write() 58 pwriter.SetInputData(input) 59 pwriter.Write() 85 del pwriter 93 pwriter = vtk.vtkXMLPDataSetWriter() variable 105 pwriter.SetNumberOfPieces(1) 106 pwriter.Write() 108 pwriter.SetInputData(input) 109 pwriter.Write() [all …]
|
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/ |
H A D | QuorumZooKeeperServer.java | 171 public void dumpConf(PrintWriter pwriter) { in dumpConf() argument 172 super.dumpConf(pwriter); in dumpConf() 174 pwriter.print("initLimit="); in dumpConf() 175 pwriter.println(self.getInitLimit()); in dumpConf() 176 pwriter.print("syncLimit="); in dumpConf() 177 pwriter.println(self.getSyncLimit()); in dumpConf() 178 pwriter.print("electionAlg="); in dumpConf() 180 pwriter.print("electionPort="); in dumpConf() 183 pwriter.print("quorumPort="); in dumpConf() 186 pwriter.print("peerType="); in dumpConf() [all …]
|
H A D | ReadOnlyZooKeeperServer.java | 213 public void dumpConf(PrintWriter pwriter) { in dumpConf() argument 214 super.dumpConf(pwriter); in dumpConf() 216 pwriter.print("initLimit="); in dumpConf() 217 pwriter.println(self.getInitLimit()); in dumpConf() 218 pwriter.print("syncLimit="); in dumpConf() 219 pwriter.println(self.getSyncLimit()); in dumpConf() 220 pwriter.print("electionAlg="); in dumpConf() 221 pwriter.println(self.getElectionType()); in dumpConf() 222 pwriter.print("electionPort="); in dumpConf() 225 pwriter.print("quorumPort="); in dumpConf() [all …]
|
H A D | LearnerSessionTracker.java | 197 public void dumpSessions(PrintWriter pwriter) { in dumpSessions() argument 199 pwriter.print("Local "); in dumpSessions() 200 localSessionTracker.dumpSessions(pwriter); in dumpSessions() 202 pwriter.print("Global Sessions("); in dumpSessions() 203 pwriter.print(globalSessionsWithTimeouts.size()); in dumpSessions() 204 pwriter.println("):"); in dumpSessions() 207 pwriter.print("0x"); in dumpSessions() 208 pwriter.print(Long.toHexString(sessionId)); in dumpSessions() 209 pwriter.print("\t"); in dumpSessions() 210 pwriter.print(globalSessionsWithTimeouts.get(sessionId)); in dumpSessions() [all …]
|
H A D | LeaderSessionTracker.java | 196 public void dumpSessions(PrintWriter pwriter) { in dumpSessions() argument 198 pwriter.print("Local "); in dumpSessions() 199 localSessionTracker.dumpSessions(pwriter); in dumpSessions() 200 pwriter.print("Global "); in dumpSessions() 202 globalSessionTracker.dumpSessions(pwriter); in dumpSessions()
|
/dports/net/clash/clash-1.6.0/component/vmess/ |
H A D | h2.go | 16 pwriter *io.PipeWriter member 27 preader, pwriter := io.Pipe() 55 hc.pwriter = pwriter 76 if hc.pwriter != nil { 77 return hc.pwriter.Write(b) 83 return hc.pwriter.Write(b) 87 if err := hc.pwriter.Close(); err != nil {
|
/dports/graphics/opencv/opencv-4.5.3/modules/videoio/src/ |
H A D | videoio_c.cpp | 41 CV_IMPL void cvReleaseVideoWriter(CvVideoWriter** pwriter) in cvReleaseVideoWriter() argument 43 if( pwriter && *pwriter ) in cvReleaseVideoWriter() 45 delete *pwriter; in cvReleaseVideoWriter() 46 *pwriter = 0; in cvReleaseVideoWriter()
|
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/util/ |
H A D | RequestPathMetricsCollector.java | 221 pwriter.println("Can not find path stats for type: " + requestTypeName); in dumpTopRequestPath() 224 pwriter.println("The top requests of type: " + requestTypeName); in dumpTopRequestPath() 232 public void dumpTopReadPaths(PrintWriter pwriter, int queryMaxDepth) { in dumpTopReadPaths() argument 233 pwriter.println("The top read requests are"); in dumpTopReadPaths() 234 dumpTopAggregatedPaths(pwriter, queryMaxDepth, queue -> !queue.isWriteOperation); in dumpTopReadPaths() 237 public void dumpTopWritePaths(PrintWriter pwriter, int queryMaxDepth) { in dumpTopWritePaths() argument 238 pwriter.println("The top write requests are"); in dumpTopWritePaths() 239 dumpTopAggregatedPaths(pwriter, queryMaxDepth, queue -> queue.isWriteOperation); in dumpTopWritePaths() 242 public void dumpTopPaths(PrintWriter pwriter, int queryMaxDepth) { in dumpTopPaths() argument 243 pwriter.println("The top requests are"); in dumpTopPaths() [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/snowflakedb/gosnowflake/vendor/github.com/apache/arrow/go/arrow/ipc/ |
H A D | file_writer.go | 37 type pwriter struct { struct 46 func (w *pwriter) start() error { argument 68 func (w *pwriter) write(p payload) error { argument 92 func (w *pwriter) Close() error { argument 133 func (w *pwriter) updatePos() error { argument 139 func (w *pwriter) align(align int32) error { argument 149 func (w *pwriter) Write(p []byte) (int, error) { argument 250 pw: &pwriter{w: w, schema: cfg.schema, pos: -1},
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/go/arrow/ipc/ |
H A D | file_writer.go | 37 type pwriter struct { struct 46 func (w *pwriter) start() error { argument 68 func (w *pwriter) write(p payload) error { argument 92 func (w *pwriter) Close() error { argument 133 func (w *pwriter) updatePos() error { argument 139 func (w *pwriter) align(align int32) error { argument 149 func (w *pwriter) Write(p []byte) (int, error) { argument 250 pw: &pwriter{w: w, schema: cfg.schema, pos: -1},
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/go/arrow/ipc/ |
H A D | file_writer.go | 40 type pwriter struct { struct 49 func (w *pwriter) Start() error { argument 71 func (w *pwriter) WritePayload(p Payload) error { argument 95 func (w *pwriter) Close() error { argument 136 func (w *pwriter) updatePos() error { argument 142 func (w *pwriter) align(align int32) error { argument 152 func (w *pwriter) Write(p []byte) (int, error) { argument 289 pw: &pwriter{w: w, schema: cfg.schema, pos: -1},
|
/dports/databases/arrow/apache-arrow-6.0.1/go/arrow/ipc/ |
H A D | file_writer.go | 40 type pwriter struct { struct 49 func (w *pwriter) Start() error { argument 71 func (w *pwriter) WritePayload(p Payload) error { argument 95 func (w *pwriter) Close() error { argument 136 func (w *pwriter) updatePos() error { argument 142 func (w *pwriter) align(align int32) error { argument 152 func (w *pwriter) Write(p []byte) (int, error) { argument 291 pw: &pwriter{w: w, schema: cfg.schema, pos: -1},
|
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/watch/ |
H A D | WatchManagerOptimized.java | 368 public void dumpWatches(PrintWriter pwriter, boolean byPath) { in dumpWatches() argument 371 pwriter.println(e.getKey()); in dumpWatches() 379 pwriter.print("\t0x"); in dumpWatches() 380 pwriter.print(Long.toHexString(((ServerCnxn) w).getSessionId())); in dumpWatches() 381 pwriter.print("\n"); in dumpWatches() 387 pwriter.print("0x"); in dumpWatches() 388 pwriter.println(Long.toHexString(((ServerCnxn) e.getKey()).getSessionId())); in dumpWatches() 390 pwriter.print("\t"); in dumpWatches() 391 pwriter.println(path); in dumpWatches()
|
H A D | WatchManager.java | 211 public synchronized void dumpWatches(PrintWriter pwriter, boolean byPath) { in dumpWatches() argument 214 pwriter.println(e.getKey()); in dumpWatches() 216 pwriter.print("\t0x"); in dumpWatches() 217 pwriter.print(Long.toHexString(((ServerCnxn) w).getSessionId())); in dumpWatches() 218 pwriter.print("\n"); in dumpWatches() 223 pwriter.print("0x"); in dumpWatches() 224 pwriter.println(Long.toHexString(((ServerCnxn) e.getKey()).getSessionId())); in dumpWatches() 226 pwriter.print("\t"); in dumpWatches() 227 pwriter.println(path); in dumpWatches()
|
/dports/textproc/miller/miller-5.10.2/c/output/ |
H A D | lrec_writer_nidx.c | 10 static void lrec_writer_nidx_free(lrec_writer_t* pwriter, context_t* pctx); 32 static void lrec_writer_nidx_free(lrec_writer_t* pwriter, context_t* pctx) { in lrec_writer_nidx_free() argument 33 free(pwriter->pvstate); in lrec_writer_nidx_free() 34 free(pwriter); in lrec_writer_nidx_free()
|
H A D | lrec_writer_dkvp.c | 11 static void lrec_writer_dkvp_free(lrec_writer_t* pwriter, context_t* pctx); 34 static void lrec_writer_dkvp_free(lrec_writer_t* pwriter, context_t* pctx) { in lrec_writer_dkvp_free() argument 35 free(pwriter->pvstate); in lrec_writer_dkvp_free() 36 free(pwriter); in lrec_writer_dkvp_free()
|
H A D | lrec_writer_markdown.c | 13 static void lrec_writer_markdown_free(lrec_writer_t* pwriter, context_t* pctx); 37 static void lrec_writer_markdown_free(lrec_writer_t* pwriter, context_t* pctx) { in lrec_writer_markdown_free() argument 38 lrec_writer_markdown_state_t* pstate = pwriter->pvstate; in lrec_writer_markdown_free() 41 free(pwriter); in lrec_writer_markdown_free()
|