Home
last modified time | relevance | path

Searched refs:pwriter (Results 1 – 25 of 75) sorted by relevance

123

/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/main/java/org/apache/zookeeper/server/command/
H A DCommandExecutor.java33 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 DServerCnxn.java497 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 DExpiryQueue.java155 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 DSessionTrackerImpl.java124 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 Ddump_vtk.cpp165 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 DTestEmptyXML.tcl46 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 DTestEmptyXML.py50 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 DTestEmptyXML.py50 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 DTestEmptyXML.py53 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 DQuorumZooKeeperServer.java171 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 DReadOnlyZooKeeperServer.java213 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 DLearnerSessionTracker.java197 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 DLeaderSessionTracker.java196 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 Dh2.go16 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 Dvideoio_c.cpp41 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 DRequestPathMetricsCollector.java221 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 Dfile_writer.go37 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 Dfile_writer.go37 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 Dfile_writer.go40 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 Dfile_writer.go40 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 DWatchManagerOptimized.java368 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 DWatchManager.java211 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 Dlrec_writer_nidx.c10 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 Dlrec_writer_dkvp.c11 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 Dlrec_writer_markdown.c13 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()

123