diff options
| author | Valery Piashchynski <[email protected]> | 2022-01-12 17:00:25 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2022-01-12 17:00:25 +0300 |
| commit | 78e51b60e11147d625ef08f1efac923a41bb33b2 (patch) | |
| tree | fce7a2fcac9cd389b659c12a2d62f14b089083dd /worker/sync_worker.go | |
| parent | a191eac78092dda89dbcd19c7a3a171f6aafb71a (diff) | |
update protocol structure, use encoder
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'worker/sync_worker.go')
| -rwxr-xr-x | worker/sync_worker.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/worker/sync_worker.go b/worker/sync_worker.go index e3e85ba6..6ece0ad7 100755 --- a/worker/sync_worker.go +++ b/worker/sync_worker.go @@ -162,6 +162,7 @@ func (tw *SyncWorkerImpl) execPayload(p *payload.Payload) (*payload.Payload, err // can be 0 here fr.WriteVersion(fr.Header(), frame.VERSION_1) + fr.WriteFlags(fr.Header(), p.Codec) // obtain a buffer buf := tw.get() @@ -207,6 +208,7 @@ func (tw *SyncWorkerImpl) execPayload(p *payload.Payload) (*payload.Payload, err } pld := &payload.Payload{ + Codec: flags, Body: make([]byte, len(frameR.Payload()[options[0]:])), Context: make([]byte, len(frameR.Payload()[:options[0]])), } |