Home
last modified time | relevance | path

Searched refs:outputChan (Results 1 – 25 of 146) sorted by relevance

123456

/dports/net-mgmt/bind_exporter/bind_exporter-0.4.0/vendor/github.com/go-kit/kit/transport/amqp/
H A Dsubscriber_test.go54 outputChan := make(chan amqp.Publishing, 1)
60 case msg = <-outputChan:
86 outputChan := make(chan amqp.Publishing, 1)
93 case msg = <-outputChan:
120 outputChan := make(chan amqp.Publishing, 1)
127 case msg = <-outputChan:
169 outputChan := make(chan amqp.Publishing, 1)
180 case msg = <-outputChan:
251 case <-outputChan:
295 case msg = <-outputChan:
[all …]
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/go-kit/kit/transport/amqp/
H A Dsubscriber_test.go54 outputChan := make(chan amqp.Publishing, 1)
60 case msg = <-outputChan:
86 outputChan := make(chan amqp.Publishing, 1)
93 case msg = <-outputChan:
120 outputChan := make(chan amqp.Publishing, 1)
127 case msg = <-outputChan:
169 outputChan := make(chan amqp.Publishing, 1)
180 case msg = <-outputChan:
251 case <-outputChan:
295 case msg = <-outputChan:
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/go-kit/kit/transport/amqp/
H A Dsubscriber_test.go54 outputChan := make(chan amqp.Publishing, 1)
60 case msg = <-outputChan:
86 outputChan := make(chan amqp.Publishing, 1)
93 case msg = <-outputChan:
120 outputChan := make(chan amqp.Publishing, 1)
127 case msg = <-outputChan:
169 outputChan := make(chan amqp.Publishing, 1)
180 case msg = <-outputChan:
251 case <-outputChan:
295 case msg = <-outputChan:
[all …]
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/go-kit/kit/transport/amqp/
H A Dsubscriber_test.go54 outputChan := make(chan amqp.Publishing, 1)
60 case msg = <-outputChan:
86 outputChan := make(chan amqp.Publishing, 1)
93 case msg = <-outputChan:
120 outputChan := make(chan amqp.Publishing, 1)
127 case msg = <-outputChan:
169 outputChan := make(chan amqp.Publishing, 1)
180 case msg = <-outputChan:
251 case <-outputChan:
295 case msg = <-outputChan:
[all …]
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/go-kit/kit/transport/amqp/
H A Dsubscriber_test.go54 outputChan := make(chan amqp.Publishing, 1)
60 case msg = <-outputChan:
86 outputChan := make(chan amqp.Publishing, 1)
93 case msg = <-outputChan:
120 outputChan := make(chan amqp.Publishing, 1)
127 case msg = <-outputChan:
169 outputChan := make(chan amqp.Publishing, 1)
180 case msg = <-outputChan:
251 case <-outputChan:
295 case msg = <-outputChan:
[all …]
/dports/sysutils/snmp_exporter/snmp_exporter-0.20.0/vendor/github.com/go-kit/kit/transport/amqp/
H A Dsubscriber_test.go54 outputChan := make(chan amqp.Publishing, 1)
60 case msg = <-outputChan:
86 outputChan := make(chan amqp.Publishing, 1)
93 case msg = <-outputChan:
120 outputChan := make(chan amqp.Publishing, 1)
127 case msg = <-outputChan:
169 outputChan := make(chan amqp.Publishing, 1)
180 case msg = <-outputChan:
251 case <-outputChan:
295 case msg = <-outputChan:
[all …]
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/go-kit/kit/transport/amqp/
H A Dsubscriber_test.go54 outputChan := make(chan amqp.Publishing, 1)
60 case msg = <-outputChan:
86 outputChan := make(chan amqp.Publishing, 1)
93 case msg = <-outputChan:
120 outputChan := make(chan amqp.Publishing, 1)
127 case msg = <-outputChan:
169 outputChan := make(chan amqp.Publishing, 1)
180 case msg = <-outputChan:
251 case <-outputChan:
295 case msg = <-outputChan:
[all …]
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/go-kit/kit/transport/amqp/
H A Dsubscriber_test.go54 outputChan := make(chan amqp.Publishing, 1)
55 ch := &mockChannel{f: nullFunc, c: outputChan}
60 case msg = <-outputChan:
86 outputChan := make(chan amqp.Publishing, 1)
93 case msg = <-outputChan:
120 outputChan := make(chan amqp.Publishing, 1)
127 case msg = <-outputChan:
169 outputChan := make(chan amqp.Publishing, 1)
180 case msg = <-outputChan:
256 case msg = <-outputChan:
[all …]
/dports/audio/ardour6/Ardour-6.8.0/libs/appleutility/CoreAudio/PublicUtility/
H A DCAMixMap.h85 void SetCrossPoint (UInt32 inputChan, UInt32 outputChan, Float32 val) in SetCrossPoint() argument
87 if (inputChan < NumIns() && outputChan < NumOuts()) in SetCrossPoint()
88 mMixMap[inputChan * NumOuts() + outputChan] = val; in SetCrossPoint()
90 Float32 GetCrossPoint (UInt32 inputChan, UInt32 outputChan) const in GetCrossPoint() argument
92 return (inputChan < NumIns() && outputChan < NumOuts()) in GetCrossPoint()
93 ? mMixMap[inputChan * NumOuts() + outputChan] in GetCrossPoint()
/dports/security/keybase/client-v5.7.1/go/vendor/github.com/saintfish/chardet/
H A Ddetector.go98 outputChan := make(chan recognizerOutput)
100 go matchHelper(r, input, outputChan)
104 o := <-outputChan
128 func matchHelper(r recognizer, input *recognizerInput, outputChan chan<- recognizerOutput) {
129 outputChan <- r.Match(input)
/dports/net-im/matterbridge/matterbridge-1.22.3/vendor/github.com/saintfish/chardet/
H A Ddetector.go98 outputChan := make(chan recognizerOutput)
100 go matchHelper(r, input, outputChan)
104 o := <-outputChan
128 func matchHelper(r recognizer, input *recognizerInput, outputChan chan<- recognizerOutput) {
129 outputChan <- r.Match(input)
/dports/www/gitea/gitea-1.16.5/vendor/github.com/gogs/chardet/
H A Ddetector.go98 outputChan := make(chan recognizerOutput)
100 go matchHelper(r, input, outputChan)
104 o := <-outputChan
128 func matchHelper(r recognizer, input *recognizerInput, outputChan chan<- recognizerOutput) {
129 outputChan <- r.Match(input)
/dports/www/colly/colly-2.1.0/vendor/github.com/saintfish/chardet/
H A Ddetector.go98 outputChan := make(chan recognizerOutput)
100 go matchHelper(r, input, outputChan)
104 o := <-outputChan
128 func matchHelper(r recognizer, input *recognizerInput, outputChan chan<- recognizerOutput) {
129 outputChan <- r.Match(input)
/dports/www/gitea/gitea-1.16.5/services/pull/
H A Dpatch_unmerged.go47 func readUnmergedLsFileLines(ctx context.Context, tmpBasePath string, outputChan chan *lsFileLine) {
50 close(outputChan)
56 outputChan <- &lsFileLine{err: fmt.Errorf("unable to open stderr pipe: %v", err)}
103 outputChan <- toemit
108 …outputChan <- &lsFileLine{err: fmt.Errorf("git ls-files -u -z: %v", git.ConcatenateError(err, stde…
/dports/security/vault/vault-1.8.2/vendor/github.com/aerospike/aerospike-client-go/
H A Dclient_appengine_exclusions.go80 outputChan := make(chan interface{})
81 ostream := lualib.NewLuaStream(luaInstance, outputChan)
114 for val := range outputChan {
120 defer close(outputChan)
/dports/net-im/matterhorn/matterhorn-50200.13.0/src/Matterhorn/
H A DScripts.hs26 outputChan <- use (csResources.crSubprocessLog)
29 doAsyncWith Preempt $ runScript cId outputChan scriptPath input
42 runScript cId outputChan fp text = do
44 runLoggedCommand outputChan fp [] (Just $ T.unpack text) (Just outputVar)
/dports/lang/spidermonkey60/firefox-60.9.0/modules/pdfium/pdfium/third_party/lcms2-2.6/
H A D0016-check-LUT-and-MPE.patch145 + if (outputChan == 0 || outputChan >= cmsMAXCHANNELS) return NULL;
148 NewLUT = cmsPipelineAlloc(self ->ContextID, inputChan, outputChan);
153 if (!_cmsReadUInt8Number(io, &outputChan)) return NULL;
156 + if (outputChan == 0 || outputChan >= cmsMAXCHANNELS) return NULL;
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoimport/
H A Dcommon.go170 func doSequentialStreaming(workers []*importWorker, readDocs chan Converter, outputChan chan bson.D…
195 outputChan <- processedDocument
303 func streamDocuments(ordered bool, numDecoders int, readDocs chan Converter, outputChan chan bson.D…
311 outChan := outputChan
339 doSequentialStreaming(importWorkers, readDocs, outputChan)
342 close(outputChan)
/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/mongoimport/
H A Dcommon.go169 func doSequentialStreaming(workers []*importWorker, readDocs chan Converter, outputChan chan bson.D…
194 outputChan <- processedDocument
285 func streamDocuments(ordered bool, numDecoders int, readDocs chan Converter, outputChan chan bson.D…
293 outChan := outputChan
321 doSequentialStreaming(importWorkers, readDocs, outputChan)
324 close(outputChan)
/dports/print/ghostscript7-base/ghostscript-7.07/icclib/
H A Dicctest.c576 wo->outputChan = 3; in doit()
626 rv |= (ro->outputChan != wo->outputChan); in doit()
635 size = wo->outputChan; in doit()
641 size = (wo->outputChan * wo->outputEnt); in doit()
674 rv |= (ro->outputChan != wo->outputChan); in doit()
683 size = wo->outputChan; in doit()
689 size = (wo->outputChan * wo->outputEnt); in doit()
707 wo->outputChan = 2; in doit()
728 * wo->outputChan + k; in doit()
752 rv |= (ro->outputChan != wo->outputChan); in doit()
[all …]
/dports/print/ghostscript7-x11/ghostscript-7.07/icclib/
H A Dicctest.c576 wo->outputChan = 3; in doit()
626 rv |= (ro->outputChan != wo->outputChan); in doit()
635 size = wo->outputChan; in doit()
641 size = (wo->outputChan * wo->outputEnt); in doit()
674 rv |= (ro->outputChan != wo->outputChan); in doit()
683 size = wo->outputChan; in doit()
689 size = (wo->outputChan * wo->outputEnt); in doit()
707 wo->outputChan = 2; in doit()
728 * wo->outputChan + k; in doit()
752 rv |= (ro->outputChan != wo->outputChan); in doit()
[all …]
/dports/graphics/argyllcms/Argyll_V1.9.2/xicc/
H A Dxlut.c314 for (i = 0; i < p->outputChan; i++) in icxLuLut_clut_aux()
361 for (i = 0; i < p->outputChan; i++) { in icxLuLut_output()
369 for (i = 0; i < p->outputChan; i++) in icxLuLut_output()
392 for (i = 0; i < p->outputChan; i++) in icxLuLut_out_abs()
598 for (i = 0; i < p->outputChan; i++) in icxLuLut_inv_out_abs()
666 for (i = 0; i < p->outputChan; i++) in icxLuLut_inv_output()
1828 for (i = 0; i < p->outputChan; i++) in icxLuLut_inv_lookup()
2023 if (p->outputChan > MXDO) { in alloc_icxLuLut()
2152 if (p->inputChan > p->outputChan) { in setup_clip_icxLuLut()
2244 for (i = 0; i < p->outputChan; i++) in icxLuLut_inout_func()
[all …]
/dports/graphics/argyllcms/Argyll_V1.9.2/icc/
H A Dicctest.c670 wo->outputChan = 3; in doit()
720 rv |= (ro->outputChan != wo->outputChan); in doit()
733 size = wo->outputChan; in doit()
739 size = (wo->outputChan * wo->outputEnt); in doit()
772 rv |= (ro->outputChan != wo->outputChan); in doit()
781 size = wo->outputChan; in doit()
787 size = (wo->outputChan * wo->outputEnt); in doit()
805 wo->outputChan = 2; in doit()
826 * wo->outputChan + k; in doit()
850 rv |= (ro->outputChan != wo->outputChan); in doit()
[all …]
/dports/net-im/matterhorn/matterhorn-50200.13.0/src/Matterhorn/State/
H A DCommon.hs185 outputChan <- use (csResources.crSubprocessLog)
187 runLoggedCommand outputChan (T.unpack urlOpenCommand)
261 runLoggedCommand outputChan cmd args mInput mOutputVar = void $ forkIO $ do function
271 STM.atomically $ STM.writeTChan outputChan po
285 STM.atomically $ STM.writeTChan outputChan po
/dports/graphics/openjpeg15/openjpeg-version.1.5.2/thirdparty/liblcms2/src/
H A Dcmslut.c539 cmsUInt32Number outputChan, in cmsStageAllocCLut16bitGranular() argument
546 NewMPE = _cmsStageAllocPlaceholder(ContextID, cmsSigCLutElemType, inputChan, outputChan, in cmsStageAllocCLut16bitGranular()
559 NewElem -> nEntries = n = outputChan * CubeSize(clutPoints, inputChan); in cmsStageAllocCLut16bitGranular()
580 …NewElem ->Params = _cmsComputeInterpParamsEx(ContextID, clutPoints, inputChan, outputChan, NewElem… in cmsStageAllocCLut16bitGranular()
592 cmsUInt32Number outputChan, in cmsStageAllocCLut16bit() argument
603 return cmsStageAllocCLut16bitGranular(ContextID, Dimensions, inputChan, outputChan, Table); in cmsStageAllocCLut16bit()
610 cmsUInt32Number outputChan, in cmsStageAllocCLutFloat() argument
620 return cmsStageAllocCLutFloatGranular(ContextID, Dimensions, inputChan, outputChan, Table); in cmsStageAllocCLutFloat()
633 NewMPE = _cmsStageAllocPlaceholder(ContextID, cmsSigCLutElemType, inputChan, outputChan, in cmsStageAllocCLutFloatGranular()
647 NewElem -> nEntries = n = outputChan * CubeSize( clutPoints, inputChan); in cmsStageAllocCLutFloatGranular()
[all …]

123456