FilesExpand file tree

 master

/

lrproxy.cpp

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

65 lines (53 loc) · 2.4 KB

 master

/

lrproxy.cpp

Copy path

Top

File metadata and controls

• Code
• Blame

65 lines (53 loc) · 2.4 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

/*

Socle - Socket Library Ecosystem

Copyright (c) 2014, Ales Stibal <astib@mag0.net>, All rights reserved.

This library is free software; you can redistribute it and/or

modify it under the terms of the GNU Lesser General Public

License as published by the Free Software Foundation; either

version 3.0 of the License, or (at your option) any later version.

This library is distributed in the hope that it will be useful,

but WITHOUT ANY WARRANTY; without even the implied warranty of

MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.

See the GNU Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public

License along with this library.

*/

#include <iostream>

#include <vector>

#include <string>

#include <sys/socket.h>

#include <sys/types.h>

#include <baseproxy.hpp>

#include <lrproxy.hpp>

SimpleLRProxy::SimpleLRProxy(baseCom* c) : baseProxy(c) {

}

void SimpleLRProxy::on_left_bytes(baseHostCX* left) {

_deb("LRProxy::on_left_bytes[%d]",left->socket());

for(auto j: right_sockets) {

//move from left read buffer -> right write buffer

_deb("LRProxy::on_left_bytes[%d]: copying into socket %d, size %d", left->socket(), j->socket(), left->readbuf()->size());

j->to_write(left->to_read());

}

for(auto j : right_pc_cx) {

_deb("LRProxy::on_left_bytes[%d]: copying into pc socket %d, size %d", left->socket(), j->socket(), left->readbuf()->size());

//move from left read buffer -> right write buffer

j->to_write(left->to_read());

}

// move away copied data from left read buffer -> they were processed and now even copied to another side

left->finish();

}

void SimpleLRProxy::on_right_bytes(baseHostCX* right) {

_deb("LRProxy::on_right_bytes[%d]",right->socket());

for(auto j : left_sockets) {

// move from right read buffer -> left write buffer

_deb("LRProxy::on_right_bytes[%d]: copying into socket %d, size %d", right->socket(), j->socket(), right->readbuf()->size());

j->to_write(right->to_read());

}

for(auto j : left_pc_cx) {

// move from right read buffer -> left write buffer

_deb("LRProxy::on_right_bytes[%d]: copying into pc socket %d, size %d", right->socket(), j->socket(), right->readbuf()->size());

j->to_write(right->to_read());

}

// move away copied data from left read buffer -> they were processed and now even copied to another side

right->finish();

}