Java Logger类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.telegram.mtproto.log.Logger类的典型用法代码示例。如果您正苦于以下问题：Java Logger类的具体用法？Java Logger怎么用？Java Logger使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Logger类属于org.telegram.mtproto.log包，在下文中一共展示了Logger类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: deserializeBody

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
@Override
public void deserializeBody(InputStream stream, TLContext context) throws IOException {
    if (this.destClass == null) {
        throw new IOException("DestClass not set");
    }
    int count = readInt(stream);
    for (int i = 0; i < count; i++) {
        Logger.d("TLVECTOR", "reading: " + i + " from " + count + " (" + this.items.size() + ")" + " --> " + this.destClass);
        if (this.destClass == Integer.class) {
            this.items.add((T) (Integer) readInt(stream));
        } else if (this.destClass == Long.class) {
            this.items.add((T) (Long) readLong(stream));
        } else if (this.destClass == String.class) {
            this.items.add((T) readTLString(stream));
        } else {
            this.items.add((T) context.deserializeMessage(stream));
        }
        Logger.d("TLVECTOR", "Extracted " + this.items.get(i).toString());
    }
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:21，代码来源:TLVector.java

示例2: run

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
@Override
public void run() {
    setPriority(Thread.MIN_PRIORITY);
    while (!MTProto.this.isClosed) {
        if (Logger.LOG_THREADS) {
            Logger.d(MTProto.this.TAG, "Response Iteration");
        }
        synchronized (MTProto.this.inQueue) {
            if (MTProto.this.inQueue.isEmpty()) {
                try {
                    MTProto.this.inQueue.wait();
                } catch (InterruptedException e) {
                    return;
                }
            }
            if (MTProto.this.inQueue.isEmpty()) {
                continue;
            }
        }
        MTMessage message = MTProto.this.inQueue.poll();
        onMTMessage(message);
        BytesCache.getInstance().put(message.getContent());
    }
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:25，代码来源:MTProto.java

示例3: onChannelBroken

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
@Override
public void onChannelBroken(TcpContext context) {
    if (MTProto.this.isClosed) {
        return;
    }
    int contextId = context.getContextId();
    Logger.d(MTProto.this.TAG, "onChannelBroken (#" + contextId + ")");
    synchronized (MTProto.this.contexts) {
        MTProto.this.contexts.remove(context);
        if (!MTProto.this.connectedContexts.contains(contextId)) {
            if (MTProto.this.contextConnectionId.containsKey(contextId)) {
                MTProto.this.exponentalBackoff.onFailureNoWait();
                MTProto.this.connectionRate.onConnectionFailure(MTProto.this.contextConnectionId.get(contextId));
            }
        }
        MTProto.this.contexts.notifyAll();
    }
    MTProto.this.scheduller.onConnectionDies(context.getContextId());
    requestSchedule();
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:21，代码来源:MTProto.java

示例4: suspendConnectionInternal

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
private void suspendConnectionInternal() {
    synchronized (timerSync) {
        if (reconnectTimer != null) {
            reconnectTimer.cancel();
            reconnectTimer = null;
        }
    }
    if ((connectionState == ConnectionState.TcpConnectionStageIdle) || (connectionState == ConnectionState.TcpConnectionStageSuspended)) {
        return;
    }
    Logger.d(TcpContext.this.TAG, "suspend connnection " + TcpContext.this);
    connectionState = ConnectionState.TcpConnectionStageSuspended;
    if (client != null) {
        client.removeListener(TcpContext.this);
        client.dropConnection();
        client = null;
    }
    callback.onChannelBroken(TcpContext.this);
    isFirstPackage = true;
    if (restOfTheData != null) {
        BuffersStorage.getInstance().reuseFreeBuffer(restOfTheData);
        restOfTheData = null;
    }
    lastPacketLength = 0;
    channelToken = 0;
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:27，代码来源:TcpContext.java

示例5: readString

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
public String readString(boolean exception) {
    try {
        int sl = 1;
        int l = getIntFromByte(this.buffer.get());
        if(l >= 254) {
            l = getIntFromByte(this.buffer.get()) | (getIntFromByte(this.buffer.get()) << 8) | (getIntFromByte(this.buffer.get()) << 16);
            sl = 4;
        }
        final byte[] b = new byte[l];
        this.buffer.get(b);
        int i = sl;
        while(((l + i) % 4) != 0) {
            this.buffer.get();
            i++;
        }
        return new String(b, "UTF-8");
    } catch (Exception e) {
        if (exception) {
            throw new RuntimeException("read string error", e);
        } else {
            Logger.w("tmessages", "read string error");
        }
    }
    return null;
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:26，代码来源:ByteBufferDesc.java

示例6: readByteArray

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
public byte[] readByteArray(boolean exception) {
    try {
        int sl = 1;
        int l = getIntFromByte(this.buffer.get());
        if (l >= 254) {
            l = getIntFromByte(this.buffer.get()) | (getIntFromByte(this.buffer.get()) << 8) | (getIntFromByte(this.buffer.get()) << 16);
            sl = 4;
        }
        final byte[] b = new byte[l];
        this.buffer.get(b);
        int i = sl;
        while(((l + i) % 4) != 0) {
            this.buffer.get();
            i++;
        }
        return b;
    } catch (Exception e) {
        if (exception) {
            throw new RuntimeException("read byte array error", e);
        } else {
            Logger.w("tmessages", "read byte array error");
        }
    }
    return null;
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:26，代码来源:ByteBufferDesc.java

示例7: run

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
@Override
public void run() {
    setPriority(Thread.MIN_PRIORITY);
    while (!isClosed) {
        if (Logger.LOG_THREADS) {
            Logger.d(TAG, "Response Iteration");
        }
        synchronized (inQueue) {
            if (inQueue.isEmpty()) {
                try {
                    inQueue.wait();
                } catch (InterruptedException e) {
                    return;
                }
            }
            if (inQueue.isEmpty()) {
                continue;
            }
        }
        MTMessage message = inQueue.poll();
        onMTMessage(message);
        BytesCache.getInstance().put(message.getContent());
    }
}

开发者ID:ardock，项目名称:telegram-mt，代码行数:25，代码来源:MTProto.java

示例8: onChannelBroken

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
@Override
public void onChannelBroken(TcpContext context) {
    if (isClosed) {
        return;
    }
    int contextId = context.getContextId();
    Logger.d(TAG, "onChannelBroken (#" + contextId + ")");
    synchronized (contexts) {
        contexts.remove(context);
        if (!connectedContexts.contains(contextId)) {
            if (contextConnectionId.containsKey(contextId)) {
                exponentalBackoff.onFailureNoWait();
                connectionRate.onConnectionFailure(contextConnectionId.get(contextId));
            }
        }
        contexts.notifyAll();
    }
    scheduller.onConnectionDies(context.getContextId());
    requestSchedule();
}

开发者ID:ardock，项目名称:telegram-mt，代码行数:21，代码来源:MTProto.java

示例9: readBytes

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
private byte[] readBytes(int count, int timeout, InputStream stream) throws IOException {
    byte[] res = BytesCache.getInstance().allocate(count);
    int offset = 0;
    long start = System.nanoTime();
    while (offset < count) {
        int readed = stream.read(res, offset, count - offset);
        Thread.yield();
        if (readed > 0) {
            offset += readed;
            onRead();
        } else if (readed < 0) {
            throw new IOException();
        } else {
            if (System.nanoTime() - start > timeout * 1000000L) {
                throw new IOException();
            }
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                Logger.e(TAG, e);
                throw new IOException();
            }
        }
    }
    return res;
}

开发者ID:ardock，项目名称:telegram-mt，代码行数:27，代码来源:TcpContext.java

示例10: registerClass

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
public <T extends TLObject> void registerClass(Class<T> tClass) {
    try {
        int classId = tClass.getField("CLASS_ID").getInt(null);
        this.registeredClasses.put(classId, tClass);
    } catch (IllegalAccessException | NoSuchFieldException e) {
        e.printStackTrace();
        Logger.e(TAG, e);
    }
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:10，代码来源:TLContext.java

示例11: registerCompatClass

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
public <T extends TLObject> void registerCompatClass(Class<T> tClass) {
    try {
        int classId = tClass.getField("CLASS_ID").getInt(null);
        this.registeredCompatClasses.put(classId, tClass);
    } catch (IllegalAccessException | NoSuchFieldException e) {
        e.printStackTrace();
        Logger.e(TAG, e);
    }
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:10，代码来源:TLContext.java

示例12: skipBytes

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
/**
 * Reading bytes from stream
 *
 * @param count  bytes count
 * @param stream source stream
 * @return readed bytes
 * @throws IOException reading exception
 */
//public static void skipBytes(int count, InputStream stream) throws IOException {
//    stream.skip(count);
//}

public static void skipBytes(int count, InputStream stream) throws IOException {
    byte[] bytes = new byte[count];
    stream.read(bytes);
    Logger.d("SKIPED", "Skypped " + count + " bytes: " + bytes);
    //stream.skip(count);
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:19，代码来源:StreamingUtils.java

示例13: resendAsNewMessageDelayed

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
public void resendAsNewMessageDelayed(long msgId, long delay) {
    for (SchedullerPackage schedullerPackage : this.messages.values().toArray(new SchedullerPackage[0])) {
        if (schedullerPackage.relatedMessageIds.contains(msgId)) {
            schedullerPackage.idGenerationTime = 0;
            schedullerPackage.dependMessageId = 0;
            schedullerPackage.messageId = 0;
            schedullerPackage.seqNo = 0;
            schedullerPackage.state = STATE_QUEUED;
            schedullerPackage.scheduleTime = getCurrentTime() + delay;
            Logger.d(this.TAG, "Resending as new #" + schedullerPackage.id);
        }
    }
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:14，代码来源:Scheduller.java

示例14: onConnectionDies

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
public synchronized void onConnectionDies(int connectionId) {
    Logger.d(this.TAG, "Connection dies " + connectionId);
    for (SchedullerPackage schedullerPackage : this.messages.values().toArray(new SchedullerPackage[0])) {
        if (schedullerPackage.writtenToChannel != connectionId) {
            continue;
        }

        if (schedullerPackage.queuedToChannel != -1) {
            Logger.d(this.TAG, "Removing: #" + schedullerPackage.id + " " + schedullerPackage.supportTag);
            forgetMessage(schedullerPackage.id);
        } else {
            if (schedullerPackage.isRpc) {
                if (schedullerPackage.state == STATE_CONFIRMED || schedullerPackage.state == STATE_QUEUED) {
                    Logger.d(this.TAG, "Re-schedule: #" + schedullerPackage.id + " " + schedullerPackage.supportTag);
                    schedullerPackage.state = STATE_QUEUED;
                    schedullerPackage.lastAttemptTime = 0;
                }
            } else {
                if (schedullerPackage.state == STATE_SENT) {
                    Logger.d(this.TAG, "Re-schedule: #" + schedullerPackage.id + " " + schedullerPackage.supportTag);
                    schedullerPackage.state = STATE_QUEUED;
                    schedullerPackage.lastAttemptTime = 0;
                }
            }

        }
    }
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:29，代码来源:Scheduller.java

示例15: sendMessage

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
public int sendMessage(TLObject request, long timeout, boolean isRpc, boolean highPriority) {
    final int id = this.scheduller.postMessage(request, isRpc, timeout, highPriority);
    Logger.d(this.TAG, "sendMessage #" + id + " " + request.toString());
    synchronized (this.scheduller) {
        this.scheduller.notifyAll();
    }

    return id;
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:10，代码来源:MTProto.java

示例16: onError

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
@Override
public void onError(int errorCode, TcpContext context) {
    if (MTProto.this.isClosed) {
        return;
    }

    Logger.e(MTProto.this.TAG, "OnError (#" + context.getContextId() + "): " + errorCode);
    context.suspendConnection(true);
    context.connect();
    // Fully maintained at transport level: TcpContext dies
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:12，代码来源:MTProto.java

示例17: tryConnection

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
public synchronized ConnectionType tryConnection() {
    float value = this.rnd.nextFloat();
    Transport[] currentTransports = this.transports.values().toArray(new Transport[0]);
    Arrays.sort(currentTransports, new Comparator<Transport>() {
        @Override
        public int compare(Transport transport, Transport transport2) {
            return -Float.compare(transport.getRate(), transport2.getRate());
        }
    });
    ConnectionType type = currentTransports[0].getConnectionType();
    Logger.d(TAG, "tryConnection #" + type.getId());
    return type;
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:14，代码来源:TransportRate.java

示例18: destroy

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
public void destroy() {
    try {
        this.socket.close();
    } catch (IOException e) {
        Logger.e(TAG, e);
    }
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:8，代码来源:PlainTcpConnection.java

示例19: receivedData

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
@Override
public void receivedData(PyroClient client, ByteBuffer data) {
    try {
        failedConnectionCount = 0;
        readData(data);
    } catch (Exception e) {
        Logger.e(TcpContext.this.TAG, e);
        reconnect();
    }
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:11，代码来源:TcpContext.java

示例20: reuseFreeBuffer

import org.telegram.mtproto.log.Logger; //导入依赖的package包/类
public void reuseFreeBuffer(ByteBufferDesc buffer) {
    if (buffer == null) {
        return;
    }
    int maxCount = 10;
    ArrayList<ByteBufferDesc> arrayToReuse = null;
    if (buffer.buffer.capacity() == 128) {
        arrayToReuse = freeBuffers128;
    } else if (buffer.buffer.capacity() == 1024 + 200) {
        arrayToReuse = freeBuffers1024;
    } if (buffer.buffer.capacity() == 4096 + 200) {
        arrayToReuse = freeBuffers4096;
    } else if (buffer.buffer.capacity() == 16384 + 200) {
        arrayToReuse = freeBuffers16384;
    } else if (buffer.buffer.capacity() == 40000) {
        arrayToReuse = freeBuffers32768;
    } else if (buffer.buffer.capacity() == 280000) {
        arrayToReuse = freeBuffersBig;
        maxCount = 10;
    }
    if (arrayToReuse != null) {
        if (isThreadSafe) {
            synchronized (sync) {
                if (arrayToReuse.size() < maxCount) {
                    arrayToReuse.add(buffer);
                } else {
                    Logger.w("tmessages", "too more");
                }
            }
        } else {
            if (arrayToReuse.size() < maxCount) {
                arrayToReuse.add(buffer);
            }
        }
    }
}

开发者ID:rubenlagus，项目名称:TelegramApi，代码行数:37，代码来源:BuffersStorage.java

注：本文中的org.telegram.mtproto.log.Logger类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java ClientCacheEntryCreated类代码示例发布时间：2022-05-22

Java MessageObserver类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18263|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9676|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8177|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8548|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8456|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9388|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8427|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7862|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8411|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java Logger类代码示例

示例1: deserializeBody

示例2: run

示例3: onChannelBroken

示例4: suspendConnectionInternal

示例5: readString

示例6: readByteArray

示例7: run

示例8: onChannelBroken

示例9: readBytes

示例10: registerClass

示例11: registerCompatClass

示例12: skipBytes

示例13: resendAsNewMessageDelayed

示例14: onConnectionDies

示例15: sendMessage

示例16: onError

示例17: tryConnection

示例18: destroy

示例19: receivedData

示例20: reuseFreeBuffer

请发表评论

全部评论

上一篇：

下一篇：

creativetimofficial/material-dashboard-r

CVE-2022-30517

pngwn/MDsveX: A markdown preprocessor fo

kubernetes/examples: Kubernetes applicat

中国4a广告公司100强图谱

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053