Fix connection ID issue in Obex lib
ConnectionID should be consistent in one Obex session.
This commit is contained in:
@@ -169,10 +169,10 @@ public final class ServerOperation implements Operation, BaseStream {
|
|||||||
mHasBody = true;
|
mHasBody = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (requestHeader.mConnectionID != null) {
|
if (mListener.getConnectionId() != -1 && requestHeader.mConnectionID != null) {
|
||||||
mListener.setConnectionId(ObexHelper.convertToLong(requestHeader.mConnectionID));
|
mListener.setConnectionId(ObexHelper.convertToLong(requestHeader.mConnectionID));
|
||||||
} else {
|
} else {
|
||||||
mListener.setConnectionId(0);
|
mListener.setConnectionId(1);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (requestHeader.mAuthResp != null) {
|
if (requestHeader.mAuthResp != null) {
|
||||||
@@ -438,7 +438,7 @@ public final class ServerOperation implements Operation, BaseStream {
|
|||||||
if (body != null) {
|
if (body != null) {
|
||||||
mHasBody = true;
|
mHasBody = true;
|
||||||
}
|
}
|
||||||
if (requestHeader.mConnectionID != null) {
|
if (mListener.getConnectionId() != -1 && requestHeader.mConnectionID != null) {
|
||||||
mListener.setConnectionId(ObexHelper
|
mListener.setConnectionId(ObexHelper
|
||||||
.convertToLong(requestHeader.mConnectionID));
|
.convertToLong(requestHeader.mConnectionID));
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
@@ -283,10 +283,10 @@ public final class ServerSession extends ObexSession implements Runnable {
|
|||||||
|
|
||||||
ObexHelper.updateHeaderSet(request, headers);
|
ObexHelper.updateHeaderSet(request, headers);
|
||||||
|
|
||||||
if (request.mConnectionID != null) {
|
if (mListener.getConnectionId() != -1 && request.mConnectionID != null) {
|
||||||
mListener.setConnectionId(ObexHelper.convertToLong(request.mConnectionID));
|
mListener.setConnectionId(ObexHelper.convertToLong(request.mConnectionID));
|
||||||
} else {
|
} else {
|
||||||
mListener.setConnectionId(-1);
|
mListener.setConnectionId(1);
|
||||||
}
|
}
|
||||||
// the Auth chan is initiated by the server, client sent back the authResp .
|
// the Auth chan is initiated by the server, client sent back the authResp .
|
||||||
if (request.mAuthResp != null) {
|
if (request.mAuthResp != null) {
|
||||||
@@ -405,7 +405,7 @@ public final class ServerSession extends ObexSession implements Runnable {
|
|||||||
ObexHelper.updateHeaderSet(request, headers);
|
ObexHelper.updateHeaderSet(request, headers);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (request.mConnectionID != null) {
|
if (mListener.getConnectionId() != -1 && request.mConnectionID != null) {
|
||||||
mListener.setConnectionId(ObexHelper.convertToLong(request.mConnectionID));
|
mListener.setConnectionId(ObexHelper.convertToLong(request.mConnectionID));
|
||||||
} else {
|
} else {
|
||||||
mListener.setConnectionId(1);
|
mListener.setConnectionId(1);
|
||||||
@@ -527,7 +527,7 @@ public final class ServerSession extends ObexSession implements Runnable {
|
|||||||
ObexHelper.updateHeaderSet(request, headers);
|
ObexHelper.updateHeaderSet(request, headers);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (request.mConnectionID != null) {
|
if (mListener.getConnectionId() != -1 && request.mConnectionID != null) {
|
||||||
mListener.setConnectionId(ObexHelper.convertToLong(request.mConnectionID));
|
mListener.setConnectionId(ObexHelper.convertToLong(request.mConnectionID));
|
||||||
} else {
|
} else {
|
||||||
mListener.setConnectionId(1);
|
mListener.setConnectionId(1);
|
||||||
|
|||||||
Reference in New Issue
Block a user