Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP

Loading…

Readded imports that were programmatically removed #135

Closed
wants to merge 1 commit into from

3 participants

@esiegel

Issue 134

@stevegury

See my comment on issue 134.
I leave the pull request open, if someone need the fix in the meantime.

@stevegury

Thank you for your help.

@esiegel

Just doing my part. Typically, how out of sync are your repos?

@stevegury

it depends a lot, but I would say between a few days to a few weeks.
For info: last sync of finagle repo was done 9 days ago.

@mariusae
Owner

It is actually automated. The system was unintentionally down for the last week. In steady state, a sync should never take more than a few hours.

@esiegel

@mariusaeriksen that's good to hear that usually there isn't much of a time gap. Thanks for the info.

@esiegel esiegel closed this
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Commits on Feb 9, 2013
  1. @esiegel
This page is out of date. Refresh to see the latest.
View
4 finagle-mysql/src/main/scala/com/twitter/finagle/mysql/Client.scala
@@ -1,6 +1,10 @@
package com.twitter.finagle.mysql
import com.twitter.finagle.mysql.util.Query
+import com.twitter.finagle.builder.ClientBuilder
+import com.twitter.finagle.mysql.protocol._
+import com.twitter.finagle.ServiceFactory
+import com.twitter.util.Future
object Client {
/**
View
7 finagle-mysql/src/main/scala/com/twitter/finagle/mysql/Codec.scala
@@ -1,8 +1,11 @@
package com.twitter.finagle.mysql
-import com.twitter.finagle.mysql.codec.{PacketFrameDecoder, Endec}
+import com.twitter.finagle._
+import com.twitter.finagle.mysql.codec.{PacketFrameDecoder, Endec}
import com.twitter.finagle.mysql.protocol._
import com.twitter.finagle.mysql.protocol.Capability._
+import com.twitter.util.Future
+import org.jboss.netty.channel.{ChannelPipelineFactory, Channels, Channel}
class MySQL(username: String, password: String, database: Option[String])
extends CodecFactory[Request, Result] {
@@ -82,4 +85,4 @@ class AuthenticationProxy(
loginRes <- service(makeLoginReq(sg))
_ <- acceptLogin(loginRes)
} yield service
-}
+}
View
8 finagle-mysql/src/main/scala/com/twitter/finagle/mysql/Example.scala
@@ -1,3 +1,9 @@
+import com.twitter.conversions.time._
+import com.twitter.util.Try
+import com.twitter.finagle.mysql._
+import com.twitter.finagle.mysql.protocol._
+import com.twitter.util.Future
+import java.net.InetSocketAddress
import java.sql.Date
case class SwimmingRecord(
@@ -132,4 +138,4 @@ object Main {
parseArgs(parsed + ("password" -> value), tail)
case unknown :: tail => parsed
}
-}
+}
View
5 finagle-mysql/src/main/scala/com/twitter/finagle/mysql/codec/Endec.scala
@@ -2,6 +2,9 @@ package com.twitter.finagle.mysql.codec
import com.twitter.finagle.mysql.ClientError
import com.twitter.finagle.mysql.protocol._
+import com.twitter.logging.Logger
+import org.jboss.netty.buffer.{ChannelBuffer, ChannelBuffers}
+import org.jboss.netty.channel._
sealed trait State
case object Idle extends State
@@ -171,4 +174,4 @@ class Endec extends SimpleChannelHandler {
case _ =>
throw new ClientError("Endec: Unexpected state when defragmenting packets.")
}
-}
+}
View
6 finagle-mysql/src/main/scala/com/twitter/finagle/mysql/codec/PacketFrameDecoder.scala
@@ -2,6 +2,10 @@ package com.twitter.finagle.mysql.codec
import com.twitter.finagle.mysql.protocol.{Packet, BufferReader}
import com.twitter.finagle.mysql.util.BufferUtil
+import com.twitter.logging.Logger
+import org.jboss.netty.buffer.ChannelBuffer
+import org.jboss.netty.channel.{Channel, ChannelHandlerContext}
+import org.jboss.netty.handler.codec.frame.FrameDecoder
/**
* Decodes logical MySQL packets that could be fragmented across
@@ -37,4 +41,4 @@ class PacketFrameDecoder extends FrameDecoder {
Packet(length, seq, body)
}
-}
+}
View
2  finagle-mysql/src/main/scala/com/twitter/finagle/mysql/protocol/Buffer.scala
@@ -3,6 +3,8 @@ package com.twitter.finagle.mysql.protocol
import com.twitter.finagle.mysql.ClientError
import java.nio.charset.{Charset => JCharset}
import java.nio.ByteOrder
+import org.jboss.netty.buffer.ChannelBuffer
+import org.jboss.netty.buffer.ChannelBuffers.wrappedBuffer
/**
* The BufferReader and BufferWriter interfaces provide methods for
View
4 finagle-mysql/src/main/scala/com/twitter/finagle/mysql/protocol/Packet.scala
@@ -1,5 +1,7 @@
package com.twitter.finagle.mysql.protocol
+import org.jboss.netty.buffer.ChannelBuffer
+import org.jboss.netty.buffer.ChannelBuffers.wrappedBuffer
/**
* Represents a logical packet received from MySQL.
@@ -37,4 +39,4 @@ object Packet {
def toChannelBuffer(size: Int, seq: Short, body: Array[Byte]): ChannelBuffer =
toChannelBuffer(size, seq, wrappedBuffer(body))
-}
+}
View
1  finagle-mysql/src/main/scala/com/twitter/finagle/mysql/protocol/PreparedStatement.scala
@@ -1,5 +1,6 @@
package com.twitter.finagle.mysql.protocol
+import com.twitter.util.Promise
case class PreparedStatement(statementId: Int, numberOfParams: Int) extends Result {
val statement: Promise[String] = new Promise[String]()
View
6 finagle-mysql/src/main/scala/com/twitter/finagle/mysql/protocol/Request.scala
@@ -1,5 +1,9 @@
package com.twitter.finagle.mysql.protocol
+import com.twitter.logging.Logger
+import org.jboss.netty.buffer.ChannelBuffer
+import org.jboss.netty.buffer.ChannelBuffers.{wrappedBuffer, EMPTY_BUFFER}
+
object Command {
val COM_SLEEP = 0x00.toByte // internal thread state
@@ -179,4 +183,4 @@ case class CloseRequest(ps: PreparedStatement) extends CommandRequest(Command.CO
bw.writeByte(cmd).writeInt(ps.statementId)
bw.toChannelBuffer
}
-}
+}
Something went wrong with that request. Please try again.