| /dports/devel/gh/cli-2.4.0/pkg/liveshare/ |
| H A D | socket.go | 63 nextWriter, err := s.conn.NextWriter(websocket.BinaryMessage)
68 bytesWritten, err := nextWriter.Write(b)
69 nextWriter.Close()
|
| /dports/net-im/dendrite/dendrite-0.5.1/internal/httputil/ |
| H A D | httpapi.go | 102 nextWriter := w
107 nextWriter = rec
146 h.ServeHTTP(nextWriter, req)
|
| /dports/security/keybase/client-v5.7.1/go/kbfs/kbfsedits/ |
| H A D | tlf_history.go | 533 nextWriter := writersHeap[0].writerName
535 doTrim := r.processNotification(nextWriter, nextNotification)
542 numProcessed := r.numProcessed[nextWriter]
543 if loggedInUser == nextWriter {
546 th.byWriter[nextWriter].notifications =
547 th.byWriter[nextWriter].notifications[:numProcessed]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gopkg.in/DataDog/dd-trace-go.v1/ddtrace/vendor/github.com/philhofer/fwd/ |
| H A D | writer_test.go | 51 type nextWriter struct { struct
55 func (c nextWriter) Write(p []byte) (int, error) { argument
188 nwr := nextWriter{wr}
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/gopkg.in/DataDog/dd-trace-go.v1/ddtrace/vendor/github.com/philhofer/fwd/ |
| H A D | writer_test.go | 51 type nextWriter struct { struct
55 func (c nextWriter) Write(p []byte) (int, error) { argument
188 nwr := nextWriter{wr}
|
| /dports/www/minio-client/mc-RELEASE.2021-12-10T00-14-28Z/vendor/github.com/philhofer/fwd/ |
| H A D | writer_test.go | 51 type nextWriter struct { struct
55 func (c nextWriter) Write(p []byte) (int, error) { argument
188 nwr := nextWriter{wr}
|
| /dports/games/automuteus/automuteus-6.15.2/vendor/github.com/googollee/go-socket.io/engineio/ |
| H A D | server.go | 163 w, err := session.nextWriter(base.FrameString, base.OPEN)
|
| H A D | session.go | 87 w, err := s.nextWriter(ft, base.PONG)
125 return s.nextWriter(base.FrameType(typ), base.MESSAGE)
168 func (s *session) nextWriter(ft base.FrameType, pt base.PacketType) (io.WriteCloser, error) { func
|
| /dports/security/horcrux/horcrux-0.3/pkg/multiplexing/ |
| H A D | multiplexing.go | 25 func (d *Demultiplexer) nextWriter() { func
45 d.nextWriter()
|
| /dports/graphics/lightzone/LightZone-4.1.8-3-g36e87773/lightcrafts/extsrc/com/lightcrafts/media/jai/util/ |
| H A D | RWLock.java | 179 int nextWriter = waitingList.indexOfFirstWriter(); in forReading() local
185 if ((nextWriter == NOT_FOUND) || (nextWriter > index)) { in forReading()
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/philhofer/fwd/ |
| H A D | writer_test.go | 51 type nextWriter struct { struct
55 func (c nextWriter) Write(p []byte) (int, error) { argument
188 nwr := nextWriter{wr}
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/github.com/philhofer/fwd/ |
| H A D | writer_test.go | 51 type nextWriter struct { struct
55 func (c nextWriter) Write(p []byte) (int, error) { argument
188 nwr := nextWriter{wr}
|
| /dports/audio/pms-devel/pms-c94e3c6/vendor/github.com/philhofer/fwd/ |
| H A D | writer_test.go | 51 type nextWriter struct { struct
55 func (c nextWriter) Write(p []byte) (int, error) { argument
188 nwr := nextWriter{wr}
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/philhofer/fwd/ |
| H A D | writer_test.go | 51 type nextWriter struct { struct
55 func (c nextWriter) Write(p []byte) (int, error) { argument
188 nwr := nextWriter{wr}
|
| /dports/mail/mailhog/MailHog-1.0.0/vendor/github.com/philhofer/fwd/ |
| H A D | writer_test.go | 51 type nextWriter struct { struct
55 func (c nextWriter) Write(p []byte) (int, error) { argument
188 nwr := nextWriter{wr}
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/ |
| H A D | FSHLog.java | 658 private void preemptiveSync(final ProtobufLogWriter nextWriter) { in preemptiveSync() argument
661 nextWriter.sync(); in preemptiveSync()
689 Writer nextWriter = this.createWriterInstance(newPath); in rollWriter() local
691 if (nextWriter instanceof ProtobufLogWriter) { in rollWriter()
692 nextHdfsOut = ((ProtobufLogWriter)nextWriter).getStream(); in rollWriter()
695 preemptiveSync((ProtobufLogWriter)nextWriter); in rollWriter()
699 newPath = replaceWriter(oldPath, newPath, nextWriter, nextHdfsOut); in rollWriter()
811 Path replaceWriter(final Path oldPath, final Path newPath, Writer nextWriter, in replaceWriter() argument
861 this.writer = nextWriter; in replaceWriter()
|