File tree Expand file tree Collapse file tree 22 files changed +219
-9
lines changed
main/java/io/rsocket/transport/aeron
test/java/io/rsocket/transport/aeron Expand file tree Collapse file tree 22 files changed +219
-9
lines changed Original file line number Diff line number Diff line change @@ -40,4 +40,4 @@ dependencies {
40
40
testRuntimeOnly ' org.junit.jupiter:junit-jupiter-engine'
41
41
}
42
42
43
- description = ' Reactor Netty RSocket transport implementations (TCP, Websocket) '
43
+ description = ' Aeron RSocket transport implementations'
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import io .netty .util .internal .ObjectUtil ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import io .aeron .Aeron ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import io .aeron .ExclusivePublication ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import io .aeron .Aeron ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import io .aeron .Aeron ;
Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright 2015-2018 the original author or authors.
2
+ * Copyright 2015-present the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import io .rsocket .internal .jctools .queues .MpscUnboundedArrayQueue ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import java .util .concurrent .atomic .AtomicInteger ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import static io .rsocket .transport .aeron .Operators .addCapCancellable ;
Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright 2015-2018 the original author or authors.
2
+ * Copyright 2015-present the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import io .aeron .ExclusivePublication ;
Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright 2015-2018 the original author or authors.
2
+ * Copyright 2015-present the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import java .util .concurrent .atomic .AtomicLongFieldUpdater ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import org .agrona .DirectBuffer ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import io .aeron .Aeron ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import io .netty .buffer .ByteBufUtil ;
Original file line number Diff line number Diff line change
1
+ /*
2
+ * Copyright 2015-present the original author or authors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License");
5
+ * you may not use this file except in compliance with the License.
6
+ * You may obtain a copy of the License at
7
+ *
8
+ * http://www.apache.org/licenses/LICENSE-2.0
9
+ *
10
+ * Unless required by applicable law or agreed to in writing, software
11
+ * distributed under the License is distributed on an "AS IS" BASIS,
12
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
+ * See the License for the specific language governing permissions and
14
+ * limitations under the License.
15
+ */
1
16
package io .rsocket .transport .aeron ;
2
17
3
18
import io .netty .buffer .AbstractByteBuf ;
Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright 2015-2018 the original author or authors.
2
+ * Copyright 2015-present the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
14
14
* limitations under the License.
15
15
*/
16
16
17
- /** The Netty -based RSocket transport implementations. */
17
+ /** The Aeron -based RSocket transport implementations. */
18
18
@ NonNullApi
19
19
package io .rsocket .transport .aeron ;
20
20
Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright 2015-2018 the original author or authors.
2
+ * Copyright 2015-present the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright 2015-2018 the original author or authors.
2
+ * Copyright 2015-present the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
Original file line number Diff line number Diff line change 1
1
/*
2
- * Copyright 2015-2018 the original author or authors.
2
+ * Copyright 2015-present the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
You can’t perform that action at this time.
0 commit comments