-
Notifications
You must be signed in to change notification settings - Fork 567
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #748 from gunlee01/develop
Develop
- Loading branch information
Showing
156 changed files
with
7,937 additions
and
1,161 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
33 changes: 33 additions & 0 deletions
33
scouter.agent.java/src/main/java/com/mongodb/async/SingleResultCallback.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,33 @@ | ||
| /* | ||
| * Copyright 2008-present MongoDB, Inc. | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
||
| //for mongo driver 3.8 | ||
| package com.mongodb.async; | ||
|
|
||
| /** | ||
| * An interface to describe the completion of an asynchronous operation. | ||
| * | ||
| * @param <T> the result type | ||
| * @since 3.0 | ||
| */ | ||
| public interface SingleResultCallback<T> { | ||
| /** | ||
| * Called when the operation completes. | ||
| * @param result the result, which may be null. Always null if e is not null. | ||
| * @param t the throwable, or null if the operation completed normally | ||
| */ | ||
| void onResult(T result, Throwable t); | ||
| } |
120 changes: 120 additions & 0 deletions
120
scouter.agent.java/src/main/java/com/mongodb/connection/InternalConnection.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,120 @@ | ||
| /* | ||
| * Copyright (c) 2008-2014 MongoDB, Inc. | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
||
| //for mongo db driver 3.6 | ||
| package com.mongodb.connection; | ||
|
|
||
| import com.mongodb.async.SingleResultCallback; | ||
| import com.mongodb.internal.connection.CommandMessage; | ||
| import com.mongodb.internal.connection.ResponseBuffers; | ||
| import com.mongodb.internal.session.SessionContext; | ||
| import org.bson.ByteBuf; | ||
| import org.bson.codecs.Decoder; | ||
|
|
||
| import java.util.List; | ||
|
|
||
| public interface InternalConnection extends BufferProvider { | ||
|
|
||
| /** | ||
| * Gets the description of this connection. | ||
| * | ||
| * @return the connection description | ||
| */ | ||
| ConnectionDescription getDescription(); | ||
|
|
||
| /** | ||
| * Opens the connection so its ready for use | ||
| */ | ||
| void open(); | ||
|
|
||
| /** | ||
| * Opens the connection so its ready for use | ||
| * | ||
| * @param callback the callback to be called once the connection has been opened | ||
| */ | ||
| void openAsync(SingleResultCallback<Void> callback); | ||
|
|
||
| /** | ||
| * Closes the connection. | ||
| */ | ||
| void close(); | ||
|
|
||
| /** | ||
| * Returns if the connection has been opened | ||
| * | ||
| * @return true if connection has been opened | ||
| */ | ||
| boolean opened(); | ||
|
|
||
| /** | ||
| * Returns the closed state of the connection | ||
| * | ||
| * @return true if connection is closed | ||
| */ | ||
| boolean isClosed(); | ||
|
|
||
| /** | ||
| * Send a command message to the server. | ||
| * | ||
| * @param message the command message to send | ||
| * @param sessionContext the session context | ||
| */ | ||
| <T> T sendAndReceive(CommandMessage message, Decoder<T> decoder, SessionContext sessionContext); | ||
|
|
||
| /** | ||
| * Send a command message to the server. | ||
| * | ||
| * @param message the command message to send | ||
| * @param sessionContext the session context | ||
| * @param callback the callback | ||
| */ | ||
| <T> void sendAndReceiveAsync(CommandMessage message, Decoder<T> decoder, SessionContext sessionContext, | ||
| SingleResultCallback<T> callback); | ||
|
|
||
| /** | ||
| * Send a message to the server. The connection may not make any attempt to validate the integrity of the message. | ||
| * | ||
| * @param byteBuffers the list of byte buffers to send. | ||
| * @param lastRequestId the request id of the last message in byteBuffers | ||
| */ | ||
| void sendMessage(List<ByteBuf> byteBuffers, int lastRequestId); | ||
|
|
||
| /** | ||
| * Receive a response to a sent message from the server. | ||
| * | ||
| * @param responseTo the request id that this message is a response to | ||
| * @return the response | ||
| */ | ||
| ResponseBuffers receiveMessage(int responseTo); | ||
|
|
||
| /** | ||
| * Asynchronously send a message to the server. The connection may not make any attempt to validate the integrity of the message. | ||
| * | ||
| * @param byteBuffers the list of byte buffers to send | ||
| * @param lastRequestId the request id of the last message in byteBuffers | ||
| * @param callback the callback to invoke on completion | ||
| */ | ||
| void sendMessageAsync(List<ByteBuf> byteBuffers, int lastRequestId, SingleResultCallback<Void> callback); | ||
|
|
||
| /** | ||
| * Asynchronously receive a response to a sent message from the server. | ||
| * | ||
| * @param responseTo the request id that this message is a response to | ||
| * @param callback the callback to invoke on completion | ||
| */ | ||
| void receiveMessageAsync(int responseTo, SingleResultCallback<ResponseBuffers> callback); | ||
|
|
||
| } |
Oops, something went wrong.