Package common.connection

Examples of common.connection.ConnectionWriterInterface

159
160
161
162
163
164
165
166
167
168
169
  public void sendSearchResults(final int cookie, final Object results)
  {
    int protocolId = ClientServerProtocol.PROTOCOL_FILES;
    int opcode = ClientServerProtocol.Files.OP_RESULTS;
    send(protocolId, opcode, new ConnectionWriterInterface()
    {
      public void run(ObjectOutputStream os) throws IOException
      {
        os.writeInt(cookie);
        os.writeObject(results);
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
  public void requestFile()
  {
    int protocolId = PeerProtocol.PROTOCOL_TRANSFER;
    int opcode = PeerProtocol.Transfer.OP_REQUEST_FILE;
    send(protocolId, opcode, new ConnectionWriterInterface()
    {
      public void run(ObjectOutputStream os) throws IOException
      {
        os.writeObject(download.getFile());
        os.writeLong(download.getCompletedSize());
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
  {
    ServerConnection serverConnection = getConnectionManager().getConnection();

    int protocolId = ClientServerProtocol.PROTOCOL_FILES;
    int opcode = ClientServerProtocol.Files.OP_KEYWORDS;
    serverConnection.send(protocolId, opcode, new ConnectionWriterInterface()
    {
      public void run(ObjectOutputStream os) throws IOException
      {
        os.writeInt(getId());
        os.writeObject(keywords);
View Full Code Here
39
40
41
42
43
44
45
46
47
48
49
  public void query(ServerConnection serverConnection)
  {
    int protocolId = ClientServerProtocol.PROTOCOL_FILES;
    int opcode = ClientServerProtocol.Files.OP_GET_INFO;
    serverConnection.sendOverlapped(protocolId, opcode,
        new ConnectionWriterInterface()
        {
          public void run(ObjectOutputStream os) throws IOException
          {
            os.writeObject(file);
          }
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
  {
    upload.setCompletedSize(offset);

    int protocolId = PeerProtocol.PROTOCOL_TRANSFER;
    int opcode = PeerProtocol.Transfer.OP_FILE;
    send(protocolId, opcode, new ConnectionWriterInterface()
    {
      public void run(ObjectOutputStream os) throws IOException
      {
        upload.transfer(fis, os);
      }
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
  public void setPort() throws IOException
  {
    int protocolId = ClientServerProtocol.PROTOCOL_LINK;
    int opcode = ClientServerProtocol.Link.OP_SET_PORT;
    sendOverlapped(protocolId, opcode, new ConnectionWriterInterface()
    {
      public void run(ObjectOutputStream os) throws IOException
      {
        os.writeInt(Settings.connection.port);
      }
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
  public void setNickName() throws IOException
  {
    int protocolId = ClientServerProtocol.PROTOCOL_NAMING;
    int opcode = ClientServerProtocol.Naming.OP_SET_NAME;
    sendOverlapped(protocolId, opcode, new ConnectionWriterInterface()
    {
      public void run(ObjectOutputStream os) throws IOException
      {
        os.writeUTF(Settings.application.nickname);
      }
View Full Code Here
TOP

Related Classes of common.connection.ConnectionWriterInterface

  • chat.connection.AbstractChatConnection
  • chat.PrivateChatSession
  • connection.ClientConnection
  • connection.server.ServerConnection
  • handlers.server.files.KeywordsHandler
  • search.SearchRequest
  • share.ServerUpdater
  • share.SharedFilesTable
  • transfer.download.DownloadRequest
  • transfer.download.FileDownload
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.