Lines Matching refs:Primitive
48 import com.android.im.imps.Primitive.TransactionMode;
66 private LinkedBlockingQueue<Primitive> mSendQueue;
67 private LinkedBlockingQueue<Primitive> mReceiveQueue;
71 private Primitive mKeepAlivePrimitive;
133 mSendQueue = new LinkedBlockingQueue<Primitive>();
134 mReceiveQueue = new LinkedBlockingQueue<Primitive>();
159 Primitive polling = new Primitive(ImpsTags.Polling_Request);
182 public void sendPrimitive(Primitive p) {
184 ImpsLog.log("DataChannel not connected, ignore primitive " + p.getType());
208 public Primitive receivePrimitive() throws InterruptedException {
230 mKeepAlivePrimitive = new Primitive(ImpsTags.KeepAlive_Request);
276 Primitive primitive = mSendQueue.take();
277 if (primitive.getType().equals(ImpsTags.Polling_Request)) {
280 doSendPrimitive(primitive);
295 public void onResponseOk(Primitive response) {
304 * Sends a primitive to the IMPS server through HTTP.
306 * @param p The primitive to send.
308 private void doSendPrimitive(Primitive p) {
330 // primitive might have been sent successfully but failed to
337 // sleep for a while and retry to send the primitive in a new
341 Log.w(ImpsLog.TAG, "Send primitive failed, retry after " + retryDelay + "ms");
358 Log.w(ImpsLog.TAG, "Failed to send primitive after " + MAX_RETRY_COUNT + " retries");
363 private void trySend(Primitive p) throws IOException {
370 "Internal serializer error, primitive: " + p.getType());
439 Primitive response = mParser.parse(in);
